mirrors/barkey
1
0
Fork 0
mirror of https://codeberg.org/yeentown/barkey.git synced 2025-11-04 07:24:13 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix type errors

Browse source
This commit is contained in:
syuilo 2022-09-24 14:45:44 +09:00
parent aa3ca438a2
commit dabe5bf7e9
4 changed files with 24 additions and 42 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
packages/backend/src/misc/check-word-mute.ts
View file

@ -5,7 +5,7 @@ import type { User } from '@/models/entities/User.js';
type NoteLike = { type NoteLike = {
userId: Note['userId']; userId: Note['userId'];
text: Note['text']; text: Note['text'];
cw: Note['cw']; cw?: Note['cw'];
}; };
type UserLike = { type UserLike = {

34
packages/backend/src/queue/DbQueueProcessorsService.ts
View file

@ -39,25 +39,19 @@ export class DbQueueProcessorsService {
) { ) {
} }
public start(dbQueue: Bull.Queue<DbJobData>) { public start(q: Bull.Queue): void {
const jobs = { q.process('deleteDriveFiles', (job, done) => this.deleteDriveFilesProcessorService.process(job, done));
deleteDriveFiles: (job, done) => this.deleteDriveFilesProcessorService.process(job, done), q.process('exportCustomEmojis', (job, done) => this.exportCustomEmojisProcessorService.process(job, done));
exportCustomEmojis: (job, done) => this.exportCustomEmojisProcessorService.process(job, done), q.process('exportNotes', (job, done) => this.exportNotesProcessorService.process(job, done));
exportNotes: (job, done) => this.exportNotesProcessorService.process(job, done), q.process('exportFollowing', (job, done) => this.exportFollowingProcessorService.process(job, done));
exportFollowing: (job, done) => this.exportFollowingProcessorService.process(job, done), q.process('exportMuting', (job, done) => this.exportMutingProcessorService.process(job, done));
exportMuting: (job, done) => this.exportMutingProcessorService.process(job, done), q.process('exportBlocking', (job, done) => this.exportBlockingProcessorService.process(job, done));
exportBlocking: (job, done) => this.exportBlockingProcessorService.process(job, done), q.process('exportUserLists', (job, done) => this.exportUserListsProcessorService.process(job, done));
exportUserLists: (job, done) => this.exportUserListsProcessorService.process(job, done), q.process('importFollowing', (job, done) => this.importFollowingProcessorService.process(job, done));
importFollowing: (job, done) => this.importFollowingProcessorService.process(job, done), q.process('importMuting', (job, done) => this.importMutingProcessorService.process(job, done));
importMuting: (job, done) => this.importMutingProcessorService.process(job, done), q.process('importBlocking', (job, done) => this.importBlockingProcessorService.process(job, done));
importBlocking: (job, done) => this.importBlockingProcessorService.process(job, done), q.process('importUserLists', (job, done) => this.importUserListsProcessorService.process(job, done));
importUserLists: (job, done) => this.importUserListsProcessorService.process(job, done), q.process('importCustomEmojis', (job, done) => this.importCustomEmojisProcessorService.process(job, done));
importCustomEmojis: (job, done) => this.importCustomEmojisProcessorService.process(job, done), q.process('deleteAccount', (job) => this.deleteAccountProcessorService.process(job));
deleteAccount: (job) => this.deleteAccountProcessorService.process(job),
} as Record<string, Bull.ProcessCallbackFunction<DbJobData | Bull.ProcessPromiseFunction<DbJobData>>>;
for (const [k, v] of Object.entries(jobs)) {
dbQueue.process(k, v);
}
} }
} }

12
packages/backend/src/queue/ObjectStorageQueueProcessorsService.ts
View file

@ -17,14 +17,8 @@ export class ObjectStorageQueueProcessorsService {
) { ) {
} }
public start(q: Bull.Queue) { public start(q: Bull.Queue): void {
const jobs = { q.process('deleteFile', 16, (job) => this.deleteFileProcessorService.process(job));
deleteFile: (job) => this.deleteFileProcessorService.process(job), q.process('cleanRemoteFiles', 16, (job, done) => this.cleanRemoteFilesProcessorService.process(job, done));
cleanRemoteFiles: (job, done) => this.cleanRemoteFilesProcessorService.process(job, done),
} as Record<string, Bull.ProcessCallbackFunction<ObjectStorageJobData | Bull.ProcessPromiseFunction<ObjectStorageJobData>>>;
for (const [k, v] of Object.entries(jobs)) {
q.process(k, 16, v);
}
} }
} }

18
packages/backend/src/queue/SystemQueueProcessorsService.ts
View file

@ -22,17 +22,11 @@ export class SystemQueueProcessorsService {
) { ) {
} }
public start(dbQueue: Bull.Queue<Record<string, unknown>>) { public start(q: Bull.Queue): void {
const jobs = { q.process('tickCharts', (job, done) => this.tickChartsProcessorService.process(job, done));
tickCharts: (job, done) => this.tickChartsProcessorService.process(job, done), q.process('resyncCharts', (job, done) => this.resyncChartsProcessorService.process(job, done));
resyncCharts: (job, done) => this.resyncChartsProcessorService.process(job, done), q.process('cleanCharts', (job, done) => this.cleanChartsProcessorService.process(job, done));
cleanCharts: (job, done) => this.cleanChartsProcessorService.process(job, done), q.process('checkExpiredMutings', (job, done) => this.checkExpiredMutingsProcessorService.process(job, done));
checkExpiredMutings: (job, done) => this.checkExpiredMutingsProcessorService.process(job, done), q.process('clean', (job, done) => this.cleanProcessorService.process(job, done));
clean: (job, done) => this.cleanProcessorService.process(job, done),
} as Record<string, Bull.ProcessCallbackFunction<Record<string, unknown>> | Bull.ProcessPromiseFunction<Record<string, unknown>>>;
for (const [k, v] of Object.entries(jobs)) {
dbQueue.process(k, v);
}
} }
} }