fix(dreaming): use ingestion date for dayBucket instead of file date (#67091)

Merged via squash.

Prepared head SHA: 2df44e4d50
Co-authored-by: Bartok9 <259807879+Bartok9@users.noreply.github.com>
Co-authored-by: jalehman <550978+jalehman@users.noreply.github.com>
Reviewed-by: @jalehman

CHANGELOG.md

@@ -75,6 +75,7 @@ Docs: https://docs.openclaw.ai
 - Matrix/security: block DM pairing-store entries from authorizing room control commands. (#67294) Thanks @pgondhi987.
 - Gateway/security: enforce `localRoots` containment on the webchat audio embedding path. (#67298) Thanks @pgondhi987.
 - Webchat/security: reject remote-host `file://` URLs in the media embedding path. (#67293) Thanks @pgondhi987.
+- Dreaming/memory-core: use the ingestion day, not the source file day, for daily recall dedupe so repeat sweeps of the same daily note can increment `dailyCount` across days instead of stalling at `1`. (#67091) Thanks @Bartok9.
 
 ## 2026.4.14
 

extensions/memory-core/src/dreaming-phases.test.ts

@@ -1648,4 +1648,94 @@ describe("memory-core dreaming phases", () => {
       "The traces braided themselves into a map.",
     );
   });
+
+  it("increments dailyCount when the same daily file is re-ingested on a later day", async () => {
+    // Regression test for #67061: dayBucket used the file date instead of the
+    // ingestion date, so re-ingesting the same file on a different day was
+    // treated as a duplicate and dailyCount stayed at 1.
+    const workspaceDir = await createDreamingWorkspace();
+    // Write a daily note dated 2026-04-03 (two days before the base test time).
+    await fs.writeFile(
+      path.join(workspaceDir, "memory", "2026-04-03.md"),
+      ["# 2026-04-03", "", "- Move backups to S3 Glacier.", "- Keep retention at 365 days."].join(
+        "\n",
+      ),
+      "utf-8",
+    );
+
+    const configForTest: OpenClawConfig = {
+      plugins: {
+        entries: {
+          "memory-core": {
+            config: {
+              dreaming: {
+                enabled: true,
+                phases: {
+                  light: {
+                    enabled: true,
+                    limit: 20,
+                    lookbackDays: 7,
+                  },
+                },
+              },
+            },
+          },
+        },
+      },
+    };
+
+    // First ingestion on 2026-04-05.
+    const day1Ms = Date.parse("2026-04-05T10:00:00.000Z");
+    const { beforeAgentReply: reply1 } = createHarness(configForTest, workspaceDir);
+    await withDreamingTestClock(async () => {
+      vi.setSystemTime(new Date(day1Ms));
+      await reply1(
+        { cleanedBody: "__openclaw_memory_core_light_sleep__" },
+        { trigger: "heartbeat", workspaceDir },
+      );
+    });
+
+    const after1 = await rankShortTermPromotionCandidates({
+      workspaceDir,
+      minScore: 0,
+      minRecallCount: 0,
+      minUniqueQueries: 0,
+      nowMs: day1Ms,
+    });
+    expect(after1).toHaveLength(1);
+    expect(after1[0]?.dailyCount).toBe(1);
+
+    // Clear the daily ingestion checkpoint so the file is re-read on the second
+    // sweep (simulating a new day where the same lookback window still covers
+    // this file).
+    const dailyStatePath = path.join(workspaceDir, "memory", ".dreams", "daily-ingestion.json");
+    try {
+      await fs.unlink(dailyStatePath);
+    } catch {
+      // ignore if not created
+    }
+
+    // Second ingestion on 2026-04-06 (next day).
+    const day2Ms = Date.parse("2026-04-06T10:00:00.000Z");
+    const { beforeAgentReply: reply2 } = createHarness(configForTest, workspaceDir);
+    await withDreamingTestClock(async () => {
+      vi.setSystemTime(new Date(day2Ms));
+      await reply2(
+        { cleanedBody: "__openclaw_memory_core_light_sleep__" },
+        { trigger: "heartbeat", workspaceDir },
+      );
+    });
+
+    const after2 = await rankShortTermPromotionCandidates({
+      workspaceDir,
+      minScore: 0,
+      minRecallCount: 0,
+      minUniqueQueries: 0,
+      nowMs: day2Ms,
+    });
+    expect(after2).toHaveLength(1);
+    // With the fix, dailyCount should be 2 because the ingestion date changed.
+    // Before the fix, it stayed at 1 because dayBucket was the file date.
+    expect(after2[0]?.dailyCount).toBe(2);
+  });
 });

extensions/memory-core/src/dreaming-phases.ts

@@ -954,6 +954,7 @@ async function ingestSessionTranscriptSignals(params: {
     timezone: params.timezone,
     state,
   });
+  const ingestionDayBucket = formatMemoryDreamingDay(params.nowMs, params.timezone);
   for (const batch of collected.batches) {
     await recordShortTermRecalls({
       workspaceDir: params.workspaceDir,
@@ -961,7 +962,7 @@ async function ingestSessionTranscriptSignals(params: {
       results: batch.results,
       signalType: "daily",
       dedupeByQueryPerDay: true,
-      dayBucket: batch.day,
+      dayBucket: ingestionDayBucket,
       nowMs: params.nowMs,
       timezone: params.timezone,
     });
@@ -1113,6 +1114,7 @@ async function ingestDailyMemorySignals(params: {
     nowMs: params.nowMs,
     state,
   });
+  const ingestionDayBucket = formatMemoryDreamingDay(params.nowMs, params.timezone);
   for (const batch of collected.batches) {
     await recordShortTermRecalls({
       workspaceDir: params.workspaceDir,
@@ -1120,7 +1122,7 @@ async function ingestDailyMemorySignals(params: {
       results: batch.results,
       signalType: "daily",
       dedupeByQueryPerDay: true,
-      dayBucket: batch.day,
+      dayBucket: ingestionDayBucket,
       nowMs: params.nowMs,
       timezone: params.timezone,
     });
@@ -1222,7 +1224,7 @@ export async function seedHistoricalDailyMemorySignals(params: {
       results,
       signalType: "daily",
       dedupeByQueryPerDay: true,
-      dayBucket: entry.day,
+      dayBucket: formatMemoryDreamingDay(params.nowMs, params.timezone),
       nowMs: params.nowMs,
       timezone: params.timezone,
     });