aho/welcomecenterbot
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

polling-log2

Browse Source
This commit is contained in:
Untone 2024-09-26 14:13:33 +03:00
parent fb977fe529
commit ff57e35f53
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
bot/api.py
View File

@ -18,12 +18,12 @@ async def telegram_api(endpoint: str, json_data=None, **kwargs):
headers = {'Content-Type': 'application/json'} headers = {'Content-Type': 'application/json'}
async with aiohttp.ClientSession() as session: async with aiohttp.ClientSession() as session:
url = api_base + f"{endpoint}?{urlencode(kwargs)}" url = api_base + f"{endpoint}?{urlencode(kwargs)}"
if not is_polling: #if not is_polling:
logger.info(f' >>> {url} {json_data if json_data else ""}') logger.info(f' >>> {url} {json_data if json_data else ""}')
async with session.get(url, data=json.dumps(json_data), headers=headers) as response: async with session.get(url, data=json.dumps(json_data), headers=headers) as response:
data = await response.json() data = await response.json()
if not is_polling: # if not is_polling:
logger.info(f' <<< {data}') logger.info(f' <<< {data}')
return data return data
except Exception as ex: except Exception as ex:
import traceback import traceback

2
main.py
View File

@ -19,7 +19,7 @@ async def start():
offset = 0 # init offset offset = 0 # init offset
while True: while True:
response = await telegram_api("getUpdates", offset=offset, allowed_updates=['message', 'message_reaction']) response = await telegram_api("getUpdates", offset=offset, allowed_updates=['message', 'message_reaction'])
logger.debug(response) # logger.debug(response)
if isinstance(response, dict): if isinstance(response, dict):
result = response.get("result", []) result = response.get("result", [])
for update in result: for update in result: