feat[event]: emit structured user role change event

src/services/org-admin.js

@@ -28,6 +28,8 @@ const emailEncryption = require('@utils/emailEncryption')
 const responses = require('@helpers/responses')
 const notificationUtils = require('@utils/notification')
 const userHelper = require('@helpers/userHelper')
+const { broadcastUserEvent } = require('@helpers/eventBroadcasterMain')
+const { eventBodyDTO } = require('@dtos/userDTO')
 
 module.exports = class OrgAdminHelper {
 	/**
@@ -628,42 +630,62 @@ module.exports = class OrgAdminHelper {
 	}
 }
 
-function updateRoleForApprovedRequest(requestDetails, user, tenantCode, orgCode) {
-	return new Promise(async (resolve, reject) => {
-		try {
-			const newRole = await roleQueries.findOne(
-				{ id: requestDetails.role, status: common.ACTIVE_STATUS, tenant_code: tenantCode },
-				{ attributes: ['title', 'id', 'user_type', 'status'] }
-			)
+async function updateRoleForApprovedRequest(requestDetails, user, tenantCode, orgCode) {
+	try {
+		const newRole = await roleQueries.findOne(
+			{ id: requestDetails.role, status: common.ACTIVE_STATUS, tenant_code: tenantCode },
+			{ attributes: ['title', 'id', 'user_type', 'status'] }
+		)
 
-			await userOrganizationRoleQueries.create({
-				tenant_code: tenantCode,
-				user_id: user.id,
-				organization_code: orgCode,
-				role_id: newRole.id,
-			})
+		if (!newRole) {
+			throw new Error('ROLE_NOT_FOUND')
+		}
 
-			eventBroadcaster('roleChange', {
-				requestBody: {
-					user_id: requestDetails.requester_id,
-					new_roles: [newRole.title],
-					current_roles: _.map(_.find(user.organizations, { code: orgCode })?.roles || [], 'title'),
-					tenant_code: tenantCode,
-					organization_code: orgCode,
-				},
-			})
-			//delete from cache
-			const redisUserKey = `${common.redisUserPrefix}${tenantCode}_${requestDetails.requester_id.toString()}`
-			await utils.redisDel(redisUserKey)
+		const oldOrganizations = user.organizations || []
+
+		await userOrganizationRoleQueries.create({
+			tenant_code: tenantCode,
+			user_id: user.id,
+			organization_code: orgCode,
+			role_id: newRole.id,
+		})
+
+		const updatedUser = await userQueries.findUserWithOrganization({
+			id: requestDetails.requester_id,
+			tenant_code: tenantCode,
+		})
+
+		const newOrganizations = updatedUser.organizations || []
+
+		const changedValues = [
+			{
+				fieldName: 'organizations',
+				oldValue: oldOrganizations,
+				newValue: newOrganizations,
+			},
+		]
+
+		const eventBody = eventBodyDTO({
+			entity: 'user',
+			eventType: 'update',
+			entityId: requestDetails.requester_id,
+			changedValues,
+			args: {
+				created_at: updatedUser.created_at,
+				updated_at: updatedUser.updated_at,
+			},
+		})
+
+		broadcastUserEvent('userEvents', { requestBody: eventBody, isInternal: true })
+
+		const redisUserKey = `${common.redisUserPrefix}${tenantCode}_${requestDetails.requester_id.toString()}`
+		await utils.redisDel(redisUserKey)
 
-			return resolve({
-				success: true,
-			})
-		} catch (error) {
-			console.log(error, 'error')
-			return error
-		}
-	})
+		return { success: true }
+	} catch (error) {
+		console.log(error, 'error')
+		throw error
+	}
 }
 
 async function sendRoleRequestStatusEmail(userDetails, status, organizationCode, tenantCode) {