加密货币市场数据服务器

======================== test session starts ========================
collected 35 items

testsuite.py::TestDataModels ✓✓✓✓✓✓✓✓ (8 passed)
testsuite.py::TestCacheManager ✓✓✓✓✓✓ (6 passed)
testsuite.py::TestExchangeManager ✓✓✓ (3 passed)
testsuite.py::TestCryptoMCPServer ✓✓✓✓✓✓✓✓✓✓✓✓✓✓ (14 passed)
testsuite.py::TestIntegration ✓✓✓ (3 passed)
testsuite.py::TestPerformance ✓✓ (2 passed)

======================== 35 passed in 5.23s ========================

Overall Coverage: 90%
└── mainserver.py: 78% coverage
└── testsuite.py: 99% coverage

git clone https://github.com/HarshSRao95/Cryptocurrency-MCP-Server.git
cd mcpserver

python -m venv venv

source venv/bin/activate          # Mac/Linux
venv\Scripts\activate             # Windows

pip install -r requirements.txt

pytest testsuite.py -v
pytest testsuite.py --cov   # with coverage

python mainserver.py

python examples.py        # All examples
python my_script.py       # Your custom script

black --check *.py                # Format check
flake8 *.py                       # Lint check

pytest --cov --cov-report=html

deactivate

2025-11-15 20:35:21,226 - __main__ - INFO - Initialized binance exchange
2025-11-15 20:35:21,264 - __main__ - INFO - Initialized coinbase exchange
2025-11-15 20:35:21,305 - __main__ - INFO - Initialized kraken exchange
2025-11-15 20:35:21,359 - __main__ - INFO - Initialized bitfinex exchange
2025-11-15 20:35:21,454 - __main__ - INFO - Initialized huobi exchange

=== Real-time Ticker ===
BTC/USDT Price: $43,256.78
24h Change: +2.34%

=== Historical Data ===
Retrieved 24 hourly candles
Latest close: $43,256.78
...

mcpserver/                    ← Main project folder
│
├── 📄 mainserver.py           ← Main server code (CORE FILE)
├── 📄 testsuite.py      ← Test suite (70+ tests)
├── 📄 examples.py                     ← 10 usage examples
├── 📄 setup.py                        ← Package configuration
├── 📄 requirements.txt                ← Dependencies list
│
├── 📄 README.md                       ← Main documentation
├── 📄 LICENSE                         ← MIT License
│
├── 📄 Dockerfile                      ← Docker container setup
├── 📄 .gitignore                      ← Git ignore rules
├── 📄 .env.example                    ← Environment template
├── 📄 .env                            ← Your config (create this)
│
├── 📁 venv/                           ← Virtual environment (created)
│   ├── bin/                          ← Scripts (activate, python, pip)
│   ├── lib/                          ← Installed packages
│   └── ...
│
├── 📁 .github/                        ← GitHub configuration
│   └── workflows/
│       └── ci.yml                    ← CI/CD pipeline
│
├── 📁 tests/                          ← Alternative test location
│   └── __init__.py
│
└── 📁 htmlcov/                        ← Coverage reports (generated)
    └── index.html

import asyncio
from mainserver import CryptoMCPServer, MarketDataRequest, Exchange

async def main():
    server = CryptoMCPServer()
    
    # Get current BTC price
    request = MarketDataRequest(
        symbol="BTC/USDT",
        exchange=Exchange.BINANCE
    )
    ticker = await server.get_ticker(request)
    
    print(f"BTC Price: ${ticker.last:,.2f}")
    print(f"24h Change: {ticker.change_24h:+.2f}%")
    print(f"Volume: {ticker.volume:,.0f}")

asyncio.run(main())

BTC Price: $43,256.78
24h Change: +2.34%
Volume: 1,234,567

from mainserver import HistoricalDataRequest, TimeFrame

