messenger/common_lib
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

patch

Browse Source
This commit is contained in:
cheykrym 2025-07-10 19:19:35 +03:00
parent 93387d0677
commit 29c1ae8fd5
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
common_lib/services/profile.py
View File

@ -8,7 +8,7 @@ from .utils import ssl_transport
async def get_profile_by_user_id(user_id: UUID, token: str) -> dict: async def get_profile_by_user_id(user_id: UUID, token: str) -> dict:
try: 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.get( response = await client.get(
f"{settings.PROFILE_SERVICE}/user_id/{user_id}", f"{settings.PROFILE_SERVICE}/user_id/{user_id}",
headers={"Authorization": f"Bearer {token}"} headers={"Authorization": f"Bearer {token}"}
@ -28,7 +28,7 @@ async def get_profile_by_user_id(user_id: UUID, token: str) -> dict:
async def get_profiles_by_user_ids(user_ids: List[UUID], token: str, user_id: UUID) -> Dict[str, dict]: async def get_profiles_by_user_ids(user_ids: List[UUID], token: str, user_id: UUID) -> Dict[str, dict]:
try: 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.PROFILE_SERVICE}/user_ids/internal", f"{settings.PROFILE_SERVICE}/user_ids/internal",
headers={"Authorization": f"Bearer {token}"}, headers={"Authorization": f"Bearer {token}"},

2
common_lib/utils/auth.py
View File

@ -28,7 +28,7 @@ async def _fetch_current_user(
user_agent = request.headers.get("User-Agent", "(unknown)") user_agent = request.headers.get("User-Agent", "(unknown)")
try: 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={