Upload 6 files

Zaid/helpers/__init__.py

@@ -0,0 +1 @@
+

Zaid/helpers/chattitle.py

@@ -0,0 +1,54 @@
+async def CHAT_TITLE(ctitle):
+    string = ctitle
+    font1 = list("𝔄𝔅ℭ𝔇𝔈𝔉𝔊ℌℑ𝔍𝔎𝔏𝔐𝔑𝔒𝔓𝔔ℜ𝔖𝔗𝔘𝔙𝔚𝔛𝔜ℨ")
+    font2 = list("𝕬𝕭𝕮𝕯𝕰𝕱𝕲𝕳𝕴𝕵𝕶𝕷𝕸𝕹𝕺𝕻𝕼𝕽𝕾𝕿𝖀𝖁𝖂𝖃𝖄𝖅")
+    font3 = list("𝓐𝓑𝓒𝓓𝓔𝓕𝓖𝓗𝓘𝓙𝓚𝓛𝓜𝓝𝓞𝓟𝓠𝓡𝓢𝓣𝓤𝓥𝓦𝓧𝓨𝓩")
+    font4 = list("𝒜𝐵𝒞𝒟𝐸𝐹𝒢𝐻𝐼𝒥𝒦𝐿𝑀𝒩𝒪𝒫𝒬𝑅𝒮𝒯𝒰𝒱𝒲𝒳𝒴𝒵")
+    font5 = list("𝔸𝔹ℂ𝔻𝔼𝔽𝔾ℍ𝕀𝕁𝕂𝕃𝕄ℕ𝕆ℙℚℝ𝕊𝕋𝕌𝕍𝕎𝕏𝕐ℤ")
+    font6 = list("ＡＢＣＤＥＦＧＨＩＪＫＬＭＮＯＰＱＲＳＴＵＶＷＸＹＺ")
+    font26 = list("𝐀𝐁𝐂𝐃𝐄𝐅𝐆𝐇𝐈𝐉𝐊𝐋𝐌𝐍𝐎𝐏𝐐𝐑𝐒𝐓𝐔𝐕𝐖𝐗𝐘𝐙")
+    font27 = list("𝗔𝗕𝗖𝗗𝗘𝗙𝗚𝗛𝗜𝗝𝗞𝗟𝗠𝗡𝗢𝗣𝗤𝗥𝗦𝗧𝗨𝗩𝗪𝗫𝗬𝗭")
+    font28 = list("𝘈𝘉𝘊𝘋𝘌𝘍𝘎𝘏𝘐𝘑𝘒𝘓𝘔𝘕𝘖𝘗𝘘𝘙𝘚𝘛𝘜𝘝𝘞𝘟𝘠𝘡")
+    font29 = list("𝘼𝘽𝘾𝘿𝙀𝙁𝙂𝙃𝙄𝙅𝙆𝙇𝙈𝙉𝙊𝙋𝙌𝙍𝙎𝙏𝙐𝙑𝙒𝙓𝙔𝙕")
+    font30 = list("𝙰𝙱𝙲𝙳𝙴𝙵𝙶𝙷𝙸𝙹𝙺𝙻𝙼𝙽𝙾𝙿𝚀𝚁𝚂𝚃𝚄𝚅𝚆𝚇𝚈𝚉")
+    font1L = list("𝔞𝔟𝔠𝔡𝔢𝔣𝔤𝔥𝔦𝔧𝔨𝔩𝔪𝔫𝔬𝔭𝔮𝔯𝔰𝔱𝔲𝔳𝔴𝔵𝔶𝔷")
+    font2L = list("𝖆𝖇𝖈𝖉𝖊𝖋𝖌𝖍𝖎𝖏𝖐𝖑𝖒𝖓𝖔𝖕𝖖𝖗𝖘𝖙𝖚𝖛𝖜𝖝𝖞𝖟")
+    font3L = list("𝓪𝓫𝓬𝓭𝓮𝓯𝓰𝓱𝓲𝓳𝓴𝓵𝓶𝓷𝓸𝓹𝓺𝓻𝓼𝓽𝓾𝓿𝔀𝔁𝔂𝔃")
+    font4L = list("𝒶𝒷𝒸𝒹𝑒𝒻𝑔𝒽𝒾𝒿𝓀𝓁𝓂𝓃𝑜𝓅𝓆𝓇𝓈𝓉𝓊𝓋𝓌𝓍𝓎𝓏")
+    font5L = list("𝕒𝕓𝕔𝕕𝕖𝕗𝕘𝕙𝕚𝕛𝕜𝕝𝕞𝕟𝕠𝕡𝕢𝕣𝕤𝕥𝕦𝕧𝕨𝕩𝕪𝕫")
+    font6L = list("ａｂｃｄｅｆｇｈｉｊｋｌｍｎｏｐｑｒｓｔｕｖｗｘｙｚ")
+    font27L = list("𝐚𝐛𝐜𝐝𝐞𝐟𝐠𝐡𝐢𝐣𝐤𝐥𝐦𝐧𝐨𝐩𝐪𝐫𝐬𝐭𝐮𝐯𝐰𝐱𝐲𝐳")
+    font28L = list("𝗮𝗯𝗰𝗱𝗲𝗳𝗴𝗵𝗶𝗷𝗸𝗹𝗺𝗻𝗼𝗽𝗾𝗿𝘀𝘁𝘂𝘃𝘄𝘅𝘆𝘇")
+    font29L = list("𝘢𝘣𝘤𝘥𝘦𝘧𝘨𝘩𝘪𝘫𝘬𝘭𝘮𝘯𝘰𝘱𝘲𝘳𝘴𝘵𝘶𝘷𝘸𝘹𝘺𝘻")
+    font30L = list("𝙖𝙗𝙘𝙙𝙚𝙛𝙜𝙝𝙞𝙟𝙠𝙡𝙢𝙣𝙤𝙥𝙦𝙧𝙨𝙩𝙪𝙫𝙬𝙭𝙮𝙯")
+    font31L = list("𝚊𝚋𝚌𝚍𝚎𝚏𝚐𝚑𝚒𝚓𝚔𝚕𝚖𝚗𝚘𝚙𝚚𝚛𝚜𝚝𝚞𝚟𝚠𝚡𝚢𝚣")
+    normal = list("ABCDEFGHIJKLMNOPQRSTUVWXYZ")
+    normalL = list("abcdefghijklmnopqrstuvwxyz")
+    # small = list("ᴀʙᴄᴅᴇғɢʜɪᴊᴋʟᴍɴᴏᴘʀsᴛᴜᴠᴡxʏᴢ")
+    cout = 0
+    for XCB in font1:
+        # string = string.replace(small[cout], normal[cout])
+        string = string.replace(font1[cout], normal[cout])
+        string = string.replace(font2[cout], normal[cout])
+        string = string.replace(font3[cout], normal[cout])
+        string = string.replace(font4[cout], normal[cout])
+        string = string.replace(font5[cout], normal[cout])
+        string = string.replace(font6[cout], normal[cout])
+        string = string.replace(font26[cout], normal[cout])
+        string = string.replace(font27[cout], normal[cout])
+        string = string.replace(font28[cout], normal[cout])
+        string = string.replace(font29[cout], normal[cout])
+        string = string.replace(font30[cout], normal[cout])
+        string = string.replace(font1L[cout], normalL[cout])
+        string = string.replace(font2L[cout], normalL[cout])
+        string = string.replace(font3L[cout], normalL[cout])
+        string = string.replace(font4L[cout], normalL[cout])
+        string = string.replace(font5L[cout], normalL[cout])
+        string = string.replace(font6L[cout], normalL[cout])
+        string = string.replace(font27L[cout], normalL[cout])
+        string = string.replace(font28L[cout], normalL[cout])
+        string = string.replace(font29L[cout], normalL[cout])
+        string = string.replace(font30L[cout], normalL[cout])
+        string = string.replace(font31L[cout], normalL[cout])
+        cout += 1
+    return string

