Update app.py

app.py

@@ -5,8 +5,6 @@ import asyncio
 import os
 import json
 
-request_count = {}
-ongoing_requests = {}
 bypass = os.getenv("BYPASS")
 MAX_REQUESTS_PER_MINUTE = 7
 app = Flask("DiscordRocks Instant Chat Proxy")
@@ -28,13 +26,6 @@ def handle_request(path=""):
     if method == 'POST':
         headers = {'Content-Type': 'application/json'}
         if 'reply' in path:
-            if request_count.get(ip, 0) >= MAX_REQUESTS_PER_MINUTE:
-                return jsonify({"error": "Too Many Requests. Please try again later."+ ip}), 429
-            if ip in ongoing_requests:
-                return jsonify({"error": "Concurrent requests not allowed."}), 429
-            ongoing_requests[ip] = True
-            request_count[ip] = request_count.get(ip, 0) + 1
-            didReply = True
             json_data = request.get_json()
             json_data['bypass'] = bypass
             data = json.dumps(json_data)
@@ -44,31 +35,9 @@ def handle_request(path=""):
     proxied_response = Response(response.content)
     proxied_response.status_code = response.status_code
     proxied_response.headers["Content-Type"] = "text/html"
-    if didReply:
-        del ongoing_requests[ip]
-        decrement_request_count_task(ip)
     
     return proxied_response
 
-def decrement_request_count_task(ip):
-    @copy_current_request_context
-    def decrement_count():
-        try:
-            loop = asyncio.new_event_loop()
-            asyncio.set_event_loop(loop)
-            loop.run_until_complete(decrement_request_count(ip))
-        except Exception as e:
-            print(e)
-
-    threading.Thread(target=decrement_count).start()
-
-async def decrement_request_count(ip):
-    try:
-        await asyncio.sleep(60)  # Ensure this runs asynchronously
-        request_count[ip] = request_count.get(ip, 0) - 1
-        print(request_count[ip])
-    except Exception as es:
-        print(es)
 
 if __name__ == "__main__":
     app.run(host="0.0.0.0", port=7860)