Update app.py

app.py

@@ -1,5 +1,4 @@
 from fastapi import FastAPI, WebSocket, WebSocketDisconnect, Query
-from fastapi.staticfiles import StaticFiles
 from fastapi.responses import FileResponse, JSONResponse
 from fastapi.middleware.cors import CORSMiddleware
 from pathlib import Path
@@ -10,33 +9,26 @@ import asyncio
 import random
 import ccxt
 
+# -------------------------------------------------
+# اپلیکیشن FastAPI
+# -------------------------------------------------
 app = FastAPI(title="Crypto Data Source API")
 
-# ------------------------------
-# CORS
-# ------------------------------
+# CORS آزاد (در صورت نیاز بعداً محدود کن)
 app.add_middleware(
     CORSMiddleware,
-    allow_origins=["*"],      # در صورت نیاز محدودترش کن
+    allow_origins=["*"],
     allow_credentials=True,
     allow_methods=["*"],
     allow_headers=["*"],
 )
 
-# ------------------------------
-# مسیرهای پایه پروژه
-# ------------------------------
+# روت پروژه = همون جایی که app.py هست
 BASE_DIR = Path(__file__).resolve().parent
 INDEX_FILE = BASE_DIR / "index.html"
-STATIC_DIR = BASE_DIR / "static"
 START_TIME = datetime.now(timezone.utc)
 
