Sync: dev with main

.github/workflows/cd-dev.yml

@@ -0,0 +1,64 @@
+name: Deploy Kaapi Dev to EC2
+
+on:
+  push:
+    branches:
+      - dev
+
+jobs:
+  deploy:
+    runs-on: ubuntu-latest
+    environment: AWS_ENV
+
+    permissions:
+      packages: write
+      contents: read
+      attestations: write
+      id-token: write
+
+    steps:
+      - name: Checkout Repository
+        uses: actions/checkout@v6
+
+      - name: Configure AWS credentials
+        uses: aws-actions/configure-aws-credentials@v6
+        with:
+          role-to-assume: ${{ secrets.AWS_ROLE_ARN }}
+          aws-region: ${{ secrets.AWS_REGION }}
+
+      - name: Deploy via SSM
+        id: ssm
+        env:
+          BUILD_DIRECTORY: ${{ secrets.DEV_BUILD_DIRECTORY }}
+          APP_NAME: ${{ secrets.DEV_PM2_APP_NAME }}
+          AWS_REGION: ${{ secrets.AWS_REGION }}
+          INSTANCE_ID: ${{ secrets.EC2_STAGING_INSTANCE_ID }}
+          ROOT_USER: ${{ secrets.USER }}
+        run: |
+          REMOTE_CMD="export HOME=/home/$ROOT_USER && export NVM_DIR="/home/$ROOT_USER/.nvm" && [ -s "\$NVM_DIR/nvm.sh" ] && \. "\$NVM_DIR/nvm.sh" && git config --global --add safe.directory ${BUILD_DIRECTORY} && set -e && cd ${BUILD_DIRECTORY} && git pull origin dev && npm ci && npm run build && sudo -iu ${ROOT_USER} pm2 restart ${APP_NAME}"
+          CMD_ID=$(aws ssm send-command \
+            --instance-ids "$INSTANCE_ID" \
+            --document-name "AWS-RunShellScript" \
+            --parameters commands="[\"$REMOTE_CMD\"]" \
+            --region "$AWS_REGION" \
+            --query 'Command.CommandId' \
+            --output text)
+          echo "cmd_id=$CMD_ID" >> "$GITHUB_OUTPUT"
+
+      - name: Wait for SSM command to finish
+        env:
+          INSTANCE_ID: ${{ secrets.EC2_STAGING_INSTANCE_ID }}
+          CMD_ID: ${{ steps.ssm.outputs.cmd_id }}
+        run: |
+          WAIT_EXIT=0
+          aws ssm wait command-executed \
+            --command-id "$CMD_ID" \
+            --instance-id "$INSTANCE_ID" || WAIT_EXIT=$?
+
+          aws ssm get-command-invocation \
+            --command-id "$CMD_ID" \
+            --instance-id "$INSTANCE_ID" \
+            --query '{Status:Status,Stdout:StandardOutputContent,Stderr:StandardErrorContent}' \
+            --output json
+
+          exit $WAIT_EXIT

app/(main)/assessment/page.tsx

@@ -0,0 +1,19 @@
+"use client";
+
+import { Suspense } from "react";
+import { Loader } from "@/app/components/ui";
+import PageLayout from "@/app/components/assessment/PageLayout";
+import { useAssessmentWorkflow } from "@/app/hooks/useAssessmentWorkflow";
+
+function PageContent() {
+  const layoutProps = useAssessmentWorkflow();
+  return <PageLayout {...layoutProps} />;
+}
+
+export default function Page() {
+  return (
+    <Suspense fallback={<Loader size="lg" message="Loading..." fullScreen />}>
+      <PageContent />
+    </Suspense>
+  );
+}

app/(main)/assessment/results/[runId]/page.tsx

