examples: change to use client module

This commit is contained in:
Jacob Plaster
2018-11-19 17:24:24 +00:00
parent aa50a399dd
commit 13847da936
6 changed files with 189 additions and 189 deletions

View File

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

View File

@@ -1,19 +1,19 @@
import os import os
import sys import sys
sys.path.append('../') sys.path.append('../')
from bfxapi import Client from bfxapi import Client
bfx = Client( bfx = Client(
logLevel='INFO' logLevel='INFO'
) )
@bfx.ws.on('error') @bfx.ws.on('error')
def log_error(msg): def log_error(msg):
print ("Error: {}".format(msg)) print ("Error: {}".format(msg))
@bfx.ws.on('all') @bfx.ws.on('all')
async def log_output(output): async def log_output(output):
print ("WS: {}".format(output)) print ("WS: {}".format(output))
bfx.ws.run() bfx.ws.run()

View File

@@ -1,38 +1,38 @@
import os import os
import sys import sys
sys.path.append('../') sys.path.append('../')
from bfxapi import Client from bfxapi import Client
API_KEY=os.getenv("BFX_KEY") API_KEY=os.getenv("BFX_KEY")
API_SECRET=os.getenv("BFX_SECRET") API_SECRET=os.getenv("BFX_SECRET")
bfx = Client( bfx = Client(
API_KEY=API_KEY, API_KEY=API_KEY,
API_SECRET=API_SECRET, API_SECRET=API_SECRET,
logLevel='INFO' logLevel='INFO'
) )
@bfx.ws.on('order_confirmed') @bfx.ws.on('order_confirmed')
def trade_completed(order, trade): def trade_completed(order, trade):
print ("Order confirmed.") print ("Order confirmed.")
print (order) print (order)
print (trade) print (trade)
@bfx.ws.on('error') @bfx.ws.on('error')
def log_error(msg): def log_error(msg):
print ("Error: {}".format(msg)) print ("Error: {}".format(msg))
@bfx.ws.on('authenticated') @bfx.ws.on('authenticated')
async def submit_order(auth_message): async def submit_order(auth_message):
await bfx.ws.submit_order('tBTCUSD', 0, 0.01, 'EXCHANGE MARKET') await bfx.ws.submit_order('tBTCUSD', 0, 0.01, 'EXCHANGE MARKET')
# If you dont want to use a decorator # If you dont want to use a decorator
# ws.on('authenticated', submit_order) # ws.on('authenticated', submit_order)
# ws.on('error', log_error) # ws.on('error', log_error)
# You can also provide a callback # You can also provide a callback
# await ws.submit_order('tBTCUSD', 0, 0.01, # await ws.submit_order('tBTCUSD', 0, 0.01,
# 'EXCHANGE MARKET', onComplete=trade_complete) # 'EXCHANGE MARKET', onComplete=trade_complete)
bfx.ws.run() bfx.ws.run()

View File

@@ -1,28 +1,28 @@
import os import os
import sys import sys
sys.path.append('../') sys.path.append('../')
from bfxapi import Client from bfxapi import Client
bfx = Client( bfx = Client(
logLevel='INFO' logLevel='INFO'
) )
@bfx.ws.on('error') @bfx.ws.on('error')
def log_error(err): def log_error(err):
print ("Error: {}".format(err)) print ("Error: {}".format(err))
@bfx.ws.on('new_candle') @bfx.ws.on('new_candle')
def log_candle(candle): def log_candle(candle):
print ("New candle: {}".format(candle)) print ("New candle: {}".format(candle))
@bfx.ws.on('new_trade') @bfx.ws.on('new_trade')
def log_trade(trade): def log_trade(trade):
print ("New trade: {}".format(trade)) print ("New trade: {}".format(trade))
def start(): def start():
bfx.ws.subscribe('candles', 'tBTCUSD', timeframe='1m') bfx.ws.subscribe('candles', 'tBTCUSD', timeframe='1m')
bfx.ws.subscribe('trades', 'tBTCUSD') bfx.ws.subscribe('trades', 'tBTCUSD')
bfx.ws.on('connected', start) bfx.ws.on('connected', start)
bfx.ws.run() bfx.ws.run()

View File

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

View File

@@ -1,28 +1,28 @@
import os import os
import sys import sys
sys.path.append('../') sys.path.append('../')
from bfxapi import Client from bfxapi import Client
API_KEY=os.getenv("BFX_KEY") API_KEY=os.getenv("BFX_KEY")
API_SECRET=os.getenv("BFX_SECRET") API_SECRET=os.getenv("BFX_SECRET")
bfx = Client( bfx = Client(
API_KEY=API_KEY, API_KEY=API_KEY,
API_SECRET=API_SECRET, API_SECRET=API_SECRET,
logLevel='INFO' logLevel='INFO'
) )
@bfx.ws.on('wallet_snapshot') @bfx.ws.on('wallet_snapshot')
def log_snapshot(data): def log_snapshot(data):
print ("Opening balance: {}".format(data)) print ("Opening balance: {}".format(data))
@bfx.ws.on('wallet_update') @bfx.ws.on('wallet_update')
def log_update(data): def log_update(data):
print ("Balance updates: {}".format(data)) print ("Balance updates: {}".format(data))
@bfx.ws.on('error') @bfx.ws.on('error')
def log_error(msg): def log_error(msg):
print ("Error: {}".format(msg)) print ("Error: {}".format(msg))
bfx.ws.run() bfx.ws.run()