import subprocess

from django.conf import settings

from celery import shared_task

from daiquiri.core.tasks import Task


@shared_task(base=Task)
def update_wordpress_user(username, email, first_name, last_name):

    # check if the user already exists
    try:
        subprocess.check_output([
            settings.WORDPRESS_CLI, '--path=%s' % settings.WORDPRESS_PATH,
            'user', 'get', username
        ], stderr=subprocess.STDOUT)

        # update the user
        subprocess.check_output([
            settings.WORDPRESS_CLI,
            'user',
            'update',
            username,
            '--user_email=%s' % email,
            '--first_name=%s' % first_name,
            '--last_name=%s' % last_name,
            '--path=%s' % settings.WORDPRESS_PATH
        ], stderr=subprocess.STDOUT)

    except subprocess.CalledProcessError:
        # create the wordpress user
        subprocess.check_output([
            settings.WORDPRESS_CLI,
            'user',
            'create',
            username,
            email,
            '--first_name=%s' % first_name,
            '--last_name=%s' % last_name,
            '--path=%s' % settings.WORDPRESS_PATH
        ], stderr=subprocess.STDOUT)


@shared_task(base=Task)
def update_wordpress_role(username, role):
    return subprocess.check_output([
        settings.WORDPRESS_CLI,
        'user',
        'set-role',
        username,
        role,
        '--path=%s' % settings.WORDPRESS_PATH
    ], stderr=subprocess.STDOUT)

import subprocess

from django.conf import settings

from celery import shared_task

from daiquiri.core.tasks import Task


@shared_task(base=Task)
def update_wordpress_user(username, email, first_name, last_name):
    # check if the user already exists
    try:
        subprocess.check_output([
            settings.WORDPRESS_CLI, '--path=%s' % settings.WORDPRESS_PATH,
            'user', 'get', username
        ], stderr=subprocess.STDOUT)

        # update the user
        subprocess.check_output([
            settings.WORDPRESS_CLI,
            'user',
            'update',
            username,
            '--user_email=%s' % email,
            '--first_name=%s' % first_name,
            '--last_name=%s' % last_name,
            '--path=%s' % settings.WORDPRESS_PATH
        ], stderr=subprocess.STDOUT)

    except subprocess.CalledProcessError:
        # create the wordpress user
        subprocess.check_output([
            settings.WORDPRESS_CLI,
            'user',
            'create',
            username,
            email,
            '--first_name=%s' % first_name,
            '--last_name=%s' % last_name,
            '--path=%s' % settings.WORDPRESS_PATH
        ], stderr=subprocess.STDOUT)


@shared_task(base=Task)
def update_wordpress_role(username, role):
    try:
        return subprocess.check_output([
            settings.WORDPRESS_CLI,
            'user',
            'set-role',
            username,
            role,
            '--path=%s' % settings.WORDPRESS_PATH
        ], stderr=subprocess.STDOUT)

    except subprocess.CalledProcessError:
        pass

Fix update_wordpress_role