Skip to content
This repository was archived by the owner on Mar 13, 2025. It is now read-only.

Commit 707c209

Browse files
author
Sachin Maheshwari
committed
reverting CQRS changes for 'user delete'
1 parent c718f54 commit 707c209

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

src/modules/user/service.js

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -187,6 +187,15 @@ async function remove (id, auth, params) {
187187
* @param params the path params
188188
*/
189189
async function beginCascadeDelete (id, params) {
190+
await serviceHelper.deleteChild(Achievement, id, ['userId', 'achievementsProviderId'], 'Achievement')
191+
await serviceHelper.deleteChild(ExternalProfile, id, ['userId', 'organizationId'], 'ExternalProfile')
192+
await serviceHelper.deleteChild(UserAttribute, id, ['userId', 'attributeId'], 'UserAttribute')
193+
await serviceHelper.deleteChild(UsersRole, id, ['userId', 'roleId'], 'UsersRole')
194+
await serviceHelper.deleteChild(UsersSkill, id, ['userId', 'skillId'], 'UsersSkill')
195+
await dbHelper.remove(User, id)
196+
await serviceHelper.deleteRecordFromEs(id, params, resource)
197+
//TODO: below code is not working, so simply commented our changes
198+
/* //Start here
190199
let payload = {id}
191200
try {
192201
await sequelize.transaction(async (t) => {
@@ -203,6 +212,7 @@ async function beginCascadeDelete (id, params) {
203212
helper.publishError(config.UBAHN_ERROR_TOPIC, payload, 'user.delete')
204213
throw e
205214
}
215+
*/ // End here
206216
}
207217

208218
module.exports = {

0 commit comments

Comments
 (0)