mirror of
https://github.com/ahmadk953/poixpixel-discord-bot.git
synced 2025-07-04 03:16:00 +00:00
chore(bot): update caching logic
This commit is contained in:
parent
20f50536b6
commit
4b7c6dda07
1 changed files with 7 additions and 15 deletions
|
@ -112,22 +112,17 @@ export async function updateAchievementProgress(
|
||||||
await db
|
await db
|
||||||
.update(schema.userAchievementsTable)
|
.update(schema.userAchievementsTable)
|
||||||
.set({ progress, earnedAt: progress === 100 ? new Date() : null })
|
.set({ progress, earnedAt: progress === 100 ? new Date() : null })
|
||||||
.where(eq(schema.userAchievementsTable.id, existing.id))
|
.where(eq(schema.userAchievementsTable.id, existing.id));
|
||||||
.returning();
|
|
||||||
} else {
|
} else {
|
||||||
await db
|
await db.insert(schema.userAchievementsTable).values({
|
||||||
.insert(schema.userAchievementsTable)
|
discordId: userId,
|
||||||
.values({
|
achievementId,
|
||||||
discordId: userId,
|
progress,
|
||||||
achievementId,
|
earnedAt: progress === 100 ? new Date() : null,
|
||||||
progress,
|
});
|
||||||
earnedAt: progress === 100 ? new Date() : null,
|
|
||||||
})
|
|
||||||
.returning();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
await invalidateCache(`userAchievements:${userId}`);
|
await invalidateCache(`userAchievements:${userId}`);
|
||||||
await getUserAchievements(userId);
|
|
||||||
|
|
||||||
return true;
|
return true;
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
|
@ -173,7 +168,6 @@ export async function createAchievement(achievementData: {
|
||||||
.returning();
|
.returning();
|
||||||
|
|
||||||
await invalidateCache('achievementDefinitions');
|
await invalidateCache('achievementDefinitions');
|
||||||
await getAllAchievements();
|
|
||||||
|
|
||||||
return achievement;
|
return achievement;
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
|
@ -205,7 +199,6 @@ export async function deleteAchievement(
|
||||||
.where(eq(schema.achievementDefinitionsTable.id, achievementId));
|
.where(eq(schema.achievementDefinitionsTable.id, achievementId));
|
||||||
|
|
||||||
await invalidateCache('achievementDefinitions');
|
await invalidateCache('achievementDefinitions');
|
||||||
await getAllAchievements();
|
|
||||||
|
|
||||||
return true;
|
return true;
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
|
@ -241,7 +234,6 @@ export async function removeUserAchievement(
|
||||||
);
|
);
|
||||||
|
|
||||||
await invalidateCache(`userAchievements:${discordId}`);
|
await invalidateCache(`userAchievements:${discordId}`);
|
||||||
await getUserAchievements(discordId);
|
|
||||||
|
|
||||||
return true;
|
return true;
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue