fix http

common_lib/utils/auth.py

@@ -8,6 +8,16 @@ from config import settings
 from .ssl_transport import ssl_transport
 from .validators import validate_username as core_validate_username, validate_password as core_validate_password
 
+
+limits = httpx.Limits(max_keepalive_connections=200, max_connections=1000)
+timeout = httpx.Timeout(connect=5.0, read=10.0, write=5.0, pool=5.0)
+
+client = httpx.AsyncClient(
+    transport=ssl_transport,
+    limits=limits,
+    timeout=timeout
+)
+
 auth_scheme = HTTPBearer()
 
 
@@ -28,16 +38,16 @@ async def _fetch_current_user(
     user_agent = request.headers.get("User-Agent", "(unknown)")
 
     try:
-        async with httpx.AsyncClient(transport=ssl_transport, timeout=5.0) as client:
+        # async with httpx.AsyncClient(transport=ssl_transport, timeout=5.0) as client:
-            response = await client.post(
+        response = await client.post(
-                f"{settings.TOKEN_SERVICE}/decode",
+            f"{settings.TOKEN_SERVICE}/decode",
-                json={
+            json={
-                    "token": token,
+                "token": token,
-                    "ip": ip,
+                "ip": ip,
-                    "user_agent": user_agent,
+                "user_agent": user_agent,
-                    "require_permissions": require_permissions
+                "require_permissions": require_permissions
-                },
+            },
-            )
+        )
     except httpx.RequestError as e:
         print("_fetch_current_user error", e)
         raise HTTPException(status_code=status.HTTP_503_SERVICE_UNAVAILABLE, detail="Token service unavailable")

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "common-lib"
-version = "0.0.21"
+version = "0.0.22"
 description = "Библиотека общих компонентов для микросервисов yobble"
 authors = [{ name = "cheykrym", email = "you@example.com" }]
 license = "MIT"