summaryrefslogtreecommitdiff
path: root/src/server/api/endpoints/aggregation
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2018-11-02 03:32:24 +0900
committersyuilo <syuilotan@yahoo.co.jp>2018-11-02 03:32:24 +0900
commit931bdc6aace5e7aa71ffdfb470e208ead78a2a53 (patch)
treeeee6d7bf5f5480b883bb601517b4d9db03f31e9f /src/server/api/endpoints/aggregation
parentRefactoring (diff)
downloadsharkey-931bdc6aace5e7aa71ffdfb470e208ead78a2a53.tar.gz
sharkey-931bdc6aace5e7aa71ffdfb470e208ead78a2a53.tar.bz2
sharkey-931bdc6aace5e7aa71ffdfb470e208ead78a2a53.zip
Refactoring, Clean up and bug fixes
Diffstat (limited to 'src/server/api/endpoints/aggregation')
-rw-r--r--src/server/api/endpoints/aggregation/hashtags.ts66
-rw-r--r--src/server/api/endpoints/aggregation/users/activity.ts110
-rw-r--r--src/server/api/endpoints/aggregation/users/post.ts104
-rw-r--r--src/server/api/endpoints/aggregation/users/reaction.ts74
4 files changed, 0 insertions, 354 deletions
diff --git a/src/server/api/endpoints/aggregation/hashtags.ts b/src/server/api/endpoints/aggregation/hashtags.ts
deleted file mode 100644
index ffeafb2538..0000000000
--- a/src/server/api/endpoints/aggregation/hashtags.ts
+++ /dev/null
@@ -1,66 +0,0 @@
-import Note from '../../../../models/note';
-import Meta from '../../../../models/meta';
-
-export default () => new Promise(async (res, rej) => {
- const meta = await Meta.findOne({});
- const hidedTags = meta ? (meta.hidedTags || []).map(t => t.toLowerCase()) : [];
-
- const span = 1000 * 60 * 60 * 24 * 7; // 1週間
-
- //#region 1. 指定期間の内に投稿されたハッシュタグ(とユーザーのペア)を集計
- const data = await Note.aggregate([{
- $match: {
- createdAt: {
- $gt: new Date(Date.now() - span)
- },
- tagsLower: {
- $exists: true,
- $ne: []
- }
- }
- }, {
- $unwind: '$tagsLower'
- }, {
- $group: {
- _id: { tag: '$tagsLower', userId: '$userId' }
- }
- }]) as Array<{
- _id: {
- tag: string;
- userId: any;
- }
- }>;
- //#endregion
-
- if (data.length == 0) {
- return res([]);
- }
-
- let tags: Array<{
- name: string;
- count: number;
- }> = [];
-
- // カウント
- data.map(x => x._id).forEach(x => {
- // ブラックリストに登録されているタグなら弾く
- if (hidedTags.includes(x.tag)) return;
-
- const i = tags.findIndex(tag => tag.name == x.tag);
- if (i != -1) {
- tags[i].count++;
- } else {
- tags.push({
- name: x.tag,
- count: 1
- });
- }
- });
-
- // タグを人気順に並べ替え
- tags = tags.sort((a, b) => b.count - a.count);
-
- tags = tags.slice(0, 30);
-
- res(tags);
-});
diff --git a/src/server/api/endpoints/aggregation/users/activity.ts b/src/server/api/endpoints/aggregation/users/activity.ts
deleted file mode 100644
index 0ec3f0db76..0000000000
--- a/src/server/api/endpoints/aggregation/users/activity.ts
+++ /dev/null
@@ -1,110 +0,0 @@
-import $ from 'cafy'; import ID from '../../../../../misc/cafy-id';
-import User from '../../../../../models/user';
-import Note from '../../../../../models/note';
-
-// TODO: likeやfollowも集計
-
-/**
- * Aggregate activity of a user
- */
-export default (params: any) => new Promise(async (res, rej) => {
- // Get 'limit' parameter
- const [limit = 365, limitErr] = $.num.optional.range(1, 365).get(params.limit);
- if (limitErr) return rej('invalid limit param');
-
- // Get 'userId' parameter
- const [userId, userIdErr] = $.type(ID).get(params.userId);
- if (userIdErr) return rej('invalid userId param');
-
- // Lookup user
- const user = await User.findOne({
- _id: userId
- }, {
- fields: {
- _id: true
- }
- });
-
- if (user === null) {
- return rej('user not found');
- }
-
- const datas = await Note
- .aggregate([
- { $match: { userId: user._id } },
- { $project: {
- renoteId: '$renoteId',
- replyId: '$replyId',
- createdAt: { $add: ['$createdAt', 9 * 60 * 60 * 1000] } // Convert into JST
- }},
- { $project: {
- date: {
- year: { $year: '$createdAt' },
- month: { $month: '$createdAt' },
- day: { $dayOfMonth: '$createdAt' }
- },
- type: {
- $cond: {
- if: { $ne: ['$renoteId', null] },
- then: 'renote',
- else: {
- $cond: {
- if: { $ne: ['$replyId', null] },
- then: 'reply',
- else: 'note'
- }
- }
- }
- }}
- },
- { $group: { _id: {
- date: '$date',
- type: '$type'
- }, count: { $sum: 1 } } },
- { $group: {
- _id: '$_id.date',
- data: { $addToSet: {
- type: '$_id.type',
- count: '$count'
- }}
- } }
- ]);
-
- datas.forEach((data: any) => {
- data.date = data._id;
- delete data._id;
-
- data.notes = (data.data.filter((x: any) => x.type == 'note')[0] || { count: 0 }).count;
- data.renotes = (data.data.filter((x: any) => x.type == 'renote')[0] || { count: 0 }).count;
- data.replies = (data.data.filter((x: any) => x.type == 'reply')[0] || { count: 0 }).count;
-
- delete data.data;
- });
-
- const graph = [];
-
- for (let i = 0; i < limit; 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, // In JavaScript, month is zero-based.
- day: day.getDate()
- },
- notes: 0,
- renotes: 0,
- replies: 0
- });
- }
- }
-
- res(graph);
-});
diff --git a/src/server/api/endpoints/aggregation/users/post.ts b/src/server/api/endpoints/aggregation/users/post.ts
deleted file mode 100644
index 090f6d2f09..0000000000
--- a/src/server/api/endpoints/aggregation/users/post.ts
+++ /dev/null
@@ -1,104 +0,0 @@
-import $ from 'cafy'; import ID from '../../../../../misc/cafy-id';
-import User from '../../../../../models/user';
-import Note from '../../../../../models/note';
-
-/**
- * Aggregate note of a user
- */
-export default (params: any) => new Promise(async (res, rej) => {
- // Get 'userId' parameter
- const [userId, userIdErr] = $.type(ID).get(params.userId);
- if (userIdErr) return rej('invalid userId param');
-
- // Lookup user
- const user = await User.findOne({
- _id: userId
- }, {
- fields: {
- _id: true
- }
- });
-
- if (user === null) {
- return rej('user not found');
- }
-
- const datas = await Note
- .aggregate([
- { $match: { userId: user._id } },
- { $project: {
- renoteId: '$renoteId',
- replyId: '$replyId',
- createdAt: { $add: ['$createdAt', 9 * 60 * 60 * 1000] } // Convert into JST
- }},
- { $project: {
- date: {
- year: { $year: '$createdAt' },
- month: { $month: '$createdAt' },
- day: { $dayOfMonth: '$createdAt' }
- },
- type: {
- $cond: {
- if: { $ne: ['$renoteId', null] },
- then: 'renote',
- else: {
- $cond: {
- if: { $ne: ['$replyId', null] },
- then: 'reply',
- else: 'note'
- }
- }
- }
- }}
- },
- { $group: { _id: {
- date: '$date',
- type: '$type'
- }, count: { $sum: 1 } } },
- { $group: {
- _id: '$_id.date',
- data: { $addToSet: {
- type: '$_id.type',
- count: '$count'
- }}
- } }
- ]);
-
- datas.forEach((data: any) => {
- data.date = data._id;
- delete data._id;
-
- data.notes = (data.data.filter((x: any) => x.type == 'note')[0] || { count: 0 }).count;
- data.renotes = (data.data.filter((x: any) => x.type == 'renote')[0] || { count: 0 }).count;
- data.replies = (data.data.filter((x: any) => x.type == 'reply')[0] || { count: 0 }).count;
-
- delete data.data;
- });
-
- const graph = [];
-
- for (let i = 0; i < 30; 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, // In JavaScript, month is zero-based.
- day: day.getDate()
- },
- notes: 0,
- renotes: 0,
- replies: 0
- });
- }
- }
-
- res(graph);
-});
diff --git a/src/server/api/endpoints/aggregation/users/reaction.ts b/src/server/api/endpoints/aggregation/users/reaction.ts
deleted file mode 100644
index ce9e150966..0000000000
--- a/src/server/api/endpoints/aggregation/users/reaction.ts
+++ /dev/null
@@ -1,74 +0,0 @@
-import $ from 'cafy'; import ID from '../../../../../misc/cafy-id';
-import User from '../../../../../models/user';
-import Reaction from '../../../../../models/note-reaction';
-
-/**
- * Aggregate reaction of a user
- */
-export default (params: any) => new Promise(async (res, rej) => {
- // Get 'userId' parameter
- const [userId, userIdErr] = $.type(ID).get(params.userId);
- if (userIdErr) return rej('invalid userId param');
-
- // Lookup user
- const user = await User.findOne({
- _id: userId
- }, {
- fields: {
- _id: true
- }
- });
-
- if (user === null) {
- return rej('user not found');
- }
-
- const datas = await Reaction
- .aggregate([
- { $match: { userId: user._id } },
- { $project: {
- createdAt: { $add: ['$createdAt', 9 * 60 * 60 * 1000] } // Convert into JST
- }},
- { $project: {
- date: {
- year: { $year: '$createdAt' },
- month: { $month: '$createdAt' },
- day: { $dayOfMonth: '$createdAt' }
- }
- }},
- { $group: {
- _id: '$date',
- count: { $sum: 1 }
- }}
- ]);
-
- datas.forEach((data: any) => {
- data.date = data._id;
- delete data._id;
- });
-
- const graph = [];
-
- for (let i = 0; i < 30; 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, // In JavaScript, month is zero-based.
- day: day.getDate()
- },
- count: 0
- });
- }
- }
-
- res(graph);
-});