mirror of
https://github.com/usestrix/strix.git
synced 2026-08-16 01:16:40 +02:00
Compare commits
2
Commits
d4573a3197
...
21e719a2eb
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
21e719a2eb | ||
|
|
21afdaea9e |
+10
-6
@@ -157,19 +157,23 @@ def _first(query: dict[str, list[str]], key: str) -> str | None:
|
||||
|
||||
|
||||
def _post_form(payload: dict[str, str]) -> dict[str, Any]:
|
||||
detail = ""
|
||||
try:
|
||||
response = requests.post(
|
||||
with requests.post(
|
||||
TOKEN_URL,
|
||||
data=payload,
|
||||
headers={"Accept": "application/json"},
|
||||
timeout=_TOKEN_TIMEOUT,
|
||||
)
|
||||
) as response:
|
||||
status_code = response.status_code
|
||||
body = response.content
|
||||
if status_code >= 400:
|
||||
detail = response.text[:300]
|
||||
except requests.RequestException as exc:
|
||||
raise GrokAuthError("unavailable", str(exc)) from exc
|
||||
if response.status_code >= 400:
|
||||
detail = response.text[:300]
|
||||
raise GrokAuthError("token_http_error", f"HTTP {response.status_code}: {detail}")
|
||||
data = json.loads(response.content or b"{}")
|
||||
if status_code >= 400:
|
||||
raise GrokAuthError("token_http_error", f"HTTP {status_code}: {detail}")
|
||||
data = json.loads(body or b"{}")
|
||||
if not isinstance(data, dict):
|
||||
raise GrokAuthError("bad_response", "token endpoint returned non-object")
|
||||
return data
|
||||
|
||||
@@ -22,6 +22,10 @@ _PROVIDERS: tuple[ModuleType, ...] = (codex, grok)
|
||||
# Human-facing provider names keyed by each module's ``PROVIDER`` constant.
|
||||
_DISPLAY_NAMES: dict[str, str] = {codex.PROVIDER: "ChatGPT", grok.PROVIDER: "Grok"}
|
||||
|
||||
# Prefix LiteLLM keys each provider's model metadata under: ChatGPT models are
|
||||
# mapped bare ("gpt-5.4"), xAI's only provider-qualified ("xai/grok-4").
|
||||
_LITELLM_PREFIXES: dict[str, str] = {codex.PROVIDER: "", grok.PROVIDER: "xai/"}
|
||||
|
||||
|
||||
def provider_for_model(model_name: str | None) -> ModuleType | None:
|
||||
"""Return the subscription provider module that owns ``model_name``'s prefix,
|
||||
@@ -43,3 +47,17 @@ def provider_label(model_name: str | None) -> str | None:
|
||||
if provider is None:
|
||||
return None
|
||||
return _DISPLAY_NAMES.get(provider.PROVIDER)
|
||||
|
||||
|
||||
def litellm_model_name(model_name: str | None) -> str | None:
|
||||
"""``model_name`` rewritten to the name LiteLLM maps metadata under.
|
||||
|
||||
Subscription prefixes are Strix routing labels LiteLLM never maps, so a
|
||||
lookup of "grok/grok-4" (or bare "grok-4") finds nothing. Non-subscription
|
||||
models are returned unchanged.
|
||||
"""
|
||||
provider = provider_for_model(model_name)
|
||||
if provider is None:
|
||||
return model_name
|
||||
prefix = _LITELLM_PREFIXES.get(provider.PROVIDER, "")
|
||||
return f"{prefix}{provider.subscription_model(model_name)}"
|
||||
|
||||
@@ -10,7 +10,7 @@ from typing import Any
|
||||
|
||||
import litellm
|
||||
|
||||
from strix.config import load_settings
|
||||
from strix.config import load_settings, subscription
|
||||
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
@@ -19,7 +19,6 @@ logger = logging.getLogger(__name__)
|
||||
# ``litellm/``, ``ollama/`` ...). Strip a leading provider segment on lookup.
|
||||
_STRIPPABLE_PREFIXES = (
|
||||
"openai/",
|
||||
"chatgpt/",
|
||||
"litellm/",
|
||||
"any-llm/",
|
||||
"ollama/",
|
||||
@@ -30,6 +29,8 @@ _DEFAULT_OUTPUT_TOKENS = 8_192
|
||||
|
||||
|
||||
def _lookup_key(model: str) -> str:
|
||||
if subscription.provider_for_model(model) is not None:
|
||||
return subscription.litellm_model_name(model) or model
|
||||
for prefix in _STRIPPABLE_PREFIXES:
|
||||
if model.startswith(prefix):
|
||||
return model[len(prefix) :]
|
||||
@@ -46,9 +47,12 @@ def _safe_get_model_info(model: str) -> dict[str, Any] | None:
|
||||
@lru_cache(maxsize=128)
|
||||
def _model_info(model: str) -> dict[str, int]:
|
||||
lookup_key = _lookup_key(model)
|
||||
# Provider-qualified ChatGPT lookups may start a synchronous device-login
|
||||
# poll. LiteLLM keys the metadata by the underlying model slug.
|
||||
candidates = (lookup_key,) if model.startswith("chatgpt/") else (model, lookup_key)
|
||||
# Subscription prefixes are never LiteLLM keys, and a provider-qualified
|
||||
# ChatGPT lookup may start a synchronous device-login poll: only ask about
|
||||
# the resolved name.
|
||||
candidates = (
|
||||
(lookup_key,) if subscription.provider_for_model(model) is not None else (model, lookup_key)
|
||||
)
|
||||
for candidate in candidates:
|
||||
info = _safe_get_model_info(candidate)
|
||||
if info is not None:
|
||||
|
||||
@@ -39,6 +39,17 @@ def test_context_window_chatgpt_prefix_skips_provider_auth(
|
||||
context_budget._model_info.cache_clear()
|
||||
|
||||
|
||||
def test_context_window_grok_prefix_resolves_to_xai() -> None:
|
||||
# LiteLLM maps xAI models only provider-qualified: neither "grok/grok-4" nor
|
||||
# bare "grok-4" resolves, so the subscription prefix becomes "xai/".
|
||||
context_budget._model_info.cache_clear()
|
||||
try:
|
||||
assert context_budget.context_window("grok/grok-4") == 256_000
|
||||
assert context_budget.output_limit("grok/grok-4") == 256_000
|
||||
finally:
|
||||
context_budget._model_info.cache_clear()
|
||||
|
||||
|
||||
def test_context_window_unmapped_uses_fallback(monkeypatch: pytest.MonkeyPatch) -> None:
|
||||
context_budget._model_info.cache_clear()
|
||||
|
||||
|
||||
@@ -56,6 +56,7 @@ def test_post_form_returns_parsed_body() -> None:
|
||||
resp = mock.MagicMock()
|
||||
resp.status_code = 200
|
||||
resp.content = b'{"access_token": "tok"}'
|
||||
resp.__enter__.return_value = resp
|
||||
|
||||
with mock.patch.object(requests, "post", return_value=resp) as post:
|
||||
data = grok._post_form({"grant_type": "refresh_token"})
|
||||
@@ -68,6 +69,7 @@ def test_post_form_raises_on_http_error() -> None:
|
||||
resp = mock.MagicMock()
|
||||
resp.status_code = 400
|
||||
resp.text = "invalid_grant"
|
||||
resp.__enter__.return_value = resp
|
||||
|
||||
with (
|
||||
mock.patch.object(requests, "post", return_value=resp),
|
||||
|
||||
@@ -47,6 +47,17 @@ def test_provider_label_names_the_subscription() -> None:
|
||||
assert subscription.provider_label("openai/gpt-5.4") is None
|
||||
|
||||
|
||||
def test_litellm_model_name_maps_subscription_prefixes() -> None:
|
||||
# Model metadata (context window, output cap) is keyed "xai/…" for Grok and
|
||||
# bare for ChatGPT; the routing prefixes themselves are never LiteLLM keys.
|
||||
assert subscription.litellm_model_name("grok/grok-4") == "xai/grok-4"
|
||||
assert subscription.litellm_model_name("chatgpt/gpt-5.4") == "gpt-5.4"
|
||||
# Non-subscription models pass through untouched.
|
||||
assert subscription.litellm_model_name("xai/grok-4") == "xai/grok-4"
|
||||
assert subscription.litellm_model_name("openai/gpt-5.4") == "openai/gpt-5.4"
|
||||
assert subscription.litellm_model_name(None) is None
|
||||
|
||||
|
||||
def test_run_record_reports_grok_provider(monkeypatch) -> None: # type: ignore[no-untyped-def]
|
||||
settings = mock.MagicMock()
|
||||
settings.llm.model = "grok/grok-4"
|
||||
|
||||
Reference in New Issue
Block a user