Generated with Hive: Add mock Stakwork prompt_daily_runs endpoint for local dev and testing

src/__tests__/integration/api/mock/stakwork-prompt-daily-runs.test.ts

@@ -0,0 +1,138 @@
+import { describe, test, expect, beforeEach } from "vitest";
+import { NextRequest } from "next/server";
+import { GET } from "@/app/api/mock/stakwork/prompt_daily_runs/route";
+import { mockPromptDailyRunsStore } from "@/app/api/mock/stakwork/prompt_daily_runs/store";
+
+function makeRequest(params: Record<string, string> = {}): NextRequest {
+  const url = new URL("http://localhost/api/mock/stakwork/prompt_daily_runs");
+  for (const [key, value] of Object.entries(params)) {
+    url.searchParams.set(key, value);
+  }
+  return new NextRequest(url.toString());
+}
+
+describe("GET /api/mock/stakwork/prompt_daily_runs", () => {
+  describe("response envelope shape", () => {
+    test("returns correct envelope with success, total, size, prompt_daily_runs", async () => {
+      const res = await GET(makeRequest({ run_date: "2024-01-15" }));
+      expect(res.status).toBe(200);
+
+      const body = await res.json();
+      expect(body.success).toBe(true);
+      expect(body.data).toBeDefined();
+      expect(typeof body.data.total).toBe("number");
+      expect(typeof body.data.size).toBe("number");
+      expect(Array.isArray(body.data.prompt_daily_runs)).toBe(true);
+    });
+
+    test("each row has all required fields", async () => {
+      const res = await GET(makeRequest({ run_date: "2024-01-15" }));
+      const { data } = await res.json();
+
+      for (const row of data.prompt_daily_runs) {
+        expect(row).toHaveProperty("id");
+        expect(row).toHaveProperty("prompt_id");
+        expect(row).toHaveProperty("prompt_version_id");
+        expect(row).toHaveProperty("workflow_id");
+        expect(row).toHaveProperty("customer_id");
+        expect(row).toHaveProperty("run_date");
+        expect(row).toHaveProperty("run_count");
+        expect(row).toHaveProperty("hive_version_id");
+        expect(row).toHaveProperty("created_at");
+        expect(row).toHaveProperty("updated_at");
+      }
+    });
+  });
+
+  describe("filtering by run_date", () => {
+    test("returns only rows matching run_date", async () => {
+      const res = await GET(makeRequest({ run_date: "2024-01-15" }));
+      const { data } = await res.json();
+
+      expect(data.prompt_daily_runs.length).toBeGreaterThan(0);
+      for (const row of data.prompt_daily_runs) {
+        expect(row.run_date).toBe("2024-01-15");
+      }
+    });
+
+    test("returns different rows for a different run_date", async () => {
+      const res = await GET(makeRequest({ run_date: "2024-01-16" }));
+      const { data } = await res.json();
+
+      expect(data.prompt_daily_runs.length).toBeGreaterThan(0);
+      for (const row of data.prompt_daily_runs) {
+        expect(row.run_date).toBe("2024-01-16");
+      }
+    });
+
+    test("returns empty prompt_daily_runs for a date with no rows", async () => {
+      const res = await GET(makeRequest({ run_date: "1999-01-01" }));
+      const { data } = await res.json();
+
+      expect(data.total).toBe(0);
+      expect(data.size).toBe(0);
+      expect(data.prompt_daily_runs).toHaveLength(0);
+    });
+
+    test("total reflects filtered count, not store total", async () => {
+      const allRows = mockPromptDailyRunsStore.filter((r) => r.run_date === "2024-01-15");
+      const res = await GET(makeRequest({ run_date: "2024-01-15" }));
+      const { data } = await res.json();
+
+      expect(data.total).toBe(allRows.length);
+    });
+  });
+
+  describe("pagination", () => {
+    test("page=1 returns first slice", async () => {
+      const res = await GET(makeRequest({ run_date: "2024-01-15", page: "1" }));
+      const { data } = await res.json();
+      expect(data.size).toBe(data.prompt_daily_runs.length);
+    });
+
+    test("page beyond available rows returns empty prompt_daily_runs", async () => {
+      const res = await GET(makeRequest({ run_date: "2024-01-15", page: "9999" }));
+      const { data } = await res.json();
+      expect(data.size).toBe(0);
+      expect(data.prompt_daily_runs).toHaveLength(0);
+    });
+
+    test("size equals the number of items in prompt_daily_runs", async () => {
+      const res = await GET(makeRequest({ run_date: "2024-01-15" }));
+      const { data } = await res.json();
+      expect(data.size).toBe(data.prompt_daily_runs.length);
+    });
+
+    test("no page param defaults to page 1", async () => {
+      const resPage1 = await GET(makeRequest({ run_date: "2024-01-15", page: "1" }));
+      const resDefault = await GET(makeRequest({ run_date: "2024-01-15" }));
+
+      const page1Data = (await resPage1.json()).data;
+      const defaultData = (await resDefault.json()).data;
+
+      expect(defaultData.prompt_daily_runs).toEqual(page1Data.prompt_daily_runs);
+    });
+  });
+
+  describe("store contains unresolvable hive_version_id row", () => {
+    test("store has at least one row with hive_version_id=unresolvable-version-id for negative testing", () => {
+      const unresolvable = mockPromptDailyRunsStore.find(
+        (r) => r.hive_version_id === "unresolvable-version-id"
+      );
+      expect(unresolvable).toBeDefined();
+    });
+
+    test("unresolvable row is still returned by the mock (sync service handles skipping)", async () => {
+      const unresolvableRow = mockPromptDailyRunsStore.find(
+        (r) => r.hive_version_id === "unresolvable-version-id"
+      )!;
+      const res = await GET(makeRequest({ run_date: unresolvableRow.run_date }));
+      const { data } = await res.json();
+
+      const found = data.prompt_daily_runs.find(
+        (r: { hive_version_id: string }) => r.hive_version_id === "unresolvable-version-id"
+      );
+      expect(found).toBeDefined();
+    });
+  });
+});

src/app/api/mock/stakwork/prompt_daily_runs/route.ts

@@ -0,0 +1,35 @@
+import { NextRequest, NextResponse } from "next/server";
+import { mockPromptDailyRunsStore } from "./store";
+export type { MockPromptDailyRunEntry } from "./store";
+
+const PAGE_SIZE = 20;
+
+// ── GET /api/mock/stakwork/prompt_daily_runs ───────────────────────────────────
+// Query params:
+//   run_date  — YYYY-MM-DD to filter by (required in production; defaults to today in mock)
+//   page      — 1-based page number (default: 1)
+//
+// Response envelope (matches real Stakwork contract):
+//   { success: true, data: { total, size, prompt_daily_runs: [...] } }
+export async function GET(request: NextRequest) {
+  const { searchParams } = new URL(request.url);
+  const runDate = searchParams.get("run_date") ?? "";
+  const page = Math.max(1, parseInt(searchParams.get("page") || "1", 10));
+
+  const filtered = runDate
+    ? mockPromptDailyRunsStore.filter((row) => row.run_date === runDate)
+    : mockPromptDailyRunsStore;
+
+  const total = filtered.length;
+  const start = (page - 1) * PAGE_SIZE;
+  const pageItems = filtered.slice(start, start + PAGE_SIZE);
+
+  return NextResponse.json({
+    success: true,
+    data: {
+      total,
+      size: pageItems.length,
+      prompt_daily_runs: pageItems,
+    },
+  });
+}

src/app/api/mock/stakwork/prompt_daily_runs/store.ts

@@ -0,0 +1,66 @@
+export interface MockPromptDailyRunEntry {
+  id: number;
+  prompt_id: number;
+  prompt_version_id: number;
+  workflow_id: number;
+  customer_id: number;
+  run_date: string; // YYYY-MM-DD
+  run_count: number;
+  hive_version_id: string;
+  created_at: string;
+  updated_at: string;
+}
+
+// In-memory store — all rows must have hive_version_id set.
+// Seeded with sample rows: some matching known PromptVersion ids, one unresolvable.
+export const mockPromptDailyRunsStore: MockPromptDailyRunEntry[] = [
+  {
+    id: 1,
+    prompt_id: 1,
+    prompt_version_id: 10,
+    workflow_id: 101,
+    customer_id: 1001,
+    run_date: "2024-01-15",
+    run_count: 42,
+    hive_version_id: "mock-version-id-1",
+    created_at: "2024-01-16T02:00:00Z",
+    updated_at: "2024-01-16T02:00:00Z",
+  },
+  {
+    id: 2,
+    prompt_id: 2,
+    prompt_version_id: 20,
+    workflow_id: 201,
+    customer_id: 1001,
+    run_date: "2024-01-15",
+    run_count: 17,
+    hive_version_id: "mock-version-id-2",
+    created_at: "2024-01-16T02:00:00Z",
+    updated_at: "2024-01-16T02:00:00Z",
+  },
+  {
+    // Unresolvable hive_version_id — for negative-path testing
+    id: 3,
+    prompt_id: 99,
+    prompt_version_id: 990,
+    workflow_id: 999,
+    customer_id: 9999,
+    run_date: "2024-01-15",
+    run_count: 5,
+    hive_version_id: "unresolvable-version-id",
+    created_at: "2024-01-16T02:00:00Z",
+    updated_at: "2024-01-16T02:00:00Z",
+  },
+  {
+    id: 4,
+    prompt_id: 1,
+    prompt_version_id: 10,
+    workflow_id: 101,
+    customer_id: 1001,
+    run_date: "2024-01-16",
+    run_count: 55,
+    hive_version_id: "mock-version-id-1",
+    created_at: "2024-01-17T02:00:00Z",
+    updated_at: "2024-01-17T02:00:00Z",
+  },
+];