Add more examples

bfxapi/examples/candel_order.py

@@ -0,0 +1,38 @@
+import os
+import sys
+sys.path.append('../')
+
+from bfxapi.websockets.LiveWebsocket import LiveBfxWebsocket
+
+API_KEY=os.getenv("BFX_KEY")
+API_SECRET=os.getenv("BFX_SECRET")
+
+ws = LiveBfxWebsocket(
+  API_KEY=API_KEY,
+  API_SECRET=API_SECRET,
+  logLevel='INFO'
+)
+
+@ws.on('order_closed')
+def order_cancelled(order, trade):
+  print ("Order cancelled.")
+  print (order)
+  print (trade)
+
+@ws.on('order_confirmed')
+async def trade_completed(order, trade):
+  print ("Order confirmed.")
+  print (order)
+  print (trade)
+  await ws.cancel_order(order.id)
+
+@ws.on('error')
+def log_error(msg):
+  print ("Error: {}".format(msg))
+
+@ws.once('authenticated')
+async def submit_order(auth_message):
+  # create an inital order a really low price so it stays open
+  await ws.submit_order('tBTCUSD', 10, 1, 'EXCHANGE LIMIT')
+
+ws.run()

bfxapi/examples/send_order.py

@@ -13,9 +13,9 @@ ws = LiveBfxWebsocket(
   logLevel='INFO'
 )
 
-@ws.on('order_closed')
+@ws.on('order_confirmed')
 def trade_completed(order, trade):
-  print ("Order filled.")
+  print ("Order confirmed.")
   print (order)
   print (trade)
 

bfxapi/examples/subscribe_trades_candles.py

@@ -4,12 +4,6 @@ sys.path.append('../')
 
 from bfxapi.websockets.LiveWebsocket import LiveBfxWebsocket
 
-'''
-This script requires you to run an instance of the bfx-hf-data-server on 
-port 8899. For more info on how to setup the data-server please visit:
-https://github.com/bitfinexcom/bfx-hf-data-server
-'''
-
 ws = LiveBfxWebsocket(
   logLevel='INFO'
 )

bfxapi/examples/update_order.py

@@ -0,0 +1,38 @@
+import os
+import sys
+sys.path.append('../')
+
+from bfxapi.websockets.LiveWebsocket import LiveBfxWebsocket
+
+API_KEY=os.getenv("BFX_KEY")
+API_SECRET=os.getenv("BFX_SECRET")
+
+ws = LiveBfxWebsocket(
+  API_KEY=API_KEY,
+  API_SECRET=API_SECRET,
+  logLevel='INFO'
+)
+
+@ws.on('order_update')
+def order_updated(order, trade):
+  print ("Order updated.")
+  print (order)
+  print (trade)
+
+@ws.once('order_confirmed')
+async def trade_completed(order, trade):
+  print ("Order confirmed.")
+  print (order)
+  print (trade)
+  await ws.update_order(order.id, price=100, amount=0.01)
+
+@ws.on('error')
+def log_error(msg):
+  print ("Error: {}".format(msg))
+
+@ws.once('authenticated')
+async def submit_order(auth_message):
+  # create an inital order a really low price so it stays open
+  await ws.submit_order('tBTCUSD', 10, 1, 'EXCHANGE LIMIT')
+
+ws.run()