Merge branch 'litellm_internal_staging' of github.com:BerriAI/litellm into litellm_/invite-button-shadcn-decouple-1463e5

This commit is contained in:
Yuneng Jiang 2026-08-15 15:39:54 -07:00
commit 81ec2540b3
No known key found for this signature in database
6 changed files with 519 additions and 67 deletions

View file

@ -71,6 +71,14 @@ class PanwPrismaAirsHandler(CustomGuardrail):
_PROVIDER_NAME = "panw_prisma_airs"
#: AIRS fields withheld from the client-visible error detail.
#: ``response_masked_data`` is the model's own generation. The block branch that builds
#: this detail is only reached when ``mask_response_content`` is False, so echoing it
#: back would hand the caller exactly the text the operator declined to deliver.
#: ``prompt_masked_data`` is deliberately NOT withheld: it is the caller's own input,
#: and it is one of the fields the ticket asks for.
_CLIENT_HIDDEN_SCAN_FIELDS: Final = frozenset({"response_masked_data"})
def __init__(
self,
guardrail_name: str,
@ -632,12 +640,21 @@ class PanwPrismaAirsHandler(CustomGuardrail):
choice.message.function_call.arguments = masked_text
def _build_error_detail(
self, scan_result: Mapping[str, object], is_response: bool = False
self,
scan_result: Mapping[str, object],
is_response: bool = False,
also_hide: str | None = None,
) -> Mapping[str, Mapping[str, object]]:
"""Build enhanced error detail with scan information."""
"""Build enhanced error detail with scan information.
``also_hide`` names one more scan field to withhold, for the caller that knows
its AIRS verdict carries model-generated content under a key that is normally
caller input.
"""
action_type: Final = "Response" if is_response else "Prompt"
code_suffix: Final = "_response_blocked" if is_response else "_blocked"
detection_key: Final = "response_detected" if is_response else "prompt_detected"
hidden_fields: Final = self._CLIENT_HIDDEN_SCAN_FIELDS.union(() if also_hide is None else (also_hide,))
category: Final = scan_result.get("category", "unknown")
default_msg: Final = f"{action_type} blocked by PANW Prisma AI Security policy (Category: {category})"
@ -653,8 +670,13 @@ class PanwPrismaAirsHandler(CustomGuardrail):
},
)
error_detail: Final[dict[str, dict[str, object]]] = {
return {
"error": {
**{
key: value
for key, value in scan_result.items()
if not key.startswith("_") and key not in hidden_fields
},
"message": error_msg,
"type": "guardrail_violation",
"code": f"panw_prisma_airs{code_suffix}",
@ -663,24 +685,6 @@ class PanwPrismaAirsHandler(CustomGuardrail):
}
}
# Add optional fields if present
optional_fields: Final = [
"scan_id",
"report_id",
"profile_name",
"profile_id",
"tr_id",
]
for field in optional_fields:
if scan_result.get(field):
error_detail["error"][field] = scan_result[field]
# Add detection details
if scan_result.get(detection_key):
error_detail["error"][detection_key] = scan_result[detection_key]
return error_detail
def _record_scan_id(self, request_data: dict[str, Any], scan_result: Mapping[str, object]) -> None:
"""Surface the AIRS scan id on the response, so allowed calls are auditable too."""
scan_id: Final = scan_result.get("scan_id")
@ -1481,7 +1485,17 @@ class PanwPrismaAirsHandler(CustomGuardrail):
):
self._set_tool_call_arguments(tool_call, masked_text)
else:
error_detail = self._build_error_detail(scan_result, is_response=is_response)
# tool_event scans are request-side in the AIRS schema, so AIRS returns
# the model's own tool arguments under prompt_masked_data. On a
# response-side block that is generated content, not caller input, and
# the class-level default only withholds response_masked_data — which is
# empty on this path. Withhold it explicitly so the 400 does not become
# the content channel this branch declined to deliver.
error_detail = self._build_error_detail(
scan_result,
is_response=is_response,
also_hide="prompt_masked_data" if is_response else None,
)
raise HTTPException(status_code=400, detail=error_detail)
@staticmethod

View file

