Class: CampBX::API

Inherits:
Object
  • Object
show all
Defined in:
lib/rbtc_arbitrage/campbx.rb

Constant Summary collapse

@@last =

CampBX API rate limiting probably per IP address (not account) which is why we don’t limit per instance

Time.new(0)

Instance Method Summary collapse

Constructor Details

#initialize(username = nil, password = nil) ⇒ API

Returns a new instance of API.



41
42
43
44
45
46
47
48
49
50
51
52
 
# File 'lib/rbtc_arbitrage/campbx.rb', line 41

def initialize( username=nil, password=nil )
  @username = username
  @password = password

  # Build meta-methods for each API call
  CALLS.each do |name|
    define_singleton_method name[0], lambda { |*args|
      data = CALLS[name[0]]
      api_request( [data[0], data[1]], Hash[data[2].zip( args )] )
    }
  end
end

Instance Method Details

#api_request(info, post_data = {}) ⇒ Object 



54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
 
# File 'lib/rbtc_arbitrage/campbx.rb', line 54

def api_request( info, post_data={} )
  url, auth = info
  uri = URI.parse(API_BASE + url + '.php')
  http = Net::HTTP.new(uri.host, uri.port)
  http.use_ssl=TRUE
  # CampBX advises latency can be >4 minutes when markets are volatile
  http.read_timeout = 300
  res = nil

  request = Net::HTTP::Get.new(uri.request_uri)
  if auth then
    post_data.merge!({
      'user' => @username,
      'pass' => @password,
    })
    request = Net::HTTP::Post.new(uri.request_uri)
    request.set_form_data( post_data )
  end

  # debug # need to test w/valid credentials
  #puts "Sending request to #{uri}"
  #puts "Post Data: #{post_data}"

  # CampBX API: max 1 request per 500ms
  delta = Time.now - @@last
  #puts delta*1000
  if delta*1000 <= 500 then
    #puts "sleeping! for #{0.5 - delta}"
    sleep(0.5 - delta)
  end

  res = http.request(request)
  @@last = Time.now # Update time after request returns

  if res.message == 'OK' then # HTTP OK
    JSON.parse( res.body )
  else # HTTP ERROR
    warn "HTTP Error: + #{res.code}"
  end

end