4b6817381b
CI (OpenClaw E2E) / openclaw test (push) Has been cancelled
CI / coverage-report (push) Has been cancelled
CI / test-kubernetes (push) Has been cancelled
CI / should-run-thorough (push) Has been cancelled
CI / test-thorough (cloudwatch-demo) (push) Has been cancelled
CI / test-thorough (flink-ecs) (push) Has been cancelled
CI / test-thorough (upstream-lambda) (push) Has been cancelled
CI / test-thorough (prefect-ecs-fargate) (push) Has been cancelled
Release / build-binaries (zip, opensre.exe, onefile, windows-latest, windows-x64) (push) Has been cancelled
Benchmark image — build + push to ECR (any adapter) / build + push (push) Has been cancelled
CI / quality (ubuntu-latest) (push) Has been cancelled
CI / test (tools-runtime) (push) Has been cancelled
CI / test (e2e-general) (push) Has been cancelled
CI / test (cli-runtime) (push) Has been cancelled
CI / test (e2e-provider-and-openclaw) (push) Has been cancelled
CI / test (integrations-and-misc) (push) Has been cancelled
Release / verify (push) Has been cancelled
Release / build-python-dist (push) Has been cancelled
Release / build-binaries (tar.gz, opensre, onedir, macos-15-intel, darwin-x64) (push) Has been cancelled
Release / build-binaries (tar.gz, opensre, onedir, macos-latest, darwin-arm64) (push) Has been cancelled
Release / build-binaries (tar.gz, opensre, onedir, ubuntu-22.04, linux-x64) (push) Has been cancelled
Release / publish-release (push) Has been cancelled
Release / publish-main-release (push) Has been cancelled
Interactive Shell Live (PR + post-merge) / turn-checks (no-LLM) (push) Has been cancelled
CodeQL / Analyze (python) (push) Has been cancelled
Interactive Shell Live (PR + post-merge) / turn-live shard ${{ matrix.shard_index }} (push) Has been cancelled
Release / prepare (push) Has been cancelled
Release / build-binaries (tar.gz, opensre, onedir, ubuntu-22.04-arm, linux-arm64) (push) Has been cancelled
Synthetic Deterministic Tests / Synthetic offline (deterministic) (push) Has been cancelled
203 lines
6.3 KiB
Python
203 lines
6.3 KiB
Python
"""CLI commands for LLM/env config and local ~/.opensre/config.yml."""
|
|
|
|
from __future__ import annotations
|
|
|
|
import json
|
|
import os
|
|
from pathlib import Path
|
|
from typing import Any
|
|
|
|
import click
|
|
|
|
from config.constants import OPENSRE_HOME_DIR
|
|
|
|
_SUPPORTED_LAYOUTS = {"classic", "pinned"}
|
|
_SUPPORTED_KEYS = ("interactive.enabled", "interactive.layout", "interactive.theme")
|
|
|
|
|
|
def _supported_themes() -> set[str]:
|
|
from platform.terminal.theme import list_theme_names
|
|
|
|
return set(list_theme_names())
|
|
|
|
|
|
def _masked(value: str | None) -> str:
|
|
if not value:
|
|
return "(not set)"
|
|
return value[:4] + "****" if len(value) > 4 else "****"
|
|
|
|
|
|
def _emit_llm_config() -> None:
|
|
"""Print current LLM provider and model from environment (legacy `opensre config`)."""
|
|
from config.config import (
|
|
get_configured_llm_provider,
|
|
get_llm_provider_api_key_env,
|
|
)
|
|
from config.llm_auth.credentials import status as credential_status
|
|
from platform.common.runtime_flags import is_json_output
|
|
|
|
provider = get_configured_llm_provider()
|
|
auth_status = credential_status(provider)
|
|
|
|
model_env_by_provider: dict[str, str] = {
|
|
"anthropic": "ANTHROPIC_REASONING_MODEL",
|
|
"openai": "OPENAI_REASONING_MODEL",
|
|
"openrouter": "OPENROUTER_REASONING_MODEL",
|
|
"deepseek": "DEEPSEEK_REASONING_MODEL",
|
|
"gemini": "GEMINI_REASONING_MODEL",
|
|
"nvidia": "NVIDIA_REASONING_MODEL",
|
|
"bedrock": "BEDROCK_MODEL",
|
|
"minimax": "MINIMAX_REASONING_MODEL",
|
|
"ollama": "OLLAMA_MODEL",
|
|
}
|
|
|
|
key_env = get_llm_provider_api_key_env(provider) or {
|
|
"bedrock": "AWS_DEFAULT_REGION",
|
|
"ollama": "OLLAMA_HOST",
|
|
}.get(provider, "")
|
|
key_value = os.getenv(key_env, "") if key_env and auth_status.source == "env" else ""
|
|
model_env = model_env_by_provider.get(provider, "")
|
|
model_value = os.getenv(model_env, "") if model_env else ""
|
|
|
|
if is_json_output():
|
|
click.echo(
|
|
json.dumps(
|
|
{
|
|
"provider": provider,
|
|
"model": model_value or None,
|
|
"api_key_set": auth_status.configured and not auth_status.stale,
|
|
"auth_source": auth_status.source,
|
|
"auth_stale": auth_status.stale,
|
|
}
|
|
)
|
|
)
|
|
return
|
|
|
|
click.echo(f"Provider : {provider}")
|
|
if model_value:
|
|
click.echo(f"Model : {model_value}")
|
|
if key_env:
|
|
masked = _masked(key_value) if key_value else f"({auth_status.source})"
|
|
click.echo(f"{key_env:<16}: {masked}")
|
|
click.echo(f"Auth : {auth_status.detail}")
|
|
click.echo()
|
|
click.echo("To log in or change LLM auth, run: opensre auth login")
|
|
click.echo("To rerun the full setup wizard, run: opensre onboard")
|
|
click.echo("Local CLI YAML: opensre config show / opensre config set …")
|
|
|
|
|
|
def _config_path() -> Path:
|
|
return OPENSRE_HOME_DIR / "config.yml"
|
|
|
|
|
|
def _load_config() -> dict[str, Any]:
|
|
path = _config_path()
|
|
if not path.exists():
|
|
return {}
|
|
|
|
try:
|
|
import yaml
|
|
|
|
data = yaml.safe_load(path.read_text(encoding="utf-8"))
|
|
except Exception as exc: # noqa: BLE001
|
|
raise click.ClickException(f"Could not parse local config file at {path}: {exc}") from exc
|
|
|
|
if data is None:
|
|
return {}
|
|
|
|
if not isinstance(data, dict):
|
|
raise click.ClickException(
|
|
f"Invalid config file at {path}: expected a mapping at the top level."
|
|
)
|
|
return data
|
|
|
|
|
|
def _save_config(data: dict[str, Any]) -> None:
|
|
import yaml
|
|
|
|
path = _config_path()
|
|
path.parent.mkdir(parents=True, exist_ok=True)
|
|
path.write_text(yaml.safe_dump(data, sort_keys=False), encoding="utf-8")
|
|
|
|
|
|
def _parse_bool(raw_value: str) -> bool:
|
|
normalized = raw_value.strip().lower()
|
|
if normalized in {"1", "true", "yes", "on"}:
|
|
return True
|
|
if normalized in {"0", "false", "no", "off"}:
|
|
return False
|
|
raise click.UsageError(
|
|
"Invalid value for interactive.enabled. Use one of: true/false, 1/0, yes/no, on/off."
|
|
)
|
|
|
|
|
|
def _coerce_value(key: str, raw_value: str) -> bool | str:
|
|
if key == "interactive.enabled":
|
|
return _parse_bool(raw_value)
|
|
if key == "interactive.layout":
|
|
layout = raw_value.strip().lower()
|
|
if layout not in _SUPPORTED_LAYOUTS:
|
|
raise click.UsageError(
|
|
"Invalid value for interactive.layout. Use 'classic' or 'pinned'."
|
|
)
|
|
return layout
|
|
if key == "interactive.theme":
|
|
theme = raw_value.strip().lower()
|
|
supported_themes = _supported_themes()
|
|
if theme not in supported_themes:
|
|
supported = ", ".join(sorted(supported_themes))
|
|
raise click.UsageError(f"Invalid value for interactive.theme. Use one of: {supported}.")
|
|
return theme
|
|
raise click.UsageError(
|
|
f"Unknown config key '{key}'. Supported keys: {', '.join(_SUPPORTED_KEYS)}"
|
|
)
|
|
|
|
|
|
def _set_nested_key(data: dict[str, Any], dotted_key: str, value: Any) -> dict[str, Any]:
|
|
head, tail = dotted_key.split(".", 1)
|
|
node = data.get(head)
|
|
if not isinstance(node, dict):
|
|
node = {}
|
|
node[tail] = value
|
|
data[head] = node
|
|
return data
|
|
|
|
|
|
@click.group(name="config", invoke_without_command=True)
|
|
@click.pass_context
|
|
def config_command(ctx: click.Context) -> None:
|
|
"""LLM/environment config by default; subcommands manage ~/.opensre/config.yml."""
|
|
if ctx.invoked_subcommand is None:
|
|
_emit_llm_config()
|
|
|
|
|
|
@config_command.command(name="show")
|
|
def config_show() -> None:
|
|
"""Show local ~/.opensre/config.yml values."""
|
|
from platform.common.runtime_flags import is_json_output
|
|
|
|
payload = _load_config()
|
|
|
|
if is_json_output():
|
|
click.echo(json.dumps(payload))
|
|
return
|
|
|
|
import yaml
|
|
|
|
path = _config_path()
|
|
click.echo(f"# {path} (on-disk values; environment variables do not override this output)")
|
|
click.echo(yaml.safe_dump(payload, sort_keys=False).rstrip())
|
|
|
|
|
|
@config_command.command(name="set")
|
|
@click.argument("key")
|
|
@click.argument("value")
|
|
def config_set(key: str, value: str) -> None:
|
|
"""Set one local config key in ~/.opensre/config.yml."""
|
|
key = key.strip()
|
|
coerced = _coerce_value(key, value)
|
|
data = _load_config()
|
|
updated = _set_nested_key(data, key, coerced)
|
|
_save_config(updated)
|
|
click.echo(f"✓ Set {key} = {coerced}")
|