changes In Upload

FileStream/bot/plugins/FileHandlers/callback.py

@@ -131,6 +131,7 @@ async def cb_data(bot: Client, update: CallbackQuery):
     try:
       user_id = str(usr_cmd[1])
       message_id = int(usr_cmd[2])
+      resp_ms_id = int(usr_cmd[3])
       message = await FileStream.get_messages(user_id, message_id)
       instruction = {
           "privacy_type": "PUBLIC",
@@ -139,7 +140,8 @@ async def cb_data(bot: Client, update: CallbackQuery):
       }
       file_caption = getattr(message, "caption",  f"{get_name(message)}" ) or "None/Unknown"
       file_name = get_name(message)
-      print("Daetail",file_caption,"\nFile:",file_name)
+      print("Detail",file_caption,"\nFile:",file_name)
+      """
       await FileStream.delete_messages(
         chat_id=user_id,
         message_ids=message_id
@@ -152,13 +154,13 @@ async def cb_data(bot: Client, update: CallbackQuery):
         allows_multiple_answers=True,
         chat_id=user_id
         )
-      """
+      
       functions.messages.EditMessage(
                 peer=user_id,
                 id=message_id,
                 media=InputMediaPoll(
                     poll=Poll(
-                        id="23tu2y3tiu2",
+                        id=FileStream.rnd_id(),
                         question="Is this a poll question?",
                         answers=["Movie", "WebSeries", "Anime", "Documentary", "Regular"],
                         multiple_choice=True,
@@ -166,9 +168,10 @@ async def cb_data(bot: Client, update: CallbackQuery):
                     )
                 ),
           )
+      """
       await FileStream.edit_message_media(
                 chat_id=user_id,
-                message_id=message_id,
+                message_id=resp_ms_id,
                 media=InputMediaPoll(
                     poll=Poll(
                         id=FileStream.rnd_id(),
@@ -179,7 +182,7 @@ async def cb_data(bot: Client, update: CallbackQuery):
                     )
                 ),
           )
-      
+      """
       PollAnswer(
       await FileStream.send_poll(
         type= enums.PollType.REGULAR,

FileStream/bot/plugins/FileHandlers/polls.py

@@ -1,9 +1,23 @@
+from pyrogram import Client
 from FileStream.bot import FileStream
 
 
+@app.on_poll()
+def handle_poll(client, poll):
+    print(f"Poll ID: {poll.id}")
+    print(f"Question: {poll.question}")
+    print(f"Options: {poll.options}")
+    print(f"Options: {poll.answers}")
+    print(f"Total Voters: {poll.total_voter_count}")
+
+
+"""
 @FileStream.on_poll()
-def handle_poll(FileStream, poll):
+def handle_poll(FileStream, poll, poll_answer):
     user_id = poll_answer.user.id
     poll_id = poll_answer.poll_id
     option_ids = poll_answer.option_ids
     print(f"User {user_id} voted in poll {poll_id} for options {option_ids}")
+
+    app.loop.create_task(poll_handler(client, poll))
+"""

FileStream/bot/plugins/FileHandlers/stream.py

@@ -61,9 +61,15 @@ async def private_receive_handler(bot: Client, message: Message):
             "privacy_type":"PUBLIC",
             "user_id":message.from_user.id if (message.chat.type == ChatType.PRIVATE) else message.chat.id,
             "user_type": "TELEGRAM"
-        }
-        reply_markup, stream_text = await upload_type_func(get_file_info(message, instruction))
-        await message.reply_text(text=stream_text,
+            }
+        reply = await message.reply_text(text=stream_text,
+                                 parse_mode=ParseMode.HTML,
+                                 disable_web_page_preview=True,
+                                 reply_markup=reply_markup,
+                                 quote=True)
+
+        reply_markup, stream_text = await upload_type_func(file_info=get_file_info(message, instruction),replied_message=reply.id)
+        await message.edit_text(text=stream_text,
                                  parse_mode=ParseMode.HTML,
                                  disable_web_page_preview=True,
                                  reply_markup=reply_markup,

FileStream/utils/FileProcessors/bot_utils.py

@@ -83,7 +83,7 @@ async def is_user_joined(bot, message: Message):
 
 
 #-------------------------------------------------------------
-async def upload_type_func(file_info):
+async def upload_type_func(file_info,replied_message):
   """
   //Used values Directly from file Info
   file_name = file_info['file_name']
@@ -105,7 +105,7 @@ async def upload_type_func(file_info):
     reply_markup = InlineKeyboardMarkup([[
         InlineKeyboardButton(
             "PUBLIC UPLOAD",
-            callback_data=f"pubup_{file_info['user_id']}_{file_info['message_id']}"),
+            callback_data=f"pubup_{file_info['user_id']}_{file_info['message_id']}_{replied_message}"),
         InlineKeyboardButton(
             "PRIVATE UPLOAD",
             callback_data=