Skip to content

Commit 0014d18

Browse files
committed
added route to delete all cache
1 parent 7e72e4c commit 0014d18

File tree

3 files changed

+30
-19
lines changed

3 files changed

+30
-19
lines changed

src/controllers/GroupController.js

Lines changed: 22 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ const logger = require('../common/logger')
1111
* @param req the request
1212
* @param res the response
1313
*/
14-
async function searchGroups (req, res) {
14+
async function searchGroups(req, res) {
1515
const criteria = req.query || {}
1616
const isAdmin = req.authUser.isMachine || helper.hasAdminRole(req.authUser)
1717
if (!isAdmin) {
@@ -28,7 +28,7 @@ async function searchGroups (req, res) {
2828
* @param req the request
2929
* @param res the response
3030
*/
31-
async function createGroup (req, res) {
31+
async function createGroup(req, res) {
3232
const result = await service.createGroup(req.authUser.isMachine ? 'M2M' : req.authUser, req.body)
3333
res.send(result)
3434
}
@@ -38,7 +38,7 @@ async function createGroup (req, res) {
3838
* @param req the request
3939
* @param res the response
4040
*/
41-
async function updateGroup (req, res) {
41+
async function updateGroup(req, res) {
4242
const result = await service.updateGroup(req.authUser.isMachine ? 'M2M' : req.authUser, req.params.groupId, req.body)
4343
res.send(result)
4444
}
@@ -48,7 +48,7 @@ async function updateGroup (req, res) {
4848
* @param req the request
4949
* @param res the response
5050
*/
51-
async function getGroup (req, res) {
51+
async function getGroup(req, res) {
5252
logger.debug(`Get group details for req = ${req}`)
5353
const result = await service.getGroup(req.authUser.isMachine ? 'M2M' : req.authUser, req.params.groupId, req.query)
5454
res.send(result)
@@ -59,7 +59,7 @@ async function getGroup (req, res) {
5959
* @param req the request
6060
* @param res the response
6161
*/
62-
async function deleteGroup (req, res) {
62+
async function deleteGroup(req, res) {
6363
const result = await service.deleteGroup(
6464
req.params.groupId,
6565
req.authUser.isMachine || helper.hasAdminRole(req.authUser)
@@ -72,7 +72,7 @@ async function deleteGroup (req, res) {
7272
* @param req the request
7373
* @param res the response
7474
*/
75-
async function getGroupByOldId (req, res) {
75+
async function getGroupByOldId(req, res) {
7676
const result = await service.getGroup(
7777
req.authUser.isMachine ? 'M2M' : req.authUser,
7878
req.params.oldId,
@@ -81,11 +81,26 @@ async function getGroupByOldId (req, res) {
8181
res.send(result)
8282
}
8383

84+
/**
85+
* flush cache
86+
* @param req the request
87+
* @param res the response
88+
*/
89+
async function flushCache(req, res) {
90+
const cachedData = helper.getCacheInstance()
91+
cachedData.flushAll()
92+
93+
res.send({
94+
message: 'all cached data has been removed'
95+
})
96+
}
97+
8498
module.exports = {
8599
searchGroups,
86100
createGroup,
87101
updateGroup,
88102
getGroup,
89103
deleteGroup,
90-
getGroupByOldId
104+
getGroupByOldId,
105+
flushCache
91106
}

src/routes.js

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,14 @@ module.exports = {
2727
method: 'checkHealth'
2828
}
2929
},
30+
'/groups/flushCache': {
31+
get: {
32+
controller: 'GroupController',
33+
auth: 'jwt',
34+
access: [constants.UserRoles.Admin],
35+
method: 'flushCache'
36+
}
37+
},
3038
'/groups/:groupId': {
3139
get: {
3240
controller: 'GroupController',

src/services/GroupMembershipService.js

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -117,12 +117,6 @@ async function addGroupMember(currentUser, groupId, data) {
117117
createdBy: currentUser === 'M2M' ? '00000000' : currentUser.userId
118118
}
119119

120-
// set the cache
121-
const cache = helper.getCacheInstance()
122-
const cachedMembers = cache.get(`${groupId}-members`)
123-
cachedMembers.push(memberId)
124-
cache.set(`${groupId}-members`, cachedMembers)
125-
126120
logger.debug(`quey for adding membership ${query} with params ${JSON.stringify(params)}`)
127121
await tx.run(query, params)
128122

@@ -282,12 +276,6 @@ async function deleteGroupMember(currentUser, groupId, memberId, query) {
282276
memberId = getMember.oldId
283277
}
284278

285-
// set the cache
286-
const cache = helper.getCacheInstance()
287-
const cachedMembers = cache.get(`${groupId}-members`)
288-
const updateMebers = _.remove(cachedMembers, memberId)
289-
cache.set(`${groupId}-members`, updateMebers)
290-
291279
const result = {
292280
groupId,
293281
name,

0 commit comments

Comments
 (0)