Update FileStream/bot/plugins/FileHandlers/callback.py
Browse files
FileStream/bot/plugins/FileHandlers/callback.py
CHANGED
@@ -33,6 +33,7 @@ from FileStream.utils.FileProcessors.bot_utils import gen_link, priv_func, gen_p
|
|
33 |
from FileStream.APIs.TMDB.Endpoint import search_tmdb_any, search_tmdb_tv, search_tmdb_movies
|
34 |
#from FileStream.APIs.IMDB import imdb
|
35 |
from FileStream.APIs.IMDB_CORE import imdb
|
|
|
36 |
#-----------------Starting Point --------------------------#
|
37 |
|
38 |
db = Database(Telegram.DATABASE_URL, Telegram.SESSION_NAME)
|
@@ -114,19 +115,25 @@ async def cb_data(bot: Client, update: CallbackQuery):
|
|
114 |
)
|
115 |
|
116 |
elif usr_cmd[0] == "pubup":
|
117 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
118 |
try:
|
119 |
-
print("Public Upload :",usr_cmd)
|
120 |
-
user_id = str(usr_cmd[1])
|
121 |
-
message_id = int(usr_cmd[2])
|
122 |
-
message = await FileStream.get_messages(user_id, message_id)
|
123 |
-
#response = await FileStream.get_messages(user_id, response_id)
|
124 |
-
#print(f"Message:{message}")
|
125 |
-
name = getattr(message, "caption", f"{get_name(message)}" ) or "None/Unknown"
|
126 |
-
#file_name = get_name(message)
|
127 |
-
#name = file_caption if (file_caption) != "None/Unknown" else file_name
|
128 |
-
from FileStream.Tools.cleanup import Get_Title_Year
|
129 |
-
title, year = Get_Title_Year(name)
|
130 |
print(f"** ANY SEARCH :{name} \nFinal :{title} YEAR :{year}")
|
131 |
get_imdb_id = json.loads(imdb.search(title, year=int(year)))
|
132 |
#print(f"ANY SEARCH :{title} YEAR :{year} IMDB Response :{res}")
|
@@ -182,12 +189,7 @@ async def cb_data(bot: Client, update: CallbackQuery):
|
|
182 |
chat_id=Telegram.ULOG_GROUP,
|
183 |
text=f"An error occurred: {str(e)}"
|
184 |
)
|
185 |
-
|
186 |
-
await update.message.edit_text(
|
187 |
-
text="You are Not An Admin ,Please Get Admin Access",
|
188 |
-
parse_mode=ParseMode.HTML,
|
189 |
-
disable_web_page_preview=True
|
190 |
-
)
|
191 |
|
192 |
elif usr_cmd[0] == "tempup":
|
193 |
try:
|
|
|
33 |
from FileStream.APIs.TMDB.Endpoint import search_tmdb_any, search_tmdb_tv, search_tmdb_movies
|
34 |
#from FileStream.APIs.IMDB import imdb
|
35 |
from FileStream.APIs.IMDB_CORE import imdb
|
36 |
+
from FileStream.Tools.cleanup import Get_Title_Year
|
37 |
#-----------------Starting Point --------------------------#
|
38 |
|
39 |
db = Database(Telegram.DATABASE_URL, Telegram.SESSION_NAME)
|
|
|
115 |
)
|
116 |
|
117 |
elif usr_cmd[0] == "pubup":
|
118 |
+
print("Public Upload :",usr_cmd)
|
119 |
+
user_id = str(usr_cmd[1])
|
120 |
+
message_id = int(usr_cmd[2])
|
121 |
+
message = await FileStream.get_messages(user_id, message_id)
|
122 |
+
#response = await FileStream.get_messages(user_id, response_id)
|
123 |
+
#print(f"Message:{message}")
|
124 |
+
name = getattr(message, "caption", f"{get_name(message)}" ) or "None/Unknown"
|
125 |
+
#file_name = get_name(message)
|
126 |
+
#name = file_caption if (file_caption) != "None/Unknown" else file_name
|
127 |
+
title, year = Get_Title_Year(name)
|
128 |
+
|
129 |
+
if user_id not in [ Telegram.OWNER_ID ]:
|
130 |
+
await update.message.edit_text(
|
131 |
+
text="You are Not An Admin ,Please Get Admin Access",
|
132 |
+
parse_mode=ParseMode.HTML,
|
133 |
+
disable_web_page_preview=True
|
134 |
+
)
|
135 |
+
else:
|
136 |
try:
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
137 |
print(f"** ANY SEARCH :{name} \nFinal :{title} YEAR :{year}")
|
138 |
get_imdb_id = json.loads(imdb.search(title, year=int(year)))
|
139 |
#print(f"ANY SEARCH :{title} YEAR :{year} IMDB Response :{res}")
|
|
|
189 |
chat_id=Telegram.ULOG_GROUP,
|
190 |
text=f"An error occurred: {str(e)}"
|
191 |
)
|
192 |
+
|
|
|
|
|
|
|
|
|
|
|
193 |
|
194 |
elif usr_cmd[0] == "tempup":
|
195 |
try:
|