PersistStrategyUtils

Utility class for managing deferred strategy state persistence.

Features:

• Memoized storage instances per strategy
• Custom adapter support
• Atomic read/write operations for the deferred state snapshot
• Crash-safe in-flight broker operation state management

Used by ClientStrategy for live mode persistence of the commit queue and deferred user actions (_commitQueue, _closedSignal, _cancelledSignal, _activatedSignal).

Constructor

constructor();
Copy

Properties

PersistStrategyInstanceCtor

PersistStrategyInstanceCtor: any
Copy

Constructor used to create per-context strategy state instances. Replaceable via usePersistStrategyAdapter() / useJson() / useDummy().

getStrategyStorage

getStrategyStorage: any
Copy

Memoized factory creating one IPersistStrategyInstance per (symbol, strategy, exchange) triple.

readStrategyData

readStrategyData: (symbol: string, strategyName: string, exchangeName: string) => Promise<StrategyData>
Copy

Reads persisted deferred strategy state for the given context. Lazily initializes the instance on first access.

writeStrategyData

writeStrategyData: (strategyRow: StrategyData, symbol: string, strategyName: string, exchangeName: string) => Promise<void>
Copy

Writes deferred strategy state (or null to clear) for the given context. Lazily initializes the instance on first access.

Methods

usePersistStrategyAdapter

usePersistStrategyAdapter(Ctor: TPersistStrategyInstanceCtor): void;
Copy

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

clear

clear(): void;
Copy

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

useJson

useJson(): void;
Copy

Switches to the default file-based PersistStrategyInstance.

useDummy

useDummy(): void;
Copy

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