mirror of
https://github.com/openclaw/openclaw.git
synced 2026-05-06 10:10:45 +00:00
91 lines
3.0 KiB
TypeScript
91 lines
3.0 KiB
TypeScript
import crypto from "node:crypto";
|
|
import { clearBootstrapSnapshotOnSessionRollover } from "../../agents/bootstrap-cache.js";
|
|
import { resolveStorePath } from "../../config/sessions/paths.js";
|
|
import {
|
|
evaluateSessionFreshness,
|
|
resolveSessionResetPolicy,
|
|
} from "../../config/sessions/reset.js";
|
|
import { loadSessionStore } from "../../config/sessions/store.js";
|
|
import type { SessionEntry } from "../../config/sessions/types.js";
|
|
import type { OpenClawConfig } from "../../config/types.openclaw.js";
|
|
|
|
export function resolveCronSession(params: {
|
|
cfg: OpenClawConfig;
|
|
sessionKey: string;
|
|
nowMs: number;
|
|
agentId: string;
|
|
forceNew?: boolean;
|
|
}) {
|
|
const sessionCfg = params.cfg.session;
|
|
const storePath = resolveStorePath(sessionCfg?.store, {
|
|
agentId: params.agentId,
|
|
});
|
|
const store = loadSessionStore(storePath);
|
|
const entry = store[params.sessionKey];
|
|
|
|
// Check if we can reuse an existing session
|
|
let sessionId: string;
|
|
let isNewSession: boolean;
|
|
let systemSent: boolean;
|
|
|
|
if (!params.forceNew && entry?.sessionId) {
|
|
// Evaluate freshness using the configured reset policy
|
|
// Cron/webhook sessions use "direct" reset type (1:1 conversation style)
|
|
const resetPolicy = resolveSessionResetPolicy({
|
|
sessionCfg,
|
|
resetType: "direct",
|
|
});
|
|
const freshness = evaluateSessionFreshness({
|
|
updatedAt: entry.updatedAt,
|
|
now: params.nowMs,
|
|
policy: resetPolicy,
|
|
});
|
|
|
|
if (freshness.fresh) {
|
|
// Reuse existing session
|
|
sessionId = entry.sessionId;
|
|
isNewSession = false;
|
|
systemSent = entry.systemSent ?? false;
|
|
} else {
|
|
// Session expired, create new
|
|
sessionId = crypto.randomUUID();
|
|
isNewSession = true;
|
|
systemSent = false;
|
|
}
|
|
} else {
|
|
// No existing session or forced new
|
|
sessionId = crypto.randomUUID();
|
|
isNewSession = true;
|
|
systemSent = false;
|
|
}
|
|
|
|
clearBootstrapSnapshotOnSessionRollover({
|
|
sessionKey: params.sessionKey,
|
|
previousSessionId: isNewSession ? entry?.sessionId : undefined,
|
|
});
|
|
|
|
const sessionEntry: SessionEntry = {
|
|
// Preserve existing per-session overrides even when rolling to a new sessionId.
|
|
...entry,
|
|
// Always update these core fields
|
|
sessionId,
|
|
updatedAt: params.nowMs,
|
|
systemSent,
|
|
// When starting a fresh session (forceNew / isolated), clear delivery routing
|
|
// state inherited from prior sessions. Without this, lastThreadId leaks into
|
|
// the new session and causes announce-mode cron deliveries to post as thread
|
|
// replies instead of channel top-level messages.
|
|
// deliveryContext must also be cleared because normalizeSessionEntryDelivery
|
|
// repopulates lastThreadId from deliveryContext.threadId on store writes.
|
|
...(isNewSession && {
|
|
lastChannel: undefined,
|
|
lastTo: undefined,
|
|
lastAccountId: undefined,
|
|
lastThreadId: undefined,
|
|
deliveryContext: undefined,
|
|
sessionFile: undefined,
|
|
}),
|
|
};
|
|
return { storePath, store, sessionEntry, systemSent, isNewSession };
|
|
}
|