Mercurial > public > sg101
view downloads/signals.py @ 697:67f8d49a9377
Cleaned up the code a bit.
Separated the S3 stuff out into its own class.
This class maybe should be in core.
Still want to do some kind of context manager around the temporary file we are
creating to ensure it gets deleted.
author | Brian Neal <bgneal@gmail.com> |
---|---|
date | Sun, 08 Sep 2013 21:02:58 -0500 |
parents | 929d0e637a37 |
children |
line wrap: on
line source
"""Signals 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.signals') post_delete.connect(on_download_delete, sender=Download, dispatch_uid='downloads.signals') post_delete.connect(on_pending_download_delete, sender=PendingDownload, dispatch_uid='downloads.signals')