Struct NodeCalls 

pub struct NodeCalls { /* private fields */ }

Shared by the door and the node-mail wake; the restream bridge signals presence here.

Implementations

impl NodeCalls

pub fn new( node_id: String, keys: Option<UpstreamKeys>, legacy: Option<(SocketAddr, Arc<NodeIdentity>)>, config_http: Option<(SocketAddr, Arc<NodeIdentity>)>, ) -> Self

pub async fn set_uplink(&self, uplink: Option<Arc<NodeUplink>>)

Bridge (re)connect: refresh product URL. Mail TCP is maintained separately by Self::spawn_mail_uplink so PTY and mail do not share fate.

pub fn spawn_mail_uplink( &self, addr: SocketAddr, keys: UpstreamKeys, journal: Option<Arc<UplinkJournal>>, shutdown: Receiver<bool>, )

Keep a dedicated TCP + ch2 Noise session open for node-calls. Reconnects with exponential backoff (5s → 30s) independently of the g4a bridge.

pub async fn refresh_product_url(&self) -> bool

Ask C2 for its public config over enroll HTTP and stash m4a_product_url.

pub async fn refresh_product_url_retrying(&self)

Self::refresh_product_url with retries (5s doubling to 5 min) until C2 answers.

pub fn spawn_rekey_watch(&self, shutdown: Receiver<bool>)

The node-call channel only reads downlink while a call waits for its reply, so a core restart (core then holds no keys and asks for a re-handshake) went unnoticed until the next call failed. Check the idle channel every few seconds and re-handshake as soon as core asks.

pub async fn call(&self, op: &str, payload: &Value) -> Result<Value, CallError>

Trait Implementations

impl Clone for NodeCalls

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.