futures api

Author: oliver-zehentleitner

CHANGELOG.md

@@ -20,16 +20,20 @@ The format is based on [Keep a Changelog](http://keepachangelog.com/) and this p
   - `manager.api.spot.get_ui_klines()`  
   - `manager.api.spot.get_recent_trades()`
   - `manager.api.spot.get_unfilled_order_count()`
-- Support for `Websocket API Futures`:
-  - `manager.api.futures.get_account_status()`
+- Full Support for `Websocket API Futures`:
   - `manager.api.futures.cancel_order()`
   - `manager.api.futures.create_order()`
-  - `manager.api.futures.get_account_status()` (v1+v2)
   - `manager.api.futures.get_account_balance()` (v1+v2)
+  - `manager.api.futures.get_account_position()` (v1+v2)
+  - `manager.api.futures.get_account_status()` (v1+v2)
+  - `manager.api.futures.get_listen_key()`
   - `manager.api.futures.get_order()` 
   - `manager.api.futures.get_order_book()`
+  - `manager.api.futures.get_ticker_order_book()`
+  - `manager.api.futures.get_ticker_price()`
+  - `manager.api.futures.get_server_time()`
   - `manager.api.futures.modify_order()`
-  
+  - `manager.api.futures.ping()`
 ### Changed
 - ujson has been replaced by orjson
 - Websocket API functions are no longer available under `manager.api` but under `manager.api.spot`. In addition, there 

binance_websocket_api_futures.py

@@ -29,16 +29,23 @@ async def handle_socket_message(stream_id=None):
     ubwa.api.futures.get_server_time(stream_id=api_stream)
     orig_client_order_id = ubwa.api.futures.create_order(stream_id=api_stream, price=1.0, order_type="LIMIT",
                                                         quantity=15.0, side="SELL", symbol=market)
-    ubwa.api.futures.ping(stream_id=api_stream)
-    orderbook = ubwa.api.futures.get_order_book(stream_id=api_stream, symbol=market, limit=2, return_response=True)
+    #ubwa.api.futures.ping(stream_id=api_stream)
+    order_book = ubwa.api.futures.get_order_book(stream_id=api_stream, symbol=market, limit=2, return_response=True)
+    print(f"Orderbook, lastUpdateId={order_book['result']['lastUpdateId']}: {order_book['result']['asks']}, "
+          f"{order_book['result']['bids']}\r\n")
     ubwa.api.futures.cancel_order(stream_id=api_stream, symbol=market, orig_client_order_id=orig_client_order_id)
     ubwa.api.futures.get_order(stream_id=api_stream, symbol=market, orig_client_order_id=orig_client_order_id)
 
     print(f"Finished! Waiting for responses:")
     await asyncio.sleep(5)
-
     print(f"Stopping!")
 
+def process_stream_signal(signal_type=None, stream_id=None, data_record=None, error_msg=None):
+    # More info about `stream_signals`:
+    # https://github.com/LUCIT-Systems-and-Development/unicorn-binance-websocket-api/wiki/%60stream_signals%60
+    print(f"Received stream_signal for stream '{ubwa_manager.get_stream_label(stream_id=stream_id)}': "
+          f"{signal_type} - {stream_id} - {data_record} - {error_msg}")
+
 if __name__ == "__main__":
     logging.basicConfig(level=logging.DEBUG,
                         filename=os.path.basename(__file__) + '.log',
@@ -48,7 +55,9 @@ async def handle_socket_message(stream_id=None):
 
     # To use this library you need a valid UNICORN Binance Suite License:
     # https://shop.lucit.services
-    with BinanceWebSocketApiManager(exchange='binance.com-futures') as ubwa_manager:
+    with BinanceWebSocketApiManager(exchange='binance.com-futures',
+                                    output_default="dict",
+                                    process_stream_signals=process_stream_signal) as ubwa_manager:
         try:
             asyncio.run(binance_api(ubwa_manager))
         except KeyboardInterrupt:

examples/binance_websocket_api_spot/binance_websocket_api_spot.py

@@ -81,9 +81,14 @@ async def handle_socket_message(stream_id=None):
 
     recent_trades = ubwa.api.spot.get_recent_trades(stream_id=api_stream, symbol=market, return_response=True)
     print(f"recent_trades: {recent_trades['result'][:5]}\r\n")
-
     print(f"Stopping!")
 
+def process_stream_signal(signal_type=None, stream_id=None, data_record=None, error_msg=None):
+    # More info about `stream_signals`:
+    # https://github.com/LUCIT-Systems-and-Development/unicorn-binance-websocket-api/wiki/%60stream_signals%60
+    print(f"Received stream_signal for stream '{ubwa_manager.get_stream_label(stream_id=stream_id)}': "
+          f"{signal_type} - {stream_id} - {data_record} - {error_msg}")
+
 if __name__ == "__main__":
     logging.basicConfig(level=logging.DEBUG,
                         filename=os.path.basename(__file__) + '.log',
@@ -95,7 +100,9 @@ async def handle_socket_message(stream_id=None):
 
     # To use this library you need a valid UNICORN Binance Suite License:
     # https://shop.lucit.services
-    with BinanceWebSocketApiManager(exchange='binance.com', output_default="dict") as ubwa_manager:
+    with BinanceWebSocketApiManager(exchange='binance.com',
+                                    output_default="dict",
+                                    process_stream_signals=process_stream_signal) as ubwa_manager:
         try:
             asyncio.run(binance_api(ubwa_manager))
         except KeyboardInterrupt: