pythonfansx
diff --git a/‎pyrogram/methods/advanced/save_file.py‎
Lines changed: 44 additions & 42 deletions b/‎pyrogram/methods/advanced/save_file.py‎
Lines changed: 44 additions & 42 deletions
@@ -116,7 +116,7 @@ async def worker(session):
         else:
             raise ValueError("Invalid file. Expected a file path as string or a binary (not text) file pointer")
 
-        file_name = fp.name
+        file_name = getattr(fp, "name", "file.jpg")
 
         fp.seek(0, os.SEEK_END)
         file_size = fp.tell()
@@ -148,53 +148,52 @@ async def worker(session):
             for session in pool:
                 await session.start()
 
-            with fp:
-                fp.seek(part_size * file_part)
+            fp.seek(part_size * file_part)
 
-                while True:
-                    chunk = fp.read(part_size)
+            while True:
+                chunk = fp.read(part_size)
 
-                    if not chunk:
-                        if not is_big and not is_missing_part:
-                            md5_sum = "".join([hex(i)[2:].zfill(2) for i in md5_sum.digest()])
-                        break
+                if not chunk:
+                    if not is_big and not is_missing_part:
+                        md5_sum = "".join([hex(i)[2:].zfill(2) for i in md5_sum.digest()])
+                    break
+
+                if is_big:
+                    rpc = raw.functions.upload.SaveBigFilePart(
+                        file_id=file_id,
+                        file_part=file_part,
+                        file_total_parts=file_total_parts,
+                        bytes=chunk
+                    )
+                else:
+                    rpc = raw.functions.upload.SaveFilePart(
+                        file_id=file_id,
+                        file_part=file_part,
+                        bytes=chunk
+                    )
+
+                await queue.put(rpc)
+
+                if is_missing_part:
+                    return
 
-                    if is_big:
-                        rpc = raw.functions.upload.SaveBigFilePart(
-                            file_id=file_id,
-                            file_part=file_part,
-                            file_total_parts=file_total_parts,
-                            bytes=chunk
-                        )
-                    else:
-                        rpc = raw.functions.upload.SaveFilePart(
-                            file_id=file_id,
-                            file_part=file_part,
-                            bytes=chunk
-                        )
+                if not is_big and not is_missing_part:
+                    md5_sum.update(chunk)
 
-                    await queue.put(rpc)
+                file_part += 1
 
-                    if is_missing_part:
-                        return
+                if progress:
+                    func = functools.partial(
+                        progress,
+                        min(file_part * part_size, file_size),
+                        file_size,
+                        *progress_args
+                    )
 
-                    if not is_big and not is_missing_part:
-                        md5_sum.update(chunk)
-
-                    file_part += 1
-
-                    if progress:
-                        func = functools.partial(
-                            progress,
-                            min(file_part * part_size, file_size),
-                            file_size,
-                            *progress_args
-                        )
-
-                        if inspect.iscoroutinefunction(progress):
-                            await func()
-                        else:
-                            await self.loop.run_in_executor(self.executor, func)
+                    if inspect.iscoroutinefunction(progress):
+                        await func()
+                    else:
+                        await self.loop.run_in_executor(self.executor, func)
         except StopTransmission:
             raise
         except Exception as e:
@@ -222,3 +221,6 @@ async def worker(session):
 
             for session in pool:
                 await session.stop()
+
+            if isinstance(path, (str, PurePath)):
+                fp.close()