updated based on review comments

Author: andreinasui

examples/basic_ws.py

@@ -20,7 +20,7 @@ def main():
     info.subscribe({"type": "bbo", "coin": "ETH"}, print)
     info.subscribe({"type": "activeAssetCtx", "coin": "BTC"}, print)  # Perp
     info.subscribe({"type": "activeAssetCtx", "coin": "@1"}, print)  # Spot
-    info.subscribe({"type": "activeAssetData", "user": address, "coin": "BTC"}, print)  # Perp
+    info.subscribe({"type": "activeAssetData", "user": address, "coin": "BTC"}, print)  # Perp only
 
 
 if __name__ == "__main__":

hyperliquid/utils/types.py

@@ -84,7 +84,7 @@
     {
         "type": Union[Literal["cross"], Literal["isolated"]],
         "value": int,
-        "rawUsd": Optional[str],
+        "rawUsd": NotRequired[str],
     },
 )
 TradesMsg = TypedDict("TradesMsg", {"channel": Literal["trades"], "data": List[Trade]})
@@ -115,8 +115,8 @@
         "user": str,
         "coin": str,
         "leverage": Leverage,
-        "maxTradeSzs": List[str],
-        "availableToTrade": List[str],
+        "maxTradeSzs": Tuple[str, str],
+        "availableToTrade": Tuple[str, str],
         "markPx": str,
     },
 )
@@ -170,6 +170,7 @@
     OtherWsMsg,
     ActiveAssetCtxMsg,
     ActiveSpotAssetCtxMsg,
+    ActiveAssetDataMsg,
 ]
 
 # b is the public address of the builder, f is the amount of the fee in tenths of basis points. e.g. 10 means 1 basis point

hyperliquid/websocket_manager.py

@@ -36,7 +36,7 @@ def subscription_to_identifier(subscription: Subscription) -> str:
     elif subscription["type"] == "activeAssetCtx":
         return f'activeAssetCtx:{subscription["coin"].lower()}'
     elif subscription["type"] == "activeAssetData":
-        return f'activeAssetData:{subscription["coin"].lower()}'
+        return f'activeAssetData:{subscription["coin"].lower()},{subscription["user"]}'
 
 
 def ws_msg_to_identifier(ws_msg: WsMsg) -> Optional[str]:
@@ -71,7 +71,7 @@ def ws_msg_to_identifier(ws_msg: WsMsg) -> Optional[str]:
     elif ws_msg["channel"] == "activeAssetCtx" or ws_msg["channel"] == "activeSpotAssetCtx":
         return f'activeAssetCtx:{ws_msg["data"]["coin"].lower()}'
     elif ws_msg["channel"] == "activeAssetData":
-        return f'activeAssetData:{ws_msg["data"]["coin"].lower()}'
+        return f'activeAssetData:{ws_msg["data"]["coin"].lower()},{ws_msg["data"]["user"]}'
 
 
 class WebsocketManager(threading.Thread):