bitaccess.ts

import {
  asArray,
  asNumber,
  asObject,
  asOptional,
  asString,
  asUnknown,
  asValue
} from 'cleaners'
import crypto from 'crypto'
import fetch from 'node-fetch'

import { PartnerPlugin, PluginParams, PluginResult, StandardTx } from '../types'
import { datelog } from '../util'
import { queryDummy } from './dummy'

const asBitaccessTx = asObject({
  trade_type: asValue<['buy', 'sell']>('buy', 'sell'),
  transaction_id: asString,
  tx_hash: asOptional(asString),
  deposit_address: asString,
  deposit_currency: asString,
  deposit_amount: asNumber,
  location_address: asString,
  withdrawal_address: asOptional(asString),
  withdrawal_currency: asString,
  withdrawal_amount: asNumber,
  updated_at: asString
})

const asBitaccessRawTx = asObject({
  status: asString
})

const asBitaccessResult = asObject({
  result: asArray(asUnknown)
})

const PAGE_LIMIT = 50
const QUERY_LOOKBACK = 60 * 60 * 24 * 5 // 5 days

export async function queryBitaccess(
  pluginParams: PluginParams
): Promise<PluginResult> {
  let lastTimestamp = 0
  if (typeof pluginParams.settings.lastTimestamp === 'number') {
    lastTimestamp = pluginParams.settings.lastTimestamp
  }
  if (
    typeof pluginParams.apiKeys.affiliateId !== 'string' ||
    typeof pluginParams.apiKeys.apiKey !== 'string' ||
    typeof pluginParams.apiKeys.apiSecret !== 'string'
  ) {
    return {
      settings: { lastTimestamp },
      transactions: []
    }
  }

  const standardTxs: StandardTx[] = []
  lastTimestamp -= QUERY_LOOKBACK
  let newestTimestamp = 0
  let page = 1
  let done = false
  while (!done) {
    const requestMethod = 'GET'
    const bodyHash = ''
    const contentType = 'application/json'
    const dateString = new Date().toISOString()
    const sigString = `${requestMethod}\n${bodyHash}\n${contentType}\n${dateString}`
    const signature = crypto
      .createHmac('sha256', pluginParams.apiKeys.apiSecret)
      .update(sigString, 'utf8')
      .digest('base64')
    const options = {
      method: requestMethod,
      headers: {
        Authorization: `HMAC ${pluginParams.apiKeys.apiKey}:${signature}`,
        'x-date': dateString,
        'Content-Type': contentType
      }
    }
    const url = `https://cashapi.bitaccessbtm.com/api/v1/affiliate/${pluginParams.apiKeys.affiliateId}/transactions?limit=${PAGE_LIMIT}&page=${page}`
    try {
      const response = await fetch(url, options)
      const result = asBitaccessResult(await response.json())
      const txs = result.result
      for (const rawTx of txs) {
        if (asBitaccessRawTx(rawTx).status === 'complete') {
          const standardTx = processBitaccessTx(rawTx)
          standardTxs.push(standardTx)

          if (standardTx.timestamp > newestTimestamp) {
            newestTimestamp = standardTx.timestamp
          }
          if (standardTx.timestamp < lastTimestamp) {
            done = true
            break
          }
        }
      }
      if (txs.length < PAGE_LIMIT) {
        break
      }
      page++
    } catch (e) {
      datelog(e)
      throw e
    }
  }

  const out = {
    settings: { lastTimestamp: newestTimestamp },
    transactions: standardTxs
  }
  return out
}

export const bitaccess: PartnerPlugin = {
  // queryFunc will take PluginSettings as arg and return PluginResult
  queryFunc: queryDummy,
  // results in a PluginResult
  pluginName: 'Bitaccess',
  pluginId: 'bitaccess'
}

export function processBitaccessTx(rawTx: unknown): StandardTx {
  const tx = asBitaccessTx(rawTx)
  const timestamp = new Date(tx.updated_at).getTime() / 1000
  let depositTxid
  let payoutTxid
  if (typeof tx.deposit_address === 'string') {
    depositTxid = tx.tx_hash
  }
  if (typeof tx.withdrawal_address === 'string') {
    payoutTxid = tx.tx_hash
  }

  const countryCode = parseLocationAddressForCountryCode(tx.location_address)

  const standardTx: StandardTx = {
    status: 'complete',
    orderId: tx.transaction_id,
    countryCode,
    depositTxid,
    depositAddress: tx.deposit_address,
    depositCurrency: tx.deposit_currency.toUpperCase(),
    depositChainPluginId: undefined,
    depositEvmChainId: undefined,
    depositTokenId: undefined,
    depositAmount: tx.deposit_amount,
    direction: tx.trade_type,
    exchangeType: 'fiat',
    paymentType: 'cash',
    payoutTxid,
    payoutAddress: tx.withdrawal_address,
    payoutCurrency: tx.withdrawal_currency.toUpperCase(),
    payoutChainPluginId: undefined,
    payoutEvmChainId: undefined,
    payoutTokenId: undefined,
    payoutAmount: tx.withdrawal_amount,
    timestamp,
    isoDate: tx.updated_at,
    usdValue: -1,
    rawTx
  }
  return standardTx
}

function parseLocationAddressForCountryCode(location: string): string {
  const parts = location.split(', ')
  if (parts.length !== 4 || parts[3].length > 3) {
    throw new Error(`Unexpected location address: ${location}`)
  }
  return parts[3]
}