diff options
author | mat <github@matdoes.dev> | 2022-06-01 17:33:23 -0500 |
---|---|---|
committer | mat <github@matdoes.dev> | 2022-06-01 17:33:23 -0500 |
commit | 8fff4f98541ecda20146d9a432aba276ebc81bcc (patch) | |
tree | 20806d337600c86865fb17861cabaf02e0556764 /src | |
parent | 0108e58c6c74825ce30867ddb589f19c466d4c7a (diff) | |
download | skyblock-api-8fff4f98541ecda20146d9a432aba276ebc81bcc.tar.gz skyblock-api-8fff4f98541ecda20146d9a432aba276ebc81bcc.tar.bz2 skyblock-api-8fff4f98541ecda20146d9a432aba276ebc81bcc.zip |
Random refactoring & temp disable achievements
Diffstat (limited to 'src')
-rw-r--r-- | src/cleaners/achievements.ts | 4 | ||||
-rw-r--r-- | src/cleaners/player.ts | 2 | ||||
-rw-r--r-- | src/cleaners/skyblock/coopInvitation.ts | 2 | ||||
-rw-r--r-- | src/database.ts | 61 | ||||
-rw-r--r-- | src/hypixelCached.ts | 8 |
5 files changed, 36 insertions, 41 deletions
diff --git a/src/cleaners/achievements.ts b/src/cleaners/achievements.ts index edb4d07..8ab3445 100644 --- a/src/cleaners/achievements.ts +++ b/src/cleaners/achievements.ts @@ -27,6 +27,10 @@ export interface Achievements { } export async function cleanPlayerAchievements(data: typedHypixelApi.PlayerDataResponse['player']): Promise<Achievements> { + // temporarily disabled because this might be causing high memory usage? + return { tiered: [], challenge: [] } + + if (!data.achievements) { return { tiered: [], challenge: [] } } diff --git a/src/cleaners/player.ts b/src/cleaners/player.ts index 5de65de..c6d9759 100644 --- a/src/cleaners/player.ts +++ b/src/cleaners/player.ts @@ -26,11 +26,11 @@ export interface CleanPlayer extends CleanBasicPlayer { rank: CleanRank socials: CleanSocialMedia profiles?: CleanBasicProfile[] - claimed?: ClaimedSkyBlockItem[] } export interface CleanFullPlayer extends CleanPlayer { achievements: Achievements + claimed: ClaimedSkyBlockItem[] } export async function cleanPlayerResponse(data: typedHypixelApi.PlayerDataResponse['player']): Promise<CleanFullPlayer | null> { diff --git a/src/cleaners/skyblock/coopInvitation.ts b/src/cleaners/skyblock/coopInvitation.ts index 031135b..52644b5 100644 --- a/src/cleaners/skyblock/coopInvitation.ts +++ b/src/cleaners/skyblock/coopInvitation.ts @@ -26,7 +26,7 @@ export async function cleanCoopInvitation(data: typedHypixelApi.SkyBlockProfileM return { invitedTimestamp, - invitedBy: await cached.fetchBasicPlayer(data.coop_invitation.invited_by, false), + invitedBy: await cached.fetchBasicPlayer(data.coop_invitation.invited_by), accepted: data.coop_invitation.confirmed, acceptedTimestamp } diff --git a/src/database.ts b/src/database.ts index 0e0a4af..f8131d9 100644 --- a/src/database.ts +++ b/src/database.ts @@ -54,14 +54,14 @@ interface DatabaseProfileLeaderboardItem { } -interface memberRawLeaderboardItem { +interface MemberRawLeaderboardItem { uuid: string profile: string color: string username: string value: number } -interface profileRawLeaderboardItem { +interface ProfileRawLeaderboardItem { uuid: string /** An array of uuids for each player in the profile */ players: string[] @@ -81,9 +81,9 @@ interface ProfileLeaderboardItem { value: number } -export const cachedRawLeaderboards: Map<string, (memberRawLeaderboardItem | profileRawLeaderboardItem)[]> = new Map() +export const cachedRawLeaderboards: Map<string, (MemberRawLeaderboardItem | ProfileRawLeaderboardItem)[]> = new Map() -const leaderboardMax = 100 +const LEADERBOARD_MAX = 100 const reversedLeaderboards = [ 'first_join', 'last_save', '_best_time', '_best_time_2', @@ -465,18 +465,18 @@ function isLeaderboardReversed(name: string): boolean { /** A set of names of the raw leaderboards that are currently being fetched. This is used to make sure two leaderboads aren't fetched at the same time */ const fetchingRawLeaderboardNames: Set<string> = new Set() -async function fetchMemberLeaderboardRaw(name: string): Promise<memberRawLeaderboardItem[]> { +async function fetchMemberLeaderboardRaw(name: string): Promise<MemberRawLeaderboardItem[]> { if (!client) throw Error('Client isn\'t initialized yet') if (cachedRawLeaderboards.has(name)) - return cachedRawLeaderboards.get(name) as memberRawLeaderboardItem[] + return cachedRawLeaderboards.get(name) as MemberRawLeaderboardItem[] // if it's currently being fetched, check every 100ms until it's in cachedRawLeaderboards if (fetchingRawLeaderboardNames.has(name) && !cachedRawLeaderboards.get(name)) { while (true) { await sleep(100) if (cachedRawLeaderboards.has(name)) - return cachedRawLeaderboards.get(name) as memberRawLeaderboardItem[] + return cachedRawLeaderboards.get(name) as MemberRawLeaderboardItem[] } } @@ -491,12 +491,12 @@ async function fetchMemberLeaderboardRaw(name: string): Promise<memberRawLeaderb if (debug) console.debug(`Fetching leaderboard ${name} from database...`) try { - const leaderboardRaw: memberRawLeaderboardItem[] = (await memberLeaderboardsCollection + const leaderboardRaw: MemberRawLeaderboardItem[] = (await memberLeaderboardsCollection .find(query) .sort(sortQuery) - .limit(leaderboardMax) + .limit(LEADERBOARD_MAX) .toArray()) - .map((i: DatabaseMemberLeaderboardItem): memberRawLeaderboardItem => { + .map((i: DatabaseMemberLeaderboardItem): MemberRawLeaderboardItem => { return { profile: i.profile, uuid: i.uuid, @@ -516,16 +516,16 @@ async function fetchMemberLeaderboardRaw(name: string): Promise<memberRawLeaderb } } -async function fetchProfileLeaderboardRaw(name: string): Promise<profileRawLeaderboardItem[]> { +async function fetchProfileLeaderboardRaw(name: string): Promise<ProfileRawLeaderboardItem[]> { if (cachedRawLeaderboards.has(name)) - return cachedRawLeaderboards.get(name) as profileRawLeaderboardItem[] + return cachedRawLeaderboards.get(name) as ProfileRawLeaderboardItem[] // if it's currently being fetched, check every 100ms until it's in cachedRawLeaderboards if (fetchingRawLeaderboardNames.has(name)) { while (true) { await sleep(100) if (cachedRawLeaderboards.has(name)) - return cachedRawLeaderboards.get(name) as profileRawLeaderboardItem[] + return cachedRawLeaderboards.get(name) as ProfileRawLeaderboardItem[] } } @@ -538,12 +538,12 @@ async function fetchProfileLeaderboardRaw(name: string): Promise<profileRawLeade fetchingRawLeaderboardNames.add(name) try { - const leaderboardRaw: profileRawLeaderboardItem[] = (await profileLeaderboardsCollection + const leaderboardRaw: ProfileRawLeaderboardItem[] = (await profileLeaderboardsCollection .find(query) .sort(sortQuery) - .limit(leaderboardMax) + .limit(LEADERBOARD_MAX) .toArray()) - .map((i: DatabaseProfileLeaderboardItem): profileRawLeaderboardItem => { + .map((i: DatabaseProfileLeaderboardItem): ProfileRawLeaderboardItem => { return { players: i.players, colors: i.colors, @@ -589,7 +589,6 @@ interface LeaderboardBasicPlayer { export async function fetchMemberLeaderboard(name: string): Promise<MemberLeaderboard> { const leaderboardRaw = await fetchMemberLeaderboardRaw(name) - const leaderboard: MemberLeaderboardItem[] = [] for (const i of leaderboardRaw) { leaderboard.push({ @@ -616,7 +615,9 @@ export async function fetchMemberLeaderboard(name: string): Promise<MemberLeader export async function fetchProfileLeaderboard(name: string): Promise<ProfileLeaderboard> { const leaderboardRaw = await fetchProfileLeaderboardRaw(name) - const fetchLeaderboardProfile = async (i: profileRawLeaderboardItem): Promise<ProfileLeaderboardItem> => { + const leaderboard: ProfileLeaderboardItem[] = [] + + for (const i of leaderboardRaw) { const players: LeaderboardBasicPlayer[] = [] for (const playerUuid of i.players) { const player: LeaderboardBasicPlayer = { @@ -629,17 +630,13 @@ export async function fetchProfileLeaderboard(name: string): Promise<ProfileLead if (player) players.push(player) } - return { + leaderboard.push({ players: players, profileUuid: i.uuid, value: i.value - } - } - const promises: Promise<ProfileLeaderboardItem>[] = [] - for (const item of leaderboardRaw) { - promises.push(fetchLeaderboardProfile(item)) + }) } - const leaderboard = await Promise.all(promises) + return { name: name, unit: getStatUnit(name) ?? null, @@ -709,7 +706,7 @@ export async function fetchMemberLeaderboardSpots(player: string, profile: strin const memberLeaderboardSpots: LeaderboardSpot[] = [] - let leaderboardPromises: Promise<memberRawLeaderboardItem[]>[] = [] + let leaderboardPromises: Promise<MemberRawLeaderboardItem[]>[] = [] for (const leaderboardName in applicableAttributes) leaderboardPromises.push(fetchMemberLeaderboardRaw(leaderboardName)) for (const leaderboardName in applicableAttributes) { @@ -732,7 +729,7 @@ export async function fetchMemberLeaderboardSpots(player: string, profile: strin } async function getLeaderboardRequirement(name: string, leaderboardType: 'member' | 'profile'): Promise<{ top_100: number | null, top_1: number | null }> { - let leaderboard: memberRawLeaderboardItem[] | profileRawLeaderboardItem[] + let leaderboard: MemberRawLeaderboardItem[] | ProfileRawLeaderboardItem[] if (leaderboardType === 'member') leaderboard = await fetchMemberLeaderboardRaw(name) else if (leaderboardType === 'profile') @@ -740,7 +737,7 @@ async function getLeaderboardRequirement(name: string, leaderboardType: 'member' // if there's more than 100 items, return the 100th. if there's less, return null return { - top_100: leaderboard![leaderboardMax - 1]?.value ?? null, + top_100: leaderboard![LEADERBOARD_MAX - 1]?.value ?? null, top_1: leaderboard![1]?.value ?? null } } @@ -969,9 +966,9 @@ export async function updateDatabaseProfile(profile: CleanFullProfile): Promise< // add the profile to the cached leaderboard without having to refetch it - for (const [attributeName, attributeValue] of Object.entries(leaderboardAttributes)) { - const existingRawLeaderboard = await fetchProfileLeaderboardRaw(attributeName) - const leaderboardReverse = isLeaderboardReversed(attributeName) + for (const [leaderboardName, attributeValue] of Object.entries(leaderboardAttributes)) { + const existingRawLeaderboard = await fetchProfileLeaderboardRaw(leaderboardName) + const leaderboardReverse = isLeaderboardReversed(leaderboardName) const newRawLeaderboard = existingRawLeaderboard // remove the player from the leaderboard, if they're there @@ -985,7 +982,7 @@ export async function updateDatabaseProfile(profile: CleanFullProfile): Promise< }]) .sort((a, b) => leaderboardReverse ? a.value - b.value : b.value - a.value) .slice(0, 100) - cachedRawLeaderboards.set(attributeName, newRawLeaderboard) + cachedRawLeaderboards.set(leaderboardName, newRawLeaderboard) } if (debug) console.debug('added profile to leaderboards', profile.name, leaderboardAttributes) diff --git a/src/hypixelCached.ts b/src/hypixelCached.ts index d94d1f5..a233380 100644 --- a/src/hypixelCached.ts +++ b/src/hypixelCached.ts @@ -164,7 +164,6 @@ function cleanFullPlayerToCleanPlayer(player: CleanFullPlayer): CleanPlayer { socials: player.socials, username: player.username, uuid: player.uuid, - claimed: player.claimed, profiles: player.profiles } } @@ -212,16 +211,13 @@ export async function fetchPlayer<Full extends boolean = true>(user: string, ful } /** Fetch a player without their profiles. This is heavily cached. */ -export async function fetchBasicPlayer(user: string, includeClaimed: boolean = true): Promise<CleanPlayer | null> { +export async function fetchBasicPlayer(user: string): Promise<CleanPlayer | null> { const playerUuid = await uuidFromUser(user) if (!playerUuid) return null if (basicPlayerCache.has(playerUuid)) { const player = basicPlayerCache.get(playerUuid)! - if (!includeClaimed) { - delete player.claimed - } return player } @@ -232,8 +228,6 @@ export async function fetchBasicPlayer(user: string, includeClaimed: boolean = t } delete player.profiles - if (!includeClaimed) - delete player.claimed return player } |