!pip install flask flask-cors web3 psutil
!wget -q -O cloudflared https://github.com/cloudflare/cloudflared/releases/latest/download/cloudflared-linux-amd64
!chmod +x cloudflared
!fuser -k 5000/tcp

import threading, os, psutil, time
print("=========================================")
print("=== SCRIPT VERSION 4 (CLOUDFLARE EDITION) ===")
print("=========================================")

from flask import Flask, request, jsonify
from flask_cors import CORS
import concurrent.futures
from web3 import Web3

app = Flask(__name__)
CORS(app)

stats = {'scanned': 0, 'found': 0, 'failed': 0}
lock = threading.Lock()

RPCS = {
    'ETH':'https://cloudflare-eth.com',
    'BSC':'https://binance.llamarpc.com',
    'POL':'https://polygon-rpc.com',
    'ARB':'https://arb1.arbitrum.io/rpc',
    'OP':'https://mainnet.optimism.io',
    'BASE':'https://mainnet.base.org'
}
w3s = {c: Web3(Web3.HTTPProvider(u)) for c, u in RPCS.items()}

def check(args):
    w, chains = args
    res = []
    errs = 0
    for c in chains:
        if c in w3s:
            try:
                bal = w3s[c].eth.get_balance(w['address'])
                if bal > 0: res.append({"address": w['address'], "chain": c, "balance": bal / 10**18})
            except Exception: errs += 1
    return res, errs

@app.route('/', methods=['GET'])
def dashboard():
    ram = psutil.virtual_memory()
    cpu = psutil.cpu_percent()
    return f"""
    
    
    
        
⚡ CRYPTO ALPHA - COLAB ENGINE
        

            
Hardware Monitor
            
CPU: {cpu}%
            
RAM: {ram.percent}% ({ram.used//10**6}MB / {ram.total//10**6}MB)
        
        

            
Scan Statistics
            
Total Scanned Checks: {stats['scanned']}
            
Failed/Rate-Limited: {stats['failed']}
            
Wallets Found: {stats['found']}
        
    
    
    """

@app.route('/status', methods=['GET'])
def status(): return jsonify({"status":"ready","threads":250})

@app.route('/scan', methods=['POST'])
def scan():
    wallets = request.json.get('wallets', [])
    chains = request.json.get('chains', ['ETH', 'BSC', 'POL'])
    found = []
    total_errs = 0
    
    with concurrent.futures.ThreadPoolExecutor(max_workers=250) as ex:
        for r, errs in ex.map(check, [(w, chains) for w in wallets]):
            found.extend(r)
            total_errs += errs
            
    with lock:
        stats['scanned'] += len(wallets) * len(chains)
        stats['found'] += len(found)
        stats['failed'] += total_errs
        
    return jsonify({"checked": len(wallets), "found": found})

if __name__ == '__main__':
    threading.Thread(target=app.run, kwargs={'port':5000}).start()
    time.sleep(2)
    print(">>> LOOK FOR THE LINK ENDING IN .trycloudflare.com BELOW <<<")
    !./cloudflared tunnel --url http://localhost:5000