update delete access token logic

This commit is contained in:
Maidul Islam
2024-05-24 12:43:14 -04:00
parent 76c9d642a9
commit 1753cd76be
2 changed files with 6 additions and 3 deletions
@@ -48,7 +48,7 @@ export const identityAccessTokenDALFactory = (db: TDbClient) => {
.where("accessTokenNumUsesLimit", ">", 0) .where("accessTokenNumUsesLimit", ">", 0)
.andWhere( .andWhere(
"accessTokenNumUses", "accessTokenNumUses",
">", ">=",
db.ref("accessTokenNumUsesLimit").withSchema(TableName.IdentityAccessToken) db.ref("accessTokenNumUsesLimit").withSchema(TableName.IdentityAccessToken)
); );
}) })
@@ -76,7 +76,7 @@ export const identityAccessTokenDALFactory = (db: TDbClient) => {
.delete(); .delete();
return await docs; return await docs;
} catch (error) { } catch (error) {
throw new DatabaseError({ error, name: "IdentityAccesTokenPrune" }); throw new DatabaseError({ error, name: "IdentityAccessTokenPrune" });
} }
}; };
@@ -44,7 +44,10 @@ export const dailyResourceCleanUpQueueServiceFactory = ({
await queueService.queue(QueueName.DailyResourceCleanUp, QueueJobs.DailyResourceCleanUp, undefined, { await queueService.queue(QueueName.DailyResourceCleanUp, QueueJobs.DailyResourceCleanUp, undefined, {
delay: 5000, delay: 5000,
jobId: QueueName.DailyResourceCleanUp, jobId: QueueName.DailyResourceCleanUp,
repeat: { pattern: "0 0 * * *", utc: true } repeat: {
every: 10000
// limit: 100,
}
}); });
}; };