prettier

Author: howardchung

global.d.ts

@@ -282,7 +282,7 @@ type MmrJob = {
 
 type ProfileJob = {
   account_id: number;
-}
+};
 
 type GcDataJob = {
   match_id: number;

package-lock.json

@@ -81,7 +81,7 @@
     "eslint": "^9.19.0",
     "mocha": "^11.0.1",
     "nock": "^13.5.6",
-    "prettier": "^3.4.2",
+    "prettier": "^3.6.2",
     "supertest": "^7.0.0",
     "tsx": "^4.19.2",
     "typescript": "^5.7.3",

package.json

@@ -1,9 +1,6 @@
 // Updates Steam profile data for players periodically
 import db from './store/db';
-import {
-  invokeIntervalAsync,
-  randomInt,
-} from './util/utility';
+import { invokeIntervalAsync, randomInt } from './util/utility';
 import { addJob } from './store/queue';
 import { getPGroup } from './util/pgroup';
 import { apiFetcher } from './fetcher/getApiData';
@@ -13,14 +10,18 @@ async function doGcData() {
   // Randomly guess IDs (about 1/2 will be valid) and try to do gcdata on them
   // If the API data is missing we'll skip
   // Otherwise we'll fetch gcdata (or skip if already present)
-  const max = (await db.raw('select max(match_id) from public_matches'))
-    ?.rows?.[0]?.max ?? 0;
+  const max =
+    (await db.raw('select max(match_id) from public_matches'))?.rows?.[0]
+      ?.max ?? 0;
   const rand = randomInt(0, max);
   if (rand) {
-      const { data } = await apiFetcher.getOrFetchData(rand);
-      if (data) {
-        await addJob({ name: 'gcQueue', data: { match_id: rand, pgroup: getPGroup(data) }});
-      }
+    const { data } = await apiFetcher.getOrFetchData(rand);
+    if (data) {
+      await addJob({
+        name: 'gcQueue',
+        data: { match_id: rand, pgroup: getPGroup(data) },
+      });
+    }
   }
 }
 invokeIntervalAsync(doGcData, 5000);

svc/autogcdata.ts

@@ -1,8 +1,6 @@
 // Updates Steam profile data for players periodically
 import db from './store/db';
-import {
-  invokeIntervalAsync,
-} from './util/utility';
+import { invokeIntervalAsync } from './util/utility';
 import { addJob } from './store/queue';
 
 async function doProfiler() {
@@ -14,8 +12,13 @@ async function doProfiler() {
     'SELECT account_id from players TABLESAMPLE SYSTEM_ROWS(100)',
   );
   // Queue the rows
-  await Promise.all(result.rows.map(async (row: any) => {
-    await addJob({ name: 'profileQueue', data: { account_id: row.account_id }});
-  }));
+  await Promise.all(
+    result.rows.map(async (row: any) => {
+      await addJob({
+        name: 'profileQueue',
+        data: { account_id: row.account_id },
+      });
+    }),
+  );
 }
 invokeIntervalAsync(doProfiler, 5000);

svc/autoprofiler.ts

@@ -11,7 +11,9 @@ async function processGcData(job: GcDataJob) {
     return;
   }
   // Currently, just attempt it once and skip if failed
-  const { data: gcMatch } = await gcFetcher.getOrFetchData(job.match_id, { pgroup });
+  const { data: gcMatch } = await gcFetcher.getOrFetchData(job.match_id, {
+    pgroup,
+  });
   // Reconcile anonymous players
   await reconcile(gcMatch, pgroup, 'pmh_gcdata');
   await new Promise((resolve) => setTimeout(resolve, 10));

svc/gcdata.ts

@@ -3,10 +3,7 @@ import { runQueue } from './store/queue';
 import db from './store/db';
 import { insertPlayerRating } from './util/insert';
 import config from '../config';
-import {
-  redisCount,
-  getRandomRetrieverUrl,
-} from './util/utility';
+import { redisCount, getRandomRetrieverUrl } from './util/utility';
 import axios from 'axios';
 
 async function processMmr(job: MmrJob) {
@@ -34,8 +31,4 @@ async function processMmr(job: MmrJob) {
   }
   await new Promise((resolve) => setTimeout(resolve, 1));
 }
-runQueue(
-  'mmrQueue',
-  Number(config.MMR_PARALLELISM) || 1,
-  processMmr,
-);
+runQueue('mmrQueue', Number(config.MMR_PARALLELISM) || 1, processMmr);

svc/mmr.ts

@@ -133,7 +133,7 @@ async function profileDelay() {
   const result = await redis.llen('profileQueue');
   return {
     metric: result,
-    threshold: 100000
+    threshold: 100000,
   };
 }
 async function postgresUsage() {

svc/monitor.ts

@@ -15,7 +15,7 @@ async function doProfile() {
   if (!resp || !resp.length) {
     return;
   }
-  const jobs = resp.map(item => JSON.parse(item) as ProfileJob);
+  const jobs = resp.map((item) => JSON.parse(item) as ProfileJob);
   const url = SteamAPIUrls.api_summaries({
     players: jobs,
   });
@@ -45,4 +45,4 @@ async function doProfile() {
     results.map((player: User) => upsertPlayer(db, player, false)),
   );
 }
-invokeIntervalAsync(doProfile, 2000);
+invokeIntervalAsync(doProfile, 2000);

svc/profiler.ts

@@ -129,17 +129,25 @@ export async function insertPlayerRating(row: PlayerRating) {
   }
 }
 
-export async function reconcile(gcMatch: GcMatch | null, pgroup: PGroup, metricName: MetricName) {
+export async function reconcile(
+  gcMatch: GcMatch | null,
+  pgroup: PGroup,
+  metricName: MetricName,
+) {
   if (gcMatch) {
     // Log the players who were previously anomymous for reconciliation
-    await Promise.all(gcMatch.players
-      .filter(p => !Boolean(pgroup[p.player_slot]?.account_id))
-      .map(async (p) => {
-        if (p.account_id) {
-          await db.raw('INSERT INTO player_match_history(account_id, match_id, player_slot) VALUES (?, ?, ?) ON CONFLICT DO NOTHING', [p.account_id, gcMatch.match_id, p.player_slot]);
-          await redisCount(metricName);
-        }
-      })
+    await Promise.all(
+      gcMatch.players
+        .filter((p) => !Boolean(pgroup[p.player_slot]?.account_id))
+        .map(async (p) => {
+          if (p.account_id) {
+            await db.raw(
+              'INSERT INTO player_match_history(account_id, match_id, player_slot) VALUES (?, ?, ?) ON CONFLICT DO NOTHING',
+              [p.account_id, gcMatch.match_id, p.player_slot],
+            );
+            await redisCount(metricName);
+          }
+        }),
     );
   }
 }