Diligence and leads as tools for your agent.

import asyncio, os
from mcp import ClientSession
from mcp.client.streamable_http import streamablehttp_client

async def main():
    headers = {"Authorization": f"Bearer {os.environ['MARKETPRIOR_API_KEY']}"}
    async with streamablehttp_client("https://marketprior-diligence.fly.dev/mcp", headers=headers) as (read, write, _):
        async with ClientSession(read, write) as session:
            await session.initialize()
            res = await session.call_tool("search_companies", {"q": "Acme"})
            print(res.content)

asyncio.run(main())

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

const transport = new StreamableHTTPClientTransport(new URL("https://marketprior-diligence.fly.dev/mcp"), {
  requestInit: { headers: { Authorization: `Bearer ${process.env.MARKETPRIOR_API_KEY}` } },
});
const client = new Client({ name: "my-agent", version: "1.0.0" });
await client.connect(transport);

const { tools } = await client.listTools();
const res = await client.callTool({ name: "search_companies", arguments: { q: "Acme" } });