amechama/sharkey
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor

Browse Source
This commit is contained in:
syuilo 2021-11-12 15:08:36 +09:00
parent 4786214e2a
commit b404ce463f
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
packages/backend/src/queue/processors/db/export-notes.ts
View File

@ -46,18 +46,18 @@ export async function exportNotes(job: Bull.Job<DbUserJobData>, done: any): Prom
}); });
let exportedNotesCount = 0; let exportedNotesCount = 0;
let cursor: any = null; let cursor: Note['id'] | null = null;
while (true) { while (true) {
const notes = await Notes.find({ const notes = await Notes.find({
where: { where: {
userId: user.id, userId: user.id,
...(cursor ? { id: MoreThan(cursor) } : {}) ...(cursor ? { id: MoreThan(cursor) } : {}),
}, },
take: 100, take: 100,
order: { order: {
id: 1 id: 1,
} },
}); });
if (notes.length === 0) { if (notes.length === 0) {
@ -115,7 +115,7 @@ export async function exportNotes(job: Bull.Job<DbUserJobData>, done: any): Prom
done(); done();
} }
function serialize(note: Note, poll: Poll | null = null): any { function serialize(note: Note, poll: Poll | null = null): Record<string, unknown> {
return { return {
id: note.id, id: note.id,
text: note.text, text: note.text,
@ -128,6 +128,6 @@ function serialize(note: Note, poll: Poll | null = null): any {
viaMobile: note.viaMobile, viaMobile: note.viaMobile,
visibility: note.visibility, visibility: note.visibility,
visibleUserIds: note.visibleUserIds, visibleUserIds: note.visibleUserIds,
localOnly: note.localOnly localOnly: note.localOnly,
}; };
} }