PersistCandleInstance

Implements IPersistCandleInstance

Default file-based implementation of IPersistCandleInstance.

Features:

• Each candle stored as a separate JSON file keyed by its timestamp
• Read returns null on any missing timestamp (cache miss → refetch)
• Write skips incomplete candles (closeTime > now) and existing keys
• Invalid cached candles emit warnings via errorEmitter and treated as miss

Constructor

constructor(symbol: string, interval: CandleInterval, exchangeName: string);
Copy

Properties

symbol

symbol: string
Copy

interval

interval: CandleInterval
Copy

exchangeName

exchangeName: string
Copy

_storage

_storage: any
Copy

Underlying file-based storage scoped to this context

Methods

waitForInit

waitForInit(initial: boolean): Promise<void>;
Copy

Initializes the underlying PersistBase storage.

readCandlesData

readCandlesData(limit: number, sinceTimestamp: number, _untilTimestamp: number): Promise<CandleData[] | null>;
Copy

Reads cached candles for the requested window. Computes expected timestamps (sinceTimestamp + i * stepMs) and reads each by timestamp key. Returns null on ANY missing timestamp (cache miss). Invalid cached candles emit a warning via errorEmitter and are treated as miss.

writeCandlesData

writeCandlesData(candles: CandleData[]): Promise<void>;
Copy

Writes candles to cache. Skips incomplete candles (closeTime > now) and existing keys to keep the cache append-only for fully closed candles.