Всем привет, есть вот такой код для отправления сообщений в разные чаты в телеграмме. Проблема заключается в том что хотел докрутить к функции send_message_otc цикл для того что бы каждый определенный промежуток времени сообщения начали отправляться заново, но цикл почему то пропускает for и сразу приступает к функции time_to_sleep. Надеюсь все понятно расписал, спасибо!
from pyrogram import Client
from pyrogram.errors import FloodWait, BadRequest, Flood, InternalServerError
from time import sleep
from sys import stderr, exit
from loguru import logger
from dotenv import dotenv_values
from msvcrt import getch
from os import system
import random
import time
def clear(): return system('cls')
config = dotenv_values()
SESSION_NAME = config['session_name']
API_ID = int(config['api_id'])
API_HASH = config['api_hash']
logger.remove()
logger.add(stderr,
format='<white>{time:HH:mm:ss}</white> | '
'<level>{level: <8}</level> | '
'<cyan>{line}</cyan> - '
'<white>{message}</white>')
app = Client(SESSION_NAME, API_ID, API_HASH)
with open('otc.txt', 'r', encoding='utf-8') as file:
otc_list = [row.strip() for row in file]
msg_text = open('msg_text.txt', 'r', encoding='utf-8').read()
def time_to_sleep():
sleep_cycle=random.randint(1, 2)
logger.info(f"I will done delay in cycle {sleep_cycle} seconds")
time.sleep(sleep_cycle)
def send_message_otc(current_otc):
while True:
for _ in range(3):
try:
with app:
app.send_message(current_otc, msg_text)
except FloodWait as error:
logger.info(f'{current_otc} | FloodWait: {error.x}')
sleep(error.x)
except Flood:
pass
except BadRequest as error:
logger.error(f'{current_otc} | {error}')
except InternalServerError as error:
logger.error(f'{current_otc} | {error}')
except Exception as error:
logger.error(f'{current_otc} | {error}')
else:
logger.success(f'{current_otc} | The message was successfully sent')
sleep_messages = random.randint(3, 7)
logger.info(f"I will sleep {sleep_messages} seconds")
time.sleep(sleep_messages)
return
with open('errors_send_message.txt', 'a', encoding='utf-8') as file:
file.write(f'{current_otc}\n')
time_to_sleep()
def join_chat_otc(current_otc):
for _ in range(3):
try:
with app:
app.join_chat(current_otc)
except FloodWait as error:
logger.info(f'{current_otc} | FloodWait: {error.x}')
sleep(error.x)
except Flood:
pass
except BadRequest as error:
logger.error(f'{current_otc} | {error}')
except InternalServerError as error:
logger.error(f'{current_otc} | {error}')
except Exception as error:
logger.error(f'{current_otc} | {error}')
else:
logger.success(f'{current_otc} | Successfully logged into the chat')
return
with open('errors_join_chat.txt', 'a', encoding='utf-8') as file:
file.write(f'{current_otc}\n')
if __name__ == '__main__':
user_action = int(input('Enter your action '
'(1 - join chats from .txt; '
'2 - send message in chats from .txt): '))
clear()
for current_otc in otc_list:
if user_action == 1:
join_chat_otc(current_otc)
elif user_action == 2:
send_message_otc(current_otc)
logger.success('Работа цикла успешно завершена')
print('\nPress Any Key To Exit..')
