Struct SurfnetSvmLocker

pub struct SurfnetSvmLocker(pub Arc<RwLock<SurfnetSvm>>);

Tuple Fields

0: Arc<RwLock<SurfnetSvm>>

Implementations

impl SurfnetSvmLocker

Functions for reading and writing to the underlying SurfnetSvm instance

pub fn with_svm_reader<T, F>(&self, reader: F) -> T

where F: Fn(&SurfnetSvm) -> T + Send + Sync, T: Send + 'static,

Executes a read-only operation on the underlying SurfnetSvm by acquiring a blocking read lock. Accepts a closure that receives a shared reference to SurfnetSvm and returns a value.

Returns

The result produced by the closure.

pub fn with_svm_writer<T, F>(&self, writer: F) -> T

where F: Fn(&mut SurfnetSvm) -> T + Send + Sync, T: Send + 'static,

Executes a write operation on the underlying SurfnetSvm by acquiring a blocking write lock. Accepts a closure that receives a mutable reference to SurfnetSvm and returns a value.

Returns

The result produced by the closure.

impl SurfnetSvmLocker

Functions for creating and initializing the underlying SurfnetSvm instance

pub fn new(svm: SurfnetSvm) -> Self

Constructs a new SurfnetSvmLocker wrapping the given SurfnetSvm instance.

pub async fn initialize( &self, remote_ctx: &Option<SurfnetRemoteClient>, ) -> SurfpoolResult<EpochInfo>

Initializes the locked SurfnetSvm by fetching or defaulting epoch info, then calling its initialize method. Returns the epoch info on success.

impl SurfnetSvmLocker

Functions for getting accounts from the underlying SurfnetSvm instance or remote client

pub fn get_account_local( &self, pubkey: &Pubkey, ) -> SvmAccessContext<GetAccountResult>

Retrieves a local account from the SVM cache, returning a contextualized result.

pub async fn get_account_local_then_remote( &self, client: &SurfnetRemoteClient, pubkey: &Pubkey, commitment_config: CommitmentConfig, ) -> SurfpoolContextualizedResult<GetAccountResult>

Attempts local retrieval, then fetches from remote if missing, returning a contextualized result.

pub async fn get_account( &self, remote_ctx: &Option<(SurfnetRemoteClient, CommitmentConfig)>, pubkey: &Pubkey, factory: Option<AccountFactory>, ) -> SurfpoolContextualizedResult<GetAccountResult>

Retrieves an account, using local or remote based on context, applying a default factory if provided.

pub fn get_multiple_accounts_local( &self, pubkeys: &[Pubkey], ) -> SvmAccessContext<Vec<GetAccountResult>>

Retrieves multiple accounts from local cache, returning a contextualized result.

pub async fn get_multiple_accounts_local_then_remote( &self, client: &SurfnetRemoteClient, pubkeys: &[Pubkey], commitment_config: CommitmentConfig, ) -> SurfpoolContextualizedResult<Vec<GetAccountResult>>

Retrieves multiple accounts, fetching missing ones from remote, returning a contextualized result.

pub async fn get_multiple_accounts( &self, remote_ctx: &Option<(SurfnetRemoteClient, CommitmentConfig)>, pubkeys: &[Pubkey], factory: Option<AccountFactory>, ) -> SurfpoolContextualizedResult<Vec<GetAccountResult>>

Retrieves multiple accounts, using local or remote context and applying factory defaults if provided.

impl SurfnetSvmLocker

Functions for getting transactions from the underlying SurfnetSvm instance or remote client

pub async fn get_transaction( &self, remote_ctx: &Option<(SurfnetRemoteClient, Option<UiTransactionEncoding>)>, signature: &Signature, ) -> SvmAccessContext<GetTransactionResult>

Retrieves a transaction by signature, using local or remote based on context.

pub fn get_transaction_local( &self, signature: &Signature, ) -> SvmAccessContext<GetTransactionResult>

Retrieves a transaction from local cache, returning a contextualized result.

pub async fn get_transaction_local_then_remote( &self, client: &SurfnetRemoteClient, signature: &Signature, encoding: Option<UiTransactionEncoding>, ) -> SvmAccessContext<GetTransactionResult>

