shoot/src/gateway/server.ts at main · alexlehm/shoot

Repository navigation

import http from "node:http";

import { WebSocketServer } from "ws";

import { initDatabase } from "../util/database.js";

import { initRabbitMQ } from "../util/events.js";

import { createLogger } from "../util/log.js";

import { onConnection } from "./socket/connection.js";

const Log = createLogger("GATEWAY");

export class GatewayServer {

server: http.Server;

socket: WebSocketServer;

public constructor(server?: http.Server) {

this.server = server ?? http.createServer();

this.socket = new WebSocketServer({

server: this.server,

});

this.socket.on("connection", onConnection);

}

public async listen(port: number) {

this.server.on("listening", () => {

Log.msg(`Listening on port ${port}`);

});

await initDatabase();

await initRabbitMQ(true);

if (!this.server.listening) this.server.listen(port);

}