writeBackfillDiaryEntries,

} from "./doctor.memory-core-runtime.js";

import { normalizeTrimmedString } from "./record-shared.js";

import type { GatewayRequestHandlers } from "./types.js";

import type { GatewayRequestContext, GatewayRequestHandlers } from "./types.js";

const MANAGED_DEEP_SLEEP_CRON_NAME = "Memory Dreaming Promotion";

const MANAGED_DEEP_SLEEP_CRON_TAG = "[managed-by=memory-core.short-term-promotion]";

return record.probe === true || record.deep === true;

}

function resolveDoctorMemoryTarget(

context: GatewayRequestContext,

params: unknown,

): {

cfg: OpenClawConfig;

agentId: string;

workspaceDir: string;

} {

const cfg = context.getRuntimeConfig();

const record = asOptionalRecord(params);

const requestedAgentId =

typeof record?.agentId === "string" ? normalizeAgentId(record.agentId) : null;

const agentId = requestedAgentId || resolveDefaultAgentId(cfg);

return {

cfg,

agentId,

workspaceDir: resolveAgentWorkspaceDir(cfg, agentId),

};

}

const SKIPPED_MEMORY_EMBEDDING_PROBE = {

ok: false,

checked: false,

}

},

"doctor.memory.dreamDiary": async ({ respond, context, params }) => {

const cfg = context.getRuntimeConfig();

const requestedAgentId =

typeof params?.agentId === "string" ? normalizeAgentId(params.agentId) : null;

const agentId = requestedAgentId || resolveDefaultAgentId(cfg);

const workspaceDir = resolveAgentWorkspaceDir(cfg, agentId);

const { agentId, workspaceDir } = resolveDoctorMemoryTarget(context, params);

const dreamDiary = await readDreamDiary(workspaceDir);

const payload: DoctorMemoryDreamDiaryPayload = {

agentId,

respond(true, payload, undefined);

},

"doctor.memory.backfillDreamDiary": async ({ respond, context, params }) => {

const cfg = context.getRuntimeConfig();

const requestedAgentId =

typeof params?.agentId === "string" ? normalizeAgentId(params.agentId) : null;

const agentId = requestedAgentId || resolveDefaultAgentId(cfg);

const workspaceDir = resolveAgentWorkspaceDir(cfg, agentId);

const { cfg, agentId, workspaceDir } = resolveDoctorMemoryTarget(context, params);

const memoryDir = path.join(workspaceDir, "memory");

const sourceFiles = await listWorkspaceDailyFiles(memoryDir);

if (sourceFiles.length === 0) {

respond(true, payload, undefined);

},

"doctor.memory.resetDreamDiary": async ({ respond, context, params }) => {

const cfg = context.getRuntimeConfig();

const requestedAgentId =

typeof params?.agentId === "string" ? normalizeAgentId(params.agentId) : null;

const agentId = requestedAgentId || resolveDefaultAgentId(cfg);

const workspaceDir = resolveAgentWorkspaceDir(cfg, agentId);

const { agentId, workspaceDir } = resolveDoctorMemoryTarget(context, params);

const removed = await removeBackfillDiaryEntries({ workspaceDir });

const dreamDiary = await readDreamDiary(workspaceDir);

const payload: DoctorMemoryDreamActionPayload = {

respond(true, payload, undefined);

},

"doctor.memory.resetGroundedShortTerm": async ({ respond, context, params }) => {

const cfg = context.getRuntimeConfig();

const requestedAgentId =

typeof params?.agentId === "string" ? normalizeAgentId(params.agentId) : null;

const agentId = requestedAgentId || resolveDefaultAgentId(cfg);

const workspaceDir = resolveAgentWorkspaceDir(cfg, agentId);

const { agentId, workspaceDir } = resolveDoctorMemoryTarget(context, params);

const removed = await removeGroundedShortTermCandidates({ workspaceDir });

const payload: DoctorMemoryDreamActionPayload = {

agentId,

respond(true, payload, undefined);

},

"doctor.memory.repairDreamingArtifacts": async ({ respond, context, params }) => {

const cfg = context.getRuntimeConfig();

const requestedAgentId =

typeof params?.agentId === "string" ? normalizeAgentId(params.agentId) : null;

const agentId = requestedAgentId || resolveDefaultAgentId(cfg);

const workspaceDir = resolveAgentWorkspaceDir(cfg, agentId);

const { agentId, workspaceDir } = resolveDoctorMemoryTarget(context, params);

const repair = await repairDreamingArtifacts({ workspaceDir });

const payload: DoctorMemoryDreamActionPayload = {

agentId,

respond(true, payload, undefined);

},

"doctor.memory.dedupeDreamDiary": async ({ respond, context, params }) => {

const cfg = context.getRuntimeConfig();

const requestedAgentId =

typeof params?.agentId === "string" ? normalizeAgentId(params.agentId) : null;

const agentId = requestedAgentId || resolveDefaultAgentId(cfg);

const workspaceDir = resolveAgentWorkspaceDir(cfg, agentId);

const { agentId, workspaceDir } = resolveDoctorMemoryTarget(context, params);

const dedupe = await dedupeDreamDiaryEntries({ workspaceDir });

const dreamDiary = await readDreamDiary(workspaceDir);

const payload: DoctorMemoryDreamActionPayload = {