Struct MerkelizedChain 

pub struct MerkelizedChain { /* private fields */ }

Merkelized chain object (Rust analogue of Python SimpleChainObject)

Maintains an append-only chain of SHA256 hashes where each hash is derived from the previous hash. Supports digest-based synchronization for efficient state sync between nodes.

Implementations

impl MerkelizedChain

pub fn new() -> Self

Create a new MerkelizedChain with a genesis hash

pub fn calculate_hash(data: &str) -> String

Calculate the SHA256 hash of data (consistent with Python)

pub fn calculate_next_hash(prev_hash: &str) -> String

Calculate what the next hash should be given a previous hash

pub fn chain_length(&self) -> usize

Get the current chain length (including genesis)

pub fn genesis_hash(&self) -> &str

Get the genesis hash

pub fn latest_hash(&self) -> &str

Get the latest (tip) hash

pub fn hash_at(&self, index: usize) -> Option<&str>

Get a specific hash by index

pub fn is_valid_next_hash(&self, hash: &str) -> bool

Check if a hash is valid as the next hash in the chain

pub fn add_next_hash(&mut self) -> String

Add a next hash to the chain (returns the new hash)

pub fn try_add_hash(&mut self, hash: &str) -> bool

Try to add an existing hash to the chain (for sync from peers) Returns true if the hash was added, false if invalid or duplicate

pub fn chain(&self) -> &[String]

Get the chain as a slice of hashes

pub fn find_hash_index(&self, hash: &str) -> Option<usize>

Find the index of a hash in the chain

Trait Implementations

impl ApplicationObject for MerkelizedChain

fn id(&self) -> &SharedObjectId

Get the object’s unique identifier

fn type_name(&self) -> &'static str

Get the object’s type name

fn is_valid<'life0, 'life1, 'async_trait>( &'life0 self, message: &'life1 SharedMessage, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Validate if a message is valid for this object

fn add_message<'life0, 'async_trait>( &'life0 mut self, message: SharedMessage, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Add a validated message to the object

fn is_merkleized(&self) -> bool

Check if this object supports merkleized synchronization

fn get_latest_digest<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>

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

Get the latest state digest

fn has_digest<'life0, 'life1, 'async_trait>( &'life0 self, digest: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Check if object has a specific digest

fn is_valid_digest<'life0, 'life1, 'async_trait>( &'life0 self, digest: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Validate if a digest is valid

fn add_digest<'life0, 'async_trait>( &'life0 mut self, digest: String, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Add a digest to the object

fn gossip_messages<'life0, 'life1, 'async_trait>( &'life0 self, digest: Option<&'life1 str>, ) -> Pin<Box<dyn Future<Output = Result<Vec<SharedMessage>>> + Send + 'async_trait>>

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

Get messages for gossip protocol

fn get_messages_since_digest<'life0, 'life1, 'async_trait>( &'life0 self, digest: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<SharedMessage>>> + Send + 'async_trait>>

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

Get messages since a specific digest

fn get_state<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Value>> + Send + 'async_trait>>

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

Get the current state as JSON

fn reset<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Reset the object to initial state

fn clone_box(&self) -> Box<dyn ApplicationObject>

Clone the object

fn as_any(&self) -> &dyn Any

Get reference as Any for downcasting

fn as_any_mut(&mut self) -> &mut dyn Any

Get mutable reference as Any for downcasting

impl Clone for MerkelizedChain

fn clone(&self) -> MerkelizedChain

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MerkelizedChain

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

Formats the value using the given formatter.

impl Default for MerkelizedChain

fn default() -> Self

Returns the “default value” for a type.