hoelee/tubesync
1
0
Fork 0
mirror of https://github.com/meeb/tubesync.git synced 2025-06-23 05:26:37 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Handle multiple matches for metadata when searching by key

Browse Source
This commit is contained in:
tcely 2025-06-07 02:07:27 -04:00 committed by GitHub
parent 3c85d5531e
commit ce2dd7bbea
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 25 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
tubesync/sync/signals.py
View File

@ -435,14 +435,33 @@ def media_post_delete(sender, instance, **kwargs):
try:
if instance_qs.count():
with atomic(durable=False):
instance_qs.update(media=skipped_media)
# clear the link to a media instance
Metadata.objects.filter(media=skipped_media).update(media=None)
# choose the oldest metadata for our key
md = instance_qs.filter(
key=skipped_media.key,
).order_by(
'key',
'created',
).first()
# set the link to a media instance only on our selected metadata
log.info('Reusing old metadata for "{}": {}', skipped_media.key, skipped_media.name)
instance_qs.filter(uuid=md.uuid).update(media=skipped_media)
# delete any metadata that we are no longer using
instance_qs.exclude(uuid=md.uuid).delete()
except IntegrityError:
# this probably won't happen, but try it without a transaction
try:
with atomic(durable=False):
# Delete the new metadata
Metadata.objects.filter(media=skipped_media).delete()
instance_qs.update(media=skipped_media)
# clear the link to a media instance
Metadata.objects.filter(media=skipped_media).update(media=None)
# keep one metadata
md = instance_qs.order_by('created').first()
instance_qs.filter(uuid=md.uuid).update(media=skipped_media)
except IntegrityError as e:
log.exception('media_post_delete: could not update selected metadata: {}', e)
finally:
# Delete the old metadata, if it wasn't used
log.debug('Deleting metadata for "{}": {}', skipped_media.key, skipped_media.pk)
# delete the old metadata
instance_qs.delete()