feat(bot): add unified VikingBot gateway routing and OpenViking auth (#3119)

* bot opt config\api check

* 优化vikingbot的启动链路

* 美化颜色

* docs: add VikingBot gateway routing diagram

* fix(bot): harden gateway auth and proxy routing

Author: yeshion23333

bot/tests/test_agent_loop_outcome.py

@@ -111,7 +111,6 @@ def test_agent_loop_omits_spawn_tool_when_subagents_disabled(temp_dir: Path, mon
     bus = MessageBus()
     provider = _RecordingProvider()
     config = Config(storage_workspace=str(temp_dir), agents={"subagent_enabled": False})
-    monkeypatch.setattr("vikingbot.agent.tools.factory.load_config", lambda: config)
 
     loop = AgentLoop(
         bus=bus,
@@ -125,6 +124,24 @@ def test_agent_loop_omits_spawn_tool_when_subagents_disabled(temp_dir: Path, mon
     assert "spawn" not in loop.tools.tool_names
 
 
+def test_agent_loop_standalone_omits_openviking_tools(temp_dir: Path, monkeypatch):
+    monkeypatch.setattr(AgentLoop, "_register_builtin_hooks", lambda self: None)
+    monkeypatch.setattr("vikingbot.agent.loop.SubagentManager", _FakeSubagentManager)
+
+    config = Config(storage_workspace=str(temp_dir))
+    loop = AgentLoop(
+        bus=MessageBus(),
+        provider=_RecordingProvider(),
+        workspace=temp_dir / "workspace",
+        config=config,
+    )
+
+    assert config.ov_server.server_url == ""
+    assert not any(name.startswith("openviking_") for name in loop.tools.tool_names)
+    session_key = SessionKey(type="cli", channel_id="default", chat_id="standalone")
+    assert loop._get_ov_tools_enable(session_key) is False
+
+
 @pytest.mark.asyncio
 async def test_context_prompt_omits_subagent_capability_when_disabled(temp_dir: Path):
     context = ContextBuilder(workspace=temp_dir / "workspace", enable_subagents=False)
@@ -174,14 +191,6 @@ async def test_agent_loop_makes_final_no_tool_call_when_iteration_limit_reached(
     monkeypatch.setattr(AgentLoop, "_register_default_tools", lambda self: None)
     monkeypatch.setattr("vikingbot.agent.loop.SubagentManager", _FakeSubagentManager)
 
-    class _OVConfig:
-        exp_write_tools = []
-
-    class _LoadedConfig:
-        ov_server = _OVConfig()
-
-    monkeypatch.setattr(loop_module, "load_config", lambda: _LoadedConfig())
-
     class _ToolLimitProvider(LLMProvider):
         def __init__(self):
             super().__init__()
@@ -458,9 +467,7 @@ async def test_agent_loop_build_prompt_history_uses_ov_context_plus_unsynced_tai
         }
     )
 
-    async def fake_get_ov_client(
-        self, session_key, openviking_connection=None, actor_peer_id=None
-    ):
+    async def fake_get_ov_client(self, session_key, openviking_connection=None, actor_peer_id=None):
         del session_key, openviking_connection, actor_peer_id
         return fake_ov_client
 
@@ -469,6 +476,7 @@ async def fake_get_ov_client(
     bus = MessageBus()
     config = Config(
         storage_workspace=str(temp_dir),
+        ov_server={"server_url": "http://127.0.0.1:1933"},
         agents={"session_context_enabled": True, "session_context_token_budget": 321},
     )
     loop = AgentLoop(
@@ -513,9 +521,7 @@ async def test_agent_loop_build_prompt_history_skips_tail_when_sync_cursor_is_pa
         context_payload={"messages": [{"role": "user", "content": "OV user turn"}]}
     )
 
-    async def fake_get_ov_client(
-        self, session_key, openviking_connection=None, actor_peer_id=None
-    ):
+    async def fake_get_ov_client(self, session_key, openviking_connection=None, actor_peer_id=None):
         del self, session_key, openviking_connection, actor_peer_id
         return fake_ov_client
 
@@ -524,6 +530,7 @@ async def fake_get_ov_client(
     bus = MessageBus()
     config = Config(
         storage_workspace=str(temp_dir),
+        ov_server={"server_url": "http://127.0.0.1:1933"},
         agents={"session_context_enabled": True, "session_context_token_budget": 321},
     )
     loop = AgentLoop(
@@ -568,6 +575,7 @@ async def fake_execute_hooks(context, **kwargs):
     bus = MessageBus()
     config = Config(
         storage_workspace=str(temp_dir),
+        ov_server={"server_url": "http://127.0.0.1:1933"},
         agents={"session_context_enabled": True},
     )
     loop = AgentLoop(
@@ -620,9 +628,7 @@ async def fake_execute_hooks(context, **kwargs):
             state["last_synced_local_index"] = len(session.messages) - 1
         return kwargs
 
-    async def fake_get_ov_client(
-        self, session_key, openviking_connection=None, actor_peer_id=None
-    ):
+    async def fake_get_ov_client(self, session_key, openviking_connection=None, actor_peer_id=None):
         del self, session_key, openviking_connection, actor_peer_id
 
         class _Client:
@@ -651,6 +657,7 @@ async def fake_run_agent_loop(self, **kwargs):
     bus = MessageBus()
     config = Config(
         storage_workspace=str(temp_dir),
+        ov_server={"server_url": "http://127.0.0.1:1933"},
         agents={
             "session_context_enabled": True,
             "session_context_token_budget": 321,
@@ -725,9 +732,7 @@ async def fake_execute_hooks(context, **kwargs):
         session.metadata["openviking"]["last_commit_performed"] = bool(kwargs["force_commit"])
         return kwargs
 
-    async def fake_get_ov_client(
-        self, session_key, openviking_connection=None, actor_peer_id=None
-    ):
+    async def fake_get_ov_client(self, session_key, openviking_connection=None, actor_peer_id=None):
         del self, session_key, openviking_connection, actor_peer_id
 
         class _Client:
@@ -756,6 +761,7 @@ async def fake_run_agent_loop(self, **kwargs):
     bus = MessageBus()
     config = Config(
         storage_workspace=str(temp_dir),
+        ov_server={"server_url": "http://127.0.0.1:1933"},
         agents={
             "session_context_enabled": True,
             "session_context_token_budget": 321,
@@ -887,7 +893,11 @@ async def fake_run_agent_loop(self, **kwargs):
     )
 
     bus = MessageBus()
-    config = Config(storage_workspace=str(temp_dir), agents={"session_context_enabled": True})
+    config = Config(
+        storage_workspace=str(temp_dir),
+        ov_server={"server_url": "http://127.0.0.1:1933"},
+        agents={"session_context_enabled": True},
+    )
     loop = AgentLoop(
         bus=bus,
         provider=_FakeProvider(),
@@ -942,7 +952,11 @@ async def fake_run_agent_loop(self, **kwargs):
     )
 
     bus = MessageBus()
-    config = Config(storage_workspace=str(temp_dir), agents={"session_context_enabled": True})
+    config = Config(
+        storage_workspace=str(temp_dir),
+        ov_server={"server_url": "http://127.0.0.1:1933"},
+        agents={"session_context_enabled": True},
+    )
     loop = AgentLoop(
         bus=bus,
         provider=_FakeProvider(),
@@ -1001,7 +1015,10 @@ async def build_messages(self, **kwargs):
     monkeypatch.setattr(AgentLoop, "_run_agent_loop", fake_run_agent_loop)
 
     bus = MessageBus()
-    config = Config(storage_workspace=str(temp_dir))
+    config = Config(
+        storage_workspace=str(temp_dir),
+        ov_server={"server_url": "http://127.0.0.1:1933"},
+    )
     loop = AgentLoop(
         bus=bus,
         provider=_FakeProvider(),
@@ -1081,7 +1098,10 @@ async def fake_run_agent_loop(self, **kwargs):
     monkeypatch.setattr(AgentLoop, "_run_agent_loop", fake_run_agent_loop)
 
     bus = MessageBus()
-    config = Config(storage_workspace=str(temp_dir))
+    config = Config(
+        storage_workspace=str(temp_dir),
+        ov_server={"server_url": "http://127.0.0.1:1933"},
+    )
     loop = AgentLoop(
         bus=bus,
         provider=_FakeProvider(),

bot/tests/test_channel_delivery_metadata.py

@@ -47,6 +47,7 @@ async def send_callback(msg: OutboundMessage) -> None:
 @pytest.mark.asyncio
 async def test_spawn_tool_preserves_channel_metadata():
     metadata = {"reply_to": "oc_chat", "chat_type": "group", "message_id": "om_old"}
+    connection = {"api_key": "request-key", "account_id": "acct", "user_id": "alice"}
     calls = []
 
     class FakeSubagentManager:
@@ -58,18 +59,21 @@ async def spawn(self, **kwargs):
     context = SimpleNamespace(
         session_key=SessionKey(type="feishu", channel_id="cli_app", chat_id="oc_chat"),
         channel_metadata=metadata,
+        openviking_connection=connection,
     )
 
     result = await tool.execute(context, task="read files", label="read")
 
     assert result == "started"
     assert calls[0]["channel_metadata"] == metadata
+    assert calls[0]["openviking_connection"] is connection
 
 
 @pytest.mark.asyncio
 async def test_subagent_announcement_preserves_channel_metadata(tmp_path):
     bus = MessageBus()
     metadata = {"reply_to": "oc_chat", "chat_type": "group", "message_id": "om_old"}
+    connection = {"api_key": "request-key", "account_id": "acct", "user_id": "alice"}
     session_key = SessionKey(type="feishu", channel_id="cli_app", chat_id="oc_chat")
     manager = SubagentManager(
         provider=SimpleNamespace(get_default_model=lambda: "fake-model"),
@@ -86,11 +90,13 @@ async def test_subagent_announcement_preserves_channel_metadata(tmp_path):
         session_key,
         "ok",
         metadata,
+        connection,
     )
 
     inbound = await bus.consume_inbound()
     assert inbound.metadata == metadata
     assert inbound.metadata is not metadata
+    assert inbound.openviking_connection is connection
 
 
 @pytest.mark.asyncio
@@ -100,6 +106,8 @@ async def test_system_message_response_preserves_channel_metadata(tmp_path, monk
     monkeypatch.setattr("vikingbot.agent.loop.SubagentManager", lambda **kwargs: SimpleNamespace())
 
     metadata = {"reply_to": "oc_chat", "chat_type": "group", "message_id": "om_old"}
+    connection = {"api_key": "request-key", "account_id": "acct", "user_id": "alice"}
+    captured = {}
     session_key = SessionKey(type="feishu", channel_id="cli_app", chat_id="oc_chat")
     config = Config(storage_workspace=str(tmp_path / "data"))
     loop = AgentLoop(
@@ -121,7 +129,15 @@ async def fake_run_agent_loop(**kwargs):
         return "summary", None, [], {}, 1
 
     loop._build_prompt_history = fake_build_prompt_history
-    loop.context = SimpleNamespace(build_messages=fake_build_messages)
+
+    class FakeContextBuilder:
+        def __init__(self, *args, **kwargs):
+            captured["connection"] = kwargs.get("openviking_connection")
+
+        async def build_messages(self, **kwargs):
+            return await fake_build_messages(**kwargs)
+
+    monkeypatch.setattr("vikingbot.agent.context.ContextBuilder", FakeContextBuilder)
     loop._run_agent_loop = fake_run_agent_loop
 
     outbound = await loop._process_system_message(
@@ -130,12 +146,14 @@ async def fake_run_agent_loop(**kwargs):
             session_key=session_key,
             content="subagent done",
             metadata=metadata,
+            openviking_connection=connection,
         )
     )
 
     assert outbound.content == "summary"
     assert outbound.metadata == metadata
     assert outbound.metadata is not metadata
+    assert captured["connection"] is connection
 
 
 @pytest.mark.asyncio

bot/tests/test_chat_functionality.py

@@ -10,6 +10,7 @@
 from vikingbot.bus.queue import MessageBus
 from vikingbot.channels.chat import ChatChannel, ChatChannelConfig
 from vikingbot.channels.single_turn import SingleTurnChannel, SingleTurnChannelConfig
+from vikingbot.cli.commands import _CHAT_PROMPT_MESSAGE, _CHAT_PROMPT_STYLE
 from vikingbot.config.schema import SessionKey
 from vikingbot.session.manager import Session
 
@@ -119,6 +120,13 @@ def test_non_deepseek_history_omits_reasoning_content(self):
 
 
 class TestChatChannel:
+    def test_interactive_prompt_uses_terminal_foreground_and_visible_label(self):
+        assert _CHAT_PROMPT_MESSAGE == [("class:user-label", "You: ")]
+        rules = dict(_CHAT_PROMPT_STYLE.style_rules)
+        assert rules[""] == "fg:ansidefault"
+        assert rules["user-label"] == "bold fg:ansicyan"
+        assert all("ansiblack" not in style for style in rules.values())
+
     def test_chat_channel_initialization(self, message_bus, temp_workspace):
         """Test that ChatChannel can be initialized correctly."""
         config = ChatChannelConfig()