/** * 网关内:按 sessionKey 串行派发 + FIFO 排队 + /stop 清队列与租约。 */ import type { OpenClawConfig } from "openclaw/plugin-sdk"; import type { Logger } from "./channel-log.js"; import type { ImStreamClient } from "./connection.js"; import type { BotIdentity, WsMessageParams, XgImConfig } from "./types.js"; import type { AutoRouteResult } from "./auto-model-router.js"; import type { InboundTrigger } from "./inbound-terminal-state.js"; export interface PendingDispatch { route: { sessionKey: string; agentId: string; }; inboundCtx: unknown; params: WsMessageParams; currentIdentity: BotIdentity; agentWorkspaceDir?: string; /** 本条消息单轮模型(OpenClaw replyOptions.modelOverride) */ modelOverride?: string; /** 本条消息单轮推理等级(OpenClaw replyOptions.thinkingLevelOverride;用户显式 /think 时不设) */ thinkingLevelOverride?: string; /** Auto Router 结果元数据(仅日志/监控,不参与 dispatch 语义) */ autoRouteMeta?: AutoRouteResult; /** 入站触发源 */ inboundTrigger?: InboundTrigger; /** /stop:立即交给 OpenClaw;并作废当前会话占用、清空排队 */ skipSessionQueue?: boolean; } export declare function createRunWithSessionQueue(options: { configProvider: () => XgImConfig; log: Logger; logPrefix: string; rt: any; cfgProvider: () => OpenClawConfig; }): (sessionKey: string, pending: PendingDispatch, streamClient: ImStreamClient) => Promise; //# sourceMappingURL=gateway-session-queue.d.ts.map