Compare commits

..
2 Commits
+13 -10
View File
@@ -98,7 +98,6 @@ def sync_recordings(
{"id": recording.id, "path": recording.path} {"id": recording.id, "path": recording.path}
) )
result.files_checked += recordings_count
result.orphans_found += len(recordings_to_delete) result.orphans_found += len(recordings_to_delete)
result.orphan_paths.extend( result.orphan_paths.extend(
[ [
@@ -173,7 +172,7 @@ def sync_recordings(
for file in files for file in files
} }
result.files_checked += len(files_on_disk) result.files_checked = len(files_on_disk)
files_to_delete: list[str] = [] files_to_delete: list[str] = []
for file in files_on_disk: for file in files_on_disk:
@@ -198,16 +197,20 @@ def sync_recordings(
result.aborted = True result.aborted = True
return result return result
if files_to_delete and not dry_run: if dry_run:
logger.info( logger.info(
f"Deleting {len(files_to_delete)} recordings files with missing DB entries" f"Recordings sync (dry run): Found {len(files_to_delete)} orphaned files"
) )
for file in files_to_delete: return result
try:
os.unlink(file) # Delete orphans
result.orphans_deleted += 1 logger.info(f"Deleting {len(files_to_delete)} orphaned recordings files")
except OSError as e: for file in files_to_delete:
logger.error(f"Failed to delete {file}: {e}") try:
os.unlink(file)
result.orphans_deleted += 1
except OSError as e:
logger.error(f"Failed to delete {file}: {e}")
logger.debug("End sync recordings.") logger.debug("End sync recordings.")