Fix and remove incomplete internal msgpack handling

Author: kutay25

lighter/paper_client/client.py

@@ -73,9 +73,9 @@ def __init__(
         self.account = new_paper_account(initial_collateral_usdc)
         self.market_configs: Dict[int, MarketConfig] = {}
         self.order_books: Dict[int, InMemoryOrderBook] = {}
-        self.ws_url = (
-            ws_url if ws_url is not None else self._default_ws_url(api_client, ws_path)
-        )
+        raw_ws_url = ws_url if ws_url is not None else self._default_ws_url(api_client, ws_path)
+        separator = "&" if "?" in raw_ws_url else "?"
+        self.ws_url = f"{raw_ws_url}{separator}encoding=json"
         self.initial_snapshot_timeout = initial_snapshot_timeout
         self._live_listeners: Dict[int, PaperOrderBookListener] = {}
         self._state_lock = asyncio.Lock()

lighter/paper_client/live.py

@@ -90,8 +90,11 @@ async def _run(self) -> None:
 
     async def _handle_raw_message(self, raw_message: Any) -> None:
         if isinstance(raw_message, bytes):
-            raw_message = raw_message.decode()
-        message = json.loads(raw_message) if isinstance(raw_message, str) else raw_message
+            raise TypeError(
+                "received binary websocket frame; paper client only supports "
+                "JSON encoding (ensure ws URL includes ?encoding=json)"
+            )
+        message = json.loads(raw_message)
         message_type = message.get("type")
 
         if message_type == "connected":