Repository navigation
Expand file tree
/
Copy pathindex.js
More file actions
90 lines (74 loc) ยท 2.83 KB
/
Copy pathindex.js
File metadata and controls
90 lines (74 loc) ยท 2.83 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
/**
* 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);
},
};