@ -5647,6 +5647,235 @@ class TestPanwAirsScanIdExposure:
assert "guardrail_scan_ids" in _UNTRUSTED_METADATA_CONTROL_FIELDS
assert "guardrail_scan_ids" in _UNTRUSTED_ROOT_CONTROL_FIELDS
class TestPanwAirsBlockedErrorDetailPassthrough:
"""Regression tests for the full AIRS scan response on blocks.
Before the fix, the error detail was built from a hardcoded allowlist
(scan_id, report_id, profile_name, profile_id, tr_id, prompt/response_detected),
so audit-relevant fields such as prompt_detection_details, prompt_masked_data,
source, transaction_id and session_id never reached the client.
"""
_FULL_BLOCK_RESPONSE = {
"action": "block",
"category": "malicious",
"scan_id": "b2f0a4be-1f6f-4f9a-9f3d-4b6a9d8b1c0e",
"report_id": "R0000000000000000000",
"tr_id": "test-call-id",
"profile_id": "6f5c9f6e-2d0b-4d3f-8a1e-9b7c5d4e3f2a",
"profile_name": "test_profile",
"source": "prisma_airs",
"transaction_id": "4b8c1e2f-5a6d-4c3b-9e8f-1a2b3c4d5e6f",
"session_id": "3a2b1c0d-9e8f-4a7b-8c6d-5e4f3a2b1c0d",
"timeout": False,
"errors": [],
"prompt_detected": {"dlp": True, "injection": False, "url_cats": False},
"prompt_detection_details": {
"dlp_report": {
"dlp_report_id": "1234567890",
"dlp_profile_name": "Sensitive Content",
"data_pattern_rule1_verdict": "MATCHED",
}
},
"prompt_masked_data": {"data": "my ssn is XXX-XX-XXXX"},
"response_detected": {"dlp": False, "url_cats": False},
"response_detection_details": {},
"response_masked_data": {},
}
@pytest.mark.asyncio
@pytest.mark.parametrize("is_response", [False, True])
async def test_block_returns_every_airs_field(
self, base_handler, user_api_key_dict, safe_prompt_data, is_response
):
response = ModelResponse(
id="test_id",
choices=[
Choices(index=0, message=Message(role="assistant", content="Test response")),
],
model="gpt-3.5-turbo",
)
with patch.object(
base_handler, "_call_panw_api", return_value=copy.deepcopy(self._FULL_BLOCK_RESPONSE)
):
with pytest.raises(HTTPException) as exc_info:
if is_response:
await base_handler.async_post_call_success_hook(
data=safe_prompt_data,
user_api_key_dict=user_api_key_dict,
response=response,
)
else:
await base_handler.async_pre_call_hook(
user_api_key_dict=user_api_key_dict,
cache=None,
data=safe_prompt_data,
call_type="completion",
)
error = exc_info.value.detail["error"]
for field, value in self._FULL_BLOCK_RESPONSE.items():
if field == "category":
continue
if field in PanwPrismaAirsHandler._CLIENT_HIDDEN_SCAN_FIELDS:
# Withheld on purpose, covered by TestPanwAirsErrorDetailWithheldFields
continue
assert error[field] == value, f"{field} missing or altered in blocked-request error"
assert error["category"] == "malicious"
assert error["type"] == "guardrail_violation"
assert error["guardrail"] == "test_panw_airs"
assert error["code"] == ("panw_prisma_airs_response_blocked" if is_response else "panw_prisma_airs_blocked")
assert "PANW Prisma AI Security policy" in error["message"]
def test_internal_control_flags_are_not_leaked(self, base_handler):
detail = base_handler._build_error_detail(
{
"action": "block",
"category": "malicious",
"scan_id": "scan-1",
"_always_block": True,
"_is_transient": True,
}
)
assert "_always_block" not in detail["error"]
assert "_is_transient" not in detail["error"]
assert detail["error"]["scan_id"] == "scan-1"
class TestPanwAirsErrorDetailWithheldFields:
"""The blocked-request passthrough must not become a content channel.
``response_masked_data`` is the model's own generation. The block branch is only
reached when ``mask_response_content`` is False, so echoing it back would hand the
caller exactly the text the operator declined to deliver. ``error`` is AIRS's own
message about the operator's Strata Cloud Manager profile configuration.
``prompt_masked_data`` is deliberately NOT withheld by default: it is the caller's
own input, and it is one of the fields LIT-5638 asks for. The one exception is the
response-side tool-call path, covered by
``TestPanwAirsToolCallBlockWithholdsGeneratedArgs`` below tool_event scans are
request-side in the AIRS schema, so there the key holds model output instead.
"""
@pytest.mark.parametrize("is_response", [False, True])
def test_response_masked_data_never_reaches_client(self, base_handler, is_response):
detail = base_handler._build_error_detail(
{
"action": "block",
"category": "sensitive_data",
"scan_id": "scan-1",
"response_detected": {"dlp": True},
"response_masked_data": {"data": "routing number XXXXXXXXXX"},
"prompt_masked_data": {"data": "my ssn is XXX-XX-XXXX"},
"prompt_detection_details": {"dlp_report": {"dlp_report_id": "1"}},
},
is_response=is_response,
)
error = detail["error"]
assert "response_masked_data" not in error
assert "routing number" not in str(error)
# The audit fields LIT-5638 asks for still come through untouched.
assert error["scan_id"] == "scan-1"
assert error["response_detected"] == {"dlp": True}
assert error["prompt_masked_data"] == {"data": "my ssn is XXX-XX-XXXX"}
assert error["prompt_detection_details"] == {"dlp_report": {"dlp_report_id": "1"}}
def test_upstream_airs_error_field_still_passes_through(self, base_handler):
"""A 2xx AIRS body can carry its own ``error`` (see _call_panw_api's
profile-misconfiguration branch, which only logs and then blocks). It is
diagnostic rather than content, so it stays in the passthrough."""
detail = base_handler._build_error_detail(
{
"action": "block",
"category": "malicious",
"scan_id": "scan-2",
"error": "profile not found",
}
)
assert detail["error"]["error"] == "profile not found"
assert detail["error"]["scan_id"] == "scan-2"
class TestPanwAirsToolCallBlockWithholdsGeneratedArgs:
"""A response-side tool-call block must not ship the model's tool arguments.
``_scan_tool_calls_for_guardrail`` calls AIRS with ``is_response=False`` because
tool_event is request-side in the AIRS schema, so AIRS returns the scanned tool
arguments under ``prompt_masked_data``. When the tool calls being scanned are the
model's own output, that key holds generated content, and the class-level
``_CLIENT_HIDDEN_SCAN_FIELDS`` default (``response_masked_data``, empty on this
path) does not cover it.
"""
MASKED_ARGS = '{"to_account": "XXXXXXXXXX", "amount": 5000}'
SCAN_RESULT = {
"action": "block",
"category": "sensitive_data",
"scan_id": "scan-tool-1",
"prompt_detected": {"dlp": True},
"prompt_masked_data": {"data": MASKED_ARGS},
"response_masked_data": {},
}
@staticmethod
def _tool_call():
return ChatCompletionMessageToolCall(
id="call_1",
type="function",
function=Function(
name="transfer_funds",
arguments='{"to_account": "ACME-VENDOR-001", "amount": 5000}',
),
)
async def _block(self, handler, is_response):
with patch.object(handler, "_call_panw_api", new_callable=AsyncMock) as mock_api:
mock_api.return_value = dict(self.SCAN_RESULT)
with pytest.raises(HTTPException) as exc_info:
await handler._scan_tool_calls_for_guardrail(
tool_calls=[self._tool_call()],
is_response=is_response,
metadata={},
call_id="test-call-id",
request_data={"metadata": {}},
start_time=datetime.now(),
)
return exc_info.value
@pytest.mark.asyncio
async def test_response_side_block_withholds_generated_tool_args(self):
handler = make_handler(mask_response_content=False)
# The block branch is only reached with masking off; guard the premise.
assert handler.mask_response_content is False
exc = await self._block(handler, is_response=True)
error = exc.detail["error"]
assert exc.status_code == 400
assert "prompt_masked_data" not in error
assert self.MASKED_ARGS not in str(error)
# The audit fields LIT-5638 asks for are unaffected.
assert error["scan_id"] == "scan-tool-1"
assert error["prompt_detected"] == {"dlp": True}
@pytest.mark.asyncio
async def test_request_side_block_still_returns_masked_tool_args(self):
"""Caller-supplied tool arguments stay in the verdict — that is the ticket's ask."""
handler = make_handler(mask_request_content=False)
exc = await self._block(handler, is_response=False)
error = exc.detail["error"]
assert error["prompt_masked_data"] == {"data": self.MASKED_ARGS}
assert error["scan_id"] == "scan-tool-1"
if __name__ == "__main__":

