분석 및 수익 추적

// analytics.ts
// 결제 이벤트를 수집하고 저장하는 분석 모듈

import { PaymentEvent } from "x402-middleware";

// 결제 이벤트 타입 정의
interface AnalyticsEvent {
  timestamp: Date;
  path: string;           // 요청된 문서 경로
  agentId: string;        // AI 에이전트 식별자
  amount: number;         // 결제 금액 (USDC)
  txHash: string;         // 블록체인 트랜잭션 해시
  network: string;        // 사용된 네트워크 (예: "base")
  userAgent: string;      // 에이전트 User-Agent 헤더
}

// 결제 완료 시 호출되는 콜백 함수
export async function trackPayment(event: PaymentEvent): Promise<void> {
  const analyticsEvent: AnalyticsEvent = {
    timestamp: new Date(),
    path: event.request.path,
    agentId: event.payment.from,      // 결제자 지갑 주소
    amount: event.payment.amount,
    txHash: event.payment.txHash,
    network: event.payment.network,
    userAgent: event.request.headers["user-agent"] || "unknown",
  };

  // 데이터베이스에 저장
  // 사용하는 DB에 맞게 구현 (PostgreSQL, MongoDB 등)
  await db.collection("x402_payments").insertOne(analyticsEvent);

  // 실시간 대시보드 업데이트 (선택사항)
  await updateRealtimeDashboard(analyticsEvent);
}

// agent-analytics.ts
// AI 에이전트별 사용 패턴 분석

// 에이전트별 사용량 및 지출 현황
export async function getAgentStats() {
  return db.collection("x402_payments").aggregate([
    {
      $group: {
        _id: "$agentId",
        totalSpent: { $sum: "$amount" },
        requestCount: { $sum: 1 },
        firstSeen: { $min: "$timestamp" },
        lastSeen: { $max: "$timestamp" },
        contentAccessed: { $addToSet: "$path" }
      }
    },
    {
      $project: {
        agentId: "$_id",
        totalSpent: 1,
        requestCount: 1,
        firstSeen: 1,
        lastSeen: 1,
        uniquePages: { $size: "$contentAccessed" },
        avgSpentPerRequest: {
          $divide: ["$totalSpent", "$requestCount"]
        }
      }
    },
    { $sort: { totalSpent: -1 } }
  ]).toArray();
}

// User-Agent 기반 에이전트 유형 분류
export function categorizeAgent(userAgent: string): string {
  const patterns = [
    { regex: /Claude/i, category: "Claude (Anthropic)" },
    { regex: /GPT|OpenAI/i, category: "GPT (OpenAI)" },
    { regex: /Cursor/i, category: "Cursor IDE" },
    { regex: /GitHub Copilot/i, category: "GitHub Copilot" },
    { regex: /Perplexity/i, category: "Perplexity AI" },
  ];

  for (const { regex, category } of patterns) {
    if (regex.test(userAgent)) return category;
  }
  return "Other AI Agent";
}

// 에이전트 유형별 통계
export async function getAgentTypeDistribution() {
  const payments = await db.collection("x402_payments")
    .find({})
    .toArray();

  const distribution: Record<string, { count: number; revenue: number }> = {};

  for (const payment of payments) {
    const category = categorizeAgent(payment.userAgent);
    if (!distribution[category]) {
      distribution[category] = { count: 0, revenue: 0 };
    }
    distribution[category].count++;
    distribution[category].revenue += payment.amount;
  }

  return distribution;
}