fixes
This commit is contained in:
parent
4d4f9e0fd1
commit
5c62a8b669
@ -6,7 +6,7 @@ import re
|
|||||||
import asyncio
|
import asyncio
|
||||||
|
|
||||||
from pyrogram import Client
|
from pyrogram import Client
|
||||||
from driver.veez import call_py
|
from driver.veez import call_py, user
|
||||||
from program import BOT_ID, USERBOT_ID
|
from program import BOT_ID, USERBOT_ID
|
||||||
from driver.queues import QUEUE, add_to_queue
|
from driver.queues import QUEUE, add_to_queue
|
||||||
from driver.filters import command, other_filters
|
from driver.filters import command, other_filters
|
||||||
@ -100,7 +100,7 @@ async def play(_, m: Message):
|
|||||||
except UserNotParticipant:
|
except UserNotParticipant:
|
||||||
if m.chat.username:
|
if m.chat.username:
|
||||||
try:
|
try:
|
||||||
await call_py.join_chat(f"{m.chat.username}")
|
await user.join_chat(f"{m.chat.username}")
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
await m.reply_text(f"❌ **userbot failed to join**\n\n**reason**:{e}")
|
await m.reply_text(f"❌ **userbot failed to join**\n\n**reason**:{e}")
|
||||||
return
|
return
|
||||||
@ -108,7 +108,7 @@ async def play(_, m: Message):
|
|||||||
try:
|
try:
|
||||||
pope = await _.export_chat_invite_link(m.chat.id)
|
pope = await _.export_chat_invite_link(m.chat.id)
|
||||||
pepo = await _.revoke_chat_invite_link(m.chat.id, pope)
|
pepo = await _.revoke_chat_invite_link(m.chat.id, pope)
|
||||||
await call_py.join_chat(pepo.invite_link)
|
await user.join_chat(pepo.invite_link)
|
||||||
except UserAlreadyParticipant:
|
except UserAlreadyParticipant:
|
||||||
pass
|
pass
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
@ -297,7 +297,7 @@ async def stream(_, m: Message):
|
|||||||
except UserNotParticipant:
|
except UserNotParticipant:
|
||||||
if m.chat.username:
|
if m.chat.username:
|
||||||
try:
|
try:
|
||||||
await call_py.join_chat(f"{m.chat.username}")
|
await user.join_chat(f"{m.chat.username}")
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
await m.reply_text(f"❌ **userbot failed to join**\n\n**reason**:{e}")
|
await m.reply_text(f"❌ **userbot failed to join**\n\n**reason**:{e}")
|
||||||
return
|
return
|
||||||
@ -305,7 +305,7 @@ async def stream(_, m: Message):
|
|||||||
try:
|
try:
|
||||||
pope = await _.export_chat_invite_link(m.chat.id)
|
pope = await _.export_chat_invite_link(m.chat.id)
|
||||||
pepo = await _.revoke_chat_invite_link(m.chat.id, pope)
|
pepo = await _.revoke_chat_invite_link(m.chat.id, pope)
|
||||||
await call_py.join_chat(pepo.invite_link)
|
await user.join_chat(pepo.invite_link)
|
||||||
except UserAlreadyParticipant:
|
except UserAlreadyParticipant:
|
||||||
pass
|
pass
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
|
Loading…
Reference in New Issue
Block a user