a37e9aa190
BREAKING CHANGE: Remove all `agent-reach read` and `agent-reach search-*` commands. Agent Reach is now an installer, configuration tool, and doctor — not a wrapper layer. After installation, agents call upstream tools directly (bird CLI, yt-dlp, mcporter, gh CLI, Jina Reader, etc.). What's kept: - agent-reach install: one-shot installer - agent-reach doctor: channel status overview - agent-reach configure: cookies, proxy, credentials - agent-reach setup: interactive wizard - SKILL.md: complete guide for agents to use upstream tools directly What's removed: - agent-reach read URL (and all channel read() methods) - agent-reach search-* commands (and all channel search() methods) - ReadResult / SearchResult data classes - URL routing system (get_channel_for_url) - All parsing/conversion logic (VTT, Reddit JSON, bird text parser, etc.) - MCP server read/search tools (kept only get_status) Net change: -1790 lines. Less code = fewer bugs.
67 lines
1.9 KiB
Python
67 lines
1.9 KiB
Python
# -*- coding: utf-8 -*-
|
|
"""
|
|
Agent Reach MCP Server — expose doctor/status as MCP tool.
|
|
|
|
Run: python -m agent_reach.integrations.mcp_server
|
|
|
|
Agent Reach is an installer + doctor tool. For actual reading/searching,
|
|
agents should call upstream tools directly (bird, yt-dlp, mcporter, etc.).
|
|
"""
|
|
|
|
import asyncio
|
|
import json
|
|
import sys
|
|
|
|
from agent_reach.config import Config
|
|
from agent_reach.core import AgentReach
|
|
|
|
try:
|
|
from mcp.server import Server
|
|
from mcp.server.stdio import stdio_server
|
|
from mcp.types import Tool, TextContent
|
|
HAS_MCP = True
|
|
except ImportError:
|
|
HAS_MCP = False
|
|
|
|
|
|
def create_server():
|
|
if not HAS_MCP:
|
|
print("MCP not installed. Install: pip install agent-reach[mcp]", file=sys.stderr)
|
|
sys.exit(1)
|
|
|
|
server = Server("agent-reach")
|
|
config = Config()
|
|
eyes = AgentReach(config)
|
|
|
|
@server.list_tools()
|
|
async def list_tools():
|
|
return [
|
|
Tool(name="get_status",
|
|
description="Get Agent Reach status: which channels are installed and active.",
|
|
inputSchema={"type": "object", "properties": {}}),
|
|
]
|
|
|
|
@server.call_tool()
|
|
async def call_tool(name: str, arguments: dict):
|
|
try:
|
|
if name == "get_status":
|
|
result = eyes.doctor_report()
|
|
else:
|
|
result = f"Unknown tool: {name}"
|
|
|
|
text = json.dumps(result, ensure_ascii=False, indent=2) if isinstance(result, (dict, list)) else str(result)
|
|
return [TextContent(type="text", text=text)]
|
|
except Exception as e:
|
|
return [TextContent(type="text", text=f"Error: {str(e)}")]
|
|
|
|
return server
|
|
|
|
|
|
async def main():
|
|
server = create_server()
|
|
async with stdio_server() as (read_stream, write_stream):
|
|
await server.run(read_stream, write_stream, server.create_initialization_options())
|
|
|
|
|
|
if __name__ == "__main__":
|
|
asyncio.run(main())
|