Update app.py

app.py

@@ -8,24 +8,23 @@ from flask import Flask, Response, render_template, stream_with_context, make_re
 import requests
 
 app = Flask(__name__)
-random.seed()  # Initialize the random number generator
-
-# Initialize a dictionary to store requests per second
-requests_per_second = {}
+random.seed() 
 
 # Rate limiting parameters
-MAX_REQUESTS_PER_SECOND = 2000
-REQUEST_TIME_WINDOW = 1  # Time window in seconds
+MAX_REQUESTS_PER_SECOND = 2000 
+REQUEST_TIME_WINDOW = 1 
 
-# Use a deque to store timestamps of recent requests
+# Store timestamps of recent requests
 recent_requests = deque()
 
-# Telegram Bot Token & Chat ID
-TELEGRAM_BOT_TOKEN = '7408530224:AAGLPps_bWOHQ7mQDBe-BsXTiaJA8JmYIeo'
-TELEGRAM_CHAT_ID = '-1001825626706'
+# Telegram configuration
+TELEGRAM_BOT_TOKEN = '7408530224:AAGLPps_bWOHQ7mQDBe-BsXTiaJA8JmYIeo' 
+TELEGRAM_CHAT_ID = '-1001825626706' 
+
+# Initialize a dictionary to store requests per second
+requests_per_second = {}
 
 def send_telegram_alert(message):
-    """Sends a message to your Telegram chat."""
     url = f"https://api.telegram.org/bot{TELEGRAM_BOT_TOKEN}/sendMessage"
     data = {"chat_id": TELEGRAM_CHAT_ID, "text": message}
     requests.post(url, json=data)
@@ -42,13 +41,14 @@ def chart_data():
         while True:
             current_time = datetime.now().strftime('%M:%S')
             if current_time not in requests_per_second:
-                requests_per_second[current_time] = 0
+                requests_per_second[current_time] = 0 
 
             json_data = json.dumps(
-                {'time': current_time, 'value': requests_per_second[current_time]})
+                {'time': current_time, 'value': requests_per_second[current_time]}
+            )
             yield f"data:{json_data}\n\n"
-            time.sleep(1)  # Wait for 1 second
-            requests_per_second[current_time] = 0  # Reset count for next second
+            time.sleep(1) 
+            requests_per_second[current_time] = 0  
 
     response = Response(stream_with_context(generate_random_data()), mimetype="text/event-stream")
     response.headers["Cache-Control"] = "no-cache"
@@ -60,29 +60,32 @@ def attack():
     global recent_requests
 
     now = time.time()
+    current_time = datetime.now().strftime('%M:%S') 
 
+    # Rate Limiting (Improved)
     while recent_requests and now - recent_requests[0] > REQUEST_TIME_WINDOW:
         recent_requests.popleft()
 
-    if len(recent_requests) < MAX_REQUESTS_PER_SECOND:
-        recent_requests.append(now)
-
-        current_time = datetime.now().strftime('%M:%S')
-        if current_time in requests_per_second:
-            requests_per_second[current_time] += 1
-        else:
-            requests_per_second[current_time] = 1
+    if len(recent_requests) >= MAX_REQUESTS_PER_SECOND:
+        return "Too many requests, please try again later.", 429
 
-        # Check if requests per second hit 1000
-        if requests_per_second[current_time] == 1000:
-            send_telegram_alert(f"𝗛𝗶𝗴𝗵 𝘁𝗿𝗮𝗳𝗳𝗶𝗰 𝗱𝗲𝘁𝗲𝗰𝘁𝗲𝗱! at https://skylinex.eu.org/ {current_time}")
+    recent_requests.append(now)
 
-        # Membuat respons dengan header Link yang berbeda
-        response = make_response("Your Requests Get Approved and Cached Check https://skylinex.eu.org/")
-        response.headers["Link"] = "TELEGRAM VANO_GANZZZ"
-        return response
+    if current_time in requests_per_second:
+        requests_per_second[current_time] += 1
     else:
-        return "Too many requests, please try again later.", 429
+        requests_per_second[current_time] = 1
+
+    if requests_per_second[current_time] == 1000: 
+        send_telegram_alert(f"High traffic detected! at https://skylinex.eu.org/ {current_time}")
+
+    # Create the response
+    response = make_response("Your Requests Get Approved and Cached Check https://skylinex.eu.org/")
+    
+    # Set the desired Link header
+    response.headers["Link"] = "TELEGRAM VANO_GANZZZ"
+
+    return response
 
 if __name__ == '__main__':
     app.run(debug=True, threaded=True, host="0.0.0.0", port=7860)