StuffAnThings/qbit_manage
1
1
Fork 0
mirror of https://github.com/StuffAnThings/qbit_manage.git synced 2025-11-10 08:20:49 +08:00
Code Issues Projects Releases Packages Wiki Activity

Update prints

Browse source
This commit is contained in:
buthed010203 2023-04-17 17:15:37 -04:00 • committed by GitHub
parent 8d8e171b81
commit d2f22b3370
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
modules/core/remove_orphaned.py
View file

@ -52,9 +52,8 @@ class RemoveOrphaned:
] ]
# Get an updated list of torrents # Get an updated list of torrents
logger.print_line("Removing torrent files from orphans", self.config.loglevel) logger.print_line("Locating orphan files", self.config.loglevel)
torrent_list = self.qbt.get_torrents({"sort": "added_on"}) torrent_list = self.qbt.get_torrents({"sort": "added_on"})
logger.print_line("Fetched torrents", self.config.loglevel)
for torrent in torrent_list: for torrent in torrent_list:
for file in torrent.files: for file in torrent.files:
fullpath = os.path.join(torrent.save_path, file.name) fullpath = os.path.join(torrent.save_path, file.name)
@ -84,7 +83,7 @@ class RemoveOrphaned:
logger.print_line(f"{num_orphaned} Orphaned files found", self.config.loglevel) logger.print_line(f"{num_orphaned} Orphaned files found", self.config.loglevel)
body += logger.print_line("\n".join(orphaned_files), self.config.loglevel) body += logger.print_line("\n".join(orphaned_files), self.config.loglevel)
body += logger.print_line( body += logger.print_line(
f"{'Did not move' if self.config.dry_run else 'Moved'} {num_orphaned} Orphaned files " f"{'Not moving' if self.config.dry_run else 'Moving'} {num_orphaned} Orphaned files "
f"to {self.orphaned_dir.replace(self.remote_dir,self.root_dir)}", f"to {self.orphaned_dir.replace(self.remote_dir,self.root_dir)}",
self.config.loglevel, self.config.loglevel,
) )
@ -99,12 +98,11 @@ class RemoveOrphaned:
} }
self.config.send_notifications(attr) self.config.send_notifications(attr)
# Delete empty directories after moving orphan files # Delete empty directories after moving orphan files
logger.info("Cleaning up any empty directories...")
if not self.config.dry_run: if not self.config.dry_run:
with Pool(processes=cpu_count()) as pool: with Pool(processes=cpu_count()) as pool:
orphaned_parent_path = set(pool.map(move_orphan, orphaned_files)) orphaned_parent_path = set(pool.map(move_orphan, orphaned_files))
logger.print_line("Removing orphan dirs", self.config.loglevel) logger.print_line("Removing newly empty directories", self.config.loglevel)
pool.starmap(util.remove_empty_directories, zip(orphaned_parent_path, repeat("**/*"))) pool.starmap(util.remove_empty_directories, zip(orphaned_parent_path, repeat("**/*")))
else: else:
logger.print_line("No Orphaned Files found.", self.config.loglevel) logger.print_line("No Orphaned Files found.", self.config.loglevel)