from datetime import datetime, timedelta

from celery.task import task

from .constants import VALIDATION_ASKED
from .models import (MangoPayUser, MangoPayBankAccount,
                     MangoPayDocument, MangoPayWallet, MangoPayPayOut)


@task
def create_mangopay_user(id):
    MangoPayUser.objects.select_subclasses().get(
        id=id, mangopay_id__isnull=True).create()


@task
def update_mangopay_user(id):
    MangoPayUser.objects.select_subclasses().get(
        id=id, mangopay_id__isnull=False).update()


@task
def create_mangopay_bank_account(id):
    MangoPayBankAccount.objects.get(id=id, mangopay_id__isnull=True).create()


@task
def create_mangopay_document_and_pages_and_ask_for_validation(id):
    document = MangoPayDocument.objects.get(
        id=id, mangopay_id__isnull=True, file__isnull=False,
        type__isnull=False)
    document.create()
    for page in document.mangopay_pages.all():
        page.create()
    document.ask_for_validation()
    eta = next_weekday()
    update_document_status.apply_async((), {"id": id}, eta=eta)


def next_weekday():
    def maybe_add_day(date):
        if datetime.weekday(date) > 6:
            date = date + timedelta(days=1)
            return maybe_add_day(date)
        else:
            return date
    return maybe_add_day(datetime.now() + timedelta(days=1))


@task
def update_document_status(id):
    document = MangoPayDocument.objects.get(id=id, status=VALIDATION_ASKED)
    updated_document = document.get()
    if updated_document.status == VALIDATION_ASKED:
        eta = next_weekday()
        update_document_status.apply_async((), {"id": id}, eta=eta)


@task
def create_mangopay_wallet(id, currency, description=""):
    wallet = MangoPayWallet.objects.get(id=id, mangopay_id__isnull=True)
    wallet.create(currency=currency, description=description)


@task
def create_mangopay_pay_out(id, tag=''):
    payout = MangoPayPayOut.objects.get(id=id, mangopay_id__isnull=True)
    payout.create(tag)
    eta = next_weekday()
    update_mangopay_pay_out.apply_async((), {"id": id}, eta=eta)


@task
def update_mangopay_pay_out(id):
    payout = MangoPayPayOut.objects.get(id=id, mangopay_id__isnull=False)
    payout = payout.get()
    if not payout.status or payout.status == "CREATED":
        eta = next_weekday()
        update_mangopay_pay_out.apply_async((), {"id": id}, eta=eta)

@@ -797,36 +797,8 @@
 rue,
- file__isnull=False,%0A       
  typ

Remove incorrect keyword argument to fix document creation