", "\n") + "..." + dev = z["developer"]["devId"] + text = f"**• App Name •** [{name}]({url})\n" + text += f"**• Developer •** `{dev}`\n" + text += f"**• Description •**\n`{desc}`" + foles.append( + await e.builder.article( + title=name, + description=dev, + thumb=wb(z["icon"], 0, "image/jpeg", []), + text=text, + link_preview=True, + buttons=[ + [Button.url("Link", url=url)], + [ + Button.switch_inline( + "More Apps", + query="app ", + same_peer=True, + ), + Button.switch_inline( + "Sʜᴀʀᴇ", + query=f"app {f}", + same_peer=False, + ), + ], + ], + ), + ) + APP_CACHE.update({f: foles}) + if RECENTS.get(e.sender_id): + RECENTS[e.sender_id].append(f) + else: + RECENTS.update({e.sender_id: [f]}) + await e.answer(foles, switch_pm="Application Searcher.", switch_pm_param="start") + + +PISTON_URI = "https://emkc.org/api/v2/piston/" +PISTON_LANGS = {} + + +@in_pattern("run", owner=True) +async def piston_run(event): + try: + lang = event.text.split()[1] + code = event.text.split(maxsplit=2)[2] + except IndexError: + result = await event.builder.article( + title="Bad Query", + description="Usage: [Language] [code]", + thumb=wb( + "https://graph.org/file/e33c57fc5f1044547e4d8.jpg", 0, "image/jpeg", [] + ), + text=f'**Inline Usage**\n\n`@{asst.me.username} run python print("hello world")`\n\n[Language List](https://graph.org/Ultroid-09-01-6)', + ) + return await event.answer([result]) + if not PISTON_LANGS: + se = await async_searcher(f"{PISTON_URI}runtimes", re_json=True) + PISTON_LANGS.update({lang.pop("language"): lang for lang in se}) + if lang in PISTON_LANGS.keys(): + version = PISTON_LANGS[lang]["version"] + else: + result = await event.builder.article( + title="Unsupported Language", + description="Usage: [Language] [code]", + thumb=wb( + "https://graph.org/file/e33c57fc5f1044547e4d8.jpg", 0, "image/jpeg", [] + ), + text=f'**Inline Usage**\n\n`@{asst.me.username} run python print("hello world")`\n\n[Language List](https://graph.org/Ultroid-09-01-6)', + ) + return await event.answer([result]) + output = await async_searcher( + f"{PISTON_URI}execute", + post=True, + json={ + "language": lang, + "version": version, + "files": [{"content": code}], + }, + re_json=True, + ) + + output = output["run"]["output"] or get_string("instu_4") + if len(output) > 3000: + output = f"{output[:3000]}..." + result = await event.builder.article( + title="Result", + description=output, + text=f"• **Language:**\n`{lang}`\n\n• **Code:**\n`{code}`\n\n• **Result:**\n`{output}`", + thumb=wb( + "https://graph.org/file/871ee4a481f58117dccc4.jpg", 0, "image/jpeg", [] + ), + buttons=Button.switch_inline("Fork", query=event.text, same_peer=True), + ) + await event.answer([result], switch_pm="• Piston •", switch_pm_param="start") + + +FDROID_ = {} + + +@in_pattern("fdroid", owner=True) +async def do_magic(event): + try: + match = event.text.split(" ", maxsplit=1)[1].lower() + except IndexError: + return await event.answer( + [], switch_pm="Enter Query to Search", switch_pm_param="start" + ) + if FDROID_.get(match): + return await event.answer( + FDROID_[match], switch_pm=f"• Results for {match}", switch_pm_param="start" + ) + link = "https://search.f-droid.org/?q=" + match.replace(" ", "+") + content = await async_searcher(link, re_content=True) + BSC = bs(content, "html.parser", from_encoding="utf-8") + ress = [] + for dat in BSC.find_all("a", "package-header")[:10]: + image = dat.find("img", "package-icon")["src"] + if image.endswith("/"): + image = "https://graph.org/file/a8dd4a92c5a53a89d0eff.jpg" + title = dat.find("h4", "package-name").text.strip() + desc = dat.find("span", "package-summary").text.strip() + text = f"• **Name :** `{title}`\n\n" + text += f"• **Description :** `{desc}`\n" + text += f"• **License :** `{dat.find('span', 'package-license').text.strip()}`" + imga = wb(image, 0, "image/jpeg", []) + ress.append( + await event.builder.article( + title=title, + type="photo", + description=desc, + text=text, + content=imga, + thumb=imga, + include_media=True, + buttons=[ + Button.inline( + "• Download •", "fd" + dat["href"].split("packages/")[-1] + ), + Button.switch_inline("• Share •", query=event.text), + ], + ) + ) + msg = f"Showing {len(ress)} Results!" if ress else "No Results Found" + FDROID_.update({match: ress}) + await event.answer(ress, switch_pm=msg, switch_pm_param="start") + + +# Thanks to OpenSource +_bearer_collected = [ + "AAAAAAAAAAAAAAAAAAAAALIKKgEAAAAA1DRuS%2BI7ZRKiagD6KHYmreaXomo%3DP5Vaje4UTtEkODg0fX7nCh5laSrchhtLxeyEqxXpv0w9ZKspLD", + "AAAAAAAAAAAAAAAAAAAAAL5iUAEAAAAAmo6FYRjqdKlI3cNziIm%2BHUQB9Xs%3DS31pj0mxARMTOk2g9dvQ1yP9wknvY4FPBPUlE00smJcncw4dPR", + "AAAAAAAAAAAAAAAAAAAAAN6sVgEAAAAAMMjMMWrwgGyv7YQOWN%2FSAsO5SGM%3Dg8MG9Jq93Rlllaok6eht7HvRCruN4Vpzp4NaVsZaaHHWSTzKI8", +] + + +@in_pattern("twitter", owner=True) +async def twitter_search(event): + try: + match = event.text.split(maxsplit=1)[1].lower() + except IndexError: + return await event.answer( + [], switch_pm="Enter Query to Search", switch_pm_param="start" + ) + try: + return await event.answer( + _ult_cache["twitter"][match], + switch_pm="• Twitter Search •", + switch_pm_param="start", + ) + except KeyError: + pass + headers = {"Authorization": f"bearer {choice(_bearer_collected)}"} + res = await async_searcher( + f"https://api.twitter.com/1.1/users/search.json?q={match}", + headers=headers, + re_json=True, + ) + reso = [] + for user in res: + thumb = wb(user["profile_image_url_https"], 0, "image/jpeg", []) + if user.get("profile_banner_url"): + url = user["profile_banner_url"] + text = f"[\xad]({url})• **Name :** `{user['name']}`\n" + else: + text = f"• **Name :** `{user['name']}`\n" + text += f"• **Description :** `{user['description']}`\n" + text += f"• **Username :** `@{user['screen_name']}`\n" + text += f"• **Followers :** `{user['followers_count']}` • **Following :** `{user['friends_count']}`\n" + pro_ = "https://twitter.com/" + user["screen_name"] + text += f"• **Link :** [Click Here]({pro_})\n_" + reso.append( + await event.builder.article( + title=user["name"], + description=user["description"], + url=pro_, + text=text, + thumb=thumb, + ) + ) + swi_ = f"🐦 Showing {len(reso)} Results!" if reso else "No User Found :(" + await event.answer(reso, switch_pm=swi_, switch_pm_param="start") + if _ult_cache.get("twitter"): + _ult_cache["twitter"].update({match: reso}) + else: + _ult_cache.update({"twitter": {match: reso}}) + + +_savn_cache = {} + + +@in_pattern("saavn", owner=True) +async def savn_s(event): + try: + query = event.text.split(maxsplit=1)[1].lower() + except IndexError: + return await event.answer( + [], switch_pm="Enter Query to search 🔍", switch_pm_param="start" + ) + if query in _savn_cache: + return await event.answer( + _savn_cache[query], + switch_pm=f"Showing Results for {query}", + switch_pm_param="start", + ) + results = await saavn_search(query) + swi = "🎵 Saavn Search" if results else "No Results Found!" + res = [] + for song in results: + thumb = wb(song["image"], 0, "image/jpeg", []) + text = f"• **Title :** {song['title']}" + text += f"\n• **Year :** {song['year']}" + text += f"\n• **Lang :** {song['language']}" + text += f"\n• **Artist :** {song['artists']}" + text += f"\n• **Release Date :** {song['release_date']}" + res.append( + await event.builder.article( + title=song["title"], + description=song["artists"], + type="audio", + text=text, + include_media=True, + buttons=Button.switch_inline( + "Search Again 🔍", query="saavn", same_peer=True + ), + thumb=thumb, + content=wb( + song["url"], + 0, + "audio/mp4", + [ + Audio( + title=song["title"], + duration=int(song["duration"]), + performer=song["artists"], + ) + ], + ), + ) + ) + await event.answer(res, switch_pm=swi, switch_pm_param="start") + _savn_cache.update({query: res}) + + +@in_pattern("tl", owner=True) +async def inline_tl(ult): + try: + match = ult.text.split(maxsplit=1)[1] + except IndexError: + text = f"**Telegram TlObjects Searcher.**\n__(Don't use if you don't know what it is!)__\n\n• Example Usage\n`@{asst.me.username} tl GetFullUserRequest`" + return await ult.answer( + [ + await ult.builder.article( + title="How to Use?", + description="Tl Searcher by Ultroid", + url="https://t.me/TeamUltroid", + text=text, + ) + ], + switch_pm="Tl Search 🔍", + switch_pm_param="start", + ) + res = [] + for key in tlobjects.values(): + if match.lower() in key.__name__.lower(): + tyyp = "Function" if "tl.functions." in str(key) else "Type" + text = f"**Name:** `{key.__name__}`\n" + text += f"**Category:** `{tyyp}`\n" + text += f"\n`from {key.__module__} import {key.__name__}`\n\n" + if args := str(inspect.signature(key))[1:][:-1]: + text += "**Parameter:**\n" + for para in args.split(","): + text += " " * 4 + "`" + para + "`\n" + text += f"\n**Layer:** `{LAYER}`" + res.append( + await ult.builder.article( + title=key.__name__, + description=tyyp, + url="https://t.me/TeamUltroid", + text=text[:4000], + ) + ) + mo = f"Showing {len(res)} results!" if res else f"No Results for {match}!" + await ult.answer(res[:50], switch_pm=mo, switch_pm_param="start") + + +InlinePlugin.update( + { + "Pʟᴀʏ Sᴛᴏʀᴇ Aᴘᴘs": "app telegram", + "Mᴏᴅᴅᴇᴅ Aᴘᴘs": "mods minecraft", + "Sᴇᴀʀᴄʜ Oɴ Gᴏᴏɢʟᴇ": "go TeamUltroid", + "WʜɪSᴘᴇʀ": "wspr @username Hello🎉", + "YᴏᴜTᴜʙᴇ Dᴏᴡɴʟᴏᴀᴅᴇʀ": "yt Ed Sheeran Perfect", + "Piston Eval": "run javascript console.log('Hello Ultroid')", + "OʀᴀɴɢᴇFᴏx🦊": "ofox beryllium", + "Tᴡɪᴛᴛᴇʀ Usᴇʀ": "twitter theultroid", + "Fᴅʀᴏɪᴅ Sᴇᴀʀᴄʜ": "fdroid telegram", + "Sᴀᴀᴠɴ sᴇᴀʀᴄʜ": "saavn", + "Tʟ Sᴇᴀʀᴄʜ": "tl", + } +) diff --git a/assistant/localization.py b/assistant/localization.py new file mode 100644 index 0000000000000000000000000000000000000000..7abbdadef60a61e2106b5cc0c286d08ed0fcd5de --- /dev/null +++ b/assistant/localization.py @@ -0,0 +1,47 @@ +# Ultroid - UserBot +# Copyright (C) 2021-2026 TeamUltroid +# +# This file is a part of < https://github.com/TeamUltroid/Ultroid/ > +# PLease read the GNU Affero General Public License in +#
(.*?)
'
+ search_match = re.search(search_pattern, html, re.DOTALL)
+ if search_match:
+ search_content = search_match.group(1)
+ url_pattern = r'https://[^\"]*?\.(?:jpg|jpeg|png|webp)'
+ url_matches = re.finditer(url_pattern, search_content, re.IGNORECASE)
+ for url_match in url_matches:
+ url = url_match.group(0)
+ if url not in img_urls and is_valid_url(url):
+ img_urls.append(url)
+
+ # Fallback to tdeeNb div if no results
+ if not img_urls:
+ pattern = r']*>(.*?)
'
+ matches = re.finditer(pattern, html, re.DOTALL)
+ for match in matches:
+ div_content = match.group(1)
+ url_pattern = r'https://[^\"]*?\.(?:jpg|jpeg|png|webp)'
+ url_matches = re.finditer(url_pattern, div_content, re.IGNORECASE)
+ for url_match in url_matches:
+ url = url_match.group(0)
+ if url not in img_urls and is_valid_url(url):
+ img_urls.append(url)
+
+ # Fallback to general image search if still no results
+ if not img_urls:
+ pattern = r"https://[^\"]*?\.(?:jpg|jpeg|png|webp)"
+ matches = re.finditer(pattern, html, re.IGNORECASE)
+ for match in matches:
+ url = match.group(0)
+ if url not in img_urls and is_valid_url(url):
+ img_urls.append(url)
+
+ # Final fallback to data URLs if still no results
+ if not img_urls:
+ pattern = r'data:image/(?:jpeg|png|webp);base64,[^\"]*'
+ matches = re.finditer(pattern, html, re.IGNORECASE)
+ for match in matches:
+ url = match.group(0)
+ if url not in img_urls:
+ img_urls.append(url)
+
+ return img_urls
+
+ except Exception as e:
+ print(f"Error fetching Google images: {e}")
+ return []
+
+
+@ultroid_cmd(pattern="autopic( (.*)|$)")
+async def autopic(e):
+ search = e.pattern_match.group(1).strip()
+ if udB.get_key("AUTOPIC") and not search:
+ udB.del_key("AUTOPIC")
+ return await e.eor(get_string("autopic_5"))
+ if not search:
+ return await e.eor(get_string("autopic_1"), time=5)
+ e = await e.eor(get_string("com_1"))
+ images = await get_google_images(search)
+ if not images:
+ return await e.eor(get_string("autopic_2").format(search), time=5)
+ await e.eor(get_string("autopic_3").format(search))
+ udB.set_key("AUTOPIC", search)
+ SLEEP_TIME = udB.get_key("SLEEP_TIME") or 1221
+ while True:
+ for lie in images:
+ if udB.get_key("AUTOPIC") != search:
+ return
+ download_path, stime = await fast_download(lie, "resources/downloads/autopic.jpg")
+ img = Image.open(download_path)
+ img.save("resources/downloads/autopic.jpg")
+ file = await e.client.upload_file("resources/downloads/autopic.jpg")
+ await e.client(UploadProfilePhotoRequest(file=file))
+ os.remove("resources/downloads/autopic.jpg")
+ await asyncio.sleep(SLEEP_TIME)
+
+ shuffle(images)
+
+
+if search := udB.get_key("AUTOPIC"):
+ images = {}
+ sleep = udB.get_key("SLEEP_TIME") or 1221
+
+ async def autopic_func():
+ search = udB.get_key("AUTOPIC")
+ if images.get(search) is None:
+ images[search] = await get_google_images(search)
+ if not images.get(search):
+ return
+ img = random.choice(images[search])
+ filee, stime = await fast_download(img, "resources/downloads/autopic.jpg")
+ img = Image.open(filee)
+ img.save("resources/downloads/autopic.jpg")
+ file = await ultroid_bot.upload_file("resources/downloads/autopic.jpg")
+ await ultroid_bot(UploadProfilePhotoRequest(file=file))
+ os.remove(filee)
+
+ try:
+ from apscheduler.schedulers.asyncio import AsyncIOScheduler
+
+ schedule = AsyncIOScheduler()
+ schedule.add_job(autopic_func, "interval", seconds=sleep)
+ schedule.start()
+ except ModuleNotFoundError as er:
+ LOGS.error(f"autopic: '{er.name}' not installed.")
diff --git a/plugins/beautify.py b/plugins/beautify.py
new file mode 100644
index 0000000000000000000000000000000000000000..733c5d2da4eb850c51b0f7a8e15b68ff2d990a90
--- /dev/null
+++ b/plugins/beautify.py
@@ -0,0 +1,197 @@
+# Ultroid - UserBot
+# Copyright (C) 2021-2026 TeamUltroid
+#
+# This file is a part of < https://github.com/TeamUltroid/Ultroid/ >
+# PLease read the GNU Affero General Public License in
+# {}\n🌀 PyUltroid -> {}\n🌀 Python -> {}\n🌀 Uptime -> {}\n🌀 Branch ->[ {} ]\n\n• Join @TeamUltroid"
+
+
+@callback("alive")
+async def alive(event):
+ text = alive_txt.format(ultroid_version, UltVer, __version__)
+ await event.answer(text, alert=True)
+
+
+@ultroid_cmd(
+ pattern="alive( (.*)|$)",
+)
+async def lol(ult):
+ match = ult.pattern_match.group(1).strip()
+ inline = None
+ if match in ["inline", "i"]:
+ try:
+ res = await ult.client.inline_query(asst.me.username, "alive")
+ return await res[0].click(ult.chat_id)
+ except BotMethodInvalidError:
+ pass
+ except BaseException as er:
+ LOGS.exception(er)
+ inline = True
+ pic = udB.get_key("ALIVE_PIC")
+ if isinstance(pic, list):
+ pic = choice(pic)
+ uptime = time_formatter((time.time() - start_time) * 1000)
+ header = udB.get_key("ALIVE_TEXT") or get_string("bot_1")
+ y = Repo().active_branch
+ xx = Repo().remotes[0].config_reader.get("url")
+ rep = xx.replace(".git", f"/tree/{y}")
+ kk = f" `[{y}]({rep})` "
+ if inline:
+ kk = f"{y}"
+ parse = "html"
+ als = in_alive.format(
+ header,
+ f"{ultroid_version} [{HOSTED_ON}]",
+ UltVer,
+ pyver(),
+ uptime,
+ kk,
+ )
+
+ if _e := udB.get_key("ALIVE_EMOJI"):
+ als = als.replace("🌀", _e)
+ else:
+ parse = "md"
+ als = (get_string("alive_1")).format(
+ header,
+ OWNER_NAME,
+ f"{ultroid_version} [{HOSTED_ON}]",
+ UltVer,
+ uptime,
+ pyver(),
+ __version__,
+ kk,
+ )
+
+ if a := udB.get_key("ALIVE_EMOJI"):
+ als = als.replace("✵", a)
+ if pic:
+ try:
+ await ult.reply(
+ als,
+ file=pic,
+ parse_mode=parse,
+ link_preview=False,
+ buttons=buttons if inline else None,
+ )
+ return await ult.try_delete()
+ except ChatSendMediaForbiddenError:
+ pass
+ except BaseException as er:
+ LOGS.exception(er)
+ try:
+ await ult.reply(file=pic)
+ await ult.reply(
+ als,
+ parse_mode=parse,
+ buttons=buttons if inline else None,
+ link_preview=False,
+ )
+ return await ult.try_delete()
+ except BaseException as er:
+ LOGS.exception(er)
+ await eor(
+ ult,
+ als,
+ parse_mode=parse,
+ link_preview=False,
+ buttons=buttons if inline else None,
+ )
+
+
+@ultroid_cmd(pattern="ping$", chats=[], type=["official", "assistant"])
+async def _(event):
+ start = time.time()
+ x = await event.eor("Pong !")
+ end = round((time.time() - start) * 1000)
+ uptime = time_formatter((time.time() - start_time) * 1000)
+ await x.edit(get_string("ping").format(end, uptime))
+
+
+@ultroid_cmd(
+ pattern="cmds$",
+)
+async def cmds(event):
+ await allcmds(event, Telegraph)
+
+
+heroku_api = Var.HEROKU_API
+
+
+@ultroid_cmd(
+ pattern="restart$",
+ fullsudo=True,
+)
+async def restartbt(ult):
+ ok = await ult.eor(get_string("bot_5"))
+ call_back()
+ who = "bot" if ult.client._bot else "user"
+ udB.set_key("_RESTART", f"{who}_{ult.chat_id}_{ok.id}")
+ if heroku_api:
+ return await restart(ok)
+ await bash("git pull && pip3 install -r requirements.txt")
+ await bash("pip3 install -r requirements.txt --break-system-packages")
+ if len(sys.argv) > 1:
+ os.execl(sys.executable, sys.executable, "main.py")
+ else:
+ os.execl(sys.executable, sys.executable, "-m", "pyUltroid")
+
+
+@ultroid_cmd(
+ pattern="shutdown$",
+ fullsudo=True,
+)
+async def shutdownbot(ult):
+ await shutdown(ult)
+
+
+@ultroid_cmd(
+ pattern="logs( (.*)|$)",
+ chats=[],
+)
+async def _(event):
+ opt = event.pattern_match.group(1).strip()
+ file = f"ultroid{sys.argv[-1]}.log" if len(sys.argv) > 1 else "ultroid.log"
+ if opt == "heroku":
+ await heroku_logs(event)
+ elif opt == "carbon" and Carbon:
+ event = await event.eor(get_string("com_1"))
+ with open(file, "r") as f:
+ code = f.read()[-2500:]
+ file = await Carbon(
+ file_name="ultroid-logs",
+ code=code,
+ backgroundColor=choice(ATRA_COL),
+ )
+ if isinstance(file, dict):
+ await event.eor(f"`{file}`")
+ return
+ await event.reply("**Ultroid Logs.**", file=file)
+ elif opt == "open":
+ with open("ultroid.log", "r") as f:
+ file = f.read()[-4000:]
+ return await event.eor(f"`{file}`")
+ elif (
+ opt.isdigit() and 5 <= int(opt) <= 100
+ ): # Check if input is a number between 10 and 100
+ num_lines = int(opt)
+ with open("ultroid.log", "r") as f:
+ lines = f.readlines()[-num_lines:]
+ file = "".join(lines)
+ return await event.eor(f"`{file}`")
+ else:
+ await def_logs(event, file)
+ await event.try_delete()
+
+
+@in_pattern("alive", owner=True)
+async def inline_alive(ult):
+ pic = udB.get_key("ALIVE_PIC")
+ if isinstance(pic, list):
+ pic = choice(pic)
+ uptime = time_formatter((time.time() - start_time) * 1000)
+ header = udB.get_key("ALIVE_TEXT") or get_string("bot_1")
+ y = Repo().active_branch
+ xx = Repo().remotes[0].config_reader.get("url")
+ rep = xx.replace(".git", f"/tree/{y}")
+ kk = f"{y}"
+ als = in_alive.format(
+ header, f"{ultroid_version} [{HOSTED_ON}]", UltVer, pyver(), uptime, kk
+ )
+
+ if _e := udB.get_key("ALIVE_EMOJI"):
+ als = als.replace("🌀", _e)
+ builder = ult.builder
+ if pic:
+ try:
+ if ".jpg" in pic:
+ results = [
+ await builder.photo(
+ pic, text=als, parse_mode="html", buttons=buttons
+ )
+ ]
+ else:
+ if _pic := resolve_bot_file_id(pic):
+ pic = _pic
+ buttons.insert(
+ 0, [Button.inline(get_string("bot_2"), data="alive")]
+ )
+ results = [
+ await builder.document(
+ pic,
+ title="Inline Alive",
+ description="@TeamUltroid",
+ parse_mode="html",
+ buttons=buttons,
+ )
+ ]
+ return await ult.answer(results)
+ except BaseException as er:
+ LOGS.exception(er)
+ result = [
+ await builder.article(
+ "Alive", text=als, parse_mode="html", link_preview=False, buttons=buttons
+ )
+ ]
+ await ult.answer(result)
+
+
+@ultroid_cmd(pattern="update( (.*)|$)")
+async def _(e):
+ xx = await e.eor(get_string("upd_1"))
+ if e.pattern_match.group(1).strip() and (
+ "fast" in e.pattern_match.group(1).strip()
+ or "soft" in e.pattern_match.group(1).strip()
+ ):
+ await bash("git pull -f && pip3 install -r requirements.txt")
+ await bash("pip3 install -r requirements.txt --break-system-packages")
+ call_back()
+ await xx.edit(get_string("upd_7"))
+ os.execl(sys.executable, "python3", "-m", "pyUltroid")
+ # return
+ m = await updater()
+ branch = (Repo.init()).active_branch
+ if m:
+ x = await asst.send_file(
+ udB.get_key("LOG_CHANNEL"),
+ ULTPIC(),
+ caption="• **Update Available** •",
+ force_document=False,
+ buttons=Button.inline("Changelogs", data="changes"),
+ )
+ Link = x.message_link
+ await xx.edit(
+ f'[ChangeLogs]',
+ parse_mode="html",
+ link_preview=False,
+ )
+ else:
+ await xx.edit(
+ f'Your BOT is up-to-date with [{branch}]',
+ parse_mode="html",
+ link_preview=False,
+ )
+
+
+@callback("updtavail", owner=True)
+async def updava(event):
+ await event.delete()
+ await asst.send_file(
+ udB.get_key("LOG_CHANNEL"),
+ ULTPIC(),
+ caption="• **Update Available** •",
+ force_document=False,
+ buttons=Button.inline("Changelogs", data="changes"),
+ )
diff --git a/plugins/broadcast.py b/plugins/broadcast.py
new file mode 100644
index 0000000000000000000000000000000000000000..9734c8ef63d0c9b055400f67057509b292051ee1
--- /dev/null
+++ b/plugins/broadcast.py
@@ -0,0 +1,261 @@
+# Ultroid - UserBot
+# Copyright (C) 2021-2026 TeamUltroid
+#
+# This file is a part of < https://github.com/TeamUltroid/Ultroid/ >
+# PLease read the GNU Affero General Public License in
+# {get_display_name(event.chat)} [{event.chat_id}]"
+ msg += f"\n\n∆ CODE:\n{cmd}\n\n∆ ERROR:\n{exc}"
+ log_chat = udB.get_key("LOG_CHANNEL")
+ if len(msg) > 4000:
+ with BytesIO(msg.encode()) as out_file:
+ out_file.name = "Eval-Error.txt"
+ return await event.client.send_message(
+ log_chat, f"`{cmd}`", file=out_file
+ )
+ await event.client.send_message(log_chat, msg, parse_mode="html")
+ return
+ tmt = tima * 1000
+ timef = time_formatter(tmt)
+ timeform = timef if not timef == "0s" else f"{tmt:.3f}ms"
+ final_output = "__►__ **EVAL** (__in {}__)\n```{}``` \n\n __►__ **OUTPUT**: \n```{}``` \n".format(
+ timeform,
+ cmd,
+ evaluation,
+ )
+ if len(final_output) > 4096:
+ final_output = evaluation
+ with BytesIO(str.encode(final_output)) as out_file:
+ out_file.name = "eval.txt"
+ await event.client.send_file(
+ event.chat_id,
+ out_file,
+ force_document=True,
+ thumb=ULTConfig.thumb,
+ allow_cache=False,
+ caption=f"```{cmd}```" if len(cmd) < 998 else None,
+ reply_to=reply_to_id,
+ )
+ return await xx.delete()
+ await xx.edit(final_output)
+
+
+def _stringify(text=None, *args, **kwargs):
+ if text:
+ u._ = text
+ text = _parse_eval(text)
+ return print(text, *args, **kwargs)
+
+
+async def aexec(code, event):
+ # Create a dedicated namespace for execution
+ exec_globals = {
+ 'print': _stringify,
+ 'p': _stringify,
+ 'message': event,
+ 'event': event,
+ 'client': event.client,
+ 'reply': await event.get_reply_message(),
+ 'chat': event.chat_id,
+ 'u': u,
+ '__builtins__': __builtins__,
+ '__name__': __name__
+ }
+
+ # Format the async function definition
+ wrapped_code = (
+ 'async def __aexec(e, client):\n' +
+ '\n'.join(f' {line}' for line in code.split('\n'))
+ )
+
+ try:
+ # Execute the wrapped code in our custom namespace
+ exec(wrapped_code, exec_globals)
+ # Get the defined async function
+ func = exec_globals['__aexec']
+ # Execute it with proper parameters
+ return await func(event, event.client)
+ except Exception as e:
+ raise Exception(f"Failed to execute code: {str(e)}")
+
+
+DUMMY_CPP = """#include {murl}")
+ extra = f"**[{xx}]({url})**\n\n"
+ e = await e.eor(f"{extra}`Loading More...`", link_preview=False)
+
+ if hasattr(r.media, "document"):
+ file = r.media.document
+ mime_type = file.mime_type
+ filename = r.file.name
+ if not filename:
+ if "audio" in mime_type:
+ filename = "audio_" + dt.now().isoformat("_", "seconds") + ".ogg"
+ elif "video" in mime_type:
+ filename = "video_" + dt.now().isoformat("_", "seconds") + ".mp4"
+ dl = await downloader(
+ f"resources/downloads/{filename}",
+ file,
+ e,
+ taime,
+ f"{extra}`Loading More...`",
+ )
+
+ naam = dl.name
+ else:
+ naam = await r.download_media()
+ elif match and (
+ os.path.isfile(match)
+ or (match.startswith("https://") and (await is_url_ok(match)))
+ ):
+ naam, xx = match, "file"
+ else:
+ return await e.eor(get_string("cvt_3"), time=5)
+ out, er = await bash(f"mediainfo '{naam}'")
+ if er:
+ LOGS.info(er)
+ out = extra or str(er)
+ return await e.edit(out, link_preview=False)
+ makehtml = ""
+ if naam.endswith((".jpg", ".png")):
+ if os.path.exists(naam):
+ med = upload_file(naam)
+ else:
+ med = match
+ makehtml += f"" + for line in out.split("\n"): + line = line.strip() + if not line: + makehtml += "
" + elif ":" not in line: + makehtml += f"
{line}
" + else: + makehtml += f"{line}
" + try: + urll = await make_html_telegraph("Mediainfo", makehtml) + except Exception as er: + LOGS.exception(er) + return + await e.eor(f"{extra}[{get_string('mdi_1')}]({urll})", link_preview=False) + if not match: + os.remove(naam) + + +@ultroid_cmd(pattern="rotate( (.*)|$)") +async def rotate_(ult): + match = ult.pattern_match.group(1).strip() + if not ult.is_reply: + return await ult.eor("`Reply to a media...`") + if match: + try: + match = int(match) + except ValueError: + match = None + if not match: + return await ult.eor("`Please provide a valid angle to rotate media..`") + reply = await ult.get_reply_message() + msg = await ult.eor(get_string("com_1")) + photo = reply.game.photo if reply.game else None + if reply.video: + media = await reply.download_media() + file = f"{media}.mp4" + await bash( + f'ffmpeg -i "{media}" -c copy -metadata:s:v:0 rotate={match} "{file}" -y' + ) + elif photo or reply.photo or reply.sticker: + media = await ult.client.download_media(photo or reply) + img = cv2.imread(media) + new_ = rotate_image(img, match) + file = "ult.png" + cv2.imwrite(file, new_) + else: + return await msg.edit("`Unsupported Media..\nReply to Photo/Video`") + if os.path.exists(file): + await ult.client.send_file( + ult.chat_id, file=file, video_note=bool(reply.video_note), reply_to=reply.id + ) + os.remove(media) + await msg.try_delete() diff --git a/plugins/misc.py b/plugins/misc.py new file mode 100644 index 0000000000000000000000000000000000000000..e82b6702e97262c19c7e95bfc2055c0dcc1e5d19 --- /dev/null +++ b/plugins/misc.py @@ -0,0 +1,140 @@ +# Ultroid - UserBot +# +# This file is a part of < https://github.com/TeamUltroid/Ultroid/ > +# PLease read the GNU Affero General Public License in +#