From 8e9896ec2e09e79b7e17b64e4b1677ecd2598256 Mon Sep 17 00:00:00 2001
From: AnimatedSwine37 <24914353+AnimatedSwine37@users.noreply.github.com>
Date: Tue, 27 Jun 2023 10:31:09 +1000
Subject: [PATCH] fix(postgresql): close connections when done

---
 packages/backend/src/apps/postgresql/actions/delete/index.ts    | 2 ++
 packages/backend/src/apps/postgresql/actions/insert/index.ts    | 2 ++
 packages/backend/src/apps/postgresql/actions/sql-query/index.ts | 1 +
 packages/backend/src/apps/postgresql/actions/update/index.ts    | 2 ++
 packages/backend/src/apps/postgresql/auth/verify-credentials.ts | 1 +
 5 files changed, 8 insertions(+)

diff --git a/packages/backend/src/apps/postgresql/actions/delete/index.ts b/packages/backend/src/apps/postgresql/actions/delete/index.ts
index 518017d0..4a79477c 100644
--- a/packages/backend/src/apps/postgresql/actions/delete/index.ts
+++ b/packages/backend/src/apps/postgresql/actions/delete/index.ts
@@ -102,6 +102,8 @@ export default defineAction({
       })
       .del() as IJSONArray;
 
+    client.destroy();
+
     $.setActionItem({
       raw: {
         rows: response
diff --git a/packages/backend/src/apps/postgresql/actions/insert/index.ts b/packages/backend/src/apps/postgresql/actions/insert/index.ts
index 5c0e8545..37471fb3 100644
--- a/packages/backend/src/apps/postgresql/actions/insert/index.ts
+++ b/packages/backend/src/apps/postgresql/actions/insert/index.ts
@@ -88,6 +88,8 @@ export default defineAction({
       .returning('*')
       .insert(data) as IJSONObject;
 
+    client.destroy();
+
     $.setActionItem({ raw: response[0] as IJSONObject });
   },
 });
diff --git a/packages/backend/src/apps/postgresql/actions/sql-query/index.ts b/packages/backend/src/apps/postgresql/actions/sql-query/index.ts
index e5145cc7..9cfd0e6f 100644
--- a/packages/backend/src/apps/postgresql/actions/sql-query/index.ts
+++ b/packages/backend/src/apps/postgresql/actions/sql-query/index.ts
@@ -46,6 +46,7 @@ export default defineAction({
 
     const queryStatemnt = $.step.parameters.queryStatement;
     const { rows } = await client.raw(queryStatemnt);
+    client.destroy();
 
     $.setActionItem({
       raw: {
diff --git a/packages/backend/src/apps/postgresql/actions/update/index.ts b/packages/backend/src/apps/postgresql/actions/update/index.ts
index 9a43506e..798e3593 100644
--- a/packages/backend/src/apps/postgresql/actions/update/index.ts
+++ b/packages/backend/src/apps/postgresql/actions/update/index.ts
@@ -132,6 +132,8 @@ export default defineAction({
       })
       .update(data) as IJSONArray;
 
+    client.destroy();
+
     $.setActionItem({
       raw: {
         rows: response
diff --git a/packages/backend/src/apps/postgresql/auth/verify-credentials.ts b/packages/backend/src/apps/postgresql/auth/verify-credentials.ts
index edccad88..4815fb45 100644
--- a/packages/backend/src/apps/postgresql/auth/verify-credentials.ts
+++ b/packages/backend/src/apps/postgresql/auth/verify-credentials.ts
@@ -5,6 +5,7 @@ import getClient from '../common/postgres-client';
 const verifyCredentials = async ($: IGlobalVariable) => {
   const client = getClient($);
   const checkConnection = await client.raw('SELECT 1');
+  client.destroy();
 
   logger.debug(checkConnection);