Zaid/helpers/joiner.py

@@ -0,0 +1,49 @@
+from typing import *
+import random
+from typing import Dict, List, Union
+
+from Zaid import *
+from telethon import *
+from telethon.errors.rpcerrorlist import (
+    UserAlreadyParticipantError,
+    UserNotParticipantError
+)
+from telethon.tl.types import PeerChannel,InputChannel
+from telethon.tl.functions.channels import *
+from telethon.tl.functions.channels import GetParticipantsRequest
+from telethon.tl.types import ChannelParticipantsSearch
+import telethon
+from telethon.tl import functions
+from telethon.tl.functions.channels import LeaveChannelRequest
+from telethon.tl.functions.messages import ImportChatInviteRequest
+from telethon.tl.functions.channels import LeaveChannelRequest
+from telethon.tl.functions.messages import ImportChatInviteRequest
+from telethon.tl.functions.messages import ExportChatInviteRequest
+
+
+def AssistantAdd(mystic):
+    async def wrapper(event):
+        try:
+            permissions = await event.client.get_permissions(int(event.chat_id), int(ASSISTANT_ID))
+        except UserNotParticipantError:
+            if event.is_group:
+                try:
+                    link = await event.client(ExportChatInviteRequest(event.chat_id))
+                    invitelinkk = link.link
+                    invitelink = invitelinkk.replace(
+                        "https://t.me/+", ""
+                    )
+                    await client(ImportChatInviteRequest(invitelink))
+                    await event.reply(
+                        f"Joined Successfully",
+                    )
+                except UserAlreadyParticipantError:
+                    pass
+                except Exception as e:
+                    await event.reply(
+                        f"__Assistant Failed To Join__\n\n**Reason**: {e}"
+                    )
+                    return
+        return await mystic(event)
+
+    return wrapper

