Merge pull request #1 from Simponic/network

Network

6 files changed, 183 insertions, 0 deletions

diff --git a/server/src/network/MessageProcessor.ts b/server/src/network/MessageProcessor.ts
new file mode 100644
index 0000000..2d9f11f
--- /dev/null
+++ b/server/src/network/MessageProcessor.ts
@@ -0,0 +1,36 @@
+import {
+  EntityUpdateBody,
+  MessageProcessor,
+  MessageType
+} from '@engine/network';
+import { ServerMessage, SessionManager } from '.';
+import { Game } from '@engine/Game';
+
+export class ServerMessageProcessor implements MessageProcessor {
+  private game: Game;
+  private sessionManager: SessionManager;
+
+  constructor(game: Game, sessionManager: SessionManager) {
+    this.game = game;
+    this.sessionManager = sessionManager;
+  }
+
+  public process(message: ServerMessage) {
+    switch (message.type) {
+      case MessageType.NEW_INPUT: {
+        const { sessionId } = message.sessionData;
+        const session = this.sessionManager.getSession(sessionId);
+        session?.inputSystem.keyPressed(message.body as string);
+        break;
+      }
+      case MessageType.REMOVE_INPUT: {
+        const { sessionId } = message.sessionData;
+        const session = this.sessionManager.getSession(sessionId);
+        session?.inputSystem.keyReleased(message.body as string);
+        break;
+      }
+      default:
+        break;
+    }
+  }
+}
diff --git a/server/src/network/MessagePublisher.ts b/server/src/network/MessagePublisher.ts
new file mode 100644
index 0000000..9c6011f
--- /dev/null
+++ b/server/src/network/MessagePublisher.ts
@@ -0,0 +1,31 @@
+import { Message, MessagePublisher } from '@engine/network';
+import { Server } from 'bun';
+import { Constants } from '../constants';
+import { stringify } from '@engine/utils';
+
+export class ServerSocketMessagePublisher implements MessagePublisher {
+  private server?: Server;
+  private messages: Message[];
+
+  constructor(server?: Server) {
+    this.messages = [];
+
+    if (server) this.setServer(server);
+  }
+
+  public setServer(server: Server) {
+    this.server = server;
+  }
+
+  public addMessage(message: Message) {
+    this.messages.push(message);
+  }
+
+  public publish() {
+    if (this.messages.length) {
+      this.server?.publish(Constants.GAME_TOPIC, stringify(this.messages));
+
+      this.messages = [];
+    }
+  }
+}
diff --git a/server/src/network/MessageReceiver.ts b/server/src/network/MessageReceiver.ts
new file mode 100644
index 0000000..fcac0a4
--- /dev/null
+++ b/server/src/network/MessageReceiver.ts
@@ -0,0 +1,22 @@
+import { MessageQueueProvider } from '@engine/network';
+import type { ServerMessage } from '.';
+
+export class ServerSocketMessageReceiver implements MessageQueueProvider {
+  private messages: ServerMessage[];
+
+  constructor() {
+    this.messages = [];
+  }
+
+  public addMessage(message: ServerMessage) {
+    this.messages.push(message);
+  }
+
+  public getNewMessages() {
+    return this.messages;
+  }
+
+  public clearMessages() {
+    this.messages = [];
+  }
+}
diff --git a/server/src/network/SessionInputSystem.ts b/server/src/network/SessionInputSystem.ts
new file mode 100644
index 0000000..44fba54
--- /dev/null
+++ b/server/src/network/SessionInputSystem.ts
@@ -0,0 +1,32 @@
+import { Game } from '@engine/Game';
+import { SessionManager } from '.';
+import { System } from '@engine/systems';
+import { BoundingBox, ComponentNames, Control } from '@engine/components';
+
+export class SessionInputSystem extends System {
+  private sessionManager: SessionManager;
+
+  constructor(sessionManager: SessionManager) {
+    super('SessionInputSystem');
+
+    this.sessionManager = sessionManager;
+  }
+
+  public update(_dt: number, game: Game) {
+    this.sessionManager.getSessions().forEach((sessionId) => {
+      const session = this.sessionManager.getSession(sessionId);
+
+      if (!session) return;
+
+      const { inputSystem } = session;
+      session.controllableEntities.forEach((entityId) => {
+        const entity = game.getEntity(entityId);
+        if (!entity) return;
+
+        if (entity.hasComponent(ComponentNames.Control)) {
+          inputSystem.handleInput(entity);
+        }
+      });
+    });
+  }
+}
diff --git a/server/src/network/SessionManager.ts b/server/src/network/SessionManager.ts
new file mode 100644
index 0000000..dbd4364
--- /dev/null
+++ b/server/src/network/SessionManager.ts
@@ -0,0 +1,33 @@
+import { Session, SessionManager } from '.';
+
+export class MemorySessionManager implements SessionManager {
+  private sessions: Map<string, Session>;
+
+  constructor() {
+    this.sessions = new Map();
+  }
+
+  public getSessions() {
+    return Array.from(this.sessions.keys());
+  }
+
+  public uniqueSessionId() {
+    return crypto.randomUUID();
+  }
+
+  public getSession(id: string) {
+    return this.sessions.get(id);
+  }
+
+  public putSession(id: string, session: Session) {
+    return this.sessions.set(id, session);
+  }
+
+  public numSessions() {
+    return this.sessions.size;
+  }
+
+  public removeSession(id: string) {
+    this.sessions.delete(id);
+  }
+}
diff --git a/server/src/network/index.ts b/server/src/network/index.ts
new file mode 100644
index 0000000..3cbf0ac
--- /dev/null
+++ b/server/src/network/index.ts
@@ -0,0 +1,29 @@
+import { Message } from '@engine/network';
+import { Input } from '@engine/systems';
+
+export * from './MessageProcessor';
+export * from './MessagePublisher';
+export * from './MessageReceiver';
+export * from './SessionManager';
+export * from './SessionInputSystem';
+
+export type SessionData = { sessionId: string };
+
+export type Session = {
+  sessionId: string;
+  controllableEntities: Set<string>;
+  inputSystem: Input;
+};
+
+export interface ServerMessage extends Message {
+  sessionData: SessionData;
+}
+
+export interface SessionManager {
+  uniqueSessionId(): string;
+  getSession(id: string): Session | undefined;
+  getSessions(): string[];
+  putSession(id: string, session: Session): void;
+  removeSession(id: string): void;
+  numSessions(): number;
+}