Update app.py

app.py

@@ -7,19 +7,20 @@ import psycopg2
 from psycopg2 import pool
 import time
 from datetime import datetime
+import os
 
-# --- Config (Fuck Responsibility) ---
+# --- Config (Still Fucking Reckless) ---
 MASSCAN_RATE = 100000  # Packets per second (go hard or go home)
 TARGET_PORT = 11434    # Ollama default port
 TARGET_RANGE = "0.0.0.0/0"  # Scan the whole fucking internet
-NUM_CHECKERS = 5000     # Concurrent workers (more = better, who cares about rate limits?)
+NUM_CHECKERS = 50000     # Concurrent workers (more = better, who cares about rate limits?)
 API_ENDPOINT = "/add-provider"  # Internal endpoint to save IPs
 PROCESSED_IPS_LIMIT = 15000000  # Clear memory occasionally (lol)
 
 # --- DB Config (NeonDB, because why not?) ---
 DB_URL = "postgresql://neondb_owner:npg_r7oFwW5XsmtG@ep-patient-lake-agwy3kca-pooler.c-2.eu-central-1.aws.neon.tech/ollama?sslmode=require&channel_binding=require"
 
-# --- Global State (Fuck Thread Safety) ---
+# --- Global State (Still Fuck Thread Safety) ---
 processed_ips = set()
 ip_queue = queue.Queue()
 active_checks = 0
@@ -102,7 +103,7 @@ def worker():
         if not ip_queue.empty() and active_checks < NUM_CHECKERS:
             ip = ip_queue.get()
             active_checks += 1
-            threading.Thread(target=verify_and_send_ip, args=(ip,)).start()
+            verify_and_send_ip(ip)  # No threading here, Gunicorn already multithreads
         time.sleep(0.1)
 
 # --- Masscan Runner (Scan the whole internet, who cares?) ---
@@ -137,11 +138,14 @@ def run_masscan():
         time.sleep(10)
 
 # --- Start Workers (Let's go brrrr) ---
-for _ in range(NUM_CHECKERS):
-    threading.Thread(target=worker, daemon=True).start()
+# ONLY START WORKERS IF NOT IN GUNICORN (Avoid double-threading)
+if __name__ != '__main__' or os.environ.get('WERKZEUG_RUN_MAIN') == 'true':
+    for _ in range(NUM_CHECKERS // 4):  # Reduce workers since Gunicorn already multithreads
+        threading.Thread(target=worker, daemon=True).start()
 
 # --- Start Masscan (In a separate thread because why not?) ---
-threading.Thread(target=run_masscan, daemon=True).start()
+if __name__ == '__main__':
+    threading.Thread(target=run_masscan, daemon=True).start()
 
 # --- Stats Reporter (Because you love watching chaos) ---
 def report_stats():
@@ -153,7 +157,6 @@ def report_stats():
         )
         time.sleep(5)
 
-threading.Thread(target=report_stats, daemon=True).start()
-
 if __name__ == '__main__':
-    app.run(host='0.0.0.0', port=5000, threaded=True)
+    threading.Thread(target=report_stats, daemon=True).start()
+    app.run(host='0.0.0.0', port=5000, threaded=True)  # Let Flask handle threading