Skip to content

Commit 56b28d3

Browse files
Use TypeAdapter to decode handshake request payload
1 parent 0743b89 commit 56b28d3

1 file changed

Lines changed: 4 additions & 3 deletions

File tree

tests/v2/test_v2_cancellation.py

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@
1010
import msgpack
1111
import nanoid
1212
import pytest
13+
from pydantic import TypeAdapter
1314

1415
from replit_river.messages import parse_transport_msg
1516
from replit_river.rpc import (
@@ -279,9 +280,9 @@ async def test_subscription_cancel(ws_server: WsServerFixture) -> None:
279280

280281
assert not isinstance(request_msg, str)
281282
assert (serverconn := conn())
282-
handshake_request: ControlMessageHandshakeRequest[None] = (
283-
ControlMessageHandshakeRequest(**request_msg.payload)
284-
)
283+
handshake_request = TypeAdapter(
284+
ControlMessageHandshakeRequest[None]
285+
).validate_python(request_msg.payload)
285286

286287
handshake_resp = ControlMessageHandshakeResponse(
287288
status=HandShakeStatus(

0 commit comments

Comments
 (0)