Struct StellarRelayerTransaction

pub struct StellarRelayerTransaction<R, T, J, S, P, C>
where
    R: Repository<RelayerRepoModel, String>,
    T: TransactionRepository,
    J: JobProducerTrait,
    S: Signer,
    P: StellarProviderTrait,
    C: TransactionCounterTrait,
{ /* private fields */ }

Implementations

impl<R, T, J, S, P, C> StellarRelayerTransaction<R, T, J, S, P, C>

where R: Repository<RelayerRepoModel, String>, T: TransactionRepository, J: JobProducerTrait, S: Signer, P: StellarProviderTrait, C: TransactionCounterTrait,

pub fn new( relayer: RelayerRepoModel, relayer_repository: Arc<R>, transaction_repository: Arc<T>, job_producer: Arc<J>, signer: Arc<S>, provider: P, transaction_counter_service: Arc<C>, ) -> Result<Self, TransactionError>

Creates a new StellarRelayerTransaction.

Arguments

• relayer - The relayer model.
• relayer_repository - Storage for relayer repository.
• transaction_repository - Storage for transaction repository.
• job_producer - Producer for job queue.
• signer - The Stellar signer.
• provider - The Stellar provider.
• transaction_counter_service - Service for managing transaction counters.

Returns

A result containing the new StellarRelayerTransaction or a TransactionError.

pub fn provider(&self) -> &P

pub fn relayer(&self) -> &RelayerRepoModel

pub fn job_producer(&self) -> &J

pub fn transaction_repository(&self) -> &T

pub fn signer(&self) -> &S

pub fn transaction_counter_service(&self) -> &C

pub async fn send_transaction_request_job( &self, tx: &TransactionRepoModel, delay_seconds: Option<i64>, ) -> Result<(), TransactionError>

Send a transaction-request job for the given transaction.

pub async fn finalize_transaction_state( &self, tx_id: String, update_req: TransactionUpdateRequest, ) -> Result<TransactionRepoModel, TransactionError>

Helper function to update transaction status, save it, and send a notification.

pub async fn enqueue_next_pending_transaction( &self, finished_tx_id: &str, ) -> Result<(), TransactionError>

pub async fn sync_sequence_from_chain( &self, relayer_address: &str, ) -> Result<(), TransactionError>

Syncs the sequence number from the blockchain for the relayer’s address. This fetches the on-chain sequence number and updates the local counter to the next usable value.

pub async fn reset_transaction_for_retry( &self, tx: TransactionRepoModel, ) -> Result<TransactionRepoModel, TransactionError>

Resets a transaction to its pre-prepare state for reprocessing through the pipeline. This is used when a transaction fails with a bad sequence error and needs to be retried.

impl<R, T, J, S, P, C> StellarRelayerTransaction<R, T, J, S, P, C>

where R: Repository<RelayerRepoModel, String> + Send + Sync, T: TransactionRepository + Send + Sync, J: JobProducerTrait + Send + Sync, S: Signer + Send + Sync, P: StellarProviderTrait + Send + Sync, C: TransactionCounterTrait + Send + Sync,

pub async fn prepare_transaction_impl( &self, tx: TransactionRepoModel, ) -> Result<TransactionRepoModel, TransactionError>

Main preparation method with robust error handling and guaranteed lane cleanup.

impl<R, T, J, S, P, C> StellarRelayerTransaction<R, T, J, S, P, C>

where R: Repository<RelayerRepoModel, String> + Send + Sync, T: TransactionRepository + Send + Sync, J: JobProducerTrait + Send + Sync, S: Signer + Send + Sync, P: StellarProviderTrait + Send + Sync, C: TransactionCounterTrait + Send + Sync,

pub async fn submit_transaction_impl( &self, tx: TransactionRepoModel, ) -> Result<TransactionRepoModel, TransactionError>

Main submission method with robust error handling. Unlike prepare, submit doesn’t claim lanes but still needs proper error handling.

pub async fn resubmit_transaction_impl( &self, tx: TransactionRepoModel, ) -> Result<TransactionRepoModel, TransactionError>

