mirror of
https://github.com/stonith404/pingvin-share.git
synced 2025-01-15 01:14:27 -05:00
fix: delete unfinished shares after a day
This commit is contained in:
parent
8ae631a626
commit
d327bc355c
1 changed files with 23 additions and 1 deletions
|
@ -61,6 +61,28 @@ export class JobsService {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Cron("0 */6 * * *")
|
||||||
|
async deleteUnfinishedShares() {
|
||||||
|
const unfinishedShares = await this.prisma.share.findMany({
|
||||||
|
where: {
|
||||||
|
createdAt: { lt: moment().subtract(1, "day").toDate() },
|
||||||
|
uploadLocked: false,
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
|
for (const unfinishedShare of unfinishedShares) {
|
||||||
|
await this.prisma.share.delete({
|
||||||
|
where: { id: unfinishedShare.id },
|
||||||
|
});
|
||||||
|
|
||||||
|
await this.fileService.deleteAllFiles(unfinishedShare.id);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (unfinishedShares.length > 0) {
|
||||||
|
this.logger.log(`Deleted ${unfinishedShares.length} unfinished shares`);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
@Cron("0 0 * * *")
|
@Cron("0 0 * * *")
|
||||||
deleteTemporaryFiles() {
|
deleteTemporaryFiles() {
|
||||||
let filesDeleted = 0;
|
let filesDeleted = 0;
|
||||||
|
@ -93,7 +115,7 @@ export class JobsService {
|
||||||
this.logger.log(`Deleted ${filesDeleted} temporary files`);
|
this.logger.log(`Deleted ${filesDeleted} temporary files`);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Cron("0 * * * *")
|
@Cron("1 * * * *")
|
||||||
async deleteExpiredTokens() {
|
async deleteExpiredTokens() {
|
||||||
const { count: refreshTokenCount } =
|
const { count: refreshTokenCount } =
|
||||||
await this.prisma.refreshToken.deleteMany({
|
await this.prisma.refreshToken.deleteMany({
|
||||||
|
|
Loading…
Add table
Reference in a new issue