PersistSessionUtils

Utility class for managing session persistence.

Features:

• Memoized storage instances per (strategyName, exchangeName, frameName) key
• Custom adapter support
• Atomic read/write operations

Storage layout: ./dump/session/<strategyName>/<exchangeName>/<frameName>.json

Used by SessionPersistInstance for crash-safe session persistence.

Constructor

constructor();
Copy

Properties

PersistSessionFactory

PersistSessionFactory: any
Copy

getSessionStorage

getSessionStorage: any
Copy

waitForInit

waitForInit: (strategyName: string, exchangeName: string, frameName: string, initial: boolean) => Promise<void>
Copy

Initializes the storage for a given (strategyName, exchangeName, frameName) triple.

readSessionData

readSessionData: (strategyName: string, exchangeName: string, frameName: string) => Promise<SessionData>
Copy

Reads a session entry from persistence storage.

writeSessionData

writeSessionData: (data: SessionData, strategyName: string, exchangeName: string, frameName: string) => Promise<void>
Copy

Writes a session 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: (strategyName: string, exchangeName: string, frameName: string) => void
Copy

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

Methods

usePersistSessionAdapter

usePersistSessionAdapter(Ctor: TPersistBaseCtor<string, SessionData>): void;
Copy

Registers a custom persistence adapter.