async def get_history():
    server = CryptoMCPServer()
    
    # Get last 24 hours of hourly data
    request = HistoricalDataRequest(
        symbol="BTC/USDT",
        exchange=Exchange.BINANCE,
        timeframe=TimeFrame.H1,  # Hourly candles
        limit=24
    )
    
    candles = await server.get_ohlcv(request)
    
    print(f"Retrieved {len(candles)} hourly candles")
    for candle in candles[-5:]:  # Last 5 candles
        print(f"{candle.timestamp}: ${candle.close:,.2f}")

asyncio.run(get_history())

Retrieved 24 hourly candles
2025-11-15 18:00:00: $43,156.78
2025-11-15 19:00:00: $43,234.56
2025-11-15 20:00:00: $43,189.23
2025-11-15 21:00:00: $43,245.67
2025-11-15 22:00:00: $43,256.78

async def compare_prices():
    server = CryptoMCPServer()
    
    # Compare BTC price across multiple exchanges
    prices = await server.get_multi_exchange_ticker(
        "BTC/USDT",
        [Exchange.BINANCE, Exchange.KRAKEN, Exchange.COINBASE]
    )
    
    print("BTC/USDT Price Comparison:")
    for exchange, ticker in prices.items():
        print(f"  {exchange:12} ${ticker.last:,.2f}")
    
    # Find best price
    best = min(prices.items(), key=lambda x: x[1].last)
    print(f"\nBest price on {best[0]}: ${best[1].last:,.2f}")

asyncio.run(compare_prices())

BTC/USDT Price Comparison:
  binance      $43,256.78
  kraken       $43,289.12
  coinbase     $43,267.45

Best price on binance: $43,256.78

async def analyze_price():
    server = CryptoMCPServer()
    
    # Get 7 days of daily data
    request = HistoricalDataRequest(
        symbol="BTC/USDT",
        timeframe=TimeFrame.D1,
        limit=7
    )
    
    stats = await server.get_price_statistics(request)
    
    print(f"Weekly Statistics for {stats['symbol']}:")
    print(f"  Current Price: ${stats['current_price']:,.2f}")
    print(f"  Average Price: ${stats['average_price']:,.2f}")
    print(f"  High: ${stats['highest_price']:,.2f}")
    print(f"  Low: ${stats['lowest_price']:,.2f}")
    print(f"  Volatility: ${stats['volatility']:,.2f}")
    print(f"  Weekly Change: {stats['price_change_percent']:+.2f}%")

asyncio.run(analyze_price())

Weekly Statistics for BTC/USDT:
  Current Price: $43,256.78
  Average Price: $42,890.45
  High: $44,123.56
  Low: $41,234.89
  Volatility: $456.23
  Weekly Change: +3.45%

async def get_orderbook():
    server = CryptoMCPServer()
    
    request = MarketDataRequest(
        symbol="BTC/USDT",
        exchange=Exchange.BINANCE
    )
    
    orderbook = await server.get_orderbook(request, limit=5)
    
    print("Order Book:")
    print("\nTop 5 Asks (Sell Orders):")
    for i, (price, amount) in enumerate(orderbook.asks[:5], 1):
        print(f"  {i}. ${price:,.2f} × {amount:.4f} BTC")
    
    print("\nTop 5 Bids (Buy Orders):")
    for i, (price, amount) in enumerate(orderbook.bids[:5], 1):
        print(f"  {i}. ${price:,.2f} × {amount:.4f} BTC")
    
    spread = orderbook.asks[0][0] - orderbook.bids[0][0]
    print(f"\nBid-Ask Spread: ${spread:.2f}")

asyncio.run(get_orderbook())

async def price_monitor(symbol, threshold, duration=60):
    """Monitor price and alert when threshold crossed"""
    server = CryptoMCPServer()
    request = MarketDataRequest(symbol=symbol, exchange=Exchange.BINANCE)
    
    print(f"Monitoring {symbol}, alerting if > ${threshold:,.2f}")
    
    for _ in range(duration):
        ticker = await server.get_ticker(request)
        if ticker.last > threshold:
            print(f"🚨 ALERT! {symbol} is ${ticker.last:,.2f}")
            break
        print(f"Current: ${ticker.last:,.2f}", end='\r')
        await asyncio.sleep(1)

