add upsert-permissioned-candidates smart-contracts node command

Cargo.toml

@@ -112,6 +112,7 @@ inquire = { version = "0.7.5" }
 parking_lot = { version = "0.12.3", default-features = false }
 envy = { version = "0.4.2" }
 log4rs = { version = "1.3.0" }
+csv = { version = "1.3.1" }
 
 # substrate dependencies
 frame-benchmarking = { default-features = false, git = "https://github.com/paritytech/polkadot-sdk.git", tag = "polkadot-stable2409" }

toolkit/cli/smart-contracts-commands/Cargo.toml

@@ -15,6 +15,7 @@ tokio = { workspace = true }
 serde = { workspace = true }
 serde_json = { workspace = true }
 cardano-serialization-lib = { workspace = true }
+csv = { workspace = true}
 
 [dev-dependencies]
 hex-literal = { workspace = true }

toolkit/cli/smart-contracts-commands/src/lib.rs

@@ -3,6 +3,7 @@ use sidechain_domain::*;
 pub mod d_parameter;
 pub mod get_scripts;
 pub mod governance;
+pub mod permissioned_candidates;
 pub mod register;
 pub mod reserve;
 
@@ -13,6 +14,8 @@ pub enum SmartContractsCmd {
 	GetScripts(get_scripts::GetScripts),
 	/// Upsert DParameter
 	UpsertDParameter(d_parameter::UpsertDParameterCmd),
+	/// Upsert Permissioned Candidates
+	UpsertPermissionedCandidates(permissioned_candidates::UpsertPermissionedCandidatesCmd),
 	/// Register candidate
 	Register(register::RegisterCmd),
 	/// Deregister candidate
@@ -40,6 +43,7 @@ impl SmartContractsCmd {
 			Self::Governance(cmd) => cmd.execute().await,
 			Self::GetScripts(cmd) => cmd.execute().await,
 			Self::UpsertDParameter(cmd) => cmd.execute().await,
+			Self::UpsertPermissionedCandidates(cmd) => cmd.execute().await,
 			Self::Register(cmd) => cmd.execute().await,
 			Self::Deregister(cmd) => cmd.execute().await,
 			Self::Reserve(cmd) => cmd.execute().await,

toolkit/cli/smart-contracts-commands/src/permissioned_candidates.rs

@@ -0,0 +1,64 @@
+use crate::PaymentFilePath;
+use ogmios_client::jsonrpsee::client_for_url;
+use partner_chains_cardano_offchain::await_tx::FixedDelayRetries;
+use partner_chains_cardano_offchain::permissioned_candidates::upsert_permissioned_candidates;
+use sidechain_domain::UtxoId;
+use sidechain_domain::AuraPublicKey;
+use sidechain_domain::GrandpaPublicKey;
+use sidechain_domain::PermissionedCandidateData;
+use sidechain_domain::SidechainPublicKey;
+
+#[derive(Clone, Debug, clap::Parser)]
+pub struct UpsertPermissionedCandidatesCmd {
+	#[clap(flatten)]
+	common_arguments: crate::CommonArguments,
+	#[arg(long)]
+	permissioned_candidates_file: String,
+	#[clap(flatten)]
+	payment_key_file: PaymentFilePath,
+	#[arg(long, short('c'))]
+	genesis_utxo: UtxoId,
+}
+
+impl UpsertPermissionedCandidatesCmd {
+	pub async fn execute(self) -> crate::CmdResult<()> {
+		let payment_key = self.payment_key_file.read_key()?;
+
+		let mut reader = csv::ReaderBuilder::new()
+			.delimiter(b':')
+			.from_path(&self.permissioned_candidates_file)?;
+
+		let mut permissioned_candidates = Vec::new();
+
+		for result in reader.records() {
+			let record = result?;
+
+			let permissioned_candidate = PermissionedCandidateData {
+				sidechain_public_key: SidechainPublicKey::from_hex_unsafe(
+					record.get(0).unwrap().to_string().as_str(),
+				),
+				aura_public_key: AuraPublicKey::from_hex_unsafe(
+					record.get(1).unwrap().to_string().as_str(),
+				),
+				grandpa_public_key: GrandpaPublicKey::from_hex_unsafe(
+					record.get(2).unwrap().to_string().as_str(),
+				),
+			};
+
+			permissioned_candidates.push(permissioned_candidate);
+		}
+
+		let client = client_for_url(&self.common_arguments.ogmios_url).await?;
+
+		upsert_permissioned_candidates(
+			self.genesis_utxo,
+			&permissioned_candidates,
+			payment_key.0,
+			&client,
+            &FixedDelayRetries::two_minutes(),
+		)
+		.await?;
+
+		Ok(())
+	}
+}