feat: parse tech stack from Algora and add integration tests

supabase/functions/runtime-opportunity-scout/index.ts

@@ -13,9 +13,6 @@ const corsHeaders = {
   "Access-Control-Allow-Headers": "Content-Type, Authorization, X-Client-Info, Apikey",
 };
 
-const SUPABASE_URL = Deno.env.get("SUPABASE_URL")!;
-const SERVICE_ROLE = Deno.env.get("SUPABASE_SERVICE_ROLE_KEY")!;
-
 const UA = "runtime-opportunity-scout/1.0 (+open-source-federation)";
 const FETCH_TIMEOUT_MS = 9000;
 
@@ -25,6 +22,7 @@ type Opportunity = {
   title: string;
   url: string;
   reward_usd: number | null;
+  tech_stack: string[] | null;
   raw: Record<string, unknown>;
 };
 
@@ -132,6 +130,7 @@ async function fetchGitcoin(): Promise<Opportunity[]> {
       title: name,
       url,
       reward_usd: reward,
+      tech_stack: null,
       raw: {
         round_id: id,
         chain_id: chainId,
@@ -184,6 +183,7 @@ async function fetchGithubBounties(): Promise<Opportunity[]> {
         title,
         url: html,
         reward_usd: reward,
+        tech_stack: labels,
         raw: {
           repo,
           number: Number(it.number ?? 0),
@@ -227,11 +227,17 @@ async function fetchAlgora(): Promise<Opportunity[]> {
     } else {
       reward = extractUsd(title);
     }
+    const languages = Array.isArray(it.languages)
+      ? (it.languages as string[])
+      : Array.isArray(it.tags)
+      ? (it.tags as string[])
+      : null;
     out.push({
       source: "algora",
       title: title || `Algora bounty`,
       url,
       reward_usd: reward,
+      tech_stack: languages,
       raw: { status: String(it.status || ""), org: String(it.org || it.organization || "") },
     });
   }
@@ -240,7 +246,7 @@ async function fetchAlgora(): Promise<Opportunity[]> {
 
 // Queue one real opportunity into runtime_jobs, idempotent on task_id.
 async function queueOpportunity(
-  sb: ReturnType<typeof createClient>,
+  sb: any,
   prefix: string,
   opp: Opportunity,
 ): Promise<"inserted" | "skipped"> {
@@ -256,7 +262,7 @@ async function queueOpportunity(
   const taskKind = opp.reward_usd != null ? "bounty_solving" : "research";
   const priority = rewardPriority(opp.reward_usd);
 
-  const { error } = await sb.from("runtime_jobs").insert({
+  const { error } = await (sb.from("runtime_jobs") as any).insert({
     task_id: taskId,
     agent_role: "research_agent_external",
     status: "queued",
@@ -271,6 +277,7 @@ async function queueOpportunity(
       url: opp.url,
       title: opp.title,
       reward_usd: opp.reward_usd,
+      tech_stack: opp.tech_stack,
       raw: opp.raw,
     },
   });
@@ -291,7 +298,9 @@ const SOURCES: Array<{ name: string; prefix: string; fn: () => Promise<Opportuni
 Deno.serve(async (req: Request) => {
   if (req.method === "OPTIONS") return new Response(null, { status: 200, headers: corsHeaders });
   try {
-    const sb = createClient(SUPABASE_URL, SERVICE_ROLE, { auth: { persistSession: false, autoRefreshToken: false } });
+    const supabaseUrl = Deno.env.get("SUPABASE_URL")!;
+    const serviceRole = Deno.env.get("SUPABASE_SERVICE_ROLE_KEY")!;
+    const sb = createClient(supabaseUrl, serviceRole, { auth: { persistSession: false, autoRefreshToken: false } });
 
     const reports: SourceReport[] = [];
     let totalInserted = 0;

tests/opportunity-scout.test.ts

@@ -0,0 +1,134 @@
+import { assertEquals } from "https://deno.land/std@0.224.0/assert/mod.ts";
+
+// Set environment variables for Deno test execution
+Deno.env.set("SUPABASE_URL", "https://dummy.supabase.co");
+Deno.env.set("SUPABASE_SERVICE_ROLE_KEY", "dummy-key");
+
+// Store original fetch for local request pass-through
+const originalFetch = globalThis.fetch;
+
+// Capture database inserts to assert correctness
+const dbInserts: any[] = [];
+let selectCallCount = 0;
+
+// Mock external HTTP endpoints
+globalThis.fetch = async (input, init) => {
+  const url = typeof input === "string" ? input : (input instanceof URL ? input.href : input.url);
+
+  // Local server requests pass through
+  if (url.includes("localhost:8000") || url.includes("127.0.0.1:8000")) {
+    return await originalFetch(input, init);
+  }
+
+  // 1. Mock Supabase REST SELECT (check existing job)
+  if (url.includes("/rest/v1/runtime_jobs") && init?.method === "GET") {
+    selectCallCount++;
+    // Simulate that the job does not exist for the first few checks
+    // Return empty list so scout will insert
+    return new Response(JSON.stringify(null), {
+      status: 200,
+      headers: { "Content-Type": "application/json" }
+    });
+  }
+
+  // 2. Mock Supabase REST INSERT
+  if (url.includes("/rest/v1/runtime_jobs") && init?.method === "POST") {
+    const body = JSON.parse(String(init.body));
+    dbInserts.push(body);
+    return new Response(JSON.stringify({ success: true }), {
+      status: 201,
+      headers: { "Content-Type": "application/json" }
+    });
+  }
+
+  // 3. Mock Gitcoin Grants GraphQL endpoint
+  if (url.includes("grants-stack-indexer-v2.gitcoin.co/graphql")) {
+    return new Response(JSON.stringify({
+      data: {
+        rounds: [
+          {
+            id: "round-1",
+            chainId: "137",
+            roundMetadata: { name: "Gitcoin Polygon Round" },
+            matchAmountInUsd: 1500,
+            totalAmountDonatedInUsd: 500,
+            uniqueDonorsCount: 8,
+            donationsStartTime: "2026-06-01T00:00:00Z",
+            donationsEndTime: "2026-06-30T00:00:00Z"
+          }
+        ]
+      }
+    }), { status: 200, headers: { "Content-Type": "application/json" } });
+  }
+
+  // 4. Mock GitHub Search Issues API
+  if (url.includes("api.github.com/search/issues")) {
+    return new Response(JSON.stringify({
+      items: [
+        {
+          html_url: "https://github.com/some/repo/issues/10",
+          title: "Fix logic error - $100 reward",
+          body: "Bounty of $100 available.",
+          repository_url: "https://api.github.com/repos/some/repo",
+          number: 10,
+          state: "open",
+          labels: [{ name: "bounty" }],
+          comments: 3,
+          updated_at: "2026-07-04T12:00:00Z"
+        }
+      ]
+    }), { status: 200, headers: { "Content-Type": "application/json" } });
+  }
+
+  // 5. Mock Algora API endpoint
+  if (url.includes("algora.io/api/bounties")) {
+    return new Response(JSON.stringify([
+      {
+        url: "https://github.com/algora/repo/issues/42",
+        title: "Implement Spec Kit integration",
+        reward: { amount: 15000 },
+        languages: ["TypeScript", "Go"],
+        status: "open",
+        org: "algora-org"
+      }
+    ]), { status: 200, headers: { "Content-Type": "application/json" } });
+  }
+
+  return new Response("Not Mocked", { status: 404 });
+};
+
+// Start local server by importing index.ts
+import "../supabase/functions/runtime-opportunity-scout/index.ts";
+
+Deno.test({
+  name: "Opportunity Scout - Integration Test",
+  async fn() {
+    // Call the local server start endpoint
+    const res = await originalFetch("http://localhost:8000", {
+      method: "POST"
+    });
+
+    assertEquals(res.status, 200);
+    const json = await res.json();
+    console.log("TEST RESPONSE:", json);
+    assertEquals(json.ok, true);
+
+    // Assert we processed the sources correctly
+    const gitcoinReport = json.sources.find((s: any) => s.name === "gitcoin");
+    const githubReport = json.sources.find((s: any) => s.name === "github");
+    const algoraReport = json.sources.find((s: any) => s.name === "algora");
+
+    assertEquals(gitcoinReport?.fetched, 1);
+    assertEquals(githubReport?.fetched, 1);
+    assertEquals(algoraReport?.fetched, 1);
+
+    // Assert database insertion contents for Algora
+    const algoraInsert = dbInserts.find((x: any) => x.scope === "algora");
+    assertEquals(algoraInsert.target, "https://github.com/algora/repo/issues/42");
+    assertEquals(algoraInsert.payload.reward_usd, 150);
+    assertEquals(algoraInsert.payload.title, "Implement Spec Kit integration");
+
+    // VERIFY TECH STACK IS PARSED CORRECTLY
+    assertEquals(algoraInsert.payload.tech_stack, ["TypeScript", "Go"]);
+  }
+});