Started cleanup

Author: D-K-P

claude-agent-github-wiki/README.md

@@ -5,6 +5,7 @@ A production-ready Next.js application that enables real-time conversations with
 ## Architecture Overview
 
 This application uses a hybrid architecture combining:
+
 - **Trigger.dev Realtime Streams v2** for streaming AI responses (main data pipeline)
 - **Supabase Broadcast** for sending questions to the AI (lightweight control plane)
 - **Claude Agent SDK** for repository analysis with tool usage
@@ -40,11 +41,13 @@ This application uses a hybrid architecture combining:
 ### Environment Setup
 
 1. Copy the example environment file:
+
 ```bash
 cp .env.example .env.local
 ```
 
 2. Add your API keys to `.env.local`:
+
 ```env
 # Trigger.dev
 TRIGGER_PROJECT_REF=your_project_ref
@@ -83,11 +86,13 @@ Open [http://localhost:3000](http://localhost:3000)
 ### Deployment
 
 Deploy to Trigger.dev:
+
 ```bash
 npx trigger.dev@latest deploy
 ```
 
 Deploy Next.js to Vercel:
+
 ```bash
 vercel deploy
 ```
@@ -117,15 +122,18 @@ Responses stream via Trigger.dev Streams v2 → Frontend
 ### Key Components
 
 1. **Build Extension** (`trigger.config.ts`):
+
    - Installs git via apt-get in container
    - Enables shallow cloning without local git dependency
 
 2. **Clone Task** (`trigger/clone-repo.ts`):
+
    - Performs shallow clone (`--depth=1`)
    - Generates unique session ID
    - Returns temp directory path
 
 3. **Chat Session Task** (`trigger/repo-chat-session.ts`):
+
    - Maintains repo in memory for 60 minutes
    - Listens for questions via Supabase Broadcast
    - Streams responses via Trigger.dev Streams v2
@@ -177,12 +185,9 @@ components/
 ## Development Notes
 
 This demo showcases:
+
 - Trigger.dev Realtime Streams v2 for data streaming
 - Build extensions for containerized dependencies
 - Hybrid architecture pattern (control + data plane separation)
 - Long-running task management
 - Claude Agent SDK integration
-
-## License
-
-MIT

claude-agent-github-wiki/app/api/analyze-repo/route.ts

@@ -1,4 +1,4 @@
-import { tasks, runs } from "@trigger.dev/sdk/v3";
+import { runs, tasks } from "@trigger.dev/sdk";
 import { cloneRepo } from "@/trigger/clone-repo";
 import { repoChatSession } from "@/trigger/repo-chat-session";
 import { NextRequest, NextResponse } from "next/server";
@@ -11,7 +11,7 @@ export async function POST(request: NextRequest) {
     if (!githubUrl || typeof githubUrl !== "string") {
       return NextResponse.json(
         { error: "GitHub URL is required" },
-        { status: 400 }
+        { status: 400 },
       );
     }
 
@@ -20,14 +20,14 @@ export async function POST(request: NextRequest) {
     if (!githubUrlPattern.test(githubUrl)) {
       return NextResponse.json(
         { error: "Invalid GitHub URL format" },
-        { status: 400 }
+        { status: 400 },
       );
     }
 
     // Trigger the clone task
     const cloneHandle = await tasks.trigger<typeof cloneRepo>(
       "clone-repo",
-      { githubUrl }
+      { githubUrl },
     );
 
     // Wait for clone to complete using pollForCompletion
@@ -44,19 +44,19 @@ export async function POST(request: NextRequest) {
       } else if (run.status === "FAILED") {
         return NextResponse.json(
           { error: "Failed to clone repository" },
-          { status: 500 }
+          { status: 500 },
         );
       }
 
       // Wait 1 second before next check
-      await new Promise(resolve => setTimeout(resolve, 1000));
+      await new Promise((resolve) => setTimeout(resolve, 1000));
       attempts++;
     }
 
     if (!cloneResult) {
       return NextResponse.json(
         { error: "Clone operation timed out" },
-        { status: 500 }
+        { status: 500 },
       );
     }
 
@@ -67,7 +67,7 @@ export async function POST(request: NextRequest) {
         tempDir: cloneResult.output.tempDir,
         sessionId: cloneResult.output.sessionId,
         repoName: cloneResult.output.repoName,
-      }
+      },
     );
 
     // Get public access token from handle (auto-generated, expires in 15 min)
@@ -81,12 +81,11 @@ export async function POST(request: NextRequest) {
       repoName: cloneResult.output.repoName,
       cloneRunId: cloneHandle.id, // Keep for backward compatibility
     });
-
   } catch (error: any) {
     console.error("Failed to trigger clone-repo task:", error);
     return NextResponse.json(
       { error: error.message || "Failed to start cloning" },
-      { status: 500 }
+      { status: 500 },
     );
   }
 }

claude-agent-github-wiki/app/api/chat/route.ts

@@ -1,96 +1,96 @@
-import { createClient } from "@supabase/supabase-js";
-import { NextRequest, NextResponse } from "next/server";
-import { randomBytes } from "crypto";
+// import { createClient } from "@supabase/supabase-js";
+// import { NextRequest, NextResponse } from "next/server";
+// import { randomBytes } from "crypto";
 
-// Generate unique message ID
-function generateMessageId(): string {
-  return `msg_${randomBytes(8).toString("hex")}`;
-}
+// // Generate unique message ID
+// function generateMessageId(): string {
+//   return `msg_${randomBytes(8).toString("hex")}`;
+// }
 
-export async function POST(request: NextRequest) {
-  try {
-    const { sessionId, question } = await request.json();
+// export async function POST(request: NextRequest) {
+//   try {
+//     const { sessionId, question } = await request.json();
 
-    console.log("📥 API received chat request:", { sessionId, question });
+//     console.log("📥 API received chat request:", { sessionId, question });
 
-    // Validate inputs
-    if (!sessionId || typeof sessionId !== "string") {
-      console.error("❌ Missing sessionId");
-      return NextResponse.json(
-        { error: "Session ID is required" },
-        { status: 400 }
-      );
-    }
+//     // Validate inputs
+//     if (!sessionId || typeof sessionId !== "string") {
+//       console.error("❌ Missing sessionId");
+//       return NextResponse.json(
+//         { error: "Session ID is required" },
+//         { status: 400 }
+//       );
+//     }
 
-    if (!question || typeof question !== "string") {
-      console.error("❌ Missing question");
-      return NextResponse.json(
-        { error: "Question is required" },
-        { status: 400 }
-      );
-    }
+//     if (!question || typeof question !== "string") {
+//       console.error("❌ Missing question");
+//       return NextResponse.json(
+//         { error: "Question is required" },
+//         { status: 400 }
+//       );
+//     }
 
-    // Initialize Supabase client with private key for secure backend communication
-    const supabase = createClient(
-      process.env.SUPABASE_URL!,
-      process.env.SUPABASE_PRIVATE_KEY!,
-      {
-        realtime: {
-          params: {
-            apikey: process.env.SUPABASE_PRIVATE_KEY!, // Explicitly pass the API key
-          },
-        },
-        auth: {
-          persistSession: false,
-        },
-      }
-    );
+//     // Initialize Supabase client with private key for secure backend communication
+//     const supabase = createClient(
+//       process.env.SUPABASE_URL!,
+//       process.env.SUPABASE_PRIVATE_KEY!,
+//       {
+//         realtime: {
+//           params: {
+//             apikey: process.env.SUPABASE_PRIVATE_KEY!, // Explicitly pass the API key
+//           },
+//         },
+//         auth: {
+//           persistSession: false,
+//         },
+//       }
+//     );
 
-    // Create channel for this session with matching configuration
-    const channel = supabase.channel(`session:${sessionId}`, {
-      config: {
-        broadcast: {
-          self: false, // Don't receive own broadcasts
-          ack: true,   // Wait for acknowledgment
-        },
-        private: false, // Use public channel (must match backend configuration)
-      },
-    });
-    const messageId = generateMessageId();
+//     // Create channel for this session with matching configuration
+//     const channel = supabase.channel(`session:${sessionId}`, {
+//       config: {
+//         broadcast: {
+//           self: false, // Don't receive own broadcasts
+//           ack: true,   // Wait for acknowledgment
+//         },
+//         private: false, // Use public channel (must match backend configuration)
+//       },
+//     });
+//     const messageId = generateMessageId();
 
-    console.log("📡 Subscribing to Supabase channel:", `session:${sessionId}`);
+//     console.log("📡 Subscribing to Supabase channel:", `session:${sessionId}`);
 
-    // Subscribe first
-    await channel.subscribe();
+//     // Subscribe first
+//     await channel.subscribe();
 
-    console.log("📤 Broadcasting question to channel with messageId:", messageId);
+//     console.log("📤 Broadcasting question to channel with messageId:", messageId);
 
-    // Send question via Supabase Broadcast (control signal only)
-    await channel.send({
-      type: 'broadcast',
-      event: 'question',
-      payload: {
-        question,
-        messageId
-      }
-    });
+//     // Send question via Supabase Broadcast (control signal only)
+//     await channel.send({
+//       type: 'broadcast',
+//       event: 'question',
+//       payload: {
+//         question,
+//         messageId
+//       }
+//     });
 
-    console.log("✅ Question broadcast successful");
+//     console.log("✅ Question broadcast successful");
 
-    // Unsubscribe after sending
-    await channel.unsubscribe();
+//     // Unsubscribe after sending
+//     await channel.unsubscribe();
 
-    // Return the message ID for tracking
-    return NextResponse.json({
-      messageId,
-      sessionId
-    });
+//     // Return the message ID for tracking
+//     return NextResponse.json({
+//       messageId,
+//       sessionId
+//     });
 
-  } catch (error: any) {
-    console.error("Failed to trigger chat task:", error);
-    return NextResponse.json(
-      { error: error.message || "Failed to start chat" },
-      { status: 500 }
-    );
-  }
-}
+//   } catch (error: any) {
+//     console.error("Failed to trigger chat task:", error);
+//     return NextResponse.json(
+//       { error: error.message || "Failed to start chat" },
+//       { status: 500 }
+//     );
+//   }
+// }