it("skips isolated cron run transcripts during session ingestion", async () => {

const workspaceDir = await createDreamingWorkspace();

vi.stubEnv("OPENCLAW_TEST_FAST", "1");

vi.stubEnv("OPENCLAW_STATE_DIR", path.join(workspaceDir, ".state"));

setDreamingTestEnv(path.join(workspaceDir, ".state"));

const sessionsDir = resolveSessionTranscriptsDirForAgent("main");

await fs.mkdir(sessionsDir, { recursive: true });

const transcriptPath = path.join(sessionsDir, "cron-run.jsonl");

{ trigger: "heartbeat", workspaceDir },

);

} finally {

vi.unstubAllEnvs();

restoreDreamingTestEnv();

}

await expectPathMissing(

it("drops generated system wrapper text without suppressing paired assistant replies", async () => {

const workspaceDir = await createDreamingWorkspace();

vi.stubEnv("OPENCLAW_TEST_FAST", "1");

vi.stubEnv("OPENCLAW_STATE_DIR", path.join(workspaceDir, ".state"));

setDreamingTestEnv(path.join(workspaceDir, ".state"));

const sessionsDir = resolveSessionTranscriptsDirForAgent("main");

await fs.mkdir(sessionsDir, { recursive: true });

const transcriptPath = path.join(sessionsDir, "ordinary-session.jsonl");

);

} finally {

vi.useRealTimers();

vi.unstubAllEnvs();

restoreDreamingTestEnv();

}

const corpus = await fs.readFile(

it("drops archive, cron, and heartbeat chatter from fresh session corpus output", async () => {

const workspaceDir = await createDreamingWorkspace();

vi.stubEnv("OPENCLAW_TEST_FAST", "1");

vi.stubEnv("OPENCLAW_STATE_DIR", path.join(workspaceDir, ".state"));

setDreamingTestEnv(path.join(workspaceDir, ".state"));

const sessionsDir = resolveSessionTranscriptsDirForAgent("main");

await fs.mkdir(sessionsDir, { recursive: true });

);

} finally {

vi.useRealTimers();

vi.unstubAllEnvs();

restoreDreamingTestEnv();

}

const corpus = await fs.readFile(

it("does not reread unchanged dreaming-generated transcripts after checkpointing skip state", async () => {

const workspaceDir = await createDreamingWorkspace();

vi.stubEnv("OPENCLAW_TEST_FAST", "1");

vi.stubEnv("OPENCLAW_STATE_DIR", path.join(workspaceDir, ".state"));

setDreamingTestEnv(path.join(workspaceDir, ".state"));

const sessionsDir = resolveSessionTranscriptsDirForAgent("main");

await fs.mkdir(sessionsDir, { recursive: true });

const transcriptPath = path.join(sessionsDir, "dreaming-narrative.jsonl");

readFileSpy.mockRestore();

} finally {

vi.restoreAllMocks();

vi.unstubAllEnvs();

restoreDreamingTestEnv();

}

});

it("dedupes reset/deleted session archives instead of double-ingesting", async () => {

const workspaceDir = await createDreamingWorkspace();

vi.stubEnv("OPENCLAW_TEST_FAST", "1");

vi.stubEnv("OPENCLAW_STATE_DIR", path.join(workspaceDir, ".state"));

setDreamingTestEnv(path.join(workspaceDir, ".state"));

const sessionsDir = resolveSessionTranscriptsDirForAgent("main");

await fs.mkdir(sessionsDir, { recursive: true });

const transcriptPath = path.join(sessionsDir, "dreaming-main.jsonl");

await triggerLightDreaming(beforeAgentReply, workspaceDir, 910);

});

} finally {

vi.unstubAllEnvs();

restoreDreamingTestEnv();

}

const ranked = await rankShortTermPromotionCandidates({