aboutsummaryrefslogtreecommitdiffstats
path: root/apps/workers/server.ts
blob: f1b8a11d64fc8dfc9d74a7fc5a6a4ed2b1500570 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
import { serve } from "@hono/node-server";
import { Hono } from "hono";
import { bearerAuth } from "hono/bearer-auth";

import serverConfig from "@karakeep/shared/config";
import logger from "@karakeep/shared/logger";

import { printMetrics } from "./metrics";

const app = new Hono()
  .get("/health", (c) =>
    c.json({ status: "ok", timestamp: new Date().toISOString() }),
  )
  .get(
    "/metrics",
    bearerAuth({ token: serverConfig.prometheus.metricsToken }),
    printMetrics,
  );

export function buildServer() {
  const server = serve(
    {
      fetch: app.fetch,
      port: serverConfig.workers.port,
      hostname: serverConfig.workers.host,
    },
    (info) => {
      logger.info(`Listening on http://${info.address}:${info.port}`);
    },
  );
  return {
    _server: server,
    stop: () =>
      new Promise<void>((resolve, reject) => {
        server.close((err) => {
          if (err) {
            reject(err);
          } else {
            resolve();
          }
        });
      }),
    serve: () =>
      new Promise<void>((resolve, reject) => {
        server.on("error", reject);
        server.on("close", () => resolve());
      }),
  };
}

export default app;