From f24c962785aca3673d69c15045e77496361764f4 Mon Sep 17 00:00:00 2001
From: Ajay Ramachandran <dev@ajay.app>
Date: Tue, 10 Aug 2021 09:50:32 -0400
Subject: [PATCH] Catch postgres exceptions

Fix #338
---
 src/databases/Postgres.ts | 32 ++++++++++++++++++--------------
 1 file changed, 18 insertions(+), 14 deletions(-)

diff --git a/src/databases/Postgres.ts b/src/databases/Postgres.ts
index e9a7fa0..4c0ec00 100644
--- a/src/databases/Postgres.ts
+++ b/src/databases/Postgres.ts
@@ -55,22 +55,26 @@ export class Postgres implements IDatabase {
 
         Logger.debug(`prepare (postgres): type: ${type}, query: ${query}, params: ${params}`);
 
-        const queryResult = await this.pool.query({text: query, values: params});
+        try {
+            const queryResult = await this.pool.query({text: query, values: params});
 
-        switch (type) {
-            case "get": {
-                const value = queryResult.rows[0];
-                Logger.debug(`result (postgres): ${JSON.stringify(value)}`);
-                return value;
-            }
-            case "all": {
-                const values = queryResult.rows;
-                Logger.debug(`result (postgres): ${values}`);
-                return values;
-            }
-            case "run": {
-                break;
+            switch (type) {
+                case "get": {
+                    const value = queryResult.rows[0];
+                    Logger.debug(`result (postgres): ${JSON.stringify(value)}`);
+                    return value;
+                }
+                case "all": {
+                    const values = queryResult.rows;
+                    Logger.debug(`result (postgres): ${values}`);
+                    return values;
+                }
+                case "run": {
+                    break;
+                }
             }
+        } catch (err) {
+            Logger.error(`prepare (postgres): ${err}`);
         }
     }