Struct ReverseChannel 

pub struct ReverseChannel(/* private fields */);

Cheaply-cloneable handle the proxy uses to speak over the WS.

Implementations

impl ReverseChannel

pub fn new() -> (Self, UnboundedReceiver<ServerRequest>)

Build a channel. Returns the channel plus the receiver the API drains (serializing each server_request onto the shared WS sink).

pub async fn laboratory_transfer( &self, request: LaboratoryTransferRequest, ) -> Result<u64, McpError>

LaboratoryExportBegin: start an export on the conduit and get its transfer id. Each transfer op below is ONE id-correlated request/response exchange awaited WITHOUT a deadline — laboratory transfers are timeout-free unconditionally (never bounded by the per-request MCP call timeout). LaboratoryTransfer: hand the WHOLE cross-host client-to-client transfer to the CLI daemon, which drives the export/import splice itself. One request, one {bytes} reply — the proxy never touches payload bytes. Timeout-free like every transfer op.

pub async fn laboratory_local_transfer( &self, request: LaboratoryLocalTransferRequest, ) -> Result<u64, McpError>

LaboratoryLocalTransfer: both endpoints share one (machine, state) — the CLI daemon forwards this verbatim to that one laboratory host, which pipes the bytes container-to-container.

pub async fn laboratory_export_begin( &self, laboratory_id: String, machine: Option<String>, machine_state: Option<String>, path: String, ) -> Result<String, McpError>

pub async fn laboratory_export_read( &self, transfer_id: String, ) -> Result<LaboratoryExportChunk, McpError>

LaboratoryExportRead: pull the next chunk.

pub async fn laboratory_export_abort(&self, transfer_id: String)

LaboratoryExportAbort: best-effort early cleanup.

pub async fn laboratory_import_begin( &self, laboratory_id: String, machine: Option<String>, machine_state: Option<String>, path: String, ) -> Result<String, McpError>

LaboratoryImportBegin: start an import on the conduit and get its transfer id.

pub async fn laboratory_import_write( &self, transfer_id: String, data: String, ) -> Result<(), McpError>

LaboratoryImportWrite: push one chunk.

pub async fn laboratory_import_end( &self, transfer_id: String, ) -> Result<u64, McpError>

LaboratoryImportEnd: close the body and get the byte total.

pub async fn laboratory_import_abort(&self, transfer_id: String)

LaboratoryImportAbort: best-effort early cleanup.

pub fn deliver_response(&self, response: ServerResponse)

Hand a proxy-bound server_response (one of the 6 MCP variants) back to the waiter that issued the matching request. Called by the API’s recv loop. Unknown id → dropped.

pub async fn deliver_client_request(&self, request: Request) -> Response

Hand a proxy-bound client_request to the proxy.

McpListChanged fires the registered list-changed callback for the upstream. The MCP-op variants (ListTools/CallTool/ ListResources/ReadResource) resolve the session by response_id and run the SAME shared [crate::session::Session] code the HTTP endpoints use — fanning out / routing exactly as mcp::handle_tools_list etc. — returning the normal MCP result. NOTE: the CallTool path deliberately does NOT consult the queue delegate (that splice is only for the regular HTTP tools/call). Returns the ack/result the API writes back over the WS.

Trait Implementations

impl Clone for ReverseChannel

fn clone(&self) -> ReverseChannel

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReverseChannel

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

Formats the value using the given formatter.