heartles/egirlskey
1
0
Fork 0
Code Issues 1 Pull requests Projects Releases Packages Wiki Activity

Compare commits

base: heartles:bef78535c940a2e9ed2d9f7dfac39fc4a956c9e4
Branches Tags
heartles:main
heartles:egirls-sharkey
..
compare: heartles:d60344dfac20d65c0868735dba72e136a235ab96
Branches Tags
heartles:main
heartles:egirls-sharkey

2 commits
bef78535c9 ... d60344dfac

Author SHA1 Message Date
jaina heartles
d60344dfac Add AutoDeleteNotesProcessorService 2024-03-17 21:35:49 -07:00
jaina heartles
fc1727870c Add noteAutoDelete form to privacy page 2024-03-17 21:35:49 -07:00
3 changed files with 25 additions and 22 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -72,7 +72,7 @@ export class QueueService {
this.systemQueue.add('autoDeleteNotes', {
}, {
repeat: { pattern: '*/1 * * * *' },
repeat: { pattern: '*/5 * * * *' },
removeOnComplete: true,
});
}

19
packages/backend/src/queue/processors/AutoDeleteNotesProcessorService.ts
View file

@ -37,35 +37,38 @@ export class AutoDeleteNotesProcessorService {
public async process(): Promise<void> {
this.logger.info('Auto deleting old notes...');
const users = await this.userProfilesRepository.createQueryBuilder('user_profile')
const userProfiles = await this.userProfilesRepository.createQueryBuilder('user_profile')
.innerJoinAndSelect('user_profile.user', 'user')
.where('user.host IS NULL')
.andWhere('user_profile.autoDeleteNotes')
.getMany();
for (const user of users) {
this.logger.info(`Deleting old notes of user @${user.user.username} (id ${user.user.id})`);
const untilTime = Date.now() - (user.autoDeleteNotesMinutes * 1000 * 60);
for (const userProfile of userProfiles) {
const user = userProfile.user;
this.logger.debug(`Deleting old notes of user @${user.username} (id ${user.id})`);
const untilTime = Date.now() - (userProfile.autoDeleteNotesMinutes * 1000 * 60);
const untilId = this.idService.gen(untilTime);
const pins = await this.userNotePiningsRepository.createQueryBuilder('user_note_pining')
.where('"userId" = :userId', { userId: user.user.id })
.where('"userId" = :userId', { userId: user.id })
.getMany();
const pinnedNoteIds = pins.map((p) => p.noteId);
const notes = await this.notesRepository.createQueryBuilder('note')
.where('note."userId" = :userId', { userId: user.user.id })
.where('note."userId" = :userId', { userId: user.id })
.andWhere('note.id < :untilId', { untilId })
.andWhere('note.id NOT IN (SELECT "noteId" FROM note_favorite WHERE "userId" = :userId)');
.andWhere('note.id NOT IN (SELECT "noteId" FROM note_favorite WHERE "userId" = :userId)')
.getMany();
for (const note of notes) {
if (pinnedNoteIds.includes(note.id)) {
this.logger.debug(`Skipping note ${note.id} as it is pinned`);
continue;
}
await this.noteDeleteService.delete(user, note);
this.logger.debug(`Deleting note ${note.id}`);
await this.noteDeleteService.delete(user, note, false, user);
}
}