add tx logs

lib/DboBuilder/DboBuilder.ts

@@ -262,15 +262,23 @@ export class DboBuilder {
     return jp;
   }
 
-  getTX = (cb: TxCB) => {
-    return this.db.tx(t => {
-      const dbTX: DbTxTableHandlers & Pick<DBHandlerServer, "sql"> = {};
-      this.tablesOrViews?.map(tov => {
-        dbTX[tov.name] = new (tov.is_view ? ViewHandler : TableHandler)(this.db, tov, this, { t, dbTX }, this.shortestJoinPaths);
+  getTX = async (cb: TxCB) => {
+    try {
+      const transaction = await this.db.tx(t => {
+        const dbTX: DbTxTableHandlers & Pick<DBHandlerServer, "sql"> = {};
+        this.tablesOrViews?.map(tov => {
+          dbTX[tov.name] = new (tov.is_view ? ViewHandler : TableHandler)(this.db, tov, this, { t, dbTX }, this.shortestJoinPaths);
+        });
+        dbTX.sql = (q, args, opts, localP) => this.runSQL(q, args, opts, { tx: { dbTX, t }, ...(localP ?? {}) })
+
+        return cb(dbTX, t);
       });
-      dbTX.sql = (q, args, opts, localP) => this.runSQL(q, args, opts, { tx: { dbTX, t }, ...(localP ?? {}) })
+
+      return transaction;
 
-      return cb(dbTX, t);
-    });
+    } catch (e) {
+      console.error("Error in getTX", e);
+      throw e;
+    }
   }
 }

lib/DboBuilder/ViewHandler/ViewHandler.ts

@@ -93,7 +93,18 @@ export class ViewHandler {
       return;
     }
     const sid = this.dboBuilder.prostgles.authHandler?.getSIDNoError(localParams);
-    return this.dboBuilder.prostgles.opts.onLog?.({ type: "table", sid, socketId: localParams?.socket?.id, tableName: this.name, command, data, localParams, duration, error });
+    return this.dboBuilder.prostgles.opts.onLog?.({ 
+      type: "table", 
+      command, 
+      duration, 
+      error,
+      txInfo: this.tx?.t.ctx,
+      sid, 
+      socketId: localParams?.socket?.id, 
+      tableName: this.name, 
+      data, 
+      localParams, 
+    });
   }
 
   getRowHashSelect(allowedFields: FieldFilter, alias?: string, tableAlias?: string): string {

lib/Logging.ts

@@ -17,6 +17,7 @@ export namespace EventTypes {
     type: "table";
     tableName: string;
     command: keyof TableHandler;
+    txInfo: AnyObject | undefined;
     data: AnyObject;
     localParams: LocalParams | undefined;
   };

lib/PubSubManager/getInitQuery.ts

@@ -580,6 +580,9 @@ BEGIN
         $$ LANGUAGE plpgsql;
         COMMENT ON FUNCTION ${DB_OBJ_NAMES.schema_watch_func} IS 'Prostgles internal function used to notify when schema has changed';
 
+    ELSE 
+                      
+      DELETE FROM prostgles.app_triggers;
     END IF;
 
 END

package.json

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