Mercurial > public > sg101
diff downloads/receivers.py @ 922:1a832625c047
Downloads app refactor.
For Django 1.7.7 upgrade.
author | Brian Neal <bgneal@gmail.com> |
---|---|
date | Tue, 07 Apr 2015 20:20:42 -0500 |
parents | downloads/signals.py@929d0e637a37 |
children |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/downloads/receivers.py Tue Apr 07 20:20:42 2015 -0500 @@ -0,0 +1,63 @@ +"""Signal handlers for the downloads application. + +We use signals to compute the denormalized category counts whenever a download +is saved. + +""" +from django.db.models.signals import post_save +from django.db.models.signals import post_delete + +from downloads.models import Category, Download, PendingDownload + + +def on_download_save(sender, **kwargs): + """This function updates the count field for all categories. + It is called whenever a download is saved via a signal. + """ + if kwargs['created']: + # we only have to update the parent category + download = kwargs['instance'] + cat = download.category + cat.count = Download.public_objects.filter(category=cat).count() + cat.save() + else: + # update all categories just to be safe (an existing download could + # have been moved from one category to another + cats = Category.objects.all() + for cat in cats: + cat.count = Download.public_objects.filter(category=cat).count() + cat.save() + + +def on_download_delete(sender, **kwargs): + """This function updates the count field for the download's parent + category. It is called when a download is deleted via a signal. + + We now delete the uploaded file when the download is deleted. + """ + # update the parent category + download = kwargs['instance'] + cat = download.category + cat.count = Download.public_objects.filter(category=cat).count() + cat.save() + + # delete the actual file + if download.file: + download.file.delete(save=False) + + +def on_pending_download_delete(sender, **kwargs): + """Delete the uploaded file if it exists.""" + + download = kwargs['instance'] + # delete the actual file + if download.file: + download.file.delete(save=False) + + +post_save.connect(on_download_save, sender=Download, + dispatch_uid='downloads.receivers') +post_delete.connect(on_download_delete, sender=Download, + dispatch_uid='downloads.receivers') +post_delete.connect(on_pending_download_delete, sender=PendingDownload, + dispatch_uid='downloads.receivers')