Add IND Admissions & KYC Master DB (/api/ind) with phone & email range lookups and update SBI master

engine.py

@@ -72,6 +72,7 @@ class LookupEngine:
         self.twitter_partitions = _load_index("twitter_index.json", [])
         self.ig_phone_partitions = _load_index("instagram_phone_index.json", [])
         self.ig_user_partitions = _load_index("instagram_username_index.json", [])
+        self.ind_partitions = _load_index("ind_partitions.json", [])
 
         logger.info(
             f"Loaded Master Index Routers: "
@@ -85,6 +86,7 @@ class LookupEngine:
             f"Twitter({len(self.twitter_partitions)}), "
             f"InstagramPhone({len(self.ig_phone_partitions)}), "
             f"InstagramUser({len(self.ig_user_partitions)}), "
+            f"IND({len(self.ind_partitions)}), "
             f"TelecomPhone({len(self.partitions.get('phone', []))})"
         )
 
@@ -130,6 +132,8 @@ class LookupEngine:
                 warm_targets.append((self.hdfc_partitions[0]["url"], "mobile"))
             if self.tg_partitions:
                 warm_targets.append((self.tg_partitions[0]["url"], "phone"))
+            if self.ind_partitions:
+                warm_targets.append((self.ind_partitions[0]["url"], "phone"))
             
             for url, col in warm_targets:
                 try:
@@ -930,6 +934,60 @@ class LookupEngine:
             self.cache[cache_key] = res
         return res
 
+    # ------------------------------------------------------------------
+    # 10d. IND Education, Admissions & KYC Master Database
+    # ------------------------------------------------------------------
+    def query_ind(self, query_input: Any) -> Dict[str, Any]:
+        t0 = time.time()
+        raw_val = str(query_input).strip()
+        clean_phone = self.sanitize_phone(raw_val)
+
+        cache_key = f"ind:{clean_phone or raw_val.lower()}"
+        with self.cache_lock:
+            if cache_key in self.cache:
+                return {**self.cache[cache_key], "cached": True, "latency_ms": round((time.time() - t0) * 1000, 2)}
+
+        cols = [
+            "phone", "email", "name", "father_name", "mother_name", "dob",
+            "aadhaar", "pan", "address", "city", "state", "pincode",
+            "college_name", "bank_name", "account_number", "ifsc_code",
+            "role", "source"
+        ]
+
+        records = []
+        if clean_phone:
+            phone_int = int(clean_phone)
+            partition = self._route_range(self.ind_partitions, phone_int, "min_id", "max_id")
+            if partition:
+                q = f"SELECT {', '.join(cols)} FROM '{partition['url']}' WHERE phone = {phone_int} LIMIT 10"
+                records = self._execute_query(q, cols)
+        else:
+            urls = [p["url"] for p in self.ind_partitions] if self.ind_partitions else []
+            if urls:
+                url_list_str = "[" + ", ".join([f"'{u}'" for u in urls]) + "]"
+                if len(raw_val) == 12 and raw_val.isdigit():
+                    q = f"SELECT {', '.join(cols)} FROM read_parquet({url_list_str}) WHERE aadhaar = '{raw_val}' LIMIT 10"
+                elif len(raw_val) == 10 and raw_val.isalnum() and not raw_val.isdigit():
+                    q = f"SELECT {', '.join(cols)} FROM read_parquet({url_list_str}) WHERE UPPER(pan) = '{raw_val.upper()}' LIMIT 10"
+                elif "@" in raw_val:
+                    q = f"SELECT {', '.join(cols)} FROM read_parquet({url_list_str}) WHERE LOWER(email) = '{raw_val.lower()}' LIMIT 10"
+                else:
+                    q = f"SELECT {', '.join(cols)} FROM read_parquet({url_list_str}) WHERE LOWER(name) LIKE '%{raw_val.lower()}%' LIMIT 10"
+                records = self._execute_query(q, cols)
+
+        res = {
+            "status": "success" if records else "not_found",
+            "database": "IND Admissions & KYC Master",
+            "query": raw_val,
+            "count": len(records),
+            "records": records,
+            "latency_ms": round((time.time() - t0) * 1000, 2),
+            "cached": False
+        }
+        with self.cache_lock:
+            self.cache[cache_key] = res
+        return res
+
     # ------------------------------------------------------------------
     # 🌟 11. UNIFIED COMBINED SEARCH ACROSS ALL 10 MASTER DATABASES
     # ------------------------------------------------------------------
@@ -964,6 +1022,7 @@ class LookupEngine:
             "airtel": self.executor.submit(self.query_airtel, mobile),
             "hdfc": self.executor.submit(self.query_hdfc, mobile),
             "sbi": self.executor.submit(self.query_sbi, str(mobile)),
+            "ind": self.executor.submit(self.query_ind, str(mobile)),
             "bsnl": self.executor.submit(self.query_bsnl, mobile),
             "paytm": self.executor.submit(self.query_paytm, mobile),
             "flipkart": self.executor.submit(self.query_flipkart, mobile),
@@ -1059,6 +1118,13 @@ class LookupEngine:
             loc = ", ".join(filter(None, [r.get("address"), r.get("city"), r.get("state"), r.get("pincode")]))
             _add_unique(locations, loc)
 
