Struct BusMessage 

pub struct BusMessage {
    pub id: String,
    pub cmd: String,
    pub data: Value,
}

A message in the bus protocol

Fields

id: String

Unique message ID

cmd: String

Command type (ACTION, presence, typing, etc.)

data: Value

Command data

Implementations

impl BusMessage

pub fn new(cmd: impl Into<String>, data: Value) -> Self

Create a new bus message

pub fn ack(id: String, status: &str) -> Self

Create an ack response

pub fn to_ws_message(&self) -> Result<Message, Error>

Serialize to JSON and wrap in WebSocket message

pub fn from_ws_message(msg: &Message) -> Result<Option<Self>, Box<dyn Error>>

Parse from WebSocket message

Trait Implementations

impl Clone for BusMessage

fn clone(&self) -> BusMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BusMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for BusMessage

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for BusMessage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.