Scratch space for learning atproto app development
cduck.me
1import events from "node:events";
2import type http from "node:http";
3import cors from "cors";
4import express, { type Express } from "express";
5import helmet from "helmet";
6import { pino } from "pino";
7
8import { createDb, migrateToLatest } from "#/db";
9import { env } from "#/env";
10import { Ingester } from "#/firehose/ingester";
11import errorHandler from "#/middleware/errorHandler";
12import requestLogger from "#/middleware/requestLogger";
13import { createRouter } from "#/routes";
14import type { AppContext } from "./config";
15
16export class Server {
17 constructor(
18 public app: express.Application,
19 public server: http.Server,
20 public ctx: AppContext
21 ) {}
22
23 static async create() {
24 const { NODE_ENV, HOST, PORT } = env;
25
26 const logger = pino({ name: "server start" });
27 const db = createDb(":memory:");
28 await migrateToLatest(db);
29 const ingester = new Ingester(db);
30 ingester.start();
31 const ctx = {
32 db,
33 ingester,
34 logger,
35 };
36
37 const app: Express = express();
38
39 // Set the application to trust the reverse proxy
40 app.set("trust proxy", true);
41
42 // TODO: middleware for sqlite server
43 // TODO: middleware for OAuth
44
45 // Middlewares
46 app.use(express.json());
47 app.use(express.urlencoded({ extended: true }));
48 app.use(cors({ origin: env.CORS_ORIGIN, credentials: true }));
49 app.use(helmet());
50
51 // Request logging
52 app.use(requestLogger);
53
54 // Routes
55 const router = createRouter(ctx);
56 app.use(router);
57
58 // Error handlers
59 app.use(errorHandler());
60
61 const server = app.listen(env.PORT);
62 await events.once(server, "listening");
63 logger.info(`Server (${NODE_ENV}) running on port http://${HOST}:${PORT}`);
64
65 return new Server(app, server, ctx);
66 }
67
68 async close() {
69 this.ctx.logger.info("sigint received, shutting down");
70 this.ctx.ingester.destroy();
71 return new Promise<void>((resolve) => {
72 this.server.close(() => {
73 this.ctx.logger.info("server closed");
74 resolve();
75 });
76 });
77 }
78}