Struct TransactionTracker

pub struct TransactionTracker { /* private fields */ }

Tracks oracle responses and execution outcomes of an ongoing transaction execution, as well as replayed oracle responses.

Implementations

impl TransactionTracker

pub fn new( local_time: Timestamp, transaction_index: u32, next_application_index: u32, next_chain_index: u32, oracle_responses: Option<Vec<OracleResponse>>, blobs: &[Vec<Blob>], ) -> Self

pub fn with_blobs(self, blobs: BTreeMap<BlobId, BlobContent>) -> Self

pub fn local_time(&self) -> Timestamp

pub fn set_local_time(&mut self, local_time: Timestamp)

pub fn transaction_index(&self) -> u32

pub fn next_application_index(&mut self) -> u32

pub fn next_chain_index(&mut self) -> u32

pub fn add_outgoing_message(&mut self, message: OutgoingMessage)

pub fn add_outgoing_messages( &mut self, messages: impl IntoIterator<Item = OutgoingMessage>, )

pub fn add_event(&mut self, stream_id: StreamId, index: u32, value: Vec<u8>)

pub fn get_blob_content(&self, blob_id: &BlobId) -> Option<&BlobContent>

pub fn add_created_blob(&mut self, blob: Blob)

pub fn add_published_blob(&mut self, blob_id: BlobId)

pub fn created_blobs(&self) -> &BTreeMap<BlobId, BlobContent>

pub fn add_operation_result(&mut self, result: Option<Vec<u8>>)

pub async fn oracle<F, G>( &mut self, f: F, ) -> Result<&OracleResponse, ExecutionError>

where F: FnOnce() -> G, G: Future<Output = Result<OracleResponse, ExecutionError>>,

In replay mode, returns the next recorded oracle response. Otherwise executes f and records and returns the result. f is the implementation of the actual oracle and is only called in validation mode, so it does not have to be fully deterministic.

pub fn add_stream_to_process( &mut self, application_id: ApplicationId, chain_id: ChainId, stream_id: StreamId, previous_index: u32, next_index: u32, )

pub fn remove_stream_to_process( &mut self, application_id: ApplicationId, chain_id: ChainId, stream_id: StreamId, )

pub fn take_streams_to_process( &mut self, ) -> BTreeMap<ApplicationId, Vec<StreamUpdate>>

pub fn replay_oracle_response( &mut self, oracle_response: OracleResponse, ) -> Result<bool, ExecutionError>

Adds the oracle response to the record. If replaying, it also checks that it matches the next replayed one and returns true.

pub fn into_outcome(self) -> Result<TransactionOutcome, ExecutionError>

impl TransactionTracker

pub fn new_replaying(oracle_responses: Vec<OracleResponse>) -> Self

Creates a new TransactionTracker for testing, with default values and the given oracle responses.

pub fn new_replaying_blobs<T>(blob_ids: T) -> Self

where T: IntoIterator, T::Item: Borrow<BlobId>,

Creates a new TransactionTracker for testing, with default values and oracle responses for the given blobs.

Trait Implementations

impl Debug for TransactionTracker

fn fmt(&self, fmt: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for TransactionTracker

fn default() -> TransactionTracker

Returns the “default value” for a type.