diff --git a/src/events/projectMembers/index.js b/src/events/projectMembers/index.js index e25eb7a2..bab7e486 100644 --- a/src/events/projectMembers/index.js +++ b/src/events/projectMembers/index.js @@ -178,7 +178,7 @@ const projectMemberUpdatedHandler = Promise.coroutine(function* a(logger, msg, c try { const data = JSON.parse(msg.content.toString()); // get member information - const memberDetails = yield util.getMemberDetailsByUserIds[data.original.userId]; + const memberDetails = yield util.getMemberDetailsByUserIds([data.original.userId], logger); const payload = _.merge(data.updated, _.pick(memberDetails[0], 'handle', 'firstName', 'lastName', 'email')); const doc = yield eClient.get({ index: ES_PROJECT_INDEX, type: ES_PROJECT_TYPE, id: data.original.projectId }); diff --git a/src/events/projects/index.js b/src/events/projects/index.js index 01848012..5bd0e150 100644 --- a/src/events/projects/index.js +++ b/src/events/projects/index.js @@ -26,7 +26,7 @@ const indexProject = Promise.coroutine(function* (logger, msg) { // eslint-disab const userIds = data.members ? data.members.map(single => `userId:${single.userId}`) : []; try { // retrieve member details - const memberDetails = yield util.getMemberDetailsByUserIds(userIds, msg.properties.correlationId, logger); + const memberDetails = yield util.getMemberDetailsByUserIds(userIds, logger, msg.properties.correlationId); // if no members are returned than this should result in nack // if (!_.isArray(memberDetails) || memberDetails.length === 0) { // logger.error(`Empty member details for userIds ${userIds.join(',')} requeing the message`); diff --git a/src/routes/projectMemberInvites/create.js b/src/routes/projectMemberInvites/create.js index 490bbba6..7717bdc9 100644 --- a/src/routes/projectMemberInvites/create.js +++ b/src/routes/projectMemberInvites/create.js @@ -103,15 +103,17 @@ const buildCreateInvitePromises = (req, invite, invites, data) => { }; const sendInviteEmail = (req, projectId, invite) => { + req.log.debug(req.authUser); const emailEventType = BUS_API_EVENT.PROJECT_MEMBER_EMAIL_INVITE_CREATED; const promises = [ models.Project.find({ where: { id: projectId }, raw: true, }), - util.getMemberDetailsByUserIds([req.authUser.userId], req.log, req.id), + util.getMemberDetailsByUserIds([`userId:${req.authUser.userId}`], req.log, req.id), ]; return Promise.all(promises).then((responses) => { + req.log.debug(responses); const project = responses[0]; const initiator = responses[1] && responses[1].length ? responses[1][0] : { userId: req.authUser.userId, diff --git a/src/util.js b/src/util.js index 33b66466..c5e999c3 100644 --- a/src/util.js +++ b/src/util.js @@ -335,6 +335,9 @@ _.assignIn(util, { try { const token = yield this.getSystemUserToken(logger); const httpClient = this.getHttpClient({ id: requestId, log: logger }); + if (logger) { + logger.trace(userIds); + } return httpClient.get(`${config.memberServiceEndpoint}/_search`, { params: { query: `${userIds.join(urlencode(' OR ', 'utf8'))}`,