Merge pull request #6 from tomvanderlee/feature/websocketsv2.1.0main

Added websocket support

1 files changed, 45 insertions, 6 deletions

diff --git a/ttun_server/types.py b/ttun_server/types.py
index 8a4d929..8591e7d 100644
--- a/ttun_server/types.py
+++ b/ttun_server/types.py
@@ -3,7 +3,7 @@ from enum import Enum
 from typing import TypedDict, Optional
 
 
-class MessageType(Enum):
+class HttpMessageType(Enum):
     request = 'request'
     response = 'response'
 
@@ -13,23 +13,62 @@ class Config(TypedDict):
     client_version: str
 
 
-class RequestData(TypedDict):
+class HttpRequestData(TypedDict):
     method: str
     path: str
     headers: list[tuple[str, str]]
     body: Optional[str]
 
 
-class ResponseData(TypedDict):
+class HttpResponseData(TypedDict):
     status: int
     headers: list[tuple[str, str]]
     body: Optional[str]
 
 
-class Message(TypedDict):
-    type: MessageType
+class HttpMessage(TypedDict):
+    type: HttpMessageType
     identifier: str
-    payload: Config | RequestData | ResponseData
+    payload: Config | HttpRequestData | HttpResponseData
+
+
+class WebsocketMessageType(Enum):
+    connect = 'connect'
+    disconnect = 'disconnect'
+    message = 'message'
+    ack = 'ack'
+
+
+class WebsocketConnectData(TypedDict):
+    path: str
+    headers: list[tuple[str, str]]
+
+
+class WebsocketDisconnectData(TypedDict):
+    close_code: int
+
+
+class WebsocketMessageData(TypedDict):
+    body: Optional[str]
+
+
+class WebsocketMessage(TypedDict):
+    type: WebsocketMessageType
+    identifier: str
+    payload: WebsocketConnectData | WebsocketDisconnectData | WebsocketMessageData
+
+
+class MessageType(Enum):
+    request = 'request'
+    response = 'response'
+
+    ws_connect = 'connect'
+    ws_disconnect = 'disconnect'
+    ws_message = 'message'
+    ws_ack = 'ack'
+
+
+Message = HttpMessage | WebsocketMessage
 
 
 class MemoryConnection(TypedDict):