diff options
Diffstat (limited to 'src/queue/processors/db/export-blocking.ts')
| -rw-r--r-- | src/queue/processors/db/export-blocking.ts | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/queue/processors/db/export-blocking.ts b/src/queue/processors/db/export-blocking.ts index 9bbc9b2f12..001b50a22c 100644 --- a/src/queue/processors/db/export-blocking.ts +++ b/src/queue/processors/db/export-blocking.ts @@ -8,10 +8,11 @@ import dateFormat = require('dateformat'); import { getFullApAccount } from '@/misc/convert-host'; import { Users, Blockings } from '../../../models'; import { MoreThan } from 'typeorm'; +import { DbUserJobData } from '@/queue/types'; const logger = queueLogger.createSubLogger('export-blocking'); -export async function exportBlocking(job: Bull.Job, done: any): Promise<void> { +export async function exportBlocking(job: Bull.Job<DbUserJobData>, done: any): Promise<void> { logger.info(`Exporting blocking of ${job.data.user.id} ...`); const user = await Users.findOne(job.data.user.id); @@ -61,7 +62,7 @@ export async function exportBlocking(job: Bull.Job, done: any): Promise<void> { } const content = getFullApAccount(u.username, u.host); - await new Promise((res, rej) => { + await new Promise<void>((res, rej) => { stream.write(content + '\n', err => { if (err) { logger.error(err); |