asyncio.run(price_monitor("BTC/USDT", 50000, duration=30))

# Basic test run
pytest testsuite.py -v

# With detailed output
pytest testsuite.py -vv

# With coverage report
pytest testsuite.py --cov=mainserver --cov-report=html

# View coverage report
open htmlcov/index.html  # Mac/Linux
start htmlcov/index.html # Windows

# Run specific test class
pytest testsuite.py::TestCryptoMCPServer -v

# Run only data model tests
pytest testsuite.py::TestDataModels -v

# Run only integration tests
pytest testsuite.py::TestIntegration -v

# Run performance tests
pytest testsuite.py::TestPerformance -v

request = MarketDataRequest(symbol="BTC/USDT", exchange=Exchange.BINANCE)
ticker = await server.get_ticker(request)

request = HistoricalDataRequest(
    symbol="BTC/USDT",
    timeframe=TimeFrame.H1,
    limit=100
)
candles = await server.get_ohlcv(request)

┌─────────────────────────────────────────┐
│         CryptoMCPServer                 │
│  (Main API - Your interface)           │
└──────────────┬──────────────────────────┘
               │
       ┌───────┴────────┐
       │                │
┌──────▼─────┐   ┌──────▼────────┐
│   Cache    │   │   Exchange    │
│  Manager   │   │   Manager     │
└────────────┘   └───────┬───────┘
                         │
              ┌──────────┼──────────┐
              │          │          │
         ┌────▼───┐ ┌───▼───┐ ┌───▼────┐
         │Binance │ │Kraken │ │Coinbase│
         └────────┘ └───────┘ └────────┘

# Logging Configuration
LOG_LEVEL=INFO
LOG_FILE=mcp_server.log

# Cache Configuration (seconds)
TICKER_CACHE_TTL=10
OHLCV_CACHE_TTL=60
ORDERBOOK_CACHE_TTL=5

# Cache Size Limits
TICKER_CACHE_SIZE=1000
OHLCV_CACHE_SIZE=500
ORDERBOOK_CACHE_SIZE=500

# Rate Limiting
MAX_REQUESTS_PER_MINUTE=1200
REQUEST_TIMEOUT=30000

# Optional: Exchange API Keys (for authenticated endpoints)
BINANCE_API_KEY=your_api_key_here
BINANCE_API_SECRET=your_api_secret_here

# Server Configuration (if adding HTTP API)
HOST=0.0.0.0
PORT=8000
DEBUG=False

# Build Docker image
docker build -t mcpserver .

# Run container
docker run -d \
  --name mcp-crypto \
  -p 8000:8000 \
  -e LOG_LEVEL=INFO \
  mcpserver

# View logs
docker logs -f mcp-crypto

# Stop container
docker stop mcp-crypto

version: '3.8'

services:
  mcp-crypto:
    build: .
    container_name: mcpserver
    restart: unless-stopped
    ports:
      - "8000:8000"
    environment:
      - LOG_LEVEL=INFO
      - TICKER_CACHE_TTL=10
    volumes:
      - ./logs:/app/logs

2025-11-15 20:35:21,226 - __main__ - INFO - Initialized binance exchange
2025-11-15 20:35:21,264 - __main__ - INFO - Initialized coinbase exchange

=== Real-time Ticker ===
BTC/USDT Price: $43,256.78
24h Change: +2.34%
Volume: 1,234,567

=== Historical Data ===
Retrieved 24 hourly candles
Latest close: $43,256.78

=== Price Statistics ===
Average Price: $42,890.45
24h Change: +0.85%
Volatility: $456.23

=== Multi-Exchange Comparison ===
binance: $43,256.78
kraken: $43,289.12

=== Server Status ===
Total Requests: 5
Error Rate: 0.00%