Struct CCCCClient 

pub struct CCCCClient { /* private fields */ }

Blocking CCCC Daemon IPC v1 client.

Implementations

impl CCCCClient

pub fn discover() -> Result<Self>

Discover the currently running daemon.

Examples found in repository

examples/compat_check.rs (line 4)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    let client = CCCCClient::discover()?;
    let requirements = CompatibilityRequirements {
        minimum_ipc_version: 1,
        operations: vec![
            "groups",
            "group_show",
            "send",
            "tracked_send",
            "reply",
            "inbox_read",
            "message_history",
            "context_get",
            "context_sync",
            "group_preamble_get",
            "send_files",
            "terminal_history",
            "term_resize",
            "web_model_delivery_preferences_get",
            "web_model_delivery_preferences_update",
            "web_model_runtime_recover_turn",
        ],
        ..Default::default()
    };
    let daemon = client.assert_compatible(&requirements)?;
    println!(
        "CCCC {} ({}) is compatible with IPC v{}",
        daemon.version, daemon.implementation, daemon.ipc_v
    );
    Ok(())
}

pub fn discover_in(cccc_home: Option<&Path>) -> Result<Self>

Discover a daemon under an explicit CCCC_HOME.

pub fn new(endpoint: DaemonEndpoint) -> Self

pub fn with_timeout(self, timeout: Duration) -> Self

pub fn endpoint(&self) -> &DaemonEndpoint

The endpoint supplied to new or found during initial discovery.

pub fn current_endpoint(&self) -> DaemonEndpoint

The endpoint currently used for calls, including a successful rediscovery after daemon restart.

pub fn call( &self, op: &str, args: Map<String, Value>, ) -> Result<Map<String, Value>>

Call any non-streaming daemon operation and return its result object.

pub fn call_raw( &self, op: &str, args: Map<String, Value>, ) -> Result<DaemonResponse>

Call an operation and retain the full response envelope.

pub fn ping(&self) -> Result<PingResult>

pub fn groups(&self) -> Result<Map<String, Value>>

pub fn group_show(&self, group_id: &str) -> Result<Map<String, Value>>

pub fn send( &self, group_id: &str, text: &str, message_mode: MessageMode, by: &str, ) -> Result<Map<String, Value>>

pub fn reply( &self, group_id: &str, reply_to: &str, text: &str, by: &str, ) -> Result<Map<String, Value>>

pub fn reply_with_mode( &self, group_id: &str, reply_to: &str, text: &str, message_mode: ReplyMessageMode, by: &str, ) -> Result<Map<String, Value>>

pub fn reply_request_cancel( &self, group_id: &str, source_event_id: &str, by: &str, ) -> Result<Map<String, Value>>

pub fn message_deliver( &self, group_id: &str, source_event_id: &str, actor_ids: &[&str], by: &str, force_ambiguous: bool, ) -> Result<Map<String, Value>>

pub fn inbox_peek( &self, group_id: &str, actor_id: &str, by: &str, limit: Option<u32>, ) -> Result<Map<String, Value>>

pub fn inbox_read( &self, group_id: &str, actor_id: &str, by: &str, limit: Option<u32>, ) -> Result<Map<String, Value>>

pub fn message_history( &self, group_id: &str, actor_id: &str, by: &str, mode: MessageHistoryMode, query: Option<&str>, before_event_id: Option<&str>, limit: Option<u32>, ) -> Result<Map<String, Value>>

Inspect actor-visible chat history without consuming Mail.

pub fn context_get(&self, group_id: &str) -> Result<Map<String, Value>>

pub fn context_get_with_detail( &self, group_id: &str, detail: ContextDetail, ) -> Result<Map<String, Value>>

pub fn context_sync( &self, group_id: &str, by: &str, operations: Vec<Value>, ) -> Result<Map<String, Value>>

pub fn context_sync_checked( &self, group_id: &str, by: &str, operations: Vec<Value>, if_version: Option<&str>, dry_run: bool, ) -> Result<Map<String, Value>>

pub fn terminal_history( &self, group_id: &str, actor_id: &str, options: &TerminalHistoryOptions, ) -> Result<TerminalHistoryResult>

pub fn terminal_since( &self, group_id: &str, actor_id: &str, after: u64, options: &TerminalSinceOptions, ) -> Result<TerminalSinceResult>

pub fn terminal_snapshot( &self, group_id: &str, actor_id: &str, options: &TerminalSnapshotOptions, ) -> Result<TerminalSnapshotResult>

pub fn term_resize( &self, group_id: &str, actor_id: &str, cols: u32, rows: u32, ) -> Result<TerminalResizeResult>

Resize a PTY using the normative op, with a compatibility fallback for Rust daemon builds that temporarily exposed terminal_resize instead.

pub fn web_model_delivery_preferences_get( &self, group_id: &str, actor_id: &str, ) -> Result<WebModelDeliveryPreferencesResult>

pub fn web_model_delivery_preferences_update( &self, group_id: &str, actor_id: &str, mode: WebModelDeliveryMode, by: &str, ) -> Result<WebModelDeliveryPreferencesResult>

pub fn web_model_runtime_recover_turn( &self, group_id: &str, actor_id: &str, event_ids: &[String], ) -> Result<WebModelRuntimeRecoverTurnResult>

pub fn assert_compatible( &self, requirements: &CompatibilityRequirements<'_>, ) -> Result<PingResult>

Validate protocol, advertised capabilities, and actual op recognition.

Examples found in repository

examples/compat_check.rs (line 27)

fn main() -> Result<(), Box<dyn std::error::Error>> {
    let client = CCCCClient::discover()?;
    let requirements = CompatibilityRequirements {
        minimum_ipc_version: 1,
        operations: vec![
            "groups",
            "group_show",
            "send",
            "tracked_send",
            "reply",
            "inbox_read",
            "message_history",
            "context_get",
            "context_sync",
            "group_preamble_get",
            "send_files",
            "terminal_history",
            "term_resize",
            "web_model_delivery_preferences_get",
            "web_model_delivery_preferences_update",
            "web_model_runtime_recover_turn",
        ],
        ..Default::default()
    };
    let daemon = client.assert_compatible(&requirements)?;
    println!(
        "CCCC {} ({}) is compatible with IPC v{}",
        daemon.version, daemon.implementation, daemon.ipc_v
    );
    Ok(())
}

impl CCCCClient

pub fn connect_catalog( &self, options: &ConnectCatalogOptions, ) -> Result<Map<String, Value>>

pub fn connect_send( &self, options: &ConnectSendOptions, ) -> Result<Map<String, Value>>

pub fn connect_send_files( &self, options: &ConnectSendOptions, paths: &[String], ) -> Result<Map<String, Value>>

Paths are read by the daemon within the source Group’s active scope.

Trait Implementations

impl Clone for CCCCClient

fn clone(&self) -> CCCCClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CCCCClient

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

Formats the value using the given formatter.