Return the current range.

Reset a doc to the on-disk content: read the file fresh, diff against the buffer; if the content actually differs, process it as if remote ops. Used b

Returns a "Unsupported" close message, where the close reason is `msg`.

Run the editor receptor on socket. Returns when fatal error occurs.

Reject names that aren't safe to use as filenames or cert subject alt names. Allow `[A-Za-z0-9_-]` only.

Helper function for sending connect message to signaling server plus cleaning up if failed to send (set remote state and send notification to editor).

* Set a new stored value

Returns the new `connection_id`.

Returns the new `connection_id`.

Stand up two `Server`s sharing one in-memory factory and signaling state, do the `AcceptConnection` / `Connect` handshake, and return once both editor

Starts the connection process for `peer_id`, which includes awaiting the future to get the transport, connecting with the peer with the transport, and

Transform `self` against every op in `ops` sequentially. In the meantime, transform every op in `ops` against `self`, and return the new `ops`.

Tear down: drop the mock editor so editor_rx's held tx is gone; the server task then exits, the `SshRemote` actor drops, the ssh session closes, and t

* Update hosted image metadata * @param options Properties to update * @returns Updated image metadata * @throws {@link ImagesError} if

Verify that engine's editor_len matches the actual buffer length.

Signal Error if `conn` doesn't provide the same certificate as `cert`.

Verify `sig` is a valid signature of `id` made with the private key corresponding to `id.cert`, and that `id.timestamp` is within [`MAX_TIMESTAMP_OFFS

Wait for Connect message and create Sock

Run a websocket receptor on `addr`. Returns a receiver that caller can read connections from.

Add or replace a permission entry for a host. Used by envoy mode to grant the spawning host full permissions.

Return the global and local ops after `seq`.

Apply an EditInstruction to the buffer and verify sync.

Transform `self` against every op in `ops` sequentially.

Measure three things for the equal-content (empty diff) case: (a) time to collect the GapBuffer to a String, (b) time for `dissimilar::diff` on two eq

Build the WebSocket upgrade request with the four `X-Collab-*` bind headers attached. The server's `accept_hdr_async` callback validates them; if anyt

Get a candidate sender for this sock. This allows sending candidates without holding a reference to the sock.

Get peer's cert hash, which is the hash portion of [`Sock::id`].

Walk the dissimilar chunk sequence and emit OT ops with positions in the OLD (left-hand-side) document, then return them in REVERSE order so each op c

Root-only. Cancel, close the shared tracker, and wait up to `timeout` for every tracked task to finish. # Panics Panics if called on a non-root mana

Spawn an [`IoRemote`] for an already-established byte stream (envoy stdio, ssh stdio).

Spawn an [`SshRemote`] for a peer reachable via ssh.

Connect using an existing Sock from SignalingClient.

* Create a new repository with an initial access token. * @param name Repository name (alphanumeric, dots, hyphens, underscores). * @param o

Check if a host has create permission Always returns true for ourselves.

Returns the current unix epoch in seconds.

Inverse of [`encode_trusted_header`]. An empty header value decodes to an empty list (rather than a list with a single empty string).

Pick a default name when the user hasn't set `host_id` in config. Use the OS hostname, replace non-`[A-Za-z0-9_-]` char with `-` and truncating to 20

Check if a host has delete permission Always returns true for ourselves

Return the doc of the ops.

Encode a trust list as a comma-separated string suitable for use as an HTTP header value. Endpoint ids have the shape `<name>::<cert_hash>` so they do

ICE/DTLS/SCTP establishment. The DTLS conn is kept alive by the SCTP association’s `net_conn`, so we don’t need to return it.

We’re trying to delete `file`, find the files we need to delete (if `file` is a directory), and find the subscribers we need to notify of the deletion

Remove pass: handle reconnect/etc for remotes.

Signaling pass: Connect to signaling servers. Also handles bind timeouts.

Timeout pass: Stage1 > 10s and Stage2 > 30s flip to Disconnected (if `ever_connected`) or Failed (if never connected).

Read a length-prefixed serialized [`Message`] from `reader`.

Generate a redo op from the current undo tip. Return en empty vector if there's no more ops to redo.

Generate a fresh self-signed key/cert pair without saving to disk. Returns `(key_pem, cert_pem, cert_hash)`. `name` is used as the cert's subject alt

Get the path where the config file should be located

Get number of editors needed from commands

Get the server info for the server with `id`.

Helper to parse ICE credentials from SDP string.

Get a mutable remote doc by EditorFileDesc.

Return global ops after `seq`.

Handle AcceptConnection notification from editor. Declares intent in `ideal_world` and kicks off the bind inline so the caller’s next request (e.g. Co

Handle a connection from client. Read headers and validate auth, if pass, start conversation with it.

Handle each client message, send response to `resp_tx`.