|
|
|
@ -1,12 +1,12 @@
|
|
|
|
|
import type { AggregateDatabase } from "../AggregateDatabase/interfaces.js";
|
|
|
|
|
import { stockDatabase as stockDatabaseClickhouse } from "../stockdb/clickhouse.js";
|
|
|
|
|
import { stockDatabase as stockDatabaseLmdbx } from "../stockdb/lmdbx.js";
|
|
|
|
|
import { stockDatabase as stockDatabaseClickhouse } from "../AggregateDatabase/Stock/clickhouse.js";
|
|
|
|
|
import { stockDatabase as stockDatabaseLmdbx } from "../AggregateDatabase/Stock/lmdbx.js";
|
|
|
|
|
// import { optionContractDatabase as optionContractDatabaseClickhouse } from "../optiondb.clickhouse.js";
|
|
|
|
|
// import { optionContractDatabase as optionContractDatabaseLmdbx } from "../optiondb.lmdbx.js";
|
|
|
|
|
import { nextDate } from "../lib/utils/nextDate.js";
|
|
|
|
|
import { retry, retryOnTimeout } from "../lib/utils/retry.js";
|
|
|
|
|
import type { OptionContractKey } from "../optiondb/interfaces.js";
|
|
|
|
|
import type { StockKey } from "../stockdb/interfaces.js";
|
|
|
|
|
import type { OptionContractKey } from "../AggregateDatabase/OptionContract/interfaces.js";
|
|
|
|
|
import type { StockKey } from "../AggregateDatabase/Stock/interfaces.js";
|
|
|
|
|
|
|
|
|
|
async function syncAggregates<T>({
|
|
|
|
|
fromDatabase,
|
|
|
|
|