* @param {Object} context Derived identity context.

* @summary Prints CLI usage to stderr. * @returns {void}

* @summary Prints CLI usage to stderr. * @returns {void}

@summary Resolves true when Chroma's TCP port accepts a connection.

* Recursively processes a data object, creating or updating Neo.core.Config instances * for each property and storing them in the #dataConfigs ma

* Handles the completion of the drag operation. Invoked exactly once per drag via the * {@link #onDragEnd} re-entry latch; subclasses extend this

* @param {String} contentString * @param {Object} map * @returns {String}

* @param {String} contentString * @param {Object} map * @returns {String}

* @param {String} contentString * @param {Object} map * @returns {String}

* @param {String} contentString * @param {String} windowId * @returns {Promise<String>}

* Recursively processes a VDOM node to instantiate components defined within it. * @param {Object} vdomTree The VDOM node to process. * @par

* Projects env-bound `key: leaf(default, 'ENV', 'type')` calls from config source text. * * @param {String} src Source text. * @returns {Array<{key

* @summary Applies the requested payload projection to a listed issue. * * Projection happens after GraphQL retrieval and client-side filter

* @param {Object} data * @param {String} data.replyId * @returns {Promise<any>}

* Fast glob with optimized settings for documentation files * @param {string|string[]} globs - Glob patterns * @returns {Promise<string[]>} - Array

* Sends remote method registration messages to other threads (workers or main-threads). * This method is crucial for enabling cross-worker commun

* @param {Object} opts * @returns {Promise<any>}

* @param {String} key * @param {Function} module * @param {String} reference * @returns {Neo.component.Base} The matching view instance

* Prunes archived log files (`embed-daemon.log.*`) older than `LOG_RETENTION_DAYS` from * `DAEMON_DATA_DIR`. Runs once at daemon startup. Best-effort

* Prunes archived log files (`wake-daemon.log.*`) older than `LOG_RETENTION_DAYS` from * `DAEMON_DATA_DIR`. Runs once at daemon startup. Best-effort:

* Permanently drops legacy Neural Link action records from the SQLite db to prevent unbounded disk growth. * @param {Number} [days=config.pruneLo

* @summary Executes one GC pulse: enumerate tenants → per-tenant retention diff → * opt-in delete → telemetry → `defrag-recommended` signal.

* @summary Executes one reconciliation pulse: enumerate tenants → per-tenant diff → * telemetry → opt-in tombstone. * * Wrapped in try/

* Execute one heartbeat pulse. The step order preserves the established * heartbeat contract while running inside the Orchestrator scheduler:

* @summary Orchestrates the purge: list → partition → (dry-run report | delete) → residue cleanup → verify. * @returns {Promise<void>}

* Pushes local changes to GitHub using GraphQL mutations. * Uses content hash comparison to detect actual changes and prevent false updates.

* @param {Object} [opts={}] * @param {Object} [opts.data] * @param {Object} [opts.params] * @param {String} [opts.resource] * @par

* @param {Object} [opts={}] * @param {Object} [opts.data] * @param {Object} [opts.params] * @param {String} [opts.resource] * @par

* Executes queries against the internal Action Log. Principally used by DreamService triggers * to harvest execution chains for automated Playwri

* Queues an event for coalescing. * Applies tuple-based deduplication (type + identity-tuple) to prevent duplicate * wake event triggers within a si

* @summary Creates a minimal parsed-chunk-v1 record for raw text payloads. * @param {Object} options * @returns {Object} * @protected

* @summary Reads the tracked Codex config template for static MCP policy guards. * @returns {String}

* @summary Reads a form-urlencoded request body. * Reads a form-urlencoded request body. * @param {http.IncomingMessage} request The incoming HTTP r

* @summary Reads the current graph schema version row, treating absent version metadata as legacy v1-compatible. * @returns {Number|null} *

* @summary Reads a JSON request body. * Reads a JSON request body. * @param {http.IncomingMessage} request The incoming HTTP request. * @returns {P

* @summary Async-generates `parsed-chunk-v1` records from a JSONL stream, one record per line. * * Takes the readable stream directly (not a file pa

* Returns the consumer's current Knowledge Base collection record count, or `null` when the * collection / Chroma daemon cannot be reached (treated a

* Reads the per-tenant-repo persisted state map. Missing file = empty map (bootstrap). * * Current per-repo persisted state shape: * ``

* @summary Reads a full process snapshot for parent-chain address discovery. * @param {Object} options * @param {Function} [options.execFile

* @summary Reads one text file from a revision. * @param {Object} options * @returns {Promise<String>} * @private

* Reads source/config/schema identity with async git access for request-time checks. * * @param {Object} options * @param {String} [opt

* Reads source/config/schema identity with sync git access for module boot capture. * * @param {Object} options * @param {String} [opti

* Reads persisted task state, clearing stale in-process fields on boot. * @returns {Object}

* Reads persisted backoff state. Corrupt state degrades gracefully to an * empty backoff map (NOT a crash-loop). Per Sub-ii AC3. * @returns

* Reconciles the locations of closed issues in the active directory. * This handles the case where a new release is created but issues weren't up

* Records completed or dead-lettered outcomes after the agent loop exhausts. * @param {Object} options * @param {String} options.runId

* Records an ISO timestamp as the first/last start boundary. * * @param {Object} ledger * @param {Date} timestamp

* Records the result of startup summarization attempt. * Called by the startup sequence in mcp-server.mjs * @param {string} status One of:

* Records the result of an orchestrator-owned maintenance task. * Called by `Neo.ai.daemons.Orchestrator` after each child-task lifecycle event.

* Recovers an orphaned `.draining` file from a prior drain cycle that crashed between * `rename(queuePath, drainingPath)` and the catch-block res

* Adopts or clears an existing child-task PID file during daemon boot. * @param {String} taskName Task key. * @returns {void}

* Recovers all child task PID files on boot. * @returns {void}

* @module ai/scripts/maintenance/recreateGraphDb

* @summary Force-refetches the given issues from GitHub and rewrites their local markdown. * * Bypasses the delta-sync `updatedAt` gate. Use

* Refills the token bucket based on elapsed time.

* Reflects on the outcome of the cycle. * @param {Object} event * @param {Object} decision (LLM Result) * @param {Object} actionResult

* Re-reads env vars + re-applies runtime overrides on demand — the explicit bounded "refresh" * handle. Call after a deliberate env change the co

*

* @summary Throws a structured policy-refusal error. * * @param {Object} options * @throws {PolicyRefusedError}

* Registers a scroll synchronization between two DOM nodes. * The method is idempotent: calling it multiple times with the same `id` will not cre

* Registers each service & method combination into the collection * @param api

* @param {String} id * @param {WebSocket} ws * @param {String} [appName='Unknown']

* Only needed for SharedWorkers * @param {String} appName * @param {String} windowId

* @param {Object} data

* @summary Receives an OffscreenCanvas directly from the Main Thread. * * This is the receiving end of the "Triangular Communication" patter

* @param {Object} data * @param {String[]} data.chars * @param {String} data.id

*

*

*

* Registers a callback to be executed for a component immediately after its current * VDOM update finishes, but before the next update cycle begi

* @returns {Promise<void>}

* @param {Object} data * @param {Function} callback

* @param {Object} data * @param {String} data.dock * @param {String} data.name * @param {Number} data.size

* Rejects the delayed-reply promise for a DOM operation whose delta application threw. * * Counterpart to {@link #resolveDomOperationPromise

* @param {Object} params * @returns {Object}