2023-11-28 14:29:16 -08:00
|
|
|
from typing import Any, Dict, Type, TypeVar, Union
|
2023-11-28 14:16:05 -08:00
|
|
|
|
2023-11-28 14:29:16 -08:00
|
|
|
import attr
|
2023-08-30 15:59:51 -07:00
|
|
|
|
|
|
|
from .failure_web_socket_response import FailureWebSocketResponse
|
|
|
|
from .success_web_socket_response import SuccessWebSocketResponse
|
|
|
|
|
2023-11-28 14:29:16 -08:00
|
|
|
GY = TypeVar("GY", bound="WebSocketResponse")
|
2023-11-28 14:16:05 -08:00
|
|
|
|
2023-11-28 14:29:16 -08:00
|
|
|
|
|
|
|
@attr.s(auto_attribs=True)
|
2023-11-28 14:16:05 -08:00
|
|
|
class WebSocketResponse:
|
|
|
|
|
|
|
|
"""Websocket responses can either be successful or unsuccessful. Slightly different schemas in either case."""
|
|
|
|
|
|
|
|
type: Union[
|
|
|
|
SuccessWebSocketResponse,
|
|
|
|
FailureWebSocketResponse,
|
2023-11-28 14:29:16 -08:00
|
|
|
]
|
2023-11-28 14:16:05 -08:00
|
|
|
|
|
|
|
def __init__(
|
|
|
|
self,
|
|
|
|
type: Union[
|
2023-11-28 14:29:16 -08:00
|
|
|
SuccessWebSocketResponse,
|
|
|
|
FailureWebSocketResponse,
|
2023-11-28 14:16:05 -08:00
|
|
|
],
|
|
|
|
):
|
|
|
|
self.type = type
|
|
|
|
|
|
|
|
def to_dict(self) -> Dict[str, Any]:
|
|
|
|
if isinstance(self.type, SuccessWebSocketResponse):
|
2023-11-28 14:29:16 -08:00
|
|
|
XP: SuccessWebSocketResponse = self.type
|
|
|
|
return XP.to_dict()
|
2023-11-28 14:16:05 -08:00
|
|
|
elif isinstance(self.type, FailureWebSocketResponse):
|
2023-11-28 14:29:16 -08:00
|
|
|
QM: FailureWebSocketResponse = self.type
|
|
|
|
return QM.to_dict()
|
2023-11-28 14:16:05 -08:00
|
|
|
|
|
|
|
raise Exception("Unknown type")
|
|
|
|
|
2023-11-28 14:29:16 -08:00
|
|
|
@classmethod
|
|
|
|
def from_dict(cls: Type[GY], d: Dict[str, Any]) -> GY:
|
2023-11-28 14:16:05 -08:00
|
|
|
if d.get("type") == "SuccessWebSocketResponse":
|
2023-11-28 14:29:16 -08:00
|
|
|
VT: SuccessWebSocketResponse = SuccessWebSocketResponse()
|
|
|
|
VT.from_dict(d)
|
|
|
|
return cls(type=VT)
|
2023-11-28 14:16:05 -08:00
|
|
|
elif d.get("type") == "FailureWebSocketResponse":
|
2023-11-28 14:29:16 -08:00
|
|
|
UR: FailureWebSocketResponse = FailureWebSocketResponse()
|
|
|
|
UR.from_dict(d)
|
|
|
|
return cls(type=UR)
|
2023-11-28 14:16:05 -08:00
|
|
|
|
|
|
|
raise Exception("Unknown type")
|