feat: expose command for broker fee withdrawal

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

@@ -56,6 +56,13 @@ pub trait Rpc {
 		channel_metadata: Option<CcmChannelMetadata>,
 		boost_fee: Option<BasisPoints>,
 	) -> RpcResult<BrokerSwapDepositAddress>;
+
+	#[method(name = "withdraw_fee_asset", aliases = ["broker_withdrawFeeAsset"])]
+	async fn withdraw_fee_asset(
+		&self,
+		asset: Asset,
+		destination_address: String,
+	) -> RpcResult<String>;
 }
 
 pub struct RpcServerImpl {
@@ -108,6 +115,22 @@ impl RpcServer for RpcServerImpl {
 			.await
 			.map(BrokerSwapDepositAddress::from)?)
 	}
+
+	async fn withdraw_fee_asset(
+		&self,
+		asset: Asset,
+		destination_address: String,
+	) -> RpcResult<String> {
+		Ok(self
+			.api
+			.broker_api()
+			.withdraw_fee_asset(
+				asset,
+				clean_foreign_chain_address(asset.into(), &destination_address)?,
+			)
+			.await
+			.map(|tx_hash| format!("{tx_hash:#x}"))?)
+	}
 }
 
 #[derive(Parser, Debug, Clone, Default)]

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

@@ -75,6 +75,19 @@ async fn run_cli() -> Result<()> {
 						.await?;
 					println!("Deposit Address: {address}");
 				},
+				Broker(BrokerSubcommands::WithdrawFeeAsset(params)) => {
+					let tx_hash = api
+						.broker_api()
+						.withdraw_fee_asset(
+							params.asset,
+							chainflip_api::clean_foreign_chain_address(
+								params.asset.into(),
+								&params.destination_address,
+							)?,
+						)
+						.await?;
+					println!("Withdrawal request successfull submitted. Tx hash: {tx_hash}");
+				},
 				LiquidityProvider(
 					LiquidityProviderSubcommands::RequestLiquidityDepositAddress {
 						asset,

api/bin/chainflip-cli/src/settings.rs

@@ -76,11 +76,18 @@ pub struct SwapRequestParams {
 	/// Commission to the booster in basis points
 	pub boost_fee: Option<u16>,
 }
-
+#[derive(Parser, Clone, Debug)]
+pub struct WithdrawFeeAssetParams {
+	/// Asset to withdraw ("ETH"|"DOT")
+	pub asset: Asset,
+	/// Egress asset address to receive withdrawn funds
+	pub destination_address: String,
+}
 #[derive(clap::Subcommand, Clone, Debug)]
 pub enum BrokerSubcommands {
 	/// Request a swap deposit address.
 	RequestSwapDepositAddress(SwapRequestParams),
+	WithdrawFeeAsset(WithdrawFeeAssetParams),
 }
 
 #[derive(clap::Subcommand, Clone, Debug)]

api/lib/src/lib.rs

@@ -356,6 +356,22 @@ pub trait BrokerApi: SignedExtrinsicApi {
 			bail!("No SwapDepositAddressReady event was found");
 		}
 	}
+	async fn withdraw_fee_asset(
+		&self,
+		asset: Asset,
+		destination_address: EncodedAddress,
+	) -> Result<H256> {
+		let (tx_hash, ..) = self
+			.submit_signed_extrinsic(RuntimeCall::from(pallet_cf_swapping::Call::withdraw {
+				asset,
+				destination_address,
+			}))
+			.await
+			.until_in_block()
+			.await
+			.context("Request to withdraw broker fee for ${asset} failed.")?;
+		Ok(tx_hash)
+	}
 }
 
 /// Sanitize the given address (hex or base58) and turn it into a EncodedAddress of the given