// Gateway chat/agent abort tracking.

// Registers active run abort controllers and projects in-flight chat state.

import {

asDateTimestampMs,

resolveDateTimestampMs,

};

if (!params.sessionKey || params.chatAbortControllers.has(params.runId)) {

// Duplicate run ids keep their fresh controller for caller cancellation, but

// do not replace the registered entry that owns active-run projection.

return { controller, registered: false, cleanup };

}

// OpenResponses output item factories.

// Keeps assistant/function-call output assembly in schema-compatible shapes.

import type { OutputItem } from "./open-responses.schema.js";

// Small OpenResponses output factories keep streamed assistant/function-call

// Gateway WebSocket broadcaster.

// Applies event scope guards and slow-consumer handling before sending frames.

import { logRejectedLargePayload } from "../logging/diagnostic-payload.js";

import {

ADMIN_SCOPE,

const NODE_ALLOWED_EVENTS = new Set<string>(["voicewake.changed", "voicewake.routing.changed"]);

function serializeFrameField(name: "payload" | "stateVersion", value: unknown): string {

// Serialize one field through JSON.stringify so embedded values keep JSON

// escaping, then splice it into the shared per-client frame body.

const fieldJSON = JSON.stringify({ [name]: value });

const keyJSON = JSON.stringify(name);

const prefix = `{${keyJSON}:`;

// Gateway session child-discovery helpers.

// Finds direct parent/child relationships across canonical and legacy fields.

import { normalizeOptionalString } from "@openclaw/normalization-core/string-coerce";

import { loadCombinedSessionStoreForGateway } from "../config/sessions/combined-store-gateway.js";

import type { SessionEntry } from "../config/sessions/types.js";

// Gateway session-history projection state.

// Tracks transcript sequence windows for paginated chat-history SSE updates.

import { asPositiveSafeInteger } from "@openclaw/normalization-core/number-coercion";

import {

DEFAULT_CHAT_HISTORY_TEXT_MAX_CHARS,

limit: number | undefined,

cursor: string | undefined,

): PaginatedSessionHistory {

// Cursors point at transcript sequence watermarks. The returned page is the

// window before that cursor, matching "older messages" pagination.

const cursorSeq = resolveCursorSeq(cursor);

let endExclusive = messages.length;

if (typeof cursorSeq === "number") {

// Gateway session lifecycle state projection.

// Converts agent run lifecycle events into session row/store status updates.

import {

buildAgentRunTerminalOutcome,

type AgentRunTerminalOutcome,

const existing = params.session ?? undefined;

if (phase === "start") {

// A start event clears terminal fields from the previous run so UI rows do

// not show stale runtime/end state while the new run is active.

const startedAt = resolveLifecycleStartedAt(existing?.startedAt, params.event);

const updatedAt = startedAt ?? existing?.updatedAt;

return {

// Gateway sessions.resolve implementation helper.

// Resolves key/sessionId/label selectors into one canonical session key.

import { normalizeOptionalString } from "@openclaw/normalization-core/string-coerce";

import {

ErrorCodes,

}

if (hasKey) {

// Key lookups may hit legacy store aliases. Migrate/prune before returning

// the canonical key so later calls operate on one store identity.

const target = resolveGatewaySessionStoreTarget({ cfg, key });

const store = loadSessionStore(target.storePath);

if (store[target.canonicalKey]) {

}

if (hasSessionId) {

// sessionId can collide across stores; delegate selection so exact key

// matches and ambiguity rules stay shared with other session-id callers.

const { store } = loadCombinedSessionStoreForGateway(cfg, { agentId: p.agentId });

const matches = findVisibleSessionIdMatches({ cfg, store, p, sessionId });

const selection = resolveSessionIdMatchSelection(matches, sessionId);

// Gateway WebSocket log formatting.

// Redacts and compacts request/response/event metadata for console diagnostics.

import { readStringValue } from "@openclaw/normalization-core/string-coerce";

import chalk from "chalk";

import { resolveSendableOutboundReplyParts } from "openclaw/plugin-sdk/reply-payload";

return restMeta;

}

for (const [key, value] of Object.entries(meta)) {

// Core frame fields are rendered elsewhere; this loop only emits extra

// metadata so logs stay compact and stable.

if (value === undefined) {

continue;

}