homeio

1import "server-only";
2
3import { Pool } from "pg";
4import { serverEnv } from "@/lib/server/env";
5import { logServerAction } from "@/lib/server/logging/logger";
6
7declare global {
8  var __homeioPgPool: Pool | undefined;
9  var __homeioPgPoolErrorListenerAttached: boolean | undefined;
10  var __homeioPgPoolInitLogged: boolean | undefined;
11}
12
13export const pgPool =
14  globalThis.__homeioPgPool ??
15  new Pool({
16    connectionString: serverEnv.DATABASE_URL,
17    max: serverEnv.PG_MAX_CONNECTIONS,
18    min: 1,
19    idleTimeoutMillis: 60_000,
20    connectionTimeoutMillis: 2_000,
21  });
22
23if (serverEnv.NODE_ENV !== "production") {
24  globalThis.__homeioPgPool = pgPool;
25}
26
27if (!globalThis.__homeioPgPoolErrorListenerAttached) {
28  pgPool.on("error", (error) => {
29    logServerAction({
30      level: "error",
31      layer: "db",
32      action: "pg.pool.error",
33      status: "error",
34      error,
35    });
36  });
37  globalThis.__homeioPgPoolErrorListenerAttached = true;
38}
39
40if (!globalThis.__homeioPgPoolInitLogged) {
41  logServerAction({
42    level: "info",
43    layer: "db",
44    action: "pg.pool.init",
45    status: "success",
46    meta: {
47      maxConnections: serverEnv.PG_MAX_CONNECTIONS,
48    },
49  });
50  globalThis.__homeioPgPoolInitLogged = true;
51}
52