make new "cache" for recentlyqueued

2 files changed, 23 insertions, 4 deletions

diff --git a/build/database.js b/build/database.js
index 381be7c..e0c8924 100644
--- a/build/database.js
+++ b/build/database.js
@@ -42,6 +42,12 @@ const recentlyUpdated = new node_cache_1.default({
     checkperiod: 60,
     useClones: false,
 });
+// don't add stuff to the queue within the same 5 minutes
+const recentlyQueued = new node_cache_1.default({
+    stdTTL: 60 * 5,
+    checkperiod: 60,
+    useClones: false,
+});
 exports.cachedRawLeaderboards = new Map();
 const leaderboardMax = 100;
 const reversedLeaderboards = [
@@ -512,15 +518,19 @@ exports.leaderboardUpdateProfileQueue = new queue_promise_1.default({
 });
 /** Queue an update for the member's leaderboard data on the server if applicable */
 function queueUpdateDatabaseMember(member, profile) {
-    if (recentlyUpdated.get(profile.uuid + member.uuid))
+    if (recentlyQueued.get(profile.uuid + member.uuid))
         return;
+    else
+        recentlyQueued.set(profile.uuid + member.uuid, true);
     exports.leaderboardUpdateMemberQueue.enqueue(async () => await updateDatabaseMember(member, profile));
 }
 exports.queueUpdateDatabaseMember = queueUpdateDatabaseMember;
 /** Queue an update for the profile's leaderboard data on the server if applicable */
 function queueUpdateDatabaseProfile(profile) {
-    if (recentlyUpdated.get(profile.uuid + 'profile'))
+    if (recentlyQueued.get(profile.uuid + 'profile'))
         return;
+    else
+        recentlyQueued.set(profile.uuid + 'profile', true);
     exports.leaderboardUpdateProfileQueue.enqueue(async () => await updateDatabaseProfile(profile));
 }
 exports.queueUpdateDatabaseProfile = queueUpdateDatabaseProfile;
diff --git a/src/database.ts b/src/database.ts
index 2c0a715..47cddbd 100644
--- a/src/database.ts
+++ b/src/database.ts
@@ -24,6 +24,13 @@ const recentlyUpdated = new NodeCache({
 	useClones: false,
 })
 
+// don't add stuff to the queue within the same 5 minutes
+const recentlyQueued = new NodeCache({
+	stdTTL: 60 * 5,
+	checkperiod: 60,
+	useClones: false,
+})
+
 interface DatabaseMemberLeaderboardItem {
 	uuid: string
 	profile: string
@@ -661,13 +668,15 @@ export const leaderboardUpdateProfileQueue = new Queue({
 
 /** Queue an update for the member's leaderboard data on the server if applicable */
 export function queueUpdateDatabaseMember(member: CleanMember, profile: CleanFullProfile): void {
-	if (recentlyUpdated.get(profile.uuid + member.uuid)) return
+	if (recentlyQueued.get(profile.uuid + member.uuid)) return
+	else recentlyQueued.set(profile.uuid + member.uuid, true)
 	leaderboardUpdateMemberQueue.enqueue(async() => await updateDatabaseMember(member, profile))
 }
 
 /** Queue an update for the profile's leaderboard data on the server if applicable */
 export function queueUpdateDatabaseProfile(profile: CleanFullProfile): void {
-	if (recentlyUpdated.get(profile.uuid + 'profile')) return
+	if (recentlyQueued.get(profile.uuid + 'profile')) return
+	else recentlyQueued.set(profile.uuid + 'profile', true)
 	leaderboardUpdateProfileQueue.enqueue(async() => await updateDatabaseProfile(profile))
 }