Xtao-Labs/Lsposed_Modules_Updates_Tracker
3
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

🐛 Fix floodwait error

Browse Source
This commit is contained in:
xtaodada 2022-03-20 02:08:54 +08:00
parent bd2d03f9e7
commit b126213c49
Signed by: xtaodada
GPG Key ID: 4CBB3F4FA8C85659
2 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
plugins/ping.py
View File

@ -4,5 +4,5 @@ from pyrogram.types import Message
@Client.on_message(filters.incoming & filters.private & @Client.on_message(filters.incoming & filters.private &
filters.command(["ping", ])) filters.command(["ping", ]))
async def force_update(bot: Client, message: Message): async def ping_check(bot: Client, message: Message):
await message.reply("poi ~", quote=True) await message.reply("poi ~", quote=True)

9
plugins/track.py
View File

@ -15,18 +15,18 @@ from defs.source import update_data, compare, download
async def send_track_msg(file, track_msg): async def send_track_msg(file, track_msg):
if file: if file:
await app.send_document(channel_id, file, await app.send_document(channel_id, file,
caption=track_msg.text, caption=track_msg.text[:1000],
file_name=track_msg.name, file_name=track_msg.name,
force_document=True, force_document=True,
parse_mode="html", parse_mode="html",
reply_markup=track_msg.button) reply_markup=track_msg.button)
else: else:
await app.send_message(channel_id, track_msg.text, await app.send_message(channel_id, track_msg.text[:1000],
parse_mode="html", parse_mode="html",
reply_markup=track_msg.button) reply_markup=track_msg.button)
# @scheduler.scheduled_job("cron", minute="*/30", id="0") @scheduler.scheduled_job("cron", minute="*/30", id="0")
async def run_every_30_minute(): async def run_every_30_minute():
await update_data() await update_data()
need_update = compare() need_update = compare()
@ -58,13 +58,14 @@ async def run_every_30_minute():
await send_track_msg(None, track_msg) await send_track_msg(None, track_msg)
except FloodWait as e: except FloodWait as e:
print(f"Send document flood - Sleep for {e.x} second(s)") print(f"Send document flood - Sleep for {e.x} second(s)")
await sleep(uniform(0.5, 1.0)) await sleep(e.x + uniform(0.5, 1.0))
await send_track_msg(None, track_msg) await send_track_msg(None, track_msg)
except ButtonUrlInvalid: except ButtonUrlInvalid:
print(f"Send button error") print(f"Send button error")
await app.send_message(channel_id, track_msg.text, parse_mode="html",) await app.send_message(channel_id, track_msg.text, parse_mode="html",)
except Exception as e: except Exception as e:
traceback.print_exc() traceback.print_exc()
await sleep(uniform(0.5, 2.0))
@Client.on_message(filters.incoming & filters.private & filters.chat(admin_id) & @Client.on_message(filters.incoming & filters.private & filters.chat(admin_id) &