fix(memory): use session corpus listing for status-mode dirty detection

liuhao1024 · liuhao1024 · commit 7727c4b68878 · 2026-07-03T03:10:12.000+08:00
Replace resolveSessionTranscriptsDirForAgent + readdirSync with
listSessionTranscriptCorpusEntriesForAgentSync so the status-mode
dirty check respects configured/fixed custom session stores and
ownership filtering, matching the async startup catch-up path.

Export listSessionTranscriptCorpusEntriesForAgentSync through the
memory-host-sdk and plugin-sdk barrels.
diff --git a/extensions/memory-core/src/memory/manager-sync-ops.ts b/extensions/memory-core/src/memory/manager-sync-ops.ts
@@ -22,6 +22,7 @@ import {
   isUsageCountedSessionTranscriptFileName,
   listSessionFilesForAgent,
   listSessionTranscriptCorpusEntriesForAgent,
+  listSessionTranscriptCorpusEntriesForAgentSync,
   parseCanonicalSessionSyncTargetFromPath,
   resolveSessionFileForSyncTarget,
   sessionPathForFile,
@@ -1501,33 +1502,35 @@ export abstract class MemoryManagerSyncOps {
    * initialization. Sets sessionsDirty when on-disk session files have no
    * corresponding memory_index_sources rows, so plain `memory status`
    * reports accurate dirty state without performing a full sync.
+   *
+   * Uses the session corpus listing (same contract as startup catch-up) so
+   * configured/fixed custom session stores and ownership filtering are respected.
    */
   protected detectSessionStartupDirtySync(): void {
     if (!this.sources.has("sessions")) {
       return;
     }
     try {
-      const sessionsDir = resolveSessionTranscriptsDirForAgent(this.agentId);
-      if (!fsSync.existsSync(sessionsDir)) {
+      const corpusEntries = listSessionTranscriptCorpusEntriesForAgentSync(this.agentId);
+      if (corpusEntries.length === 0) {
         return;
       }
-      const entries = fsSync.readdirSync(sessionsDir, { withFileTypes: true });
       const sessionFiles: MemorySessionStartupFileState[] = [];
-      for (const entry of entries) {
-        if (!entry.isFile() || !isUsageCountedSessionTranscriptFileName(entry.name)) {
-          continue;
-        }
-        const absPath = path.join(sessionsDir, entry.name);
+      for (const entry of corpusEntries) {
+        const absPath = entry.sessionFile;
         try {
           const stat = fsSync.statSync(absPath);
+          if (!stat.isFile()) {
+            continue;
+          }
           sessionFiles.push({
             absPath,
             path: sessionPathForFile(absPath),
             mtimeMs: stat.mtimeMs,
             size: stat.size,
           });
         } catch {
-          // File may have been deleted between readdir and stat; skip.
+          // File may have been deleted between corpus listing and stat; skip.
         }
       }
       if (sessionFiles.length === 0) {
diff --git a/packages/memory-host-sdk/src/engine-qmd.ts b/packages/memory-host-sdk/src/engine-qmd.ts
@@ -5,6 +5,7 @@ export {
   buildSessionEntry,
   listSessionFilesForAgent,
   listSessionTranscriptCorpusEntriesForAgent,
+  listSessionTranscriptCorpusEntriesForAgentSync,
   loadDreamingNarrativeTranscriptPathSetForAgent,
   loadSessionTranscriptClassificationForAgent,
   normalizeSessionTranscriptPathForComparison,
diff --git a/packages/memory-host-sdk/src/host/session-files.ts b/packages/memory-host-sdk/src/host/session-files.ts
@@ -31,6 +31,7 @@ import type { MemorySessionSyncTarget } from "./types.js";
 
 export {
   listSessionTranscriptCorpusEntriesForAgent,
+  listSessionTranscriptCorpusEntriesForAgentSync,
   type SessionTranscriptCorpusArtifactKind,
   type SessionTranscriptCorpusEntry,
 } from "./session-transcript-corpus.js";
