let5see/clawdbot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Cron: enqueue system events in main session

Browse Source
This commit is contained in:
Sash Zats
2026-01-06 19:55:03 -05:00
parent e816991dc5
commit eb8d7a19af
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/gateway/server.ts
View File

@@ -32,7 +32,11 @@ import {
deriveDefaultBridgePort, deriveDefaultBridgePort,
deriveDefaultCanvasHostPort, deriveDefaultCanvasHostPort,
} from "../config/port-defaults.js"; } from "../config/port-defaults.js";
import { loadSessionStore, resolveStorePath } from "../config/sessions.js"; import {
loadSessionStore,
resolveMainSessionKey,
resolveStorePath,
} from "../config/sessions.js";
import { runCronIsolatedAgentTurn } from "../cron/isolated-agent.js"; import { runCronIsolatedAgentTurn } from "../cron/isolated-agent.js";
import { appendCronRunLog, resolveCronRunLogPath } from "../cron/run-log.js"; import { appendCronRunLog, resolveCronRunLogPath } from "../cron/run-log.js";
import { CronService } from "../cron/service.js"; import { CronService } from "../cron/service.js";
@@ -689,7 +693,9 @@ export async function startGatewayServer(
const cron = new CronService({ const cron = new CronService({
storePath, storePath,
cronEnabled, cronEnabled,
enqueueSystemEvent, enqueueSystemEvent: (text) => {
enqueueSystemEvent(text, { sessionKey: resolveMainSessionKey(cfg) });
},
requestHeartbeatNow, requestHeartbeatNow,
runIsolatedAgentJob: async ({ job, message }) => { runIsolatedAgentJob: async ({ job, message }) => {
const runtimeConfig = loadConfig(); const runtimeConfig = loadConfig();