// Gateway run-id to session-key resolver.

// Bridges live agent run context with persisted session stores.

import {

asDateTimestampMs,

resolveExpiresAtMsFromDurationMs,

}

let expiresAt: number | null = null;

if (sessionKey === null) {

// Negative caching avoids repeated full-store scans while still allowing

// a just-created run/session pair to appear shortly after the first lookup.

const missExpiresAt = resolveExpiresAtMsFromDurationMs(RUN_LOOKUP_MISS_TTL_MS);

if (missExpiresAt === undefined) {

return;

);

const storeKey = resolvePreferredSessionKeyForSessionIdMatches(matches, runId);

if (storeKey) {

// Return caller-facing agent request keys, not raw store keys, because

// HTTP/RPC clients reuse this value in later session operations.

const sessionKey = resolveRunSessionKeyForCaller(storeKey);

setResolvedSessionKeyCache(runId, cacheAgentId, sessionKey);

return sessionKey;

// Gateway startup logging helpers.

// Produces the compact ready banner with resolved model and safety state.

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

import chalk from "chalk";

import { resolveDefaultAgentId, resolveAgentConfig } from "../agents/agent-scope.js";

// Gateway startup session-store migration runner.

// Keeps old orphaned session keys from surviving process upgrades.

import type { OpenClawConfig } from "../config/types.openclaw.js";

import { migrateOrphanedSessionKeys } from "../infra/state-migrations.js";

// Session patch hook dispatcher.

// Publishes internal mutation notifications after Gateway session patch calls.

import type { SessionsPatchParams } from "../../packages/gateway-protocol/src/index.js";

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

import type { OpenClawConfig } from "../config/types.openclaw.js";

// Gateway session reset/delete service.

// Rotates transcripts and coordinates lifecycle cleanup across runtimes/hooks.

import { randomUUID } from "node:crypto";

import fs from "node:fs";

import path from "node:path";

agentId: string;

}): string {

const currentEntry = params.currentEntry;

// Preserve explicit session-file placement across reset while swapping the

// embedded session id, so linked runtimes keep writing beside old transcripts.

const rewrittenSessionFile = currentEntry?.sessionId

? rewriteSessionFileForNewSessionId({

sessionFile: currentEntry.sessionFile,

}

return {

...entry,

// Reset should keep user selection preferences but drop per-run resolved

// model state so the next turn rehydrates from current config.

model: undefined,

modelProvider: undefined,

contextTokens: undefined,

// Subagent session reactivation helper.

// Replaces completed subagent run records when a user steers the child session.

import { getLatestSubagentRunByChildSessionKey } from "../agents/subagent-registry-read.js";

// Completed subagent sessions can be reactivated after a user steer by replacing

// Gateway session listing and projection helpers.

// Normalizes persisted session stores into UI/RPC rows without mutating state.

import fs from "node:fs";

import path from "node:path";

import {

return undefined;

}

try {

// Avatars can be workspace-relative, but projection must keep the file

// read inside the agent workspace and cap bytes before encoding.

const opened = openRootFileSync({

absolutePath: resolvedCandidate,

rootPath: workspaceRoot,

if (entry.status === "running" || isFinitePositiveTimestamp(entry.startedAt)) {

return true;

}

// Store-only child links lack a live subagent registry entry. Keep recent

// unknown-state rows visible briefly so reloads do not hide fresh children.

return (

isFinitePositiveTimestamp(entry.updatedAt) &&

now - entry.updatedAt <= STALE_STORE_ONLY_CHILD_LINK_MS

// Shared Gateway session projection types.

// Keeps server methods and Control UI payloads aligned.

import type { ChatType } from "../channels/chat-type.js";

import type {

SessionCompactionCheckpoint,

// Ordered Gateway startup task runner.

// Used for best-effort side effects that should not abort the server.

import { formatErrorMessage } from "../infra/errors.js";

// Startup tasks run sequentially so logs and side effects stay ordered during