Files
OpenJarvis/tests/cli/test_ask_agent.py
T
Jon Saad-FalconandClaude Opus 4.6 8d538cd1b0 Add orchestrator training, channels, LiteLLM engine, and simplify learning taxonomy
Major changes across parallel sessions:

- Add orchestrator SFT & GRPO training subpackage (learning/orchestrator/)
  with episode types, multi-objective reward, prompt registry, policy model,
  RL environment, and registered learning policies
- Add structured THOUGHT/TOOL/INPUT/FINAL_ANSWER mode to OrchestratorAgent
- Add 15 channel backends (Discord, Slack, Telegram, Email, Webhook, IRC,
  Matrix, Teams, WhatsApp, Signal, Mattermost, BlueBubbles, Feishu,
  Google Chat, Webchat) with channel tools and config
- Add LiteLLM engine backend for unified LLM provider access
- Add RLM agent and REPL tool
- Remove ToolLearningPolicy — learning taxonomy now only targets
  Intelligence (LM weights/routing) and Agents (logic/ICL/tool strategies)
- Rename SFTPolicy to SFTRouterPolicy (backward-compat alias kept)
- Remove OpenClaw agent infrastructure (openclaw*.py, openclaw_bridge.py)
- Fix async streaming tests (asyncio.run vs deprecated get_event_loop)
- Fix server channel route tests (pytest.importorskip for optional fastapi)
- Track uv.lock for reproducibility
- Update CLAUDE.md and docs to reflect all changes

1676 tests pass, 37 skipped.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
2026-02-23 18:32:32 +00:00

202 lines
6.7 KiB
Python

