catspace-dev/unicheckbot
1
1
Fork 0
mirror of https://github.com/catspace-dev/unicheckbot.git synced 2024-11-22 13:56:34 +03:00
Code Issues Packages Projects Releases Wiki Activity

result Response(500) if node unreachable

Browse Source
This commit is contained in:
kiriharu 2021-01-05 00:33:55 +03:00
parent cd2e0002f8
commit 9ca48f5973
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
apps/tgbot/tgbot/handlers/helpers.py
View File

@ -1,4 +1,4 @@
from httpx import AsyncClient, Timeout from httpx import AsyncClient, Timeout, Response, ConnectError
from typing import List from typing import List
from core.coretypes import APINode from core.coretypes import APINode
@ -15,8 +15,12 @@ def check_int(value) -> bool:
async def send_api_requests(endpoint: str, data: dict, nodes: List[APINode]): async def send_api_requests(endpoint: str, data: dict, nodes: List[APINode]):
for node in nodes: for node in nodes:
data.update(dict(token=node.token)) data.update(dict(token=node.token))
try:
async with AsyncClient(timeout=Timeout(timeout=100.0)) as client: async with AsyncClient(timeout=Timeout(timeout=100.0)) as client:
result = await client.get( result = await client.get(
f"{node.address}/{endpoint}", params=data f"{node.address}/{endpoint}", params=data
) )
except ConnectError:
# We yield 500 response when backend is offline
result = Response(500)
yield result yield result