-if STATIC_DIR.exists() and STATIC_DIR.is_dir():
-    app.mount("/static", StaticFiles(directory=str(STATIC_DIR)), name="static")
-
-# ------------------------------
-# داده‌های نمونه برای Providerها / Keys
-# ------------------------------
+# داده‌های نمونه برای داشبورد
 BASE_PROVIDERS: List[Dict[str, Any]] = [
     {"name": "Binance Spot", "category": "market_data", "has_key": False, "priority": 5},
     {"name": "Binance Futures", "category": "market_data", "has_key": False, "priority": 4},
@@ -61,27 +53,23 @@ def _utc_now() -> datetime:
     return datetime.now(timezone.utc)
 
 
-# ------------------------------
-# کمکی: ساخت snapshot از provider ها
-# ------------------------------
 def _generate_providers_snapshot() -> List[Dict[str, Any]]:
+    """ساخت دیتای فیک برای provider ها (برای داشبورد)."""
     now = _utc_now()
     providers: List[Dict[str, Any]] = []
 
     all_providers = BASE_PROVIDERS + CUSTOM_APIS
 
     for base in all_providers:
-        # response time between 80ms and 900ms
-        rt = random.randint(80, 900)
-        # staleness between 0 and 30 minutes
+        rt = random.randint(80, 900)  # response time
         minutes_ago = random.uniform(0, 30)
         last_fetch_dt = now - timedelta(minutes=minutes_ago)
 
-        # تعیین وضعیت بر اساس response time
         if rt < 300:
             status = "online"
         elif rt < 700:
             status = "degraded"
+            rt += random.randint(50, 200)
         else:
             status = "offline"
 
@@ -100,12 +88,11 @@ def _generate_providers_snapshot() -> List[Dict[str, Any]]:
     return providers
 
 
-# ------------------------------
-# APIهای پایه ccxt
-# ------------------------------
+# -------------------------------------------------
+# APIهای ccxt پایه (health / markets / ticker)
+# -------------------------------------------------
 @app.get("/api/health")
 async def health_check():
-    """Health ساده برای تست سرویس."""
     return {
         "status": "online",
         "version": "1.0.0",
@@ -116,7 +103,6 @@ async def health_check():
 
 @app.get("/api/markets")
 async def get_markets():
-    """نمونه گرفتن لیست مارکت‌ها از Binance."""
     try:
         exchange = ccxt.binance()
         markets = exchange.load_markets()
@@ -125,24 +111,23 @@ async def get_markets():
             "total_markets": len(markets),
             "markets": list(markets.keys())[:50],
         }
-    except Exception as e:  # noqa: BLE001
+    except Exception as e:
         return {"success": False, "error": str(e)}
 
 
 @app.get("/api/ticker/{symbol}")
 async def get_ticker(symbol: str):
-    """نمونه گرفتن تیکر از Binance (مثال: BTC/USDT)."""
     try:
         exchange = ccxt.binance()
         ticker = exchange.fetch_ticker(symbol)
         return {"success": True, "data": ticker}
-    except Exception as e:  # noqa: BLE001
+    except Exception as e:
         return {"success": False, "error": str(e)}
 
 
-# ------------------------------
-# /api/status – مطابق انتظار فرانت
-# ------------------------------
+# -------------------------------------------------
+# /api/status – کارت‌های بالای داشبورد
+# -------------------------------------------------
 @app.get("/api/status")
 async def api_status():
     providers = _generate_providers_snapshot()
@@ -150,19 +135,18 @@ async def api_status():
     online = sum(1 for p in providers if p["status"] == "online")
     offline = sum(1 for p in providers if p["status"] == "offline")
     degraded = sum(1 for p in providers if p["status"] == "degraded")
-
     avg_response = (
         sum(p["response_time_ms"] for p in providers) / total if total else 0
     )
 
-    # متریک‌های ساده
     total_requests_hour = random.randint(200, 1200)
     total_failures_hour = random.randint(0, max(20, degraded * 2 + offline * 5))
 
-    if offline == 0 and degraded <= max(1, total // 4):
-        system_health = "healthy"
-    else:
-        system_health = "degraded"
+    system_health = (
+        "healthy"
+        if offline == 0 and degraded <= max(1, total // 4)
+        else "degraded"
+    )
 
     now = _utc_now()
     uptime_seconds = (now - START_TIME).total_seconds()
@@ -184,33 +168,19 @@ async def api_status():
     }
 
 
-# ------------------------------
-# /api/providers – لیست Providerها
-# ------------------------------
+# -------------------------------------------------
+# /api/providers – جدول providerها
+# -------------------------------------------------
 @app.get("/api/providers")
 async def api_providers():
-    """
-    خروجی: آرایه‌ای از provider ها
-    [
-      {
-        name, category, status, response_time_ms,
-        last_fetch, has_key, priority
-      }, ...
-    ]
-    """
     return _generate_providers_snapshot()
 
 
-# ------------------------------
-# /api/categories – خلاصه per category
-# ------------------------------
+# -------------------------------------------------
+# /api/categories – کارت‌های وسط
+# -------------------------------------------------
 @app.get("/api/categories")
 async def api_categories():
-    """
-    فرانت انتظار دارد آرایه مستقیم دریافت کند، نه شیء.
-
-    هر category: name, status, online_sources, total_sources, avg_response_time_ms
-    """
     providers = _generate_providers_snapshot()
     by_cat: Dict[str, List[Dict[str, Any]]] = {}
     for p in providers:
@@ -239,15 +209,11 @@ async def api_categories():
     return categories
 
 
-# ------------------------------
-# /api/charts/health-history – برای نمودار سلامت
-# ------------------------------
+# -------------------------------------------------
+# /api/charts/health-history – نمودار خطی
+# -------------------------------------------------
 @app.get("/api/charts/health-history")
 async def api_chart_health_history(hours: int = 24):
-    """
-    فرانت انتظار دارد:
-      { timestamps: [...], success_rate: [...] }  // success_rate بین 0 تا 100
-    """
     now = _utc_now()
     points = max(12, hours)
     timestamps: List[str] = []
@@ -255,7 +221,7 @@ async def api_chart_health_history(hours: int = 24):
 
     for i in range(points):
         ts = now - timedelta(hours=(hours * (points - 1 - i) / points))
-        base = 90  # درصد پایه
+        base = 90
         noise = random.uniform(-10, 5)
         value = max(50.0, min(100.0, base + noise))
         timestamps.append(ts.isoformat())
@@ -264,15 +230,11 @@ async def api_chart_health_history(hours: int = 24):
     return {"timestamps": timestamps, "success_rate": success_rate}
 
 
-# ------------------------------
-# /api/charts/compliance – برای نمودار Bar
-# ------------------------------
+# -------------------------------------------------
+# /api/charts/compliance – نمودار میله‌ای
+# -------------------------------------------------
 @app.get("/api/charts/compliance")
 async def api_chart_compliance(days: int = 7):
-    """
-    فرانت انتظار دارد:
-      { dates: [...], compliance_percentage: [...] }  // 0..100
-    """
     today = _utc_now().date()
     dates: List[str] = []
     compliance_percentage: List[float] = []
@@ -288,15 +250,11 @@ async def api_chart_compliance(days: int = 7):
     return {"dates": dates, "compliance_percentage": compliance_percentage}
 
 
-# ------------------------------
-# /api/freshness – جدول تازگی داده‌ها
-# ------------------------------
+# -------------------------------------------------
+# /api/freshness – جدول تازگی
+# -------------------------------------------------
 @app.get("/api/freshness")
 async def api_freshness():
-    """
-    فرانت انتظار دارد آرایه‌ای از آیتم‌ها:
-      provider, category, fetch_time, staleness_minutes, ttl_minutes, status
-    """
     providers = _generate_providers_snapshot()
     items: List[Dict[str, Any]] = []
 
@@ -319,21 +277,16 @@ async def api_freshness():
     return items
 
 
-# ------------------------------
-# /api/logs – لیست لاگ‌ها
-# ------------------------------
+# -------------------------------------------------
+# /api/logs – لاگ‌ها
+# -------------------------------------------------
 @app.get("/api/logs")
 async def api_logs():
-    """
-    فرمت آیتم لاگ:
-      timestamp, provider, endpoint, status, http_code, response_time_ms, error_message?
-    """
     providers = _generate_providers_snapshot()
     logs: List[Dict[str, Any]] = []
     now = _utc_now()
 
     for p in providers:
-        # یک لاگ موفق
         logs.append(
             {
                 "timestamp": (now - timedelta(minutes=random.randint(0, 60))).isoformat(),
@@ -345,14 +298,10 @@ async def api_logs():
                 "error_message": None,
             }
         )
-
-        # احتمالاً یک لاگ خطا
         if p["status"] != "online" and random.random() < 0.5:
             logs.append(
                 {
-                    "timestamp": (
-                        now - timedelta(minutes=random.randint(0, 60))
-                    ).isoformat(),
+                    "timestamp": (now - timedelta(minutes=random.randint(0, 60))).isoformat(),
                     "provider": p["name"],
                     "endpoint": "/api/markets",
                     "status": "error",
@@ -362,20 +311,15 @@ async def api_logs():
                 }
             )
 
-    # مرتب‌سازی نزولی بر اساس زمان
     logs.sort(key=lambda x: x["timestamp"], reverse=True)
     return logs
 
 
-# ------------------------------
-# /api/failures – خطاهای اخیر
-# ------------------------------
+# -------------------------------------------------
+# /api/failures – خطاها
+# -------------------------------------------------
 @app.get("/api/failures")
 async def api_failures():
-    """
-    خروجی:
-      { recent_failures: [ {timestamp, provider, error_type, error_message, retry_attempted}, ... ] }
-    """
     logs = await api_logs()
     failures: List[Dict[str, Any]] = []
 
@@ -394,21 +338,17 @@ async def api_failures():
     return {"recent_failures": failures}
 
 
-# ------------------------------
-# /api/config/keys – نمایش کلیدها
-# ------------------------------
+# -------------------------------------------------
+# /api/config/keys – کلیدها
+# -------------------------------------------------
 @app.get("/api/config/keys")
 async def api_config_keys():
-    """
-    فرانت انتظار دارد آرایه‌ای از آیتم‌ها:
-      provider, key_masked
-    """
     return API_KEYS
 
 
-# ------------------------------
-# /api/custom/add – افزودن API سفارشی
-# ------------------------------
+# -------------------------------------------------
+# /api/custom/add – API سفارشی
+# -------------------------------------------------
 @app.post("/api/custom/add")
 async def api_custom_add(
     name: str = Query(...),
@@ -416,10 +356,6 @@ async def api_custom_add(
     category: str = Query(...),
     test_field: Optional[str] = Query(None),
 ):
-    """
-    از روی فرانت با POST و query string صدا زده می‌شود.
-    در این نسخه، API را فقط در حافظه (CUSTOM_APIS) نگه می‌داریم.
-    """
     CUSTOM_APIS.append(
         {
             "name": name,
@@ -430,13 +366,12 @@ async def api_custom_add(
             "priority": 3,
         }
     )
-
     return {"success": True, "message": "Custom API added successfully"}
 
 
-# ------------------------------
-# WebSocket /ws/live – برای داشبورد
-# ------------------------------
+# -------------------------------------------------
+# WebSocket /ws/live
+# -------------------------------------------------
 class LiveConnections:
     def __init__(self) -> None:
         self.active: List[WebSocket] = []
@@ -449,22 +384,12 @@ class LiveConnections:
         if websocket in self.active:
             self.active.remove(websocket)
 
-    async def broadcast(self, message: Dict[str, Any]) -> None:
-        for ws in list(self.active):
-            try:
-                await ws.send_json(message)
-            except Exception:
-                self.disconnect(ws)
-
 
 live_manager = LiveConnections()
 
 
 @app.websocket("/ws/live")
 async def websocket_live(websocket: WebSocket):
-    """
-    WebSocket ساده برای ارسال متریک‌های زنده.
-    """
     await live_manager.connect(websocket)
     try:
         await websocket.send_json(
@@ -494,42 +419,31 @@ async def websocket_live(websocket: WebSocket):
         live_manager.disconnect(websocket)
 
 
-# ------------------------------
-# سرو کردن index.html و SPA routing
-# ------------------------------
+# -------------------------------------------------
+# سرو index.html از همون روت
+# -------------------------------------------------
 @app.get("/")
 async def root():
-    """اگر index.html کنار فایل باشد، همان را می‌فرستیم، در غیر این صورت JSON ساده."""
     if INDEX_FILE.exists():
         return FileResponse(INDEX_FILE)
     return JSONResponse(
         {
-            "message": "No frontend index.html found in project root.",
-            "hint": "Place index.html next to this Python file or use /docs for the API.",
-            "api_docs": "/docs",
+            "message": "index.html not found next to app.py.",
+            "hint": "Put index.html in the same folder as app.py or use /docs.",
         }
     )
 
 
 @app.get("/{full_path:path}")
 async def spa_catch_all(full_path: str):
-    """
-    برای روتینگ سمت فرانت:
-      - مسیرهای /api/* اگر endpoint نداشته باشند: 404 JSON
-      - بقیه مسیرها: index.html (اگر باشد) یا 404
-    """
+    # اگر مسیر /api/... باشه و endpoint تعریف نشده باشه
     if full_path.startswith("api/"):
         return JSONResponse(
             {"error": "API endpoint not found", "path": full_path},
             status_code=404,
         )
 
-    # اگر فایل static با همین مسیر وجود دارد
-    if STATIC_DIR.exists():
-        candidate_file = STATIC_DIR / full_path
-        if candidate_file.is_file():
-            return FileResponse(candidate_file)
-
+    # غیر از API، همیشه همون index.html رو برگردون (SPA)
     if INDEX_FILE.exists():
         return FileResponse(INDEX_FILE)
 
@@ -537,12 +451,3 @@ async def spa_catch_all(full_path: str):
         {"error": "No frontend available for this path.", "path": full_path},
         status_code=404,
     )
-
-
-# ------------------------------
-# اجرای لوکال
-# ------------------------------
-if __name__ == "__main__":
-    import uvicorn
-
-    uvicorn.run(app, host="0.0.0.0", port=7860)