Create app.py

app.py

@@ -0,0 +1,87 @@
+import asyncio
+import json
+import requests
+import time
+from threading import Thread, Lock
+from http.server import BaseHTTPRequestHandler, HTTPServer
+import socketserver
+import urllib.request
+
+# --- CONFIG ---
+PROXY_JSON_URL = "https://raw.githubusercontent.com/mishableskineetudiant-stack/proxylistfiltered/main/proxies_elite.json"
+REFRESH_INTERVAL = 300  # 5 minutes
+PORT = 3129
+
+# Pool de proxies (thread-safe)
+proxy_pool = []
+pool_lock = Lock()
+
+def fetch_proxies():
+    try:
+        resp = requests.get(PROXY_JSON_URL, timeout=10)
+        data = resp.json()
+        cleaned = []
+        for p in data:
+            # Format "ip:port"
+            cleaned.append(f"http://{p}")
+        return cleaned
+    except Exception as e:
+        print(f"[Fetcher] Error fetching proxies: {e}")
+        return []
+
+def refresh_loop():
+    global proxy_pool
+    while True:
+        print("[Refresher] Fetching new proxy list...")
+        new_list = fetch_proxies()
+        if new_list:
+            with pool_lock:
+                proxy_pool = new_list
+            print(f"[Refresher] Loaded {len(new_list)} proxies")
+        else:
+            print("[Refresher] No update (empty list)")
+        time.sleep(REFRESH_INTERVAL)
+
+class ProxyHandler(BaseHTTPRequestHandler):
+    def do_GET(self):
+        self.forward_request()
+
+    def do_POST(self):
+        self.forward_request()
+
+    def forward_request(self):
+        # Choisir proxy round-robin
+        with pool_lock:
+            if not proxy_pool:
+                self.send_error(503, "No proxies available")
+                return
+            proxy = proxy_pool[int(time.time()) % len(proxy_pool)]
+
+        try:
+            req = urllib.request.Request(self.path)
+            opener = urllib.request.build_opener(urllib.request.ProxyHandler({"http": proxy, "https": proxy}))
+            resp = opener.open(req, timeout=10)
+            data = resp.read()
+
+            self.send_response(resp.getcode())
+            for key, val in resp.getheaders():
+                self.send_header(key, val)
+            self.end_headers()
+            self.wfile.write(data)
+
+        except Exception as e:
+            self.send_error(502, f"Bad Gateway: {e}")
+
+def run_server():
+    with HTTPServer(("", PORT), ProxyHandler) as httpd:
+        print(f"[Proxy Server] Running on port {PORT}")
+        httpd.serve_forever()
+
+if __name__ == "__main__":
+    # Start refresh thread
+    t = Thread(target=refresh_loop, daemon=True)
+    t.start()
+
+    # Run proxy HTTP server
+    run_server()
+