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_message_index: u32, next_application_index: u32, oracle_responses: Option<Vec<OracleResponse>>, ) -> Self

pub fn with_blobs(self, blobs: BTreeMap<BlobId, Blob>) -> 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_message_index(&self) -> u32

pub fn next_application_index(&mut self) -> u32

pub fn add_outgoing_message( &mut self, message: OutgoingMessage, ) -> Result<(), ArithmeticError>

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

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

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

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

pub fn subscribe(&mut self, name: ChannelFullName, subscriber: ChainId)

pub fn unsubscribe(&mut self, name: ChannelFullName, subscriber: ChainId)

pub fn add_oracle_response(&mut self, oracle_response: OracleResponse)

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

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 next_replayed_oracle_response( &mut self, ) -> Result<Option<OracleResponse>, ExecutionError>

If in replay mode, returns the next oracle response, or an error if it is missing.

If not in replay mode, None is returned, and the caller must execute the actual oracle to obtain the value.

In both cases, the value (returned or obtained from the oracle) must be recorded using add_oracle_response.

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.