graphite/Sharkey
1
0
Fork 0
mirror of https://git.joinsharkey.org/Sharkey/Sharkey.git synced 2024-11-27 11:43:09 +02:00
Code Issues Projects Releases Packages Wiki Activity

Some bug fixes and clean ups

Browse source
This commit is contained in:
syuilo 2018-04-08 04:02:12 +09:00
parent a02ee3a08b
commit cebea4e94c
8 changed files with 3 additions and 302 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

76
src/server/api/endpoints/aggregation/notes/reaction.ts
View file

@ -1,76 +0,0 @@
/**
* Module dependencies
*/
import $ from 'cafy';
import Note from '../../../../../models/note';
import Reaction from '../../../../../models/note-reaction';
/**
* Aggregate reaction of a note
*
* @param {any} params
* @return {Promise<any>}
*/
module.exports = (params) => new Promise(async (res, rej) => {
// Get 'noteId' parameter
const [noteId, noteIdErr] = $(params.noteId).id().$;
if (noteIdErr) return rej('invalid noteId param');
// Lookup note
const note = await Note.findOne({
_id: noteId
});
if (note === null) {
return rej('note not found');
}
const datas = await Reaction
.aggregate([
{ $match: { noteId: note._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 => {
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 =>
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);
});

72
src/server/api/endpoints/aggregation/notes/reactions.ts
View file

@ -1,72 +0,0 @@
/**
* Module dependencies
*/
import $ from 'cafy';
import Note from '../../../../../models/note';
import Reaction from '../../../../../models/note-reaction';
/**
* Aggregate reactions of a note
*
* @param {any} params
* @return {Promise<any>}
*/
module.exports = (params) => new Promise(async (res, rej) => {
// Get 'noteId' parameter
const [noteId, noteIdErr] = $(params.noteId).id().$;
if (noteIdErr) return rej('invalid noteId param');
// Lookup note
const note = await Note.findOne({
_id: noteId
});
if (note === null) {
return rej('note not found');
}
const startTime = new Date(new Date().setMonth(new Date().getMonth() - 1));
const reactions = await Reaction
.find({
noteId: note._id,
$or: [
{ deletedAt: { $exists: false } },
{ deletedAt: { $gt: startTime } }
]
}, {
sort: {
_id: -1
},
fields: {
_id: false,
noteId: false
}
});
const graph = [];
for (let i = 0; i < 30; i++) {
let day = new Date(new Date().setDate(new Date().getDate() - i));
day = new Date(day.setMilliseconds(999));
day = new Date(day.setSeconds(59));
day = new Date(day.setMinutes(59));
day = new Date(day.setHours(23));
// day = day.getTime();
const count = reactions.filter(r =>
r.createdAt < day && (r.deletedAt == null || r.deletedAt > day)
).length;
graph.push({
date: {
year: day.getFullYear(),
month: day.getMonth() + 1, // In JavaScript, month is zero-based.
day: day.getDate()
},
count: count
});
}
res(graph);
});

75
src/server/api/endpoints/aggregation/notes/reply.ts
View file

@ -1,75 +0,0 @@
/**
* Module dependencies
*/
import $ from 'cafy';
import Note from '../../../../../models/note';
/**
* Aggregate reply of a note
*
* @param {any} params
* @return {Promise<any>}
*/
module.exports = (params) => new Promise(async (res, rej) => {
// Get 'noteId' parameter
const [noteId, noteIdErr] = $(params.noteId).id().$;
if (noteIdErr) return rej('invalid noteId param');
// Lookup note
const note = await Note.findOne({
_id: noteId
});
if (note === null) {
return rej('note not found');
}
const datas = await Note
.aggregate([
{ $match: { reply: note._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 => {
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 =>
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);
});

75
src/server/api/endpoints/aggregation/notes/repost.ts
View file

@ -1,75 +0,0 @@
/**
* Module dependencies
*/
import $ from 'cafy';
import Note from '../../../../../models/note';
/**
* Aggregate renote of a note
*
* @param {any} params
* @return {Promise<any>}
*/
module.exports = (params) => new Promise(async (res, rej) => {
// Get 'noteId' parameter
const [noteId, noteIdErr] = $(params.noteId).id().$;
if (noteIdErr) return rej('invalid noteId param');
// Lookup note
const note = await Note.findOne({
_id: noteId
});
if (note === null) {
return rej('note not found');
}
const datas = await Note
.aggregate([
{ $match: { renoteId: note._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 => {
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 =>
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);
});

2
src/server/api/endpoints/drive/files/create.ts
View file

@ -3,7 +3,7 @@
*/
import $ from 'cafy';
import { validateFileName, pack } from '../../../../../models/drive-file';
import create from '../../../../../drive/add-file';
import create from '../../../../../services/drive/add-file';
/**
* Create a file

2
src/server/api/endpoints/drive/files/upload_from_url.ts
View file

@ -3,7 +3,7 @@
*/
import $ from 'cafy';
import { pack } from '../../../../../models/drive-file';
import uploadFromUrl from '../../../../../drive/upload-from-url';
import uploadFromUrl from '../../../../../services/drive/upload-from-url';
/**
* Create a file from a URL

2
src/server/api/endpoints/notes/polls/vote.ts
View file

@ -5,7 +5,7 @@ import $ from 'cafy';
import Vote from '../../../../../models/poll-vote';
import Note from '../../../../../models/note';
import Watching from '../../../../../models/note-watching';
import watch from '../../../../../note/watch';
import watch from '../../../../../services/note/watch';
import { publishNoteStream } from '../../../../../publishers/stream';
import notify from '../../../../../publishers/notify';

1
src/server/api/endpoints/notes/reactions/create.ts
View file

@ -2,7 +2,6 @@
* Module dependencies
*/
import $ from 'cafy';
import Reaction from '../../../../../models/note-reaction';
import Note from '../../../../../models/note';
import create from '../../../../../services/note/reaction/create';