Image Enhancement

FileStream/Database/database.py

@@ -128,7 +128,7 @@ class Database:
         if not file_info:
           file_info = await self.tfiles.find_one({"_id": ObjectId(_id)})
           #raise FileNotFound
-        print(file_info)
+        #print(file_info)
         return file_info
       except InvalidId:
         raise FileNotFound

FileStream/bot/plugins/FileHandlers/callback.py

@@ -105,7 +105,7 @@ async def cb_data(bot: Client, update: CallbackQuery):
 
   elif usr_cmd[0] == "mainstream":
     _id = usr_cmd[1]
-    reply_markup,stream_text, poster = await gen_link(_id=_id)
+    reply_markup,stream_text = await gen_link(_id=_id)
     await update.message.edit_text(
         text=stream_text,
         parse_mode=ParseMode.HTML,
@@ -158,7 +158,7 @@ async def cb_data(bot: Client, update: CallbackQuery):
       await get_file_ids(False, inserted_id, message)
       #All the Time Get_file_ids should be called before update privacy or else tagged_users will be {}
       await db.update_privacy(file_info)
-      reply_markup, stream_text, poster = await gen_link(_id=inserted_id)
+      reply_markup, stream_text = await gen_link(_id=inserted_id)
       await update.message.edit_text(
           text=stream_text,
           parse_mode=ParseMode.HTML,
@@ -224,7 +224,7 @@ async def cb_data(bot: Client, update: CallbackQuery):
       #All the Time Get_file_ids should be called before update privacy or else tagged_users will be {}
       print(file_info)
       await db.update_privacy(file_info)
-      reply_markup,stream_text,poster = await gen_link(_id=inserted_id)
+      reply_markup,stream_text = await gen_link(_id=inserted_id)
       await update.message.edit_text(
           text=stream_text,
           parse_mode=ParseMode.HTML,

FileStream/bot/plugins/FileHandlers/stream.py

@@ -75,20 +75,22 @@ async def private_receive_handler(bot: Client, message: Message):
         reply = await message.reply_text(LANG.PROCESSING_TEXT)
         file_info=get_file_info(message, instruction)
         #This Will give a option to Public Private and temporary Upload
-        reply_markup,stream_text, poster = await upload_type_func(get_file_info(message, instruction),reply)
-        print("Poster at Upload_type_func:", poster, type(poster))
+        reply_markup,stream_text = await upload_type_func(get_file_info(message, instruction),reply)
+        """
         if poster == "None":
-            await reply.edit_text(text=stream_text,
+            await reply.reply_photo(photo=poster,
+                                caption=stream_text,
                                 parse_mode=ParseMode.HTML,
-                                disable_web_page_preview=True,
-                                reply_markup= reply_markup,
+                                reply_markup=reply_markup
                                 )
-        else:
-            await reply.reply_photo(photo=poster,
-                                  caption=stream_text,
-                                  parse_mode=ParseMode.HTML,
-                                  reply_markup=reply_markup
-                                  )
+            
+        else:"""
+        await reply.edit_text(text=stream_text,
+                                    parse_mode=ParseMode.HTML,
+                                    disable_web_page_preview=True,
+                                    reply_markup= reply_markup,
+                                    )
+        
             
     except FloodWait as e:
         print(f"Sleeping for {str(e.value)}s")
@@ -111,7 +113,7 @@ async def channel_receive_handler(bot: Client, message: Message):
     try:
         inserted_id = await db.add_file(file_info=get_file_info(message),  db_type="TEMPORARY")
         await get_file_ids(False, inserted_id, MULTI_CLIENTS, message)
-        reply_markup,streaam_text,poster = await gen_link(_id=inserted_id)
+        reply_markup,streaam_text = await gen_link(_id=inserted_id)
         await bot.edit_message_reply_markup(
             chat_id=message.chat.id,
             message_id=message.id,
@@ -215,7 +217,7 @@ async def reply_handler(
                                           reply_to_msg_id=None,
                                           chat_id=Telegram.PFLOG_CHANNEL)
 
-        reply_markup,stream_text,poster = await gen_link(_id=file_info['_id'])
+        reply_markup,stream_text = await gen_link(_id=file_info['_id'])
         await replied_message.edit_text(
             text=f"{message_txt}\n{stream_text}",
             parse_mode=ParseMode.HTML,

FileStream/utils/FileProcessors/bot_utils.py

@@ -92,10 +92,10 @@ async def upload_type_func(file_info,replied_message):
   """
   existing_file = await db.get_file_by_fileuniqueid_only(file_info['file']['file_unique_id'], file_info['privacy_type'])
   if existing_file :
-    reply_markup,stream_text,poster = await gen_link(existing_file['_id'])
+    reply_markup,stream_text = await gen_link(existing_file['_id'])
     #await update.message.edit_text(text=stream_text,parse_mode=ParseMode.HTML,disable_web_page_preview=True,reply_markup=reply_markup,)
     #return {"reply_markup" : response.get("reply_markup"), "stream_text": response.get("stream_text"),"poster":response.get("poster"),"type":"ExistingFile"}
-    return reply_markup,stream_text,poster
+    return reply_markup,stream_text
   else:
     name = file_info['file']['caption'] if file_info['file']['caption'] else file_info['file']['file_name']
     title, year = Get_Title_Year(name)
@@ -109,7 +109,7 @@ async def upload_type_func(file_info,replied_message):
       ],
       [InlineKeyboardButton("ᴄʟᴏsᴇ", callback_data="close")]
     ])
-    return  reply_markup, stream_text, poster
+    return  reply_markup, stream_text
 
 
 async def priv_func(file_name, file_size):
@@ -160,7 +160,7 @@ async def gen_priv_file_link(_id):
 
 async def gen_link(_id):
   file_info = await db.get_file(_id)
-  print("File Info at Gen Link :",file_info,type(file_info))
+  #print("File Info at Gen Link :",file_info,type(file_info))
   #file_name = file_info.get("file").get("file_name", ""),
   file_name = file_info['file']['file_name']
   file_size = humanbytes(file_info['file']['file_size'])
@@ -173,7 +173,7 @@ async def gen_link(_id):
   stream_link = f"{Server.URL}api/dl/{_id}"
   file_link = f"https://t.me/{FileStream.username}?start=file_{_id}"
   #poster=''.join(poster)
-  print("\n Poster", poster, type(poster))
+  #print("\n Poster", poster, type(poster))
 
   if "video" in mime_type:
     stream_text = LANG.STREAM_TEXT.format(poster,description,title,release_date,file_name, file_size, stream_link, page_link, file_link)
@@ -196,7 +196,7 @@ async def gen_link(_id):
       InlineKeyboardButton("ʀᴇᴠᴏᴋᴇ ғɪʟᴇ",callback_data=f"msgdelpvt_{_id}")
       ], [InlineKeyboardButton("ᴄʟᴏsᴇ", callback_data="close")]
     ])
-  return reply_markup, stream_text, str(poster)
+  return reply_markup, stream_text
 
 
 #---------------------[ GEN STREAM LINKS FOR CHANNEL ]---------------------#

FileStream/utils/FileProcessors/custom_ul.py

@@ -222,7 +222,7 @@ class TeleUploader:
         #await db.add_webfile(file_info)
         inserted_id = await db.add_file(file_info=file_info,db_type="TEMPORARY")
         await get_file_ids(False, inserted_id, MessageFile)
-        reply_markup,stream_text, poster = await gen_link(_id=inserted_id)
+        reply_markup,stream_text = await gen_link(_id=inserted_id)
         await message.edit_text(
             text=stream_text,
             parse_mode=ParseMode.HTML,

FileStream/utils/FileProcessors/translation.py

@@ -35,7 +35,7 @@ class LANG(object):
 
     STREAM_TEXT = """
 <i>𝗬𝗼𝘂𝗿 𝗟𝗶𝗻𝗸 𝗚𝗲𝗻𝗲𝗿𝗮𝘁𝗲𝗱 !</i>\n
-<img src={}  width="150" height="300">\n
+<img src='{}'  width="150" height="300">
 <b>📣 ᴅᴇꜱᴄʀɪᴘᴛɪᴏɴ :</b> {} \n
 <b>📊 ɪᴍᴅʙ :</b> {} \n
 <b>📦 રειελȘε :</b> {} \n