use kora_lib::{
config::ValidationConfig,
transaction::{
decode_b64_transaction, encode_b64_transaction,
sign_transaction_if_paid as lib_sign_transaction_if_paid,
},
KoraError,
};
use serde::{Deserialize, Serialize};
use solana_client::nonblocking::rpc_client::RpcClient;
use std::sync::Arc;
use utoipa::ToSchema;
#[derive(Debug, Deserialize, ToSchema)]
pub struct SignTransactionIfPaidRequest {
pub transaction: String,
#[serde(default)]
pub margin: Option<f64>,
}
#[derive(Debug, Serialize, ToSchema)]
pub struct SignTransactionIfPaidResponse {
pub transaction: String,
pub signed_transaction: String,
}
pub async fn sign_transaction_if_paid(
rpc_client: &Arc<RpcClient>,
validation: &ValidationConfig,
request: SignTransactionIfPaidRequest,
) -> Result<SignTransactionIfPaidResponse, KoraError> {
let transaction_requested = decode_b64_transaction(&request.transaction)?;
let (transaction, signed_transaction) =
lib_sign_transaction_if_paid(rpc_client, validation, transaction_requested, request.margin)
.await
.map_err(|e| KoraError::TokenOperationError(e.to_string()))?;
Ok(SignTransactionIfPaidResponse {
transaction: encode_b64_transaction(&transaction)?,
signed_transaction,
})
}