mirror of
https://github.com/langbot-app/LangBot.git
synced 2026-06-12 16:56:02 +00:00
refactor(provider): formalize tool lookup contract
This commit is contained in:
@@ -265,7 +265,7 @@ class TestToolManagerExecuteFuncCall:
|
||||
|
||||
@pytest.mark.asyncio
|
||||
async def test_execute_raises_when_tool_not_found(self, mock_app_with_loaders, sample_query):
|
||||
"""Test that execute_func_call raises ValueError when tool not found."""
|
||||
"""Test that execute_func_call raises ToolNotFoundError when tool not found."""
|
||||
toolmgr = get_toolmgr_module()
|
||||
|
||||
mock_app, mock_plugin_loader, mock_mcp_loader = mock_app_with_loaders
|
||||
@@ -275,7 +275,7 @@ class TestToolManagerExecuteFuncCall:
|
||||
manager = toolmgr.ToolManager(mock_app)
|
||||
self._wire_loaders(manager, mock_app, mock_plugin_loader, mock_mcp_loader)
|
||||
|
||||
with pytest.raises(ValueError, match='未找到工具'):
|
||||
with pytest.raises(toolmgr.ToolNotFoundError, match='Tool not found: unknown_tool'):
|
||||
await manager.execute_func_call('unknown_tool', {}, sample_query)
|
||||
|
||||
@pytest.mark.asyncio
|
||||
|
||||
@@ -9,6 +9,7 @@ import pytest
|
||||
|
||||
import langbot_plugin.api.entities.builtin.resource.tool as resource_tool
|
||||
|
||||
from langbot.pkg.provider.tools.loader import ToolLoader
|
||||
from langbot.pkg.provider.tools.loaders.native import (
|
||||
_DEFAULT_TOOL_RESULT_MAX_BYTES,
|
||||
_GLOB_MAX_MATCHES,
|
||||
@@ -26,6 +27,12 @@ class StubLoader:
|
||||
async def get_tools(self, *_args, **_kwargs):
|
||||
return self._tools
|
||||
|
||||
async def get_tool(self, name: str):
|
||||
for tool in self._tools:
|
||||
if tool.name == name:
|
||||
return tool
|
||||
return None
|
||||
|
||||
async def has_tool(self, name: str) -> bool:
|
||||
return any(tool.name == name for tool in self._tools)
|
||||
|
||||
@@ -36,6 +43,14 @@ class StubLoader:
|
||||
return None
|
||||
|
||||
|
||||
class DirectLookupLoader(StubLoader):
|
||||
async def get_tools(self, *_args, **_kwargs):
|
||||
raise AssertionError('ToolManager should use the loader get_tool contract')
|
||||
|
||||
async def get_tool(self, name: str):
|
||||
return make_tool(name) if name == 'direct_tool' else None
|
||||
|
||||
|
||||
def make_tool(name: str) -> resource_tool.LLMTool:
|
||||
return resource_tool.LLMTool(
|
||||
name=name,
|
||||
@@ -46,6 +61,32 @@ def make_tool(name: str) -> resource_tool.LLMTool:
|
||||
)
|
||||
|
||||
|
||||
class ListOnlyLoader(ToolLoader):
|
||||
async def get_tools(self, *_args, **_kwargs):
|
||||
return [make_tool('listed_tool')]
|
||||
|
||||
async def has_tool(self, name: str) -> bool:
|
||||
return name == 'listed_tool'
|
||||
|
||||
async def invoke_tool(self, name: str, parameters: dict, query):
|
||||
return parameters
|
||||
|
||||
async def shutdown(self):
|
||||
return None
|
||||
|
||||
|
||||
@pytest.mark.asyncio
|
||||
async def test_tool_loader_get_tool_falls_back_to_public_tool_list():
|
||||
loader = ListOnlyLoader(SimpleNamespace())
|
||||
|
||||
tool = await loader.get_tool('listed_tool')
|
||||
missing_tool = await loader.get_tool('missing_tool')
|
||||
|
||||
assert tool is not None
|
||||
assert tool.name == 'listed_tool'
|
||||
assert missing_tool is None
|
||||
|
||||
|
||||
@pytest.mark.asyncio
|
||||
async def test_tool_manager_omits_skill_authoring_tools_by_default():
|
||||
manager = ToolManager(SimpleNamespace())
|
||||
@@ -103,6 +144,20 @@ async def test_tool_manager_get_tool_by_name_resolves_native_and_skill_tools():
|
||||
assert skill_tool.name == 'activate'
|
||||
|
||||
|
||||
@pytest.mark.asyncio
|
||||
async def test_tool_manager_uses_loader_get_tool_contract():
|
||||
manager = ToolManager(SimpleNamespace())
|
||||
manager.native_tool_loader = StubLoader([])
|
||||
manager.skill_tool_loader = StubLoader([])
|
||||
manager.plugin_tool_loader = DirectLookupLoader()
|
||||
manager.mcp_tool_loader = StubLoader([])
|
||||
|
||||
tool = await manager.get_tool_by_name('direct_tool')
|
||||
|
||||
assert tool is not None
|
||||
assert tool.name == 'direct_tool'
|
||||
|
||||
|
||||
@pytest.mark.asyncio
|
||||
async def test_native_tool_loader_hides_tools_when_box_unavailable():
|
||||
loader = NativeToolLoader(SimpleNamespace(box_service=SimpleNamespace(available=False)))
|
||||
|
||||
Reference in New Issue
Block a user