# frozen_string_literal: true

require('openssl')
require('base64')
require('curb')
require('json')

# @author Hernani Rodrigues Vaz
module Cns
  DC = %w[LTC NMC PPC DOGE XRP Linden USD CAD GBP ZEC BCH EURN NOKU FDZ GUSD SEED USDC].freeze

  # classe para acesso dados centralized exchanges
  class Apice
    # @example account_de
    #  {
    #    data: {
    #      balances: {
    #        btc: { total_amount: '0.00000000000000000000', available_amount: '0', reserved_amount: '0' },
    #        bch: { total_amount: '0.00000000000000000000', available_amount: '0', reserved_amount: '0' },
    #        btg: { total_amount: '0.00000000000000000000', available_amount: '0', reserved_amount: '0' },
    #        eth: { total_amount: '0.00000000000000000000', available_amount: '0', reserved_amount: '0' },
    #        bsv: { total_amount: '0.00000000000000000000', available_amount: '0', reserved_amount: '0' },
    #        ltc: { total_amount: '0.00000000000000000000', available_amount: '0', reserved_amount: '0' }
    #      },
    #      encrypted_information: { uid: '0y...', bic_short: '0y...', bic_full: '0y...' }
    #    },
    #    errors: [],
    #    credits: 23
    #  }
    # @param [String] uri Uniform Resource Identifier do pedido HTTP
    # @return [Hash] saldos no bitcoinde
    def account_de(uri = 'https://api.bitcoin.de/v4/account')
      JSON.parse(
        Curl.get(uri) { |obj| obj.headers = hde(uri) }.body,
        symbolize_names: true
      )[:data][:balances]
    rescue StandardError
      {}
    end

    # @example account_fr
    #  {
    #    name: '...',
    #    email: '...',
    #    locale: 'en',
    #    channel_id: '...',
    #    meta_state: 'approved',
    #    balance_eur: '0.0',
    #    locked_eur: '0.0',
    #    balance_btc: '0.0',
    #    locked_btc: '0.0',
    #    balance_lbtc: '0.0',
    #    locked_lbtc: '0.0'
    #  }
    # @param (see account_de)
    # @return [Hash] saldos no paymium
    def account_fr(uri = 'https://paymium.com/api/v1/user')
      JSON.parse(
        Curl.get(uri) { |obj| obj.headers = hfr(uri) }.body,
        symbolize_names: true
      )
    rescue StandardError
      {}
    end

    # @example account_mt
    #  {
    #    balances: [
    #      { currency: 'BTC', balance: 0.0, trading_balance: 0.0 },
    #      { currency: 'ETH', balance: 0.0, trading_balance: 0.0 },
    #      { currency: 'EUR', balance: 0.0, trading_balance: 0.0 },
    #      { currency: 'DAI', balance: 0.0, trading_balance: 0.0 },
    #    ]
    #  }
    # @param (see account_de)
    # @return [Array<Hash>] lista saldos no therock
    def account_mt(uri = 'https://api.therocktrading.com/v1/balances')
      JSON.parse(
        Curl.get(uri) { |obj| obj.headers = hmt(uri) }.body,
        symbolize_names: true
      )[:balances]
          .delete_if { |del| DC.include?(del[:currency]) }
          .sort { |oba, obb| oba[:currency] <=> obb[:currency] }
    rescue StandardError
      []
    end

    # @example account_us
    #  {
    #   error: [],
    #   result: {
    #     ZEUR: '0.0038',
    #     XXBT: '0.0000000000',
    #     XETH: '1.0000000000',
    #     XETC: '0.0000000000',
    #     EOS: '0.0000001700',
    #     BCH: '0.0000000000'
    #   }
    #  }
    # @param [String] urb Uniform Resource Base do pedido HTTP
    # @param uri (see account_de)
    # @param non (see hde)
    # @return [Hash] saldos no kraken
    def account_us(urb = 'https://api.kraken.com/0/private', uri = 'Balance', non = nnc)
      JSON.parse(
        Curl.post("#{urb}/#{uri}", nonce: non) { |obj| obj.headers = hus(uri, nonce: non) }.body,
        symbolize_names: true
      )[:result]
    rescue StandardError
      {}
    end

    # @example trades_de
    #  {
    #    trades: [{
    #      trade_id: 'XUWWD3',
    #      trading_pair: 'btceur',
    #      is_external_wallet_trade: false,
    #      type: 'sell',
    #      amount_currency_to_trade: '0.1',
    #      price: 430,
    #      volume_currency_to_pay: 43,
    #      volume_currency_to_pay_after_fee: 42.79,
    #      amount_currency_to_trade_after_fee: 0.099,
    #      fee_currency_to_pay: 0.22,
    #      fee_currency_to_trade: '0.00100000',
    #      created_at: '2014-03-22T08:14:48+01:00',
    #      successfully_finished_at: '2014-03-25T14:03:22+01:00',
    #      state: 1,
    #      is_trade_marked_as_paid: true,
    #      trade_marked_as_paid_at: '2014-03-22T08:20:01+01:00',
    #      payment_method: 1,
    #      my_rating_for_trading_partner: 'positive',
    #      trading_partner_information: {
    #        username: 'emax2000',
    #        is_kyc_full: false,
    #        trust_level: 'bronze',
    #        amount_trades: 4,
    #        rating: 100,
    #        bank_name: 'CASSA DI RISPARMIO DI CIVITAVECCHIA SPA',
    #        bic: 'CRFIIT2CXXX',
    #        seat_of_bank: 'IT'
    #      }
    #    }, {}],
    #    page: { current: 1, last: 2 },
    #    errors: [],
    #    credits: 22
    #  }
    # @param [Integer] pag pagina dos dados
    # @param [Array<Hash>] ary acumulador dos dados
    # @param [String] uri Uniform Resource Identifier do pedido HTTP
    # @return [Array<Hash>] lista completa trades bitcoinde
    def trades_de(pag = 0, ary = [], uri = 'https://api.bitcoin.de/v4/trades')
      par = "#{uri}?#{URI.encode_www_form(state: 1, page: pag += 1)}"
      res = JSON.parse(Curl.get(par) { |obj| obj.headers = hde(par) }.body, symbolize_names: true)
      ary += res[:trades]
      rep = res[:page]
      rep[:current] < rep[:last] ? trades_de(pag, ary) : ary
    rescue StandardError
      ary
    end

    # @example deposits_de
    #  {
    #    deposits: [
    #      {
    #        deposit_id: '177245',
    #        txid: '84f9e85bc5709cd471e3d58a7d0f42d2c4a7bbd888cabf844e200efbf0a7fda2',
    #        address: '1KK6HhG3quojFS4CY1mPcbyrjQ8BMDQxmT',
    #        amount: '0.13283',
    #        confirmations: 6,
    #        state: 2,
    #        created_at: '2014-01-31T22:01:30+01:00'
    #      },
    #      {}
    #    ],
    #    page: { current: 1, last: 1 },
    #    errors: [],
    #    credits: 23
    #  }
    # @param (see trades_de)
    # @return [Array<Hash>] lista completa uniformizada depositos bitcoinde
    def deposits_de(pag = 0, ary = [], uri = 'https://api.bitcoin.de/v4/btc/deposits')
      par = "#{uri}?#{URI.encode_www_form(state: 2, page: pag += 1)}"
      res = JSON.parse(Curl.get(par) { |obj| obj.headers = hde(par) }.body, symbolize_names: true)
      ary += res[:deposits].map { |has| deposit_unif(has) }
      rep = res[:page]
      rep[:current] < rep[:last] ? deposits_de(pag, ary) : ary
    rescue StandardError
      ary
    end

    # @example deposit_unif
    #  [
    #    {
    #      txid: 177_245,
    #      time: '2014-01-31T22:01:30+01:00',
    #      tp: 'deposit',
    #      add: '1KK6HhG3quojFS4CY1mPcbyrjQ8BMDQxmT',
    #      qt: '0.13283',
    #      moe: 'btc',
    #      fee: '0'
    #    },
    #    {}
    #  ]
    # @return [Hash] deposit uniformizado bitcoinde
    def deposit_unif(has)
      {
        add: has[:address],
        time: Time.parse(has[:created_at]),
        qt: has[:amount],
        txid: Integer(has[:deposit_id])
      }.merge(tp: 'deposit', moe: 'btc', fee: '0')
    end

    # @example withdrawals_de
    #  {
    #    withdrawals: [
    #      {
    #        withdrawal_id: '136605',
    #        address: '1K9YMDDrmMV25EoYNqi7KUEK57Kn3TCNUJ',
    #        amount: '0.120087',
    #        network_fee: '0',
    #        comment: '',
    #        created_at: '2014-02-05T13:01:09+01:00',
    #        txid: '6264fe528116fcb87c812a306ca8409eecfec8fa941546c86f98984b882c8042',
    #        transferred_at: '2014-02-05T13:05:17+01:00',
    #        state: 1
    #      },
    #      {}
    #    ],
    #    page: { current: 1, last: 2 },
    #    errors: [],
    #    credits: 23
    #  }
    # @param (see deposits_de)
    # @return [Array<Hash>] lista completa uniformizada withdrawals bitcoinde
    def withdrawals_de(pag = 0, ary = [], uri = 'https://api.bitcoin.de/v4/btc/withdrawals')
      par = "#{uri}?#{URI.encode_www_form(state: 1, page: pag += 1)}"
      res = JSON.parse(Curl.get(par) { |obj| obj.headers = hde(par) }.body, symbolize_names: true)
      ary += res[:withdrawals].map { |has| withdrawal_unif(has) }
      rep = res[:page]
      rep[:current] < rep[:last] ? withdrawals_de(pag, ary) : ary
    rescue StandardError
      ary
    end

    # @example withdrawal_unif
    #  [
    #    {
    #      txid: 136_605,
    #      time: '2014-02-05T13:05:17+01:00',
    #      tp: 'withdrawal',
    #      add: '1K9YMDDrmMV25EoYNqi7KUEK57Kn3TCNUJ',
    #      qt: '0.120087',
    #      fee: '0',
    #      moe: 'btc'
    #    },
    #    {}
    #  ]
    # @return [Hash] withdrawal uniformizada bitcoinde
    def withdrawal_unif(has)
      {
        add: has[:address],
        time: Time.parse(has[:transferred_at]),
        qt: has[:amount],
        fee: has[:network_fee],
        txid: Integer(has[:withdrawal_id])
      }.merge(tp: 'withdrawal', moe: 'btc')
    end

    # @example ledger_fr
    #  [
    #    {
    #      uuid: '50551e61-4e74-4ae7-85fd-9c2040542818',
    #      currency_amount: nil,
    #      state: 'executed',
    #      btc_fee: '0.0',
    #      currency_fee: '0.0',
    #      created_at: '2014-03-04T09:00Z',
    #      updated_at: '2014-03-04T09:00Z',
    #      currency: 'EUR',
    #      comment: '5723',
    #      amount: '100.0',
    #      type: 'WireDeposit',
    #      account_operations: [{
    #        uuid: 'b5058a68-cf99-4438-86d3-e773eba418ec',
    #        name: 'wire_deposit',
    #        amount: '100.0',
    #        currency: 'EUR',
    #        created_at: '2014-03-04T09:00Z',
    #        created_at_int: 1_393_923_644,
    #        is_trading_account: false
    #      }, {}]
    #    },
    #    {}
    #  ]
    # @param (see trades_de)
    # @return [Array<Hash>] lista ledger paymium
    def ledger_fr(pag = 0, ary = [], uri = 'https://paymium.com/api/v1/user/orders')
      res = JSON.parse(
        Curl.get(uri, offset: pag) { |obj| obj.headers = hfr("#{uri}?#{URI.encode_www_form(offset: pag)}") }.body,
        symbolize_names: true
      )
      res.empty? ? ary : ledger_fr(pag + res.size, ary + res)
    rescue StandardError
      ary
    end

    # @example ledger_mt
    #  {
    #    transactions: [
    #      {
    #        id: 305_445,
    #        date: '2014-03-06T10:59:13.000Z',
    #        type: 'withdraw',
    #        price: 97.47,
    #        currency: 'EUR',
    #        fund_id: nil,
    #        order_id: nil,
    #        trade_id: nil,
    #        note: 'BOV withdraw',
    #        transfer_detail: nil
    #      },
    #      {}
    #    ],
    #    meta: {
    #      total_count: nil,
    #      first: { page: 1, href: 'https://api.therocktrading.com/v1/transactions?page=1' },
    #      previous: nil,
    #      current: { page: 1, href: 'https://api.therocktrading.com/v1/transactions?page=1' },
    #      next: { page: 2, href: 'https://api.therocktrading.com/v1/transactions?page=2' },
    #      last: nil
    #    }
    #  }
    # @param (see trades_de)
    # @return [Array<Hash>] lista ledger therock
    def ledger_mt(pag = 1, ary = [], uri = 'https://api.therocktrading.com/v1/transactions')
      res = JSON.parse(
        Curl.get(uri, page: pag) { |obj| obj.headers = hmt("#{uri}?#{URI.encode_www_form(page: pag)}") }.body,
        symbolize_names: true
      )[:transactions]
      res.empty? ? ary : ledger_mt(pag + res.size, ary + res)
    rescue StandardError
      ary
    end

    # @example trades_us
    #  {
    #    error: [],
    #    result: {
    #      trades: {
    #        "TVINF5-TIOUB-YFNGKE": {
    #          ordertxid: 'ORPSUW-YKP4F-UJZOC6',
    #          pair: 'XETHXXBT',
    #          time: 1_463_435_684.8387,
    #          type: 'buy',
    #          ordertype: 'market',
    #          price: '0.024989',
    #          cost: '1.193973',
    #          fee: '0.003104',
    #          vol: '47.77994129',
    #          margin: '0.000000',
    #          misc: ''
    #        },
    #        "OUTRO-TRADE-ID": {}
    #      },
    #      count: 157
    #    }
    #  }
    # @param [Integer] ofs offset dos dados
    # @param [Hash] has acumulador dos dados
    # @param (see account_us)
    # @return [Hash] dados trades kraken
    def trades_us(ofs = 0, has = {}, urb = 'https://api.kraken.com/0/private')
      uri = 'TradesHistory'
      non = nnc
      res = JSON.parse(
        Curl.post("#{urb}/#{uri}", nonce: non, ofs: ofs) { |obj| obj.headers = hus(uri, nonce: non, ofs: ofs) }.body,
        symbolize_names: true
      )[:result]
      has.merge!(res[:trades])
      (ofs += 50) < res[:count] ? trades_us(ofs, has) : has
    rescue StandardError
      has
    end

    # @example ledger_us
    #  {
    #    error: [],
    #    result: {
    #      ledger: {
    #        "LXXURB-ITI7S-CXVERS": {
    #          refid: 'ACCHF3A-RIBBMO-VYBESY',
    #          time: 1_543_278_716.2775,
    #          type: 'withdrawal',
    #          subtype: '',
    #          aclass: 'currency',
    #          asset: 'ZEUR',
    #          amount: '-15369.6200',
    #          fee: '0.0900',
    #          balance: '0.0062'
    #        },
    #        "OUTRO-LEDGER-ID": {}
    #      },
    #      count: 376
    #    }
    #  }
    # @param (see trades_us)
    # @return [Hash] dados ledger kraken
    def ledger_us(ofs = 0, has = {}, urb = 'https://api.kraken.com/0/private')
      uri = 'Ledgers'
      non = nnc
      res = JSON.parse(
        Curl.post("#{urb}/#{uri}", nonce: non, ofs: ofs) { |obj| obj.headers = hus(uri, nonce: non, ofs: ofs) }.body,
        symbolize_names: true
      )[:result]
      has.merge!(res[:ledger])
      (ofs += 50) < res[:count] ? ledger_us(ofs, has) : has
    rescue StandardError
      has
    end

    private

    # @return [Integer] continually-increasing unsigned integer nonce from the current Unix Time
    def nnc
      Integer(Float(Time.now) * 1e6)
    end

    # @param [String] qde query a incluir no pedido HTTP
    # @param [Integer] non continually-increasing unsigned integer
    # @return [Hash] headers necessarios para pedido HTTP da exchange bitcoinde
    def hde(qde, non = nnc)
      key = ENV['BITCOINDE_API_KEY']
      {
        'X-API-KEY': key,
        'X-API-NONCE': non,
        'X-API-SIGNATURE': OpenSSL::HMAC.hexdigest(
          'sha256',
          ENV['BITCOINDE_API_SECRET'],
          ['GET', qde, key, non, Digest::MD5.hexdigest('')].join('#')
        )
      }
    end

    # @param [String] qfr query a incluir no pedido HTTP
    # @param non (see hde)
    # @return [Hash] headers necessarios para pedido HTTP da exchange paymium
    def hfr(qfr, non = nnc)
      {
        content_type: 'application/json',
        'Api-Key': ENV['PAYMIUM_API_KEY'],
        'Api-Nonce': non,
        'Api-Signature': OpenSSL::HMAC.hexdigest('sha256', ENV['PAYMIUM_API_SECRET'], [non, qfr].join)
      }
    end

    # @param [String] qmt query a incluir no pedido HTTP
    # @param non (see hde)
    # @return [Hash] headers necessarios para pedido HTTP da exchange therock
    def hmt(qmt, non = nnc)
      {
        content_type: 'application/json',
        'X-TRT-KEY': ENV['THEROCK_API_KEY'],
        'X-TRT-NONCE': non,
        'X-TRT-SIGN': OpenSSL::HMAC.hexdigest('sha512', ENV['THEROCK_API_SECRET'], [non, qmt].join)
      }
    end

    # @param [String] qus query a incluir no pedido HTTP
    # @param [Hash] ops opcoes trabalho
    # @option ops [Hash] :nonce continually-increasing unsigned integer
    # @return [Hash] headers necessarios para pedido HTTP da exchange kraken
    def hus(qus, ops)
      {
        'api-key': ENV['KRAKEN_API_KEY'],
        'api-sign': Base64.strict_encode64(
          OpenSSL::HMAC.digest(
            'sha512',
            Base64.decode64(ENV['KRAKEN_API_SECRET']),
            ['/0/private/', qus, Digest::SHA256.digest("#{ops[:nonce]}#{URI.encode_www_form(ops)}")].join
          )
        )
      }
    end
  end
end