Struct MessageEngine 

pub struct MessageEngine {
    pub store: CommStore,
}

Unified message processing engine that wraps CommStore and provides a higher-level pipeline for sending and querying messages.

The engine adds validation, trust checking, and consent enforcement as a composable layer on top of the raw store operations.

Fields

store: CommStore

The underlying communication store.

Implementations

impl MessageEngine

pub fn new() -> Self

Create a new engine backed by an empty CommStore.

pub fn from_store(store: CommStore) -> Self

Create an engine from an existing CommStore.

pub fn process_message( &mut self, channel_id: u64, sender: &str, content: &str, message_type: &str, ) -> Result<u64, String>

Process an inbound message through the full pipeline.

Steps:

1. Parse the message type from a string.
2. Validate sender trust level (must be at least Basic).
3. Check consent for the SendMessages scope.
4. Send the message via the underlying store.
5. Return the new message ID.

pub fn query(&self, query_type: &str, params: &Value) -> Result<Value, String>

Unified query dispatcher.

Supported query_type values:

• "channel_messages" — returns messages for a channel. Params: { "channel_id": <u64> }

• "message" — returns a single message by ID. Params: { "message_id": <u64> }

• "stats" — returns store-level statistics. Params: {} (none required)

• "semantic_search" — returns semantically similar messages. Params: { "embedding": [f32, ...], "top_k": <usize> }

Trait Implementations

impl Clone for MessageEngine

fn clone(&self) -> MessageEngine

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MessageEngine

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

Formats the value using the given formatter.

impl Default for MessageEngine

fn default() -> Self

Returns the “default value” for a type.