diff --git a/bfxapi/examples/candel_order.py b/bfxapi/examples/candel_order.py index b13b3af..6571e25 100644 --- a/bfxapi/examples/candel_order.py +++ b/bfxapi/examples/candel_order.py @@ -1,38 +1,38 @@ -import os -import sys -sys.path.append('../') - -from bfxapi import Client - -API_KEY=os.getenv("BFX_KEY") -API_SECRET=os.getenv("BFX_SECRET") - -bfx = Client( - API_KEY=API_KEY, - API_SECRET=API_SECRET, - logLevel='INFO' -) - -@bfx.ws.on('order_closed') -def order_cancelled(order, trade): - print ("Order cancelled.") - print (order) - print (trade) - -@bfx.ws.on('order_confirmed') -async def trade_completed(order, trade): - print ("Order confirmed.") - print (order) - print (trade) - await bfx.ws.cancel_order(order.id) - -@bfx.ws.on('error') -def log_error(msg): - print ("Error: {}".format(msg)) - -@bfx.ws.once('authenticated') -async def submit_order(auth_message): - # create an inital order a really low price so it stays open - await bfx.ws.submit_order('tBTCUSD', 10, 1, 'EXCHANGE LIMIT') - -bfx.ws.run() +import os +import sys +sys.path.append('../') + +from bfxapi import Client + +API_KEY=os.getenv("BFX_KEY") +API_SECRET=os.getenv("BFX_SECRET") + +bfx = Client( + API_KEY=API_KEY, + API_SECRET=API_SECRET, + logLevel='INFO' +) + +@bfx.ws.on('order_closed') +def order_cancelled(order, trade): + print ("Order cancelled.") + print (order) + print (trade) + +@bfx.ws.on('order_confirmed') +async def trade_completed(order, trade): + print ("Order confirmed.") + print (order) + print (trade) + await bfx.ws.cancel_order(order.id) + +@bfx.ws.on('error') +def log_error(msg): + print ("Error: {}".format(msg)) + +@bfx.ws.once('authenticated') +async def submit_order(auth_message): + # create an inital order a really low price so it stays open + await bfx.ws.submit_order('tBTCUSD', 10, 1, 'EXCHANGE LIMIT') + +bfx.ws.run() diff --git a/bfxapi/examples/connect.py b/bfxapi/examples/connect.py index 7250742..829abff 100644 --- a/bfxapi/examples/connect.py +++ b/bfxapi/examples/connect.py @@ -1,19 +1,19 @@ -import os -import sys -sys.path.append('../') - -from bfxapi import Client - -bfx = Client( - logLevel='INFO' -) - -@bfx.ws.on('error') -def log_error(msg): - print ("Error: {}".format(msg)) - -@bfx.ws.on('all') -async def log_output(output): - print ("WS: {}".format(output)) - -bfx.ws.run() +import os +import sys +sys.path.append('../') + +from bfxapi import Client + +bfx = Client( + logLevel='INFO' +) + +@bfx.ws.on('error') +def log_error(msg): + print ("Error: {}".format(msg)) + +@bfx.ws.on('all') +async def log_output(output): + print ("WS: {}".format(output)) + +bfx.ws.run() diff --git a/bfxapi/examples/send_order.py b/bfxapi/examples/send_order.py index 228c259..a465471 100644 --- a/bfxapi/examples/send_order.py +++ b/bfxapi/examples/send_order.py @@ -1,38 +1,38 @@ -import os -import sys -sys.path.append('../') - -from bfxapi import Client - -API_KEY=os.getenv("BFX_KEY") -API_SECRET=os.getenv("BFX_SECRET") - -bfx = Client( - API_KEY=API_KEY, - API_SECRET=API_SECRET, - logLevel='INFO' -) - -@bfx.ws.on('order_confirmed') -def trade_completed(order, trade): - print ("Order confirmed.") - print (order) - print (trade) - -@bfx.ws.on('error') -def log_error(msg): - print ("Error: {}".format(msg)) - -@bfx.ws.on('authenticated') -async def submit_order(auth_message): - await bfx.ws.submit_order('tBTCUSD', 0, 0.01, 'EXCHANGE MARKET') - -# If you dont want to use a decorator -# ws.on('authenticated', submit_order) -# ws.on('error', log_error) - -# You can also provide a callback -# await ws.submit_order('tBTCUSD', 0, 0.01, -# 'EXCHANGE MARKET', onComplete=trade_complete) - -bfx.ws.run() +import os +import sys +sys.path.append('../') + +from bfxapi import Client + +API_KEY=os.getenv("BFX_KEY") +API_SECRET=os.getenv("BFX_SECRET") + +bfx = Client( + API_KEY=API_KEY, + API_SECRET=API_SECRET, + logLevel='INFO' +) + +@bfx.ws.on('order_confirmed') +def trade_completed(order, trade): + print ("Order confirmed.") + print (order) + print (trade) + +@bfx.ws.on('error') +def log_error(msg): + print ("Error: {}".format(msg)) + +@bfx.ws.on('authenticated') +async def submit_order(auth_message): + await bfx.ws.submit_order('tBTCUSD', 0, 0.01, 'EXCHANGE MARKET') + +# If you dont want to use a decorator +# ws.on('authenticated', submit_order) +# ws.on('error', log_error) + +# You can also provide a callback +# await ws.submit_order('tBTCUSD', 0, 0.01, +# 'EXCHANGE MARKET', onComplete=trade_complete) + +bfx.ws.run() diff --git a/bfxapi/examples/subscribe_trades_candles.py b/bfxapi/examples/subscribe_trades_candles.py index f6ea223..f2943e3 100644 --- a/bfxapi/examples/subscribe_trades_candles.py +++ b/bfxapi/examples/subscribe_trades_candles.py @@ -1,28 +1,28 @@ -import os -import sys -sys.path.append('../') - -from bfxapi import Client - -bfx = Client( - logLevel='INFO' -) - -@bfx.ws.on('error') -def log_error(err): - print ("Error: {}".format(err)) - -@bfx.ws.on('new_candle') -def log_candle(candle): - print ("New candle: {}".format(candle)) - -@bfx.ws.on('new_trade') -def log_trade(trade): - print ("New trade: {}".format(trade)) - -def start(): - bfx.ws.subscribe('candles', 'tBTCUSD', timeframe='1m') - bfx.ws.subscribe('trades', 'tBTCUSD') - -bfx.ws.on('connected', start) -bfx.ws.run() +import os +import sys +sys.path.append('../') + +from bfxapi import Client + +bfx = Client( + logLevel='INFO' +) + +@bfx.ws.on('error') +def log_error(err): + print ("Error: {}".format(err)) + +@bfx.ws.on('new_candle') +def log_candle(candle): + print ("New candle: {}".format(candle)) + +@bfx.ws.on('new_trade') +def log_trade(trade): + print ("New trade: {}".format(trade)) + +def start(): + bfx.ws.subscribe('candles', 'tBTCUSD', timeframe='1m') + bfx.ws.subscribe('trades', 'tBTCUSD') + +bfx.ws.on('connected', start) +bfx.ws.run() diff --git a/bfxapi/examples/update_order.py b/bfxapi/examples/update_order.py index 3887dc2..f8ab4ce 100644 --- a/bfxapi/examples/update_order.py +++ b/bfxapi/examples/update_order.py @@ -1,38 +1,38 @@ -import os -import sys -sys.path.append('../') - -from bfxapi import Client - -API_KEY=os.getenv("BFX_KEY") -API_SECRET=os.getenv("BFX_SECRET") - -bfx = Client( - API_KEY=API_KEY, - API_SECRET=API_SECRET, - logLevel='INFO' -) - -@bfx.ws.on('order_update') -def order_updated(order, trade): - print ("Order updated.") - print (order) - print (trade) - -@bfx.ws.once('order_confirmed') -async def trade_completed(order, trade): - print ("Order confirmed.") - print (order) - print (trade) - await bfx.ws.update_order(order.id, price=100, amount=0.01) - -@bfx.ws.on('error') -def log_error(msg): - print ("Error: {}".format(msg)) - -@bfx.ws.once('authenticated') -async def submit_order(auth_message): - # create an inital order a really low price so it stays open - await bfx.ws.submit_order('tBTCUSD', 10, 1, 'EXCHANGE LIMIT') - -bfx.ws.run() +import os +import sys +sys.path.append('../') + +from bfxapi import Client + +API_KEY=os.getenv("BFX_KEY") +API_SECRET=os.getenv("BFX_SECRET") + +bfx = Client( + API_KEY=API_KEY, + API_SECRET=API_SECRET, + logLevel='INFO' +) + +@bfx.ws.on('order_update') +def order_updated(order, trade): + print ("Order updated.") + print (order) + print (trade) + +@bfx.ws.once('order_confirmed') +async def trade_completed(order, trade): + print ("Order confirmed.") + print (order) + print (trade) + await bfx.ws.update_order(order.id, price=100, amount=0.01) + +@bfx.ws.on('error') +def log_error(msg): + print ("Error: {}".format(msg)) + +@bfx.ws.once('authenticated') +async def submit_order(auth_message): + # create an inital order a really low price so it stays open + await bfx.ws.submit_order('tBTCUSD', 10, 1, 'EXCHANGE LIMIT') + +bfx.ws.run() diff --git a/bfxapi/examples/wallet_balance.py b/bfxapi/examples/wallet_balance.py index 9978af0..73fbea2 100644 --- a/bfxapi/examples/wallet_balance.py +++ b/bfxapi/examples/wallet_balance.py @@ -1,28 +1,28 @@ -import os -import sys -sys.path.append('../') - -from bfxapi import Client - -API_KEY=os.getenv("BFX_KEY") -API_SECRET=os.getenv("BFX_SECRET") - -bfx = Client( - API_KEY=API_KEY, - API_SECRET=API_SECRET, - logLevel='INFO' -) - -@bfx.ws.on('wallet_snapshot') -def log_snapshot(data): - print ("Opening balance: {}".format(data)) - -@bfx.ws.on('wallet_update') -def log_update(data): - print ("Balance updates: {}".format(data)) - -@bfx.ws.on('error') -def log_error(msg): - print ("Error: {}".format(msg)) - -bfx.ws.run() +import os +import sys +sys.path.append('../') + +from bfxapi import Client + +API_KEY=os.getenv("BFX_KEY") +API_SECRET=os.getenv("BFX_SECRET") + +bfx = Client( + API_KEY=API_KEY, + API_SECRET=API_SECRET, + logLevel='INFO' +) + +@bfx.ws.on('wallet_snapshot') +def log_snapshot(data): + print ("Opening balance: {}".format(data)) + +@bfx.ws.on('wallet_update') +def log_update(data): + print ("Balance updates: {}".format(data)) + +@bfx.ws.on('error') +def log_error(msg): + print ("Error: {}".format(msg)) + +bfx.ws.run()