Add bulk approval and merge functionality for open PRs; enhance request handling and validation

Author: DaleSeo

AGENTS.md

@@ -68,9 +68,9 @@ export async function newFeature(request, env) {
 }
 
 // index.js에 라우팅 추가
-import { newFeature } from './handlers/new-feature.js';
+import { newFeature } from "./handlers/new-feature.js";
 
-if (url.pathname === '/new-feature') {
+if (url.pathname === "/new-feature") {
   return newFeature(request, env);
 }
 ```
@@ -151,9 +151,10 @@ GitHub Organization webhook 수신용 엔드포인트
 
 **Request:**
 
+`repo_owner` 생략 시 기본값으로 `DaleStudy`가 사용됩니다.
+
 ```json
 {
-  "repo_owner": "DaleStudy",
   "repo_name": "leetcode-study"
 }
 ```
@@ -174,6 +175,67 @@ GitHub Organization webhook 수신용 엔드포인트
 }
 ```
 
+#### `POST /approve-prs`
+
+열려있는 답안 제출 PR을 일괄 승인합니다. `excludes` 배열로 특정 PR을 제외합니다. 이미 승인된 PR, `maintenance` 라벨, Draft 상태의 PR은 자동으로 스킵됩니다.
+
+**Request:**
+
+```json
+{ "repo_name": "leetcode-study", "excludes": [1972] }
+```
+
+**Response:**
+
+```json
+{
+  "success": true,
+  "action": "approve",
+  "repo": "DaleStudy/leetcode-study",
+  "total_open_prs": 5,
+  "processed": 2,
+  "approved": 2,
+  "skipped": 0,
+  "results": [
+    { "pr": 1970, "title": "week8 solutions", "approved": true },
+    { "pr": 1971, "title": "week8 extras", "approved": true }
+  ]
+}
+```
+
+#### `POST /merge-prs`
+
+열려있는 PR을 일괄 병합합니다. 기본 병합 방식은 `merge`이며 `merge_method` 값으로 `merge | squash | rebase` 중 선택할 수 있습니다. `excludes`로 특정 PR을 제외할 수 있습니다. 승인 리뷰가 없거나 `maintenance` 라벨이 붙은 PR, Draft PR, GitHub `mergeable_state !== "clean"` PR은 스킵되며 `unknown`/`behind` 상태는 최대 1초 후 한 번 더 확인합니다.
+
+**Request:**
+
+```json
+{
+  "repo_name": "leetcode-study",
+  "merge_method": "squash",
+  "excludes": [1972]
+}
+```
+
+**Response:**
+
+```json
+{
+  "success": true,
+  "action": "merge",
+  "repo": "DaleStudy/leetcode-study",
+  "merge_method": "squash",
+  "total_open_prs": 5,
+  "processed": 2,
+  "merged": 2,
+  "skipped": 0,
+  "results": [
+    { "pr": 1970, "title": "week8 solutions", "merged": true, "sha": "abc123" },
+    { "pr": 1971, "title": "week8 extras", "merged": true, "sha": "def456" }
+  ]
+}
+```
+
 ### 3. 워크플로우
 
 1. Open PR 목록 조회 (GitHub REST API)
@@ -192,7 +254,7 @@ GitHub Organization webhook 수신용 엔드포인트
 
 - `contents: read`: PR 정보 조회
 - `issues: write`: 댓글 작성 및 삭제
-- `pull_requests: read`: PR 목록 및 상태 조회
+- `pull_requests: read & write`: PR 목록/상태 조회, 리뷰 생성, 병합 수행
 - `organization_projects: read`: Projects v2의 Week 필드 접근 (GraphQL API)
 
 ### Secrets 관리
@@ -245,13 +307,15 @@ https://github.com/settings/apps/dalestudy
 ### 3. Permissions & events 탭 - 권한 설정
 
 **Repository permissions:**
+
 - **Contents**: Read
 - **Issues**: Read & write (issue_comment 이벤트용)
 - **Metadata**: Read
 - **Pull requests**: Read & write
 - **Projects**: Read & write (Projects V2)
 
 **Subscribe to events:**
+
 - ☑️ **Issue comments** (`issue_comment` - AI 코드 리뷰)
 - ☑️ **Projects v2 item** (`projects_v2_item` - Week 체크)
 - ☑️ **Pull requests** (`pull_request` - Week 체크)
@@ -269,6 +333,7 @@ wrangler secret put WEBHOOK_SECRET
 ### 5. GitHub App 설치
 
 저장소에 App이 설치되어 있는지 확인:
+
 ```
 https://github.com/apps/dalestudy/installations
 ```

README.md

@@ -77,9 +77,10 @@ https://github.dalestudy.com
 
 **Request:**
 
+요청 바디에서 `repo_owner`를 생략하면 자동으로 `DaleStudy`가 사용됩니다.
+
 ```json
 {
-  "repo_owner": "DaleStudy",
   "repo_name": "leetcode-study"
 }
 ```
@@ -100,6 +101,67 @@ https://github.dalestudy.com
 }
 ```
 
+### `POST /approve-prs`
+
+열려있는 답안 제출 PR을 일괄 승인합니다. `excludes` 배열을 사용해 특정 PR 번호를 제외할 수 있습니다. 이미 승인되었거나 Draft/`maintenance` 라벨이 붙은 PR은 자동으로 스킵됩니다.
+
+**Request:**
+
+```json
+{ "repo_name": "leetcode-study", "excludes": [1972] }
+```
+
+**Response:**
+
+```json
+{
+  "success": true,
+  "action": "approve",
+  "repo": "DaleStudy/leetcode-study",
+  "total_open_prs": 5,
+  "processed": 2,
+  "approved": 2,
+  "skipped": 0,
+  "results": [
+    { "pr": 1970, "title": "week8 solutions", "approved": true },
+    { "pr": 1971, "title": "week8 extras", "approved": true }
+  ]
+}
+```
+
+### `POST /merge-prs`
+
+열려있는 PR을 일괄 병합합니다. 기본 병합 방식은 `merge`이며, `merge_method`로 `merge | squash | rebase` 중 선택할 수 있습니다. `excludes` 배열로 특정 PR을 제외할 수 있습니다. 최소 1개의 승인 리뷰가 없거나 Draft/`maintenance` 라벨이 붙은 PR은 스킵되며, GitHub에서 `mergeable_state === "clean"`인 PR만 병합됩니다(`behind`, `dirty`, `unknown` 등은 스킵). `unknown`/`behind` 상태는 최대 1초 후 한 차례 재확인합니다.
+
+**Request:**
+
+```json
+{
+  "repo_name": "leetcode-study",
+  "excludes": [1972],
+  "merge_method": "squash"
+}
+```
+
+**Response:**
+
+```json
+{
+  "success": true,
+  "action": "merge",
+  "repo": "DaleStudy/leetcode-study",
+  "merge_method": "squash",
+  "total_open_prs": 5,
+  "processed": 2,
+  "merged": 2,
+  "skipped": 0,
+  "results": [
+    { "pr": 1970, "title": "week8 solutions", "merged": true, "sha": "abc123" },
+    { "pr": 1971, "title": "week8 extras", "merged": true, "sha": "def456" }
+  ]
+}
+```
+
 ## 개발 및 테스트
 
 ### 로컬 개발

handlers/approve_prs.js

@@ -0,0 +1,114 @@
+import { generateGitHubAppToken, getGitHubHeaders } from "../utils/github.js";
+import { corsResponse, errorResponse } from "../utils/cors.js";
+import {
+  parsePrActionPayload,
+  fetchOpenPullRequests,
+  filterTargetPrs,
+  getSkipReason,
+  formatResult,
+  safeJson,
+  hasApprovedReview,
+} from "../utils/prActions.js";
+
+const APPROVAL_COMMENT = `현재 주차가 종료되어 자동으로 승인되었습니다. PR을 병합해주세요!`;
+
+/**
+ * Bulk approve handler
+ *
+ * @param {Request} request - Worker request object
+ * @param {Env} env - Worker bindings (APP_ID, PRIVATE_KEY, etc.)
+ */
+export async function approvePrs(request, env) {
+  try {
+    const payload = await parsePrActionPayload(request);
+    if (!payload.valid) {
+      return payload.response;
+    }
+
+    const { repoOwner, repoName, excludes } = payload.data;
+    const appToken = await generateGitHubAppToken(env);
+    const openPrs = await fetchOpenPullRequests(repoOwner, repoName, appToken);
+    const targetPrs = filterTargetPrs(openPrs, excludes);
+
+    const results = [];
+    let approved = 0;
+    let skipped = 0;
+
+    for (const pr of targetPrs) {
+      const skipReason = getSkipReason(pr);
+      if (skipReason) {
+        skipped++;
+        results.push(formatResult(pr, { skipped: true, reason: skipReason }));
+        continue;
+      }
+
+      const alreadyApproved = await hasApprovedReview(
+        repoOwner,
+        repoName,
+        pr.number,
+        appToken
+      );
+      if (alreadyApproved) {
+        skipped++;
+        results.push(
+          formatResult(pr, { skipped: true, reason: "already approved" })
+        );
+        continue;
+      }
+
+      const reviewResult = await approvePullRequest(
+        repoOwner,
+        repoName,
+        pr.number,
+        appToken
+      );
+
+      if (reviewResult.approved) {
+        approved++;
+      }
+
+      results.push(formatResult(pr, reviewResult));
+    }
+
+    return corsResponse({
+      success: true,
+      action: "approve",
+      repo: `${repoOwner}/${repoName}`,
+      total_open_prs: openPrs.length,
+      processed: targetPrs.length,
+      approved,
+      skipped,
+      results,
+    });
+  } catch (error) {
+    console.error("approvePrs error:", error);
+    return errorResponse(`Internal server error: ${error.message}`, 500);
+  }
+}
+
+async function approvePullRequest(owner, repo, prNumber, token) {
+  const response = await fetch(
+    `https://api.github.com/repos/${owner}/${repo}/pulls/${prNumber}/reviews`,
+    {
+      method: "POST",
+      headers: {
+        ...getGitHubHeaders(token),
+        "Content-Type": "application/json",
+      },
+      body: JSON.stringify({
+        body: APPROVAL_COMMENT,
+        event: "APPROVE",
+      }),
+    }
+  );
+
+  if (response.ok) {
+    return { approved: true };
+  }
+
+  const errorData = await safeJson(response);
+  return {
+    approved: false,
+    error: errorData.message || "Approval failed",
+  };
+}