Zaid/helpers/queues.py

@@ -0,0 +1,40 @@
+QUEUE = {}
+
+active = []
+
+async def get_active_chats() -> list:
+    return active
+
+
+def add_to_queue(chat_id, songname, link, ref, type, quality):
+    if chat_id in QUEUE:
+        chat_queue = QUEUE[chat_id]
+        chat_queue.append([songname, link, ref, type, quality])
+        return int(len(chat_queue) - 1)
+    if chat_id not in active:
+        active.append(chat_id)
+
+    QUEUE[chat_id] = [[songname, link, ref, type, quality]]
+
+
+def get_queue(chat_id):
+    if chat_id in QUEUE:
+        return QUEUE[chat_id]
+    return 0
+
+
+def pop_an_item(chat_id):
+    if chat_id not in QUEUE:
+        return 0
+    chat_queue = QUEUE[chat_id]
+    chat_queue.pop(0)
+    return 1
+
+
+def clear_queue(chat_id: int):
+    if chat_id not in QUEUE:
+        return 0
+    QUEUE.pop(chat_id)
+    if chat_id in active:
+        active.remove(chat_id)
+    return 1

Zaid/helpers/thumbnail.py

@@ -0,0 +1,138 @@
+import os
+import re
+import textwrap
+ 
+import random
+import aiofiles
+import aiohttp
+from PIL import Image, ImageDraw, ImageEnhance, ImageFilter, ImageFont, ImageOps, ImageChops
+from youtubesearchpython.__future__ import VideosSearch
+ 
+MUSIC_BOT_NAME = "Telethon Music"
+YOUTUBE_IMG_URL = "https://telegra.ph/file/95d96663b73dbf278f28c.jpg"
+files = [] 
+
+for filename in os.listdir("./thumbnail"): 
+     if filename.endswith("png"): 
+         files.append(filename[:-4])
+ 
+def changeImageSize(maxWidth, maxHeight, image):
+    widthRatio = maxWidth / image.size[0]
+    heightRatio = maxHeight / image.size[1]
+    newWidth = int(widthRatio * image.size[0])
+    newHeight = int(heightRatio * image.size[1])
+    newImage = image.resize((newWidth, newHeight))
+    return newImage
+ 
+ 
+def add_corners(im):
+    bigsize = (im.size[0] * 3, im.size[1] * 3)
+    mask = Image.new('L', bigsize, 0)
+    ImageDraw.Draw(mask).ellipse((0, 0) + bigsize, fill=255)
+    mask = mask.resize(im.size, Image.ANTIALIAS)
+    mask = ImageChops.darker(mask, im.split()[-1])
+    im.putalpha(mask)
+ 
+ 
+async def gen_thumb(videoid):
+    anime = random.choice(files)
+    if os.path.isfile(f"cache/{videoid}_{anime}.png"):
+        return f"cache/{videoid}_{anime}.png"
+    url = f"https://www.youtube.com/watch?v={videoid}"
+    try:
+        results = VideosSearch(url, limit=1)
+        for result in (await results.next())["result"]:
+            try:
+                title = result["title"]
+                title = re.sub("\W+", " ", title)
+                title = title.title()
+            except:
+                title = "Unsupported Title"
+            try:
+                duration = result["duration"]
+            except:
+                duration = "Unknown"
+            thumbnail = result["thumbnails"][0]["url"].split("?")[0]
+            try:
+                views = result["viewCount"]["short"]
+            except:
+                views = "Unknown Views"
+            try:
+                channel = result["channel"]["name"]
+            except:
+                channel = "Unknown Channel"
+ 
+        async with aiohttp.ClientSession() as session:
+            async with session.get(thumbnail) as resp:
+                if resp.status == 200:
+                    f = await aiofiles.open(f"cache/thumb{videoid}.png", mode="wb")
+                    await f.write(await resp.read())
+                    await f.close()
+ 
+        
+ 
+        youtube = Image.open(f"cache/thumb{videoid}.png")
+        bg = Image.open(f"thumbnail/{anime}.png")
+        image1 = changeImageSize(1280, 720, youtube)
+        image2 = image1.convert("RGBA")
+        background = image2.filter(filter=ImageFilter.BoxBlur(30))
+        enhancer = ImageEnhance.Brightness(background)
+        background = enhancer.enhance(0.6)
+        cir = Image.open(f"thumbnail/IMG_20221129_201846_195.png") 
+        image3 = changeImageSize(1280, 720, bg)
+        circle = changeImageSize(1280, 720, cir)
+        image5 = image3.convert("RGBA")
+        Image.alpha_composite(background, image5).save(f"cache/temp{videoid}.png")
+ 
+        Xcenter = youtube.width / 2
+        Ycenter = youtube.height / 2
+        x1 = Xcenter - 250
+        y1 = Ycenter - 250
+        x2 = Xcenter + 250
+        y2 = Ycenter + 250
+        logo = youtube.crop((x1, y1, x2, y2))
+        logo.thumbnail((520, 520), Image.ANTIALIAS)
+        logo.save(f"cache/chop{videoid}.png")
+        if not os.path.isfile(f"cache/cropped{videoid}.png"):
+            im = Image.open(f"cache/chop{videoid}.png").convert('RGBA')
+            add_corners(im)
+            im.save(f"cache/cropped{videoid}.png")
+ 
+        crop_img = Image.open(f"cache/cropped{videoid}.png")
+        logo = crop_img.convert("RGBA")
+        logo.thumbnail((365, 365), Image.ANTIALIAS)
+        width = int((1280 - 365)/ 2)
+        background = Image.open(f"cache/temp{videoid}.png")
+        background.paste(logo, (width + 2, 134), mask=logo)
+        background.paste(circle, mask=circle)
+        draw = ImageDraw.Draw(background)
+        font = ImageFont.truetype("thumbnail/font2.ttf", 45)
+        font2 = ImageFont.truetype("thumbnail/font2.ttf", 70)
+        arial = ImageFont.truetype("thumbnail/font2.ttf", 30)
+        name_font = ImageFont.truetype("thumbnail/font.ttf", 30)
+        para = textwrap.wrap(title, width=32)
+        j = 0
+        try:
+            if para[0]:
+                text_w, text_h = draw.textsize(f"{para[0]}", font=font)
+                draw.text(((1280 - text_w)/2, 530), f"{para[0]}", fill="white", stroke_width=1, stroke_fill="white", font=font)
+            if para[1]:
+                text_w, text_h = draw.textsize(f"{para[1]}", font=font)
+                draw.text(((1280 - text_w)/2, 580), f"{para[1]}", fill="white", stroke_width=1, stroke_fill="white", font=font)
+        except:
+            pass
+        text_w, text_h = draw.textsize(f"Duration: {duration} Mins", font=arial)
+        draw.text(((1280 - text_w)/2, 660), f"Duration: {duration} Mins", fill="white", font=arial)
+ 
+ 
+ 
+        
+        try:
+            os.remove(f"cache/thumb{videoid}.png")
+        except:
+            pass
+        background.save(f"cache/{videoid}_{anime}.png")
+        return f"cache/{videoid}_{anime}.png"
+    except Exception as e:
+        print(e)
+        return YOUTUBE_IMG_URL

