77 lines
2.2 KiB
Python
77 lines
2.2 KiB
Python
|
import os
|
||
|
|
import time
|
||
|
|
import requests
|
||
|
|
from dotenv import load_dotenv
|
||
|
|
import json
|
||
|
|
|
||
|
|
def telegram_bot_sendtext(bot_message):
|
||
|
|
send_text = TELEGRAM_URL + BOT_TOKEN + '/sendMessage?chat_id={}&text={}'.format(CHAT_ID,bot_message)
|
||
|
|
response = requests.get(send_text)
|
||
|
|
response_json = response.json()
|
||
|
|
return response.json()
|
||
|
|
|
||
|
|
def send_media_group(**kwargs):
|
||
|
|
caption = kwargs.get('caption')
|
||
|
|
media = kwargs.get('media')
|
||
|
|
carousel = kwargs.get('carousel', None)
|
||
|
|
|
||
|
|
send_text = telegram_bot_sendtext(caption);
|
||
|
|
if send_text['ok'] is not True:
|
||
|
|
print('Stop')
|
||
|
|
return
|
||
|
|
else:
|
||
|
|
message_id = send_text.get('result')['message_id']
|
||
|
|
|
||
|
|
data = {
|
||
|
|
'chat_id' : CHAT_ID,
|
||
|
|
"reply_to_message_id":message_id,
|
||
|
|
"media": json.dumps(media)
|
||
|
|
}
|
||
|
|
send_url = TELEGRAM_URL + '{}{}'.format(BOT_TOKEN, '/sendMediaGroup')
|
||
|
|
response = requests.post(send_url, data=data)
|
||
|
|
response_json = response.json()
|
||
|
|
if response_json.get('ok') is True:
|
||
|
|
print('DONE')
|
||
|
|
return response_json
|
||
|
|
|
||
|
|
def telegram_bot_send_media(**kwargs):
|
||
|
|
fileType = kwargs.get('fileType')
|
||
|
|
url = kwargs.get('url', None)
|
||
|
|
caption = kwargs.get('caption')
|
||
|
|
reply_first = kwargs.get('reply_first', False)
|
||
|
|
reply_id = kwargs.get('reply_id', None)
|
||
|
|
data = {
|
||
|
|
'chat_id' : CHAT_ID,
|
||
|
|
"caption": caption,
|
||
|
|
}
|
||
|
|
if reply_first is True:
|
||
|
|
send_text = telegram_bot_sendtext(caption);
|
||
|
|
if send_text['ok'] is not True:
|
||
|
|
print('Stop')
|
||
|
|
return
|
||
|
|
data.update({"reply_to_message_id": send_text.get('result')['message_id']})
|
||
|
|
if reply_id is not None: data.update({"reply_to_message_id": reply_id})
|
||
|
|
if fileType == 'video':
|
||
|
|
data.update({
|
||
|
|
'video': url
|
||
|
|
})
|
||
|
|
endpoint = "/sendVideo"
|
||
|
|
elif fileType == 'photo':
|
||
|
|
data.update({
|
||
|
|
'photo': url
|
||
|
|
})
|
||
|
|
endpoint = "/sendPhoto"
|
||
|
|
else:
|
||
|
|
print("Failed")
|
||
|
|
return False
|
||
|
|
|
||
|
|
send_url = TELEGRAM_URL + '{}{}'.format(BOT_TOKEN, endpoint)
|
||
|
|
response = requests.post(send_url,data=data)
|
||
|
|
return response.json()
|
||
|
|
|
||
|
|
|
||
|
|
if __name__ == 'send_telegram':
|
||
|
|
load_dotenv()
|
||
|
|
BOT_TOKEN = os.getenv('BOT_TOKEN')
|
||
|
|
CHAT_ID = os.getenv('CHAT_ID')
|
||
|
|
TELEGRAM_URL = os.getenv('TELEGRAM_URL')
|