simrail/simrail.pro
3
1
Fork 2
Code Issues 3 Pull Requests Actions Packages Projects Releases 33 Wiki Activity

Merge pull request 'fix(): steam ratelimits' (#88) from v3.0.1 into main

Browse Source 
Reviewed-on: #88
Reviewed-by: Aleksander Wilczyński <aleks@alekswilc.dev>
This commit is contained in:
Aleksander Wilczyński 2024-12-30 23:07:43 +01:00
commit 47d98aba82
Signed by: gitea
GPG Key ID: CECFC30736A3D1C8
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
packages/backend/src/util/PlayerUtil.ts
View File

@ -18,7 +18,7 @@ import { IPlayerPayload, IPlayerStatsPayload } from "../types/player.js";
import { MProfile } from "../mongo/profile.js"; import { MProfile } from "../mongo/profile.js";
import { assert } from "node:console"; import { assert } from "node:console";
const STEAM_API_KEY = process.env.STEAM_APIKEY; const steamKeys: string[] = JSON.parse(process.env.STEAM_APIKEY!);
const steamFetch = (url: string) => const steamFetch = (url: string) =>
{ {
@ -28,12 +28,13 @@ const steamFetch = (url: string) =>
{ {
const req = () => const req = () =>
{ {
const steamKey = steamKeys[ Math.floor(Math.random() * steamKeys.length) ];
fetch(url, { signal: AbortSignal.timeout(10000) }).then(x => x.json()) fetch(url.replace("[STEAMKEY]", steamKey), { signal: AbortSignal.timeout(10000) }).then(x => x.json())
.then(x => res(x)) .then(x => res(x))
.catch(() => .catch(() =>
{ {
console.log("STEAM request failed! ", url.replace(STEAM_API_KEY!, "[XXX]"), retries); console.log("STEAM request failed! ", url.replace("[STEAMKEY]", steamKey), retries);
retries++; retries++;
setTimeout(() => req(), retries * 1000); setTimeout(() => req(), retries * 1000);
@ -54,7 +55,7 @@ export class PlayerUtil
if (!player) if (!player)
{ {
const data = await steamFetch(`https://api.steampowered.com/ISteamUser/GetPlayerSummaries/v2/?key=${ STEAM_API_KEY }&format=json&steamids=${ steamId }`) as IPlayerPayload; const data = await steamFetch(`https://api.steampowered.com/ISteamUser/GetPlayerSummaries/v2/?key=[STEAMKEY]&format=json&steamids=${ steamId }`) as IPlayerPayload;
assert(data.response.players, "Expected data.response.players to be truthy"); assert(data.response.players, "Expected data.response.players to be truthy");
@ -149,7 +150,7 @@ export class PlayerUtil
public static async getPlayerSteamData(steamId: string) public static async getPlayerSteamData(steamId: string)
{ {
const data = await steamFetch(`https://api.steampowered.com/ISteamUser/GetPlayerSummaries/v2/?key=${ STEAM_API_KEY }&format=json&steamids=${ steamId }`) as IPlayerPayload; const data = await steamFetch(`https://api.steampowered.com/ISteamUser/GetPlayerSummaries/v2/?key=[STEAMKEY]&format=json&steamids=${ steamId }`) as IPlayerPayload;
if (!data?.response?.players?.length) if (!data?.response?.players?.length)
{ {
@ -161,7 +162,7 @@ export class PlayerUtil
public static async getPlayerStats(steamId: string) public static async getPlayerStats(steamId: string)
{ {
const data = await steamFetch(`https://api.steampowered.com/ISteamUserStats/GetUserStatsForGame/v0002/?appid=1422130&key=${ STEAM_API_KEY }&steamid=${ steamId }`) as IPlayerStatsPayload; const data = await steamFetch(`https://api.steampowered.com/ISteamUserStats/GetUserStatsForGame/v0002/?appid=1422130&key=[STEAMKEY]&steamid=${ steamId }`) as IPlayerStatsPayload;
if (!data.playerstats?.stats) if (!data.playerstats?.stats)
{ {