|
1 | | -/** |
2 | | - * Endpoint to list project members. |
3 | | - */ |
4 | 1 | import _ from 'lodash'; |
| 2 | +import Joi from 'joi'; |
| 3 | +import validate from 'express-validation'; |
5 | 4 | import { middleware as tcMiddleware } from 'tc-core-library-js'; |
| 5 | +import models from '../../models'; |
6 | 6 | import util from '../../util'; |
7 | 7 |
|
| 8 | +/** |
| 9 | + * API to list all project members. |
| 10 | + * |
| 11 | + */ |
8 | 12 | const permissions = tcMiddleware.permissions; |
9 | 13 |
|
| 14 | +const schema = { |
| 15 | + query: { |
| 16 | + fields: Joi.string().optional(), |
| 17 | + }, |
| 18 | +}; |
| 19 | + |
10 | 20 | module.exports = [ |
| 21 | + validate(schema), |
11 | 22 | permissions('project.listMembers'), |
12 | | - async (req, res) => { |
13 | | - let members = req.context.currentProjectMembers; |
14 | | - |
15 | | - |
16 | | - if (members.length && _.get(req, 'query.fields')) { |
17 | | - const fields = req.query.fields.split(','); |
18 | | - |
19 | | - const ModelFields = [ |
20 | | - 'id', |
21 | | - 'userId', |
22 | | - 'role', |
23 | | - 'isPrimary', |
24 | | - 'deletedAt', |
25 | | - 'createdAt', |
26 | | - 'updatedAt', |
27 | | - 'deletedBy', |
28 | | - 'createdBy', |
29 | | - 'updatedBy', |
30 | | - ]; |
31 | | - |
32 | | - const modelFields = _.intersection(ModelFields, fields); |
33 | | - const hasUserIdField = _.indexOf(fields, 'userId') !== -1; |
34 | | - if (hasUserIdField === false) { |
35 | | - modelFields.push('userId'); |
36 | | - } |
37 | | - // merge model fields |
38 | | - members = _.map(members, m => _.pick(m, modelFields)); |
39 | | - |
40 | | - const MemberDetailFields = ['handle', 'firstName', 'lastName']; |
41 | | - const memberDetailFields = _.intersection(MemberDetailFields, fields); |
42 | | - |
43 | | - // has handleField |
44 | | - const hasHandleField = _.indexOf(memberDetailFields, 'handle') !== -1; |
45 | | - |
46 | | - if (hasHandleField === false) { |
47 | | - memberDetailFields.push('handle'); |
48 | | - } |
49 | | - |
50 | | - if (memberDetailFields.length) { |
51 | | - const userIds = _.map(members, m => `userId:${m.userId}`) || []; |
52 | | - |
53 | | - const logger = req.log; |
54 | | - try { |
55 | | - const memberDetails = await util.getMemberDetailsByUserIds(userIds, logger, req.id); |
56 | | - |
57 | | - // merge detail fields |
58 | | - _.forEach(members, (m) => { |
59 | | - const detail = _.find(memberDetails, mt => mt.userId === m.userId); |
60 | | - if (detail) { |
61 | | - _.assign(m, _.pick(detail, memberDetailFields)); |
62 | | - } |
63 | | - }); |
64 | | - |
65 | | - |
66 | | - const TraitFields = ['photoURL', 'workingHourStart', 'workingHourEnd', 'timeZone']; |
67 | | - const traitFields = _.intersection(TraitFields, fields); |
68 | | - if (traitFields.length) { |
69 | | - const promises = []; |
70 | | - _.forEach(members, (m) => { |
71 | | - if (m.handle) { |
72 | | - promises.push(util.getMemberTratisByHandle(m.handle, req.log, req.id)); |
73 | | - } |
74 | | - }); |
75 | | - |
76 | | - const traits = await Promise.all(promises); |
77 | | - |
78 | | - // remove photoURL, because connect_info also has photoURL |
79 | | - const ConnectInfoFields = ['workingHourStart', 'workingHourEnd', 'timeZone']; |
80 | | - const connectInfoFields = _.intersection(ConnectInfoFields, fields); |
81 | | - |
82 | | - // merge traits |
83 | | - _.forEach(members, (m) => { |
84 | | - const traitsArr = _.find(traits, t => t[0].userId === m.userId); |
85 | | - if (traitsArr) { |
86 | | - if (traitFields[0] === 'photoURL') { |
87 | | - _.assign(m, { |
88 | | - photoURL: _.get(_.find(traitsArr, { traitId: 'basic_info' }), 'traits.data[0].photoURL'), |
89 | | - }); |
90 | | - if (traitFields.length > 1) { |
91 | | - const traitInfo = _.get(_.find(traitsArr, { traitId: 'connect_info' }), 'traits.data[0]', {}); |
92 | | - _.assign(m, _.pick(traitInfo, connectInfoFields)); |
93 | | - } |
94 | | - } else { |
95 | | - const traitInfo = _.get(_.find(traitsArr, { traitId: 'connect_info' }), 'traits.data[0]', {}); |
96 | | - _.assign(m, _.pick(traitInfo, connectInfoFields)); |
97 | | - } |
98 | | - } |
99 | | - }); |
100 | | - } |
101 | | - } catch (e) { |
102 | | - logger.error('Error getting member details', e); |
103 | | - if (hasUserIdField === false) { |
104 | | - members = _.map(members, m => _.omit(m, ['userId'])); |
105 | | - } |
106 | | - if (hasHandleField === false) { |
107 | | - members = _.map(members, m => _.omit(m, ['handle'])); |
108 | | - } |
109 | | - return res.json(util.wrapResponse(req.id, members)); |
110 | | - } |
111 | | - } |
112 | | - |
113 | | - if (hasUserIdField === false) { |
114 | | - members = _.map(members, m => _.omit(m, ['userId'])); |
115 | | - } |
116 | | - if (hasHandleField === false) { |
117 | | - members = _.map(members, m => _.omit(m, ['handle'])); |
118 | | - } |
| 23 | + async (req, res, next) => { |
| 24 | + let fields = null; |
| 25 | + if (req.query.fields) { |
| 26 | + fields = req.query.fields.split(','); |
| 27 | + } |
| 28 | + try { |
| 29 | + const memberFields = _.keys(models.ProjectMember.attributes); |
| 30 | + const members = await util.getObjectsWithMemberDetails( |
| 31 | + req.context.currentProjectMembers, fields, { |
| 32 | + logger: req.log, |
| 33 | + requestId: req.id, |
| 34 | + memberFields, |
| 35 | + }, |
| 36 | + ); |
119 | 37 | return res.json(util.wrapResponse(req.id, members)); |
| 38 | + } catch (err) { |
| 39 | + return next(err); |
120 | 40 | } |
121 | | - |
122 | | - return res.json(util.wrapResponse(req.id, req.context.currentProjectMembers)); |
123 | 41 | }, |
124 | 42 | ]; |
0 commit comments