Merge pull request #100 from crux-bphc/fix-handle-changed

fix(backend): resolve historic handles issues

Author: rev-975

backend/src/codeforces_api.ts

@@ -68,15 +68,15 @@ export async function verifySubmission(
 export async function linkCfHandle(cfHandle: string, userId: string) {
   try {
     const res = await fetch(
-      `https://codeforces.com/api/user.info?handles=${cfHandle}`
+      `https://codeforces.com/api/user.info?handles=${cfHandle}&checkHistoricHandles=true`
     );
     const fetchedUser = await res.json();
     if (fetchedUser.status === "OK") {
       const userData = fetchedUser.result[0] as User;
       const [linkedUser] = await db
         .update(users)
         .set({
-          cfHandle: cfHandle,
+          cfHandle: userData.handle,
           cfRating: userData.rating,
         })
         .where(eq(users.id, userId))

backend/src/controllers/codeforces.ts

@@ -119,3 +119,31 @@ export async function fetchUserSubmissions(
     `Enqueued fetchUserSubmissions job for ${cfHandle} (Priority: ${priority})`
   );
 }
+
+export async function refreshHistoricHandles(priority: number = 5) {
+  const dateKey = new Date().toISOString().slice(0, 10); 
+  const userData = await db
+    .select({
+      cfHandle: users.cfHandle,
+      userId: users.id,
+    })
+    .from(users);
+
+  for (const user of userData) {
+    if (!user.cfHandle || !user.userId) continue;
+
+    await addWithRetry(
+      codeforcesQueue,
+      "cf-job",
+      {
+        type: "user.resolveHandle",
+        handle: user.cfHandle,
+        userId: user.userId,
+      },
+      {
+        priority,
+        jobId: `${user.userId}-ResolveHandle-${dateKey}`,
+      }
+    );
+  }
+}

backend/src/cron.ts

@@ -4,8 +4,16 @@ import {
   fetchProblems,
   fetchSubmissions,
   fetchRatingChanges,
+  refreshHistoricHandles,
 } from "./controllers/codeforces";
 
+function isDec21ToJan11UTC(d: Date) {
+  const month = d.getUTCMonth() + 1; 
+  const day = d.getUTCDate(); 
+
+  return (month === 12 && day >= 21) || (month === 1 && day <= 11);
+}
+
 export function startCronJobs() {
   cron.schedule("0 */2 * * *", async () => {
     console.log(
@@ -26,4 +34,14 @@ export function startCronJobs() {
     );
     await fetchRatingChanges();
   });
+
+  cron.schedule("0 0 * * *", async () => {
+    const now = new Date();
+    if (!isDec21ToJan11UTC(now)) return;
+
+    console.log(
+      `[Cron] Refreshing historic CF handles at ${now.toISOString()}`
+    );
+    await refreshHistoricHandles();
+  });
 }

backend/src/workers/codeforcesWorker.ts

@@ -10,6 +10,7 @@ import {
   updateProblems,
   updateUserRatings,
 } from "../utils/dbHelpers";
+import { linkCfHandle } from "../codeforces_api";
 
 //Keep track of problem key to problem id relations in local map
 //Problem key is contestId-problemIndex, like 2323-B, 122-C, etc.
@@ -45,6 +46,10 @@ async function init() {
         url = `https://codeforces.com/api/user.rating?handle=${handle}`;
       } else if (type === "user.submissions") {
         url = `https://codeforces.com/api/user.status?handle=${handle}`;
+      } else if (type === "user.resolveHandle") {
+        //This returns unlike the other ones as the url logic is already handled in linkCfHandle() function itself so I'm just calling the function directly.
+        await linkCfHandle(handle, userId);
+        return;
       } else if (type === "problemset.problems") {
         url = `https://codeforces.com/api/problemset.problems`;
       } else if (type === "contest.list") {