load the session

web/database/build.sql

@@ -1,5 +1,5 @@
 BEGIN;
-
+DROP TABLE IF EXISTS shopify_sessions;
 CREATE TABLE IF NOT EXISTS shopify_sessions (
   id TEXT PRIMARY KEY,
   shop TEXT NOT NULL,
@@ -10,5 +10,4 @@ CREATE TABLE IF NOT EXISTS shopify_sessions (
   scope TEXT,
   expires INTEGER
 );
-
 COMMIT;

web/database/connect.js

@@ -23,9 +23,10 @@ const isInsertOrUpdateRegex = new RegExp(/(UPDATE(.|\n)*SET)|(INSERT INTO)/i);
 // eslint-disable-next-line no-underscore-dangle
 let __pool;
 if (env !== 'production' || connectionString.includes('localhost')) {
-  __pool = new Pool({ connectionString });
+  __pool = new Pool({ max: 20, connectionString });
 } else {
   __pool = new Pool({
+    max: 20,
     connectionString,
     ssl: { rejectUnauthorized: false, require: true }
   });
@@ -99,13 +100,18 @@ const query = async (text, _params, client) => {
     params = sanitizeCSVInjection(_params);
   }
 
-  const res = await _pool.query(text, params);
+  try {
+    const res = await _pool.query(text, params);
 
-  if (res && res.rows) {
-    const rows = toCamelCase(toParentChild(res.rows));
-    res.rows = rows;
+    if (res && res.rows) {
+      const rows = toCamelCase(toParentChild(res.rows));
+      res.rows = rows;
+    }
+    return res;
+  } catch (e) {
+    console.log('Error from query fun', e, 'with query', text);
+    throw new Error(e);
   }
-  return res;
 };
 
 const readSqlFile = async (filePath) => {

web/database/initTestData.js

@@ -1,26 +1,6 @@
-import { query } from './connect.js';
-import deleteAllShopifySessionsData from './shopify_sessions/deleteAllShopifySessionsData.js';
+import { join } from 'path';
+import { readSqlFile as readSQLFileAndQuery } from './connect.js';
 
-const initTestData = async () => {
-  console.log('initTestData');
-  await query(
-    `
-    BEGIN;
-
-CREATE TABLE IF NOT EXISTS shopify_sessions (
-  id TEXT PRIMARY KEY,
-  shop TEXT NOT NULL,
-  state TEXT NOT NULL,
-  "isOnline" BOOLEAN NOT NULL DEFAULT FALSE,
-  "accessToken" TEXT NOT NULL,
-  "onlineAccessInfo" TEXT,
-  scope TEXT,
-  expires INTEGER
-);
-
-COMMIT;`
-  );
-  await deleteAllShopifySessionsData();
-};
+const initTestData = async () => Promise.resolve();
 
 export default initTestData;

web/database/shopify_sessions/InsertSession.js

@@ -7,6 +7,7 @@ const insertSession = async ({ id, shop, state, accessToken }) => {
     (id, "accessToken", shop, state,"isOnline")
     VALUES
     ($1, $2, $3, $4,FALSE)
+    on conflict (id) DO NOTHING
     RETURNING *
     `;