Upload 7 files

.dockerignore

@@ -1,16 +1,41 @@
+# Node modules
+node_modules/
+frontend/node_modules/
+
+# Build artifacts
+frontend/dist/
+
+# Python cache
 __pycache__/
-*.py[cod]
-*$py.class
+*.pyc
+*.pyo
+*.pyd
+.Python
 *.so
+
+# Environment files
 .env
-.venv
-env/
-venv/
-ENV/
-.DS_Store
-.git
+.env.local
+.env.*.local
+
+# IDE
+.vscode/
+.idea/
+*.swp
+*.swo
+
+# Git
+.git/
 .gitignore
+
+# OS
+.DS_Store
+Thumbs.db
+
+# Logs
 *.log
-*.sqlite
-.idea/
-.vscode/
+logs/
+
+# Testing
+coverage/
+.pytest_cache/

Dockerfile

@@ -1,38 +1,47 @@
-FROM python:3.9-slim
+# Stage 1: Build Frontend
+FROM node:18-slim AS frontend-builder
 
-WORKDIR /code
+WORKDIR /app/frontend
+
+# Copy frontend package files
+COPY frontend/package*.json ./
+
+# Install dependencies
+RUN npm install
+
+# Copy frontend source
+COPY frontend/ ./
+
+# Build frontend
+RUN npm run build
+
+# Stage 2: Setup Backend and Serve
+FROM python:3.10-slim
+
+WORKDIR /app
 
 # Install system dependencies
