Crypto Market Data x402 Integration

Real-time crypto prices, OHLCV, orderbook for 10,000+ tokens with premium data tiers.

Overview

Repository: nirholas/crypto-market-data
MCP Registry: io.github.nirholas/crypto-market-data
x402 Use Case: Pay-per-query for premium data, real-time streams, historical depth

Installation

npm install @nirholas/x402-ecosystem @nirholas/crypto-market-data

Integration Pattern

import { PricingStrategy, PaywallBuilder } from '@nirholas/x402-ecosystem/premium';
import { MarketDataClient } from '@nirholas/crypto-market-data';

// Resource-based pricing for data queries
const dataPricing = PricingStrategy.resourceBased({
  'price-single': 0,           // Free: single price
  'price-batch': 0.001,        // $0.001 per 100 tokens
  'ohlcv-1d': 0.002,           // $0.002 per query
  'ohlcv-1h': 0.005,           // $0.005 per query (higher resolution)
  'ohlcv-1m': 0.02,            // $0.02 per query (minute data)
  'orderbook-l1': 0.001,       // $0.001 top of book
  'orderbook-l2': 0.01,        // $0.01 full depth
  'trades-realtime': 0.05,     // $0.05/hour stream
});

// Build paywall
const marketData = new PaywallBuilder()
  .service('crypto-market-data')
  .pricing(dataPricing)
  .rateLimit({ free: 100, premium: 10000 }) // per hour
  .build();

// Usage
async function getOHLCV(symbol: string, interval: string, limit: number) {
  const resourceType = `ohlcv-${interval}`;
  const price = dataPricing.calculate({ resource: resourceType });

  if (price > 0) {
    await marketData.charge(price, { symbol, interval, limit });
  }

  return MarketDataClient.ohlcv(symbol, interval, limit);
}

Data Tiers

Endpoint	Free Tier	Premium
Current prices	✅ 100/hr	✅ Unlimited
24h OHLCV	✅ 10/hr	✅ $0.002/query
Hourly OHLCV	❌	✅ $0.005/query
Minute OHLCV	❌	✅ $0.02/query
L1 Orderbook	✅ 10/hr	✅ $0.001/query
L2 Orderbook	❌	✅ $0.01/query
Trade stream	❌	✅ $0.05/hour
Historical (30d+)	❌	✅ $0.10/query

Streaming with x402

import { PayableAgent } from '@nirholas/x402-ecosystem/agent';

const agent = new PayableAgent({
  wallet: agentWallet,
  dailyLimit: 10, // $10/day max for data
});

// Subscribe to real-time trades
const subscription = await agent.subscribe({
  service: 'crypto-market-data',
  endpoint: 'trades-realtime',
  symbols: ['BTC/USDT', 'ETH/USDT'],
  costPerHour: 0.05,
  maxHours: 24
});

subscription.on('trade', (trade) => {
  console.log(`${trade.symbol}: ${trade.price} x ${trade.amount}`);
});

Batch Queries

// Efficient batch pricing
async function getBatchPrices(symbols: string[]) {
  const batchSize = symbols.length;
  const cost = Math.ceil(batchSize / 100) * 0.001; // $0.001 per 100

  if (cost > 0) {
    await marketData.charge(cost, { batch: symbols });
  }

  return MarketDataClient.batchPrices(symbols);
}

Revenue Model

const revenueSplit = {
  dataProvider: 0.60,   // Crypto Market Data
  ecosystem: 0.25,      // Universal Crypto MCP
  infrastructure: 0.15  // x402 + data sources
};