meerkat-core 0.8.31

Foundational agent contracts, config, and runtime-neutral logic for Meerkat
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

//! Agent comms helpers.

use crate::agent::{Agent, AgentLlmClient, AgentSessionStore, AgentToolDispatcher, CommsRuntime};

impl<C, T, S> Agent<C, T, S>
where
    C: AgentLlmClient + ?Sized + 'static,
    T: AgentToolDispatcher + ?Sized + 'static,
    S: AgentSessionStore + ?Sized + 'static,
{
    /// Get the comms runtime, if enabled.
    pub fn comms(&self) -> Option<&dyn CommsRuntime> {
        self.comms_runtime.as_deref()
    }

    /// Get a shared handle to the comms runtime, if enabled.
    pub fn comms_arc(&self) -> Option<std::sync::Arc<dyn CommsRuntime>> {
        self.comms_runtime.clone()
    }

    pub fn observed_comms_sender(&self) -> Option<std::sync::Arc<super::ObservedCommsSender>> {
        Some(std::sync::Arc::new(super::ObservedCommsSender::new(
            self.comms_runtime.clone()?,
            std::sync::Arc::clone(&self.post_commit_hooks),
        )))
    }

    /// Send through the configured comms runtime and project a successful peer
    /// delivery onto the observe-only post-commit hook surface.
    pub async fn send_comms(
        &self,
        command: crate::comms::CommsCommand,
    ) -> Result<crate::comms::SendReceipt, crate::comms::SendError> {
        let sender = self.observed_comms_sender().ok_or_else(|| {
            crate::comms::SendError::Unsupported("comms runtime is not configured".to_string())
        })?;
        sender.send(command).await
    }
}