from collections import namedtuple

from django.core.management.base import BaseCommand
from tqdm import tqdm

Progress = namedtuple(
    'Progress',
    [
        'progress_fraction',
        'message',
        'extra_data',
        'level',
    ]
)


class ProgressTracker():

    def __init__(self, total=100, level=0, update_callback=None):

        # set default values
        self.progress = 0
        self.message = ""
        self.extra_data = None

        # store provided arguments
        self.total = total
        self.level = level
        self.update_callback = update_callback

        # initialize the tqdm progress bar
        self.progressbar = tqdm(total=total)

    def update_progress(self, increment=1, message="", extra_data=None):

        self.progressbar.update(increment)

        self.progress += increment

        self.message = message

        self.extra_data = extra_data

        if callable(self.update_callback):
            p = self.get_progress()
            self.update_callback(p.progress_fraction, p)

    def get_progress(self):

        return Progress(
            progress_fraction=0 if self.total == 0 else self.progress / float(self.total),
            message=self.message,
            extra_data=self.extra_data,
            level=self.level,
        )

    def __enter__(self):
        return self.update_progress

    def __exit__(self, *exc_details):
        if self.progressbar is not None:
            self.progressbar.close()


class AsyncCommand(BaseCommand):
    """A management command with added convenience functions for displaying
    progress to the user.

    Rather than implementing handle() (as is for BaseCommand), subclasses, must
    implement handle_async(), which accepts the same arguments as handle().

    If ran from the command line, AsynCommand displays a progress bar to the
    user. If ran asynchronously through kolibri.tasks.schedule_command(),
    AsyncCommand sends results through the Progress class to the main Django
    process. Anyone who knows the task id for the command instance can check
    the intermediate progress by looking at the task's AsyncResult.result
    variable.

    """

    def __init__(self, *args, **kwargs):
        self.progresstrackers = []

    def _update_all_progress(self, progress_fraction, progress):
        if callable(self.update_progress):
            progress_list = [p.get_progress() for p in self.progresstrackers]
            self.update_progress(progress_list[0].progress_fraction, progress_list)

    def handle(self, *args, **options):
        self.update_progress = options.pop("update_progress", None)
        return self.handle_async(*args, **options)

    def start_progress(self, total=100):
        level = len(self.progresstrackers)
        tracker = ProgressTracker(total=total, level=level, update_callback=self._update_all_progress)
        self.progresstrackers.append(tracker)
        return tracker

@@ -2441,32 +2441,47 @@
 ers%5D%0A           
+ # HACK (aron):
  self.update_pro
@@ -2489,58 +2489,287 @@
 ress
-(progress_list%5B0%5D.progress_fraction, progress_list
+' signature has changed between django_q%0A            # and iceqube/bbq. It now expects the current progress,%0A            # the total progress, and then derives the%0A            # percentage progress manually.%0A            self.update_progress(progress_list%5B0%5D.progress_fraction, 1.
 )%0A%0A 

use the API that the new update_progress command expects.