mirror
/
TLG_JoinCaptchaBot
kopia lustrzana https://github.com/J-Rios/TLG_JoinCaptchaBot
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

Use asyncio sleeps

pull/179/head
J-Rios 2023-01-06 15:28:50 +01:00
rodzic 30226154e5
commit d07898d706
Nie znaleziono w bazie danych klucza dla tego podpisu
1 zmienionych plików z 9 dodań i 8 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

17
sources/join_captcha_bot.py
Wyświetl plik

@ -29,6 +29,7 @@ import logging
import signal import signal
# Asynchronous Input-Output Concurrency Library # Asynchronous Input-Output Concurrency Library
from asyncio import sleep as asyncio_sleep
from asyncio import run as asyncio_run from asyncio import run as asyncio_run
# Collections Data Types Library # Collections Data Types Library
@ -1574,7 +1575,7 @@ async def receive_poll_answer(
escape_markdown(user_name, 2)) escape_markdown(user_name, 2))
restrict_non_text_msgs = get_chat_config(chat_id, "Restrict_Non_Text") restrict_non_text_msgs = get_chat_config(chat_id, "Restrict_Non_Text")
# Wait 3s to let poll animation be shown # Wait 3s to let poll animation be shown
sleep(3) await asyncio_sleep(3)
# Remove previous join messages # Remove previous join messages
for msg in Global.new_users[chat_id][user_id]["msg_to_rm"]: for msg in Global.new_users[chat_id][user_id]["msg_to_rm"]:
await delete_tlg_msg(bot, chat_id, msg) await delete_tlg_msg(bot, chat_id, msg)
@ -1632,7 +1633,7 @@ async def receive_poll_answer(
else: else:
await tlg_send_msg(bot, chat_id, bot_msg) await tlg_send_msg(bot, chat_id, bot_msg)
# Wait 10s # Wait 10s
sleep(10) await asyncio_sleep(10)
# Try to kick the user # Try to kick the user
await captcha_fail_kick_ban_member( await captcha_fail_kick_ban_member(
bot, chat_id, user_id, CONST["MAX_FAIL_BAN_POLL"]) bot, chat_id, user_id, CONST["MAX_FAIL_BAN_POLL"])
@ -3528,7 +3529,7 @@ async def th_selfdestruct_messages(bot):
''' '''
while not Global.force_exit: while not Global.force_exit:
# Thread sleep for each iteration # Thread sleep for each iteration
sleep(0.01) await asyncio_sleep(0.01)
# Check each Bot sent message # Check each Bot sent message
i = 0 i = 0
while i < len(Global.to_delete_in_time_messages_list): while i < len(Global.to_delete_in_time_messages_list):
@ -3539,7 +3540,7 @@ async def th_selfdestruct_messages(bot):
# Sleep each 100 iterations # Sleep each 100 iterations
i = i + 1 i = i + 1
if (i > 1) and ((i % 1000) == 0): if (i > 1) and ((i % 1000) == 0):
sleep(0.01) await asyncio_sleep(0.01)
# Check if delete time has arrive for this message # Check if delete time has arrive for this message
if time() - sent_msg["time"] < sent_msg["delete_time"]: if time() - sent_msg["time"] < sent_msg["delete_time"]:
continue continue
@ -3565,7 +3566,7 @@ async def th_selfdestruct_messages(bot):
tlg_msg_to_selfdestruct(sent_result["msg"]) tlg_msg_to_selfdestruct(sent_result["msg"])
list_remove_element( list_remove_element(
Global.to_delete_in_time_messages_list, sent_msg) Global.to_delete_in_time_messages_list, sent_msg)
sleep(0.01) await asyncio_sleep(0.01)
############################################################################### ###############################################################################
@ -3579,7 +3580,7 @@ async def th_time_to_kick_not_verify_users(bot):
''' '''
while not Global.force_exit: while not Global.force_exit:
# Thread sleep for each iteration # Thread sleep for each iteration
sleep(0.01) await asyncio_sleep(0.01)
# Get all id from users in captcha process (list shallow copy) # Get all id from users in captcha process (list shallow copy)
users_id = [] users_id = []
chats_id_list = list(Global.new_users.keys()).copy() chats_id_list = list(Global.new_users.keys()).copy()
@ -3596,7 +3597,7 @@ async def th_time_to_kick_not_verify_users(bot):
i = i + 1 i = i + 1
if i > 1000: if i > 1000:
i = 0 i = 0
sleep(0.01) await asyncio_sleep(0.01)
# Check if script must exit for end thread # Check if script must exit for end thread
if Global.force_exit: if Global.force_exit:
return return
@ -3630,7 +3631,7 @@ async def th_time_to_kick_not_verify_users(bot):
chat_id, user_name) chat_id, user_name)
await captcha_fail_kick_ban_member( await captcha_fail_kick_ban_member(
bot, chat_id, user_id, CONST["MAX_FAIL_BAN"]) bot, chat_id, user_id, CONST["MAX_FAIL_BAN"])
sleep(0.01) await asyncio_sleep(0.01)
except Exception: except Exception:
logger.error(format_exc()) logger.error(format_exc())
logger.error("Fail to kick/ban an user") logger.error("Fail to kick/ban an user")