// Gateway node connect reconciliation.

// Computes approved runtime surfaces and pending pairing upgrades on reconnect.

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

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

import {

// Gateway pending node-work queue.

// Stores short-lived per-node prompts until connected nodes drain/ack them.

import { randomUUID } from "node:crypto";

import {

asDateTimestampMs,

}

function pruneExpired(state: NodePendingWorkState, nowMs: number): boolean {

// Expiry pruning bumps revision so polling nodes can observe that work changed

// even when no explicit acknowledge call happened.

const validNowMs = asDateTimestampMs(nowMs);

if (validNowMs === undefined) {

return false;

// Gateway node event dispatcher.

// Handles device/node-originated events and routes them to sessions/channels.

import { randomUUID } from "node:crypto";

import {

normalizeLowercaseStringOrEmpty,

fingerprint: string;

now: number;

}): boolean {

// Voice providers can replay identical transcript fragments during reconnect.

// Keep only a bounded last fingerprint per session to avoid duplicate sends.

const previous = recentVoiceTranscripts.get(params.sessionKey);

if (

previous &&

// Gateway node session runtime factory.

// Creates node registry, subscription, and voice-wake fanout state.

import { NodeRegistry, type SerializedEventPayload } from "./node-registry.js";

import {

createSessionEventSubscriberRegistry,

// Gateway node subscription manager.

// Maintains bidirectional node/session fanout indexes.

import { serializeEventPayload, type SerializedEventPayload } from "./node-registry.js";

// Node subscription manager keeps bidirectional node/session indexes so gateway

if (!nodeSet) {

return;

}

// Remove reverse session indexes before deleting the node index so session

// fanout cannot retain disconnected node ids.

for (const sessionKey of nodeSet) {

const sessionSet = sessionSubscribers.get(sessionKey);

sessionSet?.delete(normalizedNodeId);