"""
Daily cleanup job.

Can be run as a cronjob to clean out old data from the database (only expired
sessions at the moment).
"""

from django_extensions.management.jobs import DailyJob

class Job(DailyJob):
    help = "Cache (db) cleanup Job"

    def execute(self):
        from django.conf import settings
        import os

        if settings.CACHE_BACKEND.startswith('db://'):
            os.environ['TZ'] = settings.TIME_ZONE
            table_name = settings.CACHE_BACKEND[5:]
            cursor = connection.cursor()
            cursor.execute("DELETE FROM %s WHERE %s < UTC_TIMESTAMP()" % \
                (backend.quote_name(table_name), backend.quote_name('expires')))
            transaction.commit_unless_managed()