aljaz/bitfinex-api-py
1
0
Fork 0
mirror of https://github.com/aljazceru/bitfinex-api-py.git synced 2025-12-19 06:44:22 +01:00
Code Issues Packages Projects Releases Wiki Activity

Change examples to use new Client module

Browse Source
This commit is contained in:
Jacob Plaster
2018-11-19 16:50:40 +00:00
parent 4be08dfa43
commit 02e232362b
6 changed files with 45 additions and 45 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
bfxapi/examples/candel_order.py
View File

@@ -2,37 +2,37 @@ import os
import sys import sys
sys.path.append('../') sys.path.append('../')
from bfxapi.websockets.LiveWebsocket import LiveBfxWebsocket 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")
ws = LiveBfxWebsocket( bfx = Client(
API_KEY=API_KEY, API_KEY=API_KEY,
API_SECRET=API_SECRET, API_SECRET=API_SECRET,
logLevel='INFO' logLevel='INFO'
) )
@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)
@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 ws.cancel_order(order.id) await bfx.ws.cancel_order(order.id)
@ws.on('error') @bfx.ws.on('error')
def log_error(msg): def log_error(msg):
print ("Error: {}".format(msg)) print ("Error: {}".format(msg))
@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 ws.submit_order('tBTCUSD', 10, 1, 'EXCHANGE LIMIT') await bfx.ws.submit_order('tBTCUSD', 10, 1, 'EXCHANGE LIMIT')
ws.run() bfx.ws.run()

10
bfxapi/examples/connect.py
View File

@@ -2,18 +2,18 @@ import os
import sys import sys
sys.path.append('../') sys.path.append('../')
from bfxapi.websockets.LiveWebsocket import LiveBfxWebsocket from bfxapi import Client
ws = LiveBfxWebsocket( bfx = Client(
logLevel='INFO' logLevel='INFO'
) )
@ws.on('error') @bfx.ws.on('error')
def log_error(msg): def log_error(msg):
print ("Error: {}".format(msg)) print ("Error: {}".format(msg))
@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))
ws.run() bfx.ws.run()

14
bfxapi/examples/send_order.py
View File

@@ -2,30 +2,30 @@ import os
import sys import sys
sys.path.append('../') sys.path.append('../')
from bfxapi.websockets.LiveWebsocket import LiveBfxWebsocket 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")
ws = LiveBfxWebsocket( bfx = Client(
API_KEY=API_KEY, API_KEY=API_KEY,
API_SECRET=API_SECRET, API_SECRET=API_SECRET,
logLevel='INFO' logLevel='INFO'
) )
@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)
@ws.on('error') @bfx.ws.on('error')
def log_error(msg): def log_error(msg):
print ("Error: {}".format(msg)) print ("Error: {}".format(msg))
@ws.on('authenticated') @bfx.ws.on('authenticated')
async def submit_order(auth_message): async def submit_order(auth_message):
await 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)
@@ -35,4 +35,4 @@ async def submit_order(auth_message):
# 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)
ws.run() bfx.ws.run()

18
bfxapi/examples/subscribe_trades_candles.py
View File

@@ -2,27 +2,27 @@ import os
import sys import sys
sys.path.append('../') sys.path.append('../')
from bfxapi.websockets.LiveWebsocket import LiveBfxWebsocket from bfxapi import Client
ws = LiveBfxWebsocket( bfx = Client(
logLevel='INFO' logLevel='INFO'
) )
@ws.on('error') @bfx.ws.on('error')
def log_error(err): def log_error(err):
print ("Error: {}".format(err)) print ("Error: {}".format(err))
@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))
@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():
ws.subscribe('candles', 'tBTCUSD', timeframe='1m') bfx.ws.subscribe('candles', 'tBTCUSD', timeframe='1m')
ws.subscribe('trades', 'tBTCUSD') bfx.ws.subscribe('trades', 'tBTCUSD')
ws.on('connected', start) bfx.ws.on('connected', start)
ws.run() bfx.ws.run()

18
bfxapi/examples/update_order.py
View File

@@ -2,37 +2,37 @@ import os
import sys import sys
sys.path.append('../') sys.path.append('../')
from bfxapi.websockets.LiveWebsocket import LiveBfxWebsocket 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")
ws = LiveBfxWebsocket( bfx = Client(
API_KEY=API_KEY, API_KEY=API_KEY,
API_SECRET=API_SECRET, API_SECRET=API_SECRET,
logLevel='INFO' logLevel='INFO'
) )
@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)
@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 ws.update_order(order.id, price=100, amount=0.01) await bfx.ws.update_order(order.id, price=100, amount=0.01)
@ws.on('error') @bfx.ws.on('error')
def log_error(msg): def log_error(msg):
print ("Error: {}".format(msg)) print ("Error: {}".format(msg))
@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 ws.submit_order('tBTCUSD', 10, 1, 'EXCHANGE LIMIT') await bfx.ws.submit_order('tBTCUSD', 10, 1, 'EXCHANGE LIMIT')
ws.run() bfx.ws.run()

12
bfxapi/examples/wallet_balance.py
View File

@@ -2,27 +2,27 @@ import os
import sys import sys
sys.path.append('../') sys.path.append('../')
from bfxapi.websockets.LiveWebsocket import LiveBfxWebsocket 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")
ws = LiveBfxWebsocket( bfx = Client(
API_KEY=API_KEY, API_KEY=API_KEY,
API_SECRET=API_SECRET, API_SECRET=API_SECRET,
logLevel='INFO' logLevel='INFO'
) )
@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))
@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))
ws.on('error') @bfx.ws.on('error')
def log_error(msg): def log_error(msg):
print ("Error: {}".format(msg)) print ("Error: {}".format(msg))
ws.run() bfx.ws.run()