* Queues a low-latency summarization marker for a disconnected session. * * @summary Writes an idempotent `pending` SummarizationJobs row wi

* Reads a repository file as UTF-8. * @param {String} root Repository root. * @param {String} relPath Repository-relative path. * @returns {String}

* @summary Enforces a single live process for a port-owning ("singleton") task by * SIGKILLing any extra listeners on its port. * * The

* Reconciles rich profile records that are missing from the tracker queue. * * @summary Restores refresh scheduling for rich users without b

* @param {Object} options * @param {String} options.taskName Deferred task name. * @param {String} options.reasonCode Discriminator field.

* @param {Object} data * @param {Array|String} data.cls * @param {String} data.name

* Convenience method to combine add & remove in one call. * You can pass single items or an array of items to add or to remove. * @param {Ar

* Clears the item array * @param {Boolean} destroyItems=true * @param {Boolean} silent=false

* There should be max 1 node (resize handle) at any given time. * see: /issues/1139

* Removes a container item at a given index. * * @param {Number} index * @param {Boolean} destroyItem=true * @param {Boolean} sile

* Main animation loop for the "Living Sparklines" effect. * Implements a "Sparse Animation" strategy: * - Only animates a few items at a tim

* @summary Runs one REM observability axis probe with zero-value fallback. * * The MCP surface is operator-facing diagnostics, not a scheduling inpu

* @summary Resolves the authoritative tenant context for the ingest call. * @param {Object} payload Ingestion payload. * @returns {{tenantId

* Resolves the effective `tenantRepos` across all tenants via the tiered resolver * `KnowledgeBaseIngestionService.listConfiguredTenantRepos` (gr

* Round numeric output so small sample summaries do not expose floating-point noise. * * @param {number} value * @param {number} [decimals=3] * @r

* Runs `node <root>/ai/scripts/setup/initServerConfigs.mjs --migrate-config` from the * pulled checkout to reconcile the gitignored `config.mjs`

* @summary Batches an async stream of parsed records and ingests each batch, aggregating a summary. * * Pure orchestration: `ingestFn` is injected s

* @summary Safely serializes a value for durable telemetry storage. * @param {*} value Value to encode. * @returns {String} * @protecte

* You can either pass the id or a querySelector * @param {Object} data * @param {String} [data.id] * @param {String} data.behavior='smo

* A silent version of set(), which does not trigger a vdom update at the end. * Useful for batching multiple config changes. * @param {Objec

* @summary Spawn a child process and (optionally) record its PID for later harness cleanup. * * When `identity` is provided, the spawned PID is pers

* @param {String} id=this.id

* Toggles the expansion state of a node. * @param {String|Number} nodeId

* Build a unique per-test handoff file path under the OS tmpdir. Caller must * `await mkdir(tmpRoot, {recursive: true})` before `writeFile`. * * @p

* Removes the component DOM

* @returns {Promise<void>}

* Unregisters an async operation. * @param {Number|Symbol} id - The unique ID for the async operation.

* Removes a component's update from the "in-flight" registry. This is called after * the VDOM worker confirms the update has been processed.

* @param {Object} data

* Convenience shortcut * @returns {Object}

* @param {Boolean} silent=false

* Updates the Tracker Index with new states or timestamps. * * Handles three types of operations based on the input: * 1. **Insert (Di

* @summary Validates parsed CLI args before network work begins. * @param {Object} args Parsed CLI args. * @returns {String[]} Human-readable valida

* Validates whether a session ID is in a state safe for the agent to resume by reconnecting * with that session ID in their `Mcp-Session-Id` head

* Verifies if the event target (or a delegate matching node) is a descendant of the listener's component. * This check supports two modes: *

* Convenience wrapper for the Discussion syncer's required key set. Centralizes the * "what counts as a complete Discussion frontmatter" contract so

* Writes a JSONL file in the per-test tmp dir from an array of records. * Returns the absolute file path.

* Writes a fake issue markdown file into the temp issues dir. Always includes YAML * frontmatter + a body long enough to exceed MIN_SOURCE_LENGTH

* Appends a daemon log line to disk and mirrors it to stdout/stderr. * @param {String} level Log level. * @param {String} message Log messag

* @summary Builds the structured error response for a GitLab API/transport failure. * @param {Error} error * @param {String} context Human-

* Re-asserts env precedence: for each registered env-bound leaf, the value is the runtime * override (keyed by env var name) if present, else the

* Determines the correct local file path for a given issue based on its state (OPEN/CLOSED), * labels (dropped), and milestone or closed date (fo

* @summary Pre-computes bucket counts and indices for all active and archived issues. * @param {Object} metadata The sync metadata. * @param

* @summary Parses a SQLite Nodes row that should contain a WAKE_SUBSCRIPTION graph node. * * Malformed historical rows are ignored rather th

* @summary Advances the in-process GraphLog cursor and mirrors it to an operator-readable file. * * The file is the durable watermark consum

* Either a string like 'color: red; background-color: blue;' * or an object containing style attributes * @param {String|Object} value

* Resolves the 24:00 issue, where an event would end on the next day * @param {Date} date * @returns {Date}

* Triggered after the rowHeight config got changed * @param {Number} value * @param {Number} oldValue * @protected

* Re-calculates and applies pinning offsets based on the actual scroll position * minus the worker's last known scroll position. * * **

* Receiver-side archive. Hides the message from the default `listMessages` view without * deleting it — opt-in surfacing via `listMessages({inclu

* Wraps an array as an async iterable for `runIngest`'s `records` parameter. * @param {Array} entries * @returns {AsyncIterable}

* Helper method to copy routing information (appName, port, windowId) from a source message to a target message. * This is crucial in SharedWorke

* Mounting a map into an inactive tab and activating it should call this * @param {Object} data * @param {String} data.id

* @summary Backfills compact per-turn summaries for existing `AGENT_MEMORY` graph rows. * * Mirrors the inline {@link addMemory} enrichment

* Builds a synthetic graph JSONL file with the given nodes/edges. * Returns the directory path containing the file.

* @summary Recursively builds a Zod schema from an OpenAPI schema object. * * The OpenAPI-to-Zod bridge is the Agent OS tool-shape compiler. It must

* @param {Object} data * @param {Neo.button.Base} data.column * @param {Number} data.columnIndex * @param {S

* @param {String} layerId * @param {String} visibility

* @param {String} layerId * @param {String} visibility

* @summary Returns true when JSON serialization differs after identity metadata rewrite. * @param {*} before Source value. * @param {*} after Rewrit

* @summary Given a source file path, returns the concepts it implements. * Performs reverse lookup on `IMPLEMENTED_BY` edges. * * @para

* Clear all per-subscription state without dispatching. Used for tests. * @returns {void}

* Clears the health check cache, forcing the next call to perform a fresh check. * * Intent: This is primarily useful for testing and debugg

* Clears one or multiple setTimeout call(s) * @param {String[]|String} timers valid values: dismiss, hide, show

* Collapses all folders * @param {Boolean} [silent]=false Set silent to true to prevent a vnode update

* Collects all routes (top-level + content routes). * @returns {Promise<Array<{id: String, filePath: String|null}>>}

* @param {Object[]} rows * @param {Function} getKeys * @returns {Object[]}