Data Sources

enum Source {
    yfinance,  // Yahoo Finance
    binance    // Binance
}

const source = Source.binance
const ticker = "BTCUSDT"  // Bitcoin to USDT pair
const tframe = TFrame.parse("1h")  // 1-hour timeframe
const tzone = "UTC"
const limit = 500  // Number of candles to fetch

await fetchData(source, baseSer, ticker, tframe, tzone, undefined, limit)

const symbols = await fetchSymbolList(
  Source.binance,
  "BTC",  // Filter text (shows pairs containing "BTC")
  init    // RequestInit object
)
// Returns: [{ ticker: "BTCUSDT" }, { ticker: "BTCETH" }, ...]

const source = Source.yfinance
const ticker = "AAPL"  // Apple Inc.
const tframe = TFrame.parse("1D")  // Daily timeframe
const tzone = "America/New_York"
const limit = 300  // Number of periods to fetch

await fetchData(source, baseSer, ticker, tframe, tzone, undefined, limit)

const symbols = await fetchSymbolList(
  Source.yfinance,
  "AAPL",  // Search query
  init
)

fetchData(
  source: Source,        // yfinance or binance
  baseSer: TSer,        // Time series object to populate
  ticker: string,       // Symbol/ticker to fetch
  tframe: TFrame,       // Timeframe (1m, 5m, 1h, 1D, etc.)
  tzone: string,        // Timezone (e.g., "UTC", "America/New_York")
  startTime?: number,   // Optional start time (milliseconds)
  limit?: number        // Optional limit on number of candles
): Promise<number>      // Returns latest candle timestamp

// Sort by time to ensure chronological order
binanceKline.sort((a, b) => a.openTime - b.openTime)

// Remove duplicates based on openTime
const uniqueKlines = binanceKline.filter(
  (kline, index, self) => 
    index === self.findIndex((k) => k.openTime === kline.openTime)
)

const kline = new Kline(
  openTime,   // Open time
  open,       // Open price
  high,       // High price
  low,        // Low price
  close,      // Close price
  volume,     // Volume
  openTime,   // Begin time (same as openTime)
  closeTime,  // End time
  true        // Is occurred (data exists)
)

baseSer.addToVar(KVAR_NAME, kline)

// If API returns undefined, try loading local klines.json
return fetch("./klines.json")
  .then(r => r.json())
  .then(json => {
    for (const k of json) {
      const time = Date.parse(k.Date)
      const kline = new Kline(time, k.Open, k.High, k.Low, k.Close, k.Volume, time, time, true)
      baseSer.addToVar(KVAR_NAME, kline)
    }
  })

const endTime = new Date().getTime()
const backLimitTime = tframe.timeBeforeNTimeframes(endTime, limit, tzone)
startTime = startTime || backLimitTime

import { fetchData, Source } from './lib/domain/DataFecther'
import { TFrame } from './lib/timeseris/TFrame'
import { TSer } from './lib/timeseris/TSer'

// Initialize time series
const baseSer = new TSer()

// Configure request
const source = Source.binance
const ticker = "ETHUSDT"
const tframe = TFrame.parse("1h")
const tzone = "UTC"
const limit = 500

try {
  // Fetch data
  const latestTime = await fetchData(
    source,
    baseSer,
    ticker,
    tframe,
    tzone,
    undefined,
    limit
  )
  
  console.log(`Fetched ${baseSer.size()} candles`)
  console.log(`Latest candle time: ${new Date(latestTime)}`)
  
  // Now baseSer contains all the kline data
  // Ready to display on charts
  
} catch (error) {
  console.error('Failed to fetch data:', error)
  // Handle error appropriately
}