CustomModules/get_key.py at main · FoxUserbot/CustomModules · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
import asyncio

from pyrogram import Client
from command import fox_command, fox_sudo, who_message , get_text
import base64
import os

from requirements_installer import install_library

install_library('requests -U')
import requests

headers = {
    "User-Agent": "Happ/3.9.1",
}

LANGUAGES = {
    "en": {
        "need_link": "<b><emoji id='5210952531676504517'>❌</emoji> Give me a subscription link!</b>",
        "searching": "<b><emoji id='5264727218734524899'>🔄</emoji> Searching subscription...</b>",
        "decrypting": "<b><emoji id='5264727218734524899'>🔄</emoji> Decrypting happ:// link...</b>",
        "empty_response": "<b><emoji id='5210952531676504517'>❌</emoji> Empty response from the link.</b>",
        "decrypt_fail": "<b><emoji id='5210952531676504517'>❌</emoji> Failed to decrypt happ:// link.</b>",
        "fetch_decode_fail": "<b><emoji id='5210952531676504517'>❌</emoji> Failed to fetch or decode subscription.</b>",
        "caption": "<emoji id='5267392860122006833'>📝</emoji> | FoxUserbot",
    },
    "ru": {
        "need_link": "<b><emoji id='5210952531676504517'>❌</emoji> Дай ссылку на подписку!</b>",
        "searching": "<b><emoji id='5264727218734524899'>🔄</emoji> Ищу подписку...</b>",
        "decrypting": "<b><emoji id='5264727218734524899'>🔄</emoji> Расшифровываю happ:// ссылку...</b>",
        "empty_response": "<b><emoji id='5210952531676504517'>❌</emoji> Пустой ответ по ссылке.</b>",
        "decrypt_fail": "<b><emoji id='5210952531676504517'>❌</emoji> Не удалось расшифровать happ:// ссылку.</b>",
        "fetch_decode_fail": "<b><emoji id='5210952531676504517'>❌</emoji> Не удалось получить или декодировать подписку.</b>",
        "caption": "<emoji id='5267392860122006833'>📝</emoji> Лови файл",
    },
    "ua": {
        "need_link": "<b><emoji id='5210952531676504517'>❌</emoji> Дай посилання на підписку!</b>",
        "searching": "<b><emoji id='5264727218734524899'>🔄</emoji> Шукаю підписку...</b>",
        "decrypting": "<b><emoji id='5264727218734524899'>🔄</emoji> Розшифровую happ:// посилання...</b>",
        "empty_response": "<b><emoji id='5210952531676504517'>❌</emoji> Порожня відповідь за посиланням.</b>",
        "decrypt_fail": "<b><emoji id='5210952531676504517'>❌</emoji> Не вдалося розшифрувати happ:// посилання.</b>",
        "fetch_decode_fail": "<b><emoji id='5210952531676504517'>❌</emoji> Не вдалося отримати або декодувати підписку.</b>",
        "caption": "<emoji id='5267392860122006833'>📝</emoji> Лови файл",
    }
}


@Client.on_message(fox_command("get_keys", "GetKeys", os.path.basename(__file__), "[link to sub]") & fox_sudo())
async def get_config(client, message):
    message = await who_message(client, message)
    args = (message.text or "").split(maxsplit=1)
    arg = args[1].strip() if len(args) > 1 else None
    if not arg:
        await message.edit(get_text("get_keys", "need_link", LANGUAGES=LANGUAGES))
        return
    await message.edit(get_text("get_keys", "searching", LANGUAGES=LANGUAGES))

    if arg.startswith("happ://crypt"):
        await message.edit(get_text("get_keys", "decrypting", LANGUAGES=LANGUAGES))
        try:
            unhapp_headers = {"Content-Type": "application/json"}
            resp = await asyncio.to_thread(
                requests.post,
                "https://unhapp.xyz/api.php",
                headers=unhapp_headers,
                json={"url": arg},
                timeout=30,
            )
            resp.raise_for_status()
            decrypted = (resp.text or "").strip()
            if not decrypted.startswith("http"):
                await message.edit(get_text("get_keys", "decrypt_fail", LANGUAGES=LANGUAGES))
                return
            arg = decrypted
            await message.edit(get_text("get_keys", "searching", LANGUAGES=LANGUAGES))
        except Exception:
            await message.edit(get_text("get_keys", "decrypt_fail", LANGUAGES=LANGUAGES))
            return

    try:
        req = await asyncio.to_thread(requests.get, arg, headers=headers, timeout=30)
        req.raise_for_status()
        ans = (req.text or "").strip()
        if not ans:
            await message.edit(get_text("get_keys", "empty_response", LANGUAGES=LANGUAGES))
            return

        padded = ans + ("=" * (-len(ans) % 4))
        decoded = base64.b64decode(padded).decode("utf-8", errors="replace")
    except Exception:
        await message.edit(get_text("get_keys", "fetch_decode_fail", LANGUAGES=LANGUAGES))
        return
    file_path = 'temp/keys.txt'
    with open(file_path, 'w', encoding='utf-8') as file:
        file.write(decoded)

    await client.send_document(message.chat.id, file_path, caption=get_text("get_keys", "caption", LANGUAGES=LANGUAGES), message_thread_id=message.message_thread_id)
    try:
        os.remove(file_path)
    except OSError:
        pass