Neofetch",
+ }
+
+ @loader.command(
+ ru_doc="- запустить команду neofetch",
+ ua_doc="- запустити команду neofetch",
+ )
+ async def neofetchcmd(self, message):
+ """- run neofetch command"""
+ try:
+ result = subprocess.run(["neofetch", "--stdout"], capture_output=True, text=True)
+ output = result.stdout
+ await utils.answer(message, f"{utils.escape_html(output)}")
+
+ except FileNotFoundError:
+ await utils.answer(message, self.strings("not_installed"))
+
diff --git a/radiocycle/Modules/PicToStories.py b/radiocycle/Modules/PicToStories.py
new file mode 100644
index 0000000..84bbd9a
--- /dev/null
+++ b/radiocycle/Modules/PicToStories.py
@@ -0,0 +1,211 @@
+# =======================================
+# _ __ __ __ _
+# | |/ /___ | \/ | ___ __| |___
+# | ' // _ \ | |\/| |/ _ \ / _` / __|
+# | . \ __/ | | | | (_) | (_| \__ \
+# |_|\_\___| |_| |_|\___/ \__,_|___/
+# @ke_mods
+# =======================================
+#
+# LICENSE: CC BY-ND 4.0 (Attribution-NoDerivatives 4.0 International)
+# --------------------------------------
+# https://creativecommons.org/licenses/by-nd/4.0/legalcode
+# =======================================
+
+# meta developer: @ke_mods
+# requires: pillow
+
+import io
+import asyncio
+
+from telethon import functions, types
+from PIL import Image
+
+from .. import loader, utils
+
+
+@loader.tds
+class PicToStoriesMod(loader.Module):
+ """Grid for stories"""
+
+ strings = {
+ "name": "PicToStories",
+ "no_rep": (
+ "❗️ "
+ "Reply to photo!"
+ ),
+ "work": (
+ "🕔 "
+ "Processing..."
+ ),
+ "done": (
+ "✅ "
+ "Done! Check your profile."
+ ),
+ "err": (
+ "❌ "
+ "Error: {}"
+ ),
+ }
+
+ strings_ru = {
+ "no_rep": (
+ "❗️ "
+ "Реплай на фото!"
+ ),
+ "work": (
+ "🕔 "
+ "Обрабатываю..."
+ ),
+ "done": (
+ "✅ "
+ "Готово! Проверяй профиль."
+ ),
+ "err": (
+ "❌ "
+ "Ошибка: {}"
+ ),
+ }
+
+ def __init__(self):
+ self.config = loader.ModuleConfig(
+ loader.ConfigValue(
+ "period",
+ 48,
+ lambda: "Visibility period in hours",
+ validator=loader.validators.Integer(),
+ ),
+ loader.ConfigValue(
+ "blacklist",
+ [],
+ lambda: "Blacklisted user IDs",
+ validator=loader.validators.Series(loader.validators.Integer()),
+ ),
+ loader.ConfigValue(
+ "cooldown",
+ 0,
+ lambda: "Cooldown between stories in seconds",
+ validator=loader.validators.Integer(minimum=0),
+ ),
+ )
+
+ @loader.command(ru_doc="<реплай на фото> [название альбома] - сделать сетку")
+ async def ptscmd(self, message):
+ """ [album name] - make grid"""
+ args = utils.get_args_raw(message)
+ reply = await message.get_reply_message()
+ if not reply or not reply.media:
+ await utils.answer(message, self.strings("no_rep"))
+ return
+
+ try:
+ image_bytes = await reply.download_media(file=bytes)
+ img = Image.open(io.BytesIO(image_bytes))
+ except Exception as e:
+ await utils.answer(message, self.strings("err").format(e))
+ return
+
+ await utils.answer(message, self.strings("work"))
+
+ w, h = img.size
+ curr_ratio = w / h
+ variants = [
+ (5 / 4, 2),
+ (4 / 5, 3),
+ (3 / 5, 4),
+ (9 / 16, 5)
+ ]
+ best_ratio, rows = min(variants, key=lambda x: abs(curr_ratio - x[0]))
+
+ new_h = int(w / best_ratio)
+ img = img.resize((w, new_h), Image.LANCZOS)
+ w, h = img.size
+
+ parts = []
+ pw, ph = w // 3, h // rows
+ for r in range(rows):
+ for c in range(3):
+ x, y = c * pw, r * ph
+ parts.append(img.crop((x, y, x + pw, y + ph)))
+
+ parts.reverse()
+
+ privacy = [types.InputPrivacyValueAllowAll()]
+ if self.config["blacklist"]:
+ entities = []
+ for uid in self.config["blacklist"]:
+ try:
+ entities.append(await self.client.get_input_entity(uid))
+ except Exception:
+ continue
+ if entities:
+ privacy.append(types.InputPrivacyValueDisallowUsers(users=entities))
+
+ story_ids = []
+ for i, p in enumerate(parts):
+ out = io.BytesIO()
+ p.save(out, "JPEG", quality=95)
+ out.seek(0)
+
+ uploaded_file = await self.client.upload_file(out, file_name="s.jpg")
+ res = await self.client(
+ functions.stories.SendStoryRequest(
+ peer=types.InputPeerSelf(),
+ media=types.InputMediaUploadedPhoto(uploaded_file),
+ privacy_rules=privacy,
+ period=self.config["period"] * 3600,
+ )
+ )
+
+ sid = next(
+ (
+ u.story_id if hasattr(u, "story_id") else u.id
+ for u in res.updates
+ if hasattr(u, "story_id") or hasattr(u, "id")
+ ),
+ None,
+ )
+
+ if sid:
+ story_ids.append(sid)
+
+ if self.config["cooldown"] > 0 and i < len(parts) - 1:
+ await asyncio.sleep(self.config["cooldown"])
+
+ if not story_ids:
+ return
+
+ if args:
+ all_albums = await self.client(
+ functions.stories.GetAlbumsRequest(peer=types.InputPeerSelf(), hash=0)
+ )
+
+ target = next(
+ (a for a in all_albums.albums if getattr(a, 'title', '') == args),
+ None
+ )
+
+ if target:
+ await self.client(
+ functions.stories.UpdateAlbumRequest(
+ peer=types.InputPeerSelf(),
+ album_id=target.album_id,
+ add_stories=story_ids,
+ )
+ )
+ else:
+ await self.client(
+ functions.stories.CreateAlbumRequest(
+ peer=types.InputPeerSelf(),
+ stories=story_ids,
+ title=args,
+ )
+ )
+ else:
+ await self.client(
+ functions.stories.TogglePinnedRequest(
+ peer=types.InputPeerSelf(), id=story_ids, pinned=True
+ )
+ )
+
+ await utils.answer(message, self.strings("done"))
\ No newline at end of file
diff --git a/radiocycle/Modules/SpotifyMod.py b/radiocycle/Modules/SpotifyMod.py
new file mode 100644
index 0000000..7834a05
--- /dev/null
+++ b/radiocycle/Modules/SpotifyMod.py
@@ -0,0 +1 @@
+# License Violation. Original module has GPL-v3 but author of nowhere tried to change it to CC BY-ND 4.0
diff --git a/radiocycle/Modules/UnbanAll.py b/radiocycle/Modules/UnbanAll.py
new file mode 100644
index 0000000..922fc3d
--- /dev/null
+++ b/radiocycle/Modules/UnbanAll.py
@@ -0,0 +1,74 @@
+# =======================================
+# _ __ __ __ _
+# | |/ /___ | \/ | ___ __| |___
+# | ' // _ \ | |\/| |/ _ \ / _` / __|
+# | . \ __/ | | | | (_) | (_| \__ \
+# |_|\_\___| |_| |_|\___/ \__,_|___/
+# @ke_mods
+# =======================================
+#
+# LICENSE: CC BY-ND 4.0 (Attribution-NoDerivatives 4.0 International)
+# --------------------------------------
+# https://creativecommons.org/licenses/by-nd/4.0/legalcode
+# =======================================
+
+# meta developer: @ke_mods
+
+from .. import loader, utils
+from telethon.tl.types import ChatBannedRights
+from telethon.tl.functions.channels import EditBannedRequest
+from telethon.tl.types import ChannelParticipantsKicked
+
+@loader.tds
+class UnbanAllMod(loader.Module):
+ strings = {
+ "name": "UnbanAll",
+ "no_rights": "❌ I don't have administrator rights to remove restrictions.",
+ "success": "✅ All banned chat members have been unbanned.",
+ "unban_in_process": "👀 Unbanning users...",
+ "no_banned": "ℹ️ There are no banned members in this chat.",
+ "error_occured": "💢 An error occurred while unbanning user {}:\n{}",
+ }
+ strings_ru = {
+ "no_rights": "❌ У меня нет прав администратора для снятия ограничений.",
+ "success": "✅ Все забаненные участники чата были разблокированы.",
+ "unban_in_process": "👀 Разбаниваю пользователей...",
+ "no_banned": "ℹ️ В этом чате нет забаненных участников.",
+ "error_occured": "💢 Произошла ошибка при разблокировке пользователя {}:\n{}",
+ }
+
+ @loader.command(ru_doc="- Разбанить всех забаненных пользователей")
+ async def unbanallcmd(self, message):
+ """- Unban all banned users"""
+ chat = await message.get_chat()
+
+ if not chat.admin_rights and not chat.creator:
+ await utils.answer(message, self.strings("no_rights"))
+ return
+
+ await utils.answer(message, self.strings("unban_in_process"))
+
+ no_banned = True
+
+ async for user in self.client.iter_participants(
+ message.chat_id, filter=ChannelParticipantsKicked
+ ):
+
+ no_banned = False
+
+ try:
+ await self.client(EditBannedRequest(
+ message.chat_id,
+ user.id,
+ ChatBannedRights(until_date=0)
+ ))
+
+ except Exception as e:
+ await utils.answer(message, self.strings("error_occured").format(user.id, e))
+ pass
+
+ if no_banned:
+ await utils.answer(message, self.strings("no_banned"))
+ return
+
+ await utils.answer(message, self.strings("success"))
diff --git a/radiocycle/Modules/full.txt b/radiocycle/Modules/full.txt
new file mode 100644
index 0000000..699e87a
--- /dev/null
+++ b/radiocycle/Modules/full.txt
@@ -0,0 +1,7 @@
+Neofetch
+randomanimepic
+SpotifyMod
+UnbanAll
+voicetotext
+LastFm
+PicToStories
diff --git a/radiocycle/Modules/randomanimepic.py b/radiocycle/Modules/randomanimepic.py
new file mode 100644
index 0000000..aa7766b
--- /dev/null
+++ b/radiocycle/Modules/randomanimepic.py
@@ -0,0 +1,65 @@
+# =======================================
+# _ __ __ __ _
+# | |/ /___ | \/ | ___ __| |___
+# | ' // _ \ | |\/| |/ _ \ / _` / __|
+# | . \ __/ | | | | (_) | (_| \__ \
+# |_|\_\___| |_| |_|\___/ \__,_|___/
+# @ke_mods
+# =======================================
+#
+# LICENSE: CC BY-ND 4.0 (Attribution-NoDerivatives 4.0 International)
+# --------------------------------------
+# https://creativecommons.org/licenses/by-nd/4.0/legalcode
+# =======================================
+
+# meta developer: @ke_mods
+
+import requests
+import asyncio
+import logging
+import traceback
+from logging import basicConfig
+from .. import loader, utils
+
+basicConfig(level=logging.INFO)
+logger = logging.getLogger(__name__)
+
+@loader.tds
+class RandomAnimePicMod(loader.Module):
+ strings = {
+ "name": "RandomAnimePic",
+ "img": "✅ Your anime pic\n🔗 URL: {}",
+ "loading": "✨ Loading image...",
+ "error": "🚫 An unexpected error occurred...",
+ }
+
+ strings_ru = {
+ "img": "✅ Ваша аниме-картинка\n🔗 Ссылка: {}",
+ "loading": "✨ Загрузка изображения...",
+ "error": "🚫 Произошла непредвиденная ошибка...",
+ }
+
+ @loader.command(
+ ru_doc="- получить рандомную аниме-картинку 👀"
+ )
+ async def rapiccmd(self, message):
+ """- fetch random anime-pic 👀"""
+
+ await utils.answer(message, self.strings("loading"))
+
+ try:
+ res = requests.get("https://api.nekosia.cat/api/v1/images/cute?count=1")
+ res.raise_for_status()
+ data = res.json()
+ image_url = data['image']['original']['url']
+
+ await asyncio.sleep(2)
+
+ await utils.answer(message, self.strings("img").format(image_url), file=image_url, reply_to=message.reply_to_msg_id)
+
+ except Exception:
+ logger.error("Error fetching random anime pic: %s", traceback.format_exc())
+
+ await utils.answer(message, self.strings("error"))
+
+ await asyncio.sleep(5)
diff --git a/radiocycle/Modules/voicetotext.py b/radiocycle/Modules/voicetotext.py
new file mode 100644
index 0000000..0e4cfd5
--- /dev/null
+++ b/radiocycle/Modules/voicetotext.py
@@ -0,0 +1,77 @@
+# =======================================
+# _ __ __ __ _
+# | |/ /___ | \/ | ___ __| |___
+# | ' // _ \ | |\/| |/ _ \ / _` / __|
+# | . \ __/ | | | | (_) | (_| \__ \
+# |_|\_\___| |_| |_|\___/ \__,_|___/
+# @ke_mods
+# =======================================
+#
+# LICENSE: CC BY-ND 4.0 (Attribution-NoDerivatives 4.0 International)
+# --------------------------------------
+# https://creativecommons.org/licenses/by-nd/4.0/legalcode
+# =======================================
+
+# meta developer: @ke_mods
+# scope: ffmpeg
+# requires: pydub SpeechRecognition
+
+from .. import loader, utils
+import os
+import speech_recognition as sr
+from pydub import AudioSegment
+
+@loader.tds
+class VoiceToTextMod(loader.Module):
+ strings = {
+ "name": "VoiceToText",
+ "process_text": "✨ Recognizing the message text...",
+ "vtt_success": "🔥 Recognized text:\n{}
",
+ "vtt_failure": "🚫 Failed to recognize the message.",
+ "vtt_request_error": "🚫 Error when contacting the recognition service:\n{}",
+ "vtt_invalid": "🚫 Please reply to a voice or video message with the command {}vtt",
+ "vtt_successful": "✅ Text recognized successfully",
+ }
+
+ strings_ru = {
+ "process_text": "✨ Распознаю текст сообщения...",
+ "vtt_success": "🔥 Распознанный текст:\n{}
",
+ "vtt_failure": "🚫 Не удалось распознать сообщение.",
+ "vtt_request_error": "🚫 Ошибка при обращении к сервису распознавания:\n{}",
+ "vtt_invalid": "🚫 Пожалуйста, ответьте на голосовое или видеосообщение командой {}vtt",
+ "vtt_successful": "✅ Текст успешно распознан",
+ }
+
+ @loader.command(
+ ru_doc="- распознает текст из голосового или видеосообщения.",
+ )
+ async def vttcmd(self, message):
+ """- recognizes text from voice or video messages."""
+ reply = await message.get_reply_message()
+
+ if not reply or not (reply.voice or reply.video_note):
+ await utils.answer(message, self.strings["vtt_invalid"].format(self.get_prefix()))
+ return
+
+ msg = await utils.answer(
+ message, self.strings["process_text"], reply_to=message.id
+ )
+
+ media_file = await reply.download_media()
+ wav_file = media_file.replace('.mp4', '.wav') if reply.video_note else media_file.replace('.oga', '.wav')
+
+ try:
+ AudioSegment.from_file(media_file).export(wav_file, format='wav')
+ recognizer = sr.Recognizer()
+ with sr.AudioFile(wav_file) as source:
+ audio_data = recognizer.record(source)
+ try:
+ text = recognizer.recognize_google(audio_data, language='ru-RU')
+ await utils.answer(msg, self.strings["vtt_success"].format(text))
+ except sr.UnknownValueError:
+ await utils.answer(msg, self.strings["vtt_failure"])
+ except sr.RequestError as e:
+ await utils.answer(msg, self.strings["vtt_request_error"].format(e))
+ finally:
+ os.remove(media_file)
+ os.remove(wav_file)
diff --git a/yummy1gay/limoka/yg_quotes.py b/yummy1gay/limoka/yg_quotes.py
index b2f6231..28f89ac 100644
--- a/yummy1gay/limoka/yg_quotes.py
+++ b/yummy1gay/limoka/yg_quotes.py
@@ -1,396 +1,409 @@
-__version__ = (1, 1, 1, 1)
-
-# This file is a part of Hikka Userbot!
-# This product includes software developed by t.me/Fl1yd and t.me/spypm.
-# Based on the "SQuotes" module.
-
-# 🌐 https://github.com/hikariatama/Hikka
-
-# You CAN edit this file without direct permission from the author.
-# You can redistribute this file with any modifications.
-
-# thx to t.me/LyoSU for github.com/LyoSU/quote-api
-
-# meta developer: @yg_modules
-# scope: hikka_only
-# scope: hikka_min 1.6.3
-
-# █▄█ █░█ █▀▄▀█ █▀▄▀█ █▄█ █▀▄▀█ █▀█ █▀▄ █▀
-# ░█░ █▄█ █░▀░█ █░▀░█ ░█░ █░▀░█ █▄█ █▄▀ ▄█
-
-import base64, io, requests, telethon
-from time import gmtime
-from typing import List, Optional, Tuple, Union
-from PIL import Image, ImageDraw
-from telethon.tl import types
-from telethon.extensions import html
-from telethon.tl.patched import Message
-
-from .. import loader, utils
-
-class Dick:
- @staticmethod
- def ents(es: types.TypeMessageEntity) -> List[dict]:
- out: List[dict] = []
- if not es: return out
- for e in es:
- try:
- d = e.to_dict(); t = d.pop("_","").replace("MessageEntity","").lower()
- if not t: continue
- mt = {"bold": "bold","italic": "italic","underline": "underline","strikethrough": "strikethrough",
- "code": "code","pre": "pre","texturl": "text_link","url": "url","email": "email",
- "phone": "phone_number","mention": "mention",
- "mentionname": "text_mention","hashtag": "hashtag","cashtag": "cashtag",
- "botcommand": "bot_command","spoiler": "spoiler","customemoji": "custom_emoji"}.get(t,t)
- it = {"type": mt,"offset": d.get("offset",0),"length": d.get("length",0)}
- if t=="texturl": it["url"]=d.get("url","")
- elif t=="mentionname": it["user"]={"id": d.get("user_id",0)}
- elif t=="customemoji": it["custom_emoji_id"]=str(d.get("document_id",""))
- elif t=="pre": it["language"]=d.get("language","")
- out.append(it)
- except Exception: continue
- return out
-
- @staticmethod
- def dur(s: Union[int,float]) -> str:
- t=gmtime(s); return (f"{t.tm_hour:02d}:" if t.tm_hour>0 else "")+f"{t.tm_min:02d}:{t.tm_sec:02d}"
-
- @staticmethod
- def desc(m: Message, rep: bool=False) -> str:
- return (
- "📷 Фото" if m.photo and rep else
- (m.file.emoji+" Стикер") if m.sticker and rep else
- "📹 Видеосообщение" if m.video_note and rep else
- "📹 Видео" if m.video and rep else
- "🖼 GIF" if m.gif else
- "📊 Опрос" if m.poll else
- "📍 Местоположение" if m.geo else
- "👤 Контакт" if m.contact else
- (f"🎵 Голосовое сообщение: {Dick.dur(m.voice.attributes[0].duration)}" if m.voice else
- (f"🎧 Музыка: {Dick.dur(m.audio.attributes[0].duration)} | {m.audio.attributes[0].performer} - {m.audio.attributes[0].title}" if m.audio else
- (f"💾 Файл: {m.file.name}" if isinstance(m.media, types.MessageMediaDocument) and not Dick.pick(m) else
- (f"{m.media.emoticon} Кость: {m.media.value}" if isinstance(m.media, types.MessageMediaDice) else
- (f"Сервисное сообщение: {m.action.to_dict().get('_')}" if isinstance(m, types.MessageService) else "")))))) #)))
-
- @staticmethod
- def split(name: Optional[str]) -> Tuple[str,str]:
- if not name: return "",""
- p=name.split(); return (p[0], " ".join(p[1:]) if len(p)>1 else "")
-
- @staticmethod
- def pick(m: Message):
- if m and m.media:
- return m.photo or m.sticker or m.video or m.video_note or m.gif or m.web_preview
- return None
-
- @staticmethod
- def wf(b: Optional[bytes]) -> List[int]:
- if not b: return []
- n=(len(b)*8)//5
- if not n: return []
- out: List[int]=[]
- last=n-1
- for i in range(last):
- j=i*5; bi,sh=j//8,j%8
- v=int.from_bytes(b[bi:bi+2],"little") if bi+1>sh)&0b11111)
- j=last*5; bi,sh=j//8,j%8
- v=int.from_bytes(b[bi:bi+2],"little") if bi+1>sh)&0b11111)
- return out
-
- @staticmethod
- async def img(b: bytes, circle: bool=False) -> Optional[str]:
- try:
- im=Image.open(io.BytesIO(b))
- if im.mode!="RGBA": im=im.convert("RGBA")
- if circle:
- size=min(im.size)
- mask=Image.new("L",(size,size),0); ImageDraw.Draw(mask).ellipse((0,0,size,size),fill=255)
- sq=Image.new("RGBA",(size,size),(0,0,0,0))
- off=((size-im.width)//2,(size-im.height)//2); sq.paste(im,off)
- im=Image.composite(sq,Image.new("RGBA",(size,size),(0,0,0,0)),mask)
- o=io.BytesIO(); im.save(o,format="PNG")
- return f"data:image/png;base64,{base64.b64encode(o.getvalue()).decode()}"
- except Exception:
- return None
-
- @staticmethod
- async def stc(b: bytes) -> Optional[str]:
- try:
- im=Image.open(io.BytesIO(b))
- if im.mode not in ("RGBA","LA"): im=im.convert("RGBA")
- elif im.mode=="LA": im=im.convert("RGBA")
- o=io.BytesIO(); im.save(o,format="PNG")
- return f"data:image/png;base64,{base64.b64encode(o.getvalue()).decode()}"
- except Exception:
- return None
-
- @staticmethod
- async def proc(cli, obj, m: Message) -> Optional[dict]:
- try:
- if m.voice:
- for a in m.voice.attributes or []:
- if getattr(a,"voice",False) and hasattr(a,"waveform"):
- return {"voice":{"waveform":Dick.wf(a.waveform)}}
- b: bytes = await cli.download_media(obj, bytes, thumb=-1)
- if not b: return None
- if m.sticker:
- u=await Dick.stc(b); return {"url": u} if u else None
- u=await Dick.img(b, circle=bool(m.video_note))
- return {"url": u} if u else None
- except Exception:
- return None
-
- @staticmethod
- async def ava(cli, uid: int) -> Optional[str]:
- try:
- b=await cli.download_profile_photo(uid, bytes)
- if b: return f"data:image/jpeg;base64,{base64.b64encode(b).decode()}"
- except Exception: pass
- return None
-
- @staticmethod
- async def post(url: str, data: dict):
- try:
- return await utils.run_sync(requests.post, url, json=data, timeout=30)
- except Exception:
- return None
-
-@loader.tds
-class Quotes(loader.Module):
- """Модуль для создания цитат из сообщений"""
-
- strings = {"name": "yg_quotes",
- "no_reply": "🏳️🌈 Нет реплая на сообщение",
- "processing": "🏳️🌈 Обработка…",
- "api_processing": "🏳️🌈 Ожидание ответа API…",
- "api_error": "🏳️🌈 Ошибка API: {}",
- "loading_media": "🏳️🌈 Отправка…",
- "no_args_or_reply": "🏳️🌈 Нет аргументов или реплая",
- "args_error": "🏳️🌈 Ошибка разбора аргументов. Запрос: {}",
- "too_many_messages": "🏳️🌈 Слишком много сообщений. Максимум: {}"}
-
- def __init__(self):
- self.config=loader.ModuleConfig(
- loader.ConfigValue("type","quote",
- lambda:"Тип цитаты",
- validator=loader.validators.Choice(["quote", "stories"])),
- loader.ConfigValue("bg_color","#162330",
- lambda:"Цвет фона цитаты (например, #1a1a1a или red)"),
- loader.ConfigValue("width",512,
- lambda:"Ширина цитаты (px)",
- validator=loader.validators.Integer(minimum=200,maximum=2000)),
- loader.ConfigValue("height",768,
- lambda:"Высота цитаты (px)",
- validator=loader.validators.Integer(minimum=200,maximum=2000)),
- loader.ConfigValue("scale",2,
- lambda:"Масштаб рендера",
- validator=loader.validators.Choice([1, 2, 3])),
- loader.ConfigValue("emoji_brand","apple",
- lambda:"Стиль эмодзи (apple, google, twitter и т.д.)"),
- loader.ConfigValue("max_messages",15,
- lambda:"Максимальное число сообщений в цитате",
- validator=loader.validators.Integer(minimum=1,maximum=50)),
- loader.ConfigValue("endpoint","https://kok.gay/gayotes/generate",
- lambda:"URL API-эндпоинта (можешь поднять локально - github.com/yummy1gay/quote-api)",
- validator=loader.validators.Link()))
-
- async def client_ready(self, client, db):
- self.client=client; self.db=db
-
- async def qcmd(self, m: Message):
- """
- Обычные цитаты:
- • .q — процитировать одно сообщение из реплая
- • .q 2 — процитировать 2 сообщения
- • .q 3 #2d2d2d — 3 сообщения на тёмном фоне
- • .q pink — фон по имени цвета
- • .q !file — отправить как файл (PNG)
- """
- try:
- args=utils.get_args(m); rep=await m.get_reply_message()
- if not rep: return await utils.answer(m,self.strings["no_reply"])
- st=await utils.answer(m,self.strings["processing"])
- doc="!file" in args
- n=next((int(a) for a in args if a.isdigit() and int(a)>0),1)
- bg=next((a for a in args if a!="!file" and not a.isdigit()), self.config["bg_color"])
- if n>self.config["max_messages"]:
- return await utils.answer(st,self.strings["too_many_messages"].format(self.config["max_messages"]))
-
- js=await self.parse(m,n)
- if not js: return await utils.answer(st,self.strings["api_error"].format("Не удалось собрать сообщения"))
-
- pay={"backgroundColor":bg,"width":self.config["width"],"height":self.config["height"],
- "scale":self.config["scale"],"emojiBrand":self.config["emoji_brand"],"messages":js,
- "format": "webp" if not doc else "png", "type": self.config["type"]}
-
- await utils.answer(st,self.strings["api_processing"])
- r=await Dick.post(f"{self.config['endpoint']}.webp",pay)
- if not r or r.status_code!=200:
- try: err=r.json().get("error",f"HTTP {r.status_code}") if r else "Нетворк еррорь"
- except Exception: err=f"HTTP {r.status_code}" if r else "Нетворк еррорь"
- return await utils.answer(st,self.strings["api_error"].format(err))
-
- buf=io.BytesIO(r.content); buf.name="YgQuote"+(".png" if doc else ".webp")
- await utils.answer(st,buf,force_document=doc)
- except Exception as e:
- return await utils.answer(m,f"🏳️🌈 Ошибка: {e}")
-
- async def fqcmd(self, m: Message):
- """
- Фейковые цитаты:
- • .fq <@ или ID> <текст> — цитата от пользователя
- • .fq <текст> — цитата от автора реплая
- • .fq <@/ID> <текст> -r <@/ID> <текст> — с ответом
- • .fq user1 текст; user2 текст — несколько сообщений
- """
- try:
- raw=utils.get_args_html(m); rep=await m.get_reply_message()
- if not (raw or rep): return await utils.answer(m,self.strings["no_args_or_reply"])
- st= await utils.answer(m,self.strings["processing"])
- try: js=await self.fake(raw,rep)
- except (IndexError,ValueError): return await utils.answer(st,self.strings["args_error"].format(m.text))
- if len(js)>self.config["max_messages"]:
- return await utils.answer(st,self.strings["too_many_messages"].format(self.config["max_messages"]))
-
- dickk={"backgroundColor":self.config["bg_color"],"width":self.config["width"],"height":self.config["height"],
- "scale":self.config["scale"],"emojiBrand":self.config["emoji_brand"],"messages":js,
- "format": "webp","type":self.config["type"]}
-
- await utils.answer(st,self.strings["api_processing"])
- r=await Dick.post(f"{self.config['endpoint']}.webp",dickk)
- if not r or r.status_code!=200:
- try: err=r.json().get("error",f"HTTP {r.status_code}") if r else "Нетворк еррорь"
- except Exception: err=f"HTTP {r.status_code}" if r else "Нетворк еррорь"
- return await utils.answer(st,self.strings["api_error"].format(err))
-
- buf=io.BytesIO(r.content); buf.name="YgQuote.webp"
- await utils.answer(st,buf)
- except Exception as e:
- return await utils.answer(m,f"🏳️🌈 Ошибка: {e}")
-
- async def parse(self, trg: Message, n: int) -> Optional[List[dict]]:
- try:
- rep= await trg.get_reply_message()
- lst: List[Message]=[mm async for mm in self.client.iter_messages(trg.chat_id,limit=n,reverse=True,add_offset=1,offset_id=rep.id if rep else None)]
- except Exception:
- return None
-
- out: List[dict]=[]
- for mm in lst:
- try:
- u=await self.who(mm)
- if not u: continue
- name=telethon.utils.get_display_name(u); f,l=Dick.split(name)
- ava=await Dick.ava(self.client,getattr(u,"id",0)) if getattr(u,"id",None) else None
-
- rb=None
- try:
- r=await mm.get_reply_message()
- if r:
- rname=telethon.utils.get_display_name(r.sender)
- rtxt=Dick.desc(r,True)
- if r.raw_text: rtxt=(rtxt+". "+r.raw_text) if rtxt else r.raw_text
- rb={"name":rname,"text":rtxt or "","entities":Dick.ents(r.entities),
- "chatId": r.sender.id if r.sender else mm.chat_id,"from":{"name":rname}}
- except Exception: rb=None
-
- med=None; obj=Dick.pick(mm)
- if obj: med=await Dick.proc(self.client,obj,mm)
-
- txt=mm.raw_text or ""; ad=Dick.desc(mm)
- if ad: txt=f"{txt}\n\n{ad}" if txt else ad
-
- item={"from":{"id":getattr(u,"id", 0),"first_name":getattr(u,"first_name","") or f,"last_name":getattr(u,"last_name","") or l,
- "username":getattr(u,"username",None),"name":name,"photo":{"url":ava} if ava else {}},
- "text":txt,"entities":Dick.ents(mm.entities),"avatar":True}
-
- try:
- if mm.voice:
- a = next((a for a in mm.voice.attributes or []
- if getattr(a, "voice", False) and hasattr(a, "waveform")), None)
- if a: item["voice"] = {"waveform": Dick.wf(a.waveform)}
- except Exception: pass
-
- if med: item["voice" if "voice" in med else "media"] = med.get("voice", med)
-
- es=getattr(u,"emoji_status",None)
- if getattr(es,"document_id",None): item["from"]["emoji_status"]=str(es.document_id)
- if rb: item["replyMessage"]=rb
- out.append(item)
- except Exception: continue
- return out
-
- async def who(self, m: Message):
- try:
- if m.fwd_from:
- if m.fwd_from.from_id:
- pid=m.fwd_from.from_id
- uid=pid.channel_id if isinstance(pid, types.PeerChannel) else pid.user_id
- try: return await self.client.get_entity(uid)
- except Exception: return m.sender
- if m.fwd_from.from_name:
- return types.User(
- id=hash(m.fwd_from.from_name)%2147483647, first_name=m.fwd_from.from_name,
- username=None, phone=None, bot=False, verified=False, restricted=False,
- scam=False, fake=False, premium=False)
- return m.sender
- except Exception:
- return m.sender
-
- async def fake(self, args: str, rep: Optional[Message]) -> List[dict]:
- async def tok(ch: str):
- p=ch.split()
- if not p: return None,""
- who=p[0]; tx=ch.split(maxsplit=1)[1] if len(p)>1 else ""
- try:
- u=await self.client.get_entity(int(who) if who.isdigit() else who)
- return u,tx
- except Exception:
- return None,tx
-
- if rep and not args:
- u=rep.sender; name=telethon.utils.get_display_name(u); f,l=Dick.split(name)
- ava=await Dick.ava(self.client,u.id) if getattr(u,"id",None) else None
- msg={"from":{"id":u.id,"first_name":getattr(u,"first_name","") or f,"last_name":getattr(u,"last_name","") or l,
- "username":getattr(u,"username",None),"name":name,"photo":{"url":ava} if ava else {}},
- "text":"","entities":[], "avatar":True}
- es=getattr(u,"emoji_status",None)
- if getattr(es,"document_id", None): msg["from"]["emoji_status"]=str(es.document_id)
- return [msg]
-
- if rep and args:
- u=rep.sender
- return await self.fake(f"{getattr(u,'id','')} {args}", None)
-
- out: List[dict]=[]
- for part in args.split("; "):
- try:
- rb=None
- if " -r " in part:
- a,b=part.split(" -r ",1); u1,t1=await tok(a); u2,t2=await tok(b)
- else:
- u1,t1=await tok(part); u2,t2=None,None
- if not u1: continue
-
- txt1, ents1 = html.parse(t1) if t1 else ("", [])
-
- name=telethon.utils.get_display_name(u1); f,l=Dick.split(name)
- ava=await Dick.ava(self.client,u1.id)
-
- if u2:
- txt2, ents2 = html.parse(t2) if t2 else ("", [])
- name2=telethon.utils.get_display_name(u2); ava2=await Dick.ava(self.client,u2.id)
- rb={"name":name2,"text":txt2,"entities":Dick.ents(ents2),"chatId":u2.id,"from":{"name":name2,"photo":{"url":ava2} if ava2 else {}}}
-
- msg={"from":{"id":u1.id,"first_name":getattr(u1,"first_name","") or f,"last_name":getattr(u1,"last_name","") or l,
- "username":getattr(u1,"username",None),"name":name,"photo":{"url":ava} if ava else {}},
- "text":txt1,"entities":Dick.ents(ents1), "avatar":True}
-
- es=getattr(u1,"emoji_status",None)
- if getattr(es,"document_id",None): msg["from"]["emoji_status"]=str(es.document_id)
- if rb: msg["replyMessage"]=rb
- out.append(msg)
- except Exception: continue
+__version__ = (1, 2, 0, 0)
+
+# This file is a part of Hikka Userbot!
+# This product includes software developed by t.me/Fl1yd and t.me/spypm.
+# Based on the "SQuotes" module.
+
+# 🌐 https://github.com/hikariatama/Hikka
+
+# You CAN edit this file without direct permission from the author.
+# You can redistribute this file with any modifications.
+
+# thx to t.me/LyoSU for github.com/LyoSU/quote-api
+
+# meta developer: @yg_modules
+# scope: hikka_only
+# scope: hikka_min 1.6.3
+
+# Changelog v1.2:
+# - Added: Proxy for users from RF
+# - Fixed: Correct reply author resolving for forwarded messages
+
+# █▄█ █░█ █▀▄▀█ █▀▄▀█ █▄█ █▀▄▀█ █▀█ █▀▄ █▀
+# ░█░ █▄█ █░▀░█ █░▀░█ ░█░ █░▀░█ █▄█ █▄▀ ▄█
+
+import base64, io, requests, telethon
+from time import gmtime
+from typing import List, Optional, Tuple, Union
+from PIL import Image, ImageDraw
+from telethon.tl import types
+from telethon.extensions import html
+from telethon.tl.patched import Message
+
+from .. import loader, utils
+
+class Dick:
+ @staticmethod
+ def ents(es: types.TypeMessageEntity) -> List[dict]:
+ out: List[dict] = []
+ if not es: return out
+ for e in es:
+ try:
+ d = e.to_dict(); t = d.pop("_","").replace("MessageEntity","").lower()
+ if not t: continue
+ mt = {"bold": "bold","italic": "italic","underline": "underline","strikethrough": "strikethrough",
+ "code": "code","pre": "pre","texturl": "text_link","url": "url","email": "email",
+ "phone": "phone_number","mention": "mention",
+ "mentionname": "text_mention","hashtag": "hashtag","cashtag": "cashtag",
+ "botcommand": "bot_command","spoiler": "spoiler","customemoji": "custom_emoji"}.get(t,t)
+ it = {"type": mt,"offset": d.get("offset",0),"length": d.get("length",0)}
+ if t=="texturl": it["url"]=d.get("url","")
+ elif t=="mentionname": it["user"]={"id": d.get("user_id",0)}
+ elif t=="customemoji": it["custom_emoji_id"]=str(d.get("document_id",""))
+ elif t=="pre": it["language"]=d.get("language","")
+ out.append(it)
+ except Exception: continue
+ return out
+
+ @staticmethod
+ def dur(s: Union[int,float]) -> str:
+ t=gmtime(s); return (f"{t.tm_hour:02d}:" if t.tm_hour>0 else "")+f"{t.tm_min:02d}:{t.tm_sec:02d}"
+
+ @staticmethod
+ def desc(m: Message, rep: bool=False) -> str:
+ return (
+ "📷 Фото" if m.photo and rep else
+ (m.file.emoji+" Стикер") if m.sticker and rep else
+ "📹 Видеосообщение" if m.video_note and rep else
+ "📹 Видео" if m.video and rep else
+ "🖼 GIF" if m.gif else
+ "📊 Опрос" if m.poll else
+ "📍 Местоположение" if m.geo else
+ "👤 Контакт" if m.contact else
+ (f"🎵 Голосовое сообщение: {Dick.dur(m.voice.attributes[0].duration)}" if m.voice else
+ (f"🎧 Музыка: {Dick.dur(m.audio.attributes[0].duration)} | {m.audio.attributes[0].performer} - {m.audio.attributes[0].title}" if m.audio else
+ (f"💾 Файл: {m.file.name}" if isinstance(m.media, types.MessageMediaDocument) and not Dick.pick(m) else
+ (f"{m.media.emoticon} Кость: {m.media.value}" if isinstance(m.media, types.MessageMediaDice) else
+ (f"Сервисное сообщение: {m.action.to_dict().get('_')}" if isinstance(m, types.MessageService) else "")))))) #)))
+
+ @staticmethod
+ def split(name: Optional[str]) -> Tuple[str,str]:
+ if not name: return "",""
+ p=name.split(); return (p[0], " ".join(p[1:]) if len(p)>1 else "")
+
+ @staticmethod
+ def pick(m: Message):
+ if m and m.media:
+ return m.photo or m.sticker or m.video or m.video_note or m.gif or m.web_preview
+ return None
+
+ @staticmethod
+ def wf(b: Optional[bytes]) -> List[int]:
+ if not b: return []
+ n=(len(b)*8)//5
+ if not n: return []
+ out: List[int]=[]
+ last=n-1
+ for i in range(last):
+ j=i*5; bi,sh=j//8,j%8
+ v=int.from_bytes(b[bi:bi+2],"little") if bi+1>sh)&0b11111)
+ j=last*5; bi,sh=j//8,j%8
+ v=int.from_bytes(b[bi:bi+2],"little") if bi+1>sh)&0b11111)
+ return out
+
+ @staticmethod
+ async def img(b: bytes, circle: bool=False) -> Optional[str]:
+ try:
+ im=Image.open(io.BytesIO(b))
+ if im.mode!="RGBA": im=im.convert("RGBA")
+ if circle:
+ size=min(im.size)
+ mask=Image.new("L",(size,size),0); ImageDraw.Draw(mask).ellipse((0,0,size,size),fill=255)
+ sq=Image.new("RGBA",(size,size),(0,0,0,0))
+ off=((size-im.width)//2,(size-im.height)//2); sq.paste(im,off)
+ im=Image.composite(sq,Image.new("RGBA",(size,size),(0,0,0,0)),mask)
+ o=io.BytesIO(); im.save(o,format="PNG")
+ return f"data:image/png;base64,{base64.b64encode(o.getvalue()).decode()}"
+ except Exception:
+ return None
+
+ @staticmethod
+ async def stc(b: bytes) -> Optional[str]:
+ try:
+ im=Image.open(io.BytesIO(b))
+ if im.mode not in ("RGBA","LA"): im=im.convert("RGBA")
+ elif im.mode=="LA": im=im.convert("RGBA")
+ o=io.BytesIO(); im.save(o,format="PNG")
+ return f"data:image/png;base64,{base64.b64encode(o.getvalue()).decode()}"
+ except Exception:
+ return None
+
+ @staticmethod
+ async def proc(cli, obj, m: Message) -> Optional[dict]:
+ try:
+ if m.voice:
+ for a in m.voice.attributes or []:
+ if getattr(a,"voice",False) and hasattr(a,"waveform"):
+ return {"voice":{"waveform":Dick.wf(a.waveform)}}
+ b: bytes = await cli.download_media(obj, bytes, thumb=-1)
+ if not b: return None
+ if m.sticker:
+ u=await Dick.stc(b); return {"url": u} if u else None
+ u=await Dick.img(b, circle=bool(m.video_note))
+ return {"url": u} if u else None
+ except Exception:
+ return None
+
+ @staticmethod
+ async def ava(cli, uid: int) -> Optional[str]:
+ try:
+ b=await cli.download_profile_photo(uid, bytes)
+ if b: return f"data:image/jpeg;base64,{base64.b64encode(b).decode()}"
+ except Exception: pass
+ return None
+
+ @staticmethod
+ async def post(url: str, data: dict):
+ try:
+ return await utils.run_sync(requests.post, url, json=data, timeout=30)
+ except Exception:
+ return None
+
+@loader.tds
+class Quotes(loader.Module):
+ """Модуль для создания цитат из сообщений"""
+
+ strings = {"name": "yg_quotes",
+ "no_reply": "🏳️🌈 Нет реплая на сообщение",
+ "processing": "🏳️🌈 Обработка…",
+ "api_processing": "🏳️🌈 Ожидание ответа API…",
+ "api_error": "🏳️🌈 Ошибка API: {}",
+ "loading_media": "🏳️🌈 Отправка…",
+ "no_args_or_reply": "🏳️🌈 Нет аргументов или реплая",
+ "args_error": "🏳️🌈 Ошибка разбора аргументов. Запрос: {}",
+ "too_many_messages": "🏳️🌈 Слишком много сообщений. Максимум: {}"}
+
+ def __init__(self):
+ self.config=loader.ModuleConfig(
+ loader.ConfigValue("type","quote",
+ lambda:"Тип цитаты",
+ validator=loader.validators.Choice(["quote", "stories"])),
+ loader.ConfigValue("bg_color","#162330",
+ lambda:"Цвет фона цитаты (например, #1a1a1a или red)"),
+ loader.ConfigValue("width",512,
+ lambda:"Ширина цитаты (px)",
+ validator=loader.validators.Integer(minimum=200,maximum=2000)),
+ loader.ConfigValue("height",768,
+ lambda:"Высота цитаты (px)",
+ validator=loader.validators.Integer(minimum=200,maximum=2000)),
+ loader.ConfigValue("scale",2,
+ lambda:"Масштаб рендера",
+ validator=loader.validators.Choice([1, 2, 3])),
+ loader.ConfigValue("emoji_brand","apple",
+ lambda:"Стиль эмодзи (apple, google, twitter и т.д.)"),
+ loader.ConfigValue("max_messages",15,
+ lambda:"Максимальное число сообщений в цитате",
+ validator=loader.validators.Integer(minimum=1,maximum=50)),
+ loader.ConfigValue("endpoint","https://kok.gay/gayotes/generate",
+ lambda:"URL API-эндпоинта (можешь поднять локально - github.com/yummy1gay/quote-api)",
+ validator=loader.validators.Link()),
+ loader.ConfigValue("use_rf_proxy", False,
+ lambda:'Включает прокси для РФ, если основной эндпоинт возвращает ошибку "Нетворк еррорь", и при этом сервер с юзерботом находится в России или ты сам сидишь в России с ограниченным доступом к зарубежным ресурсам (Termux / UserLAnd)',
+ validator=loader.validators.Boolean()),
+ loader.ConfigValue("rf_endpoint", "https://ru.kok.gay/gayotes/generate",
+ lambda:"URL API-эндпоинта для РФ",
+ validator=loader.validators.Link()))
+
+ async def client_ready(self, client, db):
+ self.client=client; self.db=db
+
+ async def qcmd(self, m: Message):
+ """
+ Обычные цитаты:
+ • .q — процитировать одно сообщение из реплая
+ • .q 2 — процитировать 2 сообщения
+ • .q 3 #2d2d2d — 3 сообщения на тёмном фоне
+ • .q pink — фон по имени цвета
+ • .q !file — отправить как файл (PNG)
+ """
+ try:
+ args=utils.get_args(m); rep=await m.get_reply_message()
+ if not rep: return await utils.answer(m,self.strings["no_reply"])
+ st=await utils.answer(m,self.strings["processing"])
+ doc="!file" in args
+ n=next((int(a) for a in args if a.isdigit() and int(a)>0),1)
+ bg=next((a for a in args if a!="!file" and not a.isdigit()), self.config["bg_color"])
+ if n>self.config["max_messages"]:
+ return await utils.answer(st,self.strings["too_many_messages"].format(self.config["max_messages"]))
+
+ js=await self.parse(m,n)
+ if not js: return await utils.answer(st,self.strings["api_error"].format("Не удалось собрать сообщения"))
+
+ pay={"backgroundColor":bg,"width":self.config["width"],"height":self.config["height"],
+ "scale":self.config["scale"],"emojiBrand":self.config["emoji_brand"],"messages":js,
+ "format": "webp" if not doc else "png", "type": self.config["type"]}
+
+ await utils.answer(st,self.strings["api_processing"])
+ endpoint=self.config['rf_endpoint'] if self.config['use_rf_proxy'] else self.config['endpoint']
+ r=await Dick.post(f"{endpoint}.webp",pay)
+ if not r or r.status_code!=200:
+ try: err=r.json().get("error",f"HTTP {r.status_code}") if r else "Нетворк еррорь (попробуй включить use_rf_proxy в конфиге)"
+ except Exception: err=f"HTTP {r.status_code}" if r else "Нетворк еррорь (попробуй включить use_rf_proxy в конфиге)"
+ return await utils.answer(st,self.strings["api_error"].format(err))
+
+ buf=io.BytesIO(r.content); buf.name="YgQuote"+(".png" if doc else ".webp")
+ await utils.answer(st,buf,force_document=doc)
+ except Exception as e:
+ return await utils.answer(m,f"🏳️🌈 Ошибка: {e}")
+
+ async def fqcmd(self, m: Message):
+ """
+ Фейковые цитаты:
+ • .fq <@ или ID> <текст> — цитата от пользователя
+ • .fq <текст> — цитата от автора реплая
+ • .fq <@/ID> <текст> -r <@/ID> <текст> — с ответом
+ • .fq user1 текст; user2 текст — несколько сообщений
+ """
+ try:
+ raw=utils.get_args_html(m); rep=await m.get_reply_message()
+ if not (raw or rep): return await utils.answer(m,self.strings["no_args_or_reply"])
+ st= await utils.answer(m,self.strings["processing"])
+ try: js=await self.fake(raw,rep)
+ except (IndexError,ValueError): return await utils.answer(st,self.strings["args_error"].format(m.text))
+ if len(js)>self.config["max_messages"]:
+ return await utils.answer(st,self.strings["too_many_messages"].format(self.config["max_messages"]))
+
+ dickk={"backgroundColor":self.config["bg_color"],"width":self.config["width"],"height":self.config["height"],
+ "scale":self.config["scale"],"emojiBrand":self.config["emoji_brand"],"messages":js,
+ "format": "webp","type":self.config["type"]}
+
+ await utils.answer(st,self.strings["api_processing"])
+ endpoint=self.config['rf_endpoint'] if self.config['use_rf_proxy'] else self.config['endpoint']
+ r=await Dick.post(f"{endpoint}.webp",dickk)
+ if not r or r.status_code!=200:
+ try: err=r.json().get("error",f"HTTP {r.status_code}") if r else "Нетворк еррорь (попробуй включить use_rf_proxy в конфиге)"
+ except Exception: err=f"HTTP {r.status_code}" if r else "Нетворк еррорь (попробуй включить use_rf_proxy в конфиге)"
+ return await utils.answer(st,self.strings["api_error"].format(err))
+
+ buf=io.BytesIO(r.content); buf.name="YgQuote.webp"
+ await utils.answer(st,buf)
+ except Exception as e:
+ return await utils.answer(m,f"🏳️🌈 Ошибка: {e}")
+
+ async def parse(self, trg: Message, n: int) -> Optional[List[dict]]:
+ try:
+ rep= await trg.get_reply_message()
+ lst: List[Message]=[mm async for mm in self.client.iter_messages(trg.chat_id,limit=n,reverse=True,add_offset=1,offset_id=rep.id if rep else None)]
+ except Exception:
+ return None
+
+ out: List[dict]=[]
+ for mm in lst:
+ try:
+ u=await self.who(mm)
+ if not u: continue
+ name=telethon.utils.get_display_name(u); f,l=Dick.split(name)
+ ava=await Dick.ava(self.client,getattr(u,"id",0)) if getattr(u,"id",None) else None
+
+ rb=None
+ try:
+ r=await mm.get_reply_message()
+ if r:
+ ruser = await self.who(r)
+ rname=telethon.utils.get_display_name(ruser)
+ rtxt=Dick.desc(r,True)
+ if r.raw_text: rtxt=(rtxt+". "+r.raw_text) if rtxt else r.raw_text
+ rb={"name":rname,"text":rtxt or "","entities":Dick.ents(r.entities),
+ "chatId": r.sender.id if r.sender else mm.chat_id,"from":{"name":rname}}
+ except Exception: rb=None
+
+ med=None; obj=Dick.pick(mm)
+ if obj: med=await Dick.proc(self.client,obj,mm)
+
+ txt=mm.raw_text or ""; ad=Dick.desc(mm)
+ if ad: txt=f"{txt}\n\n{ad}" if txt else ad
+
+ item={"from":{"id":getattr(u,"id", 0),"first_name":getattr(u,"first_name","") or f,"last_name":getattr(u,"last_name","") or l,
+ "username":getattr(u,"username",None),"name":name,"photo":{"url":ava} if ava else {}},
+ "text":txt,"entities":Dick.ents(mm.entities),"avatar":True}
+
+ try:
+ if mm.voice:
+ a = next((a for a in mm.voice.attributes or []
+ if getattr(a, "voice", False) and hasattr(a, "waveform")), None)
+ if a: item["voice"] = {"waveform": Dick.wf(a.waveform)}
+ except Exception: pass
+
+ if med: item["voice" if "voice" in med else "media"] = med.get("voice", med)
+
+ es=getattr(u,"emoji_status",None)
+ if getattr(es,"document_id",None): item["from"]["emoji_status"]=str(es.document_id)
+ if rb: item["replyMessage"]=rb
+ out.append(item)
+ except Exception: continue
+ return out
+
+ async def who(self, m: Message):
+ try:
+ if m.fwd_from:
+ if m.fwd_from.from_id:
+ pid=m.fwd_from.from_id
+ uid=pid.channel_id if isinstance(pid, types.PeerChannel) else pid.user_id
+ try: return await self.client.get_entity(uid)
+ except Exception: return m.sender
+ if m.fwd_from.from_name:
+ return types.User(
+ id=hash(m.fwd_from.from_name)%2147483647, first_name=m.fwd_from.from_name,
+ username=None, phone=None, bot=False, verified=False, restricted=False,
+ scam=False, fake=False, premium=False)
+ return m.sender
+ except Exception:
+ return m.sender
+
+ async def fake(self, args: str, rep: Optional[Message]) -> List[dict]:
+ async def tok(ch: str):
+ p=ch.split()
+ if not p: return None,""
+ who=p[0]; tx=ch.split(maxsplit=1)[1] if len(p)>1 else ""
+ try:
+ u=await self.client.get_entity(int(who) if who.isdigit() else who)
+ return u,tx
+ except Exception:
+ return None,tx
+
+ if rep and not args:
+ u=rep.sender; name=telethon.utils.get_display_name(u); f,l=Dick.split(name)
+ ava=await Dick.ava(self.client,u.id) if getattr(u,"id",None) else None
+ msg={"from":{"id":u.id,"first_name":getattr(u,"first_name","") or f,"last_name":getattr(u,"last_name","") or l,
+ "username":getattr(u,"username",None),"name":name,"photo":{"url":ava} if ava else {}},
+ "text":"","entities":[], "avatar":True}
+ es=getattr(u,"emoji_status",None)
+ if getattr(es,"document_id", None): msg["from"]["emoji_status"]=str(es.document_id)
+ return [msg]
+
+ if rep and args:
+ u=rep.sender
+ return await self.fake(f"{getattr(u,'id','')} {args}", None)
+
+ out: List[dict]=[]
+ for part in args.split("; "):
+ try:
+ rb=None
+ if " -r " in part:
+ a,b=part.split(" -r ",1); u1,t1=await tok(a); u2,t2=await tok(b)
+ else:
+ u1,t1=await tok(part); u2,t2=None,None
+ if not u1: continue
+
+ txt1, ents1 = html.parse(t1) if t1 else ("", [])
+
+ name=telethon.utils.get_display_name(u1); f,l=Dick.split(name)
+ ava=await Dick.ava(self.client,u1.id)
+
+ if u2:
+ txt2, ents2 = html.parse(t2) if t2 else ("", [])
+ name2=telethon.utils.get_display_name(u2); ava2=await Dick.ava(self.client,u2.id)
+ rb={"name":name2,"text":txt2,"entities":Dick.ents(ents2),"chatId":u2.id,"from":{"name":name2,"photo":{"url":ava2} if ava2 else {}}}
+
+ msg={"from":{"id":u1.id,"first_name":getattr(u1,"first_name","") or f,"last_name":getattr(u1,"last_name","") or l,
+ "username":getattr(u1,"username",None),"name":name,"photo":{"url":ava} if ava else {}},
+ "text":txt1,"entities":Dick.ents(ents1), "avatar":True}
+
+ es=getattr(u1,"emoji_status",None)
+ if getattr(es,"document_id",None): msg["from"]["emoji_status"]=str(es.document_id)
+ if rb: msg["replyMessage"]=rb
+ out.append(msg)
+ except Exception: continue
return out
\ No newline at end of file