+        # 10. Parse IND Admissions & Education Master DB
+        for r in results.get("ind", {}).get("records", []):
+            _add_unique(names, r.get("name"))
+            _add_unique(emails, r.get("email"))
+            loc = ", ".join(filter(None, [r.get("address"), r.get("city"), r.get("state"), r.get("pincode")]))
+            _add_unique(locations, loc)
+
         # Calculate hits count
         hits = 0
         for src, data in results.items():

ind_partitions.json

@@ -0,0 +1,16 @@
+[
+  {
+    "part": 0,
+    "min_id": 6000000000,
+    "max_id": 9699907928,
+    "file": "part_0000_6000000000_9699907928.parquet",
+    "url": "hf://datasets/ItsXyron/IND-Master-DB/data/part_0000_6000000000_9699907928.parquet"
+  },
+  {
+    "part": 1,
+    "min_id": 9699907942,
+    "max_id": 9999999999,
+    "file": "part_0001_9699907942_9999999999.parquet",
+    "url": "hf://datasets/ItsXyron/IND-Master-DB/data/part_0001_9699907942_9999999999.parquet"
+  }
+]

main.py

@@ -320,6 +320,26 @@ async def lookup_sbi(
     return res
 
 
+@app.get("/api/ind/{query}")
+@app.get("/api/ind")
+async def lookup_ind(
+    query: Optional[str] = None,
+    q: Optional[str] = Query(None, description="Search query (phone, email, aadhaar, pan, name)"),
+    phone: Optional[str] = Query(None, description="10-digit mobile number"),
+    email: Optional[str] = Query(None, description="Email address"),
+    auth_meta: Dict[str, Any] = Depends(verify_api_key)
+):
+    """Search IND Education, Admissions & KYC Master Database by Phone, Email, Aadhaar, PAN, or Name."""
+    target = query or q or phone or email
+    if not target:
+        raise HTTPException(status_code=400, detail="Missing required parameter: provide 'query', 'q', 'phone', or 'email'.")
+    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/phone/{phone_number}")
 async def lookup_by_phone(phone_number: str, auth_meta: Dict[str, Any] = Depends(verify_api_key)):
     """Search Telecom 2.5B Database by phone number."""
@@ -403,6 +423,7 @@ async def unified_lookup(
     family: Optional[str] = Query(None, description="Direct Aadhaar family query"),
     user_id: Optional[str] = Query(None, description="Direct Telegram User ID"),
     sbi: Optional[str] = Query(None, description="Direct SBI POSP query"),
+    ind: Optional[str] = Query(None, description="Direct IND Admissions & KYC query"),
     auth_meta: Dict[str, Any] = Depends(verify_api_key)
 ):
     """
@@ -416,7 +437,9 @@ async def unified_lookup(
     """
     eng = get_engine()
 
-    if sbi:
+    if ind:
+        res = eng.query_ind(ind)
+    elif sbi:
         res = eng.query_sbi(sbi)
     elif family:
         res = eng.query_by_aadhar_family(family)

static/index.html

@@ -1289,6 +1289,15 @@
             </div>
             <div class="service-chip-desc">SBI, OLX &amp; Muthoot</div>
           </div>
+
+          <!-- IND Admissions & KYC Master -->
+          <div class="service-chip" data-service="ind" onclick="selectService('ind')">
+            <div class="service-chip-top">
+              <span class="service-chip-name">&#127891; IND Admissions &amp; KYC</span>
+              <span class="service-chip-tag">KYC / 686K</span>
+            </div>
+            <div class="service-chip-desc">HR, KC, Colleges &amp; Banks</div>
+          </div>
         </div>
       </section>
 
@@ -1510,6 +1519,14 @@
         maxLength: 32,
         presets: ["9910415684", "nehacarstreet1@gmail.com", "Carstreet naraina"],
         hasSubMode: false
+      },
+      ind: {
+        label: "TARGET: IND ADMISSIONS, EDUCATION & KYC MASTER DB",
+        placeholder: "Enter Phone, Email, Aadhaar, PAN, or Name...",
+        inputType: "text",
+        maxLength: 40,
+        presets: ["9769009011", "9699616059", "AVI.ALWAYSWITHU@GMAIL.COM"],
+        hasSubMode: false
       }
     };
 
@@ -1783,6 +1800,9 @@
         case "sbi":
           endpoint = `/api/sbi/${encodeURIComponent(cleanInput)}`;
           break;
+        case "ind":
+          endpoint = `/api/ind/${encodeURIComponent(cleanInput)}`;
+          break;
         default:
           endpoint = `/api/lookup?q=${encodeURIComponent(cleanInput)}`;
       }
@@ -1998,6 +2018,7 @@
         airtel: "Airtel India Subscriber DB (73M)",
         hdfc: "HDFC Banking & Loan DB (11.3M)",
         sbi: "SBI POSP & Indian Banking DB",
+        ind: "IND Admissions, Colleges & KYC Master (686K)",
         bsnl: "BSNL National DB (18.1M)",
         paytm: "Paytm Payments Core (2.95M)",
         flipkart: "Flipkart Logistics Accounts (926K)",