Zaid/helpers/yt_dlp.py

@@ -0,0 +1,69 @@
+import re
+import hashlib
+import asyncio
+import shlex
+import os
+from os.path import basename
+import os.path
+from PIL import Image
+from yt_dlp import YoutubeDL
+from typing import Optional, Union
+from Zaid import Zaid as bot
+LOGS = {}
+SUDO_USERS = {}
+
+from telethon.tl.functions.channels import GetParticipantRequest
+from telethon.tl.types import ChannelParticipantAdmin, ChannelParticipantCreator, DocumentAttributeFilename
+
+
+
+
+async def is_admin(chat_id, user_id):
+    req_jo = await bot(GetParticipantRequest(
+        channel=chat_id,
+        user_id=user_id
+    ))
+    chat_participant = req_jo.participant
+    if isinstance(
+            chat_participant,
+            ChannelParticipantCreator) or isinstance(
+            chat_participant,
+            ChannelParticipantAdmin):
+        return True
+    return False
+
+
+
+
+
+# https://github.com/TeamUltroid/pyUltroid/blob/31c271cf4d35ab700e5880e952e54c82046812c2/pyUltroid/functions/helper.py#L154
+
+
+async def bash(cmd):
+    process = await asyncio.create_subprocess_shell(
+        cmd,
+        stdout=asyncio.subprocess.PIPE,
+        stderr=asyncio.subprocess.PIPE,
+    )
+    stdout, stderr = await process.communicate()
+    err = stderr.decode().strip()
+    out = stdout.decode().strip()
+    return out, err
+
+
+ydl_opts = {
+    "format": "best",
+    "geo-bypass": True,
+    "noprogress": True,
+    "user-agent": "Mozilla/5.0 (Linux; Android 7.0; k960n_mt6580_32_n) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.101 Safari/537.36",
+    "extractor-args": "youtube:player_client=all",
+    "nocheckcertificate": True,
+    "outtmpl": "downloads/%(id)s.%(ext)s",
+}
+ydl = YoutubeDL(ydl_opts)
+
+
+def download_lagu(url: str) -> str:
+    info = ydl.extract_info(url, download=False)
+    ydl.download([url])
+    return os.path.join("downloads", f"{info['id']}.{info['ext']}")