@@ -0,0 +1,109 @@
+"use client";
+
+import { useEffect, useState } from "react";
+import { useParams, useSearchParams } from "next/navigation";
+import dynamic from "next/dynamic";
+import { Loader } from "@/app/components/ui";
+import { useToast } from "@/app/hooks/useToast";
+import { useAuth } from "@/app/lib/context/AuthContext";
+import { apiFetch } from "@/app/lib/apiClient";
+import { jsonResultsToTableData } from "@/app/lib/assessment/results";
+import { SPREADSHEET_PREVIEW_ROW_LIMIT } from "@/app/lib/assessment/constants";
+
+const SpreadsheetView = dynamic(
+  () => import("@/app/components/assessment/SpreadsheetView"),
+  {
+    ssr: false,
+    loading: () => (
+      <div className="w-full h-screen flex items-center justify-center bg-bg-primary">
+        <Loader size="lg" message="Loading spreadsheet..." />
+      </div>
+    ),
+  },
+);
+
+export default function AssessmentResultsPage() {
+  const params = useParams<{ runId: string }>();
+  const searchParams = useSearchParams();
+  const toast = useToast();
+  const { apiKeys, isAuthenticated, isHydrated } = useAuth();
+  const apiKey = apiKeys[0]?.key ?? "";
+
+  const [headers, setHeaders] = useState<string[] | null>(null);
+  const [rows, setRows] = useState<string[][] | null>(null);
+  const [error, setError] = useState<string | null>(null);
+
+  const runId = Number(params?.runId);
+  const title = searchParams.get("title") ?? `Run ${runId}`;
+
+  useEffect(() => {
+    if (!isHydrated) return;
+    if (!isAuthenticated) {
+      setError("You must be signed in to view this run.");
+      return;
+    }
+    if (!Number.isFinite(runId) || runId <= 0) {
+      setError("Invalid run id.");
+      return;
+    }
+
+    let cancelled = false;
+    (async () => {
+      try {
+        const json = await apiFetch<
+          { data?: Record<string, unknown>[] } | Record<string, unknown>[]
+        >(`/api/assessment/runs/${runId}/results?export_format=json`, apiKey);
+        const results: Record<string, unknown>[] = Array.isArray(json)
+          ? json
+          : json.data || [];
+        const table = jsonResultsToTableData(results, {
+          rowLimit: SPREADSHEET_PREVIEW_ROW_LIMIT,
+        });
+        if (cancelled) return;
+        if (results.length > SPREADSHEET_PREVIEW_ROW_LIMIT) {
+          toast.warning(
+            `Preview capped at ${SPREADSHEET_PREVIEW_ROW_LIMIT} rows. Download CSV for full data.`,
+          );
+        }
+        setHeaders(table.headers);
+        setRows(table.rows);
+      } catch (err) {
+        if (cancelled) return;
+        const msg =
+          err instanceof Error ? err.message : "Failed to load results";
+        setError(msg);
+        toast.error(msg);
+      }
+    })();
+
+    return () => {
+      cancelled = true;
+    };
+  }, [apiKey, isAuthenticated, isHydrated, runId, toast]);
+
+  if (error) {
+    return (
+      <div className="w-full h-screen flex items-center justify-center bg-bg-primary">
+        <p className="text-sm text-text-secondary">{error}</p>
+      </div>
+    );
+  }
+
+  if (!headers || !rows) {
+    return (
+      <div className="w-full h-screen flex items-center justify-center bg-bg-primary">
+        <Loader size="lg" message="Loading results..." />
+      </div>
+    );
+  }
+
+  return (
+    <SpreadsheetView
+      runId={runId}
+      title={title}
+      subtitle={`${rows.length} rows · ${headers.length} columns`}
+      headers={headers}
+      rows={rows}
+    />
+  );
+}

app/(main)/configurations/page.tsx

