fix 7z progrss

Signed-off-by: anasty17 <e.anastayyar@gmail.com>

Author: anasty17

bot/helper/ext_utils/files_utils.py

@@ -1,5 +1,5 @@
 from aioshutil import rmtree as aiormtree, move
-from asyncio import create_subprocess_exec, sleep, wait_for
+from asyncio import create_subprocess_exec, wait_for
 from asyncio.subprocess import PIPE
 from magic import Magic
 from os import walk, path as ospath, readlink
@@ -308,7 +308,9 @@ def progress(self):
         return self._percentage
 
     async def _sevenz_progress(self):
-        pattern = r"(\d+)\s+bytes|Total Physical Size\s*=\s*(\d+)"
+        pattern = (
+            r"(\d+)\s+bytes|Total Physical Size\s*=\s*(\d+)|Physical Size\s*=\s*(\d+)"
+        )
         while not (
             self._listener.subproc.returncode is not None
             or self._listener.is_cancelled
@@ -321,7 +323,6 @@ async def _sevenz_progress(self):
             line = line.decode().strip()
             if match := re_search(pattern, line):
                 self._listener.subsize = int(match[1] or match[2])
-            await sleep(0.05)
         s = b""
         while not (
             self._listener.is_cancelled
@@ -345,7 +346,6 @@ async def _sevenz_progress(self):
                     self._processed_bytes = 0
                     self._percentage = "0%"
                 s = b""
-            await sleep(0.05)
 
         self._processed_bytes = 0
         self._percentage = "0%"

bot/helper/ext_utils/media_utils.py

@@ -4,7 +4,6 @@
     create_subprocess_exec,
     gather,
     wait_for,
-    sleep,
 )
 from asyncio.subprocess import PIPE
 from os import path as ospath
@@ -367,7 +366,6 @@ async def _ffmpeg_progress(self):
                         except:
                             self._progress_raw = 0
                             self._eta_raw = 0
-            await sleep(0.05)
 
     async def ffmpeg_cmds(self, ffmpeg, f_path):
         self.clear()

bot/helper/mirror_leech_utils/rclone_utils/transfer.py

@@ -1,6 +1,6 @@
 from aiofiles import open as aiopen
 from aiofiles.os import path as aiopath, makedirs, listdir
-from asyncio import create_subprocess_exec, gather, sleep, wait_for
+from asyncio import create_subprocess_exec, gather, wait_for
 from asyncio.subprocess import PIPE
 from configparser import RawConfigParser
 from json import loads
@@ -79,7 +79,6 @@ async def _progress(self):
                     self._speed,
                     self._eta,
                 ) = data[0]
-            await sleep(0.05)
 
     def _switch_service_account(self):
         if self._sa_index == self._sa_number - 1: