Add session server routes and SessionError class

Introduces new session server endpoints for hasJoined and profile lookup, adds a SessionError class for improved error handling, and updates error exports. Also renames sessionRepository and sessionService files to sessionsRepository and sessionsService for consistency, and sets max listeners in logger.

repositories/sessionsRepository.js

@@ -0,0 +1,165 @@
+const path = require("node:path")
+const Logger = require("../modules/logger")
+const logger = Logger.createLogger(path.join(__dirname, ".."))
+const database = require("../modules/database")
+const { DefaultError } = require("../errors/errors")
+
+async function insertLegacyClientSessions(sessionId, uuid) {
+    try {
+        await database.query(`DELETE FROM legacyClientSessions WHERE uuid = ?`, [uuid])
+
+        const sql = `INSERT INTO legacyClientSessions (sessionId, uuid) VALUES (?, ?)`
+        const result = await database.query(sql, [sessionId, uuid])
+
+        if (result.affectedRows > 0) {
+            return { code: 200, sessionId, uuid }
+        } else {
+            throw new DefaultError(500, "Internal Server Error", "Unknown DB Error")
+        }
+    } catch (error) {
+        if (error instanceof DefaultError) throw error
+        logger.log("Internal Server Error".bold + " : " + error.toString(), ["MariaDB", "yellow"])
+        throw new DefaultError(500, "Internal Server Error", "Please contact an administrator.")
+    }
+}
+
+async function validateLegacyClientSession(sessionId, uuid) {
+    try {
+        const sql = `SELECT * FROM legacyClientSessions WHERE sessionId = ? AND uuid = ?`
+        const rows = await database.query(sql, [sessionId, uuid])
+        
+        const session = rows[0]
+        if (session) { 
+            return { 
+                code: 200, 
+                message: "Client session valid."
+            } 
+        } else {
+            return { 
+                code: 404, 
+                message: "Client session not found for this accessToken/clientToken combination" 
+            }
+        }
+    } catch (error) {
+        logger.log("Internal Server Error".bold + " : " + error.toString(), ["MariaDB", "yellow"])
+        throw new DefaultError(500, "Internal Server Error", "Please contact an administrator.")
+    }
+}
+
+async function getBlockedServers() {
+    try {
+        const sql = `SELECT * FROM blockedServers`
+        const blockedServers = await database.query(sql)
+
+        return { 
+            code: 200, 
+            blockedServers: blockedServers.map(bannedServer => ({ sha1: bannedServer.hashedIp })) 
+        }
+    } catch (error) {
+        logger.log("Internal Server Error".bold + " : " + error.toString(), ["MariaDB", "yellow"])
+        throw new DefaultError(500, "Internal Server Error", "Please contact an administrator.")
+    }
+}
+
+async function getActiveSkin(uuid) {
+    try {
+        const sql = `
+            SELECT t.url, ps.variant 
+            FROM playersSkins ps
+            JOIN textures t ON ps.assetHash = t.hash
+            WHERE ps.playerUuid = ? AND ps.isSelected = 1
+        `
+        const rows = await database.query(sql, [uuid])
+        const skin = rows[0]
+
+        return { code: 200, data: skin || null }
+    } catch (error) {
+        logger.log("Internal Server Error".bold + " : " + error.toString(), ["MariaDB", "yellow"])
+        throw new DefaultError(500, "Internal Server Error", "Please contact an administrator.")
+    }
+}
+
+async function getActiveCape(uuid) {
+    try {
+        const sql = `
+            SELECT t.url 
+            FROM playersCapes pc
+            JOIN textures t ON pc.assetHash = t.hash
+            WHERE pc.playerUuid = ? AND pc.isSelected = 1
+        `
+        const rows = await database.query(sql, [uuid])
+        const cape = rows[0]
+
+        return { code: 200, data: cape || null }
+    } catch (error) {
+        logger.log("Internal Server Error".bold + " : " + error.toString(), ["MariaDB", "yellow"])
+        throw new DefaultError(500, "Internal Server Error", "Please contact an administrator.")
+    }
+}
+
+async function getProfileActionsList(uuid) {
+    try {
+        const cleanUuid = uuid.replace(/-/g, "")
+        const sql = "SELECT action FROM playerProfileActions WHERE uuid = ?"
+        const rows = await database.query(sql, [cleanUuid])
+
+        const actions = rows.map(row => row.action)
+
+        return { code: 200, data: actions }
+    } catch (error) {
+        logger.log("Internal Server Error".bold + " : " + error.toString(), ["MariaDB", "yellow"])
+        throw new DefaultError(500, "Internal Server Error", "Please contact an administrator.")
+    }
+}
+
+async function saveServerSession(uuid, accessToken, serverId, ip) {
+    try {
+        const sql = `
+            INSERT INTO serverSessions (uuid, accessToken, serverId, ip, createdAt)
+            VALUES (?, ?, ?, ?, CURRENT_TIMESTAMP)
+            ON DUPLICATE KEY UPDATE 
+            accessToken = VALUES(accessToken),
+            serverId = VALUES(serverId),
+            ip = VALUES(ip),
+            createdAt = CURRENT_TIMESTAMP
+        `
+        const result = await database.query(sql, [uuid, accessToken, serverId, ip])
+
+        return { code: 200, success: result.affectedRows > 0 }
+    } catch (error) {
+        logger.log("Internal Server Error".bold + " : " + error.toString(), ["MariaDB", "yellow"])
+        throw new DefaultError(500, "Internal Server Error", "Please contact an administrator.")
+    }
+}
+
+async function getServerSession(uuid, serverId) {
+    try {
+        const sql = `
+            SELECT ip 
+            FROM serverSessions 
+            WHERE uuid = ? AND serverId = ?
+        `
+        const rows = await database.query(sql, [uuid, serverId])
+        const session = rows[0]
+
+        if (!session) {
+            return { code: 404, valid: false }
+        }
+
+        return { code: 200, valid: true, ip: session.ip }
+    } catch (error) {
+        logger.log("Internal Server Error".bold + " : " + error.toString(), ["MariaDB", "yellow"])
+        throw new DefaultError(500, "Internal Server Error", "Please contact an administrator.")
+    }
+}
+
+module.exports = {
+    insertLegacyClientSessions,
+    validateLegacyClientSession,
+    getBlockedServers,
+    getActiveSkin,
+    getActiveCape,
+    getProfileActionsList,
+    saveServerSession,
+    getServerSession
+}