import type { ConnectorDefinition } from "@market-atlas/connector-sdk";
import { coinbaseWs } from "./coinbase-ws/index.js";
import { krakenWs } from "./kraken-ws/index.js";
import { binanceWs } from "./binance-ws/index.js";
import { okxWs } from "./okx-ws/index.js";
import { cboeDelayedQuotes } from "./cboe-delayed-quotes/index.js";
import { ecbFrankfurter } from "./ecb-frankfurter/index.js";
import { bankOfCanada } from "./bank-of-canada/index.js";
import { usTreasuryYieldCurve } from "./us-treasury-yield-curve/index.js";
import { secEdgarFilings } from "./sec-edgar-filings/index.js";
import { secCompanyTickers } from "./sec-company-tickers/index.js";
import { nasdaqSymbolDirectory } from "./nasdaq-symbol-directory/index.js";
import { nasdaqTradeHalts } from "./nasdaq-trade-halts/index.js";
import { nasdaqMarketCalendar } from "./nasdaq-market-calendar/index.js";
import { hfmarketdata } from "./hfmarketdata/index.js";
import { bitstampWs } from "./bitstamp-ws/index.js";
import { geminiWs } from "./gemini-ws/index.js";
import { bitfinexWs } from "./bitfinex-ws/index.js";
import { bybitWs } from "./bybit-ws/index.js";
import { gateWs } from "./gate-ws/index.js";
import { cryptocomWs } from "./cryptocom-ws/index.js";
import { kucoinWs } from "./kucoin-ws/index.js";
import { nasdaqQuoteApi } from "./nasdaq-quote-api/index.js";

export { SOURCES, sourceById } from "./sources.js";

/**
 * Production connector registry. Order matters slightly: directories first so that quote
 * connectors resolve onto the canonical listed instruments when everything starts cold.
 */
export const CONNECTORS: ConnectorDefinition[] = [
  nasdaqSymbolDirectory,
  secCompanyTickers,
  nasdaqMarketCalendar,
  coinbaseWs,
  krakenWs,
  binanceWs,
  okxWs,
  bitstampWs,
  geminiWs,
  bitfinexWs,
  bybitWs,
  gateWs,
  cryptocomWs,
  kucoinWs,
  cboeDelayedQuotes,
  nasdaqQuoteApi,
  ecbFrankfurter,
  bankOfCanada,
  usTreasuryYieldCurve,
  secEdgarFilings,
  nasdaqTradeHalts,
  hfmarketdata,
];

export const connectorById = (id: string) => CONNECTORS.find((c) => c.metadata.id === id);