/**
 * GET /api/tools/agent-bridge/agents/[id]/mappings   — list model mappings
 * PUT /api/tools/agent-bridge/agents/[id]/mappings   — replace all mappings
 * LOCAL_ONLY: registered in routeGuard.ts
 */
import { AgentBridgeMappingPutSchema } from "@/shared/schemas/agentBridge";
import { getMappingsForAgent, setMappings } from "@/lib/db/agentBridgeMappings";
import { sanitizeErrorMessage } from "@omniroute/open-sse/utils/error";
import { createErrorResponse } from "@/lib/api/errorResponse";

type Params = { params: { id: string } };

export async function GET(_request: Request, { params }: Params): Promise<Response> {
  try {
    const mappings = getMappingsForAgent(params.id);
    return Response.json({ mappings });
  } catch (err) {
    const msg = sanitizeErrorMessage(err instanceof Error ? err.message : String(err));
    return createErrorResponse({ status: 500, message: msg });
  }
}

export async function PUT(request: Request, { params }: Params): Promise<Response> {
  let body: unknown;
  try {
    body = await request.json();
  } catch {
    return createErrorResponse({ status: 400, message: "Invalid JSON body" });
  }

  const parsed = AgentBridgeMappingPutSchema.safeParse(body);
  if (!parsed.success) {
    return createErrorResponse({
      status: 400,
      message: "Invalid request body",
      details: parsed.error.flatten(),
    });
  }

  try {
    setMappings(params.id, parsed.data.mappings);
    const mappings = getMappingsForAgent(params.id);
    return Response.json({ ok: true, mappings });
  } catch (err) {
    const msg = sanitizeErrorMessage(err instanceof Error ? err.message : String(err));
    return createErrorResponse({ status: 500, message: msg });
  }
}