Merge pull request #128 from bountyC0d3r/develop

patch group

Author: bountyC0d3r

src/controllers/GroupController.js

@@ -43,6 +43,16 @@ async function updateGroup(req, res) {
   res.send(result)
 }
 
+/**
+ * Patch group
+ * @param req the request
+ * @param res the response
+ */
+async function patchGroup(req, res) {
+  const result = await service.patchGroup(req.authUser.isMachine ? 'M2M' : req.authUser, req.params.groupId, req.body)
+  res.send(result)
+}
+
 /**
  * Get group
  * @param req the request
@@ -99,6 +109,7 @@ module.exports = {
   searchGroups,
   createGroup,
   updateGroup,
+  patchGroup,
   getGroup,
   deleteGroup,
   getGroupByOldId,

src/routes.js

@@ -50,6 +50,13 @@ module.exports = {
       access: [constants.UserRoles.Admin],
       scopes: ['write:groups', 'all:groups']
     },
+    patch: {
+      controller: 'GroupController',
+      method: 'patchGroup',
+      auth: 'jwt',
+      access: [constants.UserRoles.Admin],
+      scopes: ['write:groups', 'all:groups']
+    },
     delete: {
       controller: 'GroupController',
       method: 'deleteGroup',

src/services/GroupService.js

@@ -300,6 +300,66 @@ updateGroup.schema = {
   })
 }
 
+/**
+ * Patch group
+ * @param {Object} currentUser the current user
+ * @param {String} groupId the id of group to update
+ * @param {Object} data the data to update group
+ * @returns {Object} the updated group
+ */
+async function patchGroup(currentUser, groupId, data) {
+  const session = helper.createDBSession()
+  const tx = session.beginTransaction()
+  try {
+    logger.debug(`Patch Group - user - ${currentUser} , data -  ${JSON.stringify(data)}`)
+    const group = await helper.ensureExists(
+      tx,
+      'Group',
+      groupId,
+      currentUser === 'M2M' || helper.hasAdminRole(currentUser)
+    )
+
+    const groupData = data
+    groupData.id = groupId
+    groupData.updatedAt = new Date().toISOString()
+    groupData.updatedBy = currentUser === 'M2M' ? '00000000' : currentUser.userId
+    groupData.oldId = data.oldId ? data.oldId : ''
+
+    const updateRes = await tx.run(
+      'MATCH (g:Group {id: {id}}) SET g.updatedAt={updatedAt}, g.updatedBy={updatedBy}, g.oldId={oldId} RETURN g',
+      groupData
+    )
+
+    const updatedGroup = updateRes.records[0].get(0).properties
+    logger.debug(`Group = ${JSON.stringify(updatedGroup)}`)
+
+    await tx.commit()
+
+    // update the cache
+    const cache = await helper.getCacheInstance()
+    cache.set(group.id, updatedGroup)
+
+    return updatedGroup
+  } catch (error) {
+    logger.error(error)
+    logger.debug('Transaction Rollback')
+    await tx.rollback()
+    throw error
+  } finally {
+    logger.debug('Session Close')
+    await session.close()
+  }
+}
+
+patchGroup.schema = {
+  currentUser: Joi.any(),
+  groupId: Joi.string(), // defined in app-bootstrap
+  data: Joi.object()
+    .keys({
+      oldId: Joi.string(),
+    })
+}
+
 /**
  * Get group.
  * @param {Object} currentUser the current user
@@ -532,6 +592,7 @@ module.exports = {
   searchGroups,
   createGroup,
   updateGroup,
+  patchGroup,
   getGroup,
   deleteGroup
 }