MCP 서버로 결제하기

1단계. Claude의 사용자: "ACME Corp의 재무 데이터를 가져와 신용 위험을 평가해 줘."

2단계. 클라이언트가 get_company_financials("ACME")를 호출합니다.
        → MCP 핸들러: fetchWithPayment("/financials?ticker=ACME")
        → 402 결제 필요 → ERC-3009 서명 → 다시 시도
        → Facilitator가 $0.01 USDT0를 온체인에서 정산합니다.
        → tx: 0x8f3a...aaaa
        → 200 OK { revenue, debt_ratio, cash_flow }

3단계. 클라이언트가 assess_credit_risk(financials)를 호출합니다.
        → MCP 핸들러: fetchWithPayment("/credit-risk", POST)
        → Facilitator가 $0.05 USDT0를 온체인에서 정산합니다.
        → tx: 0x9bc4...bbbb
        → 200 OK { score: 72, rating: "moderate" }

4단계. Claude가 응답합니다.
        "ACME Corp의 신용 위험 점수는 72점(보통)입니다. 매출은 안정적이지만,
        부채-자본 비율은 1.8배로 높습니다..."

// --- MCP 서버 ---
// x402 지원 API를 MCP 도구에 연결합니다.
tools = {
  "get_company_financials": {
    handler: (ticker) =>
      fetchWithPayment("https://api.example.com/financials?ticker=" + ticker),
  },
  "assess_credit_risk": {
    handler: (financials) =>
      fetchWithPayment("https://api.example.com/credit-risk", {
        method: "POST",
        body: JSON.stringify({ financials }),
      }),
  },
}

─── AI 클라이언트 ───────────────────────────────────────
사용자: "ACME Corp의 재무 데이터를 가져와 신용 위험을 평가해 줘."

클라이언트가 get_company_financials 도구를 호출합니다.
  → MCP 서버가 x402 유료 요청을 보냅니다.
  → Facilitator가 USDT0를 온체인에서 정산합니다.
  → API가 재무 데이터를 반환합니다.

클라이언트가 결과와 함께 assess_credit_risk 도구를 호출합니다.
  → MCP 서버가 x402 유료 요청을 보냅니다.
  → Facilitator가 USDT0를 온체인에서 정산합니다.
  → API가 위험 평가를 반환합니다.
  → 클라이언트가 결합된 결과로 응답합니다.

npm install @modelcontextprotocol/sdk @x402/fetch @x402/evm @tetherto/wdk-wallet-evm

// mcp-server.ts
import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js";
import WalletManagerEvm from "@tetherto/wdk-wallet-evm";
import { x402Client, wrapFetchWithPayment } from "@x402/fetch";
import { registerExactEvmScheme } from "@x402/evm/exact/client";
import { z } from "zod";
 
// --- 지갑 및 x402 클라이언트 ---
const account = await new WalletManagerEvm(process.env.SEED_PHRASE!, {
  provider: "https://rpc.stable.xyz",
}).getAccount(0);
 
const client = new x402Client();
registerExactEvmScheme(client, { signer: account });
const fetchWithPayment = wrapFetchWithPayment(fetch, client);
 
// --- x402 API 기본 URL ---
const API_BASE = process.env.API_BASE || "http://localhost:4021";
 
// --- MCP 서버 ---
const server = new McpServer({
  name: "x402-payments",
  version: "1.0.0",
});
 
server.tool(
  "get_company_financials",
  "티커로 회사 재무 데이터 가져오기 (유료 엔드포인트, 호출당 $0.01)",
  { ticker: z.string().describe("회사 티커 심볼 (예: ACME)") },
  async ({ ticker }) => {
    const response = await fetchWithPayment(`${API_BASE}/financials?ticker=${ticker}`);
    const data = await response.json();
    return { content: [{ type: "text", text: JSON.stringify(data) }] };
  },
);
 
server.tool(
  "assess_credit_risk",
  "재무 데이터로 신용 위험 평가 (유료 엔드포인트, 호출당 $0.05)",
  { financials: z.string().describe("회사 재무 데이터의 JSON 문자열") },
  async ({ financials }) => {
    const response = await fetchWithPayment(`${API_BASE}/credit-risk`, {
      method: "POST",
      headers: { "Content-Type": "application/json" },
      body: financials,
    });
    const data = await response.json();
    return { content: [{ type: "text", text: JSON.stringify(data) }] };
  },
);
 
server.tool(
  "check_balance",
  "결제 지갑의 USDT0 잔액 확인",
  {},
  async () => {
    const USDT0_STABLE = "0x779Ded0c9e1022225f8E0630b35a9b54bE713736";
    const balance = await account.getTokenBalance(USDT0_STABLE);
    const formatted = (Number(balance) / 1e6).toFixed(2);
    return {
      content: [{ type: "text", text: `지갑 잔액: ${formatted} USDT0` }],
    };
  },
);
 
// --- 시작 ---
const transport = new StdioServerTransport();
await server.connect(transport);

{
  "mcpServers": {
    "x402-payments": {
      "command": "npx",
      "args": ["tsx", "/path/to/mcp-server.ts"],
      "env": {
        "SEED_PHRASE": "여기에 시드 문구 입력",
        "API_BASE": "https://api.example.com"
      }
    }
  }
}

claude mcp add x402-payments -- npx tsx /path/to/mcp-server.ts

const MAX_PER_CALL = 100_000;   // 기본 단위로 $0.10
const MAX_PER_SESSION = 5_000_000; // 기본 단위로 $5.00
let sessionSpent = 0n;
 
function checkSpendingLimit(amount: bigint) {
  if (amount > BigInt(MAX_PER_CALL)) {
    throw new Error(`금액이 호출당 제한인 ${MAX_PER_CALL / 1e6}을 초과합니다.`);
  }
  if (sessionSpent + amount > BigInt(MAX_PER_SESSION)) {
    throw new Error(`세션 지출 한도인 ${MAX_PER_SESSION / 1e6}에 도달했습니다.`);
  }
  sessionSpent += amount;
}