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

fixed not joined/leaved

Browse Source
This commit is contained in:
levina 2021-10-09 22:31:18 +07:00 committed by GitHub
parent efae31c0fd
commit be98297098
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 37 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

62
bot/userbotjoin.py
View File

@ -1,80 +1,88 @@
# Copyright (C) 2021 Veez Music Project
import asyncio import asyncio
from pyrogram import Client, filters
from pyrogram.errors import UserAlreadyParticipant
from pyrogram.raw.types import InputGroupCall
from pyrogram.raw.functions.phone import CreateGroupCall, DiscardGroupCall, GetGroupCall
from helpers.filters import command from helpers.filters import command
from pyrogram import Client, filters
from config import BOT_USERNAME, SUDO_USERS
from pyrogram.errors import UserAlreadyParticipant
from helpers.decorators import authorized_users_only, errors from helpers.decorators import authorized_users_only, errors
from bot.videoplayer import app as USER
from config import Veez
@Client.on_message(
@Client.on_message(command(["vjoin", f"vjoin@{Veez.BOT_USERNAME}"]) & ~filters.private & ~filters.bot) command(["userbotjoin", f"userbotjoin@{BOT_USERNAME}"]) & ~filters.private & ~filters.bot
)
@authorized_users_only @authorized_users_only
@errors @errors
async def entergroup(client, message): async def addchannel(client, message):
chid = message.chat.id chid = message.chat.id
try: try:
invitelink = await client.export_chat_invite_link(chid) invitelink = await client.export_chat_invite_link(chid)
except: except:
await message.reply_text( await message.reply_text(
"<b>💡 promote me as admin first to do that !</b>", "<b>• **i'm not have permission:**\n\n» ❌ __Add Users__</b>",
) )
return return
try: try:
user = await USER.get_me() user = await USER.get_me()
except: except:
user.first_name = "assistant" user.first_name = "music assistant"
try: try:
await USER.join_chat(invitelink) await USER.join_chat(invitelink)
await USER.send_message(message.chat.id, "🤖: i'm joined here for streaming video on video chat") await USER.send_message(
message.chat.id, "🤖: i'm joined here for playing music on voice chat"
)
except UserAlreadyParticipant: except UserAlreadyParticipant:
await message.reply_text( await message.reply_text(
"<b>✅ assistant already entered this group</b>", f"<b>✅ userbot already joined chat</b>",
) )
except Exception as e: except Exception as e:
print(e) print(e)
await message.reply_text( await message.reply_text(
f"<b>🔴 FLOODWAIT ERROR 🔴\n\n user {user.first_name} couldn't join your group due to heavy join requests for userbot! make sure assistant is not banned in this group." f"<b>🛑 Flood Wait Error 🛑 \n\n User {user.first_name} couldn't join your group due to heavy join requests for userbot."
"\n\nor manually add assistant to your Group and try again</b>",
) )
return return
await message.reply_text( await message.reply_text(
"<b>✅ assistant userbot joined your chat</b>", f"<b>✅ userbot successfully joined chat</b>",
) )
@Client.on_message(command(["vleave", f"vleave@{Veez.BOT_USERNAME}"]) & filters.group & ~filters.edited) @Client.on_message(
command(["userbotleave", f"userbotleave@{BOT_USERNAME}"]) & filters.group & ~filters.edited
)
@authorized_users_only @authorized_users_only
async def leavegroup(client, message): async def rem(client, message):
try: try:
await USER.send_message(message.chat.id, "✅ userbot successfully left chat")
await USER.leave_chat(message.chat.id) await USER.leave_chat(message.chat.id)
except: except:
await message.reply_text( await message.reply_text(
"<b>❌ assistant can't leave from group because floodwaits.\n\n» you can manually kick me from this group</b>" "<b>user couldn't leave your group, may be floodwaits.\n\nor manually kick me from your group</b>"
) )
return return
@Client.on_message(command(["leaveall", f"leaveall@{Veez.BOT_USERNAME}"])) @Client.on_message(command(["leaveall", f"leaveall@{BOT_USERNAME}"]))
async def outall(client, message): async def bye(client, message):
if message.from_user.id not in Veez.SUDO_USERS: if message.from_user.id not in SUDO_USERS:
return return
left = 0 left = 0
failed = 0 failed = 0
lol = await message.reply("🔁 assistant leaving all chats") lol = await message.reply("🔄 **userbot** leaving all chats !")
async for dialog in USER.iter_dialogs(): async for dialog in USER.iter_dialogs():
try: try:
await USER.leave_chat(dialog.chat.id) await USER.leave_chat(dialog.chat.id)
left += 1 left += 1
await lol.edit(f"🔁 assistant leaving...\n⏳ Left: {left} chats.\n\n❌ Failed: {failed} chats.") await lol.edit(
f"Userbot leaving all group...\n\nLeft: {left} chats.\nFailed: {failed} chats."
)
except: except:
failed += 1 failed += 1
await lol.edit(f"🔁 assistant leaving...\n⏳ Left: {left} chats.\n\n❌ Failed: {failed} chats.") await lol.edit(
f"Userbot leaving...\n\nLeft: {left} chats.\nFailed: {failed} chats."
)
await asyncio.sleep(0.7) await asyncio.sleep(0.7)
await client.send_message(message.chat.id, f"✅ Left {left} chats.\n\n❌ Failed {failed} chats.") await client.send_message(
message.chat.id, f"Left {left} chats.\nFailed {failed} chats."
)