isCronActiveJobMarkerCurrent,

isCronJobActive,

markCronJobActive,

resetCronActiveJobsForTests,

resetCronActiveJobs,

} from "./active-jobs.js";

import { CronService } from "./service.js";

import {

describe("cron activeJobIds — manual-run mark/clear", () => {

beforeEach(() => {

resetCronActiveJobsForTests();

resetCronActiveJobs();

});

afterEach(() => {

expect(isCronActiveJobMarkerCurrent(marker)).toBe(true);

resetCronActiveJobsForTests();

resetCronActiveJobs();

expect(isCronActiveJobMarkerCurrent(marker)).toBe(false);

expect(isCronJobActive("manual-main-cutoff")).toBe(false);

state.activeJobIds?.clear();

notifyActiveCronJobWaitersIfEmpty(state);

}

/** Clears process-global cron active-job state between tests. */

export const resetCronActiveJobsForTests = resetCronActiveJobs;

createReplyOperation,

} from "../auto-reply/reply/reply-run-registry.js";

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

import { markCronJobActive, resetCronActiveJobsForTests } from "../cron/active-jobs.js";

import { markCronJobActive, resetCronActiveJobs } from "../cron/active-jobs.js";

import { getActivePluginRegistry, setActivePluginRegistry } from "../plugins/runtime.js";

import type { CommandLaneSnapshot } from "../process/command-queue.js";

import { CommandLane } from "../process/lanes.js";

beforeEach(() => {

resetSystemEventsForTest();

resetCronActiveJobsForTests();

resetCronActiveJobs();

replyRunRegistryTesting.resetReplyRunRegistry();

});

import { afterEach, beforeEach, describe, expect, it, vi } from "vitest";

import type { AcpSessionStoreEntry } from "../acp/runtime/session-meta.js";

import { startAcpSpawnParentStreamRelay } from "../agents/acp-spawn-parent-stream.js";

import { resetCronActiveJobsForTests } from "../cron/active-jobs.js";

import { resetCronActiveJobs } from "../cron/active-jobs.js";

import {

emitAgentEvent,

registerAgentRunContext,

resetSystemEventsForTest();

resetHeartbeatWakeStateForTests();

resetAgentRunContextForTest();

resetCronActiveJobsForTests();

resetCronActiveJobs();

resetActiveCronTaskRunsForTests();

resetTaskRegistryControlRuntimeForTests();

resetTaskRegistryDeliveryRuntimeForTests();