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

merge pull request #174 from levina-lab/beta-test

Browse Source 
fix floodwait issue
This commit is contained in:
levina 2022-02-26 12:29:04 +07:00 committed by GitHub
commit edcd46b055
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 25 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
program/music_stream.py
View File

@ -197,20 +197,21 @@ async def play(c: Client, m: Message):
ubot = me_user.id ubot = me_user.id
b = await c.get_chat_member(chat_id, ubot) b = await c.get_chat_member(chat_id, ubot)
if b.status == "banned": if b.status == "banned":
await m.reply_text("❌ The userbot is banned in this chat, unban the userbot first to be able to play music !") try:
return await m.reply_text("❌ The userbot is banned in this chat, unban the userbot first to be able to play music !")
invitelink = (await c.get_chat(chat_id)).invite_link await remove_active_chat(chat_id)
if not invitelink: except BaseException:
await c.export_chat_invite_link(chat_id) pass
invitelink = (await c.get_chat(chat_id)).invite_link invitelink = (await c.get_chat(chat_id)).invite_link
if invitelink.startswith("https://t.me/+"): if not invitelink:
invitelink = invitelink.replace( await c.export_chat_invite_link(chat_id)
"https://t.me/+", "https://t.me/joinchat/" invitelink = (await c.get_chat(chat_id)).invite_link
) if invitelink.startswith("https://t.me/+"):
invitelink = invitelink.replace(
"https://t.me/+", "https://t.me/joinchat/"
)
await user.join_chat(invitelink) await user.join_chat(invitelink)
await remove_active_chat(chat_id) await remove_active_chat(chat_id)
except UserAlreadyParticipant:
pass
except UserNotParticipant: except UserNotParticipant:
try: try:
invitelink = (await c.get_chat(chat_id)).invite_link invitelink = (await c.get_chat(chat_id)).invite_link

23
program/video_stream.py
View File

@ -218,20 +218,21 @@ async def vplay(c: Client, m: Message):
ubot = me_user.id ubot = me_user.id
b = await c.get_chat_member(chat_id, ubot) b = await c.get_chat_member(chat_id, ubot)
if b.status == "banned": if b.status == "banned":
await m.reply_text("❌ The userbot is banned in this chat, unban the userbot first to be able to play music !") try:
return await m.reply_text("❌ The userbot is banned in this chat, unban the userbot first to be able to play music !")
invitelink = (await c.get_chat(chat_id)).invite_link await remove_active_chat(chat_id)
if not invitelink: except BaseException:
await c.export_chat_invite_link(chat_id) pass
invitelink = (await c.get_chat(chat_id)).invite_link invitelink = (await c.get_chat(chat_id)).invite_link
if invitelink.startswith("https://t.me/+"): if not invitelink:
invitelink = invitelink.replace( await c.export_chat_invite_link(chat_id)
"https://t.me/+", "https://t.me/joinchat/" invitelink = (await c.get_chat(chat_id)).invite_link
) if invitelink.startswith("https://t.me/+"):
invitelink = invitelink.replace(
"https://t.me/+", "https://t.me/joinchat/"
)
await user.join_chat(invitelink) await user.join_chat(invitelink)
await remove_active_chat(chat_id) await remove_active_chat(chat_id)
except UserAlreadyParticipant:
pass
except UserNotParticipant: except UserNotParticipant:
try: try:
invitelink = (await c.get_chat(chat_id)).invite_link invitelink = (await c.get_chat(chat_id)).invite_link