Resubmit transaction - delegates to submit_transaction_impl

impl<R, T, J, S, P, C> StellarRelayerTransaction<R, T, J, S, P, C>

where R: Repository<RelayerRepoModel, String> + Send + Sync, T: TransactionRepository + Send + Sync, J: JobProducerTrait + Send + Sync, S: Signer + Send + Sync, P: StellarProviderTrait + Send + Sync, C: TransactionCounterTrait + Send + Sync,

pub async fn handle_transaction_status_impl( &self, tx: TransactionRepoModel, ) -> Result<TransactionRepoModel, TransactionError>

Main status handling method with robust error handling. This method checks transaction status and handles lane cleanup for finalized transactions.

pub async fn requeue_status_check( &self, tx: &TransactionRepoModel, ) -> Result<(), TransactionError>

Helper function to re-queue a transaction status check job.

pub fn parse_and_validate_hash( &self, tx: &TransactionRepoModel, ) -> Result<Hash, TransactionError>

Parses the transaction hash from the network data and validates it. Returns a TransactionError::ValidationError if the hash is missing, empty, or invalid.

pub async fn handle_stellar_success( &self, tx: TransactionRepoModel, provider_response: GetTransactionResponse, ) -> Result<TransactionRepoModel, TransactionError>

Handles the logic when a Stellar transaction is confirmed successfully.

pub async fn handle_stellar_failed( &self, tx: TransactionRepoModel, provider_response: GetTransactionResponse, ) -> Result<TransactionRepoModel, TransactionError>

Handles the logic when a Stellar transaction has failed.

pub async fn handle_stellar_pending( &self, tx: TransactionRepoModel, original_status_str: String, ) -> Result<TransactionRepoModel, TransactionError>

Handles the logic when a Stellar transaction is still pending or in an unknown state.

Trait Implementations

impl<R, T, J, S, P, C> Transaction for StellarRelayerTransaction<R, T, J, S, P, C>

where R: Repository<RelayerRepoModel, String> + Send + Sync, T: TransactionRepository + Send + Sync, J: JobProducerTrait + Send + Sync, S: Signer + Send + Sync, P: StellarProviderTrait + Send + Sync, C: TransactionCounterTrait + Send + Sync,

fn prepare_transaction<'life0, 'async_trait>( &'life0 self, tx: TransactionRepoModel, ) -> Pin<Box<dyn Future<Output = Result<TransactionRepoModel, TransactionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Prepares a transaction for submission.

fn submit_transaction<'life0, 'async_trait>( &'life0 self, tx: TransactionRepoModel, ) -> Pin<Box<dyn Future<Output = Result<TransactionRepoModel, TransactionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Submits a transaction to the network.

fn resubmit_transaction<'life0, 'async_trait>( &'life0 self, tx: TransactionRepoModel, ) -> Pin<Box<dyn Future<Output = Result<TransactionRepoModel, TransactionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Resubmits a transaction with updated parameters.

fn handle_transaction_status<'life0, 'async_trait>( &'life0 self, tx: TransactionRepoModel, ) -> Pin<Box<dyn Future<Output = Result<TransactionRepoModel, TransactionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handles the status of a transaction.

fn cancel_transaction<'life0, 'async_trait>( &'life0 self, tx: TransactionRepoModel, ) -> Pin<Box<dyn Future<Output = Result<TransactionRepoModel, TransactionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Cancels a transaction.

fn replace_transaction<'life0, 'async_trait>( &'life0 self, _old_tx: TransactionRepoModel, _new_tx_request: NetworkTransactionRequest, ) -> Pin<Box<dyn Future<Output = Result<TransactionRepoModel, TransactionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Replaces a transaction with a new one.

fn sign_transaction<'life0, 'async_trait>( &'life0 self, tx: TransactionRepoModel, ) -> Pin<Box<dyn Future<Output = Result<TransactionRepoModel, TransactionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Signs a transaction.

fn validate_transaction<'life0, 'async_trait>( &'life0 self, _tx: TransactionRepoModel, ) -> Pin<Box<dyn Future<Output = Result<bool, TransactionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Validates a transaction.