Struct SharedMessage

pub struct SharedMessage {
    pub id: SharedObjectId,
    pub message_type: MessageType,
    pub target_id: Option<SharedObjectId>,
    pub data: Value,
    pub timestamp: DateTime<Utc>,
    pub signature: Option<Vec<u8>>,
    pub hash: String,
}

A message that can be shared between nodes

Fields

id: SharedObjectId

Unique message identifier

message_type: MessageType

Message type

target_id: Option<SharedObjectId>

Target object ID (if applicable)

data: Value

Message payload

timestamp: DateTime<Utc>

Timestamp when message was created

signature: Option<Vec<u8>>

Optional signature for authenticated messages

hash: String

Hash of the message content

Implementations

impl SharedMessage

pub fn new(message_type: MessageType, data: Value) -> Self

Create a new shared message

pub fn new_with_target( message_type: MessageType, target_id: SharedObjectId, data: Value, ) -> Self

Create a new message with a target

pub fn custom<T: Serialize>( message_type: impl Into<String>, data: T, ) -> Result<Self>

Create a custom message

pub fn sign(&mut self, private_key: &PrivateKey) -> Result<()>

Sign this message with the given private key

pub fn verify_signature(&self, public_key: &PublicKey) -> Result<bool>

Verify the signature of this message

pub fn calculate_hash(&self) -> String

Calculate the hash of this message

pub fn verify_hash(&self) -> bool

Verify the message hash

pub fn size(&self) -> usize

Get the message size in bytes

pub fn to_bytes(&self) -> Result<Vec<u8>>

Convert message to bytes for signing/verification

pub fn from_bytes(bytes: &[u8]) -> Result<Self>

Create message from bytes

pub fn to_json(&self) -> Result<String>

Serialize to JSON

pub fn from_json(json: &str) -> Result<Self>

Deserialize from JSON

Trait Implementations

impl Clone for SharedMessage

fn clone(&self) -> SharedMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SharedMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SharedMessage

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for SharedMessage

fn eq(&self, other: &Self) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for SharedMessage

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for SharedMessage