summary refs log tree commit diff
path: root/gateway/src/Server.ts
diff options
context:
space:
mode:
authorFlam3rboy <34555296+Flam3rboy@users.noreply.github.com>2022-08-13 02:00:50 +0200
committerTheArcaneBrony <myrainbowdash949@gmail.com>2022-08-13 22:00:55 +0200
commit5e86d7ab9c5200d794c3adb2b422d20a2aefd2ce (patch)
tree0a4b23ee96862077b21dea20cf71205709e15f7c /gateway/src/Server.ts
parenttry to update build script (diff)
downloadserver-5e86d7ab9c5200d794c3adb2b422d20a2aefd2ce.tar.xz
restructure to single project
Diffstat (limited to 'gateway/src/Server.ts')
-rw-r--r--gateway/src/Server.ts62
1 files changed, 0 insertions, 62 deletions
diff --git a/gateway/src/Server.ts b/gateway/src/Server.ts
deleted file mode 100644
index 82fbeba2..00000000
--- a/gateway/src/Server.ts
+++ /dev/null
@@ -1,62 +0,0 @@
-import dotenv from "dotenv";
-dotenv.config();
-import { closeDatabase, Config, getOrInitialiseDatabase, initEvent } from "@fosscord/util";
-import ws from "ws";
-import { Connection } from "./events/Connection";
-import http from "http";
-
-export class Server {
-	public ws: ws.Server;
-	public port: number;
-	public server: http.Server;
-	public production: boolean;
-
-	constructor({
-		port,
-		server,
-		production,
-	}: {
-		port: number;
-		server?: http.Server;
-		production?: boolean;
-	}) {
-		this.port = port;
-		this.production = production || false;
-
-		if (server) this.server = server;
-		else {
-			this.server = http.createServer(function (req, res) {
-				res.writeHead(200).end("Online");
-			});
-		}
-
-		this.server.on("upgrade", (request, socket, head) => {
-			// @ts-ignore
-			this.ws.handleUpgrade(request, socket, head, (socket) => {
-				this.ws.emit("connection", socket, request);
-			});
-		});
-
-		this.ws = new ws.Server({
-			maxPayload: 4096,
-			noServer: true,
-		});
-		this.ws.on("connection", Connection);
-		this.ws.on("error", console.error);
-	}
-
-	async start(): Promise<void> {
-		await getOrInitialiseDatabase();
-		await Config.init();
-		await initEvent();
-		if (!this.server.listening) {
-			this.server.listen(this.port);
-			console.log(`[Gateway] online on 0.0.0.0:${this.port}`);
-		}
-	}
-
-	async stop() {
-		closeDatabase();
-		this.server.close();
-	}
-}