diff options
| author | syuilo <Syuilotan@yahoo.co.jp> | 2021-05-11 14:39:40 +0900 |
|---|---|---|
| committer | syuilo <Syuilotan@yahoo.co.jp> | 2021-05-11 14:39:40 +0900 |
| commit | f96c60c1a0374aabeecbe82c15d7e3373efed8eb (patch) | |
| tree | 59b136dff0287f74166b385d6de811d83b1f455a /src/queue/processors/db/export-notes.ts | |
| parent | Merge branch 'develop' (diff) | |
| parent | 12.81.0 (diff) | |
| download | misskey-f96c60c1a0374aabeecbe82c15d7e3373efed8eb.tar.gz misskey-f96c60c1a0374aabeecbe82c15d7e3373efed8eb.tar.bz2 misskey-f96c60c1a0374aabeecbe82c15d7e3373efed8eb.zip | |
Merge branch 'develop'
Diffstat (limited to 'src/queue/processors/db/export-notes.ts')
| -rw-r--r-- | src/queue/processors/db/export-notes.ts | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/queue/processors/db/export-notes.ts b/src/queue/processors/db/export-notes.ts index f76a47aacd..2d09c0d201 100644 --- a/src/queue/processors/db/export-notes.ts +++ b/src/queue/processors/db/export-notes.ts @@ -9,10 +9,11 @@ import { Users, Notes, Polls } from '../../../models'; import { MoreThan } from 'typeorm'; import { Note } from '../../../models/entities/note'; import { Poll } from '../../../models/entities/poll'; +import { DbUserJobData } from '@/queue/types'; const logger = queueLogger.createSubLogger('export-notes'); -export async function exportNotes(job: Bull.Job, done: any): Promise<void> { +export async function exportNotes(job: Bull.Job<DbUserJobData>, done: any): Promise<void> { logger.info(`Exporting notes of ${job.data.user.id} ...`); const user = await Users.findOne(job.data.user.id); @@ -33,7 +34,7 @@ export async function exportNotes(job: Bull.Job, done: any): Promise<void> { const stream = fs.createWriteStream(path, { flags: 'a' }); - await new Promise((res, rej) => { + await new Promise<void>((res, rej) => { stream.write('[', err => { if (err) { logger.error(err); @@ -72,7 +73,7 @@ export async function exportNotes(job: Bull.Job, done: any): Promise<void> { poll = await Polls.findOneOrFail({ noteId: note.id }); } const content = JSON.stringify(serialize(note, poll)); - await new Promise((res, rej) => { + await new Promise<void>((res, rej) => { stream.write(exportedNotesCount === 0 ? content : ',\n' + content, err => { if (err) { logger.error(err); @@ -92,7 +93,7 @@ export async function exportNotes(job: Bull.Job, done: any): Promise<void> { job.progress(exportedNotesCount / total); } - await new Promise((res, rej) => { + await new Promise<void>((res, rej) => { stream.write(']', err => { if (err) { logger.error(err); |