src/server/ArchiveServer.ts

import express from "express";
import path from "path";
import { MessageType } from "../types/MessageType";

class ArchiveServer {
    private readonly app: express.Application;
    private readonly port: number;
    private readonly db: import("bun:sqlite").Database | import("better-sqlite3").Database;

    public constructor(
        db: import("bun:sqlite").Database | import("better-sqlite3").Database,
        port: number = +(process.env.ARCHIVE_SERVER_PORT ?? 7575) || 7575
    ) {
        this.db = db;
        this.app = express();
        this.port = port;
    }

    private setup() {
        this.app.set("view engine", "ejs");
        this.app.set("views", path.join(__dirname, "../html"));
        this.app.use(express.static(path.join(__dirname, "../../public")));
        this.app.get(
            "/guilds/:guildId/channels/:channelId/messages",
            this.handleGetMessages.bind(this)
        );
    }

    private prepare(query: string, params: string[] = [], results = true) {
        const db = this.db as unknown as import("bun:sqlite").Database;
        const compiled = db.prepare(query, params);

        if (results) {
            return compiled.all();
        }

        compiled.run();
    }

    private handleGetMessages(
        request: express.Request<{
            guildId: string;
            channelId: string;
        }>,
        response: express.Response
    ) {
        const messages = this.prepare(
            "SELECT * FROM messages JOIN users ON users.id = messages.userId WHERE guildId = ? AND channelId = ? ORDER BY timestamp DESC;",
            [request.params.guildId, request.params.channelId]
        );

        response.render("messages", {
            guildId: request.params.guildId,
            channelId: request.params.channelId,
            messages
        });
    }

    public start() {
        this.setup();
        this.app.listen(this.port, () => {
            process.send?.({
                type: MessageType.ServerReady,
                port: this.port
            });
        });
    }
}

export default ArchiveServer;
1	import express from "express";
2	import path from "path";
3	import { MessageType } from "../types/MessageType";
4
5	class ArchiveServer {
6	private readonly app: express.Application;
7	private readonly port: number;
8	private readonly db: import("bun:sqlite").Database \| import("better-sqlite3").Database;
9
10	public constructor(
11	db: import("bun:sqlite").Database \| import("better-sqlite3").Database,
12	port: number = +(process.env.ARCHIVE_SERVER_PORT ?? 7575) \|\| 7575
13	) {
14	this.db = db;
15	this.app = express();
16	this.port = port;
17	}
18
19	private setup() {
20	this.app.set("view engine", "ejs");
21	this.app.set("views", path.join(__dirname, "../html"));
22	this.app.use(express.static(path.join(__dirname, "../../public")));
23	this.app.get(
24	"/guilds/:guildId/channels/:channelId/messages",
25	this.handleGetMessages.bind(this)
26	);
27	}
28
29	private prepare(query: string, params: string[] = [], results = true) {
30	const db = this.db as unknown as import("bun:sqlite").Database;
31	const compiled = db.prepare(query, params);
32
33	if (results) {
34	return compiled.all();
35	}
36
37	compiled.run();
38	}
39
40	private handleGetMessages(
41	request: express.Request<{
42	guildId: string;
43	channelId: string;
44	}>,
45	response: express.Response
46	) {
47	const messages = this.prepare(
48	"SELECT * FROM messages JOIN users ON users.id = messages.userId WHERE guildId = ? AND channelId = ? ORDER BY timestamp DESC;",
49	[request.params.guildId, request.params.channelId]
50	);
51
52	response.render("messages", {
53	guildId: request.params.guildId,
54	channelId: request.params.channelId,
55	messages
56	});
57	}
58
59	public start() {
60	this.setup();
61	this.app.listen(this.port, () => {
62	process.send?.({
63	type: MessageType.ServerReady,
64	port: this.port
65	});
66	});
67	}
68	}
69
70	export default ArchiveServer;