fix: skip stale link updates and page through comments

Author: DaleSeo

AGENTS.md

@@ -69,7 +69,7 @@ GitHub webhook
 ```
 
 `INTERNAL_SECRET` 과 `WORKER_URL` 이 둘 다 있어야 켜진다. 하나라도 없으면 같은 invocation 에서 차례로 실행된다.
-`tests/subrequest-budget.test.js` 가 fetch 횟수(`tagPatterns` 파일 15 개에 36, `postLearningStatus` 파일 5 개에 31)를 회귀 테스트로 고정한다.
+`tests/subrequest-budget.test.js` 가 fetch 횟수(`tagPatterns` 파일 15 개에 37, `postLearningStatus` 파일 5 개에 31)를 회귀 테스트로 고정한다.
 
 ## 배포와 시크릿
 

handlers/tag-patterns.js

@@ -124,6 +124,7 @@ export async function tagPatterns(
     repoOwner,
     repoName,
     prNumber,
+    headSha,
     checkRun.html_url,
     appToken
   );
@@ -280,47 +281,98 @@ async function downloadFileEntries(solutionFiles) {
 /**
  * issue comment 목록을 한 번 읽어 두 가지를 처리한다.
  *  - 링크 댓글: 봇이 단 것이 있으면 최신 check run 링크로 고치고, 없으면 새로 단다.
+ *    분석 중에 새 커밋이 푸시됐다면 더 늦게 끝난 이전 분석이 최신 링크를 덮지 않도록 건너뛴다.
  *  - 레거시 단독 복잡도 issue comment: 있으면 삭제한다 (마이그레이션).
  * 실패해도 check run 은 이미 게시됐으므로 로그만 남긴다.
  */
 async function syncIssueComments(
   repoOwner,
   repoName,
   prNumber,
+  headSha,
   checkRunUrl,
   appToken
 ) {
-  const listResponse = await fetch(
-    `https://api.github.com/repos/${repoOwner}/${repoName}/issues/${prNumber}/comments?per_page=100`,
-    { headers: getGitHubHeaders(appToken) }
+  const comments = await listIssueComments(
+    repoOwner,
+    repoName,
+    prNumber,
+    appToken
   );
+  if (comments === null) return;
 
-  if (!listResponse.ok) {
-    console.error(
-      `[tagPatterns] Failed to list issue comments: ${listResponse.status}`
-    );
-    return;
-  }
-
-  const comments = await listResponse.json();
   const findBotComment = (marker) =>
     comments.find((c) => c.user?.type === "Bot" && c.body?.includes(marker));
 
-  await upsertLinkComment(
+  const latestHeadSha = await getHeadSha(
     repoOwner,
     repoName,
     prNumber,
-    findBotComment(LINK_COMMENT_MARKER),
-    checkRunUrl,
     appToken
   );
+  if (latestHeadSha === headSha) {
+    await upsertLinkComment(
+      repoOwner,
+      repoName,
+      prNumber,
+      findBotComment(LINK_COMMENT_MARKER),
+      checkRunUrl,
+      appToken
+    );
+  } else {
+    console.log(
+      `[tagPatterns] Skipping link comment on PR #${prNumber}: head moved from ${headSha} to ${latestHeadSha}`
+    );
+  }
 
   const legacy = findBotComment(LEGACY_COMPLEXITY_MARKER);
   if (legacy) {
     await deleteIssueComment(repoOwner, repoName, legacy.id, appToken);
   }
 }
 
