"""Celery task for async export."""

from io import BytesIO
from time import gmtime, strftime

from celery import shared_task
from flask import current_app, request
from flask_login import login_user
from six.moves.urllib.parse import urlparse
from werkzeug.utils import import_string

from abilian.core.models.subjects import User

from .util import XLSX_MIME

DEFAULT_EXPIRES = 1800  # generally user will not wait 1/2h. No need to process
# this long task


@shared_task(
    bind=True, track_started=True, ignore_result=False, expires=DEFAULT_EXPIRES
)
def export(self, app, module, from_url, user_id, component="excel", manager=None):
    """Async export xls task.

    :param app: `CRUDApp` name

    :param module: module id

    :param from_url: full url that started this task

    :param user_id: user's id for who this task is run
    """
    user = User.query.get(user_id)
    crud_app = current_app.extensions[app]
    module = crud_app.get_module(module)
    component = module.get_component(component)
    url = urlparse(from_url)
    rq_ctx = current_app.test_request_context(
        base_url="{url.scheme}://{url.netloc}/{url.path}".format(url=url),
        path=url.path,
        query_string=url.query,
    )

    def progress_callback(exported=0, total=0, **kw):
        self.update_state(state="PROGRESS", meta={"exported": exported, "total": total})

    uploads = current_app.extensions["uploads"]

    with rq_ctx:
        login_user(user)
        objects = module.ordered_query(request)
        related_cs = None
        if manager is not None:
            manager = import_string(manager)
        else:
            manager = component.excel_manager

        manager = manager(
            module.managed_class, component.export_form, component.EXCEL_EXPORT_RELATED
        )

        if "related" in request.args:
            related = request.args["related"]
            related_cs = filter(
                lambda cs: cs.related_attr == related, component.EXCEL_EXPORT_RELATED
            )
            try:
                related_cs = next(related_cs)
            except StopIteration:
                related_cs = None

        workbook = manager.export(
            objects, related_cs, progress_callback=progress_callback
        )
        fd = BytesIO()
        workbook.save(fd)
        fd.seek(0)
        # save in uploads dir, return handle needed for download
        filename = "{}-{}.xlsx".format(
            module.managed_class.__name__, strftime("%d:%m:%Y-%H:%M:%S", gmtime())
        )
        handle = uploads.add_file(user, fd, filename=filename, mimetype=XLSX_MIME)
        return dict(handle=handle)

d6cb40dc62e3c5abc6e7836c14296fe6140260d3
<mask token>

<mask token>


@shared_task(bind=True, track_started=True, ignore_result=False, expires=
    DEFAULT_EXPIRES)
def export(self, app, module, from_url, user_id, component='excel', manager
    =None):
    """Async export xls task.

    :param app: `CRUDApp` name

    :param module: module id

    :param from_url: full url that started this task

    :param user_id: user's id for who this task is run
    """
    user = User.query.get(user_id)
    crud_app = current_app.extensions[app]
    module = crud_app.get_module(module)
    component = module.get_component(component)
    url = urlparse(from_url)
    rq_ctx = current_app.test_request_context(base_url=
        '{url.scheme}://{url.netloc}/{url.path}'.format(url=url), path=url.
        path, query_string=url.query)

    def progress_callback(exported=0, total=0, **kw):
        self.update_state(state='PROGRESS', meta={'exported': exported,
            'total': total})
    uploads = current_app.extensions['uploads']
    with rq_ctx:
        login_user(user)
        objects = module.ordered_query(request)
        related_cs = None
        if manager is not None:
            manager = import_string(manager)
        else:
            manager = component.excel_manager
        manager = manager(module.managed_class, component.export_form,
            component.EXCEL_EXPORT_RELATED)
        if 'related' in request.args:
            related = request.args['related']
            related_cs = filter(lambda cs: cs.related_attr == related,
                component.EXCEL_EXPORT_RELATED)
            try:
                related_cs = next(related_cs)
            except StopIteration:
                related_cs = None
        workbook = manager.export(objects, related_cs, progress_callback=
            progress_callback)
        fd = BytesIO()
        workbook.save(fd)
        fd.seek(0)
        filename = '{}-{}.xlsx'.format(module.managed_class.__name__,
            strftime('%d:%m:%Y-%H:%M:%S', gmtime()))
        handle = uploads.add_file(user, fd, filename=filename, mimetype=
            XLSX_MIME)
        return dict(handle=handle)

<mask token>
DEFAULT_EXPIRES = 1800


@shared_task(bind=True, track_started=True, ignore_result=False, expires=
    DEFAULT_EXPIRES)
def export(self, app, module, from_url, user_id, component='excel', manager
    =None):
    """Async export xls task.

    :param app: `CRUDApp` name

    :param module: module id

    :param from_url: full url that started this task

    :param user_id: user's id for who this task is run
    """
    user = User.query.get(user_id)
    crud_app = current_app.extensions[app]
    module = crud_app.get_module(module)
    component = module.get_component(component)
    url = urlparse(from_url)
    rq_ctx = current_app.test_request_context(base_url=
        '{url.scheme}://{url.netloc}/{url.path}'.format(url=url), path=url.
        path, query_string=url.query)

    def progress_callback(exported=0, total=0, **kw):
        self.update_state(state='PROGRESS', meta={'exported': exported,
            'total': total})
    uploads = current_app.extensions['uploads']
    with rq_ctx:
        login_user(user)
        objects = module.ordered_query(request)
        related_cs = None
        if manager is not None:
            manager = import_string(manager)
        else:
            manager = component.excel_manager
        manager = manager(module.managed_class, component.export_form,
            component.EXCEL_EXPORT_RELATED)
        if 'related' in request.args:
            related = request.args['related']
            related_cs = filter(lambda cs: cs.related_attr == related,
                component.EXCEL_EXPORT_RELATED)
            try:
                related_cs = next(related_cs)
            except StopIteration:
                related_cs = None
        workbook = manager.export(objects, related_cs, progress_callback=
            progress_callback)
        fd = BytesIO()
        workbook.save(fd)
        fd.seek(0)
        filename = '{}-{}.xlsx'.format(module.managed_class.__name__,
            strftime('%d:%m:%Y-%H:%M:%S', gmtime()))
        handle = uploads.add_file(user, fd, filename=filename, mimetype=
            XLSX_MIME)
        return dict(handle=handle)

