prepareuserdatadownloads.py 2.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455
  1. import logging
  2. from django.core.management.base import BaseCommand
  3. from django.utils.translation import gettext
  4. from misago.cache.versions import get_cache_versions
  5. from misago.conf import settings
  6. from misago.conf.dynamicsettings import DynamicSettings
  7. from misago.core.mail import mail_user
  8. from misago.core.pgutils import chunk_queryset
  9. from misago.users.datadownloads import prepare_user_data_download
  10. from misago.users.models import DataDownload
  11. logger = logging.getLogger("misago.users.datadownloads")
  12. class Command(BaseCommand):
  13. help = "Prepares user data downloads."
  14. leave_locale_alone = True
  15. def handle(self, *args, **options):
  16. working_dir = settings.MISAGO_USER_DATA_DOWNLOADS_WORKING_DIR
  17. if not working_dir:
  18. self.stdout.write(
  19. "MISAGO_USER_DATA_DOWNLOADS_WORKING_DIR has to be set in order for "
  20. "this feature to work."
  21. )
  22. return
  23. cache_versions = get_cache_versions()
  24. dynamic_settings = DynamicSettings(cache_versions)
  25. downloads_prepared = 0
  26. queryset = DataDownload.objects.select_related("user")
  27. queryset = queryset.filter(status=DataDownload.STATUS_PENDING)
  28. for data_download in chunk_queryset(queryset):
  29. if prepare_user_data_download(data_download, logger):
  30. user = data_download.user
  31. subject = gettext("%(user)s, your data download is ready") % {
  32. "user": user
  33. }
  34. mail_user(
  35. user,
  36. subject,
  37. "misago/emails/data_download",
  38. context={
  39. "data_download": data_download,
  40. "expires_in": settings.MISAGO_USER_DATA_DOWNLOADS_EXPIRE_IN_HOURS,
  41. "settings": dynamic_settings,
  42. },
  43. )
  44. downloads_prepared += 1
  45. self.stdout.write("Data downloads prepared: %s" % downloads_prepared)