feat: add user added topic

config/default.js

@@ -35,6 +35,7 @@ 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_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

@@ -4,8 +4,10 @@
 
 const joi = require('@hapi/joi')
 const _ = require('lodash')
+const config = require('config')
 
 const errors = require('../../common/errors')
+const logger = require('../../common/logger')
 const helper = require('../../common/helper')
 const dbHelper = require('../../common/db-helper')
 const serviceHelper = require('../../common/service-helper')
@@ -33,7 +35,11 @@ async function create (entity, auth) {
   const result = await sequelize.transaction(async (t) => {
     const userEntity = await dbHelper.create(User, entity, auth, t)
     await serviceHelper.createRecordInEs(resource, userEntity.dataValues, true)
-    return userEntity
+    try {
+      await helper.postEvent(config.UBAHN_CREATE_USER_TOPIC, userEntity.dataValues)
+    } catch (err) {
+      logger.logFullError(err)
+    }
   })
 
   return result