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/util.js b/src/util.js index 6fe533ee..c5e999c3 100644 --- a/src/util.js +++ b/src/util.js @@ -335,7 +335,9 @@ _.assignIn(util, { try { const token = yield this.getSystemUserToken(logger); const httpClient = this.getHttpClient({ id: requestId, log: logger }); - logger.trace(userIds); + if (logger) { + logger.trace(userIds); + } return httpClient.get(`${config.memberServiceEndpoint}/_search`, { params: { query: `${userIds.join(urlencode(' OR ', 'utf8'))}`,