Fix build (#70)

Author: slavingia

app/api/github/webhook/route.test.ts

@@ -0,0 +1,133 @@
+import { describe, it, expect, vi, beforeEach } from "vitest";
+import { NextRequest, NextResponse } from "next/server";
+import { POST } from "./route";
+import { getOctokit } from "@/lib/github";
+import { revalidateTag } from "next/cache";
+import type { Mock } from "vitest";
+
+vi.mock("@/lib/github", () => ({
+  getOctokit: vi.fn(),
+}));
+
+vi.mock("next/cache", () => ({
+  revalidateTag: vi.fn(),
+}));
+
+describe("POST", () => {
+  let mockRequest: NextRequest;
+  let mockOctokit: any;
+
+  beforeEach(() => {
+    vi.clearAllMocks();
+    mockOctokit = {};
+    (getOctokit as Mock).mockResolvedValue(mockOctokit);
+    mockRequest = {
+      json: vi.fn(),
+      headers: {
+        get: vi.fn(),
+      },
+    } as unknown as NextRequest;
+  });
+
+  it("should handle push event", async () => {
+    const mockJson = vi.fn().mockResolvedValue({
+      repository: { full_name: "test/repo" },
+      commits: [],
+    });
+    const mockGet = vi.fn().mockReturnValue("push");
+
+    mockRequest.json = mockJson;
+    mockRequest.headers.get = mockGet;
+
+    const response = await POST(mockRequest);
+
+    expect(response).toBeInstanceOf(NextResponse);
+    expect(response.status).toBe(200);
+    expect(getOctokit).toHaveBeenCalled();
+    // Add more specific assertions based on the expected behavior
+  });
+
+  it("should handle pull request event", async () => {
+    const mockJson = vi.fn().mockResolvedValue({
+      action: "opened",
+      pull_request: { id: "123" },
+      repository: { full_name: "test/repo" },
+    });
+    const mockGet = vi.fn().mockReturnValue("pull_request");
+
+    mockRequest.json = mockJson;
+    mockRequest.headers.get = mockGet;
+
+    const response = await POST(mockRequest);
+
+    expect(response).toBeInstanceOf(NextResponse);
+    expect(response.status).toBe(200);
+    expect(getOctokit).toHaveBeenCalled();
+    expect(revalidateTag).toHaveBeenCalledWith("pullRequest-123");
+  });
+
+  it("should handle check run event", async () => {
+    const mockJson = vi.fn().mockResolvedValue({
+      action: "completed",
+      check_run: { pull_requests: [{ id: "456" }] },
+      repository: { full_name: "test/repo" },
+    });
+    const mockGet = vi.fn().mockReturnValue("check_run");
+
+    mockRequest.json = mockJson;
+    mockRequest.headers.get = mockGet;
+
+    const response = await POST(mockRequest);
+
+    expect(response).toBeInstanceOf(NextResponse);
+    expect(response.status).toBe(200);
+    expect(getOctokit).toHaveBeenCalled();
+    expect(revalidateTag).toHaveBeenCalledWith("pullRequest-456");
+  });
+
+  it("should handle check suite event", async () => {
+    const mockJson = vi.fn().mockResolvedValue({
+      action: "completed",
+      check_suite: { pull_requests: [{ id: "789" }] },
+      repository: { full_name: "test/repo" },
+    });
+    const mockGet = vi.fn().mockReturnValue("check_suite");
+
+    mockRequest.json = mockJson;
+    mockRequest.headers.get = mockGet;
+
+    const response = await POST(mockRequest);
+
+    expect(response).toBeInstanceOf(NextResponse);
+    expect(response.status).toBe(200);
+    expect(getOctokit).toHaveBeenCalled();
+    expect(revalidateTag).toHaveBeenCalledWith("pullRequest-789");
+  });
+
+  it("should handle unhandled event types", async () => {
+    const mockJson = vi.fn().mockResolvedValue({});
+    const mockGet = vi.fn().mockReturnValue("unhandled_event");
+
+    mockRequest.json = mockJson;
+    mockRequest.headers.get = mockGet;
+
+    const response = await POST(mockRequest);
+
+    expect(response).toBeInstanceOf(NextResponse);
+    expect(response.status).toBe(200);
+    expect(getOctokit).toHaveBeenCalled();
+    expect(revalidateTag).not.toHaveBeenCalled();
+  });
+
+  it("should handle errors", async () => {
+    const mockJson = vi.fn().mockImplementation(() => {
+      throw new Error("Test error");
+    });
+    mockRequest.json = mockJson;
+
+    const response = await POST(mockRequest);
+
+    expect(response).toBeInstanceOf(NextResponse);
+    expect(response.status).toBe(500);
+  });
+});

app/api/github/webhook/route.ts

@@ -1,13 +1,22 @@
 import { NextResponse } from "next/server";
 import { getOctokit } from "@/lib/github";
 import { revalidateTag } from "next/cache";
+import { type NextRequest } from "next/server";
 
-const octokit = getOctokit();
+export async function POST(request: NextRequest) {
+  const octokit = await getOctokit();
 
-// Webhooks documentation: https://docs.github.com/en/webhooks
+  let payload;
+  try {
+    payload = await request.json();
+  } catch (error) {
+    console.error("Failed to parse webhook payload:", error);
+    return NextResponse.json(
+      { error: "Failed to parse webhook payload" },
+      { status: 500 }
+    );
+  }
 
-export async function POST(request: Request) {
-  const payload = await request.json();
   const githubEvent = request.headers.get("x-github-event");
 
   if (!githubEvent) {
@@ -20,16 +29,16 @@ export async function POST(request: Request) {
   try {
     switch (githubEvent) {
       case "push":
-        await handlePushEvent(payload);
+        await handlePushEvent(payload, octokit);
         break;
       case "pull_request":
-        await handlePullRequestEvent(payload);
+        await handlePullRequestEvent(payload, octokit);
         break;
       case "check_run":
-        await handleCheckRunEvent(payload);
+        await handleCheckRunEvent(payload, octokit);
         break;
       case "check_suite":
-        await handleCheckSuiteEvent(payload);
+        await handleCheckSuiteEvent(payload, octokit);
         break;
       default:
         console.log(`Unhandled event type: ${githubEvent}`);
@@ -45,19 +54,18 @@ export async function POST(request: Request) {
   }
 }
 
-async function handlePushEvent(payload: any) {
+async function handlePushEvent(payload: any, octokit: any) {
   const { repository, commits } = payload;
   console.log(`New push to ${repository.full_name}`);
-  // Process commits
 }
 
-async function handlePullRequestEvent(payload: any) {
+async function handlePullRequestEvent(payload: any, octokit: any) {
   const { action, pull_request, repository } = payload;
   console.log(`Pull request ${action} in ${repository.full_name}`);
   revalidateTag(`pullRequest-${pull_request.id}`);
 }
 
-async function handleCheckRunEvent(payload: any) {
+async function handleCheckRunEvent(payload: any, octokit: any) {
   const { action, check_run, repository } = payload;
   console.log(`Check run ${action} in ${repository.full_name}`);
   if (check_run.pull_requests && check_run.pull_requests.length > 0) {
@@ -67,7 +75,7 @@ async function handleCheckRunEvent(payload: any) {
   }
 }
 
-async function handleCheckSuiteEvent(payload: any) {
+async function handleCheckSuiteEvent(payload: any, octokit: any) {
   const { action, check_suite, repository } = payload;
   console.log(`Check suite ${action} in ${repository.full_name}`);
   if (check_suite.pull_requests && check_suite.pull_requests.length > 0) {