fmt pep8

app/public/bitfinex.py

@@ -9,7 +9,8 @@
 import time
 import utils
 
-class BitFinex_Market(object):
+
+class BitfnexMarket(object):
     """Bitfinex Market Data"""
     def __init__(self):
         self.api_url = settings.BITFINEX_API_URL

app/public/bitmex.py

@@ -7,7 +7,8 @@
 import requests
 import utils
 
-class BitMex_Market(object):
+
+class BitMexMarket(object):
     """BitMex Market Data"""
     def __init__(self):
         self.api_url = settings.BITMEX_API_URL

app/public/bittrex.py

@@ -7,7 +7,8 @@
 import requests
 import utils
 
-class BitTrex_Market(object):
+
+class BitTrexMarket(object):
     """BitTrex Market Data"""
     def __init__(self):
         self.api_url = settings.BITTREX_API_URL

app/public/gdax.py

@@ -7,7 +7,8 @@
 import requests
 import utils
 
-class GDAX_Market(object):
+
+class GDAXMarket(object):
     """GDAX Market Data"""
     def __init__(self):
         self.api_url = settings.GDAX_API_URL

app/public/gemini.py

@@ -7,7 +7,8 @@
 import requests
 import utils
 
-class Gemini_Market(object):
+
+class GeminiMarket(object):
     """Gemini Market Data"""
     def __init__(self):
         self.api_url = settings.GEMINI_API_URL

app/public/kraken.py

@@ -7,7 +7,8 @@
 import requests
 import utils
 
-class Kraken_Market(object):
+
+class KrakenMarket(object):
     """ETH Kraken Market Data"""
     def __init__(self):
         self.api_url = settings.KRAKEN_API_URL

app/public/okcoin.py

@@ -7,7 +7,8 @@
 import requests
 import utils
 
-class OKCoin_Market(object):
+
+class OkCoinMarket(object):
     """OKCOIN Market Data"""
     def __init__(self):
         self.api_url = settings.OKCOIN_API_URL

app/public/poloniex.py

@@ -7,7 +7,8 @@
 import requests
 import utils
 
-class Poloniex_Market(object):
+
+class PloloniexMarket(object):
     """Poloniex Market Data"""
     def __init__(self):
         self.api_url = settings.POLONIEX_API_URL

app/tracker.py

@@ -5,14 +5,14 @@
           avelkoski
 """
 from elasticsearch import Elasticsearch, helpers
-from public.bitfinex import BitFinex_Market
-from public.bitmex import BitMex_Market
-from public.bittrex import BitTrex_Market
-from public.gdax import GDAX_Market
-from public.gemini import Gemini_Market
-from public.kraken import Kraken_Market
-from public.okcoin import OKCoin_Market
-from public.poloniex import Poloniex_Market
+from public.bitfinex import BitfnexMarket
+from public.bitmex import BitMexMarket
+from public.bittrex import BitTrexMarket
+from public.gdax import GDAXMarket
+from public.gemini import GeminiMarket
+from public.kraken import KrakenMarket
+from public.okcoin import OkCoinMarket
+from public.poloniex import PloloniexMarket
 from dotenv import Dotenv
 from time import sleep
 import logging
@@ -22,6 +22,18 @@
 import random
 import time
 
+support_exchange = [
+    BitTrexMarket,
+    BitMexMarket,
+    GDAXMarket,
+    GeminiMarket,
+    KrakenMarket,
+    OkCoinMarket,
+    PloloniexMarket,
+    BitfnexMarket
+]
+
+
 def main():
     logging.basicConfig(format='%(levelname)s:%(asctime)s %(message)s',level=settings.LOGLEVEL)
     es = Elasticsearch(settings.ELASTICSEARCH_CONNECT_STRING)
@@ -31,19 +43,17 @@ def main():
 
     sleep(settings.INITIAL_SLEEP)
     logging.info('Application Started.')
-    #supported_exchanges = [BitFinex_Market(), BitMex_Market(), BitTrex_Market(), GDAX_Market(), Gemini_Market(), Kraken_Market(), OKCoin_Market(), Poloniex_Market()]
-    exchanges = [BitFinex_Market(), BitMex_Market(), BitTrex_Market(), GDAX_Market(), Gemini_Market(), Kraken_Market(), OKCoin_Market(), Poloniex_Market()]
+    exchanges = [ex() for ex in support_exchange]
 
-
-    #print active exchanges and create indexes in kibana based on products listed in each market
+    # print active exchanges and create indexes in kibana based on products listed in each market
     for exchange in exchanges:
         logging.info(exchange.exchange + ': activated and indexed.')
         for product, kibana_index in exchange.products.iteritems():
             utils.create_index(es, kibana_index)
 
     logging.warn('Initiating Market Tracking.')
 
-    #Record Ticks
+    # Record Ticks
     while True:
         sleep(settings.MARKET_REFRESH_RATE)
         try:
@@ -54,5 +64,6 @@ def main():
             logging.warning(e)
             sleep(settings.RETRY_RATE)
 
+
 if __name__ == '__main__':
     main()