RecentAdapter

Main recent signal adapter that manages both backtest and live recent signal storage.

Features:

• Subscribes to activePingSubject for automatic storage updates
• Provides unified access to the latest signal for any context
• Singleshot enable pattern prevents duplicate subscriptions
• Cleanup function for proper unsubscription

Constructor

constructor();
Copy

Properties

enable

enable: (() => (...args: any[]) => any) & ISingleshotClearable<() => (...args: any[]) => any>
Copy

Enables recent signal storage by subscribing to activePingSubject. Uses singleshot to ensure one-time subscription.

disable

disable: () => void
Copy

Disables recent signal storage by unsubscribing from all emitters. Safe to call multiple times.

getLatestSignal

getLatestSignal: (symbol: string, context: { strategyName: string; exchangeName: string; frameName: string; }, when: Date) => Promise<IPublicSignalRow>
Copy

Retrieves the latest active signal for the given symbol and context. Searches backtest storage first, then live storage. Returns null if the stored signal's timestamp is greater than the requested when (look-ahead bias protection).

getMinutesSinceLatestSignalCreated

getMinutesSinceLatestSignalCreated: (symbol: string, context: { strategyName: string; exchangeName: string; frameName: string; }, when: Date) => Promise<number>
Copy

Returns the number of whole minutes elapsed since the latest signal's creation timestamp. Searches backtest storage first, then live storage. when doubles as the look-ahead cutoff — a signal whose timestamp exceeds when.getTime() is treated as not yet visible — and as the "now" against which elapsed minutes are computed.