feat: Implemented HTTP 50x error tracking, per-route exhaust ratelimiting, refactored decor.py

Author: FayeDel

interactions/api/http/request.py

@@ -98,7 +98,8 @@ async def request(self, route: Route, **kwargs) -> Optional[Any]:
         """
 
         kwargs["headers"] = {**self._headers, **kwargs.get("headers", {})}
-        kwargs["headers"]["Content-Type"] = "application/json"
+        if kwargs.get("json"):
+            kwargs["headers"]["Content-Type"] = "application/json"
 
         reason = kwargs.pop("reason", None)
         if reason:
@@ -165,7 +166,7 @@ async def request(self, route: Route, **kwargs) -> Optional[Any]:
                         # This "redundant" debug line is for debug use and tracing back the error codes.
 
                         raise HTTPException(data["code"], message=data["message"])
-                    elif remaining and not int(remaining):
+                    if remaining and not int(remaining):
                         if response.status == 429:
                             log.warning(
                                 f"The HTTP client has encountered a per-route ratelimit. Locking down future requests for {reset_after} seconds."
@@ -181,6 +182,18 @@ async def request(self, route: Route, **kwargs) -> Optional[Any]:
                             self._loop.call_later(
                                 self._global_lock.reset_after, self._global_lock.lock.release
                             )
+                        elif int(remaining) == 0:
+                            log.warning(
+                                f"The HTTP client has exhausted a per-route ratelimit. Locking route for {reset_after} seconds."
+                            )
+                            self._loop.call_later(reset_after, _limiter.release_lock())
+
+                    if response.status in {500, 502, 504}:
+                        log.warning(
+                            f"{route.endpoint} Received {response.status}... retrying in {1 + tries * 2} seconds"
+                        )
+                        await asyncio.sleep(1 + tries * 2)
+                        continue
 
                     log.debug(f"RETURN {response.status}: {dumps(data, indent=4, sort_keys=True)}")
 

interactions/decor.py

@@ -34,17 +34,18 @@ def command(
     _description: str = "" if description is MISSING else description
     _options: list = []
 
-    _name_localizations: dict = {} if name_localizations is MISSING else name_localizations
-    _description_localizations: dict = (
-        {} if description_localizations is MISSING else description_localizations
+    _name_localizations = (
+        {}
+        if name_localizations is MISSING
+        else {k.value if isinstance(k, Locale) else k: v for k, v in name_localizations.items()}
+    )
+    _description_localizations = (
+        {}
+        if description_localizations is MISSING
+        else {
+            k.value if isinstance(k, Locale) else k: v for k, v in description_localizations.items()
+        }
     )
-
-    _name_localizations = {
-        k.value if isinstance(k, Locale) else k: v for k, v in _name_localizations.items()
-    }
-    _description_localizations = {
-        k.value if isinstance(k, Locale) else k: v for k, v in _description_localizations.items()
-    }
 
     if options is not MISSING:
         if all(isinstance(option, Option) for option in options):