"""Tests for ``jarvis ask --agent`` CLI integration."""
from __future__ import annotations
import importlib
from unittest.mock import MagicMock, patch
import pytest
from click.testing import CliRunner
from openjarvis.cli import cli
_ask_mod = importlib.import_module("openjarvis.cli.ask")
def _mock_engine(content="Hello from engine"):
"""Create a mock engine that returns content."""
engine = MagicMock()
engine.engine_id = "mock"
engine.health.return_value = True
engine.list_models.return_value = ["test-model"]
engine.generate.return_value = {
"content": content,
"usage": {"prompt_tokens": 5, "completion_tokens": 3, "total_tokens": 8},
"model": "test-model",
"finish_reason": "stop",
}
return engine
def _register_agents():
"""Re-register agents after registry clear."""
from openjarvis.agents.custom import CustomAgent
from openjarvis.agents.orchestrator import OrchestratorAgent
from openjarvis.agents.simple import SimpleAgent
from openjarvis.core.registry import AgentRegistry
for name, cls in [
("simple", SimpleAgent),
("orchestrator", OrchestratorAgent),
("custom", CustomAgent),
]:
if not AgentRegistry.contains(name):
AgentRegistry.register_value(name, cls)
def _register_tools():
"""Re-register tools after registry clear."""
from openjarvis.core.registry import ToolRegistry
from openjarvis.tools.calculator import CalculatorTool
from openjarvis.tools.file_read import FileReadTool
from openjarvis.tools.llm_tool import LLMTool
from openjarvis.tools.retrieval import RetrievalTool
from openjarvis.tools.think import ThinkTool
for name, cls in [
("calculator", CalculatorTool),
("think", ThinkTool),
("retrieval", RetrievalTool),
("llm", LLMTool),
("file_read", FileReadTool),
]:
if not ToolRegistry.contains(name):
ToolRegistry.register_value(name, cls)
@pytest.fixture
def runner():
return CliRunner()
@pytest.fixture
def mock_setup():
"""Patch engine discovery to avoid needing a running engine."""
engine = _mock_engine()
_register_agents()
_register_tools()
with (
patch.object(_ask_mod, "load_config") as mock_cfg,
patch.object(_ask_mod, "get_engine") as mock_ge,
patch.object(_ask_mod, "discover_engines") as mock_de,
patch.object(_ask_mod, "discover_models") as mock_dm,
patch.object(_ask_mod, "register_builtin_models"),
patch.object(_ask_mod, "merge_discovered_models"),
):
from openjarvis.core.config import JarvisConfig
mock_cfg.return_value = JarvisConfig()
mock_ge.return_value = ("mock", engine)
mock_de.return_value = [("mock", engine)]
mock_dm.return_value = {"mock": ["test-model"]}
yield engine
class TestAskAgentOption:
def test_help_shows_agent_option(self, runner):
result = runner.invoke(cli, ["ask", "--help"])
assert "--agent" in result.output or "-a" in result.output
def test_help_shows_tools_option(self, runner):
result = runner.invoke(cli, ["ask", "--help"])
assert "--tools" in result.output
def test_agent_simple(self, runner, mock_setup):
result = runner.invoke(cli, ["ask", "--agent", "simple", "Hello"])
assert result.exit_code == 0
assert "Hello from engine" in result.output
def test_agent_orchestrator_no_tools(self, runner, mock_setup):
result = runner.invoke(
cli, ["ask", "--agent", "orchestrator", "Hello"],
)
assert result.exit_code == 0
def test_agent_orchestrator_with_tools(self, runner, mock_setup):
result = runner.invoke(
cli,
[
"ask", "--agent", "orchestrator",
"--tools", "calculator,think",
"What is 2+2?",
],
)
assert result.exit_code == 0
def test_agent_json_output(self, runner, mock_setup):
result = runner.invoke(
cli, ["ask", "--agent", "simple", "--json", "Hello"],
)
assert result.exit_code == 0
assert '"content"' in result.output
assert '"turns"' in result.output
def test_unknown_agent(self, runner, mock_setup):
result = runner.invoke(
cli, ["ask", "--agent", "nonexistent", "Hello"],
)
assert result.exit_code != 0
def test_no_agent_uses_direct_mode(self, runner, mock_setup):
result = runner.invoke(cli, ["ask", "Hello"])
assert result.exit_code == 0
assert "Hello from engine" in result.output
def test_agent_simple_with_model(self, runner, mock_setup):
result = runner.invoke(
cli, ["ask", "--agent", "simple", "-m", "test-model", "Hello"],
)
assert result.exit_code == 0
def test_agent_simple_with_temperature(self, runner, mock_setup):
result = runner.invoke(
cli, ["ask", "--agent", "simple", "-t", "0.1", "Hello"],
)
assert result.exit_code == 0
class TestBuildTools:
def test_build_calculator(self, mock_setup):
from openjarvis.cli.ask import _build_tools
from openjarvis.core.config import JarvisConfig
_register_tools()
config = JarvisConfig()
tools = _build_tools(["calculator"], config, mock_setup, "test-model")
assert len(tools) == 1
assert tools[0].tool_id == "calculator"
def test_build_think(self, mock_setup):
from openjarvis.cli.ask import _build_tools
from openjarvis.core.config import JarvisConfig
_register_tools()
config = JarvisConfig()
tools = _build_tools(["think"], config, mock_setup, "test-model")
assert len(tools) == 1
assert tools[0].tool_id == "think"
def test_build_unknown_tool_skipped(self, mock_setup):
from openjarvis.cli.ask import _build_tools
from openjarvis.core.config import JarvisConfig
config = JarvisConfig()
tools = _build_tools(["nonexistent"], config, mock_setup, "test-model")
assert len(tools) == 0
def test_build_empty_names(self, mock_setup):
from openjarvis.cli.ask import _build_tools
from openjarvis.core.config import JarvisConfig
config = JarvisConfig()
tools = _build_tools(["", " "], config, mock_setup, "test-model")
assert len(tools) == 0
def test_build_multiple_tools(self, mock_setup):
from openjarvis.cli.ask import _build_tools
from openjarvis.core.config import JarvisConfig
_register_tools()
config = JarvisConfig()
tools = _build_tools(["calculator", "think"], config, mock_setup, "test-model")
assert len(tools) == 2