Upload deep_diver_engine.py

src/services/deep_diver_engine.py

@@ -1,57 +1,75 @@
 import requests
-import json
-import os
+import time
+from decimal import Decimal, ROUND_HALF_UP  # Added for financial precision
 
-def sync_library():
-    """
-    Builds the Master Ticker Library. 
-    Downloads ~15,000 coin IDs and metadata for the Top 500.
-    """
-    DATA_DIR = os.path.join(os.getcwd(), "data")
-    TICKER_FILE = os.path.join(DATA_DIR, "tickers.json")
+STEALTH_HEADERS = {
+    "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36",
+    "Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8",
+    "Connection": "keep-alive",
+}
 
-    if not os.path.exists(DATA_DIR):
-        os.makedirs(DATA_DIR)
+def format_compact(num):
+    if num is None or num == 0: return "0"
+    for unit in ['', 'K', 'M', 'B', 'T']:
+        if abs(num) < 1000.0:
+            return f"{num:,.2f}{unit}".replace(".00", "")
+        num /= 1000.0
+    return f"{num:,.2f}P"
 
-    print("[SYNC] Starting Master Library Build...")
+def calculate_deep_dive(coin_id: str, user_keys: dict):
+    cg_key = str(user_keys.get("COINGECKO_API_KEY", "")).strip()
+    coin_id = coin_id.strip().lower()
+    base_url = "https://api.coingecko.com/api/v3"
+    headers = STEALTH_HEADERS.copy()
     
+    if cg_key and cg_key != "CONFIG_REQUIRED_CG":
+        headers["x-cg-demo-api-key" if cg_key.startswith("CG-") else "x-cg-pro-api-key"] = cg_key
+
     try:
-        # 1. Fetch all tokens (1 API Call)
-        all_coins = requests.get("https://api.coingecko.com/api/v3/coins/list").json()
+        r = requests.get(f"{base_url}/coins/{coin_id}?localization=false&tickers=true&market_data=true", headers=headers, timeout=15)
+        if r.status_code != 200: return {"status": "error", "message": f"API {r.status_code}"}
+            
+        res = r.json()
+        mkt = res.get('market_data', {})
         
-        # 2. Fetch Metadata for Top 500 (2 API Calls)
-        top_metadata = {}
-        for page in range(1, 3):
-            m_url = f"https://api.coingecko.com/api/v3/coins/markets?vs_currency=usd&order=market_cap_desc&per_page=250&page={page}"
-            m_data = requests.get(m_url).json()
-            for coin in m_data:
-                top_metadata[coin['id']] = {
-                    "img": coin['image'], 
-                    "rank": coin['market_cap_rank']
-                }
-
-        # 3. Merge into memory-efficient structure
-        library = []
-        for coin in all_coins:
-            c_id = coin['id']
-            meta = top_metadata.get(c_id, {})
-            library.append({
-                "id": c_id,
-                "s": coin['symbol'].lower(),
-                "n": coin['name'],
-                "i": meta.get("img", None),
-                "r": meta.get("rank", 99999)
-            })
+        # RAW DATA (Restored v_ch_pct for perfect logic alignment)
+        mcap = mkt.get('market_cap', {}).get('usd', 0) or 0
+        vol = mkt.get('total_volume', {}).get('usd', 0) or 0
+        p_ch = mkt.get('price_change_percentage_24h', 0) or 0
+        v_ch_pct = mkt.get('total_volume_change_24h_percentage', 0) or 0
         
-        # 4. Atomic Write to Local Disk
-        with open(TICKER_FILE, "w") as f:
-            json.dump(library, f)
+        # 3. METRIC CALCULATIONS 
+        # High-accuracy VTMR using Decimal to prevent approximation errors
+        d_vol = Decimal(str(vol))
+        d_mcap = Decimal(str(mcap))
+        # Rounding to 2 decimal places using standard financial ROUND_HALF_UP
+        vtmr_val = (d_vol / d_mcap).quantize(Decimal('0.01'), rounding=ROUND_HALF_UP) if d_mcap > 0 else 0
         
-        print(f"[SYNC] Success: {len(library)} tokens indexed in {TICKER_FILE}")
-        return True
-    except Exception as e:
-        print(f"[SYNC ERROR] {str(e)}")
-        return False
+        vtpc_val = vol / abs(p_ch) if p_ch != 0 else 0
+        current_price = mkt.get('current_price', {}).get('usd', 0)
 
-if __name__ == "__main__":
-    sync_library()
+        return {
+            "status": "success",
+            "vitals": {
+                "name": res.get('name', 'Unknown'),
+                "symbol": res.get('symbol', '').upper(),
+                "price": f"${current_price:,.8f}" if current_price < 1 else f"${current_price:,.2f}",
+                "mcap": f"${format_compact(mcap)}",
+                "vol24h": f"${format_compact(vol)}"
+            },
+            "ratios": {
+                "vtmr": f"{vtmr_val}x",
+                "vtpc": f"${format_compact(vtpc_val)}"
+            },
+            "velocity": {
+                "h24": f"{p_ch:+.2f}%",
+                "d7": f"{(mkt.get('price_change_percentage_7d') or 0):+.2f}%",
+                "m1": f"{(mkt.get('price_change_percentage_30d') or 0):+.2f}%",
+                "y1": f"{(mkt.get('price_change_percentage_1y') or 0):+.2f}%"
+            },
+            "supply": {
+                "total": format_compact(mkt.get('total_supply', 0))
+            }
+        }
+    except Exception as e:
+        return {"status": "error", "message": str(e)}