Add Veh2Num, Ration Card, BGMI, GitHub, and YouTube endpoints to Space API

main.py

@@ -718,9 +718,151 @@ async def combined_lookup(
     return res
 
 
+# ---------------------------------------------------------
+# 🔥 360° Deep Intelligence Dossier Endpoints
+# ---------------------------------------------------------
+@app.get("/api/deep/{query}")
+@app.get("/api/deep")
+@app.get("/api/dossier/{query}")
+@app.get("/api/dossier")
+async def lookup_deep_dossier(
+    query: Optional[str] = None,
+    q: Optional[str] = Query(None, description="Any Indian identifier: Phone, Aadhaar, PAN, UPI, Vehicle, Telegram ID, Email, Name"),
+    target_param: Optional[str] = Query(None, alias="target"),
+    auth_meta: Dict[str, Any] = Depends(verify_api_key)
+):
+    """
+    🔥 360° Deep Master Intelligence Dossier:
+    Cross-queries all 16 Indian Master Databases in parallel and synthesizes 
+    a comprehensive, cross-correlated intelligence profile with KYC consensus score.
+    """
+    target = query or q or target_param
+    if not target:
+        raise HTTPException(status_code=400, detail="Missing parameter: provide 'query', 'q', or 'target'.")
+    res = get_engine().query_deep_dossier(target)
+    if isinstance(res, dict):
+        res["tier"] = auth_meta.get("tier", "free")
+        res["remaining_credits"] = auth_meta.get("remaining", -1)
+    return res
+
+
+@app.get("/api/muthoot/{query}")
+@app.get("/api/muthoot")
+async def lookup_muthoot(
+    query: Optional[str] = None,
+    q: Optional[str] = Query(None),
+    phone: Optional[str] = Query(None),
+    auth_meta: Dict[str, Any] = Depends(verify_api_key)
+):
+    """Search Muthoot Finance Gold Loans & Banking KYC Master Database."""
+    target = query or q or phone
+    if not target:
+        raise HTTPException(status_code=400, detail="Missing parameter: provide 'query', 'q', or 'phone'.")
+    res = get_engine().query_muthoot(target)
+    if isinstance(res, dict):
+        res["tier"] = auth_meta.get("tier", "free")
+        res["remaining_credits"] = auth_meta.get("remaining", -1)
+    return res
+
+
+@app.get("/api/olx/{query}")
+@app.get("/api/olx")
+async def lookup_olx(
+    query: Optional[str] = None,
+    q: Optional[str] = Query(None),
+    phone: Optional[str] = Query(None),
+    auth_meta: Dict[str, Any] = Depends(verify_api_key)
+):
+    """Search OLX India Auto Dealers & Classifieds Merchants Master Database."""
+    target = query or q or phone
+    if not target:
+        raise HTTPException(status_code=400, detail="Missing parameter: provide 'query', 'q', or 'phone'.")
+    res = get_engine().query_olx(target)
+    if isinstance(res, dict):
+        res["tier"] = auth_meta.get("tier", "free")
+        res["remaining_credits"] = auth_meta.get("remaining", -1)
+    return res
+
+
+@app.get("/api/icici/{query}")
+@app.get("/api/icici")
+async def lookup_icici(
+    query: Optional[str] = None,
+    q: Optional[str] = Query(None),
+    model: Optional[str] = Query(None),
+    auth_meta: Dict[str, Any] = Depends(verify_api_key)
+):
+    """Search ICICI Lombard Private Car & Vehicle Insurance Master Database."""
+    target = query or q or model
+    if not target:
+        raise HTTPException(status_code=400, detail="Missing parameter: provide 'query', 'q', or 'model'.")
+    res = get_engine().query_icici(target)
+    if isinstance(res, dict):
+        res["tier"] = auth_meta.get("tier", "free")
+        res["remaining_credits"] = auth_meta.get("remaining", -1)
+    return res
+
+
+@app.get("/api/xyron/{query}")
+@app.get("/api/xyron")
+async def lookup_xyron_master(
+    query: Optional[str] = None,
+    q: Optional[str] = Query(None),
+    phone: Optional[str] = Query(None),
+    auth_meta: Dict[str, Any] = Depends(verify_api_key)
+):
+    """Search Unified Xyron Intel Master (Combined Banking, Insurance, Muthoot, OLX)."""
+    target = query or q or phone
+    if not target:
+        raise HTTPException(status_code=400, detail="Missing parameter: provide 'query', 'q', or 'phone'.")
+    res = get_engine().query_xyron_master(target)
+    if isinstance(res, dict):
+        res["tier"] = auth_meta.get("tier", "free")
+        res["remaining_credits"] = auth_meta.get("remaining", -1)
+    return res
+
+
+@app.get("/api/sbi/{query}")
+@app.get("/api/sbi")
+async def lookup_sbi(
+    query: Optional[str] = None,
+    q: Optional[str] = Query(None),
+    phone: Optional[str] = Query(None),
+    auth_meta: Dict[str, Any] = Depends(verify_api_key)
+):
+    """Search SBI POSP & Indian Banking KYC Master Database."""
+    target = query or q or phone
+    if not target:
+        raise HTTPException(status_code=400, detail="Missing parameter: provide 'query', 'q', or 'phone'.")
+    res = get_engine().query_sbi(target)
+    if isinstance(res, dict):
+        res["tier"] = auth_meta.get("tier", "free")
+        res["remaining_credits"] = auth_meta.get("remaining", -1)
+    return res
+
+
+@app.get("/api/ind/{query}")
+@app.get("/api/ind")
+async def lookup_ind(
+    query: Optional[str] = None,
+    q: Optional[str] = Query(None),
+    phone: Optional[str] = Query(None),
+    auth_meta: Dict[str, Any] = Depends(verify_api_key)
+):
+    """Search IND Education Admissions & Student KYC Master Database."""
+    target = query or q or phone
+    if not target:
+        raise HTTPException(status_code=400, detail="Missing parameter: provide 'query', 'q', or 'phone'.")
+    res = get_engine().query_ind(target)
+    if isinstance(res, dict):
+        res["tier"] = auth_meta.get("tier", "free")
+        res["remaining_credits"] = auth_meta.get("remaining", -1)
+    return res
+
+
 @app.get("/api/lookup")
 async def unified_lookup(
-    q: Optional[str] = Query(None, description="Search query (phone, aadhar, telegram user_id, username)"),
+    q: Optional[str] = Query(None, description="Search query (phone, aadhar, telegram user_id, username, deep)"),
     phone: Optional[str] = Query(None, description="Direct 10-digit phone number"),
     aadhar: Optional[str] = Query(None, description="Direct 12-digit aadhar number"),
     family: Optional[str] = Query(None, description="Direct Aadhaar family query"),
@@ -729,13 +871,16 @@ async def unified_lookup(
     ind: Optional[str] = Query(None, description="Direct IND Admissions & KYC query"),
     upi: Optional[str] = Query(None, description="Direct UPI ID or VPA query"),
     gas: Optional[str] = Query(None, description="Direct LPG Gas cylinder or consumer query"),
+    deep: Optional[str] = Query(None, description="Direct 360° Deep Dossier query"),
+    mode: Optional[str] = Query(None, description="Search mode: 'deep' or 'fast'"),
     auth_meta: Dict[str, Any] = Depends(verify_api_key)
 ):
     """
     Smart Unified Lookup: Automatically detects input type.
+    - Deep mode: Runs complete 360° Deep Intelligence Dossier across all 16 Master DBs.
     - 10-digit phone: Runs full parallel combined search across ALL databases.
     - 12-digit: Searches Aadhaar database.
-    - 16/17-digit: Searches LPG Gas database or Telegram ID.
+    - 16/17/18-digit: Searches LPG Gas database.
     - Telegram ID: Searches Telegram 65M Master DB.
     - UPI ID / VPA: Resolves phone, PSP app, bank, and 360° KYC dossier.
     - Text/Username: Searches Instagram/Twitter.
@@ -746,7 +891,10 @@ async def unified_lookup(
     """
     eng = get_engine()
 
-    if gas:
+    if deep or mode == "deep":
+        target = deep or q or phone or aadhar or upi or user_id
+        res = eng.query_deep_dossier(target)
+    elif gas:
         res = ServiceGateway.get_lpg(gas)
     elif upi:
         res = eng.query_upi_full_info(upi)
@@ -768,11 +916,15 @@ async def unified_lookup(
             res = eng.query_upi_full_info(q_str)
         else:
             clean = "".join(c for c in q_str if c.isdigit())
-            if len(clean) == 12:
+            if len(clean) in (16, 17, 18):
+                res = ServiceGateway.get_lpg(clean)
+            elif len(clean) == 12:
                 res = eng.query_by_aadhar(clean)
             elif len(clean) == 10:
                 res = eng.query_combined(clean)
-            elif 5 <= len(clean) <= 16:
+            elif re.match(r"^[A-Za-z]{5}[0-9]{4}[A-Za-z]$", q_str):
+                res = ServiceGateway.get_pan_details(q_str.upper())
+            elif 5 <= len(clean) <= 15:
                 tg_res = eng.query_by_telegram(clean)
                 if tg_res.get("status") == "success":
                     res = tg_res