Retrieves a transaction locally then from remote if missing, returning a contextualized result.

impl SurfnetSvmLocker

Functions for simulating and processing transactions in the underlying SurfnetSvm instance

pub fn simulate_transaction( &self, transaction: VersionedTransaction, ) -> Result<SimulatedTransactionInfo, FailedTransactionMetadata>

Simulates a transaction on the SVM, returning detailed info or failure metadata.

pub async fn process_transaction( &self, remote_ctx: &Option<SurfnetRemoteClient>, transaction: VersionedTransaction, status_tx: Sender<TransactionStatusEvent>, skip_preflight: bool, ) -> SurfpoolContextualizedResult<()>

Processes a transaction: verifies signatures, preflight sim, sends to SVM, and enqueues status events.

impl SurfnetSvmLocker

Functions for writing account updates to the underlying SurfnetSvm instance

pub fn write_account_update(&self, account_update: GetAccountResult)

Writes a single account update into the SVM state if present.

pub fn write_multiple_account_updates( &self, account_updates: &[GetAccountResult], )

Writes multiple account updates into the SVM state when any are present.

impl SurfnetSvmLocker

Token account related functions

pub async fn get_all_token_accounts( &self, remote_ctx: &Option<SurfnetRemoteClient>, owner: Pubkey, token_program: Pubkey, ) -> SurfpoolContextualizedResult<(Vec<RpcKeyedAccount>, Vec<Pubkey>)>

Fetches all token accounts for an owner, returning remote results and missing pubkeys contexts.

impl SurfnetSvmLocker

Address lookup table related functions

pub async fn get_pubkeys_from_message( &self, remote_ctx: &Option<(SurfnetRemoteClient, CommitmentConfig)>, message: &VersionedMessage, ) -> SurfpoolResult<Vec<Pubkey>>

Extracts pubkeys from a VersionedMessage, resolving address lookup tables as needed.

pub async fn get_lookup_table_addresses( &self, remote_ctx: &Option<(SurfnetRemoteClient, CommitmentConfig)>, address_table_lookup: &MessageAddressTableLookup, ) -> SurfpoolContextualizedResult<LoadedAddresses>

Retrieves loaded addresses from a lookup table account, validating owner and indices.

impl SurfnetSvmLocker

Profiling helper functions

pub fn estimate_compute_units( &self, transaction: &VersionedTransaction, ) -> SvmAccessContext<ComputeUnitsEstimationResult>

Estimates compute units for a transaction via contextualized simulation.

pub fn write_profiling_results( &self, tag: String, profile_result: ProfileResult, )

Records profiling results under a tag and emits a tagged profile event.

impl SurfnetSvmLocker

Program account related functions

pub async fn clone_program_account( &self, remote_ctx: &Option<(SurfnetRemoteClient, CommitmentConfig)>, source_program_id: &Pubkey, destination_program_id: &Pubkey, ) -> SurfpoolContextualizedResult<()>

Clones a program account from source to destination, handling upgradeable loader state.

impl SurfnetSvmLocker

Pass through functions for accessing the underlying SurfnetSvm instance

pub fn simnet_events_tx(&self) -> Sender<SimnetEvent>

Returns a sender for simulation events from the underlying SVM.

pub fn get_epoch_info(&self) -> EpochInfo

Retrieves the latest epoch info from the underlying SVM.

pub fn get_latest_absolute_slot(&self) -> Slot

Retrieves the latest absolute slot from the underlying SVM.

pub fn airdrop(&self, pubkey: &Pubkey, lamports: u64) -> TransactionResult

Executes an airdrop via the underlying SVM.

pub fn airdrop_pubkeys(&self, lamports: u64, addresses: &[Pubkey])

Executes a batch airdrop via the underlying SVM.

pub fn confirm_current_block(&self) -> SurfpoolResult<()>

Confirms the current block on the underlying SVM, returning Ok(()) or an error.

pub fn subscribe_for_signature_updates( &self, signature: &Signature, subscription_type: SignatureSubscriptionType, ) -> Receiver<(Slot, Option<TransactionError>)>

Subscribes for signature updates (confirmed/finalized) and returns a receiver of events.

Trait Implementations

impl Clone for SurfnetSvmLocker

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.