90ad5646ff
Co-authored-by: Amit Sharma <48654350+buddhhu@users.noreply.github.com> Co-authored-by: Aditya <xditya@ultroid.tech> Co-authored-by: Kaif <88398455+kaif-00z@users.noreply.github.com> Co-authored-by: Aditya <me@xditya.me> Co-authored-by: 1Danish-00 <danish@ultroid.tech> Co-authored-by: smartman_ru <bblkovo@gmail.com>
268 lines
8.6 KiB
Python
268 lines
8.6 KiB
Python
# Ultroid - UserBot
|
|
# Copyright (C) 2021-2022 TeamUltroid
|
|
#
|
|
# This file is a part of < https://github.com/TeamUltroid/Ultroid/ >
|
|
# PLease read the GNU Affero General Public License in
|
|
# <https://www.github.com/TeamUltroid/Ultroid/blob/main/LICENSE/>.
|
|
"""
|
|
✘ Commands Available -
|
|
|
|
• `{i}instadl <Instagram Url>`
|
|
`Download Instagram Media...`
|
|
|
|
• `{i}instadata <username>`
|
|
`Get Instagram Data of someone or self`
|
|
|
|
• `{i}instaul <reply video/photo> <caption>`
|
|
`Upload Media to Instagram...`
|
|
|
|
• `{i}igtv <reply video> <caption>`
|
|
`Upload Media to Igtv...`
|
|
|
|
• `{i}reels <reply video> <caption>`
|
|
`Upload Media to Instagram reels...`
|
|
|
|
• Go Inline with Your Assistant with query `instatm`
|
|
To get home page's posts...
|
|
|
|
• Fill `INSTA_USERNAME` and `INSTA_PASSWORD`
|
|
before using it..
|
|
"""
|
|
|
|
import os
|
|
from re import compile
|
|
|
|
from pyUltroid.functions.helper import numerize
|
|
from pyUltroid.functions.misc import create_instagram_client
|
|
from telethon.errors.rpcerrorlist import ChatSendInlineForbiddenError
|
|
from telethon.tl.types import (
|
|
DocumentAttributeFilename,
|
|
InputWebDocument,
|
|
MessageMediaWebPage,
|
|
WebPage,
|
|
)
|
|
|
|
from . import (
|
|
LOGS,
|
|
Button,
|
|
asst,
|
|
callback,
|
|
eor,
|
|
get_string,
|
|
in_pattern,
|
|
udB,
|
|
ultroid_cmd,
|
|
)
|
|
|
|
|
|
@ultroid_cmd(pattern="instadl( (.*)|$)")
|
|
async def insta_dl(e):
|
|
match = e.pattern_match.group(1).strip()
|
|
replied = await e.get_reply_message()
|
|
tt = await e.eor(get_string("com_1"))
|
|
if match:
|
|
text = match
|
|
elif e.is_reply and "insta" in replied.message:
|
|
text = replied.message
|
|
else:
|
|
return await eor(tt, "Provide a Link to Download...")
|
|
CL = await create_instagram_client(e)
|
|
if CL:
|
|
try:
|
|
mpk = CL.media_pk_from_url(text)
|
|
media = CL.media_info(mpk)
|
|
if media.media_type == 1: # photo
|
|
media = CL.photo_download(mpk)
|
|
elif media.media_type == 2 and media.product_type == "feed": # video:
|
|
media = CL.video_download(mpk)
|
|
elif media.media_type == 2 and media.product_type == "igtv": # igtv:
|
|
media = CL.igtv_download(mpk)
|
|
elif (
|
|
media.media_type == 2 and media.product_type == "clips"
|
|
): # clips/reels:
|
|
media = CL.clip_download(mpk)
|
|
elif media.media_type == 8: # Album:
|
|
media = CL.album_download(mpk)
|
|
else:
|
|
LOGS.info(f"UnPredictable Media Type : {mpk}")
|
|
return
|
|
await e.reply(
|
|
f"**• Uploaded Successfully\n• Link :** {text}\n",
|
|
file=media,
|
|
)
|
|
await tt.delete()
|
|
if not isinstance(media, list):
|
|
os.remove(media)
|
|
else:
|
|
[os.remove(media) for media in media]
|
|
return
|
|
except Exception as B:
|
|
LOGS.exception(B)
|
|
return await eor(tt, str(B))
|
|
if isinstance(e.media, MessageMediaWebPage) and isinstance(
|
|
e.media.webpage, WebPage
|
|
):
|
|
photo = e.media.webpage.photo or e.media.webpage.document
|
|
if photo:
|
|
await tt.delete()
|
|
return await e.reply(
|
|
f"**Link** :{text}\n\nIf This Wasnt Excepted Result, Please Fill `INSTA_USERNAME` and `INSTA_PASSWORD`...",
|
|
file=photo,
|
|
)
|
|
# await eor(tt, "Please Fill Instagram Credential to Use this Command...")
|
|
|
|
|
|
@ultroid_cmd(pattern="instadata( (.*)|$)")
|
|
async def soon_(e):
|
|
cl = await create_instagram_client(e)
|
|
if not cl:
|
|
return
|
|
match = e.pattern_match.group(1).strip()
|
|
ew = await e.eor(get_string("com_1"))
|
|
if match:
|
|
try:
|
|
iid = cl.user_id_from_username(match)
|
|
data = cl.user_info(iid)
|
|
except Exception as g:
|
|
return await eor(ew, f"**ERROR** : `{g}`")
|
|
else:
|
|
data = cl.account_info()
|
|
data = cl.user_info(data.pk)
|
|
photo = data.profile_pic_url
|
|
unam = "https://instagram.com/" + data.username
|
|
msg = f"• **Full Name** : __{data.full_name}__"
|
|
if hasattr(data, "biography") and data.biography:
|
|
msg += f"\n• **Bio** : `{data.biography}`"
|
|
msg += f"\n• **UserName** : [@{data.username}]({unam})"
|
|
msg += f"\n• **Verified** : {data.is_verified}"
|
|
msg += f"\n• **Posts Count** : {numerize(data.media_count)}"
|
|
msg += f"\n• **Followers** : {numerize(data.follower_count)}"
|
|
msg += f"\n• **Following** : {numerize(data.following_count)}"
|
|
msg += f"\n• **Category** : {data.category_name}"
|
|
await e.reply(
|
|
msg,
|
|
file=photo,
|
|
force_document=True,
|
|
attributes=[DocumentAttributeFilename("InstaUltroid.jpg")],
|
|
)
|
|
await ew.delete()
|
|
|
|
|
|
@ultroid_cmd(pattern="(instaul|reels|igtv)( (.*)|$)")
|
|
async def insta_karbon(event):
|
|
cl = await create_instagram_client(event)
|
|
if not cl:
|
|
return
|
|
msg = await event.eor(get_string("com_1"))
|
|
replied = await event.get_reply_message()
|
|
type_ = event.pattern_match.group(1).strip()
|
|
if not (replied and (replied.photo or replied.video)):
|
|
return await event.eor("`Reply to Photo Or Video...`")
|
|
caption = (
|
|
event.pattern_match.group(2) + "\n\n• By #Ultroid"
|
|
or replied.message + "\n\n• By #Ultroid"
|
|
or "Telegram To Instagram Upload\nBy #Ultroid.."
|
|
)
|
|
dle = await replied.download_media()
|
|
title = None
|
|
if replied.photo:
|
|
method = cl.photo_upload
|
|
elif type_ == "instaul":
|
|
method = cl.video_upload
|
|
elif type_ == "igtv":
|
|
method = cl.igtv_upload
|
|
title = caption
|
|
elif type_ == "reels":
|
|
method = cl.clip_upload
|
|
else:
|
|
return await eor(msg, "`Use In Proper Format...`")
|
|
try:
|
|
if title:
|
|
uri = method(dle, caption=caption, title=title)
|
|
else:
|
|
uri = method(dle, caption=caption)
|
|
os.remove(dle)
|
|
except Exception as er:
|
|
LOGS.exception(er)
|
|
return await msg.edit(str(er))
|
|
if not event.client._bot:
|
|
try:
|
|
que = await event.client.inline_query(
|
|
asst.me.username, f"instp-{uri.code}_{uri.pk}"
|
|
)
|
|
await que[0].click(event.chat_id, reply_to=replied.id)
|
|
await msg.delete()
|
|
except ChatSendInlineForbiddenError:
|
|
pass
|
|
except Exception as er:
|
|
return await msg.edit(str(er))
|
|
await msg.edit(
|
|
f"__Uploaded To Instagram!__\n~ https://instagram.com/p/{uri.code}",
|
|
buttons=Button.inline("•Delete•", f"instd{uri.pk}"),
|
|
link_preview=False,
|
|
)
|
|
|
|
|
|
@in_pattern("instp-(.*)", owner=True)
|
|
async def instapl(event):
|
|
match = event.pattern_match.group(1).strip().split("_")
|
|
uri = "https://instagram.com/p/" + match[0]
|
|
await event.answer(
|
|
[
|
|
await event.builder.article(
|
|
title="Instagram Post",
|
|
text="**Uploaded on Instagram**",
|
|
buttons=[
|
|
Button.url("•View•", uri),
|
|
Button.inline("•Delete•", "instd" + match[1]),
|
|
],
|
|
)
|
|
]
|
|
)
|
|
|
|
|
|
@callback(compile("instd(.*)"), owner=True)
|
|
async def dele_post(event):
|
|
CL = await create_instagram_client(event)
|
|
if not CL:
|
|
return await event.answer("Fill Instagram Credentials", alert=True)
|
|
await event.answer("• Deleting...")
|
|
try:
|
|
CL.media_delete(event.data_match.group(1).decode("utf-8"))
|
|
except Exception as er:
|
|
return await event.edit("ERROR: " + str(er))
|
|
await event.edit("**• Deleted!**")
|
|
|
|
|
|
@in_pattern(pattern="instatm", owner=True)
|
|
async def bhoot_ayaa(event):
|
|
if not udB.get_key("INSTA_SET"):
|
|
return await event.answer(
|
|
[], switch_pm="Fill Instagram Credentials First.", switch_pm_param="start"
|
|
)
|
|
insta = await create_instagram_client(event)
|
|
posts = insta.get_timeline_feed()
|
|
res = []
|
|
switch_pm = f"Showing {posts['num_results']} Feeds.."
|
|
for rp in posts["feed_items"]:
|
|
try:
|
|
me = rp["media_or_ad"]
|
|
url = me["image_versions2"]["candidates"][1]["url"] + ".jpg"
|
|
text = (
|
|
f"| Instagram Inline Search |\n~ https://instagram.com/p/{me['code']}"
|
|
)
|
|
file = InputWebDocument(url, 0, "image/jpeg", [])
|
|
res.append(
|
|
await event.builder.article(
|
|
title="Instagram",
|
|
type="photo",
|
|
content=file,
|
|
thumb=file,
|
|
text=text,
|
|
include_media=True,
|
|
)
|
|
)
|
|
except Exception as er:
|
|
LOGS.exception(er)
|
|
await event.answer(res, gallery=True, switch_pm=switch_pm, switch_pm_param="start")
|