<mask token>
from io import BytesIO
from time import gmtime, strftime
from celery import shared_task
from flask import current_app, request
from flask_login import login_user
from six.moves.urllib.parse import urlparse
from werkzeug.utils import import_string
from abilian.core.models.subjects import User
from .util import XLSX_MIME
DEFAULT_EXPIRES = 1800


@shared_task(bind=True, track_started=True, ignore_result=False, expires=
    DEFAULT_EXPIRES)
def export(self, app, module, from_url, user_id, component='excel', manager
    =None):
    """Async export xls task.

    :param app: `CRUDApp` name

    :param module: module id

    :param from_url: full url that started this task

    :param user_id: user's id for who this task is run
    """
    user = User.query.get(user_id)
    crud_app = current_app.extensions[app]
    module = crud_app.get_module(module)
    component = module.get_component(component)
    url = urlparse(from_url)
    rq_ctx = current_app.test_request_context(base_url=
        '{url.scheme}://{url.netloc}/{url.path}'.format(url=url), path=url.
        path, query_string=url.query)

    def progress_callback(exported=0, total=0, **kw):
        self.update_state(state='PROGRESS', meta={'exported': exported,
            'total': total})
    uploads = current_app.extensions['uploads']
    with rq_ctx:
        login_user(user)
        objects = module.ordered_query(request)
        related_cs = None
        if manager is not None:
            manager = import_string(manager)
        else:
            manager = component.excel_manager
        manager = manager(module.managed_class, component.export_form,
            component.EXCEL_EXPORT_RELATED)
        if 'related' in request.args:
            related = request.args['related']
            related_cs = filter(lambda cs: cs.related_attr == related,
                component.EXCEL_EXPORT_RELATED)
            try:
                related_cs = next(related_cs)
            except StopIteration:
                related_cs = None
        workbook = manager.export(objects, related_cs, progress_callback=
            progress_callback)
        fd = BytesIO()
        workbook.save(fd)
        fd.seek(0)
        filename = '{}-{}.xlsx'.format(module.managed_class.__name__,
            strftime('%d:%m:%Y-%H:%M:%S', gmtime()))
        handle = uploads.add_file(user, fd, filename=filename, mimetype=
            XLSX_MIME)
        return dict(handle=handle)

"""Celery task for async export."""

from io import BytesIO
from time import gmtime, strftime

from celery import shared_task
from flask import current_app, request
from flask_login import login_user
from six.moves.urllib.parse import urlparse
from werkzeug.utils import import_string

from abilian.core.models.subjects import User

from .util import XLSX_MIME

DEFAULT_EXPIRES = 1800  # generally user will not wait 1/2h. No need to process
# this long task


@shared_task(
    bind=True, track_started=True, ignore_result=False, expires=DEFAULT_EXPIRES
)
def export(self, app, module, from_url, user_id, component="excel", manager=None):
    """Async export xls task.

    :param app: `CRUDApp` name

    :param module: module id

    :param from_url: full url that started this task

    :param user_id: user's id for who this task is run
    """
    user = User.query.get(user_id)
    crud_app = current_app.extensions[app]
    module = crud_app.get_module(module)
    component = module.get_component(component)
    url = urlparse(from_url)
    rq_ctx = current_app.test_request_context(
        base_url="{url.scheme}://{url.netloc}/{url.path}".format(url=url),
        path=url.path,
        query_string=url.query,
    )

    def progress_callback(exported=0, total=0, **kw):
        self.update_state(state="PROGRESS", meta={"exported": exported, "total": total})

    uploads = current_app.extensions["uploads"]

    with rq_ctx:
        login_user(user)
        objects = module.ordered_query(request)
        related_cs = None
        if manager is not None:
            manager = import_string(manager)
        else:
            manager = component.excel_manager

        manager = manager(
            module.managed_class, component.export_form, component.EXCEL_EXPORT_RELATED
        )

        if "related" in request.args:
            related = request.args["related"]
            related_cs = filter(
                lambda cs: cs.related_attr == related, component.EXCEL_EXPORT_RELATED
            )
            try:
                related_cs = next(related_cs)
            except StopIteration:
                related_cs = None

        workbook = manager.export(
            objects, related_cs, progress_callback=progress_callback
        )
        fd = BytesIO()
        workbook.save(fd)
        fd.seek(0)
        # save in uploads dir, return handle needed for download
        filename = "{}-{}.xlsx".format(
            module.managed_class.__name__, strftime("%d:%m:%Y-%H:%M:%S", gmtime())
        )
        handle = uploads.add_file(user, fd, filename=filename, mimetype=XLSX_MIME)
        return dict(handle=handle)