handlers/check-weeks.js

@@ -17,26 +17,24 @@ import { validateOrganization, hasMaintenanceLabel } from "../utils/validation.j
 export async function checkWeeks(request, env) {
   try {
     const { repo_owner, repo_name } = await request.json();
+    const repoOwner = repo_owner || "DaleStudy";
 
     // Validation
-    if (!repo_owner || !repo_name) {
-      return errorResponse(
-        "Missing required fields: repo_owner, repo_name",
-        400
-      );
+    if (!repo_name) {
+      return errorResponse("Missing required field: repo_name", 400);
     }
 
     // DaleStudy organization만 허용
-    if (!validateOrganization(repo_owner)) {
-      return errorResponse(`Unauthorized organization: ${repo_owner}`, 403);
+    if (!validateOrganization(repoOwner)) {
+      return errorResponse(`Unauthorized organization: ${repoOwner}`, 403);
     }
 
     // GitHub App Token 생성
     const appToken = await generateGitHubAppToken(env);
 
     // Open PR 목록 조회
     const prsResponse = await fetch(
-      `https://api.github.com/repos/${repo_owner}/${repo_name}/pulls?state=open&per_page=100`,
+      `https://api.github.com/repos/${repoOwner}/${repo_name}/pulls?state=open&per_page=100`,
       { headers: getGitHubHeaders(appToken) }
     );
 
@@ -63,7 +61,7 @@ export async function checkWeeks(request, env) {
 
       // Week 값 확인 및 댓글 처리
       const weekValue = await handleWeekComment(
-        repo_owner,
+        repoOwner,
         repo_name,
         prNumber,
         env,