common_lib/utils/auth.py

@@ -8,16 +8,6 @@ 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()
 
 
@@ -38,16 +28,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.22"
+version = "0.0.21"
 description = "Библиотека общих компонентов для микросервисов yobble"
 authors = [{ name = "cheykrym", email = "you@example.com" }]
 license = "MIT"