summaryrefslogtreecommitdiff
path: root/src/server/api/endpoints/aggregation/users.ts
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2018-08-19 00:27:23 +0900
committersyuilo <syuilotan@yahoo.co.jp>2018-08-19 00:27:23 +0900
commit0481de6629536f7f3144321d9e4fe2144c62d7f0 (patch)
treea4b10a50c4114d4229c6ff87905f9bd2bc4ed375 /src/server/api/endpoints/aggregation/users.ts
parentwip (diff)
downloadsharkey-0481de6629536f7f3144321d9e4fe2144c62d7f0.tar.gz
sharkey-0481de6629536f7f3144321d9e4fe2144c62d7f0.tar.bz2
sharkey-0481de6629536f7f3144321d9e4fe2144c62d7f0.zip
wip
Diffstat (limited to 'src/server/api/endpoints/aggregation/users.ts')
-rw-r--r--src/server/api/endpoints/aggregation/users.ts92
1 files changed, 0 insertions, 92 deletions
diff --git a/src/server/api/endpoints/aggregation/users.ts b/src/server/api/endpoints/aggregation/users.ts
deleted file mode 100644
index d016484238..0000000000
--- a/src/server/api/endpoints/aggregation/users.ts
+++ /dev/null
@@ -1,92 +0,0 @@
-import User from '../../../../models/user';
-
-export const meta = {
- requireCredential: true,
- requireAdmin: true
-};
-
-/**
- * Aggregate users
- */
-export default (params: any) => new Promise(async (res, rej) => {
- const query = [{
- $match: {
- createdAt: {
- $gt: new Date(new Date().setFullYear(new Date().getFullYear() - 1))
- }
- }
- }, {
- $project: {
- host: '$host',
- createdAt: { $add: ['$createdAt', 9 * 60 * 60 * 1000] } // Convert into JST
- }
- }, {
- $project: {
- date: {
- year: { $year: '$createdAt' },
- month: { $month: '$createdAt' },
- day: { $dayOfMonth: '$createdAt' }
- },
- origin: {
- $cond: {
- if: { $eq: ['$host', null] },
- then: 'local',
- else: 'remote'
- }
- }
- }
- }, {
- $group: {
- _id: {
- date: '$date',
- origin: '$origin'
- },
- count: { $sum: 1 }
- }
- }, {
- $group: {
- _id: '$_id.date',
- data: {
- $addToSet: {
- type: '$_id.type',
- origin: '$_id.origin',
- count: '$count'
- }
- }
- }
- }] as any;
-
- const datas = await User.aggregate(query);
-
- datas.forEach((data: any) => {
- data.date = data._id;
- delete data._id;
-
- data.local = (data.data.filter((x: any) => x.origin == 'local')[0] || { count: 0 }).count;
- data.remote = (data.data.filter((x: any) => x.origin == 'remote')[0] || { count: 0 }).count;
-
- delete data.data;
- });
-
- const graph = [];
-
- for (let i = 0; i < 365; i++) {
- const day = new Date(new Date().setDate(new Date().getDate() - i));
-
- const data = datas.filter((d: any) =>
- d.date.year == day.getFullYear() && d.date.month == day.getMonth() + 1 && d.date.day == day.getDate()
- )[0];
-
- if (data) {
- graph.push(data);
- } else {
- graph.push({
- date: { year: day.getFullYear(), month: day.getMonth() + 1, day: day.getDate() },
- local: 0,
- remote: 0
- });
- }
- }
-
- res(graph);
-});