From 5edf0eac681647b74f8624f8e1c8d0f83a8e5451 Mon Sep 17 00:00:00 2001
From: Collin Duncan <3679940+cgduncan7@users.noreply.github.com>
Date: Fri, 10 Feb 2023 14:33:04 +0100
Subject: [PATCH] Adding database debug log for database queries

---
 src/common/database/index.ts | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/src/common/database/index.ts b/src/common/database/index.ts
index 686f5ba..3708e7b 100644
--- a/src/common/database/index.ts
+++ b/src/common/database/index.ts
@@ -1,10 +1,12 @@
 import { resolve } from 'path'
 import sqlite from 'sqlite3'
+import { asyncLocalStorage } from '../logger'
 import { CREATE_TABLE_reservations } from './sql'
 
 export const run = async (sql: string, params?: unknown) => {
   const db = new sqlite.Database(resolve('autobaan_db'))
   await new Promise<void>((res, rej) => {
+    asyncLocalStorage.getStore()?.debug(`<database> run ${sql} (${params})`)
     db.run(sql, params, (err) => {
       if (err) rej(err)
       res()
@@ -15,11 +17,13 @@ export const run = async (sql: string, params?: unknown) => {
 
 export const all = async <T>(sql: string, params?: unknown) => {
   const db = new sqlite.Database(resolve('autobaan_db'))
-  const rows = await new Promise<T[]>((res, rej) =>
+  const rows = await new Promise<T[]>((res, rej) => {
+    asyncLocalStorage.getStore()?.debug(`<database> all ${sql} (${params})`)
     db.all(sql, params, (err, rows) => {
       if (err) rej(err)
       res(rows)
     })
+  }
   )
   db.close()
   return rows