SockTrader
diff --git a/Collapse file
‎packages/core/src/lib/db.ts‎
Copy file name to clipboard
+20-8Lines changed: 20 additions & 8 deletions b/Collapse file
‎packages/core/src/lib/db.ts‎
Copy file name to clipboard
+20-8Lines changed: 20 additions & 8 deletions
diff --git a/Collapse file
‎packages/core/src/lib/worker/execution.script.ts‎
Copy file name to clipboardExpand all lines: packages/core/src/lib/worker/execution.script.ts
+1-1Lines changed: 1 addition & 1 deletion b/Collapse file
‎packages/core/src/lib/worker/execution.script.ts‎
Copy file name to clipboardExpand all lines: packages/core/src/lib/worker/execution.script.ts
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/Collapse file
‎packages/core/src/lib/worker/worker.ts‎
Copy file name to clipboardExpand all lines: packages/core/src/lib/worker/worker.ts
+1-1Lines changed: 1 addition & 1 deletion b/Collapse file
‎packages/core/src/lib/worker/worker.ts‎
Copy file name to clipboardExpand all lines: packages/core/src/lib/worker/worker.ts
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/Collapse file
‎packages/web/src/lib/.gitkeep‎
Copy file name to clipboardExpand all lines: packages/web/src/lib/.gitkeep b/Collapse file
‎packages/web/src/lib/.gitkeep‎
Copy file name to clipboardExpand all lines: packages/web/src/lib/.gitkeep
@@ -1,15 +1,27 @@
 import { Pool, QueryResultRow, QueryResult } from 'pg'
 import config from 'config'
 
-const pool = new Pool({
-  host: config.get('database.host'),
-  user: config.get('database.username'),
-  database: config.get('database.database'),
-  password: config.get('database.password'),
-  port: config.get('database.port'),
-})
+const poolCreator = () => {
+  let pool: Pool | null = null;
+
+  return () => {
+    if (!pool) {
+      pool = new Pool({
+        host: config.get('database.host'),
+        user: config.get('database.username'),
+        database: config.get('database.database'),
+        password: config.get('database.password'),
+        port: config.get('database.port'),
+      })
+    }
+
+    return pool
+  }
+}
+
+const getPool = poolCreator()
 
 //eslint-disable-next-line
 export const query = <R extends QueryResultRow = any, I extends any[] = any[]>(text: string, params?: I): Promise<QueryResult<R>> => {
-  return pool.query(text, params)
+  return getPool().query(text, params)
 }
@@ -25,4 +25,4 @@ class ExecutionScript {
 
 }
 
-new ExecutionScript()
+export default () => new ExecutionScript()
@@ -20,7 +20,7 @@ export class Worker {
 
     return `
       require("ts-node/register/transpile-only");
-      require("${__dirname}/execution.script");
+      require("${__dirname}/execution.script").default();
     `
   }
Original file line number	Diff line number	Diff line change
`@@ -25,4 +25,4 @@ class ExecutionScript {`
`25`	`25`
`26`	`26`	`}`
`27`	`27`
`28`		`-new ExecutionScript()`
	`28`	`+export default () => new ExecutionScript()`
Original file line number	Diff line number	Diff line change
`@@ -20,7 +20,7 @@ export class Worker {`
`20`	`20`
`21`	`21`	return `
`22`	`22`	`require("ts-node/register/transpile-only");`
`23`		`- require("${__dirname}/execution.script");`
	`23`	`+ require("${__dirname}/execution.script").default();`
`24`	`24`	`
`25`	`25`	`}`
`26`	`26`