clearcache when updating mq

skadefro · skadefro · commit 2573d1edb838 · 2021-12-03T22:01:06.000+01:00
diff --git a/OpenFlow/src/DatabaseConnection.ts b/OpenFlow/src/DatabaseConnection.ts
@@ -1592,7 +1592,10 @@ export class DatabaseConnection extends events.EventEmitter {
                         q.item = await this.Cleanmembers(q.item as any, original);
                         DBHelper.cached_roles = [];
                     }
-                    if (q.item._type === "role") {
+                    if (q.item._type === "role" && q.collectionname === "users") {
+                        amqpwrapper.Instance().send("openflow", "", { "command": "clearcache" }, 20000, null, "", 1);
+                    }
+                    if (q.collectionname === "mq") {
                         amqpwrapper.Instance().send("openflow", "", { "command": "clearcache" }, 20000, null, "", 1);
                     }
                     if (q.collectionname != "fs.files") {
@@ -1995,6 +1998,9 @@ export class DatabaseConnection extends events.EventEmitter {
                 if (collectionname == "users" && doc._type == "role") {
                     amqpwrapper.Instance().send("openflow", "", { "command": "clearcache" }, 20000, null, "", 1);
                 }
+                if (collectionname === "mq") {
+                    amqpwrapper.Instance().send("openflow", "", { "command": "clearcache" }, 20000, null, "", 1);
+                }
             }
         } catch (error) {
             span.recordException(error);

Original file line number	Diff line number	Diff line change
`@@ -1592,7 +1592,10 @@ export class DatabaseConnection extends events.EventEmitter {`
`1592`	`1592`	`q.item = await this.Cleanmembers(q.item as any, original);`
`1593`	`1593`	`DBHelper.cached_roles = [];`
`1594`	`1594`	`}`
`1595`		`- if (q.item._type === "role") {`
	`1595`	`+ if (q.item._type === "role" && q.collectionname === "users") {`
	`1596`	`+ amqpwrapper.Instance().send("openflow", "", { "command": "clearcache" }, 20000, null, "", 1);`
	`1597`	`+ }`
	`1598`	`+ if (q.collectionname === "mq") {`
`1596`	`1599`	`amqpwrapper.Instance().send("openflow", "", { "command": "clearcache" }, 20000, null, "", 1);`
`1597`	`1600`	`}`
`1598`	`1601`	`if (q.collectionname != "fs.files") {`
`@@ -1995,6 +1998,9 @@ export class DatabaseConnection extends events.EventEmitter {`
`1995`	`1998`	`if (collectionname == "users" && doc._type == "role") {`
`1996`	`1999`	`amqpwrapper.Instance().send("openflow", "", { "command": "clearcache" }, 20000, null, "", 1);`
`1997`	`2000`	`}`
	`2001`	`+ if (collectionname === "mq") {`
	`2002`	`+ amqpwrapper.Instance().send("openflow", "", { "command": "clearcache" }, 20000, null, "", 1);`
	`2003`	`+ }`
`1998`	`2004`	`}`
`1999`	`2005`	`} catch (error) {`
`2000`	`2006`	`span.recordException(error);`