Sync generated WS files with backend AsyncAPI spec (#191)

* chore: sync generated WS files with backend AsyncAPI spec

* fix(ws): drop announcement_internal accessor (channel spec-excluded)

Backend AsyncAPI spec no longer emits /announcement/listing/internal,
so the regenerated WS_CHANNELS drops it and the hand-written client's
announcement_internal Subscription failed _require_channel at
construction, breaking every WS client test. Remove the accessor and
its docstring/README/docs rows to match the generated surface.

Author: martinkersner

README.md

@@ -572,7 +572,6 @@ you can also read the expected shape at runtime via `ws.<channel>.param_format`.
 | `ws.liquidation`            | `subscribe(*p)`                             | `SYMBOL@exchange`                                    | Basic |
 | `ws.liquidation_feed`       | `stream()`                                  | — (firehose, no params)                             | Basic |
 | `ws.announcement`           | `subscribe()`                               | — (no params)                                       | Pro+  |
-| `ws.announcement_internal`  | `subscribe()`                               | — (no params)                                       | Pro+  |
 
 ### Multiplexing and filtering
 

datamaxi/_ws_endpoints.py

@@ -19,14 +19,6 @@
         "subscribe": True,
         "unsubscribe": True,
     },
-    "/announcement/listing/internal": {
-        "plan": "pro_plus",
-        "market": None,
-        "message": "InternalListingMessage",
-        "param": None,
-        "subscribe": True,
-        "unsubscribe": True,
-    },
     "/forex": {
         "plan": "basic",
         "market": None,

datamaxi/_ws_models.py

@@ -62,21 +62,6 @@
 )
 
 
-# source: asyncapi:payload
-InternalListingMessage = TypedDict(
-    "InternalListingMessage",
-    {
-        "b": str,
-        "d": int,
-        "e": str,
-        "s": str,
-        "t": str,
-        "u": str,
-    },
-    total=False,
-)
-
-
 # source: asyncapi:payload
 LiquidationMessage = TypedDict(
     "LiquidationMessage",

datamaxi/aio/ws.py

@@ -23,7 +23,7 @@
 Channels (accessors driven by the generated ``WS_CHANNELS`` registry):
 ``ticker`` (market-keyed), ``forex``, ``premium``, ``funding_rate``,
 ``open_interest``, ``liquidation`` (subscribe), ``liquidation_feed``
-(firehose, no params), ``announcement`` / ``announcement_internal`` (Pro+).
+(firehose, no params), ``announcement`` (Pro+).
 
 Consumes the **generated** WS surface — ``WS_CHANNELS`` / ``WS_BASE_PATH`` /
 ``WS_AUTH_HEADER`` from ``datamaxi._ws_endpoints`` and the per-channel message
@@ -419,7 +419,7 @@ class AsyncDatamaxiWS:
     Accessors are driven by the generated ``WS_CHANNELS`` registry:
     ``ticker`` (market-keyed), ``forex``, ``premium``, ``funding_rate``,
     ``open_interest``, ``liquidation`` (subscribe), ``liquidation_feed``
-    (firehose), ``announcement`` / ``announcement_internal`` (Pro+).
+    (firehose), ``announcement`` (Pro+).
 
     Use as an async context manager so open connections are closed, or call
     :meth:`aclose` explicitly.
@@ -449,9 +449,6 @@ def __init__(
         self.liquidation = Subscription(self, "/liquidation")
         self.liquidation_feed = Feed(self, "/liquidation/feed")
         self.announcement = Subscription(self, "/announcement/listing")
-        self.announcement_internal = Subscription(
-            self, "/announcement/listing/internal"
-        )
 
     async def _conn(self, path: str) -> AsyncWSConnection:
         conn = self._conns.get(path)

docs/websocket.md

@@ -53,7 +53,6 @@ strings shown below; you can also inspect the expected format at runtime via
 | `ws.liquidation`            | `subscribe(*p)`                             | `SYMBOL@exchange`                                    | Basic |
 | `ws.liquidation_feed`       | `stream()`                                  | — (firehose, no params)                             | Basic |
 | `ws.announcement`           | `subscribe()`                               | — (no params)                                       | Pro+  |
-| `ws.announcement_internal`  | `subscribe()`                               | — (no params)                                       | Pro+  |
 
 `ticker` is market-keyed — pass `market="spot"` (default) or `market="futures"`.
 The announcement channels require a **Pro+** plan.

tests/test_ws.py

@@ -63,7 +63,6 @@ def test_ws_every_channel_has_a_generated_model_and_accessor():
         "liquidation",
         "liquidation_feed",
         "announcement",
-        "announcement_internal",
     ):
         assert hasattr(ws, name), f"client missing ws.{name}"