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

Separate _BfxWebsocketInputs from bfxapi/websocket/BfxWebsocketClient.py to _BfxWebsocketInputs.py. Rename websocket authenticated inputs methods. Refactoring to maintain consistency across the library.

Browse Source
This commit is contained in:
Davide Casale
2023-01-12 18:10:00 +01:00
parent ccabb0f2c2
commit ff58f049a7
6 changed files with 100 additions and 107 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
bfxapi/websocket/BfxWebsocketClient.py
View File

@@ -1,12 +1,10 @@
import traceback, json, asyncio, hmac, hashlib, time, uuid, websockets
from typing import Tuple, Union, Literal, TypeVar, Callable, cast
from enum import Enum
from typing import Literal, TypeVar, Callable, cast
from pyee.asyncio import AsyncIOEventEmitter
from .typings import Inputs
from ._BfxWebsocketInputs import _BfxWebsocketInputs
from .handlers import Channels, PublicChannelsHandler, AuthenticatedChannelsHandler
from .exceptions import ConnectionNotOpen, TooManySubscriptions, WebsocketAuthenticationRequired, InvalidAuthenticationCredentials, EventNotSupported, OutdatedClientVersion
@@ -230,29 +228,4 @@ class _BfxWebsocketBucket(object):
@_require_websocket_connection
async def _close(self, code=1000, reason=str()):
await self.websocket.close(code=code, reason=reason)
class _BfxWebsocketInputs(object):
def __init__(self, __handle_websocket_input):
self.__handle_websocket_input = __handle_websocket_input
async def order_new(self, data: Inputs.Order.New):
await self.__handle_websocket_input("on", data)
async def order_update(self, data: Inputs.Order.Update):
await self.__handle_websocket_input("ou", data)
async def order_cancel(self, data: Inputs.Order.Cancel):
await self.__handle_websocket_input("oc", data)
async def order_multiple_operations(self, *args: Tuple[str, Union[Inputs.Order.New, Inputs.Order.Update, Inputs.Order.Cancel]]):
await self.__handle_websocket_input("ox_multi", args)
async def offer_new(self, data: Inputs.Offer.New):
await self.__handle_websocket_input("fon", data)
async def offer_cancel(self, data: Inputs.Offer.Cancel):
await self.__handle_websocket_input("foc", data)
async def calc(self, *args: str):
await self.__handle_websocket_input("calc", list(map(lambda arg: [arg], args)))
await self.websocket.close(code=code, reason=reason)