fix statement_timeout bug

prostgles · Oct 15, 2023 · e561ce7 · e561ce7
1 parent 6798a70
commit e561ce7
Show file tree

Hide file tree

Showing 5 changed files with 10 additions and 7 deletions.
diff --git a/lib/PubSubManager/initPubSubManager.ts b/lib/PubSubManager/initPubSubManager.ts
@@ -62,10 +62,12 @@ export async function initPubSubManager(this: PubSubManager): Promise<PubSubMana
               `
             }
 
+            const queryIdentifier = "prostgles query used to keep track of which prgl backend clients are still connected"
             checkForStaleTriggers = `                          
               DO $$
               BEGIN
                 /* 
+                  ${queryIdentifier}
                   ${REALTIME_TRIGGER_CHECK_QUERY} 
                   ${PubSubManager.EXCLUDE_QUERY_FROM_SCHEMA_WATCH_ID}
                 */
@@ -92,6 +94,7 @@ export async function initPubSubManager(this: PubSubManager): Promise<PubSubMana
             const queryTimeoutMillis = Math.min(5e3, Math.round(this.appCheckFrequencyMS/2));
             this.db.any(`    
               /* 
+                ${queryIdentifier}
                 ${REALTIME_TRIGGER_CHECK_QUERY} 
                 ${PubSubManager.EXCLUDE_QUERY_FROM_SCHEMA_WATCH_ID}
               */
@@ -101,9 +104,9 @@ export async function initPubSubManager(this: PubSubManager): Promise<PubSubMana
                 SELECT pg_cancel_backend(pid)
                 FROM pg_catalog.pg_stat_activity
                 WHERE pid <> pg_backend_pid()
-                AND query = \${checkForStaleTriggers};
+                AND query = \${queryIdentifier};
               END $$;
-            `, { queryTimeoutMillis, checkForStaleTriggers })
+            `, { queryTimeoutMillis, queryIdentifier })
             await this.db.any(checkForStaleTriggers);
             tries = 5;
             log("updated last_check");

diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "prostgles-server",
-  "version": "4.1.90",
+  "version": "4.1.91",
   "description": "",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",

diff --git a/tests/client/PID.txt b/tests/client/PID.txt
@@ -1 +1 @@
-2606752
+2611629
diff --git a/tests/server/package-lock.json b/tests/server/package-lock.json