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; }) => Promise<IPublicSignalRow>
Copy

Retrieves the latest active signal for the given symbol and context. Searches backtest storage first, then live storage.

getMinutesSinceLatestSignalCreated

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

Returns the number of whole minutes elapsed since the latest signal's creation timestamp. Searches backtest storage first, then live storage.