Blame for app.py

import os
import time
import hashlib
import hmac
import sys
import multiprocessing
from mnemonic import Mnemonic
import coincurve
from eth_utils import keccak, to_checksum_address
from web3 import Web3

# ============================================================
# 🛠️ APNI SETTINGS YAHAN SET KAREIN
# ============================================================
CSV_FILE = "14262022_addresses.csv"      

NUM_PHRASES = 1800000
SCAN_MODE = "File"       
ACC_START = 0
ACC_END = 29
ADDR_START = 0
ADDR_END = 29
SHOW_ALL = False
PASSPHRASE = ""

NUM_WORKERS = 48
# ============================================================

# Web3 Setup
alchemy_api_key = "Rjey8KWIGjKik1qfZ4vdU"
alchemy_url = f"https://eth-mainnet.g.alchemy.com/v2/{alchemy_api_key}"
web3_eth = Web3(Web3.HTTPProvider(alchemy_url, request_kwargs={"timeout": 10}))
bsc_url = "https://bsc-dataseed.binance.org/"
web3_bsc = Web3(Web3.HTTPProvider(bsc_url, request_kwargs={"timeout": 10}))

def get_balances(address):
    eth_float, bnb_float = 0.0, 0.0
    eth_str, bnb_str = "0.0", "0.0"
    try:
        eth_wei = web3_eth.eth.get_balance(Web3.to_checksum_address(address))
        eth_float = float(Web3.from_wei(eth_wei, 'ether'))
        if eth_float > 0: eth_str = f"{eth_float:.6f}"
    except Exception: pass
    try:
        bnb_wei = web3_bsc.eth.get_balance(Web3.to_checksum_address(address))
        bnb_float = float(Web3.from_wei(bnb_wei, 'ether'))
        if bnb_float > 0: bnb_str = f"{bnb_float:.6f}"
    except Exception: pass
    return eth_float, bnb_float, eth_str, bnb_str

# ============================================================
# Global Variables for Workers
# ============================================================
KNOWN_ADDRESSES = None
_MNEMONIC = None

def init_worker(known_addresses):
    global KNOWN_ADDRESSES
    KNOWN_ADDRESSES = known_addresses
    _get_mnemonic()

def _get_mnemonic():
    global _MNEMONIC
    if _MNEMONIC is None: _MNEMONIC = Mnemonic("english")
    return _MNEMONIC

# ============================================================
# Crypto Logic
# ============================================================
_SECP256K1_N = 0xFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFEBAAEDCE6AF48A03BBFD25E8CD0364141
_HARDENED = 0x80000000

def _bip32_derive_child_priv(parent_priv, parent_chain, index):
    if index >= _HARDENED:
        data = b'\x00' + parent_priv + index.to_bytes(4, 'big')
    else:
        pub = coincurve.PrivateKey(parent_priv).public_key.format(compressed=True)
        data = pub + index.to_bytes(4, 'big')
    I = hmac.new(parent_chain, data, hashlib.sha512).digest()
    child_int = (int.from_bytes(I[:32], 'big') + int.from_bytes(parent_priv, 'big')) % _SECP256K1_N
    if child_int == 0: raise ValueError("Invalid child key")
    return child_int.to_bytes(32, 'big'), I[32:]

def seed_to_privkey_hd(seed, account_idx=0, address_idx=0):
    I = hmac.new(b"Bitcoin seed", seed, hashlib.sha512).digest()
    key, chain = I[:32], I[32:]
    for idx in [44 + _HARDENED, 60 + _HARDENED, account_idx + _HARDENED, 0, address_idx]:
        key, chain = _bip32_derive_child_priv(key, chain, idx)
    return key

def phrase_to_seed(phrase, passphrase=""):
    return _get_mnemonic().to_seed(phrase, passphrase=passphrase)

