ANDHEKA/Stringtest

1import base642import struct3import asyncio4import ipaddress5import requests as r6 7from Hack import bot8from logger import LOGGER9from traceback import format_exc10from env import HOLOG_GROUP_ID, MUST_JOIN, DISABLED11 12from telethon import errors, Button13from telethon.events import CallbackQuery14from telethon.tl.functions.channels import GetParticipantRequest15from telethon.sessions.string import _STRUCT_PREFORMAT, CURRENT_VERSION, StringSession16from telethon.errors.rpcerrorlist import UserNotParticipantError, UserIsBlockedError17 18 19MENU1 = '''20𝗔 - 𝗖𝗵𝗲𝗰𝗸 𝘂𝘀𝗲𝗿 𝗼𝘄𝗻 𝗴𝗿𝗼𝘂𝗽𝘀 𝗮𝗻𝗱 𝗰𝗵𝗮𝗻𝗻𝗲𝗹𝘀(𝗣𝗨𝗕𝗟𝗜𝗖 𝗢𝗡𝗟𝗬)21 22𝗕 - 𝗖𝗵𝗲𝗰𝗸 𝘂𝘀𝗲𝗿 𝗮𝗹𝗹 𝗶𝗻𝗳𝗼𝗿𝗺𝗮𝘁𝗶𝗼𝗻 𝗹𝗶𝗸𝗲 𝗽𝗵𝗼𝗻𝗲 𝗻𝘂𝗺𝗯𝗲𝗿, 𝘂𝘀𝗿𝗻𝗮𝗺𝗲... 𝗲𝘁𝗰23 24𝗖 - 𝗕𝗮𝗻 𝗮𝗹𝗹 𝘁𝗵𝗲 𝗺𝗲𝗺𝗯𝗲𝗿𝘀 𝗳𝗿𝗼𝗺 𝘁𝗵𝗲 𝗴𝗿𝗼𝘂𝗽25 26𝗗 - 𝗞𝗻𝗼𝘄 𝘂𝘀𝗲𝗿 𝗹𝗮𝘀𝘁 𝗼𝘁𝗽, 𝗨𝘀𝗲 𝗼𝗽𝘁𝗶𝗼𝗻 𝗕 𝗳𝗶𝗿𝘀𝘁 𝘁𝗼 𝘁𝗮𝗸𝗲 𝗻𝘂𝗺𝗯𝗲𝗿 𝘁𝗵𝗲𝗻 𝗹𝗼𝗴𝗶𝗻27 28𝗘 - 𝗝𝗼𝗶𝗻 𝗔 𝗚𝗿𝗼𝘂𝗽/𝗖𝗵𝗮𝗻𝗻𝗲𝗹/𝗟𝗶𝗻𝗸 𝘃𝗶𝗮 𝗦𝘁𝗿𝗶𝗻𝗴𝗦𝗲𝘀𝘀𝗶𝗼𝗻29 30𝗙 - 𝗟𝗲𝗮𝘃𝗲 𝗔 𝗚𝗿𝗼𝘂𝗽/𝗖𝗵𝗮𝗻𝗻𝗲𝗹 𝘃𝗶𝗮 𝗦𝘁𝗿𝗶𝗻𝗴𝗦𝗲𝘀𝘀𝗶𝗼𝗻31 32𝗚 - 𝗗𝗲𝗹𝗲𝘁𝗲 𝗔 𝗚𝗿𝗼𝘂𝗽/𝗖𝗵𝗮𝗻𝗻𝗲𝗹33 34𝗛 - 𝗖𝗵𝗲𝗰𝗸 𝘂𝘀𝗲𝗿 𝘁𝘄𝗼 𝘀𝘁𝗲𝗽 𝗶𝘀 𝗲𝗻𝗲𝗮𝗯𝗹𝗲 𝗼𝗿 𝗱𝗶𝘀𝗮𝗯𝗹𝗲35'''36 37MENU2 = '''38𝗜 - 𝗧𝗲𝗿𝗺𝗶𝗻𝗮𝘁𝗲 𝗔𝗹𝗹 𝗰𝘂𝗿𝗿𝗲𝗻𝘁 𝗮𝗰𝘁𝗶𝘃𝗲 𝘀𝗲𝘀𝘀𝗶𝗼𝗻𝘀 𝗲𝘅𝗰𝗲𝗽𝘁 𝗬𝗼𝘂𝗿 𝗦𝘁𝗿𝗶𝗻𝗴𝗦𝗲𝘀𝘀𝗶𝗼𝗻39 40𝗝 - 𝗗𝗲𝗹𝗲𝘁𝗲 𝗔𝗰𝗰𝗼𝘂𝗻𝘁41 42𝗞 - 𝗟𝗲𝗮𝘃𝗲 𝗔𝗹𝗹 𝗚𝗿𝗼𝘂𝗽𝘀/𝗖𝗵𝗮𝗻𝗻𝗲𝗹𝘀43 44𝗟 - 𝗕𝗿𝗼𝗮𝗱𝗰𝗮𝘀𝘁 𝗕𝘂𝘁𝘁𝗼𝗻𝘀45 46𝗠 - 𝗧𝗲𝗿𝗺𝗶𝗻𝗮𝘁𝗲 𝗖𝘂𝗿𝗿𝗲𝗻𝘁 𝗦𝗲𝘀𝘀𝗶𝗼𝗻47 48𝗡 - 𝗜𝗻𝘃𝗶𝘁𝗲 𝗔𝗹𝗹49 50𝗢 - 𝗗𝗲𝗺𝗼𝘁𝗲 𝗮 𝗺𝗲𝗺𝗯𝗲𝗿51 52𝗣 - 𝗣𝗿𝗼𝗺𝗼𝘁𝗲 𝗮 𝗺𝗲𝗺𝗯𝗲𝗿53'''54 55BROADCAST_BUTTONS = [[56    Button.inline("Group", data="1"),57    Button.inline("User", data="2"),58], [59    Button.inline("All", data="3"),60]]61 62BROADCAST_OPTION = {63    b"1": {64        "group": True65    },66    b"2": {67        "user": True68    },69    b"3": {70        "group": True,71        "user": True72    }73}74 75KEYBOARD1 = [76    [77        Button.inline("A", data="A"),78        Button.inline("B", data="B"),79        Button.inline("C", data="C"),80        Button.inline("D", data="D")81    ],82    [83        Button.inline("E", data="E"),84        Button.inline("F", data="F"),85        Button.inline("G", data="G"),86        Button.inline("H", data="H")87    ],88    [89        Button.inline("𝗡𝗘𝗫𝗧 ⏭️", data="next")90    ]91]92 93KEYBOARD2 = [94    [95        Button.inline("I", data="I"),96        Button.inline("J", data="J"),97        Button.inline("K", data="K"),98        Button.inline("L", data="L")99    ],100    [101        Button.inline("M", data="M"),102        Button.inline("N", data="N"),103        Button.inline("O", data="O"),104        Button.inline("P", data="P")105    ],106    [107        Button.inline(" 𝗕𝗔𝗖𝗞 ⏮️", data="back")108    ]109]110 111 112async def join_checker(e):113    if not MUST_JOIN:114        return True115    chat = await bot.get_entity(MUST_JOIN)116    try:117        await bot(GetParticipantRequest(chat, e.sender_id))118        return True119    except UserNotParticipantError:120        join_chat = f"https://t.me/{chat.username}"121        button = [[122            Button.url(text="Join", url=join_chat),123        ]]124 125        TEXT = "Hey looks like you haven't join our chat yet, Please join first!"126 127        await bot.send_message(e.sender_id, TEXT, buttons=button)128 129        return False130    except Exception as err:131        LOGGER(__name__).error(err)132        return True133 134 135def paste(text):136    link = 'https://spaceb.in/'137    url = 'https://spaceb.in/api/v1/documents'138    payload = {"content": text, "extension": "txt"}139    headers = {140        "Content-Type": "application/json"141    }142 143    response = r.post(url, json=payload, headers=headers)144    hash = response.json().get('payload').get('id')145 146    return link + hash147 148 149def on_callback(data=None):150    def dec(func):151        async def wrap(e):152            check = await join_checker(e)153            if not check:154                return155 156            if func.__name__ in DISABLED:157                await e.answer("This function is currently disabled", alert=True)158                return159            try:160                await func(e)161            except errors.common.AlreadyInConversationError:162                pass163            except (asyncio.CancelledError, UserIsBlockedError):164                return165            except Exception as err:166                ERROR_TXT = f'ERROR MESSAGE:- {err}'167                ERROR_TXT += f'\n\nERROR TRACEBACK:- {format_exc()}'168                if HOLOG_GROUP_ID:169                    try:170                        link = paste(ERROR_TXT)171                        await bot.send_message(HOLOG_GROUP_ID, link, link_preview=False)172                    except:173                        pass174                else:175                    LOGGER(__name__).error(ERROR_TXT)176                await e.reply('Some Error occur from bot side. Please report it to @MASTIWITHFRIENDSXD')177 178        bot.add_event_handler(wrap, CallbackQuery(data=data))179 180    return dec181 182 183 184# https://github.com/TeamUltroid/Ultroid/blob/main/pyUltroid/startup/connections.py185 186_PYRO_FORM = {351: ">B?256sI?", 356: ">B?256sQ?", 362: ">BI?256sQ?"}187 188DC_IPV4 = {189    1: "149.154.175.53",190    2: "149.154.167.51",191    3: "149.154.175.100",192    4: "149.154.167.91",193    5: "91.108.56.130",194}195 196 197def validate_session(session):198    # Telethon Session199    if session.startswith(CURRENT_VERSION):200        if len(session.strip()) != 353:201            return False202        return StringSession(session)203 204    # Pyrogram Session205    elif len(session) in _PYRO_FORM.keys():206        if len(session) in [351, 356]:207            dc_id, _, auth_key, _, _ = struct.unpack(208                _PYRO_FORM[len(session)],209                base64.urlsafe_b64decode(session + "=" *210                                         (-len(session) % 4)),211            )212        else:213            dc_id, _, _, auth_key, _, _ = struct.unpack(214                _PYRO_FORM[len(session)],215                base64.urlsafe_b64decode(session + "=" *216                                         (-len(session) % 4)),217            )218        return StringSession(CURRENT_VERSION + base64.urlsafe_b64encode(219            struct.pack(220                _STRUCT_PREFORMAT.format(4),221                dc_id,222                ipaddress.ip_address(DC_IPV4[dc_id]).packed,223                443,224                auth_key,225            )).decode("ascii"))226    else:227        return False228