mirror of
https://github.com/zoriya/Kyoo.git
synced 2025-07-08 10:44:20 -04:00
fix: reorder delete/register
This commit is contained in:
parent
6992de5e2f
commit
46543d1f74
@ -49,14 +49,19 @@ async def scan(
|
|||||||
to_register = videos - registered
|
to_register = videos - registered
|
||||||
to_delete = registered - videos if remove_deleted else set()
|
to_delete = registered - videos if remove_deleted else set()
|
||||||
|
|
||||||
if to_register:
|
if not any(to_register) and any(to_delete) and len(to_delete) == len(registered):
|
||||||
logger.info("Found %d new files to register.", len(to_register))
|
logger.warning("All video files are unavailable. Check your disks.")
|
||||||
await asyncio.gather(*[publisher.add(path) for path in to_register])
|
return
|
||||||
|
|
||||||
|
# delete stale files before creating new ones to prevent potential conflicts
|
||||||
if to_delete:
|
if to_delete:
|
||||||
logger.info("Removing %d stale files.", len(to_delete))
|
logger.info("Removing %d stale files.", len(to_delete))
|
||||||
await asyncio.gather(*[publisher.delete(path) for path in to_delete])
|
await asyncio.gather(*[publisher.delete(path) for path in to_delete])
|
||||||
|
|
||||||
|
if to_register:
|
||||||
|
logger.info("Found %d new files to register.", len(to_register))
|
||||||
|
await asyncio.gather(*[publisher.add(path) for path in to_register])
|
||||||
|
|
||||||
if remove_deleted:
|
if remove_deleted:
|
||||||
issues = set(await client.get_issues())
|
issues = set(await client.get_issues())
|
||||||
issues_to_delete = issues - videos
|
issues_to_delete = issues - videos
|
||||||
|
Loading…
x
Reference in New Issue
Block a user