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

Sync demos in examples/websocket with new bfxapi improvements.

Browse Source
This commit is contained in:
Davide Casale
2023-01-19 16:35:17 +01:00
parent 578882b4c2
commit c471a3b52b
4 changed files with 7 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
examples/websocket/create_order.py
View File

@@ -4,7 +4,7 @@ import os
from bfxapi.client import Client, Constants from bfxapi.client import Client, Constants
from bfxapi.websocket.enums import Error, OrderType from bfxapi.websocket.enums import Error, OrderType
from bfxapi.websocket.typings import Notification, Order from bfxapi.websocket.types import Notification, Order
bfx = Client( bfx = Client(
WSS_HOST=Constants.WSS_HOST, WSS_HOST=Constants.WSS_HOST,
@@ -30,7 +30,7 @@ async def on_authenticated(event):
print("The order has been sent.") print("The order has been sent.")
@bfx.wss.on("on-req-notification") @bfx.wss.on("on-req-notification")
async def on_notification(notification: Notification): async def on_notification(notification: Notification[Order]):
print(f"Notification: {notification}.") print(f"Notification: {notification}.")
@bfx.wss.on("order_new") @bfx.wss.on("order_new")

4
examples/websocket/order_book.py
View File

@@ -7,7 +7,7 @@ from typing import List
from bfxapi import Client, Constants from bfxapi import Client, Constants
from bfxapi.websocket.enums import Channels, Error from bfxapi.websocket.enums import Channels, Error
from bfxapi.websocket.typings import Subscriptions, TradingPairBook from bfxapi.websocket.types import Subscriptions, TradingPairBook
class OrderBook(object): class OrderBook(object):
def __init__(self, symbols: List[str]): def __init__(self, symbols: List[str]):
@@ -18,7 +18,7 @@ class OrderBook(object):
} }
def update(self, symbol: str, data: TradingPairBook) -> None: def update(self, symbol: str, data: TradingPairBook) -> None:
price, count, amount = data["PRICE"], data["COUNT"], data["AMOUNT"] price, count, amount = data.PRICE, data.COUNT, data.AMOUNT
kind = (amount > 0) and "bids" or "asks" kind = (amount > 0) and "bids" or "asks"

4
examples/websocket/raw_order_book.py
View File

@@ -7,7 +7,7 @@ from typing import List
from bfxapi import Client, Constants from bfxapi import Client, Constants
from bfxapi.websocket.enums import Channels, Error from bfxapi.websocket.enums import Channels, Error
from bfxapi.websocket.typings import Subscriptions, TradingPairRawBook from bfxapi.websocket.types import Subscriptions, TradingPairRawBook
class RawOrderBook(object): class RawOrderBook(object):
def __init__(self, symbols: List[str]): def __init__(self, symbols: List[str]):
@@ -18,7 +18,7 @@ class RawOrderBook(object):
} }
def update(self, symbol: str, data: TradingPairRawBook) -> None: def update(self, symbol: str, data: TradingPairRawBook) -> None:
order_id, price, amount = data["ORDER_ID"], data["PRICE"], data["AMOUNT"] order_id, price, amount = data.ORDER_ID, data.PRICE, data.AMOUNT
kind = (amount > 0) and "bids" or "asks" kind = (amount > 0) and "bids" or "asks"

4
examples/websocket/ticker.py
View File

@@ -1,10 +1,8 @@
# python -c "from examples.websocket.ticker import *" # python -c "from examples.websocket.ticker import *"
import asyncio
from bfxapi import Client, Constants from bfxapi import Client, Constants
from bfxapi.websocket.enums import Channels from bfxapi.websocket.enums import Channels
from bfxapi.websocket.typings import Subscriptions, TradingPairTicker from bfxapi.websocket.types import Subscriptions, TradingPairTicker
bfx = Client(WSS_HOST=Constants.PUB_WSS_HOST) bfx = Client(WSS_HOST=Constants.PUB_WSS_HOST)