exchange.coffee

# these methods must be implemented for any exchange
module.exports = exchange = 
  all_clear: -> 
    console.assert config.exchange, message: 'Exchange is not configured'
    exchange[config.exchange].all_clear()


  #####
  # PUBLIC API 

  minimum_order_size: (currency) -> 
    currency ||= config.c2
    mins = exchange[config.exchange].minimum_order_size
    if !(currency of mins) 
      log_error true, {message: "minimum order size for #{currency} not defined"}
    mins[currency]

  minimum_rate_diff: -> exchange[config.exchange].minimum_rate_diff()
  minimum_rate_precision: -> exchange[config.exchange].minimum_rate_precision()
  
  # opts: 
  # c1, c2
  get_earliest_trade: (opts) ->
    if opts.c1 != opts.accounting_currency && opts.c2 != opts.accounting_currency
      Math.max  exchange[opts.exchange].get_earliest_trade({only_high_volume: opts.only_high_volume, c1: opts.c1, c2: opts.c2}), \
                exchange[opts.exchange].get_earliest_trade({only_high_volume: false, c1: opts.accounting_currency, c2: opts.c1}), \
                exchange[opts.exchange].get_earliest_trade({only_high_volume: false, c1: opts.accounting_currency, c2: opts.c2})
    else 
      exchange[opts.exchange].get_earliest_trade({only_high_volume: opts.only_high_volume, c1: opts.c1, c2: opts.c2})
      
  # opts: 
  #  c1, c2, start, end, period, callback
  get_chart_data: (opts, callback) -> 
    exchange[config.exchange].get_chart_data opts, callback

  # opts: 
  #  currency_pair, start, end, callback
  get_trade_history: (opts, callback) -> 
    exchange[config.exchange].get_trade_history opts, callback

  download_all_trade_history: (opts, callback) -> 
    if exchange[config.exchange].download_all_trade_history 
      exchange[config.exchange].download_all_trade_history opts, callback 
    else 
      callback()

  # callsback for each new trade
  # opts: none
  subscribe_to_exchange_feed: (opts, callback) -> 
    exchange[config.exchange].subscribe_to_exchange_feed opts, callback

  #####
  # TRADING API

  # opts: 
  #  c1, c2, start, end, callback
  get_my_fills: (opts, callback) -> 
    exchange[config.exchange].get_my_fills opts, callback


  # opts: 
  #  c1, c2
  get_my_open_orders: (opts, callback) -> 
    exchange[config.exchange].get_my_open_orders opts, callback

  # opts: 
  #  c1, c2
  get_my_balance: (opts, callback) -> 
    exchange[config.exchange].get_my_balance 
      currencies: [opts.c1, config.c2]
    , callback


  # opts: 
  #  none
  get_my_exchange_fee: (opts, callback) -> 
    exchange[config.exchange].get_my_exchange_fee opts, callback


  # opts: 
  #  type (buy / sell)
  #  amount
  #  rate 
  #  c1
  #  c2
  #  market
  place_order: (opts, callback) -> 
    exchange[config.exchange].place_order opts, callback

  dynamic_place_order: (opts, placed_callback, updated_callback, finished_callback) -> 
    if exchange[config.exchange].dynamic_place_order
      exchange[config.exchange].dynamic_place_order opts, placed_callback, updated_callback, finished_callback
    else 
      throw "#{config.exchange} does not have a dynamic_place_order method"

  dynamic_move_order: (opts, updated_callback, finished_callback) -> 
    if exchange[config.exchange].dynamic_move_order
      exchange[config.exchange].dynamic_move_order opts, updated_callback, finished_callback
    else 
      throw "#{config.exchange} does not have a dynamic_move_order method"

  # opts: 
  #  order_id
  cancel_order: (opts, callback) -> 
    exchange[config.exchange].cancel_order opts, callback


  # opts: 
  #  order_id
  #  amount
  #  rate 
  #  c1
  #  c2
  #  type
  #  market  
  move_order: (opts, callback) ->
    exchange[config.exchange].move_order opts, callback 



exchange.poloniex = require './exchanges/poloniex'
exchange.gdax = require './exchanges/gdax'