Skip to content

Commit 9913ae7

Browse files
committed
reset cache no matter what
1 parent 5b5ce24 commit 9913ae7

1 file changed

Lines changed: 17 additions & 17 deletions

File tree

OpenFlow/src/DatabaseConnection.ts

Lines changed: 17 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -318,23 +318,23 @@ export class DatabaseConnection extends events.EventEmitter {
318318
if (_type == "queue") await DBHelper.memoryCache.del("queuename_" + item.name);
319319
}
320320
if (collectionname == "users" && (_type == "user" || _type == "role" || _type == "customer")) {
321-
// DBHelper.clearCache("watch detected change in " + collectionname + " collection for a " + _type + " " + item.name);
322-
await DBHelper.memoryCache.del("users" + item._id);
323-
if (_type == "role") {
324-
var role: Role = item as Role;
325-
await DBHelper.memoryCache.del("rolename_" + item.name);
326-
// this.WellknownIdsArray.indexOf(item._id) == -1
327-
if (!NoderedUtil.IsNullUndefinded(role.members) && role.members.length > 0 && item._id != WellknownIds.users) {
328-
for (let i = 0; i < role.members.length; i++) {
329-
let member = role.members[i];
330-
await DBHelper.memoryCache.del("users" + member._id);
331-
await DBHelper.memoryCache.del("username_" + member.name);
332-
await DBHelper.memoryCache.del("rolename_" + member.name);
333-
}
334-
}
335-
} else {
336-
await DBHelper.memoryCache.del("username_" + item.name);
337-
}
321+
DBHelper.clearCache("watch detected change in " + collectionname + " collection for a " + _type + " " + item.name);
322+
// await DBHelper.memoryCache.del("users" + item._id);
323+
// if (_type == "role") {
324+
// var role: Role = item as Role;
325+
// await DBHelper.memoryCache.del("rolename_" + item.name);
326+
// // this.WellknownIdsArray.indexOf(item._id) == -1
327+
// if (!NoderedUtil.IsNullUndefinded(role.members) && role.members.length > 0 && item._id != WellknownIds.users) {
328+
// for (let i = 0; i < role.members.length; i++) {
329+
// let member = role.members[i];
330+
// await DBHelper.memoryCache.del("users" + member._id);
331+
// await DBHelper.memoryCache.del("username_" + member.name);
332+
// await DBHelper.memoryCache.del("rolename_" + member.name);
333+
// }
334+
// }
335+
// } else {
336+
// await DBHelper.memoryCache.del("username_" + item.name);
337+
// }
338338
}
339339
if (collectionname == "config" && (_type == "provider" || _type == "restriction" || _type == "resource")) {
340340
DBHelper.clearCache("watch detected change in " + collectionname + " collection for a " + _type + " " + item.name);

0 commit comments

Comments
 (0)