feat(authserver): initialize auth server with database and authentication logic

app/authserver/.env.example

@@ -0,0 +1,2 @@
+AUTH_DB_CONNECTION_URL="sqlite://authserver.db"
+LOG_LEVEL="debug"

app/authserver/AuthServer.ts

@@ -0,0 +1,69 @@
+import { IncomingMessage, ServerResponse, createServer } from "http";
+import { getServerLogger } from "rusty-motors-shared";
+import { AuthServerConfig } from "./config.ts";
+import { handleAuthLogin } from "./handleAuthLogin.ts";
+import { handleShardList } from "./handleShardList.ts";
+
+export class AuthServer {
+
+	constructor(private config: AuthServerConfig, private log: ReturnType<typeof getServerLogger>) {
+		this.log = log.child({ name: "auth-server" });
+		this.config = config;
+	}
+
+	handleRequest(req: IncomingMessage, res: ServerResponse) {
+		if (!req.url || !req.method) {
+			res.writeHead(400, { 'Content-Type': 'text/plain' });
+			res.end('Bad Request\n');
+			return;
+		}
+
+		// Handle incoming requests here
+		this.log.info(`Received request: ${req.method} ${new URL(req.url, `http://${req.headers.host}`).pathname}`);
+
+		if (req.url.startsWith("/AuthLogin")) {
+			// Handle AuthLogin request
+			handleAuthLogin.call(this, req, res);
+		} else if (req.url === "/ShardList/") {
+			// Handle ShardList request
+			// Implement shard list retrieval logic here
+			handleShardList.call(this, req, res);
+		}
+		else {
+			res.writeHead(404, { 'Content-Type': 'text/plain' });
+			res.end('Not Found\n');
+			return;
+		}
+	}
+
+	public start() {
+		this.log.info("AuthServer started successfully.");
+		// Initialize server components here (e.g., HTTP server, routes, etc.)
+		const server = createServer((this.handleRequest).bind(this));
+
+		const port = parseInt("3000", 10);
+		server.listen(port, '0.0.0.0', () => {
+			this.log.info(`AuthServer listening on port ${port}`);
+		});
+
+		process.on('SIGINT', () => {
+			this.log.info('Received SIGINT. Shutting down gracefully...');
+			server.close(() => {
+				this.stop();
+				process.exit(0);
+			});
+		});
+
+		process.on('SIGTERM', () => {
+			this.log.info('Received SIGTERM. Shutting down gracefully...');
+			server.close(() => {
+				this.stop();
+				process.exit(0);
+			});
+		});
+	}
+	public stop() {
+		this.log.info("AuthServer stopped successfully.");
+		// Clean up resources here
+	}
+}

app/authserver/config.ts

@@ -0,0 +1,27 @@
+// detroit is a game server, written from scratch, for an old game
+// Copyright (C) <2017>  <Drazi Crendraven>
+//
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU Affero General Public License as published
+// by the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+//
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+// GNU Affero General Public License for more details.
+//
+// You should have received a copy of the GNU Affero General Public License
+// along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+export interface AuthServerConfig {
+    dbConnectionUrl: string;
+    logLevel: string;
+}
+
+export function getConfig() : AuthServerConfig {
+    return {
+        dbConnectionUrl: process.env.AUTH_DB_CONNECTION_URL || "sqlite://:memory:",
+        logLevel: process.env.LOG_LEVEL || "debug",
+    };
+}

app/authserver/databaseConstrants.ts

@@ -0,0 +1,26 @@
+// Constants
+export const DATABASE_PATH = process.env["DATABASE_PATH"] ?? "data/lotus.db";
+// SQL Queries
+export const SQL = {
+	CREATE_USER_TABLE: `
+        CREATE TABLE IF NOT EXISTS user(
+        username TEXT UNIQUE NOT NULL,
+        password TEXT NOT NULL,
+        customerId INTEGER PRIMARY KEY NOT NULL
+    ) STRICT`,
+	CREATE_SESSION_TABLE: `
+        CREATE TABLE IF NOT EXISTS session(
+        id INTEGER PRIMARY KEY AUTOINCREMENT,
+        contextId TEXT UNIQUE NOT NULL,
+        customerId INTEGER NOT NULL,
+        profileId INTEGER DEFAULT 0
+
+    ) STRICT`,
+	INSERT_USER:
+		"INSERT INTO user (username, password, customerId) VALUES (?, ?, ?)",
+	FIND_USER: "SELECT * FROM user WHERE username = ? AND password = ?",
+	GET_ALL_USERS: "SELECT * FROM user",
+	UPDATE_SESSION:
+		"INSERT OR REPLACE INTO session (contextId, customerId, profileId) VALUES (?, ?, ?)",
+	FIND_SESSION_BY_CONTEXT: "SELECT * FROM session WHERE contextId = ?",
+} as const;