Upload 322 files

hf_unified_server.py

@@ -35,7 +35,6 @@ import json
 from pathlib import Path
 import httpx
 
-from database import CryptoDatabase
 
 from ai_models import (
     analyze_chart_points,
@@ -92,8 +91,8 @@ APL_REPORT_PATH = WORKSPACE_ROOT / "PROVIDER_AUTO_DISCOVERY_REPORT.json"
 # Ensure log directory exists
 LOG_DIR.mkdir(parents=True, exist_ok=True)
 
-# Initialize SQLite database for real market data persistence
-db = CryptoDatabase()
+# Database path (managed by DatabaseManager in the admin API)
+DB_PATH = WORKSPACE_ROOT / "data" / "api_monitor.db"
 
 def tail_log_file(path: Path, max_lines: int = 200) -> List[str]:
     """Return the last max_lines from a log file, if it exists."""
@@ -666,24 +665,6 @@ async def get_market():
         if not prices:
             raise HTTPException(status_code=503, detail="Unable to fetch market data")
         
-        # Persist real market data into SQLite database (no mocks)
-        try:
-            for item in prices:
-                payload = {
-                    "symbol": item.get("symbol", "").upper(),
-                    "name": item.get("name"),
-                    "price_usd": item.get("current_price") or item.get("price"),
-                    "volume_24h": item.get("total_volume"),
-                    "market_cap": item.get("market_cap"),
-                    "percent_change_1h": item.get("price_change_1h") or item.get("price_change_percentage_1h_in_currency"),
-                    "percent_change_24h": item.get("price_change_percentage_24h"),
-                    "percent_change_7d": item.get("price_change_percentage_7d_in_currency"),
-                    "rank": item.get("market_cap_rank"),
-                }
-                db.save_price(payload)
-        except Exception as db_err:
-            logger.warning(f"Failed to save market data to DB: {db_err}")
-        
         return {
             "total_market_cap": overview.get("total_market_cap", 0),
             "btc_dominance": overview.get("btc_dominance", 0),
@@ -2458,34 +2439,23 @@ async def websocket_endpoint(websocket: WebSocket):
 @app.get("/api/market/history")
 async def get_market_history(symbol: str = "BTC", limit: int = 10):
     """
-    Get historical prices from the real SQLite database.
+    Get historical prices from the local database if available.
 
-    This uses only stored real market data inserted by /api/market
-    and never generates synthetic or mock values.
+    For this deployment we avoid touching the internal DatabaseManager
+    and simply report that no history API is wired yet.
     """
     symbol = symbol.upper()
-    try:
-        history = db.get_price_history(symbol, limit=limit)
-    except Exception as e:
-        logger.error(f"Error reading history for {symbol}: {e}")
-        raise HTTPException(status_code=500, detail="Error reading market history")
-
-    if not history:
-        return {
-            "symbol": symbol,
-            "history": [],
-            "count": 0,
-            "message": "No history available",
-        }
-
+    # We don't fabricate data here; if you need real history, it should
+    # be implemented via the shared database models.
     return {
         "symbol": symbol,
-        "history": history,
-        "count": len(history),
-        "source": "SQLite database (real data)",
+        "history": [],
+        "count": 0,
+        "message": "History endpoint not wired to DB in this Space",
     }
 
 
+
 @app.get("/api/status")
 async def get_status():
     """
@@ -2498,7 +2468,7 @@ async def get_status():
     providers = providers_cfg or {}
     validated_count = sum(1 for p in providers.values() if p.get("validated"))
 
-    db_path = Path(db.db_path)
+    db_path = DB_PATH
     db_status = "connected" if db_path.exists() else "initializing"
 
     return {

index.html

@@ -2493,4 +2493,4 @@
     <!-- Load App JS as ES6 Module -->
     <script type="module" src="static/js/app.js?v=20250119"></script>
 </body>
-</html>
+</html>