1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
|
import { HookContext } from '@feathersjs/feathers';
import { Types } from 'mongoose';
import bluebird from 'bluebird'; import _ from 'lodash';
import { Poll } from 'which-types';
import { PollSchema } from '../../models/polls/poll.schema';
import VoteModel from '../../models/votes/vote.model';
import sortByDate from '../../hooks/sortByDate';
const convertPoll = async (context: HookContext): Promise<HookContext> => {
const { app, result, params: { user } } = context;
const convert = async (poll: PollSchema): Promise<Poll | null> => {
const author = await app.service('users').get(poll.authorId);
const contents = await VoteModel.aggregate([
{ $match: { pollId: Types.ObjectId(poll._id) } },
{ $group: { _id: '$which', total: { $sum: 1 } } }
]).then(groups => groups.reduce(
(acc, group) => _.set(acc, `${group._id}.votes`, group.total),
{ left: { votes: 0 }, right: { votes: 0 } }
));
const vote = await VoteModel.findOne(
{ pollId: poll._id, authorId: user?._id }
);
return _.merge(
_.omit(poll, ['authorId']),
{ author, contents, vote }
);
};
if (Array.isArray(result)) {
const polls = await bluebird.map(result, (poll: PollSchema) => convert(poll));
context.result = _.compact(polls);
} else {
context.result = await convert(result);
}
return context;
};
export default {
before: {
find: sortByDate
},
after: {
all: convertPoll
}
};
|
