Add support for event base_margin_info and symbol_margin_info.

Author: Davi0kProgramsThings

MANIFEST

@@ -248,7 +248,7 @@ def get_ledgers(
 
     def get_base_margin_info(self) -> BaseMarginInfo:
         return serializers.BaseMarginInfo.parse(
-            *(self._m.post("auth/r/info/margin/base")[1])
+            *self._m.post("auth/r/info/margin/base")
         )
 
     def get_symbol_margin_info(self, symbol: str) -> SymbolMarginInfo:

bfxapi/rest/_interfaces/rest_auth_endpoints.py

@@ -745,7 +745,15 @@
 BaseMarginInfo = generate_labeler_serializer(
     name="BaseMarginInfo",
     klass=dataclasses.BaseMarginInfo,
-    labels=["user_pl", "user_swaps", "margin_balance", "margin_net", "margin_min"],
+    labels=[
+        "_PLACEHOLDER",
+        "user_pl",
+        "user_swaps",
+        "margin_balance",
+        "margin_net",
+        "margin_min",
+    ],
+    flat=True,
 )
 
 PositionClaim = generate_labeler_serializer(

bfxapi/types/serializers.py

@@ -64,6 +64,8 @@
     "trade_execution",
     "trade_execution_update",
     "wallet_update",
+    "base_margin_info",
+    "symbol_margin_info",
     "notification",
     "on-req-notification",
     "ou-req-notification",
@@ -105,7 +107,7 @@ def on(
     ) -> Union[_Handler, Callable[[_Handler], _Handler]]:
         if event not in BfxEventEmitter._EVENTS:
             raise UnknownEventError(
-                f"Can't register to unknown event: <{event}> (to get a full"
+                f"Can't register to unknown event: <{event}> (to get a full "
                 "list of available events see https://docs.bitfinex.com/)."
             )
 

bfxapi/websocket/_event_emitter/bfx_event_emitter.py

@@ -51,17 +51,26 @@ def __init__(self, event_emitter: EventEmitter) -> None:
     def handle(self, abbrevation: str, stream: Any) -> None:
         if abbrevation == "n":
             self.__notification(stream)
+        elif abbrevation == "miu":
+            if stream[0] == "base":
+                self.__event_emitter.emit(
+                    "base_margin_info", serializers.BaseMarginInfo.parse(*stream)
+                )
+            elif stream[0] == "sym":
+                self.__event_emitter.emit(
+                    "symbol_margin_info", serializers.SymbolMarginInfo.parse(*stream)
+                )
+        else:
+            for abbrevations, serializer in AuthEventsHandler.__SERIALIZERS.items():
+                if abbrevation in abbrevations:
+                    event = AuthEventsHandler.__ABBREVIATIONS[abbrevation]
 
-        for abbrevations, serializer in AuthEventsHandler.__SERIALIZERS.items():
-            if abbrevation in abbrevations:
-                event = AuthEventsHandler.__ABBREVIATIONS[abbrevation]
+                    if all(isinstance(sub_stream, list) for sub_stream in stream):
+                        data = [serializer.parse(*sub_stream) for sub_stream in stream]
+                    else:
+                        data = serializer.parse(*stream)
 
-                if all(isinstance(sub_stream, list) for sub_stream in stream):
-                    data = [serializer.parse(*sub_stream) for sub_stream in stream]
-                else:
-                    data = serializer.parse(*stream)
-
-                self.__event_emitter.emit(event, data)
+                    self.__event_emitter.emit(event, data)
 
     def __notification(self, stream: Any) -> None:
         event: str = "notification"