Migrate to colyseus

.env-example

@@ -1,4 +1,8 @@
 TICKRATE=24
-COUNTDOWN=5
+COUNTDOWN=5000
+COUNTDOWN_SPAWN_SELECTION=10000
+COUNTDOWN_DEFAULT=15000
 MAX_SESSION_PER_WORKER=10
-MINIMUM_PLAYERS_PER_SESSION=2
+MINIMUM_PLAYERS_PER_SESSION=2
+COLYSEUS_SERVER_URL=localhost
+PORT=3000

.gitignore

@@ -1,2 +1,3 @@
 node_modules/
 dist/
+*.env*

.vscode/settings.json

@@ -0,0 +1,2 @@
+{
+}

Dockerfile

@@ -1,8 +1,7 @@
-FROM node:16
+FROM node:18
 WORKDIR /rtsApp
 COPY package*.json ./
 RUN npm install
 COPY . .
 EXPOSE 3000
-EXPOSE 3007
-CMD ["npm", "start"]
+CMD ["npm", "run", "deploy"]

README.md

@@ -19,3 +19,17 @@ This is a timestep based approach that makes sure server only send delta updates
 
 Both the GIFs shows basic boid avoidance behaviour
 [![Image from Gyazo](https://i.gyazo.com/2dec336b740c0d9ecf454c53cac8991f.gif)](https://gyazo.com/2dec336b740c0d9ecf454c53cac8991f)
+
+
+# Getting Started
+
+1. Build the client side code, this includes phaser related code that is used to draw/render game on the browser.
+> npm run build
+
+
+2. Once done, simply run the server.
+> npx ts-node server.ts
+
+3. Check the port where server is running and you're good to go.
+   1. Create game room
+   2. open another window on same url, click on join room (it may take few seconds)

common/PacketType.ts

@@ -0,0 +1,43 @@
+export enum ClientToServerPacketType {
+  CLIENT_INIT_REQUESTED = "cir",
+  PLAYER_READY = "plr",
+  PLAYER_UNREADY = "plur",
+  SOLDIER_CREATE_REQUESTED = "slcrreq",
+  SPAWN_POINT_REQUESTED = "spwnpntreq",
+  SOLDIER_DELETED = "sldel",
+  SOLDIER_MOVE_REQUESTED = "slmovreq",
+  PLAYER_JOINED = "pljoin",
+  SOLDIER_ATTACK_REQUESTED = "sldierattkreq",
+  CLIENT_SENT_CHAT = "clientchat",
+  SPAWN_POINT_SELECTED = "spwnpntslct",
+  SOLDIER_SPAWN_REQUESTED = "unitspwnreq",
+}
+export enum ServerToClientPacketType {
+  NEW_CHAT_MESSAGE = "newcm",
+  SOLDIER_KILLED = "sk",
+  GAME_STARTED = "gs",
+  SOLDIER_CREATE_ACK = "sca",
+  SOLDIER_SPAWN_SCHEDULED = "sspwnsch",
+  SPAWN_POINT_ACK = "spnpntack",
+  GAME_STATE_SYNC = "gss",
+  PLAYER_LEFT = "pl",
+  PLAYER_INIT = "pi",
+  PLAYER_LOST = "plyrlost",
+  SOLDIER_ATTACK_ACK = "saa",
+  SOLDIER_ATTACKED = "sh",
+  PLAYER_RESOURCE_UPDATED = "pru",
+  SOLDIER_POSITION_UPDATED = "spu",
+  COUNTDOWN_TIME = "cdwn",
+  SOLDIER_STATE_DEBUG = "debug_soldierState",
+
+  SOLDIER_SPAWN_REQUEST_UPDATED = "spawn_request_updated",
+}
+
+export const PacketType = {
+  ByClient: {
+    ...ClientToServerPacketType,
+  },
+  ByServer: {
+    ...ServerToClientPacketType,
+  },
+};

common/Queue.ts

@@ -0,0 +1,44 @@
+import LinkedList from "dbly-linked-list";
+export class Queue<T extends object | number | string = string> {
+  mList: LinkedList;
+  constructor() {
+    this.mList = new LinkedList();
+  }
+  enqueue(data: T) {
+    this.mList.insert(data);
+  }
+  dequeue() {
+    if (this.mList.isEmpty()) return;
+    this.mList.removeFirst();
+  }
+  peekFront() {
+    const headNode = this.mList.getHeadNode();
+    if (this.mList.isEmpty() || !headNode) return null;
+    return headNode.getData<T>();
+  }
+  peekEnd() {
+    const tailNode = this.mList.getTailNode();
+    if (this.mList.isEmpty() || !tailNode) return null;
+    return tailNode.getData<T>();
+  }
+  toArray() {
+    return this.mList.toArray().map((d) => d as T);
+  }
+  findAt(offset: number) {
+    if (this.mList.getSize() === 0) return null;
+    if (offset >= this.mList.getSize() && this.mList.getSize() > 0)
+      offset = offset % this.mList.getSize();
+    return this.mList.findAt(offset).getData<T>();
+  }
+  removeNode(data: T) {
+    let contains = this.mList.contains(data);
+    if (contains) this.mList.removeNode(data);
+    return contains;
+  }
+  isEmpty() {
+    return this.mList.isEmpty();
+  }
+  getSize() {
+    return this.mList.getSize();
+  }
+}

common/SoldierType.ts

@@ -0,0 +1,11 @@
+export type SoldierType = "SPEARMAN" | "KNIGHT";
+export const SoldierTypeConfig: {
+  [K in SoldierType]: { cost: number };
+} = {
+  SPEARMAN: {
+    cost: 10,
+  },
+  KNIGHT: {
+    cost: 20,
+  },
+};

common/__tests__/Queue.test.ts

@@ -0,0 +1,70 @@
+import { Queue } from "../Queue";
+
+describe("Queue", () => {
+  let queue: Queue<string>;
+  beforeEach(() => {
+    queue = new Queue<string>();
+  });
+
+  test("enqueue", () => {
+    queue.enqueue("first");
+    queue.enqueue("second");
+    queue.enqueue("third");
+    expect(queue.getSize()).toBe(3);
+    expect(queue.peekFront()).toBe("first");
+    expect(queue.peekEnd()).toBe("third");
+  });
+
+  test("dequeue", () => {
+    queue.enqueue("first");
+    queue.enqueue("second");
+    queue.enqueue("third");
+    queue.dequeue();
+    expect(queue.getSize()).toBe(2);
+    expect(queue.peekFront()).toBe("second");
+    expect(queue.peekEnd()).toBe("third");
+  });
+
+  test("toArray", () => {
+    queue.enqueue("first");
+    queue.enqueue("second");
+    queue.enqueue("third");
+    expect(queue.toArray()).toEqual(
+      expect.arrayContaining(["first", "second", "third"])
+    );
+  });
+
+  test("peekFront", () => {
+    queue.enqueue("first");
+    expect(queue.peekFront()).toBe("first");
+    expect(queue.getSize()).toBe(1);
+  });
+
+  test("peekEnd", () => {
+    queue.enqueue("first");
+    expect(queue.peekEnd()).toBe("first");
+    expect(queue.getSize()).toBe(1);
+  });
+
+  test("findAt", () => {
+    queue.enqueue("first");
+    queue.enqueue("second");
+    queue.enqueue("third");
+    expect(queue.findAt(1)).toBe("second");
+    expect(queue.findAt(3)).toBe("first");
+  });
+
+  test("removeNode", () => {
+    queue.enqueue("first");
+    queue.enqueue("second");
+    queue.enqueue("third");
+    expect(queue.removeNode("second")).toBe(true);
+    expect(queue.getSize()).toBe(2);
+  });
+
+  test("isEmpty", () => {
+    expect(queue.isEmpty()).toBe(true);
+    queue.enqueue("first");
+    expect(queue.isEmpty()).toBe(false);
+  });
+});