misty.cafe/mistykey
1
0
Fork 0
Code Issues Pull requests 1 Projects Releases Packages Wiki Activity Actions

remove check-hibernation task, as it's been obsoleted by HibernateUsersProcessorService

Browse source
This commit is contained in:
Hazelnoot 2025-11-13 20:08:49 -05:00
parent 152714ca03
commit be517b5fdc
3 changed files with 0 additions and 21 deletions
Download patch file Download diff file Expand all files Collapse all files

10
packages/backend/src/core/QueueService.ts
View file

@ -877,16 +877,6 @@ export class QueueService implements OnModuleInit {
return await this.createBackgroundTask({ type: 'post-note', noteId, silent, edit }, duplication); return await this.createBackgroundTask({ type: 'post-note', noteId, silent, edit }, duplication);
} }
@bindThis
public async createCheckHibernationJob(userId: string) {
return await this.createBackgroundTask(
{ type: 'check-hibernation', userId },
// This is a very heavy task, so only run once per day per user
{ id: `check-hibernation:${userId}`, ttl: 1000 * 60 * 60 * 24 },
);
}
@bindThis @bindThis
public async createUpdateUserTagsJob(userId: string) { public async createUpdateUserTagsJob(userId: string) {
return await this.createBackgroundTask({ type: 'update-user-tags', userId }, userId); return await this.createBackgroundTask({ type: 'update-user-tags', userId }, userId);

10
packages/backend/src/queue/processors/BackgroundTaskProcessorService.ts
View file

@ -91,8 +91,6 @@ export class BackgroundTaskProcessorService {
return await this.processPostInbox(job.data); return await this.processPostInbox(job.data);
} else if (job.data.type === 'post-note') { } else if (job.data.type === 'post-note') {
return await this.processPostNote(job.data); return await this.processPostNote(job.data);
} else if (job.data.type === 'check-hibernation') {
return await this.processCheckHibernation(job.data);
} else if (job.data.type === 'delete-file') { } else if (job.data.type === 'delete-file') {
return await this.processDeleteFile(job.data); return await this.processDeleteFile(job.data);
} else if (job.data.type === 'update-latest-note') { } else if (job.data.type === 'update-latest-note') {
@ -272,14 +270,6 @@ export class BackgroundTaskProcessorService {
return 'ok'; return 'ok';
} }
private async processCheckHibernation(task: CheckHibernationBackgroundTask): Promise<string> {
const followers = await this.cacheService.getNonHibernatedFollowers(task.userId);
if (followers.length < 1) return `Skipping check-hibernation task: user ${task.userId} has no non-hibernated followers`;
await this.noteCreateService.checkHibernation(followers);
return 'ok';
}
private async processDeleteFile(task: DeleteFileBackgroundTask): Promise<string> { private async processDeleteFile(task: DeleteFileBackgroundTask): Promise<string> {
const file = await this.driveFilesRepository.findOneBy({ id: task.fileId }); const file = await this.driveFilesRepository.findOneBy({ id: task.fileId });
if (!file) return `Skipping delete-file task: file ${task.fileId} has been deleted`; if (!file) return `Skipping delete-file task: file ${task.fileId} has been deleted`;

1
packages/backend/src/queue/types.ts
View file

@ -179,7 +179,6 @@ export type BackgroundTaskJobData =
PostDeliverBackgroundTask | PostDeliverBackgroundTask |
PostInboxBackgroundTask | PostInboxBackgroundTask |
PostNoteBackgroundTask | PostNoteBackgroundTask |
CheckHibernationBackgroundTask |
DeleteFileBackgroundTask | DeleteFileBackgroundTask |
UpdateLatestNoteBackgroundTask | UpdateLatestNoteBackgroundTask |
PostSuspendBackgroundTask | PostSuspendBackgroundTask |