index.ts

import { parseArgs } from 'util'
import { resolve } from 'path'
import { parse } from 'csv-parse/sync'
import { stringify } from 'csv-stringify/sync'
import { BigNumber } from 'bignumber.js'

async function getInputFile(): Promise<string> {
  const {
    values: { input }
  } = parseArgs({
    args: Bun.argv,
    options: {
      input: {
        type: 'string',
        short: 'i'
      }
    },
    strict: true,
    allowPositionals: true
  })

  if (!input) throw new Error('No file path provided')

  const resolvedPath = resolve(__dirname, input)
  const csvFile = Bun.file(resolvedPath)
  const fileExists = await csvFile.exists()
  if (!fileExists) throw new Error('File does not exist')

  return csvFile.text()
}

try {
  const fileContent = await getInputFile()
  const bybitOrders = parse(fileContent, {
    columns: true,
    skip_empty_lines: true
  })
  const snowballOrders = bybitOrders.map((bybitOrder: any) => {
    if (bybitOrder.Direction !== 'BUY' && bybitOrder.Direction !== 'SELL')
      throw new Error('Invalid direction')
    const pair = bybitOrder['Spot Pairs']
    if (!pair.endsWith('USDT')) throw new Error('Unsupported pair')

    const eventDate = bybitOrder['Timestamp (UTC)'].split(' ')[1]
    let eventSymbol = pair.replace('USDT', '-USD')
    if (eventSymbol === 'TON-USD') eventSymbol = 'TON11419-USD'

    const fees = new BigNumber(bybitOrder['Fees'], 10)

    return {
      Event: bybitOrder.Direction === 'BUY' ? 'Buy' : 'Sell',
      Date: eventDate,
      Symbol: eventSymbol,
      Price: bybitOrder['Filled Price'],
      Quantity: bybitOrder['Filled Quantity'],
      Currency: 'USD',
      FeeTax: fees.multipliedBy(bybitOrder['Filled Price'], 10).toString(10),
      Exchange: 'BYBIT',
      NKD: '',
      FeeCurrency: '',
      DoNotAdjustCash: '',
      Note: `Bybit order ${bybitOrder['Order No.'].trim()}`
    }
  })

  const snowballCSV = stringify(snowballOrders, {
    header: true
  })
  await Bun.file(`snowball-${Date.now()}.csv`).write(snowballCSV)
} catch (err) {
  console.error((err as Error).message)
  process.exit(1)
}