PersistStateUtils

Utility class for managing state persistence.

Features:

• Memoized storage instances per (signalId, bucketName) pair
• Custom adapter support
• Atomic read/write operations

Storage layout: ./dump/state/<signalId>/<bucketName>.json

Used by StatePersistInstance for crash-safe state persistence.

Constructor

constructor();
Copy

Properties

PersistStateFactory

PersistStateFactory: any
Copy

getStateStorage

getStateStorage: any
Copy

waitForInit

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

Initializes the storage for a given (signalId, bucketName) pair.

readStateData

readStateData: (signalId: string, bucketName: string) => Promise<StateData>
Copy

Reads a state entry from persistence storage.

writeStateData

writeStateData: (data: StateData, signalId: string, bucketName: string) => Promise<void>
Copy

Writes a state entry to disk with atomic file writes.

useDummy

useDummy: () => void
Copy

Switches to a dummy persist adapter that discards all writes. All future persistence writes will be no-ops.

useJson

useJson: () => void
Copy

Switches to the default JSON persist adapter. All future persistence writes will use JSON storage.

clear

clear: () => void
Copy

Clears the memoized storage cache. Call this when process.cwd() changes between strategy iterations so new storage instances are created with the updated base path.

dispose

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

Disposes of the state adapter and releases any resources. Call this when a signal is removed to clean up its associated storage.

Methods

usePersistStateAdapter

usePersistStateAdapter(Ctor: TPersistBaseCtor<string, StateData>): void;
Copy

Registers a custom persistence adapter.