From 9e2833ba85b98a319ea4033bd87d7a0fad18b4a5 Mon Sep 17 00:00:00 2001
From: Zac Gaetano <zgaetano@wilddragon.net>
Date: Tue, 7 Apr 2026 21:58:20 -0400
Subject: [PATCH] add services/worker/src/db/client.js

---
 services/worker/src/db/client.js | 30 ++++++++++++++++++++++++++++++
 1 file changed, 30 insertions(+)
 create mode 100644 services/worker/src/db/client.js

diff --git a/services/worker/src/db/client.js b/services/worker/src/db/client.js
new file mode 100644
index 0000000..0a254e4
--- /dev/null
+++ b/services/worker/src/db/client.js
@@ -0,0 +1,30 @@
+import pg from 'pg';
+
+const { Pool } = pg;
+
+let pool;
+
+export const getPool = () => {
+  if (!pool) {
+    pool = new Pool({
+      connectionString: process.env.DATABASE_URL,
+    });
+  }
+  return pool;
+};
+
+export const query = async (text, params) => {
+  const client = await getPool().connect();
+  try {
+    return await client.query(text, params);
+  } finally {
+    client.release();
+  }
+};
+
+export const closePool = async () => {
+  if (pool) {
+    await pool.end();
+    pool = null;
+  }
+};