| | |
| | |
| | |
| | |
| | |
| | |
| | from . import get_help |
| |
|
| | __doc__ = get_help("help_channelhacks") |
| |
|
| |
|
| | import asyncio |
| | import io |
| |
|
| | from telethon.errors.rpcerrorlist import FloodWaitError |
| | from telethon.utils import get_display_name, get_peer_id |
| |
|
| | from pyUltroid.dB.base import KeyManager |
| |
|
| | from . import LOGS, asst, eor, events, get_string, udB, ultroid_bot, ultroid_cmd |
| |
|
| | ERROR = {} |
| | SourceM = KeyManager("CH_SOURCE", cast=list) |
| | DestiM = KeyManager("CH_DESTINATIONS", cast=list) |
| |
|
| |
|
| | async def autopost_func(e): |
| | if not udB.get_key("AUTOPOST"): |
| | return |
| | x = SourceM.get() |
| | th = await e.get_chat() |
| | if get_peer_id(th) not in x: |
| | return |
| | y = DestiM.get() |
| | for ys in y: |
| | try: |
| | await e.client.send_message(int(ys), e.message) |
| | except Exception as ex: |
| | try: |
| | ERROR[str(ex)] |
| | except KeyError: |
| | ERROR.update({str(ex): ex}) |
| | Error = f"**Error on AUTOPOST**\n\n`{ex}`" |
| | await asst.send_message(udB.get_key("LOG_CHANNEL"), Error) |
| |
|
| |
|
| | @ultroid_cmd(pattern="shift (.*)") |
| | async def _(e): |
| | x = e.pattern_match.group(1).strip() |
| | z = await e.eor(get_string("com_1")) |
| | a, b = x.split("|") |
| | try: |
| | c = await e.client.parse_id(a) |
| | except Exception: |
| | await z.edit(get_string("cha_1")) |
| | return |
| | try: |
| | d = await e.client.parse_id(b) |
| | except Exception as er: |
| | LOGS.exception(er) |
| | await z.edit(get_string("cha_1")) |
| | return |
| | async for msg in e.client.iter_messages(int(c), reverse=True): |
| | try: |
| | await asyncio.sleep(2) |
| | await e.client.send_message(int(d), msg) |
| | except FloodWaitError as er: |
| | await asyncio.sleep(er.seconds + 5) |
| | await e.client.send_message(int(d), msg) |
| | except BaseException as er: |
| | LOGS.exception(er) |
| | await z.edit("Done") |
| |
|
| |
|
| | @ultroid_cmd(pattern="asource (.*)") |
| | async def source(e): |
| | if x := e.pattern_match.group(1).strip(): |
| | try: |
| | y = await e.client.parse_id(x) |
| | except Exception as er: |
| | LOGS.exception(er) |
| | return |
| | else: |
| | y = e.chat_id |
| | if not SourceM.contains(y): |
| | SourceM.add(y) |
| | await e.eor(get_string("cha_2")) |
| | ultroid_bot.add_handler(autopost_func, events.NewMessage()) |
| | else: |
| | await e.eor(get_string("cha_3")) |
| |
|
| |
|
| | @ultroid_cmd(pattern="dsource( (.*)|$)") |
| | async def dd(event): |
| | chat_id = event.pattern_match.group(1).strip() |
| | x = await event.eor(get_string("com_1")) |
| | if chat_id == "all": |
| | await x.edit(get_string("bd_8")) |
| | udB.del_key("CH_SOURCE") |
| | await x.edit(get_string("cha_4")) |
| | return |
| | if chat_id: |
| | try: |
| | y = await event.client.parse_id(chat_id) |
| | except Exception as er: |
| | LOGS.exception(er) |
| | return |
| | else: |
| | y = event.chat_id |
| | if SourceM.contains(y): |
| | SourceM.remove(y) |
| | await eor(x, get_string("cha_5"), time=5) |
| | else: |
| | await eor(x, "Source channel is already removed from database. ", time=3) |
| |
|
| |
|
| | @ultroid_cmd(pattern="listsource") |
| | async def list_all(event): |
| | x = await event.eor(get_string("com_1")) |
| | num = SourceM.count() |
| | if not num: |
| | return await eor(x, "No chats were added.", time=5) |
| | msg = get_string("cha_8") |
| | channels = SourceM.get() |
| | for channel in channels: |
| | name = "" |
| | try: |
| | name = get_display_name(await event.client.get_entity(int(channel))) |
| | except BaseException: |
| | name = "" |
| | msg += f"\n=> **{name}** [`{channel}`]" |
| | msg += f"\nTotal {num} channels." |
| | if len(msg) > 4096: |
| | MSG = msg.replace("*", "").replace("`", "") |
| | with io.BytesIO(str.encode(MSG)) as out_file: |
| | out_file.name = "channels.txt" |
| | await event.reply( |
| | "Channels in database", |
| | file=out_file, |
| | force_document=True, |
| | allow_cache=False, |
| | ) |
| | await x.delete() |
| | else: |
| | await x.edit(msg) |
| |
|
| |
|
| | @ultroid_cmd(pattern="adest (.*)") |
| | async def destination(e): |
| | if x := e.pattern_match.group(1).strip(): |
| | try: |
| | y = await e.client.parse_id(x) |
| | except Exception as er: |
| | LOGS.exception(er) |
| | return |
| | else: |
| | y = e.chat_id |
| | if not DestiM.contains(y): |
| | DestiM.add(y) |
| | await e.eor("Destination added succesfully") |
| | else: |
| | await e.eor("Destination channel already added") |
| |
|
| |
|
| | @ultroid_cmd(pattern="ddest( (.*)|$)") |
| | async def dd(event): |
| | chat_id = event.pattern_match.group(1).strip() |
| | x = await event.eor(get_string("com_1")) |
| | if chat_id == "all": |
| | await x.edit(get_string("bd_8")) |
| | udB.del_key("CH_DESTINATION") |
| | await x.edit("Destinations database cleared.") |
| | return |
| | if chat_id: |
| | try: |
| | y = await event.client.parse_id(chat_id) |
| | except Exception as er: |
| | LOGS.exception(er) |
| | return |
| | else: |
| | y = event.chat_id |
| | if DestiM.contains(y): |
| | DestiM.remove(y) |
| | await eor(x, "Destination removed from database") |
| | else: |
| | await eor(x, "Destination channel is already removed from database. ", time=5) |
| |
|
| |
|
| | @ultroid_cmd(pattern="listdest") |
| | async def list_all(event): |
| | ultroid_bot = event.client |
| | x = await event.eor(get_string("com_1")) |
| | channels = DestiM.get() |
| | num = len(channels) |
| | if not num: |
| | return await eor(x, "No chats were added.", time=5) |
| | msg = get_string("cha_7") |
| | for channel in channels: |
| | name = "" |
| | try: |
| | name = get_display_name(await ultroid_bot.get_entity(int(channel))) |
| | except BaseException: |
| | name = "" |
| | msg += f"\n=> **{name}** [`{channel}`]" |
| | msg += f"\nTotal {num} channels." |
| | if len(msg) > 4096: |
| | MSG = msg.replace("*", "").replace("`", "") |
| | with io.BytesIO(str.encode(MSG)) as out_file: |
| | out_file.name = "channels.txt" |
| | await ultroid_bot.send_file( |
| | event.chat_id, |
| | out_file, |
| | force_document=True, |
| | allow_cache=False, |
| | caption="Destination channels in database", |
| | reply_to=event, |
| | ) |
| | await x.delete() |
| | else: |
| | await x.edit(msg) |
| |
|
| |
|
| | if udB.get_key("AUTOPOST"): |
| | ultroid_bot.add_handler(autopost_func, events.NewMessage()) |
| |
|
