monkeytypegame/monkeytype
1
1
Fork 0
mirror of https://github.com/monkeytypegame/monkeytype.git synced 2025-02-01 03:19:20 +08:00
Code Issues Projects Releases Packages Wiki Activity

impr: provide all-time LB results during LB update (@fehmer) (#5614)

Browse source
This commit is contained in:
Christian Fehmer 2024-07-15 12:25:47 +02:00 committed by GitHub
parent aca3fe205b
commit 94a393fd87
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 21 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

39
backend/src/dal/leaderboards.ts
View file

@ -5,8 +5,6 @@ import { setLeaderboard } from "../utils/prometheus";
import { isDevEnvironment } from "../utils/misc";
import { getCachedConfiguration } from "../init/configuration";
const leaderboardUpdating: Record<string, boolean> = {};
export async function get(
mode: string,
mode2: string,
@ -57,21 +55,28 @@ export async function getRank(
language: string,
uid: string
): Promise<GetRankResponse | false> {
if (leaderboardUpdating[`${language}_${mode}_${mode2}`]) return false;
const entry = await db
.collection<SharedTypes.LeaderboardEntry>(
`leaderboards.${language}.${mode}.${mode2}`
)
.findOne({ uid });
const count = await db
.collection(`leaderboards.${language}.${mode}.${mode2}`)
.estimatedDocumentCount();
try {
const entry = await db
.collection<SharedTypes.LeaderboardEntry>(
`leaderboards.${language}.${mode}.${mode2}`
)
.findOne({ uid });
const count = await db
.collection(`leaderboards.${language}.${mode}.${mode2}`)
.estimatedDocumentCount();
return {
count,
rank: entry ? entry.rank : null,
entry,
};
return {
count,
rank: entry ? entry.rank : null,
entry,
};
} catch (e) {
if (e.error === 175) {
//QueryPlanKilled, collection was removed during the query
return false;
}
throw e;
}
}
export async function update(
@ -84,7 +89,6 @@ export async function update(
}> {
const key = `lbPersonalBests.${mode}.${mode2}.${language}`;
const lbCollectionName = `leaderboards.${language}.${mode}.${mode2}`;
leaderboardUpdating[`${language}_${mode}_${mode2}`] = true;
const lb = db
.collection<MonkeyTypes.DBUser>("users")
.aggregate<SharedTypes.LeaderboardEntry>(
@ -185,7 +189,6 @@ export async function update(
const start2 = performance.now();
await db.collection(lbCollectionName).createIndex({ uid: -1 });
await db.collection(lbCollectionName).createIndex({ rank: 1 });
leaderboardUpdating[`${language}_${mode}_${mode2}`] = false;
const end2 = performance.now();
//update speedStats