resolveMemoryRemDreamingConfig,

} from "openclaw/plugin-sdk/memory-core-host-status";

import { writeDailyDreamingPhaseBlock } from "./dreaming-markdown.js";

import {

buildNarrativeSessionKey,

generateAndAppendDreamNarrative,

type NarrativePhaseData,

} from "./dreaming-narrative.js";

import { generateAndAppendDreamNarrative, type NarrativePhaseData } from "./dreaming-narrative.js";

import { asRecord, formatErrorMessage, normalizeTrimmedString } from "./dreaming-shared.js";

import {

filterLiveShortTermRecallEntries,

}

}

async function deleteNarrativeSessionBestEffort(

subagent: Parameters<typeof generateAndAppendDreamNarrative>[0]["subagent"],

sessionKey: string,

): Promise<void> {

try {

await subagent.deleteSession({ sessionKey });

} catch {

// Cleanup is best-effort; request-scoped runtimes can throw synchronously.

}

}

export async function runDreamingSweepPhases(params: {

workspaceDir: string;

pluginConfig?: Record<string, unknown>;

nowMs: sweepNowMs,

detachNarratives: params.detachNarratives,

});

// Defensive cleanup: ensure the light-phase narrative session is deleted even if

// generateAndAppendDreamNarrative's primary cleanup was skipped due to an error.

// Skip when narratives are detached: the queued subagent run hasn't read the

// session yet, so eager cleanup would race the writer and silently drop the

// diary entry. The narrative function does its own cleanup in finally{}.

if (params.subagent && !params.detachNarratives) {

const lightSessionKey = buildNarrativeSessionKey({

workspaceDir: params.workspaceDir,

phase: "light",

nowMs: sweepNowMs,

});

await deleteNarrativeSessionBestEffort(params.subagent, lightSessionKey);

}

}

const rem = resolveMemoryRemDreamingConfig({

nowMs: sweepNowMs,

detachNarratives: params.detachNarratives,

});

// Defensive cleanup: ensure the REM-phase narrative session is deleted.

// Skip when narratives are detached (see light-phase comment above).

if (params.subagent && !params.detachNarratives) {

const remSessionKey = buildNarrativeSessionKey({

workspaceDir: params.workspaceDir,

phase: "rem",

nowMs: sweepNowMs,

});

await deleteNarrativeSessionBestEffort(params.subagent, remSessionKey);

}

}

}