Callback Update

FileStream/bot/plugins/FileHandlers/callback.py

@@ -171,6 +171,69 @@ async def cb_data(bot: Client, update: CallbackQuery):
           chat_id=Telegram.ULOG_GROUP,
           text=f"An error occurred: {str(e)}"
       )
+  elif usr_cmd[0] == "tempup":
+    try:
+      print("Public Upload :",usr_cmd)
+      user_id = str(usr_cmd[1])
+      message_id = int(usr_cmd[2])
+      message = await FileStream.get_messages(user_id, message_id)
+      #response = await FileStream.get_messages(user_id, response_id)
+      #print(f"Message:{message}")      
+      name = getattr(message, "caption",  f"{get_name(message)}" ) or "None/Unknown"
+      #file_name = get_name(message)
+      #name = file_caption if (file_caption) != "None/Unknown" else file_name
+      from FileStream.Tools.cleanup import Get_Title_Year
+      title, year = Get_Title_Year(name)
+      print(f"** ANY SEARCH :{name} YEAR :{year}")
+      get_imdb_id = json.loads(imdb.search(title, year=int(year)))
+      #print(f"ANY SEARCH :{title} YEAR :{year} IMDB Response :{res}")
+      #print("TMDB",search_tmdb_any(title, year))
+      #print(f"IMDB ID :{get_imdb_id['results'][0]['id']}")
+      print(f"\n** GET_ID {get_imdb_id}")
+      res=json.loads(imdb.get_by_id(get_imdb_id['results'][0]['id']))
+      print(f"\n** IMDB Response :{res}")
+      instruction = {
+        "privacy_type": "PUBLIC",
+        "user_id": user_id,
+        "user_type": "TELEGRAM",
+        "IMDB_id": get_imdb_id['results'][0]['id'],
+        "poster": res['poster'],   
+        "title": res['name'],
+        "release_date": res["datePublished"],
+        "type": res['type'],
+        "description":res["description"],
+        "keywords":res["keywords"].split(",") if res.get("keywords") else [],
+        "genre": res.get("genre", []) ,
+      }
+      
+      file_info = get_file_info(message, instruction)
+      # Here we are Adding the File Into the database First
+      inserted_id = await db.add_file(file_info)
+      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 = await gen_link(_id=inserted_id)
+      await update.message.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")
+      await asyncio.sleep(e.value)
+      await FileStream.send_message(
+          chat_id=Telegram.ULOG_GROUP,
+          text=
+          f"Gᴏᴛ FʟᴏᴏᴅWᴀɪᴛ ᴏғ {str(e.value)}s ғʀᴏᴍ [{message.from_user.first_name}](tg://user?id={message.from_user.id})\n\n**ᴜsᴇʀ ɪᴅ :** `{str(message.from_user.id)}`",
+          disable_web_page_preview=True,
+          parse_mode=ParseMode.MARKDOWN)
+    except Exception as e:
+      print(f"An error occurred: {str(e)}")
+      await FileStream.send_message(
+          chat_id=Telegram.ULOG_GROUP,
+          text=f"An error occurred: {str(e)}"
+    )
 
   elif usr_cmd[0] == "privup":
     try:

FileStream/bot/plugins/FileHandlers/stream.py

@@ -74,6 +74,7 @@ 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 = await upload_type_func(get_file_info(message, instruction),reply)
         await reply.edit_text(text=stream_text,
                               parse_mode=ParseMode.HTML,

FileStream/config.py

@@ -17,21 +17,14 @@ class Telegram:
     FORCE_SUB = env.get('FORCE_UPDATES_CHANNEL', False)
     FORCE_SUB = True if str(FORCE_SUB).lower() == "true" else False
     SLEEP_THRESHOLD = int(env.get("SLEEP_THRESHOLD", "60"))
-    FILE_PIC = env.get(
-      'FILE_PIC',
-      "https://graph.org/file/5bb9935be0229adf98b73.jpg")
-    START_PIC = env.get(
-      'START_PIC',
-      "https://graph.org/file/290af25276fa34fa8f0aa.jpg")
-    VERIFY_PIC = env.get(
-      'VERIFY_PIC',
-      "https://graph.org/file/736e21cc0efa4d8c2a0e4.jpg")
+    FILE_PIC = env.get('FILE_PIC',"https://graph.org/file/5bb9935be0229adf98b73.jpg")
+    START_PIC = env.get('START_PIC',"https://graph.org/file/290af25276fa34fa8f0aa.jpg")
+    VERIFY_PIC = env.get('VERIFY_PIC',"https://graph.org/file/736e21cc0efa4d8c2a0e4.jpg")
     MULTI_CLIENT = False
-    FLOG_CHANNEL = int(env.get(
-      "FLOG_CHANNEL", None))  # Logs channel for file logs
+    FLOG_CHANNEL = int(env.get("FLOG_CHANNEL", None))  # Logs channel for file logs
     PFLOG_CHANNEL = int(env.get("PFLOG_CHANNEL"))
-    ULOG_GROUP = int(env.get(
-      "ULOG_GROUP", None))  # Logs channel for user logs
+    TFLOG_CHANNEL = int(env.get("TFLOG_CHANNEL", None))
+    ULOG_GROUP = int(env.get("ULOG_GROUP", None))  # Logs channel for user logs
     MODE = env.get("MODE", "primary")
     SECONDARY = True if MODE.lower() == "secondary" else False
     AUTH_USERS = list(set(int(x)for x in str(env.get("AUTH_USERS", "")).split()))

FileStream/utils/FileProcessors/bot_utils.py

@@ -113,12 +113,16 @@ async def upload_type_func(file_info,replied_message):
     stream_text = LANG.STREAM_TEXT_Y.format(file_info['file']['file_name'],str(title+" "+year),humanbytes(file_info['file']['file_size']))
     reply_markup = InlineKeyboardMarkup([[
         InlineKeyboardButton(
-            "PUBLIC UPLOAD",
+            "PUBLIC",
             callback_data=f"pubup_{file_info['user_id']}_{file_info['message_id']}"),
         InlineKeyboardButton(
-            "PRIVATE UPLOAD",
+            "PRIVATE",
             callback_data=
-            f"privup_{file_info['user_id']}_{file_info['message_id']}")
+            f"privup_{file_info['user_id']}_{file_info['message_id']}"),
+        InlineKeyboardButton(
+            "TEMPORARY",
+            callback_data=
+            f"tempup_{file_info['user_id']}_{file_info['message_id']}")
     ], [InlineKeyboardButton("ᴄʟᴏsᴇ", callback_data="close")]])
 
     return reply_markup, stream_text

FileStream/utils/FileProcessors/translation.py

@@ -42,7 +42,7 @@ class LANG(object):
 <b>🔗 Sʜᴀʀᴇ :</b> <code>{}</code>\n"""
 
     STREAM_TEXT_Y = """
-<b>🪂 : 𝔹𝕊ℙ𝔸ℝ𝕂 𝔻ℝ𝕀𝕍𝔼 : 🪂</b>\n
+<b>🪂 : 𝕌𝕡𝕝𝕠𝕒𝕕 𝔽𝕚𝕝𝕖 : 🪂</b>\n
 <b>📂 Fɪʟᴇ ɴᴀᴍᴇ :</b> <b>{}</b>\n
 <b>📂 𝖣𝖾𝗋𝗂𝗏𝖾𝖽 𝖭𝖺𝗆𝖾 :</b> <b>{}</b>\n
 <b>📦 Fɪʟᴇ ꜱɪᴢᴇ :</b> <code>{}</code>\n