diff options
Diffstat (limited to 'src/queue/index.ts')
| -rw-r--r-- | src/queue/index.ts | 17 |
1 files changed, 4 insertions, 13 deletions
diff --git a/src/queue/index.ts b/src/queue/index.ts index d8328a1d57..728c43c6ac 100644 --- a/src/queue/index.ts +++ b/src/queue/index.ts @@ -2,14 +2,14 @@ import * as Queue from 'bull'; import * as httpSignature from 'http-signature'; import config from '../config'; -import { ILocalUser } from '../models/user'; +import { ILocalUser } from '../models/entities/user'; import { program } from '../argv'; import processDeliver from './processors/deliver'; import processInbox from './processors/inbox'; import processDb from './processors/db'; import { queueLogger } from './logger'; -import { IDriveFile } from '../models/drive-file'; +import { DriveFile } from '../models/entities/drive-file'; function initializeQueue(name: string) { return new Queue(name, config.redis != null ? { @@ -83,15 +83,6 @@ export function inbox(activity: any, signature: httpSignature.IParsedSignature) }); } -export function createDeleteNotesJob(user: ILocalUser) { - return dbQueue.add('deleteNotes', { - user: user - }, { - removeOnComplete: true, - removeOnFail: true - }); -} - export function createDeleteDriveFilesJob(user: ILocalUser) { return dbQueue.add('deleteDriveFiles', { user: user @@ -146,7 +137,7 @@ export function createExportUserListsJob(user: ILocalUser) { }); } -export function createImportFollowingJob(user: ILocalUser, fileId: IDriveFile['_id']) { +export function createImportFollowingJob(user: ILocalUser, fileId: DriveFile['id']) { return dbQueue.add('importFollowing', { user: user, fileId: fileId @@ -156,7 +147,7 @@ export function createImportFollowingJob(user: ILocalUser, fileId: IDriveFile['_ }); } -export function createImportUserListsJob(user: ILocalUser, fileId: IDriveFile['_id']) { +export function createImportUserListsJob(user: ILocalUser, fileId: DriveFile['id']) { return dbQueue.add('importUserLists', { user: user, fileId: fileId |