diff --git a/bot/helpers.py b/bot/helpers.py deleted file mode 100644 index 63ab898..0000000 --- a/bot/helpers.py +++ /dev/null @@ -1,3 +0,0 @@ -def get_answer(): - """Get an answer.""" - return True diff --git a/bot/market_data_crawler.py b/bot/market_data_crawler.py new file mode 100644 index 0000000..9cb0fe6 --- /dev/null +++ b/bot/market_data_crawler.py @@ -0,0 +1,37 @@ +import tornado.escape, tornado.httpclient + +def update_market_data_for_basecoin(basecoin): + global market_data + market_data = {} + market_requests = [] + + """Bittrex""" + + def handle_response_bittrex(response): + if response.error: + print("Error: %s" % response.error) + else: + response_data = tornado.escape.json_decode(response.body) + + for market in response_data["result"]: + base, target = market["MarketName"].split("-") + if base == basecoin: + market_data.update({ + target: { + "Bittrex": market["Last"] + } + }) + + + bittrex = { + "url": "https://bittrex.com/api/v1.1/public/getmarketsummaries", + "response_handler": handle_response_bittrex + } + + market_requests.append(bittrex) + + http_client = tornado.httpclient.AsyncHTTPClient() + for request in market_requests: + print("Doing request to {0}".format(request["url"])) + http_client.fetch(request["url"], request["response_handler"]) +