Feed one length-delimited Envelope into the core->client stream.

Build a config, applying explicit > env > default precedence. Relay token sources: ``CMDOP_TOKEN`` then ``CMDOP_API_KEY`` (token wins

Close stdin (graceful drain) and reap the core process.

Close stdin (graceful drain) and reap the core process.

Public, non-pagination instance methods declared on ``cls`` itself.

Public, non-pagination instance methods of a resource class, snake_cased.

Open a streaming call (machines.ask). Returns an {@link AskStream}.

Open a streaming call (machines.ask). Returns a :class:`FrameStream` whose first iteration sends the REQUEST and yields typed frames.

Return ``<plat>-<arch>`` for this host, or None if unsupported.

* Send a REQUEST envelope, await the RESPONSE/ERROR on its id. `req` carries * the oneof payload arm; `id`/`kind` are filled here.

Convert a 1-based ``page`` + optional ``per_page`` to the proto ``OffsetPage{offset, per_page}`` the core expects.

Send a REQUEST envelope, await the RESPONSE/ERROR on its id. ``req`` must already carry ``kind=KIND_REQUEST`` and the right oneof arm;

Return an absolute path to a runnable ``cmdop-core`` binary. Raises :class:`FileNotFoundError` if neither the override nor a baked binary is

The host's baked binary filename, e.g. ``cmdop-core-darwin-arm64``.

Yield each offset page (1-based) until the offset+items covers total.

EOF / crash: fail every in-flight call.

Read one length-delimited protobuf body off ``reader``. Reads the varint length one byte at a time (high bit = continue), then the exact body

* Reader: `sizeDelimitedDecodeStream` consumes the stdout (an * `AsyncIterable<Uint8Array>`) and yields fully-assembled Envelopes, * reassemblin

Yield each cursor page; follow ``next_cursor`` until exhausted. Works over both ``MachineList`` (next_cursor + has_more) and ``Schedu

Raise the typed PIN exception for a PIN-gate verdict; otherwise the generic :class:`AgentStreamError` (the ask stream's error-frame contract).

Write an ANSWER envelope on this stream's id.

* @internal Test seam: drive the demux off a provided stdin/stdout pair * instead of spawning a binary. Used by the transport unit tests, mirroring

Minimal Client stand-in SkillsResource needs (transport + fleetId).

Find a fleet by id within the (offset-paginated) list.

Map a core ``ErrorInfo{code, message}`` to a typed exception.

Run history (cursor-paginated, newest first).

Write an ANSWER envelope (pin/confirm) on an open stream's id.

Route a frame by id, branch on kind (report 13 §4.1).

Drain the core's stderr so its diagnostics never block / corrupt the protocol pipe. We discard it (set CMDOP_DEBUG=1 to have the core log to a

Project one streamed Envelope onto a typed frame.

Internal: register the stream id + send its REQUEST. Called lazily by :class:`FrameStream` on first iteration so the same stream object can be

Write ``env`` as a varint-size-prefixed protobuf frame.

Close a tunnel (idempotent).

Drain to the final text (the ``done`` frame's text, else accumulated event deltas). Raises :class:`AgentStreamError` on an error outcome.

* Drain to the final text (the `done` frame's text, else accumulated event * deltas). Throws {@link AgentStreamError} on an error outcome.

Answer a ``confirm_required`` frame. ``accept=True`` resumes the stream onto the same id; ``accept=False`` ends it with a rejected DONE.

* Answer a `confirm_required` frame. `accept=true` resumes the stream onto the * same id; `accept=false` ends it with a rejected `done`.

Async-iterate the raw envelopes for this stream (terminates on done).

Get the install payload (command, README, files, deps) for a skill.