Connect via MCP

import os
import httpx
from mcp.server.fastmcp import FastMCP

BASE = "https://api.creatoraudit.com/v2"
HEADERS = {"Authorization": f"Bearer {os.environ['CREATORAUDIT_API_KEY']}"}
mcp = FastMCP("creatoraudit")


async def _get(path: str, params: dict | None = None) -> dict:
    async with httpx.AsyncClient(base_url=BASE, headers=HEADERS) as client:
        resp = await client.get(path, params=params or {})
        # On 4xx/5xx the body is RFC 9457 problem+json; surface it as-is.
        return {
            "status": resp.status_code,
            "request_id": resp.headers.get("X-Request-ID"),
            "body": resp.json(),
        }


@mcp.tool()
async def search(q: str, limit: int = 20) -> dict:
    """Search tracked accounts, creators, and videos."""
    return await _get("/search", {"q": q, "limit": limit})


@mcp.tool()
async def overview(period: str | None = None) -> dict:
    """Organization-level headline figures."""
    return await _get("/overview", {"period": period} if period else None)


@mcp.tool()
async def list_accounts(limit: int = 50, cursor: str | None = None) -> dict:
    """List tracked accounts (one page). Pass the returned next_cursor to page."""
    params = {"limit": limit}
    if cursor:
        params["cursor"] = cursor
    return await _get("/accounts", params)


if __name__ == "__main__":
    mcp.run()  # stdio transport

import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js";
import { z } from "zod";

const BASE = "https://api.creatoraudit.com/v2";
const headers = { Authorization: `Bearer ${process.env.CREATORAUDIT_API_KEY!}` };

async function get(path: string, params: Record<string, unknown> = {}) {
  const url = new URL(`${BASE}${path}`);
  for (const [k, v] of Object.entries(params)) {
    if (v != null) url.searchParams.set(k, String(v));
  }
  const resp = await fetch(url, { headers });
  // On 4xx/5xx the body is RFC 9457 problem+json; surface it as-is.
  return {
    status: resp.status,
    requestId: resp.headers.get("X-Request-ID"),
    body: await resp.json(),
  };
}

const server = new McpServer({ name: "creatoraudit", version: "1.0.0" });

server.tool(
  "search",
  "Search tracked accounts, creators, and videos.",
  { q: z.string(), limit: z.number().int().min(1).max(25).default(20) },
  async ({ q, limit }) => ({
    content: [{ type: "text", text: JSON.stringify(await get("/search", { q, limit })) }],
  }),
);

server.tool(
  "list_accounts",
  "List tracked accounts (one page). Pass next_cursor to page.",
  { limit: z.number().int().min(1).max(200).default(50), cursor: z.string().optional() },
  async ({ limit, cursor }) => ({
    content: [{ type: "text", text: JSON.stringify(await get("/accounts", { limit, cursor })) }],
  }),
);

await server.connect(new StdioServerTransport());