fix: add update and delete topic for user

config/default.js

@@ -35,7 +35,9 @@ module.exports = {
   KAFKA_MESSAGE_ORIGINATOR: process.env.KAFKA_MESSAGE_ORIGINATOR || 'u-bahn-api',
 
   // topics
-  UBAHN_CREATE_USER_TOPIC: process.env.UBAHN_CREATE_TOPIC || 'user.action.topic.create',
+  UBAHN_CREATE_USER_TOPIC: process.env.UBAHN_CREATE_USER_TOPIC || 'user.action.topic.create',
+  UBAHN_UPDATE_USER_TOPIC: process.env.UBAHN_UPDATE_USER_TOPIC || 'user.action.topic.update',
+  UBAHN_DELETE_USER_TOPIC: process.env.UBAHN_DELETE_USER_TOPIC || 'user.action.topic.delete',
   UBAHN_CREATE_TOPIC: process.env.UBAHN_CREATE_TOPIC || 'u-bahn.action.create',
   UBAHN_UPDATE_TOPIC: process.env.UBAHN_UPDATE_TOPIC || 'u-bahn.action.update',
   UBAHN_DELETE_TOPIC: process.env.UBAHN_DELETE_TOPIC || 'u-bahn.action.delete',

src/modules/user/service.js

@@ -68,6 +68,12 @@ async function patch (id, entity, auth, params) {
   const result = await sequelize.transaction(async (t) => {
     const newEntity = await dbHelper.update(User, id, entity, auth, null, t)
     await serviceHelper.patchRecordInEs(resource, newEntity.dataValues, true)
+
+    try {
+      await helper.postEvent(config.UBAHN_UPDATE_USER_TOPIC, newEntity.dataValues)
+    } catch (err) {
+      logger.logFullError(err)
+    }
     return newEntity
   })
 
@@ -182,6 +188,11 @@ async function beginCascadeDelete (id, params) {
     await serviceHelper.deleteChild(UsersSkill, id, ['userId', 'skillId'], 'UsersSkill', t)
     await dbHelper.remove(User, id, null, t)
     await serviceHelper.deleteRecordFromEs(id, params, resource, true)
+    try {
+      await helper.postEvent(config.UBAHN_DELETE_USER_TOPIC, {id})
+    } catch (err) {
+      logger.logFullError(err)
+    }
   })
 }