# ============================================================
# Worker Function
# ============================================================
def process_phrase_worker(phrase):
    global KNOWN_ADDRESSES
    seed = phrase_to_seed(phrase, PASSPHRASE)
    matches_found = []
    paths_checked = 0

    for acc_idx in range(ACC_START, ACC_END + 1):
        for addr_idx in range(ADDR_START, ADDR_END + 1):
            paths_checked += 1
            try:
                priv = seed_to_privkey_hd(seed, acc_idx, addr_idx)
                pub = coincurve.PrivateKey(priv).public_key.format(compressed=False)[1:]
                addr = to_checksum_address(keccak(pub)[-20:])
            except Exception:
                continue

            if SCAN_MODE == "File":
                norm_addr = addr[2:].lower() if addr.startswith("0x") else addr.lower()
                
                if norm_addr in KNOWN_ADDRESSES:
                    match_details = (
                        f"\n{'🎯'*20}\n"
                        f"🎯 FILE MATCH FOUND!\n"
                        f"Phrase:      {phrase}\n"
                        f"Path:        m/44'/60'/{acc_idx}'/0/{addr_idx}\n"
                        f"Private Key: {priv.hex()}\n"
                        f"Address:     {addr}\n"
                        f"{'🎯'*20}\n"
                    )
                    matches_found.append(match_details)

            else: 
                eth_float, bnb_float, eth_str, bnb_str = get_balances(addr)
                if eth_float > 0 or bnb_float > 0:
                    match_details = (
                        f"\n{'🎉'*20}\n"
                        f"🎉 MATCH WITH BALANCE!\n"
                        f"Phrase:      {phrase}\n"
                        f"Path:        m/44'/60'/{acc_idx}'/0/{addr_idx}\n"
                        f"Private Key: {priv.hex()}\n"
                        f"Address:     {addr}\n"
                        f"ETH:         {eth_str}\n"
                        f"BNB:         {bnb_str}\n"
                        f"{'🎉'*20}\n"
                    )
                    matches_found.append(match_details)

    return paths_checked, matches_found

# ============================================================
# CSV File Setup
# ============================================================
def load_addresses_from_csv(path):
    if not os.path.exists(path): return None
    print(f"⏳ Loading CSV: {path}")
    start = time.time()
    
    addresses = set()
    with open(path, "r", encoding="utf-8", errors="replace") as f:
        for line in f:
            a = line.strip().strip('"').strip("'").lstrip("\ufeff").lower()
            if a.startswith("0x"): a = a[2:]
            if a and len(a) == 40:
                addresses.add(a)
    
    elapsed = time.time() - start
    print(f"✅ Loaded {len(addresses):,} addresses in {elapsed:.1f} seconds.\n")
    return addresses

# ============================================================
# Generator for phrases
# ============================================================
def phrase_generator():
    mnemo = _get_mnemonic()
    for _ in range(NUM_PHRASES):
        yield mnemo.generate(strength=128)

# ============================================================
# Main
# ============================================================
def main():
    global_start = time.time()

    known_addresses = None
    if SCAN_MODE == "File":
        known_addresses = load_addresses_from_csv(CSV_FILE)
        if not known_addresses:
            print(f"❌ CSV File nahi mili ya khali hai: {CSV_FILE}")
            return

    print("=" * 60)
    print(f"🔍 HD Wallet Scanner (Parallel: {NUM_WORKERS} Cores)")
    print("=" * 60)
    print(f"🛠️ Scan Mode: {SCAN_MODE} | Account: {ACC_START}-{ACC_END} | Address: {ADDR_START}-{ADDR_END}")
    print(f"📝 Total Phrases to scan: {NUM_PHRASES}\n")

    total_phrases = NUM_PHRASES
    phrases_checked = 0
    total_paths_checked = 0
    total_matches = 0
    last_percentage_printed = -1 

    print(f"🚀 Starting {NUM_WORKERS} workers on your Dual-Socket Xeon...\n")

    try:
        with multiprocessing.Pool(
            processes=NUM_WORKERS, 
            initializer=init_worker, 
            initargs=(known_addresses,)
        ) as pool:
            
            for paths, matches in pool.imap_unordered(process_phrase_worker, phrase_generator(), chunksize=2):
                phrases_checked += 1
                total_paths_checked += paths
                
                for match in matches:
                    print(f"\n{match}")
                    total_matches += 1
                
                # ✅ Sirf 10% par progress print karein
                current_pct = int((phrases_checked / total_phrases) * 100)
                if current_pct >= last_percentage_printed + 10:
                    print(f"⏳ Scanning Progress: {current_pct}% ({phrases_checked}/{total_phrases})")
                    last_percentage_printed = current_pct

        # Print 100% if it skipped due to loop limits
        if last_percentage_printed < 100:
             print(f"⏳ Scanning Progress: 100% ({phrases_checked}/{total_phrases})")

        print() 
            
    except KeyboardInterrupt:
        print("\n\n🛑 Script ruk gayi (Ctrl+C).")
        pool.terminate()
        pool.join()
    
    global_elapsed = time.time() - global_start

    print("=" * 60)
    print("🏁 RUN SUMMARY")
    print("=" * 60)
    print(f"📝 Phrases checked in THIS run:          {phrases_checked}")
    print(f"🔑 Private Keys generated in THIS run:   {total_paths_checked:,}")
    print(f"📬 Addresses checked in THIS run:        {total_paths_checked:,}")
    print(f"🎯 Matches found in THIS run:            {total_matches}")
    print("-" * 60)
    
    print(f"⏱️ Total time to complete process:       {global_elapsed:.2f} seconds")
    print("=" * 60)

if __name__ == "__main__":
    main()