chore(deps): add rusty-motors-chat as a dependency

package.json

@@ -39,6 +39,7 @@
         "lobby": "link:packages/lobby",
         "moment": "^2.29.4",
         "pino": "^9.3.2",
+        "rusty-motors-chat": "link:src/chat",
         "rusty-motors-cli": "link:packages/cli",
         "rusty-motors-connection": "link:packages/connection",
         "rusty-motors-database": "link:packages/database",

pnpm-workspace.yaml

@@ -1,2 +1,3 @@
 packages:
   - 'packages/*'
+  - "src/*"

src/chat/index.ts

@@ -0,0 +1,46 @@
+import {
+    GameMessage,
+    getServerLogger,
+    type ServiceResponse,
+} from "rusty-motors-shared";
+import type { Serializable } from "rusty-motors-shared-packets";
+
+/**
+ * Receive chat data
+ *
+ * @param connectionId - Connection ID
+ * @param message - Message
+ * @returns Service response
+ */
+async function receiveChatData({
+    connectionId,
+    message,
+}: {
+    connectionId: string;
+    message: Serializable;
+}): Promise<ServiceResponse> {
+    const log = getServerLogger({});
+
+    log.info(`Received chat data from connection ${connectionId}`);
+    log.debug(`Message: ${message.toHexString()}`);
+
+    const inboundMessage = new GameMessage(0);
+    inboundMessage.deserialize(message.serialize());
+
+    log.debug(`Deserialized message: ${inboundMessage.toHexString()}`);
+
+    const id = inboundMessage._header.id;
+
+    log.debug(`Message ID: ${id}`);
+
+    throw new Error(
+        `Unable to process chat data from connection ${connectionId}, data: ${message.toHexString()}`,
+    );
+
+    return {
+        connectionId,
+        messages: [],
+    };
+}
+
+export { receiveChatData };

src/chat/package.json

@@ -0,0 +1,17 @@
+{
+  "name": "rusty-motors-chat",
+  "version": "1.0.0",
+  "exports": {
+    ".": {
+      "import": "./index.js"
+    }
+  },
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "type": "module",
+  "keywords": [],
+  "author": "",
+  "license": "ISC",
+  "description": ""
+}

src/chat/tsconfig.json

@@ -0,0 +1,11 @@
+{
+	"extends": "../../tsconfig.base.json",
+    "compilerOptions": {
+		"incremental": true,
+        "composite": true
+	},
+	"include": [
+		"index.ts",
+		"**/*.ts"
+	]
+}

src/chat/types.ts

@@ -0,0 +1 @@
+export type GameSocketCallback = (messages: Buffer[]) => void;

src/chat/vite.config.ts

@@ -0,0 +1,22 @@
+import { defineConfig } from "vitest/config";
+
+export default defineConfig({
+	test: {
+		coverage: {
+			enabled: true,
+			all: true,
+			exclude: [
+				"src/**/*.spec.ts",
+				"src/**/*.test.ts",
+				"bin/**/*.ts",
+				"ecosystem.config.js",
+				"migrate.ts",
+				"packages/**/*.d.ts",
+			],
+			reporter: ["lcov", "text", "cobertura"],
+		},
+		reporters: ["junit", "default", "hanging-process"],
+		outputFile: "mcos.junit.xml",
+		pool: "forks",
+	},
+});