Fb/asset ownership transfer api

src/routes/programRoutes.js

@@ -139,4 +139,8 @@ module.exports = function (app) {
     app.route(BASE_URL + '/user/:userId')
       .delete(requestMiddleware.createAndValidateRequestBody,
       userService.deleteUser)
+
+    app.route(BASE_URL + '/user/transfer')
+      .post(requestMiddleware.createAndValidateRequestBody,
+      userService.transferAssetOfDeleteduser)
 }

src/service/messageUtil.js

@@ -1017,7 +1017,9 @@ exports.USER = {
     MISSING_MESSAGE: "User id is not passed in the request",
     FAILED_MESSAGE: 'Unable to delete given user',
     EXCEPTION_CODE: 'USER_DEL',
-    INFO: 'Delete User'
+    INFO: 'Delete User',
+    OWNERSHIP_TRANSFER_FAIL: "Error on transfering assets",
+    OWNERSHIP_TRANSFER: "Transfering assets"
   }
 }
 

src/service/userService.js

@@ -314,6 +314,42 @@ function deleteOsUser (userDetails, callback) {
   return registryService.updateRecord(regReq, callback);
 }
 
+async function transferAssetOfDeleteduser(req, response){
+  logObject['message'] = userMessages.DELETE.OWNERSHIP_TRANSFER
+  logObject['traceId'] = req.headers['x-request-id'] || '',
+  loggerService.entryLog(req.body, logObject);
+  try {
+  KafkaService.sendRecordWithTopic(req.rspObj.request, envVariables.COKREAT_USER_DELETE_KAFKA_TOPIC, function (err, res) {
+    if (err) {
+      handelAssetOwnershiptransfer(req, err);
+    } else{
+      return response.status(200).send(successResponse(rspObj));
+    }
+  });
+ }catch(err) {
+  handelAssetOwnershiptransfer(req, err)
+ }
+}
+
+function handelAssetOwnershiptransfer(req, err){
+  var rspObj = req.rspObj
+  console.log('User transferAssetOfDeleteduser failed', JSON.stringify(err))
+  if(err && err.response && err.response.data) {
+    console.log(`User transferAssetOfDeleteduser err ==> ${req.params.userId}  ==>`, JSON.stringify(err.response.data));
+  }
+  const errCode = userMessages.DELETE.OWNERSHIP_TRANSFER_FAIL;
+  rspObj.errCode = userMessages.DELETE.FAILED_CODE;
+  rspObj.errMsg = userMessages.DELETE.FAILED_MESSAGE
+  rspObj.responseCode = responseCode.SERVER_err
+  rspObj.result  = err;
+  loggererr(rspObj, errCode);
+  loggerService.exitLog({responseCode: rspObj.responseCode}, logObject);
+  return response.status(400).send(errorResponse(rspObj,errCode))
+
+}
+
+
+
 function onIndividualUserDeletion (req, response, userDetails) {
   const eventData = generateDeleteUserEvent (req, response, userDetails, []);
   try {
@@ -366,4 +402,4 @@ function onOrgUserDeletion(req, response, userDetails) {
   });
 }
 
-module.exports = { getSunbirdUserProfiles, deleteUser }
+module.exports = { getSunbirdUserProfiles, deleteUser, transferAssetOfDeleteduser }