BONKETIBA MCP server

// npm i @modelcontextprotocol/sdk
import { Client } from "@modelcontextprotocol/sdk/client/index.js";
import { StreamableHTTPClientTransport } from "@modelcontextprotocol/sdk/client/streamableHttp.js";

const transport = new StreamableHTTPClientTransport(
  new URL("https://<your-bonketiba-domain>/mcp"),
  // The SDK handles OAuth 2.1 discovery + dynamic registration
  // via /.well-known/oauth-protected-resource. On first run it opens
  // a browser tab for consent, then caches tokens locally.
  { authProvider: /* your OAuth persistence, e.g. keychain-backed */ undefined }
);

const client = new Client({ name: "my-agent", version: "1.0.0" });
await client.connect(transport);

// 1) Discover tools (10 available; scopes: search | history | sources | notes)
const { tools } = await client.listTools();
console.log(tools.map((t) => t.name));

// 2) Run an AI search (scope: search)
const search = await client.callTool({
  name: "run_ai_search",
  arguments: { query: "How to open a company in Rwanda?" },
});
console.log(search.structuredContent);

// 3) Save a source (scope: sources)
await client.callTool({
  name: "save_source",
  arguments: { url: "https://gov.rwanda.rw", title: "Rwanda gov" },
});

// 4) Create a note (scope: notes)
await client.callTool({
  name: "create_note",
  arguments: { title: "Rwanda plan", content: "Next steps..." },
});

await client.close();

# pip install "mcp[cli]"
import asyncio
from mcp import ClientSession
from mcp.client.streamable_http import streamablehttp_client

MCP_URL = "https://<your-bonketiba-domain>/mcp"

async def main() -> None:
    # streamablehttp_client walks OAuth 2.1 discovery at
    # /.well-known/oauth-protected-resource, registers a client
    # dynamically and prompts the user for consent on first run.
    async with streamablehttp_client(MCP_URL) as (read, write, _):
        async with ClientSession(read, write) as session:
            await session.initialize()

            # Discover the 10 tools (scopes: search|history|sources|notes)
            tools = await session.list_tools()
            print([t.name for t in tools.tools])

            # Run an AI search (scope: search)
            result = await session.call_tool(
                "run_ai_search",
                {"query": "How to open a company in Rwanda?"},
            )
            print(result.structuredContent)

            # List saved sources (scope: sources)
            await session.call_tool("list_saved_sources", {"limit": 20})

            # Create a note (scope: notes)
            await session.call_tool(
                "create_note",
                {"title": "Rwanda plan", "content": "Next steps..."},
            )

asyncio.run(main())

# 1) OAuth discovery
curl https://<your-bonketiba-domain>/.well-known/oauth-protected-resource

# 2) After completing the OAuth flow you have an access token.
#    Call tools with a JSON-RPC POST to /mcp.
curl -X POST https://<your-bonketiba-domain>/mcp \
  -H "Authorization: Bearer $ACCESS_TOKEN" \
  -H "Content-Type: application/json" \
  -H "Accept: application/json, text/event-stream" \
  -d '{
    "jsonrpc": "2.0",
    "id": 1,
    "method": "tools/call",
    "params": {
      "name": "run_ai_search",
      "arguments": { "query": "How to open a company in Rwanda?" }
    }
  }'

Requests to /mcp MUST send Accept: application/json, text/event-stream; the server may respond with either a JSON body or a single SSE frame.