View file

@ -46,6 +46,7 @@ vi.mock("@/app/(dashboard)/hooks/models/useModels", () => ({
{ model_name: "gpt-auto", litellm_params: { model: "auto_router/gpt-auto" } },
],
})),
usePlainModelGroups: vi.fn(() => new Set(["prod-claude"])),
}));
vi.mock("@/app/(dashboard)/hooks/models/useModelCostMap", () => ({
@ -72,6 +73,8 @@ const job = (overrides: Partial<ShadowEvalJob> = {}): ShadowEvalJob => ({
job_id: "job-1",
status: "running",
router_name: "claude-auto",
direction: "forward",
baseline_model: null,
judge_model: "anthropic/claude-sonnet-5",
shadow_percentage: 10,
max_turns: 200,
@ -367,6 +370,58 @@ describe("ShadowEvalSection", () => {
expect(start.mutate).toHaveBeenCalledWith(expectedBody);
});
it("requires a baseline model in reverse mode and submits it, while forward mode never shows the picker", async () => {
const user = userEvent.setup();
const { start } = mockHooks({});
render(<ShadowEvalSection />);
expect(screen.queryByPlaceholderText("Select a baseline model")).not.toBeInTheDocument();
await user.click(screen.getByText("Adoption check: key's traffic vs the router"));
await user.click(await screen.findByText("Regression check: router's picks vs a baseline"));
await user.click(screen.getByPlaceholderText("Search keys by alias"));
await user.click(await screen.findByText("prod-alpha"));
await user.click(screen.getByPlaceholderText("Select an auto-router"));
await user.click(await screen.findByText("gpt-auto"));
await user.click(screen.getByPlaceholderText("Select a judge model"));
await user.click(await screen.findByRole("option", { name: /anthropic\/claude-sonnet-5/ }));
expect(screen.getByText("Start shadow eval")).toBeDisabled();
await user.click(screen.getByPlaceholderText("Select a baseline model"));
expect(await screen.findByRole("option", { name: /openai\/gpt-4o/ })).toBeInTheDocument();
await user.click(screen.getByRole("option", { name: /prod-claude/ }));
await user.click(screen.getByText("Start shadow eval"));
const expectedBody = {
api_key_id: "hash-alpha",
router_name: "gpt-auto",
direction: "reverse",
baseline_model: "prod-claude",
shadow_percentage: 10,
duration_days: 7,
max_turns: 200,
judge_model: "anthropic/claude-sonnet-5",
};
expect(start.mutate).toHaveBeenCalledWith(expectedBody);
});
it("flips the arm labels and headline for a reverse job's results", () => {
const j = job({ direction: "reverse", baseline_model: "openai/gpt-4o" });
mockHooks({ jobs: [j], detailsById: { "job-1": j } });
render(<ShadowEvalSection />);
expect(screen.getByText(/on 10% of its traffic/)).toBeInTheDocument();
expect(screen.getByText("Router matched or beat the baseline")).toBeInTheDocument();
expect(screen.getByText("52.0%")).toBeInTheDocument();
expect(screen.getByText(/Router won 30.0%/)).toBeInTheDocument();
expect(screen.getByText(/Baseline won 48.0%/)).toBeInTheDocument();
expect(screen.getAllByText("Baseline wins")).toHaveLength(2);
expect(screen.getByText("Router pick")).toBeInTheDocument();
expect(screen.queryByText(/Current model/)).not.toBeInTheDocument();
expect(screen.queryByText("Compared against")).not.toBeInTheDocument();
});
it("keeps an older job's verdicts reachable through the previous evaluations list", async () => {
const user = userEvent.setup();
const emptyOverrides: Partial<ShadowEvalJob> = {

View file

@ -5,7 +5,7 @@ import React, { useMemo, useState } from "react";
import { useInfiniteKeys } from "@/app/(dashboard)/hooks/keys/useKeys";
import useAuthorized from "@/app/(dashboard)/hooks/useAuthorized";
import { useModelCostMap } from "@/app/(dashboard)/hooks/models/useModelCostMap";
import { useAutoRouters } from "@/app/(dashboard)/hooks/models/useModels";
import { useAutoRouters, usePlainModelGroups } from "@/app/(dashboard)/hooks/models/useModels";
import { PaginatedSearchSelect } from "@/components/shared/PaginatedSearchSelect";
import { SearchSelect, type SearchSelectOption } from "@/components/shared/SearchSelect";
import { Badge } from "@/components/ui/badge";
@ -31,6 +31,37 @@ const pct = (value: number): string => `${value.toFixed(1)}%`;
const MIN_TURNS_FOR_CONFIDENCE = 30;
type ShadowEvalDirection = ShadowEvalJob["direction"];
const otherArmLabel = (direction: ShadowEvalDirection): string =>
direction === "reverse" ? "Baseline" : "Current model";
const routerWinRate = (direction: ShadowEvalDirection, slice: ShadowEvalSlice): number =>
direction === "reverse" ? slice.real_win_rate_pct : slice.shadow_win_rate_pct;
const otherArmWinRate = (direction: ShadowEvalDirection, slice: ShadowEvalSlice): number =>
direction === "reverse" ? slice.shadow_win_rate_pct : slice.real_win_rate_pct;
const routerMatchedOrBeatPct = (
direction: ShadowEvalDirection,
results: NonNullable<ShadowEvalJob["results"]>,
): number =>
direction === "reverse"
? 100 - results.overall_shadow_win_rate_pct
: results.overall_shadow_win_rate_pct + results.overall_tie_rate_pct;
const jobHeadline = (job: ShadowEvalJob): React.ReactNode =>
job.direction === "reverse" ? (
<>
Comparing <span className="font-mono text-xs">{job.router_name}</span> to{" "}
<span className="font-mono text-xs">{job.baseline_model}</span> on {job.shadow_percentage}% of its traffic
</>
) : (
<>
Shadowing {job.shadow_percentage}% via <span className="font-mono text-xs">{job.router_name}</span>
</>
);
const isActive = (job: ShadowEvalJob): boolean => job.status === "running";
const endsIn = (endsAt: string | null | undefined): string | null => {
@ -54,16 +85,22 @@ const StatusBadge: React.FC<{ status: string }> = ({ status }) => (
</Badge>
);
const SliceTable: React.FC<{ groupHeader: string; slices: readonly ShadowEvalSlice[] }> = ({ groupHeader, slices }) => (
const SliceTable: React.FC<{
groupHeader: string;
direction: ShadowEvalDirection;
slices: readonly ShadowEvalSlice[];
}> = ({ groupHeader, direction, slices }) => (
<Table>
<TableHeader>
<TableRow>
<TableHead>{groupHeader}</TableHead>
{["Judged turns", "Router wins", "Current model wins", "Ties", "Judge confidence"].map((label) => (
<TableHead key={label} className="text-right">
{label}
</TableHead>
))}
{["Judged turns", "Router wins", `${otherArmLabel(direction)} wins`, "Ties", "Judge confidence"].map(
(label) => (
<TableHead key={label} className="text-right">
{label}
</TableHead>
),
)}
</TableRow>
</TableHeader>
<TableBody>
@ -77,9 +114,9 @@ const SliceTable: React.FC<{ groupHeader: string; slices: readonly ShadowEvalSli
</TableCell>
<TableCell className="text-right tabular-nums">{slice.turn_count.toLocaleString()}</TableCell>
<TableCell className="text-right font-medium tabular-nums text-foreground">
{pct(slice.shadow_win_rate_pct)}
{pct(routerWinRate(direction, slice))}
</TableCell>
<TableCell className="text-right tabular-nums">{pct(slice.real_win_rate_pct)}</TableCell>
<TableCell className="text-right tabular-nums">{pct(otherArmWinRate(direction, slice))}</TableCell>
<TableCell className="text-right tabular-nums">{pct(slice.tie_rate_pct)}</TableCell>
<TableCell className="text-right tabular-nums">{slice.avg_judge_confidence.toFixed(2)}</TableCell>
</TableRow>
@ -88,13 +125,23 @@ const SliceTable: React.FC<{ groupHeader: string; slices: readonly ShadowEvalSli
</Table>
);
const VerdictBar: React.FC<{ results: NonNullable<ShadowEvalJob["results"]> }> = ({ results }) => {
const routerWins = results.overall_shadow_win_rate_pct;
const VerdictBar: React.FC<{ direction: ShadowEvalDirection; results: NonNullable<ShadowEvalJob["results"]> }> = ({
direction,
results,
}) => {
const ties = results.overall_tie_rate_pct;
const routerWins =
direction === "reverse"
? Math.max(0, 100 - results.overall_shadow_win_rate_pct - ties)
: results.overall_shadow_win_rate_pct;
const segments = [
{ label: "Router won", value: routerWins, fill: "bg-emerald-500" },
{ label: "Tie", value: ties, fill: "bg-emerald-200" },
{ label: "Current model won", value: Math.max(0, 100 - routerWins - ties), fill: "bg-muted-foreground/30" },
{
label: `${otherArmLabel(direction)} won`,
value: Math.max(0, 100 - routerWins - ties),
fill: "bg-muted-foreground/30",
},
];
return (
<div className="space-y-2 border-b px-6 py-4">
@ -133,20 +180,22 @@ const ResultsBody: React.FC<{ job: ShadowEvalJob; resultsError?: boolean }> = ({
<>
<div className="flex flex-col gap-1 border-b px-6 py-4">
<p className="text-[11px] uppercase tracking-wide text-muted-foreground">
Router matched or beat your current model
</p>
<p className="text-3xl font-semibold text-foreground">
{pct(results.overall_shadow_win_rate_pct + results.overall_tie_rate_pct)}
Router matched or beat {job.direction === "reverse" ? "the baseline" : "your current model"}
</p>
<p className="text-3xl font-semibold text-foreground">{pct(routerMatchedOrBeatPct(job.direction, results))}</p>
<p className="text-xs text-muted-foreground">of {(job.judged_count ?? 0).toLocaleString()} judged responses</p>
</div>
<VerdictBar results={results} />
<VerdictBar direction={job.direction} results={results} />
{results.by_current_model.length > 0 && (
<SliceTable groupHeader="Compared against" slices={results.by_current_model} />
<SliceTable
groupHeader={job.direction === "reverse" ? "Router pick" : "Compared against"}
direction={job.direction}
slices={results.by_current_model}
/>
)}
{results.by_tier.length > 0 && (
<div className={results.by_current_model.length > 0 ? "border-t" : ""}>
<SliceTable groupHeader="Prompt difficulty" slices={results.by_tier} />
<SliceTable groupHeader="Prompt difficulty" direction={job.direction} slices={results.by_tier} />
</div>
)}
</>
@ -168,9 +217,7 @@ const JobResults: React.FC<{
<div className="flex items-center gap-3">
<StatusBadge status={job.status} />
<div>
<p className="text-sm font-medium text-foreground">
Shadowing {job.shadow_percentage}% via <span className="font-mono text-xs">{job.router_name}</span>
</p>
<p className="text-sm font-medium text-foreground">{jobHeadline(job)}</p>
<p className="text-xs text-muted-foreground">
{(job.judged_count ?? 0).toLocaleString()} of {job.max_turns.toLocaleString()} turns judged ·{" "}
{(job.error_count ?? 0).toLocaleString()} errored · {usd(job.judge_spend ?? 0)} judge spend
@ -201,25 +248,55 @@ interface CostMapEntry {
mode?: string;
}
const useJudgeModelOptions = (): SearchSelectOption[] => {
const useChatModelNames = (): string[] => {
const { data: costMap } = useModelCostMap();
return useMemo(() => {
if (!costMap) return [];
const chatModels = Object.entries(costMap as Record<string, CostMapEntry>)
.filter(([, value]) => value?.mode === "chat" && value?.litellm_provider)
.map(([key, value]) => (key.startsWith(`${value.litellm_provider}/`) ? key : `${value.litellm_provider}/${key}`));
return [...new Set(chatModels)].toSorted((a, b) => a.localeCompare(b));
}, [costMap]);
};
const useJudgeModelOptions = (): SearchSelectOption[] => {
const chatModels = useChatModelNames();
return useMemo(() => {
const pinned: SearchSelectOption[] = RECOMMENDED_JUDGE_MODELS.map((model) => ({
label: model,
value: model,
sublabel: "Recommended",
}));
if (!costMap) return pinned;
const pinnedNames = new Set<string>(RECOMMENDED_JUDGE_MODELS);
const chatModels = Object.entries(costMap as Record<string, CostMapEntry>)
.filter(([, value]) => value?.mode === "chat" && value?.litellm_provider)
.map(([key, value]) => (key.startsWith(`${value.litellm_provider}/`) ? key : `${value.litellm_provider}/${key}`));
const rest = [...new Set(chatModels)]
.filter((model) => !pinnedNames.has(model))
.toSorted((a, b) => a.localeCompare(b))
.map((model) => ({ label: model, value: model }));
const rest = chatModels.filter((model) => !pinnedNames.has(model)).map((model) => ({ label: model, value: model }));
return [...pinned, ...rest];
}, [costMap]);
}, [chatModels]);
};
const useBaselineModelOptions = (): SearchSelectOption[] => {
const configuredGroups = usePlainModelGroups();
const chatModels = useChatModelNames();
return useMemo(() => {
const configured = [...configuredGroups]
.toSorted((a, b) => a.localeCompare(b))
.map((model) => ({ label: model, value: model, sublabel: "Configured on this gateway" }));
const rest = chatModels
.filter((model) => !configuredGroups.has(model))
.map((model) => ({ label: model, value: model }));
return [...configured, ...rest];
}, [configuredGroups, chatModels]);
};
const DIRECTION_OPTIONS: readonly { value: ShadowEvalDirection; label: string }[] = [
{ value: "forward", label: "Adoption check: key's traffic vs the router" },
{ value: "reverse", label: "Regression check: router's picks vs a baseline" },
] as const;
const START_FORM_DESCRIPTION: Record<ShadowEvalDirection, string> = {
forward:
"Duplicates a sampled slice of the key's traffic through the auto-router and has an LLM judge compare both answers blind. The router's answers are never served to users; judge calls bill to the shadowed key.",
reverse:
"Duplicates a sampled slice of the traffic the auto-router already serves against a fixed baseline model and has an LLM judge compare both answers blind. The baseline's answers are never served to users; judge calls bill to the shadowed key.",
};
const DURATION_OPTIONS = [
@ -282,12 +359,15 @@ const StartForm: React.FC = () => {
const { accessToken } = useAuthorized();
const [apiKeyId, setApiKeyId] = useState("");
const [routerName, setRouterName] = useState("");
const [direction, setDirection] = useState<ShadowEvalDirection>("forward");
const [baselineModel, setBaselineModel] = useState("");
const [percentage, setPercentage] = useState("10");
const [durationDays, setDurationDays] = useState("7");
const [judgeModel, setJudgeModel] = useState("");
const [maxTurns, setMaxTurns] = useState("200");
const { data: autoRouters } = useAutoRouters();
const judgeModelOptions = useJudgeModelOptions();
const baselineModelOptions = useBaselineModelOptions();
const start = useStartShadowEval();
const routerOptions = useMemo<SearchSelectOption[]>(() => {
@ -301,14 +381,17 @@ const StartForm: React.FC = () => {
const percentageValid = parsedPct >= 0.1 && parsedPct <= 100;
const parsedMaxTurns = Number.parseInt(maxTurns, 10);
const maxTurnsValid = parsedMaxTurns >= 1 && parsedMaxTurns <= 2000;
const filled = [apiKeyId, routerName, judgeModel].every((field) => field !== "");
const filled =
[apiKeyId, routerName, judgeModel].every((field) => field !== "") &&
(direction === "forward" || baselineModel !== "");
const boundsValid = percentageValid && maxTurnsValid;
const valid = Boolean(accessToken) && filled && boundsValid;
const handleStart = () => {
const startBody = {
api_key_id: apiKeyId,
router_name: routerName,
direction: "forward" as const,
direction,
...(direction === "reverse" ? { baseline_model: baselineModel } : {}),
shadow_percentage: parsedPct,
duration_days: Number.parseInt(durationDays, 10),
max_turns: parsedMaxTurns,
@ -321,13 +404,27 @@ const StartForm: React.FC = () => {
<Card size="sm">
<CardHeader>
<CardTitle className="text-sm font-medium text-foreground">Start a shadow eval</CardTitle>
<p className="text-xs text-muted-foreground">
Duplicates a sampled slice of the key&apos;s traffic through the auto-router and has an LLM judge compare both
answers blind. The router&apos;s answers are never served to users; judge calls bill to the shadowed key.
</p>
<p className="text-xs text-muted-foreground">{START_FORM_DESCRIPTION[direction]}</p>
</CardHeader>
<CardContent className="space-y-3">
<div className="grid gap-3 sm:grid-cols-3">
<Field label="Direction">
<Select
value={direction}
onValueChange={(v: string | null) => setDirection(v === "reverse" ? "reverse" : "forward")}
>
<SelectTrigger className="w-full">
<SelectValue>{DIRECTION_OPTIONS.find((o) => o.value === direction)?.label}</SelectValue>
</SelectTrigger>
<SelectContent>
{DIRECTION_OPTIONS.map((option) => (
<SelectItem key={option.value} value={option.value}>
{option.label}
</SelectItem>
))}
</SelectContent>
</Select>
</Field>
<Field label="Key to shadow" htmlFor="shadow-eval-key">
<KeySelect value={apiKeyId} onChange={setApiKeyId} />
</Field>
@ -390,6 +487,17 @@ const StartForm: React.FC = () => {
<p className="text-xs text-destructive">Enter a value from 1 to 2000</p>
)}
</Field>
{direction === "reverse" && (
<Field label="Baseline model">
<SearchSelect
options={baselineModelOptions}
value={baselineModel}
onValueChange={setBaselineModel}
placeholder="Select a baseline model"
emptyText="No chat models available"
/>
</Field>
)}
<Field label="Judge model" className="sm:col-span-2">
<SearchSelect
options={judgeModelOptions}
@ -410,7 +518,7 @@ const StartForm: React.FC = () => {
const previousSummary = (job: ShadowEvalJob): string => {
const results = job.results;
if (results) return pct(results.overall_shadow_win_rate_pct + results.overall_tie_rate_pct);
if (results) return pct(routerMatchedOrBeatPct(job.direction, results));
return job.judged_count === 0 ? "no verdicts" : "view results";
};
@ -429,9 +537,7 @@ const PreviousJob: React.FC<{ job: ShadowEvalJob }> = ({ job }) => {
<div className="flex items-center gap-3">
<StatusBadge status={shown.status} />
<div>
<p className="text-sm font-medium text-foreground">
{shown.shadow_percentage}% via <span className="font-mono text-xs">{shown.router_name}</span>
</p>
<p className="text-sm font-medium text-foreground">{jobHeadline(shown)}</p>
<p className="text-xs text-muted-foreground">
{shown.judged_count != null &&
`${shown.judged_count.toLocaleString()} judged · ${(shown.error_count ?? 0).toLocaleString()} errored · ${usd(shown.judge_spend ?? 0)} judge spend · `}
@ -507,8 +613,8 @@ const ShadowEvalSection: React.FC = () => {
<div className="flex flex-wrap items-baseline gap-2">
<h2 className="text-xl font-semibold text-foreground">Shadow eval</h2>
<p className="text-sm text-muted-foreground">
Would the auto-router have answered as well as the models you use today? Find out on your real traffic, before
switching anything.
Blind-judge the auto-router on your real traffic: against the models a key uses today before switching, or
against a fixed baseline after it has switched.
</p>
</div>

View file

@ -5,6 +5,7 @@ import { beforeEach, describe, expect, it, vi } from "vitest";
import {
isAutoRouterDeployment,
selectAutoRouterModelGroups,
selectPlainModelGroups,
useAllProxyModels,
useAutoRouterModelGroups,
useAutoRouters,
@ -977,6 +978,32 @@ describe("selectAutoRouterModelGroups", () => {
});
});
describe("selectPlainModelGroups", () => {
it("keeps only non-auto-router model groups", () => {
const deployments: AutoRouterCandidateDeployment[] = [
{ model_name: "smart-router", litellm_params: { model: "auto_router/complexity_router" } },
{ model_name: "claude-haiku", litellm_params: { model: "anthropic/claude-haiku-4-5" } },
{ model_name: "claude-sonnet", litellm_params: { model: "anthropic/claude-sonnet-4-5" } },
{ model_name: "cheap-router", litellm_params: { model: "auto_router/adaptive_router" } },
];
expect(selectPlainModelGroups(deployments)).toEqual(new Set(["claude-haiku", "claude-sonnet"]));
});
it("drops a group name that also fronts an auto-router deployment", () => {
const deployments: AutoRouterCandidateDeployment[] = [
{ model_name: "shared-name", litellm_params: { model: "auto_router/complexity_router" } },
{ model_name: "shared-name", litellm_params: { model: "anthropic/claude-sonnet-4-5" } },
];
expect(selectPlainModelGroups(deployments)).toEqual(new Set());
});
it("drops deployments that have no public model_name", () => {
expect(selectPlainModelGroups([{ model_name: "", litellm_params: { model: "openai/gpt-4o" } }])).toEqual(new Set());
});
});
describe("useAutoRouterModelGroups", () => {
let queryClient: QueryClient;

View file

@ -123,6 +123,16 @@ export const selectAutoRouterModelGroups = (deployments: AutoRouterCandidateDepl
export const selectAutoRouterDeployments = (deployments: AutoRouterDeployment[]): AutoRouterDeployment[] =>
deployments.filter(isAutoRouterDeployment);
export const selectPlainModelGroups = (deployments: AutoRouterCandidateDeployment[]): ReadonlySet<string> => {
const autoRouterGroups = selectAutoRouterModelGroups(deployments);
return new Set(
deployments
.map((deployment) => deployment.model_name)
.filter((modelName): modelName is string => Boolean(modelName))
.filter((modelName) => !autoRouterGroups.has(modelName)),
);
};
export const fetchAllModelDeployments = async (
accessToken: string,
userId: string,
@ -172,6 +182,17 @@ export const useAutoRouterModelGroups = (): ReadonlySet<string> => {
return data ?? NO_AUTO_ROUTERS;
};
export const usePlainModelGroups = (): ReadonlySet<string> => {
const { accessToken, userId, userRole } = useAuthorized();
const { data } = useQuery<AutoRouterDeployment[], Error, ReadonlySet<string>>({
queryKey: autoRouterListKey(userId, userRole),
queryFn: async () => await fetchAllModelDeployments(accessToken!, userId!, userRole!),
enabled: Boolean(accessToken && userId && userRole),
select: selectPlainModelGroups,
});
return data ?? NO_AUTO_ROUTERS;
};
export const useAutoRouters = (): UseQueryResult<AutoRouterDeployment[], Error> => {
const { accessToken, userId, userRole } = useAuthorized();
return useQuery<AutoRouterDeployment[], Error, AutoRouterDeployment[]>({