feat: protocol config (#986)

Conceptual Changes:
- foresters need to be registered with `forester_account`s
- foresters need to register to epochs to forest

Changes:
- refactor registry program folder structure
  - moved everything from the decentralization and contention prevention test into the program
  - selection is not used yet
  - claim functionality is not implemented yet

Note:
- security and failing tests are not implemented yet
- rewards are not implemented yet
- implementation is insecure, security checks are missing
- leaving `msg!` prints in registry program for now for debugging

Author: ananas-block

Cargo.lock

@@ -0,0 +1 @@
+{"pubkey":"C388ZXSoy5p9uQUpPAtFoJHwcYhts2Xu2ArWNJUgYyji","account":{"lamports":1781760,"data":["QuAuAqeJeGsAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAMqaOwAAAAACAAAAAAAAAADKmjsAAAAAZAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAQAAAAAAAAA=","base64"],"owner":"7Z9Yuy3HkBCc2Wf3xzMGnz6qpV4n7ciwcoEMGKqhAnj1","executable":false,"rentEpoch":18446744073709551615,"space":128}}

cli/accounts/epoch_pda_C388ZXSoy5p9uQUpPAtFoJHwcYhts2Xu2ArWNJUgYyji.json

@@ -0,0 +1 @@
+{"pubkey":"5Tpw5vUpnXzSKgGpEGHuxMRFtTz6Gt6hozVqu8e5fiqt","account":{"lamports":2345520,"data":["HXXTjWOP+nLMuMIVdedaPnWzorVHJCIvMcPXWnMDRUrSS6K/PzOqzAAAAAAAAAAAAAAAAAAAAAABAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAgAAAAAAAAABAQAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAADKmjsAAAAAAgAAAAAAAAAAypo7AAAAAGQAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAABAAAAAAAAAAAAAAAAAAA=","base64"],"owner":"7Z9Yuy3HkBCc2Wf3xzMGnz6qpV4n7ciwcoEMGKqhAnj1","executable":false,"rentEpoch":18446744073709551615,"space":209}}

cli/accounts/forester_epoch_pda_5Tpw5vUpnXzSKgGpEGHuxMRFtTz6Gt6hozVqu8e5fiqt.json

@@ -1 +1 @@
-{"pubkey":"8KEKiyAMugpKq9XCGzx81UtTBuytByW8arm9EaBVpD5k","account":{"lamports":1670400,"data":["92V2ansKL5ECY+L7WEJcIRnY07lwy9TuaZBIebD9aqhznpq8Pv+mUf0AAAAAAAAAAP//////////AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA==","base64"],"owner":"7Z9Yuy3HkBCc2Wf3xzMGnz6qpV4n7ciwcoEMGKqhAnj1","executable":false,"rentEpoch":18446744073709551615,"space":112}}
+{"pubkey":"8KEKiyAMugpKq9XCGzx81UtTBuytByW8arm9EaBVpD5k","account":{"lamports":1844400,"data":["YLDvkgH+Y5ICY+L7WEJcIRnY07lwy9TuaZBIebD9aqhznpq8Pv+mUf0AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAADKmjsAAAAAAgAAAAAAAAAAypo7AAAAAGQAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA=","base64"],"owner":"7Z9Yuy3HkBCc2Wf3xzMGnz6qpV4n7ciwcoEMGKqhAnj1","executable":false,"rentEpoch":18446744073709551615,"space":137}}

cli/accounts/governance_authority_pda_8KEKiyAMugpKq9XCGzx81UtTBuytByW8arm9EaBVpD5k.json

@@ -0,0 +1 @@
+{"pubkey":"BqDEaVeLffn32a2EnsmvFFmGK4ZZgqYrDkAxpGXc1ogj","account":{"lamports":1670400,"data":["BesVNs5W82rMuMIVdedaPnWzorVHJCIvMcPXWnMDRUrSS6K/PzOqzAAAAAAAAAAAAQAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA==","base64"],"owner":"7Z9Yuy3HkBCc2Wf3xzMGnz6qpV4n7ciwcoEMGKqhAnj1","executable":false,"rentEpoch":18446744073709551615,"space":112}}

cli/accounts/registered_forester_epoch_pda_DFiGEbaz75wSdqy9bpeWacqLWrqAwWBfqh4iSYtejiwK.json

@@ -108,8 +108,7 @@ async fn test_escrow_with_compressed_pda() {
     let rpc_error = RpcError::TransactionError(transaction_error);
     assert!(matches!(result, Err(error) if error.to_string() == rpc_error.to_string()));
 
-    rpc.warp_to_slot(lock_up_time + 1).unwrap();
-
+    rpc.warp_to_slot(lockup_end + 1).unwrap();
     perform_withdrawal_with_event(
         &mut rpc,
         &mut test_indexer,

cli/accounts/registered_forester_pda_BqDEaVeLffn32a2EnsmvFFmGK4ZZgqYrDkAxpGXc1ogj.json

@@ -8,7 +8,8 @@ use crate::{ForesterConfig, RpcPool};
 use account_compression::utils::constants::{
     ADDRESS_MERKLE_TREE_CHANGELOG, ADDRESS_MERKLE_TREE_INDEXED_CHANGELOG,
 };
-use light_registry::sdk::{
+
+use light_registry::account_compression_cpi::sdk::{
     create_update_address_merkle_tree_instruction, UpdateAddressMerkleTreeInstructionInputs,
 };
 use light_test_utils::indexer::Indexer;
@@ -268,8 +269,8 @@ pub async fn update_merkle_tree<R: RpcConnection>(
 ) -> Result<bool, ForesterError> {
     let start = Instant::now();
 
-    let update_ix =
-        create_update_address_merkle_tree_instruction(UpdateAddressMerkleTreeInstructionInputs {
+    let update_ix = create_update_address_merkle_tree_instruction(
+        UpdateAddressMerkleTreeInstructionInputs {
             authority: config.payer_keypair.pubkey(),
             address_merkle_tree: tree_data.tree_pubkey,
             address_queue: tree_data.queue_pubkey,
@@ -283,7 +284,9 @@ pub async fn update_merkle_tree<R: RpcConnection>(
             indexed_changelog_index: ((account_data.proof.root_seq - 1)
                 % ADDRESS_MERKLE_TREE_INDEXED_CHANGELOG)
                 as u16,
-        });
+        },
+        0, // TODO: add correct epoch
+    );
 
     // Prepare the instructions
     let instructions = vec![

examples/token-escrow/programs/token-escrow/tests/test_compressed_pda.rs

@@ -5,7 +5,9 @@ use crate::operations::fetch_state_queue_data;
 use crate::tree_sync::TreeData;
 use crate::{ForesterConfig, RpcPool};
 use account_compression::utils::constants::STATE_MERKLE_TREE_CHANGELOG;
-use light_registry::sdk::{create_nullify_instruction, CreateNullifyInstructionInputs};
+use light_registry::account_compression_cpi::sdk::{
+    create_nullify_instruction, CreateNullifyInstructionInputs,
+};
 use light_test_utils::indexer::Indexer;
 use light_test_utils::rpc::rpc_connection::RpcConnection;
 use log::{debug, error, info, warn};
@@ -276,16 +278,19 @@ async fn nullify_state<R: RpcConnection>(
     let change_log_index = root_seq % STATE_MERKLE_TREE_CHANGELOG;
     debug!("change_log_index: {:?}", change_log_index);
 
-    let ix = create_nullify_instruction(CreateNullifyInstructionInputs {
-        nullifier_queue: tree_data.queue_pubkey,
-        merkle_tree: tree_data.tree_pubkey,
-        change_log_indices: vec![change_log_index],
-        leaves_queue_indices: vec![leaves_queue_index],
-        indices: vec![leaf_index],
-        proofs: vec![proof],
-        authority: payer.pubkey(),
-        derivation: Pubkey::from_str(&config.external_services.derivation).unwrap(),
-    });
+    let ix = create_nullify_instruction(
+        CreateNullifyInstructionInputs {
+            nullifier_queue: tree_data.queue_pubkey,
+            merkle_tree: tree_data.tree_pubkey,
+            change_log_indices: vec![change_log_index],
+            leaves_queue_indices: vec![leaves_queue_index],
+            indices: vec![leaf_index],
+            proofs: vec![proof],
+            authority: payer.pubkey(),
+            derivation: Pubkey::from_str(&config.external_services.derivation).unwrap(),
+        },
+        0,
+    );
 
     let instructions = vec![
         ComputeBudgetInstruction::set_compute_unit_limit(config.cu_limit),

forester/src/nullifier/address/processor.rs

@@ -2,6 +2,10 @@ use std::ops::DerefMut;
 use std::sync::Arc;
 
 use anchor_lang::{system_program, InstructionData, ToAccountMetas};
+use light_registry::account_compression_cpi::sdk::{
+    create_rollover_address_merkle_tree_instruction, create_rollover_state_merkle_tree_instruction,
+    CreateRolloverMerkleTreeInstructionInputs,
+};
 use log::info;
 use solana_sdk::instruction::Instruction;
 use solana_sdk::pubkey::Pubkey;
@@ -19,10 +23,6 @@ use account_compression::{
 };
 use light_hasher::Poseidon;
 use light_merkle_tree_reference::MerkleTree;
-use light_registry::sdk::{
-    create_rollover_address_merkle_tree_instruction, create_rollover_state_merkle_tree_instruction,
-    CreateRolloverMerkleTreeInstructionInputs,
-};
 use light_test_utils::address_merkle_tree_config::{
     get_address_bundle_config, get_state_bundle_config,
 };
@@ -320,6 +320,7 @@ pub async fn create_rollover_address_merkle_tree_instructions<R: RpcConnection>(
             old_queue: *nullifier_queue_pubkey,
             old_merkle_tree: *merkle_tree_pubkey,
         },
+        0, // TODO: make epoch dynamic
     );
     vec![
         create_nullifier_queue_instruction,
@@ -368,14 +369,16 @@ pub async fn create_rollover_state_merkle_tree_instructions<R: RpcConnection>(
         &account_compression::ID,
         Some(new_state_merkle_tree_keypair),
     );
-    let instruction =
-        create_rollover_state_merkle_tree_instruction(CreateRolloverMerkleTreeInstructionInputs {
+    let instruction = create_rollover_state_merkle_tree_instruction(
+        CreateRolloverMerkleTreeInstructionInputs {
             authority: *authority,
             new_queue: new_nullifier_queue_keypair.pubkey(),
             new_merkle_tree: new_state_merkle_tree_keypair.pubkey(),
             old_queue: *nullifier_queue_pubkey,
             old_merkle_tree: *merkle_tree_pubkey,
-        });
+        },
+        0, // TODO: make epoch dynamic
+    );
     vec![
         create_nullifier_queue_instruction,
         create_state_merkle_tree_instruction,