PersistMemoryUtils

Utility class for managing memory entry persistence.

Features:

• Memoized storage instances per (signalId, bucketName) pair
• Custom adapter support
• Atomic read/write/remove operations
• Async iteration over stored keys for index rebuilding

Storage layout: ./dump/memory/<signalId>/<bucketName>/<memoryId>.json

Used by MemoryPersistInstance for crash-safe memory persistence.

Constructor

constructor();
Copy

Properties

PersistMemoryInstanceCtor

PersistMemoryInstanceCtor: any
Copy

Constructor used to create per-context memory instances. Replaceable via usePersistMemoryAdapter() / useJson() / useDummy().

getMemoryStorage

getMemoryStorage: any
Copy

Memoized factory creating one IPersistMemoryInstance per (signalId, bucketName) pair.

waitForInit

waitForInit: (signalId: string, bucketName: string, initial: boolean) => Promise<void>
Copy

Initializes the memory storage for the given context. Skips initialization when initial is false (used to gate first-time setup).

readMemoryData

readMemoryData: (signalId: string, bucketName: string, memoryId: string) => Promise<MemoryData>
Copy

Reads a memory entry for the given context and id. Lazily initializes the instance on first access.

hasMemoryData

hasMemoryData: (signalId: string, bucketName: string, memoryId: string) => Promise<boolean>
Copy

Checks whether a memory entry exists on disk for the given context. Lazily initializes the instance on first access.

writeMemoryData

writeMemoryData: (data: MemoryData, signalId: string, bucketName: string, memoryId: string, when: Date) => Promise<void>
Copy

Writes a memory entry for the given context. Lazily initializes the instance on first access.

removeMemoryData

removeMemoryData: (signalId: string, bucketName: string, memoryId: string) => Promise<void>
Copy

Soft-deletes a memory entry for the given context. Lazily initializes the instance on first access.

clear

clear: () => void
Copy

Clears the memoized instance cache. Call when process.cwd() changes between strategy iterations.

dispose

dispose: (signalId: string, bucketName: string) => void
Copy

Drops the memoized instance for the given context. Call when a signal is removed to clean up its associated storage entry.

Methods

usePersistMemoryAdapter

usePersistMemoryAdapter(Ctor: TPersistMemoryInstanceCtor): void;
Copy

Registers a custom IPersistMemoryInstance constructor. Clears the memoization cache so subsequent calls use the new adapter.

listMemoryData

listMemoryData(signalId: string, bucketName: string): AsyncGenerator<{
    memoryId: string;
    data: MemoryData;
}>;
Copy

Iterates all non-removed memory entries for the given context. Used by MemoryPersistInstance to rebuild the BM25 index on init. Lazily initializes the instance on first access.

useJson

useJson(): void;
Copy

Switches to the default file-based PersistMemoryInstance.

useDummy

useDummy(): void;
Copy

Switches to PersistMemoryDummyInstance (all operations are no-ops).