improve test fail log

lib/SchemaWatch/SchemaWatch.ts

@@ -4,8 +4,9 @@ import { OnSchemaChangeCallback } from "../Prostgles";
 import { PubSubManager, log } from "../PubSubManager/PubSubManager";
 import { ValidatedWatchSchemaType, getValidatedWatchSchemaType } from "./getValidatedWatchSchemaType";
 const COMMAND_FIRST_KEYWORDS = EVENT_TRIGGER_TAGS
-  .map(tag => tag.split(" ")[0]!).filter(tag => tag !== "SELECT")
-  .concat("SELECT INTO");
+  .map(tag => tag.split(" ")[0]!)
+  .filter(tag => tag !== "SELECT"); /** SELECT INTO is not easily detectable with pg-node (command = "SELECT")  */
+
 const DB_FALLBACK_COMMANDS = Array.from(new Set(COMMAND_FIRST_KEYWORDS));
 
 export type VoidFunction = () => void;

lib/SchemaWatch/getValidatedWatchSchemaType.ts

@@ -7,7 +7,7 @@ export type ValidatedWatchSchemaType =
 | { watchType: "prostgles_queries"; onChange?: OnSchemaChangeCallback; isFallbackFromDDL: boolean; }
 
 export const getValidatedWatchSchemaType = (dboBuilder: DboBuilder): ValidatedWatchSchemaType => {
-  const {watchSchema, watchSchemaType, tsGeneratedTypesDir} = dboBuilder.prostgles.opts;
+  const {watchSchema, watchSchemaType, tsGeneratedTypesDir, disableRealtime } = dboBuilder.prostgles.opts;
   if(!watchSchema) return { watchType: "NONE" };
 
   if (watchSchema === "hotReloadMode" && !tsGeneratedTypesDir) {
@@ -17,12 +17,12 @@ export const getValidatedWatchSchemaType = (dboBuilder: DboBuilder): ValidatedWa
   const onChange = typeof watchSchema === "function"? watchSchema : undefined;
 
   if(watchSchemaType === "DDL_trigger" || !watchSchemaType){
-    if(!dboBuilder.prostgles.isSuperUser){
+    if(!dboBuilder.prostgles.isSuperUser || disableRealtime){
 
       if(watchSchemaType === "DDL_trigger"){
         console.error(`watchSchemaType "DDL_trigger" cannot be used because db user is not a superuser. Will fallback to watchSchemaType "prostgles_queries" `)
       } else {
-        console.warn(`watchSchema fallback to watchSchemaType "prostgles_queries" due to non-superuser`)
+        console.warn(`watchSchema fallback to watchSchemaType "prostgles_queries" due to ${disableRealtime? "disableRealtime setting" : "non-superuser"}`)
       }
       return {
         watchType: "prostgles_queries",

package.json

@@ -1,6 +1,6 @@
 {
   "name": "prostgles-server",
-  "version": "4.2.43",
+  "version": "4.2.44",
   "description": "",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",

tests/client/renderReactHook.ts

@@ -166,7 +166,7 @@ export const renderReactHook = (rootArgs: RenderHookArgs): Promise<RenderResult>
 		});
 		setTimeout(() => {
 			if(!resolved){
-				reject(new Error(`Expected ${expectedRerenders} rerenders, got ${results.length}`));
+				reject(new Error(`Expected ${expectedRerenders} rerenders, got ${results.length}:\n${JSON.stringify(results)}`));
 			}
 		}, timeout);
 	});

tests/client/useProstgles.spec.ts

@@ -7,6 +7,7 @@ import { renderReactHook, renderReactHookManual } from "./renderReactHook";
 
 export const newly_created_table = "newly_created_table";
 export const useProstglesTest = async (db: DBHandlerClient, getSocketOptions: (watchSchema?: boolean) => AnyObject) => {
+  await db.sql(`DROP TABLE IF EXISTS ${newly_created_table};`);
   await describe("useProstgles hook", async (t) => {
     const socketOptions = getSocketOptions();
     await test("useProstglesClient", async (t) => {
@@ -23,10 +24,13 @@ export const useProstglesTest = async (db: DBHandlerClient, getSocketOptions: (w
         typeof (res2 as any)?.dbo.items4.useFind,
         "function"
       );
+      assert.equal(
+        typeof (res2 as any)?.dbo[newly_created_table],
+        "undefined"
+      );
     });
 
     await test("useProstglesClient with schema reload", async (t) => {
-      await db.sql(`DROP TABLE IF EXISTS ${newly_created_table}; DROP TABLE IF EXISTS will_delete;`);
       await db.sql(`select pg_sleep(1)`);
       let rerenders = 0
       const { results: [res1, res2, res3], rerender } = await renderReactHook({

tests/server/DBoGenerated.d.ts

@@ -257,16 +257,6 @@ export type DBSchemaGenerated = {
       id: string;
     };
   };
-  newly_created_table: {
-    is_view: false;
-    select: true;
-    insert: true;
-    update: true;
-    delete: true;
-    columns: {
-      id?: null | number;
-    };
-  };
   obj_table: {
     is_view: false;
     select: true;