Refactor websockets

3 files changed, 66 insertions, 0 deletions

diff --git a/backend/src/model/actions/coop.ts b/backend/src/model/actions/coop.ts
new file mode 100644
index 0000000..e1dfed5
--- /dev/null
+++ b/backend/src/model/actions/coop.ts
@@ -0,0 +1,43 @@
+import { SessionState } from "../session";
+
+export type CoopSessionCreatedMessage = {
+  type: "create";
+  payload: {
+    sessionId: string;
+  };
+};
+
+export type ClientJoinedCoopSessionMessage = {
+  type: "join";
+  payload: {
+    numberOfClients: number;
+  };
+};
+
+export type CoopSessionStateChangeMessage = {
+  type: "state";
+  payload: {
+    state: SessionState;
+  };
+};
+
+export type CoopSessionMoveMessage = {
+  type: "move";
+  payload: {
+    move: string;
+  };
+};
+
+export type CoopSessionMoveTimeoutMessage = {
+  type: "timeout";
+  payload: {
+    timeoutUntil: number;
+  };
+};
+
+export type CoopSessionMessage =
+  | CoopSessionCreatedMessage
+  | ClientJoinedCoopSessionMessage
+  | CoopSessionStateChangeMessage
+  | CoopSessionMoveMessage
+  | CoopSessionMoveTimeoutMessage;
\ No newline at end of file
diff --git a/backend/src/model/session.ts b/backend/src/model/session.ts
new file mode 100644
index 0000000..d2fdea3
--- /dev/null
+++ b/backend/src/model/session.ts
@@ -0,0 +1,16 @@
+import { CoopWebSocket } from "./websocket";
+
+export type CoopSession = {
+  id: string;
+  state: SessionState;
+  host: CoopWebSocket;
+  clients: CoopWebSocket[];
+};
+
+export type VersusSession = {
+  id: string;
+  state: SessionState;
+  clients: string[];
+};
+
+export type SessionState = 'waiting' | 'playing' | 'finished';
\ No newline at end of file
diff --git a/backend/src/model/websocket.ts b/backend/src/model/websocket.ts
new file mode 100644
index 0000000..bb2ae8d
--- /dev/null
+++ b/backend/src/model/websocket.ts
@@ -0,0 +1,7 @@
+import { WebSocket } from 'ws';
+
+export interface CoopWebSocket extends WebSocket {
+  clientId: string;
+  sessionId: string;
+  nextMoveTimestamp: number;
+}