Fix for running with mongodb v5

Author: skadefro

OpenFlow/src/DatabaseConnection.ts

@@ -149,7 +149,8 @@ export class DatabaseConnection {
         Logger.otel.endSpan(span);
     }
     async ListCollections(jwt: string): Promise<any[]> {
-        const result = await DatabaseConnection.toArray(this.db.listCollections());
+        let result = await DatabaseConnection.toArray(this.db.listCollections());
+        result = result.filter(x => x.name.indexOf("system.") === -1);
         Crypt.verityToken(jwt);
         return result;
     }
@@ -2663,7 +2664,8 @@ export class DatabaseConnection {
         const span: Span = Logger.otel.startSubSpan("db.ensureindexes", parent);
         try {
             if (!Config.ensure_indexes) return;
-            const collections = await DatabaseConnection.toArray(this.db.listCollections());
+            let collections = await DatabaseConnection.toArray(this.db.listCollections());
+            collections = collections.filter(x => x.name.indexOf("system.") === -1);
 
             for (let i = 0; i < collections.length; i++) {
                 try {

OpenFlow/src/Messages/Message.ts

@@ -748,6 +748,7 @@ export class Message {
             } else {
                 span.addEvent("ListCollections");
                 msg.result = await Config.db.ListCollections(msg.jwt);
+                msg.result = msg.result.filter(x => x.name.indexOf("system.") === -1);
                 span.addEvent("Filter collections");
                 if (msg.includehist !== true) {
                     msg.result = msg.result.filter(x => !x.name.endsWith("_hist"));
@@ -834,6 +835,8 @@ export class Message {
                 span.recordException("Access denied, not signed in")
                 msg.error = "Access denied, not signed in";
             } else {
+                console.log("Query: " + JSON.stringify(msg.query, null, 4));
+                console.log("Orderby: " + JSON.stringify(msg.orderby, null, 4));
                 msg.result = await Config.db.query(msg.query, msg.projection, msg.top, msg.skip, msg.orderby, msg.collectionname, msg.jwt, msg.queryas, msg.hint, span);
             }
         } catch (error) {
@@ -4096,7 +4099,8 @@ export class Message {
                 const user = Crypt.rootUser();
                 const tuser = TokenUser.From(user);
                 const jwt: string = Crypt.rootToken();
-                const collections = await Config.db.ListCollections(jwt);
+                let collections = await Config.db.ListCollections(jwt);
+                collections = collections.filter(x => x.name.indexOf("system.") === -1);
                 let totalusage = 0;
                 let index = 0;
                 for (let col of collections) {

OpenFlow/src/public/Controllers.ts

@@ -2924,6 +2924,12 @@ export class EntitiesCtrl extends entitiesCtrl<Base> {
         if (!this.$scope.$$phase) { this.$scope.$apply(); }
         WebSocketClientService.onSignedin(async (user: TokenUser) => {
             try {
+                if (this.collection == "audit") {
+                    if (this.orderby && this.orderby["_id"]) {
+                        this.orderby["_created"] = this.orderby["_id"];
+                        delete this.orderby["_id"];
+                    }
+                }
                 this.loadData();
                 this.collections = await NoderedUtil.ListCollections(null);
             } catch (error) {

OpenFlowNodeRED/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@openiap/nodered",
-  "version": "1.3.54",
+  "version": "1.3.55",
   "description": "Simple wrapper around NodeRed, RabbitMQ and MongoDB to support a more scaleable NodeRed implementation.\r Also the \"backend\" for [OpenRPA](https://github.com/skadefro/OpenRPA)",
   "main": "index.js",
   "scripts": {

VERSION

@@ -1 +1 @@
-1.3.54
+1.3.55

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@openiap/openflow",
-  "version": "1.3.54",
+  "version": "1.3.55",
   "description": "Simple wrapper around NodeRed, RabbitMQ and MongoDB to support a more scaleable NodeRed implementation.\r Also the \"backend\" for [OpenRPA](https://github.com/skadefro/OpenRPA)",
   "main": "index.js",
   "scripts": {

test/DatabaseConnection.test.ts

@@ -43,12 +43,14 @@ import { Crypt } from '../OpenFlow/src/Crypt';
     }
     @test async 'ListCollections'() {
         var rootcollections = await Config.db.ListCollections(this.rootToken);
+        rootcollections = rootcollections.filter(x => x.name.indexOf("system.") === -1);
         assert.notDeepStrictEqual(rootcollections, null);
         assert.notDeepStrictEqual(rootcollections.length, 0);
     }
     @test async 'DropCollections'() {
         const colname = "testcollection"
         var rootcollections = await Config.db.ListCollections(this.rootToken);
+        rootcollections = rootcollections.filter(x => x.name.indexOf("system.") === -1);
         assert.notDeepStrictEqual(rootcollections, null);
         assert.notDeepStrictEqual(rootcollections.length, 0);
         var exists = rootcollections.filter(x => x.name == colname);