index.js

/**
 * Cloudflare Worker: DaleStudy GitHub App
 *
 * DaleStudy 조직의 자동화 작업을 처리하는 통합 GitHub App
 */

import { checkWeeks } from "./handlers/check-weeks.js";
import { handleWebhook } from "./handlers/webhooks.js";
import { handleInternalDispatch } from "./handlers/internal-dispatch.js";
import { approvePrs } from "./handlers/approve_prs.js";
import { mergePrs } from "./handlers/merge_prs.js";
import { resolveIterationHandler } from "./handlers/resolve-iteration.js";
import { preflightResponse, corsResponse, errorResponse } from "./utils/cors.js";
import { verifyWebhookSignature } from "./utils/webhook.js";

export default {
  async fetch(request, env, ctx) {
    // Handle CORS preflight
    if (request.method === "OPTIONS") {
      return preflightResponse();
    }

    if (request.method !== "POST") {
      return corsResponse({ error: "Method not allowed" }, 405);
    }

    const url = new URL(request.url);

    // 내부 디스패치 엔드포인트 (self-fetch로 호출, 별도 Worker 호출로 subrequest 분리)
    if (url.pathname.startsWith("/internal/")) {
      return handleInternalDispatch(request, env, url.pathname);
    }

    // GitHub Webhook 수신
    if (url.pathname === "/webhooks") {
      // Webhook signature 검증
      const signature = request.headers.get("X-Hub-Signature-256");
      const rawBody = await request.text();

      // Secret이 없으면 서명을 검증할 수 없으므로 받지 않는다
      if (!env.WEBHOOK_SECRET) {
        console.error("WEBHOOK_SECRET is not configured");
        return errorResponse("Webhook secret is not configured", 500);
      }

      const isValid = await verifyWebhookSignature(
        rawBody,
        signature,
        env.WEBHOOK_SECRET
      );

      if (!isValid) {
        console.error("Invalid webhook signature");
        return errorResponse("Invalid signature", 401);
      }

      // Request 객체 재생성 (body를 다시 읽을 수 있도록)
      const newRequest = new Request(request.url, {
        method: request.method,
        headers: request.headers,
        body: rawBody,
      });

      return handleWebhook(newRequest, env, ctx);
    }

    // PR Week 설정 검사 (수동 호출용)
    if (url.pathname === "/check-weeks") {
      return checkWeeks(request, env);
    }

    // Bulk approve open PRs
    if (url.pathname === "/approve-prs" || url.pathname === "/approve_prs") {
      return approvePrs(request, env);
    }

    // Bulk merge open PRs
    if (url.pathname === "/merge-prs" || url.pathname === "/merge_prs") {
      return mergePrs(request, env);
    }

    // 특정 날짜가 속한 기수/주차 조회
    if (url.pathname === "/resolve-iteration") {
      return resolveIterationHandler(request, env);
    }

    // 지원하지 않는 엔드포인트
    return corsResponse({ error: "Not found" }, 404);
  },
};