-RUN apt-get update && \
-    apt-get install -y --no-install-recommends \
-    build-essential \
-    curl \
-    git \
-    && apt-get clean \
+RUN apt-get update && apt-get install -y \
+    gcc \
     && rm -rf /var/lib/apt/lists/*
 
-# Create necessary directories
-RUN mkdir -p /code/data /code/logs
-
-# Copy requirements first to leverage Docker cache
-COPY requirements.txt .
+# Copy backend requirements
+COPY backend/requirements.txt ./
 
 # Install Python dependencies
-RUN pip install --no-cache-dir --upgrade pip && \
-    pip install --no-cache-dir -r requirements.txt
-
-# Copy application code
-COPY . .
+RUN pip install --no-cache-dir -r requirements.txt
 
-# Ensure directories have correct permissions
-RUN chmod -R 755 /code/data /code/logs
+# Copy backend code
+COPY backend/ ./backend/
 
-# Set environment variables
-ENV PYTHONPATH=/code
-ENV PORT=7860
+# Copy built frontend from previous stage
+COPY --from=frontend-builder /app/frontend/dist ./frontend/dist
 
-# Expose the port
+# Expose Hugging Face Space port
 EXPOSE 7860
 
+# Set environment variables
+ENV PYTHONUNBUFFERED=1
+
 # Run the application
-CMD ["uvicorn", "main:app", "--host", "0.0.0.0", "--port", "7860"]
+CMD ["uvicorn", "backend.app:app", "--host", "0.0.0.0", "--port", "7860"]

README.md

@@ -1,42 +1,51 @@
 ---
-title: Cryptocurrency Data API
+title: Datasourceforcryptocurrency
 emoji: 📈
 colorFrom: blue
 colorTo: green
 sdk: docker
-app_port: 7860
 pinned: false
+app_port: 7860
 ---
 
-# Cryptocurrency Data Source API
+# Crypto Data Source & Trading System
 
-This API provides cryptocurrency market data from various exchanges using the CCXT library.
+A comprehensive cryptocurrency data source and trading platform built with FastAPI backend and React frontend.
 
 ## Features
 
-- Access to multiple cryptocurrency exchanges
-- OHLCV (Open, High, Low, Close, Volume) data
-- Easy integration with trading systems
+- Real-time cryptocurrency market data
+- Technical analysis indicators
+- Trading signals
+- Portfolio management
+- Multi-exchange support via CCXT
 
 ## API Endpoints
 
-- `GET /` - API status and version
-- `GET /exchanges` - List all available exchanges
-- `GET /markets/{exchange_id}` - Get markets for a specific exchange
-- `GET /ohlcv/{exchange_id}/{symbol}` - Get OHLCV data for a specific market
-- `GET /health` - Health check endpoint
+- `GET /api/health` - Health check
+- `GET /api/markets` - List available markets
+- `GET /api/ticker/{symbol}` - Get ticker data for a symbol
+
+## Documentation
 
-## Usage
+Visit `/docs` for interactive API documentation.
 
-Once deployed, visit the `/docs` endpoint to see the interactive API documentation.
+## Local Development
 
-## Development
+### Backend
+```bash
+cd backend
+pip install -r requirements.txt
+uvicorn app:app --reload --port 8000
+```
 
-Built with:
-- FastAPI - Modern, fast web framework
-- CCXT - Cryptocurrency exchange trading library
-- Docker - Containerization
+### Frontend
+```bash
+cd frontend
+npm install
+npm run dev
+```
 
-## Deployment on Hugging Face Spaces
+## Deployment
 
-This project is designed to be deployed as a Docker space on Hugging Face.
+This Space automatically builds and deploys on push to the main branch.

SUMMARY.md

@@ -0,0 +1,109 @@
+# 📦 فایل‌های دانلود شده برای Hugging Face Space
+
+## ✅ فایل‌هایی که دانلود کردید:
+
+### 1️⃣ `Dockerfile`
+**کاربرد**: تنظیمات Docker برای build کردن و اجرای پروژه
+- Stage 1: Build کردن Frontend (React/Vite)
+- Stage 2: نصب Backend (FastAPI) + کپی کردن Frontend بیلد شده
+**مکان**: ریشه پروژه (root)
+
+---
+
+### 2️⃣ `app.py`
+**کاربرد**: Backend اصلی FastAPI
+**ویژگی‌ها**:
+- ✅ Serve کردن API endpoints (مثل `/api/health`, `/api/markets`)
+- ✅ Serve کردن Frontend static files
+- ✅ CORS middleware برای دسترسی از همه جا
+- ✅ Integration با CCXT برای دیتای کریپتو
+**مکان**: `backend/app.py`
+
+---
+
+### 3️⃣ `requirements.txt`
+**کاربرد**: لیست کتابخانه‌های Python
+**شامل**:
+- fastapi: فریمورک وب
+- uvicorn: ASGI server
+- ccxt: دسترسی به exchange ها
+- و سایر dependencies
+**مکان**: `backend/requirements.txt`
+
+---
+
+### 4️⃣ `README.md`
+**کاربرد**: توضیحات و تنظیمات Hugging Face Space
+**شامل**:
+- Metadata برای Space (emoji, SDK, port)
+- مستندات پروژه
+- راهنمای استفاده
+**مکان**: ریشه پروژه (root)
+
+---
+
+### 5️⃣ `.dockerignore`
+**کاربرد**: فایل‌هایی که نباید در Docker build کپی بشن
+**شامل**: node_modules, cache files, logs, etc.
+**مکان**: ریشه پروژه (root)
+
+---
+
+### 6️⃣ `راهنمای_نصب.md`
+**کاربرد**: راهنمای کامل فارسی برای بارگذاری
+**شامل**:
+- ساختار پوشه‌ها
+- مراحل بارگذاری
+- عیب‌یابی
+**مکان**: فقط برای مطالعه (نیاز به آپلود نیست)
+
+---
+
+## 🎯 چطور استفاده کنم؟
+
+### گام 1: دانلود
+همه فایل‌ها رو دانلود کن از پایین صفحه
+
+### گام 2: ساختار
+پوشه‌های پروژه رو مطابق این ساختار بچین:
+```
+Datasourceforcryptocurrency/
+├── Dockerfile
+├── README.md
+├── .dockerignore
+├── backend/
+│   ├── app.py
+│   └── requirements.txt
+└── frontend/
+    └── ... (فایل‌های موجود شما)
+```
+
+### گام 3: آپلود
+یا از Web UI Hugging Face آپلود کن یا با Git push کن
+
+### گام 4: منتظر بمون
+Space خودش rebuild می‌شه و بعدش UI کار می‌کنه!
+
+---
+
+## ⚠️ نکات مهم:
+
+1. **پوشه backend**: حتماً بساز و فایل‌ها رو داخلش بذار
+2. **Frontend باید داشته باشه**: `package.json`, `vite.config.js`, `src/`
+3. **Port 7860**: حتماً این port رو استفاده کن (الزامی Hugging Face)
+4. **بعد از push**: 5-10 دقیقه صبر کن تا rebuild بشه
+
+---
+
+## 🆘 مشکل داری؟
+
+اگر بعد از آپلود باز هم JSON می‌بینی:
+1. لاگ Build رو چک کن
+2. مطمئن شو frontend/dist ساخته شده
+3. مطمئن شو به root URL دسترسی داری (`/`) نه (`/api`)
+
+برای کمک بیشتر، لاگ‌ها یا screenshot بفرست! 💪
+
+---
+
+**آماده‌س! همه فایل‌ها پایین صفحه‌ان، دانلودشون کن و آپلود کن! 🚀**

app.py

@@ -1,629 +1,85 @@
-"""
-Crypto API Monitoring System - Main Application
-Production-ready FastAPI application with comprehensive monitoring and WebSocket support
-"""
-
-import asyncio
-import uvicorn
-from datetime import datetime
-from contextlib import asynccontextmanager
-
-from fastapi import FastAPI, Request
-from fastapi.middleware.cors import CORSMiddleware
-from fastapi.responses import JSONResponse, HTMLResponse, FileResponse
+from fastapi import FastAPI
 from fastapi.staticfiles import StaticFiles
+from fastapi.responses import FileResponse
+from fastapi.middleware.cors import CORSMiddleware
+import os
+import ccxt
+from datetime import datetime
+from pathlib import Path
 
-# Import API modules
-from api.endpoints import router as api_router
-from api.websocket import router as websocket_router, manager as ws_manager
-from api.pool_endpoints import router as pool_router
-from api.data_endpoints import router as data_router
-
-# Import new WebSocket service routers
-from api.ws_unified_router import router as ws_unified_router, start_all_websocket_streams
-from api.ws_data_services import router as ws_data_router
-from api.ws_monitoring_services import router as ws_monitoring_router
-from api.ws_integration_services import router as ws_integration_router
-
-# Import monitoring and database modules
-from monitoring.scheduler import task_scheduler
-from monitoring.rate_limiter import rate_limiter
-from database.db_manager import db_manager
-from config import config
-from utils.logger import setup_logger
-
-# Setup logger
-logger = setup_logger("main", level="INFO")
-
-# Import HF router (optional, graceful fallback)
-try:
-    from backend.routers import hf_connect
-    HF_ROUTER_AVAILABLE = True
-except Exception as e:
-    logger.warning(f"HF router not available: {e}")
-    HF_ROUTER_AVAILABLE = False
-
-
-# ============================================================================
-# Lifespan Context Manager for Startup/Shutdown Events
-# ============================================================================
-
-@asynccontextmanager
-async def lifespan(app: FastAPI):
-    """
-    Lifespan context manager for application startup and shutdown
-
-    Handles:
-    - Database initialization
-    - Scheduler startup
-    - Rate limiter configuration
-    - WebSocket background tasks
-    - Graceful shutdown
-    """
-    logger.info("=" * 80)
-    logger.info("Starting Crypto API Monitoring System")
-    logger.info("=" * 80)
-
-    try:
-        # ===== STARTUP SEQUENCE =====
-
-        # 1. Initialize database
-        logger.info("Initializing database...")
-        db_manager.init_database()
-
-        # Verify database health
-        db_health = db_manager.health_check()
-        if db_health.get('status') == 'healthy':
-            logger.info(f"Database initialized successfully: {db_health.get('database_path')}")
-        else:
-            logger.error(f"Database health check failed: {db_health}")
-
-        # 2. Configure rate limiters for all providers
-        logger.info("Configuring rate limiters...")
-        providers = config.get_all_providers()
-
-        for provider in providers:
-            if provider.rate_limit_type and provider.rate_limit_value:
-                rate_limiter.configure_limit(
-                    provider=provider.name,
-                    limit_type=provider.rate_limit_type,
-                    limit_value=provider.rate_limit_value
-                )
-                logger.info(
-                    f"Configured rate limit for {provider.name}: "
-                    f"{provider.rate_limit_value} {provider.rate_limit_type}"
-                )
-
-        logger.info(f"Configured rate limiters for {len(providers)} providers")
-
-        # 3. Populate database with provider configurations
-        logger.info("Populating database with provider configurations...")
-
-        for provider in providers:
-            # Check if provider already exists in database
-            db_provider = db_manager.get_provider(name=provider.name)
-
-            if not db_provider:
-                # Create new provider in database
-                db_provider = db_manager.create_provider(
-                    name=provider.name,
-                    category=provider.category,
-                    endpoint_url=provider.endpoint_url,
-                    requires_key=provider.requires_key,
-                    api_key_masked=provider._mask_key() if provider.api_key else None,
-                    rate_limit_type=provider.rate_limit_type,
-                    rate_limit_value=provider.rate_limit_value,
-                    timeout_ms=provider.timeout_ms,
-                    priority_tier=provider.priority_tier
-                )
-
-                if db_provider:
-                    logger.info(f"Added provider to database: {provider.name}")
-
-                    # Create schedule configuration for the provider
-                    # Set interval based on category
-                    interval_map = {
-                        'market_data': 'every_1_min',
-                        'blockchain_explorers': 'every_5_min',
-                        'news': 'every_10_min',
-                        'sentiment': 'every_15_min',
-                        'onchain_analytics': 'every_5_min',
-                        'rpc_nodes': 'every_5_min',
-                        'cors_proxies': 'every_30_min'
-                    }
-
-                    schedule_interval = interval_map.get(provider.category, 'every_5_min')
-
-                    schedule_config = db_manager.create_schedule_config(
-                        provider_id=db_provider.id,
-                        schedule_interval=schedule_interval,
-                        enabled=True
-                    )
-
-                    if schedule_config:
-                        logger.info(
-                            f"Created schedule config for {provider.name}: {schedule_interval}"
-                        )
-
-        # 4. Start HF registry background refresh (if available)
-        if HF_ROUTER_AVAILABLE:
-            try:
-                from backend.services.hf_registry import periodic_refresh
-                logger.info("Starting HF registry background refresh...")
-                asyncio.create_task(periodic_refresh())
-                logger.info("HF registry background refresh started")
-            except Exception as e:
-                logger.warning(f"Could not start HF background refresh: {e}")
-
-        # 5. Start WebSocket background tasks
-        logger.info("Starting WebSocket background tasks...")
-        await ws_manager.start_background_tasks()
-        logger.info("WebSocket background tasks started")
-
-        # 5.1 Start new WebSocket service streams
-        logger.info("Starting WebSocket service streams...")
-        asyncio.create_task(start_all_websocket_streams())
-        logger.info("WebSocket service streams started")
-
-        # 6. Start task scheduler
-        logger.info("Starting task scheduler...")
-        task_scheduler.start()
-        logger.info("Task scheduler started successfully")
-
-        # 7. Start WebSocket data broadcaster
-        logger.info("Starting WebSocket data broadcaster...")
-        try:
-            from api.ws_data_broadcaster import broadcaster
-            asyncio.create_task(broadcaster.start_broadcasting())
-            logger.info("WebSocket data broadcaster started")
-        except Exception as e:
-            logger.warning(f"Could not start WebSocket data broadcaster: {e}")
-
-        # Log startup summary
-        logger.info("=" * 80)
-        logger.info("Crypto API Monitoring System started successfully")
-        logger.info(f"Total providers configured: {len(providers)}")
-        logger.info(f"Database: {db_health.get('database_path')}")
-        logger.info(f"Scheduler running: {task_scheduler.is_running()}")
-        logger.info(f"WebSocket manager active: {ws_manager._is_running}")
-        logger.info("=" * 80)
-
-        yield  # Application runs here
-
-        # ===== SHUTDOWN SEQUENCE =====
-
-        logger.info("=" * 80)
-        logger.info("Shutting down Crypto API Monitoring System...")
-        logger.info("=" * 80)
-
-        # 1. Stop WebSocket data broadcaster
-        logger.info("Stopping WebSocket data broadcaster...")
-        try:
-            from api.ws_data_broadcaster import broadcaster
-            await broadcaster.stop_broadcasting()
-            logger.info("WebSocket data broadcaster stopped")
-        except Exception as e:
-            logger.warning(f"Error stopping WebSocket data broadcaster: {e}")
-
-        # 2. Stop task scheduler
-        logger.info("Stopping task scheduler...")
-        task_scheduler.stop()
-        logger.info("Task scheduler stopped")
-
-        # 3. Stop WebSocket background tasks
-        logger.info("Stopping WebSocket background tasks...")
-        await ws_manager.stop_background_tasks()
-        logger.info("WebSocket background tasks stopped")
-
-        # 4. Close all WebSocket connections
-        logger.info("Closing WebSocket connections...")
-        await ws_manager.close_all_connections()
-        logger.info("WebSocket connections closed")
-
-        logger.info("=" * 80)
-        logger.info("Crypto API Monitoring System shut down successfully")
-        logger.info("=" * 80)
-
-    except Exception as e:
-        logger.error(f"Error during application lifecycle: {e}", exc_info=True)
-        raise
-
-
-# ============================================================================
-# Create FastAPI Application
-# ============================================================================
-
-app = FastAPI(
-    title="Crypto API Monitoring System",
-    description="""
-    Comprehensive cryptocurrency API monitoring system with real-time WebSocket updates.
-
-    Features:
-    - Multi-provider API monitoring
-    - Real-time WebSocket streaming for all services
-    - Data collection APIs: Market data, News, Sentiment, Whale tracking, RPC nodes, On-chain analytics
-    - Monitoring APIs: Health checks, Pool management, Scheduler status
-    - Integration APIs: HuggingFace AI/ML, Persistence services
-    - Subscription-based message routing
-    - Rate limit tracking
-    - Automated health checks
-    - Scheduled data collection
-    - Failure detection and alerts
-    - Historical analytics
-
-    WebSocket Endpoints:
-    - Master: /ws, /ws/master, /ws/all
-    - Data Collection: /ws/data, /ws/market_data, /ws/news, /ws/sentiment, /ws/whale_tracking
-    - Monitoring: /ws/monitoring, /ws/health, /ws/pool_status, /ws/scheduler_status
-    - Integration: /ws/integration, /ws/huggingface, /ws/ai, /ws/persistence
-    - Legacy: /ws/live
-    """,
-    version="2.0.0",
-    lifespan=lifespan,
-    docs_url="/docs",
-    redoc_url="/redoc"
-)
-
-
-# ============================================================================
-# CORS Middleware Configuration
-# ============================================================================
+app = FastAPI(title="Crypto Data Source API")
 
+# CORS middleware
 app.add_middleware(
     CORSMiddleware,
-    allow_origins=["*"],  # In production, specify allowed origins
+    allow_origins=["*"],
     allow_credentials=True,
     allow_methods=["*"],
     allow_headers=["*"],
 )
 
-
-# ============================================================================
-# Exception Handlers
-# ============================================================================
-
-@app.exception_handler(Exception)
-async def global_exception_handler(request: Request, exc: Exception):
-    """
-    Global exception handler for unhandled exceptions
-
-    Args:
-        request: Request object
-        exc: Exception that was raised
-
-    Returns:
-        JSON error response
-    """
-    logger.error(f"Unhandled exception: {exc}", exc_info=True)
-
-    return JSONResponse(
-        status_code=500,
-        content={
-            "error": "Internal server error",
-            "detail": str(exc),
-            "timestamp": datetime.utcnow().isoformat()
-        }
-    )
-
-
-# ============================================================================
-# Include Routers
-# ============================================================================
-
-# Include API endpoints router
-app.include_router(
-    api_router,
-    prefix="/api",
-    tags=["API"]
-)
-
-# Include WebSocket router
-app.include_router(
-    websocket_router,
-    tags=["WebSocket"]
-)
-
-# Include Pool Management router
-app.include_router(
-    pool_router,
-    tags=["Pool Management"]
-)
-
-# Include Data endpoints router (cryptocurrency data)
-app.include_router(
-    data_router,
-    tags=["Crypto Data"]
-)
-
-# Include HF router (if available)
-if HF_ROUTER_AVAILABLE:
-    try:
-        app.include_router(
-            hf_connect.router,
-            tags=["HuggingFace"]
-        )
-        logger.info("HF router included successfully")
-    except Exception as e:
-        logger.warning(f"Could not include HF router: {e}")
-
-# Include new WebSocket service routers
-app.include_router(
-    ws_unified_router,
-    tags=["WebSocket Services"]
-)
-
-app.include_router(
-    ws_data_router,
-    tags=["WebSocket - Data Collection"]
-)
-
-app.include_router(
-    ws_monitoring_router,
-    tags=["WebSocket - Monitoring"]
-)
-
-app.include_router(
-    ws_integration_router,
-    tags=["WebSocket - Integration"]
-)
-
-logger.info("All WebSocket service routers included successfully")
-
-
-# ============================================================================
-# Root Endpoints
-# ============================================================================
-
-@app.get("/", response_class=HTMLResponse, tags=["Root"])
-async def root():
-    """
-    Serve the Vidya HTML UI dashboard
-
-    Returns:
-        HTML dashboard interface
-    """
-    try:
-        with open("index.html", "r", encoding="utf-8") as f:
-            return HTMLResponse(content=f.read())
-    except Exception as e:
-        logger.error(f"Error serving index.html: {e}")
-        return HTMLResponse(content=f"<h1>Error loading dashboard</h1><p>{str(e)}</p>", status_code=500)
-
-
-@app.get("/api-info", tags=["Root"])
-async def api_info():
-    """
-    API information and available endpoints
-
-    Returns:
-        API information and endpoint listing
-    """
+# Health check endpoint
+@app.get("/api/health")
+async def health_check():
     return {
-        "name": "Crypto API Monitoring System",
-        "version": "2.0.0",
-        "description": "Comprehensive cryptocurrency API monitoring with real-time updates",
         "status": "online",
-        "timestamp": datetime.utcnow().isoformat(),
-        "endpoints": {
-            "documentation": {
-                "swagger": "/docs",
-                "redoc": "/redoc"
-            },
-            "health": "/health",
-            "api": {
-                "providers": "/api/providers",
-                "status": "/api/status",
-                "rate_limits": "/api/rate-limits",
-                "logs": "/api/logs/{log_type}",
-                "alerts": "/api/alerts",
-                "scheduler": "/api/scheduler/status",
-                "database": "/api/database/stats",
-                "analytics": "/api/analytics/failures"
-            },
-            "websocket": {
-                "master": {
-                    "default": "/ws",
-                    "master": "/ws/master",
-                    "all_services": "/ws/all",
-                    "stats": "/ws/stats",
-                    "services": "/ws/services",
-                    "endpoints": "/ws/endpoints"
-                },
-                "data_collection": {
-                    "unified": "/ws/data",
-                    "market_data": "/ws/market_data",
-                    "whale_tracking": "/ws/whale_tracking",
-                    "news": "/ws/news",
-                    "sentiment": "/ws/sentiment"
-                },
-                "monitoring": {
-                    "unified": "/ws/monitoring",
-                    "health": "/ws/health",
-                    "pool_status": "/ws/pool_status",
-                    "scheduler": "/ws/scheduler_status"
-                },
-                "integration": {
-                    "unified": "/ws/integration",
-                    "huggingface": "/ws/huggingface",
-                    "ai": "/ws/ai",
-                    "persistence": "/ws/persistence"
-                },
-                "legacy": {
-                    "live": "/ws/live"
-                }
-            }
-        },
-        "features": [
-            "Multi-provider API monitoring",
-            "Real-time WebSocket updates for all services",
-            "Data collection WebSocket APIs (market data, news, sentiment, whale tracking, etc.)",
-            "Monitoring WebSocket APIs (health checks, pool management, scheduler)",
-            "Integration WebSocket APIs (HuggingFace AI, persistence)",
-            "Rate limit tracking",
-            "Automated health checks",
-            "Scheduled data collection",
-            "Failure detection and alerts",
-            "Historical analytics",
-            "Subscription-based message routing"
-        ],
-        "system_info": {
-            "total_providers": len(config.get_all_providers()),
-            "categories": config.get_categories(),
-            "scheduler_running": task_scheduler.is_running(),
-            "websocket_connections": ws_manager.get_connection_count(),
-            "database_path": db_manager.db_path
-        }
+        "version": "1.0.0",
+        "timestamp": datetime.now().isoformat(),
+        "ccxt_version": ccxt.__version__
     }
 
-
-@app.get("/health", tags=["Health"])
-async def health_check():
-    """
-    Comprehensive health check endpoint
-
-    Returns:
-        System health status
-    """
+# Example API endpoint - Add your trading endpoints here
+@app.get("/api/markets")
+async def get_markets():
     try:
-        # Check database health
-        db_health = db_manager.health_check()
-
-        # Get latest system metrics
-        latest_metrics = db_manager.get_latest_system_metrics()
-
-        # Check scheduler status
-        scheduler_status = task_scheduler.is_running()
-
-        # Check WebSocket status
-        ws_status = ws_manager._is_running
-        ws_connections = ws_manager.get_connection_count()
-
-        # Determine overall health
-        overall_health = "healthy"
-
-        if db_health.get('status') != 'healthy':
-            overall_health = "degraded"
-
-        if not scheduler_status:
-            overall_health = "degraded"
-
-        if latest_metrics and latest_metrics.system_health == "critical":
-            overall_health = "critical"
-
+        exchange = ccxt.binance()
+        markets = exchange.load_markets()
         return {
-            "status": overall_health,
-            "timestamp": datetime.utcnow().isoformat(),
-            "components": {
-                "database": {
-                    "status": db_health.get('status', 'unknown'),
-                    "path": db_health.get('database_path'),
-                    "size_mb": db_health.get('stats', {}).get('database_size_mb', 0)
-                },
-                "scheduler": {
-                    "status": "running" if scheduler_status else "stopped",
-                    "active_jobs": task_scheduler.get_job_status().get('total_jobs', 0)
-                },
-                "websocket": {
-                    "status": "running" if ws_status else "stopped",
-                    "active_connections": ws_connections
-                },
-                "providers": {
-                    "total": len(config.get_all_providers()),
-                    "online": latest_metrics.online_count if latest_metrics else 0,
-                    "degraded": latest_metrics.degraded_count if latest_metrics else 0,
-                    "offline": latest_metrics.offline_count if latest_metrics else 0
-                }
-            },
-            "metrics": {
-                "avg_response_time_ms": latest_metrics.avg_response_time_ms if latest_metrics else 0,
-                "total_requests_hour": latest_metrics.total_requests_hour if latest_metrics else 0,
-                "total_failures_hour": latest_metrics.total_failures_hour if latest_metrics else 0,
-                "system_health": latest_metrics.system_health if latest_metrics else "unknown"
-            }
+            "success": True,
+            "total_markets": len(markets),
+            "markets": list(markets.keys())[:50]  # Return first 50
         }
-
     except Exception as e:
-        logger.error(f"Health check error: {e}", exc_info=True)
-        return {
-            "status": "unhealthy",
-            "timestamp": datetime.utcnow().isoformat(),
-            "error": str(e)
-        }
-
+        return {"success": False, "error": str(e)}
 
-@app.get("/info", tags=["Root"])
-async def system_info():
-    """
-    Get detailed system information
-
-    Returns:
-        Detailed system information
-    """
+@app.get("/api/ticker/{symbol}")
+async def get_ticker(symbol: str):
     try:
-        # Get configuration stats
-        config_stats = config.stats()
-
-        # Get database stats
-        db_stats = db_manager.get_database_stats()
-
-        # Get rate limit statuses
-        rate_limit_count = len(rate_limiter.get_all_statuses())
-
-        # Get scheduler info
-        scheduler_info = task_scheduler.get_job_status()
-
-        return {
-            "application": {
-                "name": "Crypto API Monitoring System",
-                "version": "2.0.0",
-                "environment": "production"
-            },
-            "configuration": config_stats,
-            "database": db_stats,
-            "rate_limits": {
-                "configured_providers": rate_limit_count
-            },
-            "scheduler": {
-                "running": task_scheduler.is_running(),
-                "total_jobs": scheduler_info.get('total_jobs', 0),
-                "jobs": scheduler_info.get('jobs', [])
-            },
-            "websocket": {
-                "active_connections": ws_manager.get_connection_count(),
-                "background_tasks_running": ws_manager._is_running
-            },
-            "timestamp": datetime.utcnow().isoformat()
-        }
-
+        exchange = ccxt.binance()
+        ticker = exchange.fetch_ticker(symbol)
+        return {"success": True, "data": ticker}
     except Exception as e:
-        logger.error(f"System info error: {e}", exc_info=True)
+        return {"success": False, "error": str(e)}
+
+# Serve static files for frontend
+frontend_dist = Path("frontend/dist")
+
+if frontend_dist.exists():
+    # Mount static assets (JS, CSS, images, etc.)
+    app.mount("/assets", StaticFiles(directory=str(frontend_dist / "assets")), name="assets")
+    
+    # Catch-all route for SPA (Single Page Application)
+    @app.get("/{full_path:path}")
+    async def serve_spa(full_path: str):
+        # If it's an API route that doesn't exist, return 404
+        if full_path.startswith("api/"):
+            return {"error": "API endpoint not found"}, 404
+        
+        # Check if the requested file exists
+        file_path = frontend_dist / full_path
+        if file_path.is_file():
+            return FileResponse(file_path)
+        
+        # Otherwise, serve index.html (for client-side routing)
+        return FileResponse(frontend_dist / "index.html")
+else:
+    @app.get("/")
+    async def root():
         return {
-            "error": str(e),
-            "timestamp": datetime.utcnow().isoformat()
+            "message": "Frontend not built. Please build the frontend first.",
+            "api_docs": "/docs"
         }
 
-
-# ============================================================================
-# Run Application
-# ============================================================================
-
 if __name__ == "__main__":
-    """
-    Run the application with uvicorn
-
-    Configuration:
-    - Host: 0.0.0.0 (all interfaces)
-    - Port: 7860
-    - Log level: info
-    - Reload: disabled (production mode)
-    """
-    logger.info("Starting Crypto API Monitoring System on 0.0.0.0:7860")
-
-    uvicorn.run(
-        app,
-        host="0.0.0.0",
-        port=7860,
-        log_level="info",
-        access_log=True,
-        use_colors=True
-    )
+    import uvicorn
+    uvicorn.run(app, host="0.0.0.0", port=7860)

requirements.txt

@@ -1,15 +1,6 @@
 fastapi==0.104.1
 uvicorn[standard]==0.24.0
-pydantic==2.5.0
-python-multipart==0.0.6
-httpx==0.25.0
-python-dotenv==1.0.0
-requests==2.31.0
 ccxt==4.0.107
-pandas==2.1.1
-numpy==1.26.0
-matplotlib==3.8.0
-plotly==5.18.0
-ta==0.10.2
-scikit-learn==1.3.1
-joblib==1.3.2
+python-multipart==0.0.6
+pydantic==2.5.0
+aiofiles==23.2.1

راهنمای_نصب.md

@@ -0,0 +1,109 @@
+# 🚀 راهنمای نصب و بارگذاری در Hugging Face Space
+
+## 📁 ساختار پروژه شما باید اینطور باشه:
+
+```
+Datasourceforcryptocurrency/
+├── Dockerfile                  ← فایل جدید (دانلود کردید)
+├── README.md                   ← فایل جدید (دانلود کردید)
+├── .dockerignore              ← فایل جدید (دانلود کردید)
+├── backend/
+│   ├── app.py                 ← فایل جدید (دانلود کردید)
+│   └── requirements.txt       ← فایل جدید (دانلود کردید)
+└── frontend/
+    ├── package.json
+    ├── vite.config.js
+    ├── index.html
+    └── src/
+        └── ... (فایل‌های React شما)
+```
+
+## 📝 مراحل بارگذاری:
+
+### مرحله 1: ساختار پوشه‌ها
+1. یک پوشه جدید به اسم `backend` بسازید
+2. فایل‌های `app.py` و `requirements.txt` رو داخلش بذارید
+3. مطمئن بشید پوشه `frontend` شما همه فایل‌های React رو داره
+
+### مرحله 2: بررسی frontend/package.json
+مطمئن بشید که این script رو داره:
+```json
+{
+  "scripts": {
+    "build": "vite build",
+    "dev": "vite"
+  }
+}
+```
+
+### مرحله 3: بررسی frontend/vite.config.js
+مطمئن بشید که base config داره:
+```javascript
+import { defineConfig } from 'vite'
+import react from '@vitejs/plugin-react'
+
+export default defineConfig({
+  plugins: [react()],
+  base: '/',
+  server: {
+    port: 3000
+  }
+})
+```
+
+### مرحله 4: بارگذاری در Hugging Face
+
+#### روش 1: از طریق Web UI (ساده‌تر)
+1. برو به: https://huggingface.co/spaces/Really-amin/Datasourceforcryptocurrency
+2. روی "Files" کلیک کن
+3. فایل‌ها رو یکی یکی آپلود کن:
+   - `Dockerfile` در root
+   - `README.md` در root  
+   - `.dockerignore` در root
+   - `app.py` در پوشه `backend/`
+   - `requirements.txt` در پوشه `backend/`
+
+#### روش 2: از طریق Git (پیشرفته‌تر)
+```bash
+# 1. Clone کردن Space
+git clone https://huggingface.co/spaces/Really-amin/Datasourceforcryptocurrency
+cd Datasourceforcryptocurrency
+
+# 2. کپی کردن فایل‌های جدید
+# فایل‌های دانلود شده رو کپی کنید به ساختار بالا
+
+# 3. Commit و Push
+git add .
+git commit -m "Fix: Add proper Docker setup with frontend serving"
+git push
+```
+
+### مرحله 5: منتظر Build بمونید
+- Space به صورت خودکار rebuild می‌شه (5-10 دقیقه)
+- لاگ‌ها رو نگاه کنید تا مطمئن بشید همه چیز درست Build شده
+- وقتی "Running" شد، باید UI رو ببینید نه JSON!
+
+## 🔧 اگر هنوز مشکل داشتید:
+
+### خطای Build:
+- چک کنید که `frontend/package.json` و `frontend/vite.config.js` وجود داشته باشه
+- چک کنید که dependencies نصب شده باشن
+
+### هنوز JSON نشون میده:
+- لاگ Space رو بررسی کنید
+- مطمئن بشید که `frontend/dist` بعد از build ساخته شده
+- مطمئن بشید که به root URL دسترسی دارید نه `/api`
+
+### نیاز به کمک بیشتر:
+- لاگ‌های Build رو بفرستید
+- محتویات `frontend/package.json` رو بفرستید
+- Screenshot از ساختار پوشه‌ها بفرستید
+
+## ✅ بعد از موفقیت:
+
+شما باید بتونید:
+- به UI دسترسی داشته باشید در: https://really-amin-datasourceforcryptocurrency.hf.space
+- API docs ببینید در: https://really-amin-datasourceforcryptocurrency.hf.space/docs
+- Health check کار کنه: https://really-amin-datasourceforcryptocurrency.hf.space/api/health
+
+موفق باشید! 🚀