Struct NodeClient 

pub struct NodeClient { /* private fields */ }

One local ACP node: a single OpenedStore, its push link, and an optional send socket for m4a-send.

Implementations

impl NodeClient

pub fn from_env() -> Result<Self, ShellError>

Open from the process environment: refuse webhook env, require the leader named by LEADER_SOCK_ENV to be listening, register + first key drive, open the push socket. Does not start grok and does not invent a leader. On Windows the path is only what grok hashes into a named pipe; the file does not have to exist.

pub fn nick(&self) -> Option<&str>

Derived nick of the one session, when register stored one.

pub fn session_id(&self) -> &str

Session id used for ACP sessionId.

pub fn user_id(&self) -> &str

Matrix user id of the open session.

pub fn store_root(&self) -> &Path

Store root this client seals under.

pub fn store(&self) -> &OpenedStore

Underlying sealed store (for tests and advanced callers).

pub fn store_mut(&mut self) -> &mut OpenedStore

Mutable underlying store.

pub fn wake_log(&self) -> &[WakeAttempt]

Routine wake attempts since open (event id + HTTP status). Empty on the node path because webhook wake is refused.

pub fn wake_note(&self) -> Option<&str>

Last wake failure note (ACP errors), if any.

pub fn listen_for_sends(&mut self, path: &Path) -> Result<(), ShellError>

Listen for m4a-send on path. Replaces a stale socket file and refuses when another live client already holds it. Unix is a mode 0600 domain socket. Windows writes 127.0.0.1:{port} and listens on that loopback port.

pub fn listen_for_sends_from_env(&mut self) -> Result<PathBuf, ShellError>

Self::listen_for_sends on crate::SEND_SOCK_ENV, or NODE_DEFAULT_SOCK_NAME under the store root.

pub fn tick(&mut self, now_ms: i64, full_drive_secs: u64) -> NodeTickReport

One step of the long-running node loop.

Drains the push socket, drives the session (waiting on /sync when a push arrived so decrypt + ACP wake can run), accepts DM invites, and answers queued m4a-send requests. Every full_drive_secs a catch-up drive runs even without a push.

pub fn send_blocking( &mut self, to: &str, text: &str, wait: Duration, ) -> SendReply

Blocking send from this node’s nick to to (encrypted DM). Used when m4a-send falls through with no socket answer, or by callers that already hold the client.

Trait Implementations

impl Drop for NodeClient

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.