Infrastructure/zipline
1
Fork 0
mirror of https://github.com/diced/zipline.git synced 2025-03-28 23:11:22 -05:00
Code Issues Activity

fix: delete invites that expired or are used

Browse source
This commit is contained in:
diced 2022-11-19 17:16:46 -08:00
parent 8d510f5d90
commit 24f8300b2c
No known key found for this signature in database
GPG key ID: 370BD1BA142842D1
1 changed files with 20 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

40
src/server/index.ts
View file

@ -190,16 +190,10 @@ async function start() {
logger.info(`started ${dev ? 'development' : 'production'} zipline@${version} server`);
stats(prisma);
clearInvites(prisma);
setInterval(async () => {
const { count } = await prisma.invite.deleteMany({
where: {
used: true,
},
});
logger.debug(`deleted ${count} used invites`);
}, config.core.invites_interval * 1000);
setInterval(() => clearInvites(prisma), config.core.invites_interval * 1000);
setInterval(() => stats(prisma), config.core.stats_interval * 1000);
}
async function preFile(file: Image, prisma: PrismaClient) {
@ -277,15 +271,21 @@ async function stats(prisma: PrismaClient) {
});
logger.debug(`stats updated ${JSON.stringify(stats)}`);
setInterval(async () => {
const stats = await getStats(prisma, datasource);
await prisma.stats.create({
data: {
data: stats,
},
});
logger.debug(`stats updated ${JSON.stringify(stats)}`);
}, config.core.stats_interval * 1000);
}
async function clearInvites(prisma: PrismaClient) {
const { count } = await prisma.invite.deleteMany({
where: {
OR: [
{
expires_at: { lt: new Date() },
},
{
used: true,
},
],
},
});
logger.debug(`deleted ${count} used invites`);
}