44 lines
1.4 KiB
Python
44 lines
1.4 KiB
Python
import logging as log
|
|
|
|
import aiohttp
|
|
import asyncio
|
|
from config import conf
|
|
|
|
|
|
async def send_message_to_dashboard(text):
|
|
url = f"https://api.telegram.org/bot{conf.tg.token}/sendMessage"
|
|
params = {
|
|
"chat_id": conf.tg.dashboard_chat_id,
|
|
"text": text,
|
|
}
|
|
if conf.tg.dashboard_tred_id:
|
|
params["message_thread_id"] = conf.tg.dashboard_tred_id
|
|
async with aiohttp.ClientSession() as session:
|
|
async with session.post(
|
|
url,
|
|
json=params,
|
|
) as response:
|
|
log.info(f"Response status: {response.status}")
|
|
resp = await response.json()
|
|
log.info(f"Message ID: {resp['result']['message_id']}")
|
|
return {
|
|
"status": response.status,
|
|
"msg_id": resp["result"]["message_id"],
|
|
}
|
|
|
|
|
|
async def del_message_from_dashboard(message_id):
|
|
url = f"https://api.telegram.org/bot{conf.tg.token}/deleteMessage"
|
|
async with aiohttp.ClientSession() as session:
|
|
async with session.post(
|
|
url,
|
|
json={
|
|
"chat_id": conf.tg.dashboard_chat_id,
|
|
"message_id": message_id,
|
|
},
|
|
) as response:
|
|
log.info(f"Response status: {response.status}")
|
|
resp = await response.json()
|
|
log.info(f"Message ID {message_id} deleted")
|
|
return resp
|