@@ -24,7 +24,7 @@ import {
   configState,
   pendingVersionLoads,
   pendingSingleVersionLoads,
-} from "@/app/lib/store/configStore";
+} from "@/app/lib/store/config";
 import { flattenConfigVersion } from "@/app/lib/utils";
 import {
   SearchIcon,

app/(main)/configurations/prompt-editor/page.tsx

@@ -21,10 +21,10 @@
 import { useConfigs } from "@/app/hooks";
 import { useConfigPersistence } from "@/app/hooks/useConfigPersistence";
 import { SavedConfig, ConfigVersionItems } from "@/app/lib/types/configs";
-import { configState } from "@/app/lib/store/configStore";
+import { configState } from "@/app/lib/store/config";
 import { DEFAULT_CONFIG } from "@/app/lib/constants";
 
 function PromptEditorContent() {
   const searchParams = useSearchParams();
   const { sidebarCollapsed } = useApp();
   const { activeKey } = useAuth();

app/(main)/datasets/page.tsx

@@ -8,20 +8,20 @@
 import { useState, useEffect, useCallback } from "react";
 import { useAuth } from "@/app/lib/context/AuthContext";
 import { useApp } from "@/app/lib/context/AppContext";
+import { Dataset } from "@/app/lib/types/dataset";
 import { apiFetch } from "@/app/lib/apiClient";
 import Sidebar from "@/app/components/Sidebar";
 import { PageHeader } from "@/app/components";
 import { useToast } from "@/app/hooks/useToast";
 import DatasetListing from "@/app/components/datasets/DatasetListing";
 import UploadDatasetModal from "@/app/components/datasets/UploadDatasetModal";
 import DeleteDatasetModal from "@/app/components/datasets/DeleteDatasetModal";
-import { Dataset } from "@/app/lib/types/dataset";
 
 export const DATASETS_STORAGE_KEY = "kaapi_datasets";
 
 const ITEMS_PER_PAGE = 10;
 
 export default function Datasets() {
   const toast = useToast();
   const { sidebarCollapsed } = useApp();
   const { activeKey: apiKey, isAuthenticated } = useAuth();

app/(main)/keystore/page.tsx

@@ -16,8 +16,6 @@ import { useToast } from "@/app/hooks/useToast";
 import { apiFetch } from "@/app/lib/apiClient";
 import { APIKey } from "@/app/lib/types/credentials";
 
-export const STORAGE_KEY = "kaapi_api_keys";
-
 export default function KaapiKeystore() {
   const { sidebarCollapsed } = useApp();
   const { apiKeys, addKey, removeKey: removeApiKey } = useAuth();

app/api/_routeProxy.ts

@@ -0,0 +1,93 @@
+import "server-only";
+
+import { NextResponse } from "next/server";
+import { apiClient } from "@/app/lib/apiClient";
+
+const DOWNLOAD_CONTENT_TYPE_HINTS = [
+  "text/csv",
+  "spreadsheetml",
+  "octet-stream",
+  "application/zip",
+];
+
+function isDownloadContentType(contentType: string): boolean {
+  return DOWNLOAD_CONTENT_TYPE_HINTS.some((hint) => contentType.includes(hint));
+}
+
+async function safeParseJson(
+  response: Response,
+): Promise<Record<string, unknown> | unknown[] | null> {
+  const text = response.status === 204 ? "" : await response.text();
+  if (!text) return null;
+
+  try {
+    return JSON.parse(text) as Record<string, unknown> | unknown[];
+  } catch {
+    return null;
+  }
+}
+
+async function toDownloadResponse(
+  response: Response,
+): Promise<NextResponse | null> {
+  const contentType = response.headers.get("content-type") || "";
+  if (!isDownloadContentType(contentType)) {
+    return null;
+  }
+
+  const blob = await response.blob();
+  const headers = new Headers();
+  headers.set("Content-Type", contentType);
+
+  const disposition = response.headers.get("content-disposition");
+  if (disposition) {
+    headers.set("Content-Disposition", disposition);
+  }
+
+  return new NextResponse(blob, { status: response.status, headers });
+}
+
+export function withQueryParams(
+  endpoint: string,
+  queryParams: URLSearchParams,
+): string {
+  const query = queryParams.toString();
+  return query ? `${endpoint}?${query}` : endpoint;
+}
+
+export async function proxyJsonResponse(
+  request: Request,
+  endpoint: string,
+  init: RequestInit = {},
+): Promise<NextResponse> {
+  const { status, data } = await apiClient(request, endpoint, init);
+  return NextResponse.json(data, { status });
+}
+
+export async function proxyDownloadOrJsonResponse(
+  request: Request,
+  endpoint: string,
+  init: RequestInit = {},
+): Promise<NextResponse> {
+  const response = await apiClient(request, endpoint, {
+    ...init,
+    responseType: "raw",
+  });
+
+  const downloadResponse = await toDownloadResponse(response);
+  if (downloadResponse) {
+    return downloadResponse;
+  }
+
+  const data = await safeParseJson(response);
+  return NextResponse.json(data, { status: response.status });
+}
+
+export function proxyErrorResponse(
+  logLabel: string,
+  error: unknown,
+  message = "Failed to forward request to backend",
+): NextResponse {
+  console.error(logLabel, error);
+  return NextResponse.json({ error: message }, { status: 500 });
+}

app/api/assessment/assessments/[assessment_id]/results/route.ts

@@ -0,0 +1,32 @@
+// BFF proxy — GET /api/v1/assessment/assessments/:id/results (JSON or file download)
+import { NextRequest } from "next/server";
+import {
+  proxyDownloadOrJsonResponse,
+  proxyErrorResponse,
+  withQueryParams,
+} from "@/app/api/_routeProxy";
+
+export async function GET(
+  request: NextRequest,
+  { params }: { params: Promise<{ assessment_id: string }> },
+) {
+  try {
+    const { assessment_id } = await params;
+    const queryParams = new URLSearchParams(request.nextUrl.searchParams);
+    queryParams.set("get_trace_info", "true");
+    return await proxyDownloadOrJsonResponse(
+      request,
+      withQueryParams(
+        `/api/v1/assessment/assessments/${assessment_id}/results`,
+        queryParams,
+      ),
+      { method: "GET" },
+    );
+  } catch (error: unknown) {
+    return proxyErrorResponse(
+      "Assessment results proxy error:",
+      error,
+      "Failed to forward request",
+    );
+  }
+}

app/api/assessment/assessments/[assessment_id]/retry/route.ts

@@ -0,0 +1,28 @@
+// BFF proxy — POST /api/v1/assessment/assessments/:id/retry
+import { NextRequest, NextResponse } from "next/server";
+import { apiClient } from "@/app/lib/apiClient";
+import type { RouteContext } from "@/app/lib/types/assessment";
+
+export async function POST(
+  request: NextRequest,
+  context: RouteContext<"assessment_id">,
+) {
+  try {
+    const { assessment_id } = await context.params;
+    const { status, data } = await apiClient(
+      request,
+      `/api/v1/assessment/assessments/${assessment_id}/retry`,
+      { method: "POST" },
+    );
+
+    return NextResponse.json(data, { status });
+  } catch (error: unknown) {
+    console.error("Assessment retry proxy error:", error);
+    return NextResponse.json(
+      {
+        error: "Failed to forward assessment retry request",
+      },
+      { status: 500 },
+    );
+  }
+}