feat: Solana Vault Swaps Elections

engine/Cargo.toml

@@ -20,6 +20,11 @@ async-channel = "1.7.1"
 async-trait = "0.1.49"
 bincode = "1.3.3"
 bitcoin = { version = "0.30.0", features = ["serde"] }
+borsh = { version = "1.2.1", default_features = false, features = [
+  "derive",
+  "unstable__schema",
+  "hashbrown",
+] }
 chrono = { version = "0.4.21", default_features = false, features = ["clock"] }
 clap = { version = "3.2.16", features = ["derive", "env"] }
 config = "0.13.1"

engine/src/elections/voter_api.rs

@@ -66,4 +66,4 @@ macro_rules! generate_voter_api_tuple_impls {
     }
 }
 
-generate_voter_api_tuple_impls!(tuple_5_impls: ((A, A0), (B, B0), (C, C0), (D, D0), (EE, E0)));
+generate_voter_api_tuple_impls!(tuple_6_impls: ((A, A0), (B, B0), (C, C0), (D, D0), (EE, E0), (FF,F0)));

engine/src/witness/sol.rs

@@ -1,6 +1,7 @@
 mod egress_witnessing;
 mod fee_tracking;
 mod nonce_witnessing;
+mod program_swaps_witnessing;
 mod sol_deposits;
 
 use crate::{
@@ -20,7 +21,8 @@ use pallet_cf_elections::{electoral_system::ElectoralSystem, vote_storage::VoteS
 use state_chain_runtime::{
 	chainflip::solana_elections::{
 		SolanaBlockHeightTracking, SolanaEgressWitnessing, SolanaElectoralSystem,
-		SolanaFeeTracking, SolanaIngressTracking, SolanaNonceTracking, TransactionSuccessDetails,
+		SolanaFeeTracking, SolanaIngressTracking, SolanaNonceTracking, SolanaVaultSwapTracking,
+		TransactionSuccessDetails,
 	},
 	SolanaInstance,
 };
@@ -140,6 +142,26 @@ impl VoterApi<SolanaEgressWitnessing> for SolanaEgressWitnessingVoter {
 	}
 }
 
+#[allow(dead_code)]
+#[derive(Clone)]
+struct SolanaVaultSwapsVoter {
+	client: SolRetryRpcClient,
+}
+
+#[async_trait::async_trait]
+impl VoterApi<SolanaVaultSwapTracking> for SolanaVaultSwapsVoter {
+	async fn vote(
+		&self,
+		_settings: <SolanaVaultSwapTracking as ElectoralSystem>::ElectoralSettings,
+		_properties: <SolanaVaultSwapTracking as ElectoralSystem>::ElectionProperties,
+	) -> Result<
+		<<SolanaVaultSwapTracking as ElectoralSystem>::Vote as VoteStorage>::Vote,
+		anyhow::Error,
+	> {
+		todo!()
+	}
+}
+
 pub async fn start<StateChainClient>(
 	scope: &Scope<'_, anyhow::Error>,
 	client: SolRetryRpcClient,
@@ -165,7 +187,8 @@ where
 						SolanaFeeTrackingVoter { client: client.clone() },
 						SolanaIngressTrackingVoter { client: client.clone() },
 						SolanaNonceTrackingVoter { client: client.clone() },
-						SolanaEgressWitnessingVoter { client },
+						SolanaEgressWitnessingVoter { client: client.clone() },
+						SolanaVaultSwapsVoter { client },
 					)),
 				)
 				.continuously_vote()