+/**
+ * PR 의 issue comment 를 모든 페이지에 걸쳐 모은다. 실패하면 null.
+ */
+async function listIssueComments(repoOwner, repoName, prNumber, appToken) {
+  const comments = [];
+  for (let page = 1; ; page++) {
+    const response = await fetch(
+      `https://api.github.com/repos/${repoOwner}/${repoName}/issues/${prNumber}/comments?per_page=100&page=${page}`,
+      { headers: getGitHubHeaders(appToken) }
+    );
+
+    if (!response.ok) {
+      console.error(
+        `[tagPatterns] Failed to list issue comments: ${response.status}`
+      );
+      return null;
+    }
+
+    const batch = await response.json();
+    comments.push(...batch);
+    if (batch.length < 100) return comments;
+  }
+}
+
+/**
+ * PR 의 현재 head 커밋 SHA. 실패하면 null 이라 링크 댓글 갱신을 건너뛴다.
+ */
+async function getHeadSha(repoOwner, repoName, prNumber, appToken) {
+  const response = await fetch(
+    `https://api.github.com/repos/${repoOwner}/${repoName}/pulls/${prNumber}`,
+    { headers: getGitHubHeaders(appToken) }
+  );
+
+  if (!response.ok) {
+    console.error(`[tagPatterns] Failed to get PR #${prNumber}: ${response.status}`);
+    return null;
+  }
+
+  const pr = await response.json();
+  return pr.head?.sha ?? null;
+}
+
 async function upsertLinkComment(
   repoOwner,
   repoName,

tests/subrequest-budget.test.js

@@ -44,7 +44,7 @@ describe("subrequest 예산 — 핸들러별 invocation", () => {
     vi.clearAllMocks();
   });
 
-  it("tagPatterns 는 변경 파일 15개에서 50회 이하 subrequest를 호출한다 (예상 36: files 1 + raw 15 + 패턴 OpenAI 15 + 복잡도 OpenAI 1 + check run 1 + issue 코멘트 목록 1 + 링크 댓글 POST 1 + 레거시 DELETE 1)", async () => {
+  it("tagPatterns 는 변경 파일 15개에서 50회 이하 subrequest를 호출한다 (예상 37: files 1 + raw 15 + 패턴 OpenAI 15 + 복잡도 OpenAI 1 + check run 1 + issue 코멘트 목록 1 + PR head 조회 1 + 링크 댓글 POST 1 + 레거시 DELETE 1)", async () => {
     const solutionFiles = makeSolutionFiles(15);
 
     globalThis.fetch = vi.fn().mockImplementation((url, opts) => {
@@ -112,6 +112,10 @@ describe("subrequest 예산 — 핸들러별 invocation", () => {
         return okJson({ id: 500 });
       }
 
+      if (urlStr.endsWith(`/pulls/${PR_NUMBER}`) && method === "GET") {
+        return okJson({ head: { sha: HEAD_SHA } });
+      }
+
       // 레거시 단독 복잡도 issue comment 마이그레이션
       if (urlStr.includes(`/issues/${PR_NUMBER}/comments`) && method === "GET") {
         return okJson([
@@ -143,7 +147,7 @@ describe("subrequest 예산 — 핸들러별 invocation", () => {
     const fetchCount = globalThis.fetch.mock.calls.length;
 
     expect(result.analyzed).toBe(15);
-    expect(fetchCount).toBe(36);
+    expect(fetchCount).toBe(37);
     expect(fetchCount).toBeLessThanOrEqual(50);
   });
 

tests/tag-patterns.test.js

@@ -87,6 +87,7 @@ function makeFetchMock({
   complexityFails = false,
   checkRunFails = false,
   existingIssueComments = [],
+  latestHeadSha = HEAD_SHA,
 } = {}) {
   const requests = [];
   const fetchMock = vi.fn().mockImplementation((url, opts) => {
@@ -139,8 +140,13 @@ function makeFetchMock({
       return okJson({ id: 777, html_url: CHECK_RUN_URL });
     }
 
+    if (urlStr.endsWith(`/pulls/${PR_NUMBER}`) && method === "GET") {
+      return okJson({ head: { sha: latestHeadSha } });
+    }
+
     if (urlStr.includes(`/issues/${PR_NUMBER}/comments`) && method === "GET") {
-      return okJson(existingIssueComments);
+      const page = Number(new URL(urlStr).searchParams.get("page"));
+      return okJson(existingIssueComments.slice((page - 1) * 100, page * 100));
     }
 
     if (urlStr.includes(`/issues/${PR_NUMBER}/comments`) && method === "POST") {
@@ -428,6 +434,50 @@ describe("tagPatterns — 대화 탭 링크 댓글", () => {
     expect(commentWrites[0].body.body).toContain(CHECK_RUN_URL);
   });
 
+  it("링크 댓글이 두 번째 페이지에 있어도 찾아서 고친다", async () => {
+    const requests = setupFetch({
+      solutionFiles: [makeSolutionFile("two-sum")],
+      existingIssueComments: [
+        ...Array.from({ length: 100 }, (_, i) => ({
+          id: i + 1,
+          user: { type: "User" },
+          body: "리뷰 감사합니다",
+        })),
+        {
+          id: 321,
+          user: { type: "Bot" },
+          body: `${LINK_COMMENT_MARKER}\n이전 링크`,
+        },
+      ],
+    });
+
+    await runTagPatterns();
+
+    const commentWrites = requests.filter((r) => r.url.includes("/issues/"));
+    expect(commentWrites).toHaveLength(1);
+    expect(commentWrites[0].method).toBe("PATCH");
+    expect(commentWrites[0].url).toContain("/issues/comments/321");
+  });
+
+  it("분석 중에 새 커밋이 푸시됐으면 링크 댓글을 건드리지 않는다", async () => {
+    const requests = setupFetch({
+      solutionFiles: [makeSolutionFile("two-sum")],
+      latestHeadSha: "newer-sha",
+      existingIssueComments: [
+        {
+          id: 321,
+          user: { type: "Bot" },
+          body: `${LINK_COMMENT_MARKER}\n최신 링크`,
+        },
+      ],
+    });
+
+    await runTagPatterns();
+
+    expect(findCheckRun(requests).head_sha).toBe(HEAD_SHA);
+    expect(requests.filter((r) => r.url.includes("/issues/"))).toHaveLength(0);
+  });
+
   it("사람이 마커를 포함해 단 댓글은 링크 댓글로 보지 않는다", async () => {
     const requests = setupFetch({
       solutionFiles: [makeSolutionFile("two-sum")],