Add open_btc_deposit_channels method to broker api.

api/bin/chainflip-broker-api/src/main.rs

@@ -9,9 +9,10 @@ use chainflip_api::{
 	primitives::{AccountRole, Affiliates, Asset, BasisPoints, CcmChannelMetadata, DcaParameters},
 	settings::StateChain,
 	AccountId32, AddressString, BrokerApi, DepositMonitorApi, OperatorApi, RefundParameters,
-	StateChainApi, SwapDepositAddress, SwapPayload, WithdrawFeesDetail,
+	SignedExtrinsicApi, StateChainApi, SwapDepositAddress, SwapPayload, WithdrawFeesDetail,
 };
 use clap::Parser;
+use custom_rpc::CustomApiClient;
 use futures::FutureExt;
 use jsonrpsee::{
 	core::{async_trait, ClientError},
@@ -103,6 +104,11 @@ pub trait Rpc {
 
 	#[method(name = "mark_btc_transaction_as_tainted", aliases = ["broker_markBtcTransactionAsTainted"])]
 	async fn mark_btc_transaction_as_tainted(&self, tx_id: cf_chains::btc::Hash) -> RpcResult<()>;
+
+	#[method(name = "open_btc_deposit_channels", aliases = ["broker_openBtcDepositChannels"])]
+	async fn open_btc_deposit_channels(
+		&self,
+	) -> RpcResult<Vec<<cf_chains::Bitcoin as cf_chains::Chain>::ChainAccount>>;
 }
 
 pub struct RpcServerImpl {
@@ -205,6 +211,20 @@ impl RpcServer for RpcServerImpl {
 			.await
 			.map_err(BrokerApiError::Other)
 	}
+
+	async fn open_btc_deposit_channels(
+		&self,
+	) -> RpcResult<Vec<<cf_chains::Bitcoin as cf_chains::Chain>::ChainAccount>> {
+		let account_id = self.api.state_chain_client.account_id();
+
+		self.api
+			.state_chain_client
+			.base_rpc_client
+			.raw_rpc_client
+			.cf_open_btc_deposit_channels(account_id, None)
+			.await
+			.map_err(BrokerApiError::ClientError)
+	}
 }
 
 #[derive(Parser, Debug, Clone, Default)]

state-chain/custom-rpc/src/lib.rs

@@ -1751,9 +1751,7 @@ where
 			false, /* only_on_changes */
 			true,  /* end_on_error */
 			sink,
-			|client, hash| {
-				Ok(client.runtime_api().cf_tainted_btc_transaction_events(hash)?)
-			},
+			|client, hash| Ok(client.runtime_api().cf_tainted_btc_transaction_events(hash)?),
 		)
 	}
 }