Update app.py

Dockerfile

@@ -1,20 +1,10 @@
-FROM python:3.11-slim
+FROM python:3.9
 
-RUN apt-get update && \
-    apt-get install -y --no-install-recommends ca-certificates && \
-    rm -rf /var/lib/apt/lists/*
+WORKDIR /code
 
-WORKDIR /app
-
-COPY requirements.txt .
-RUN pip install --no-cache-dir -r requirements.txt
+COPY ./requirements.txt /code/requirements.txt
+RUN pip install --no-cache-dir --upgrade -r /code/requirements.txt
 
 COPY . .
 
-ENV PING_URL=http://127.0.0.1:7860/health
-ENV PING_INTERVAL=240
-ENV PYTHONUNBUFFERED=1
-
-EXPOSE 7860
-
-CMD ["sh", "-c", "python pinger.py & uvicorn app:app --host 0.0.0.0 --port 7860"]
+CMD ["sh", "-c", "python pinger.py & uvicorn app:app --host 0.0.0.0 --port 7860"]

README.md

@@ -1,31 +1,9 @@
 ---
-title: Fast Search API
-emoji: ⚡
-colorFrom: blue
-colorTo: purple
-sdk: docker
-app_port: 7860
-pinned: true
-license: mit
 ---
-
-# Fast Search API (1.78B)
-
-- ⚡ **Mobile** → sorted `mobile` column (~2-3s)
-- 🆔 **Aadhaar** → `id` column as aadharNumber (unsorted, slow scan)
-
-## API
-
-```
-GET /search?q=<mobile>&limit=5
-GET /search?mobile=<number>
-GET /search?aadhar=<aadhaar>
-GET /health
-GET /docs
-```
-
-## Source
-
-- DB: [tfqdeadlo/Inddatainonefile](https://huggingface.co/datasets/tfqdeadlo/Inddatainonefile)
-- Developer: @kzr0x
-- Team: TEAM DARK KNIGHT APIs
+title: ICMR FastAPI Search
+emoji: 🚀
+colorFrom: yellow
+colorTo: indigo
+sdk: docker
+pinned: false
+---

app.py

@@ -1,83 +1,89 @@
 from fastapi import FastAPI, HTTPException, Query
 import duckdb
 from contextlib import asynccontextmanager
+from datetime import datetime, timedelta
 
-# Global connection object
-con = duckdb.connect()
+# === VALIDITY CHECK ===
+DEPLOYMENT_DATE = datetime(2026, 6, 27)  # Tune aaj deploy kiya hai
+EXPIRY_DAYS = 21  # 3 weeks
+
+def is_api_valid():
+    return datetime.now() < DEPLOYMENT_DATE + timedelta(days=EXPIRY_DAYS)
+
+# Global Connection
+con = None
 
-# Lifespan use karke app start hote hi heavy initialization ek baar karenge
 @asynccontextmanager
 async def lifespan(app: FastAPI):
-    print("DuckDB extensions load ho rahi hain aur View ban raha hai...")
+    global con
+    print("🟢 DuckDB initialize ho raha hai...")
+    
+    con = duckdb.connect()
+    con.execute("PRAGMA memory_limit='800MB'")
+    con.execute("PRAGMA threads=2")
+    con.execute("SET enable_object_cache=true")
+    con.execute("SET preserve_insertion_order=false")
     con.execute("INSTALL httpfs; LOAD httpfs;")
-
-    # Parquet file ka correct URL
-    PARQUET_URL = "https://huggingface.co/datasets/tfqdeadlo/Inddatainonefile/resolve/main/users_data.parquet"
-
-    # Startup par hi Ek baar View bana kar metadata cache kar lete hain
-    # Isse har API request par network par load nahi padega
-    con.execute(f"CREATE OR REPLACE VIEW users_view AS SELECT * FROM read_parquet('{PARQUET_URL}')")
-    print("View taiyar hai! API requests ke liye taiyar hai.")
+    
+    URL_ICMR = "https://huggingface.co/datasets/kzropx/icmr-parquet/resolve/main/icmr.parquet"
+    con.execute(f"SELECT 1 FROM read_parquet('{URL_ICMR}') LIMIT 1")
+    print("🟢 DuckDB ready!")
     yield
     con.close()
 
-app = FastAPI(title="Super Fast Search API", lifespan=lifespan)
+app = FastAPI(lifespan=lifespan)
 
-@app.get("/")
-def home():
-    return {"message": "Fast API online hai! Use /search?mobile=YOUR_NUMBER"}
+VALID_KEY = "@kzr0x"
 
-@app.get("/health")
-def health():
-    return {"status": "ok"}
+@app.get("/")
+def home(key: str = Query(..., description="API Key required")):
+    if not is_api_valid():
+        return {"status": "error", "message": "API Expired! Valid only for 3 weeks from 27-June-2026."}
+    if key != VALID_KEY:
+        return {"status": "error", "message": "Invalid API key"}
+    return {"status": "success", "message": "API Live! Use /search"}
 
 @app.get("/search")
-async def search_mobile(
-    mobile: str | None = Query(None),
-    q: str | None = Query(None),
-    num: str | None = Query(None),
-    number: str | None = Query(None),
-    phone: str | None = Query(None),
-    aadhar: str | None = Query(None),
-    aadhaar: str | None = Query(None),
+async def search_data(
+    key: str = Query(..., description="API Key required"),
+    number: str = Query(None, description="Search by Phone Number"),
+    aadhar: str = Query(None, description="Search by Aadhar Number"),
+    q: str = Query(None, description="Generic search")
 ):
-    target = (q or mobile or num or number or phone or aadhar or aadhaar or "").strip()
-    if not target:
-        raise HTTPException(status_code=422, detail="Enter mobile number to search")
+    # === EXPIRY CHECK (SAB SE PEHLE) ===
+    if not is_api_valid():
+        return {"status": "error", "message": "This API has expired. Valid only for 3 weeks (till 18-July-2026)."}
+    
+    if key != VALID_KEY:
+        return {"status": "error", "message": "Invalid or missing API key"}
+    
+    if not number and not aadhar and not q:
+        raise HTTPException(status_code=400, detail="Provide number, aadhar, or q")
+    
+    search_term = q or number or aadhar
+    URL_ICMR = "https://huggingface.co/datasets/kzropx/icmr-parquet/resolve/main/icmr.parquet"
+    
     try:
-        # Mobile pehle (sorted, fast)
-        query = """
-            SELECT mobile, name, fname, address, alt, circle, id, email
-            FROM users_view
-            WHERE mobile = ?
+        query = f"""
+            SELECT name, fathersName, phoneNumber, aadharNumber, address, district, pincode, state, town 
+            FROM read_parquet('{URL_ICMR}')
+            WHERE phoneNumber = ? OR aadharNumber = ?
             LIMIT 1
         """
-        result = con.execute(query, [str(target)]).fetchall()
-        # 12-digit mobile pe na mile to id (aadhar) pe try
-        if not result and target.isdigit() and len(target) == 12:
-            query2 = """
-                SELECT mobile, name, fname, address, alt, circle, id, email
-                FROM users_view
-                WHERE id = ?
-                LIMIT 1
-            """
-            result = con.execute(query2, [str(target)]).fetchall()
-
+        result = con.execute(query, [search_term, search_term]).fetchall()
+        
         if not result:
             return {
                 "status": "error",
-                "message": f"Mobile number {target} nahi mila."
+                "message": f"'{search_term}' not found.",
+                "developer": {"name": "@kzr0x", "team": "TEAM DARK KNIGHT APIs"}
             }
-
-        # Data mapping
+        
         columns = [desc[0] for desc in con.description]
-        row_dict = dict(zip(columns, result[0]))
-
         return {
             "status": "success",
-            "data": row_dict
+            "data": dict(zip(columns, result[0])),
+            "developer": {"name": "@kzr0x", "team": "TEAM DARK KNIGHT APIs"}
         }
-
     except Exception as e:
-        # Internal error ko secure rakhne ke liye mask kiya hai
-        raise HTTPException(status_code=500, detail="Query timeout ya process nahi ho payi.")
+        return {"status": "error", "message": str(e)}

pinger.py

@@ -1,26 +1,12 @@
-"""Keep-alive pinger: pings the Space's /health endpoint every few minutes
-so the container doesn't sleep. Runs as a background process inside the Space
-(started from Dockerfile CMD)."""
-import os
 import time
-
 import requests
 
-PORT = os.environ.get("APP_PORT", "7860")
-URL = os.environ.get("PING_URL", f"http://127.0.0.1:{PORT}/health")
-INTERVAL = int(os.environ.get("PING_INTERVAL", "240"))
-
-
-def _ping_loop():
-    while True:
-        try:
-            r = requests.get(URL, timeout=10)
-            print(f"[pinger] {URL} -> {r.status_code}", flush=True)
-        except Exception as e:
-            print(f"[pinger] error: {e}", flush=True)
-        time.sleep(INTERVAL)
-
+URL = "https://kzropx-icmr-data.hf.space"
 
-if __name__ == "__main__":
-    print(f"[pinger] starting, target={URL} interval={INTERVAL}s", flush=True)
-    _ping_loop()
+while True:
+    try:
+        requests.get(URL)
+        print(f"Pinged {URL} successfully!")
+    except Exception as e:
+        print(f"Error: {e}")
+    time.sleep(300)

requirements.txt

@@ -1,4 +1,4 @@
 fastapi
-duckdb==1.5.3
+duckdb
 uvicorn
-requests
+requests