From 90b70806bf9942405006182b53b05c50235c2258 Mon Sep 17 00:00:00 2001
From: Mode-Mirror <123309231+Mirrordcrrv2@users.noreply.github.com>
Date: Sat, 15 Apr 2023 21:18:36 +0530
Subject: [PATCH] Add UserName In Tag Msg....

---
 bot/helper/listeners/tasks_listener.py | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/bot/helper/listeners/tasks_listener.py b/bot/helper/listeners/tasks_listener.py
index 47dad8549..ef913078a 100644
--- a/bot/helper/listeners/tasks_listener.py
+++ b/bot/helper/listeners/tasks_listener.py
@@ -366,6 +366,7 @@ async def onUploadComplete(self, link, size, files, folders, mime_type, name, rc
         if self.isSuperGroup and config_dict['INCOMPLETE_TASK_NOTIFIER'] and DATABASE_URL:
             await DbManger().rm_complete_task(self.message.link)
         LOGGER.info(f'Done Uploading {name}')
+        usr_name = self.message.from_user.first_name.replace('>', '').replace('<', '')
         if self.isLeech:
             msg = f'<b><i>{escape(name)}</i></b>\n'
             msg += f'\n<b>• Size</b>: {get_readable_file_size(size)}'
@@ -373,7 +374,7 @@ async def onUploadComplete(self, link, size, files, folders, mime_type, name, rc
             msg += f"\n<b>• Elapsed</b>: {get_readable_time(time() - self.extra_details['startTime'])}"
             if mime_type != 0:
                 msg += f'\n<b>• Corrupted Files</b>: {mime_type}'
-            msg += f'\n<b>• Leeched by</b>: {self.tag}\n\n'
+            msg += f'\n<b>• Leeched by</b>: {usr_name}\n\n'
             if not files:
                 await sendMessage(self.message, msg)
                 if self.logMessage:
@@ -417,7 +418,7 @@ async def onUploadComplete(self, link, size, files, folders, mime_type, name, rc
             if mime_type == "Folder":
                 msg += f'\n<b>• SubFolders</b>: {folders}'
                 msg += f'\n<b>• Files</b>: {files}'
-            msg += f'\n<b>• Uploaded by</b>: {self.tag}'
+            msg += f'\n<b>• Uploaded by</b>: {usr_name}'
             msg += f'\n<b>• Elapsed</b>: {get_readable_time(time() - self.extra_details["startTime"])}'
             if link or rclonePath and config_dict['RCLONE_SERVE_URL']:
                 if drive_id and config_dict['GDRIVE_ID'] != drive_id:
@@ -581,4 +582,4 @@ async def onUploadError(self, error):
         if not self.isClone:
             await clean_download(self.dir)
             if self.newDir:
-                await clean_download(self.newDir)
\ No newline at end of file
+                await clean_download(self.newDir)