import fetch from 'node-fetch'
import { fetchAllRows } from './utils/rpc'
import { computeAllRoutes } from '../src'

// Alcor v2 sdk: https://github.com/alcorexchange/alcor-v2-sdk
import { Token, Pool, Trade, CurrencyAmount, Percent } from '../src'

import { asset } from 'eos-common'
import { JsonRpc } from 'eosjs'

export function parseToken(token) {
  return new Token(
    token.contract,
    asset(token.quantity).symbol.precision(),
    asset(token.quantity).symbol.code().to_string()
  )
}

const rpc = new JsonRpc('https://eos-api.alcor.exchange', { fetch });

async function main() {
  const rows = await fetchAllRows(rpc, {
    scope: 'swap.alcor',
    table: 'pools',
    code: 'swap.alcor',
  })

  const pools: Pool[] = []

  // We have to get all pools with fetched ticks for them
  let i = 0
  for (const p of rows) {
    const { id, tokenA, tokenB, currSlot: { sqrtPriceX64, tick } } = p

    const ticks = await fetchAllRows(rpc, {
      scope: id,
      table: 'ticks',
      code: 'swap.alcor',
    })

    if (ticks.length == 0) continue

    pools.push(new Pool({
      ...p as any,
      tokenA: parseToken(tokenA),
      tokenB: parseToken(tokenB),
      sqrtPriceX64,
      tickCurrent: tick,
      ticks: ticks.sort((a: any, b: any) => a.id - b.id)
    }))
    i += 1
    process.stdout.write(`fetching ticks: ${i}/${rows.length} \r`)
  }

  // 1.0000 EOS
  const amountIn = CurrencyAmount.fromRawAmount(new Token('eosio.token', 4, 'EOS'), 1_0000)
  const tokenOut = new Token('tethertether', 4, 'USDT')
  const slippage = new Percent(3, 100) // 0.3%
  const receiver = 'myaccount'

  // First trade sorted by biggest output
  const routes = computeAllRoutes(amountIn.currency, tokenOut, pools, 2)
  const [trade] = Trade.bestTradeExactIn(routes, amountIn, 1)

  const route = trade.route.pools.map(p => p.id)

  const maxSent = trade.inputAmount
  const minReceived = trade.minimumAmountOut(slippage)

  // Memo Format <Service Name>#<Pool ID's>#<Recipient>#<Output Token>#<Deadline>
  const memo = `swapexactin#${route.join(',')}#${receiver}#${minReceived.toExtendedAsset()}#0`

  const result = {
    input: trade.inputAmount.toFixed(),
    output: trade.outputAmount.toFixed(),
    minReceived: minReceived.toFixed(),
    maxSent: maxSent.toFixed(),
    priceImpact: trade.priceImpact.toSignificant(2),
    memo,
    route,
    executionPrice: {
      numerator: trade.executionPrice.numerator.toString(),
      denominator: trade.executionPrice.denominator.toString()
    }
  }

  console.log(result)
}

main()

// {
//   input: '1.0000',
//   output: '1.0314 USDT',
//   minReceived: '1.0013',
//   maxSent: '1.0000',
//   priceImpact: '0.44',
//   memo: 'swapexactin#2#myaccount#1.0013 USDT@tethertether#0',
//   route: [ 2 ],
//   executionPrice: { numerator: '10314', denominator: '10000' }
// }