Struct MessageStore 

pub struct MessageStore;

Stateless message store. All methods take &SqliteGraph for the shared connection.

Implementations

impl MessageStore

pub fn new() -> Self

pub fn store( &self, graph: &SqliteGraph, msg_type: MessageType, from: String, to: String, task_id: Option<String>, context_id: Option<String>, parts: Vec<Part>, ) -> Result<MessageEnvelope>

Store a message and return a fully-built MessageEnvelope.

pub fn store_notification( &self, graph: &SqliteGraph, to: &str, event_type: &str, data: &Value, ) -> Result<MessageEnvelope>

Store a system notification for an offline agent. Reuses the message entity schema so it appears in poll/reconnect catch-up.

pub fn ack( &self, graph: &SqliteGraph, message_id: &str, agent_id: &str, ) -> Result<Vec<String>>

Mark a message as consumed (ACKed) by an agent.

pub fn poll( &self, graph: &SqliteGraph, to: &str, since: i64, limit: i64, include_acked: bool, ) -> Result<Vec<MessageEnvelope>>

Get messages for a recipient since a given sequence_id. When include_acked is false, only returns messages not yet ACKed by the recipient.

pub fn get( &self, graph: &SqliteGraph, message_id: &str, ) -> Result<MessageEnvelope>

Get a single message by ID.

pub fn count_all(&self, graph: &SqliteGraph) -> Result<i64>

Get total message count.

Trait Implementations

impl Default for MessageStore

fn default() -> Self

Returns the “default value” for a type.