from flask import request, Blueprint, send_from_directory, current_app as app
import requests
import os
from werkzeug.exceptions import HTTPException
from .responses import send_message, send_error
from .sessionJWT import create_auth_token, check_auth_token


# Request Post
def request_post(url, data_json):
    return requests.post(app.config['API_URL'] + url, json=data_json)


# Request Put
def request_put(url, data_json):
    return requests.put(app.config['API_URL'] + url, json=data_json)


# Request Get
def request_get(url):
    return requests.get(app.config['API_URL'] + url)


# Request Delete
def request_delete(url, data_json):
    return requests.delete(app.config['API_URL'] + url, json=data_json)


bp = Blueprint('myapp', __name__)


@bp.app_errorhandler(HTTPException)
def handle_exception(e):
    return send_error(e.code, e.name)


@bp.route('/', methods=['GET'])
def root():
    return send_from_directory("frontend/dist", "index.html")


@bp.route('/frontend/dist/<path:path>', methods=['GET'])
def static(path):
    return send_from_directory("frontend/dist", path)


@bp.route('/assets/<path:path>', methods=['GET'])
def assets(path):
    return send_from_directory("frontend/dist/assets", path)


# Login
@bp.route('/api/login', methods=['POST'])
def login():
    post_json = request.json
    try:
        post_email = str(post_json['email'])
        post_password = str(post_json['password'])
        if post_email != '' and post_password != '':
            ip = request.remote_addr
            # res = db_login(ip, post_email, post_password)
            res = request_post('login', {'ip': ip, 'email': post_email, 'password': post_password}).json()
            if res['status'] == 'success':
                user = res['data']
                token = create_auth_token(user)
                return send_message(res['message'], user, token)
            elif res['status'] == 'error':
                user = None
                token = create_auth_token(user)
                return send_error(400, res['message'], token)
        else:
            return send_error(400, 'Empty email and/or password fields.')
    except KeyError as e:
        return send_error(400, 'Need email, password fields.')


# Register
@bp.route('/api/register', methods=['POST'])
def register():
    post_json = request.json
    try:
        post_email = str(post_json['email'])
        post_nickname = str(post_json['nickname'])
        post_password = str(post_json['password'])
        if post_email != '' and post_password != '' and post_nickname != '':
            ip = request.remote_addr
            # res = db_register(ip, post_email, post_nickname, post_password)
            res = request_post('register', {'ip': ip, 'email': post_email, 'nickname': post_nickname,
                                            'password': post_password}).json()
            if res['status'] == 'error':
                return send_error(500, res['message'])
            elif res['status'] == 'success':
                return send_message(res['message'], res['data'])
        else:
            return send_error(400, 'Empty email and/or password and/or nickname fields.')
    except KeyError as e:
        return send_error(400, 'Need ' + str(e) + 'field.')


# Logout
@bp.route('/api/logout', methods=['DELETE'])
def logout():
    token = check_auth_token(request)
    if token['success']:
        ip = request.remote_addr
        user_id = token['payload']['id']
        res = request_delete('logout', {'ip': ip, 'user_id': user_id}).json()
        return send_message(res['message'], None, token_delete=True)
    else:
        return send_error(500, token['message'])


# Update User (Nickname, Password)
@bp.route('/api/user/update', methods=['PUT'])
def user_update():
    token = check_auth_token(request)
    if token['success']:
        post_json = request.json
        post_nickname = None
        post_password = None
        fields = ''
        if 'nickname' in post_json:
            post_nickname = str(post_json['nickname'])
        else:
            fields += 'nickname '

        if 'password' in post_json:
            post_password = str(post_json['password'])
        else:
            fields += 'password '

        if post_nickname is not None or post_password is not None:
            if post_nickname != '' and post_password != '':
                ip = request.remote_addr
                user_id = token['payload']['id']
                # res = db_user_update(ip, user_id, post_nickname, post_password)
                res = request_put('user/update', {'ip': ip, 'user_id': user_id, 'nickname': post_nickname,
                                                   'password': post_password}).json()
                if res['status'] == 'error':
                    return send_error(500, res['message'])
                elif res['status'] == 'success':
                    return send_message(res['message'], res['data'])
            else:
                return send_error(400, 'Empty nickname and/or password fields.')
        else:
            return send_error(400, 'Need ' + fields + 'field.')
    else:
        return send_error(500, token['message'])


# Delete User
@bp.route('/api/user/delete', methods=['DELETE'])
def user_delete():
    token = check_auth_token(request)
    if token['success']:
        ip = request.remote_addr
        user_id = token['payload']['id']
        # res = db_user_delete(ip, user_id)
        res = request_delete('user/delete', {'ip': ip, 'user_id': user_id}).json()
        if res['status'] != 'success':
            return send_error(500, res['message'])
        else:
            return send_message(res['message'], None, token_delete=True)
    else:
        return send_error(500, token['message'])


# Admin : Create User
@bp.route('/api/admin/create/user', methods=['POST'])
def admin_create_user():
    token = check_auth_token(request)
    if token['success']:
        ip = request.remote_addr
        user_id = token['payload']['id']
        is_admin = token['payload']['is_admin']
        if is_admin:
            post_json = request.json
            post_email = None
            post_nickname = None
            post_password = None
            post_is_admin = None
            fields = ''
            if 'email' in post_json:
                post_email = str(post_json['email'])
            else:
                fields += 'email '

            if 'nickname' in post_json:
                post_nickname = str(post_json['nickname'])
            else:
                fields += 'nickname '

            if 'password' in post_json:
                post_password = str(post_json['password'])
            else:
                fields += 'password '

            if 'is_admin' in post_json:
                post_is_admin = bool(post_json['is_admin'])
            else:
                fields += 'is_admin '

            if post_email is not None or post_nickname is not None or post_password is not None or post_is_admin is not None:
                if post_email != '' and post_nickname != '' and post_password != '' and str(post_is_admin) != '':
                    # res = db_register(ip, post_email, post_nickname, post_password, is_admin=post_is_admin)
                    res = request_post('admin/create/user', {
                        'ip': ip,
                        'user_id': user_id,
                        'token_is_admin': is_admin,
                        'email': post_email,
                        'nickname': post_nickname,
                        'password': post_password,
                        'is_admin': post_is_admin
                    }).json()
                    if res['status'] == 'error':
                        return send_error(500, res['message'])
                    elif res['status'] == 'success':
                        return send_message(res['message'], res['data'])
                else:
                    return send_error(400, 'Empty email and/or nickname and/or password and/or is_admin fields.')
            else:
                return send_error(400, 'Need ' + fields + 'field.')
        else:
            return send_error(500, 'User does not have permission.')
    else:
        return send_error(500, token['message'])


# Admin : Change User password and/or role
@bp.route('/api/admin/update/user', methods=['PUT'])
def admin_update_user():
    token = check_auth_token(request)
    if token['success']:
        user_id = token['payload']['id']
        is_admin = token['payload']['is_admin']
        if is_admin:
            post_json = request.json
            post_is_admin = None
            post_password = None
            post_user_id_delete = None
            fields = ''
            if 'id' in post_json:
                post_user_id_delete = int(post_json['id'])
            else:
                fields += 'id '

            if 'is_admin' in post_json:
                post_is_admin = bool(post_json['is_admin'])
            else:
                fields += 'is_admin '

            if 'password' in post_json:
                post_password = str(post_json['password'])
            else:
                fields += 'password '

            if post_user_id_delete is not None and (post_is_admin is not None or post_password is not None):
                if str(post_is_admin) != '' and post_password != '' and str(post_user_id_delete) != '':
                    ip = request.remote_addr
                    # res = db_admin_update_user(ip, post_user_id_delete, post_is_admin, post_password)
                    res = request_put('admin/update/user', {
                        'ip': ip,
                        'user_id': user_id,
                        'token_is_admin': is_admin,
                        'id': post_user_id_delete,
                        'is_admin': post_is_admin,
                        'password': post_password
                    }).json()
                    if res['status'] == 'error':
                        return send_error(500, res['message'])
                    elif res['status'] == 'success':
                        return send_message(res['message'], res['data'])
                else:
                    return send_error(400, 'Empty is_admin and/or password fields.')
            else:
                return send_error(400, 'Need ' + fields + 'field.')
        else:
            return send_error(500, 'User does not have permission.')
    else:
        return send_error(500, token['message'])


# Admin : Delete User
@bp.route('/api/admin/delete/user/<id>', methods=['DELETE'])
def admin_delete_user(id):
    token = check_auth_token(request)
    if token['success']:
        ip = request.remote_addr
        user_id = token['payload']['id']
        is_admin = token['payload']['is_admin']
        if is_admin:
            post_json = {'id': id}
            post_user_id_delete = None
            fields = ''
            if 'id' in post_json:
                post_user_id_delete = int(post_json['id'])
            else:
                fields += 'id'
            if post_user_id_delete is not None:
                if str(post_user_id_delete) != '':
                    # res = db_user_delete(ip, int(post_user_id_delete))
                    res = request_delete('admin/delete/user', {
                        'ip': ip,
                        'user_id': user_id,
                        'token_is_admin': is_admin,
                        'id': post_user_id_delete
                    }).json()
                    if res['status'] == 'error':
                        return send_error(500, res['message'])
                    else:
                        return send_message(res['message'], None)
                else:
                    return send_error(400, 'Empty id field.')
            else:
                return send_error(400, 'Need ' + fields + 'field.')
        else:
            return send_error(500, 'User does not have permission.')
    else:
        return send_error(500, token['message'])


# List of User (must be authenticated) & Search
@bp.route('/api/users', methods=['GET'])
def users():
    token = check_auth_token(request)
    if token['success']:
        ip = request.remote_addr
        user_id = token['payload']['id']

        filter = ''
        get_query = request.args.get('q')
        if get_query is not None:
            filter += f'&q={get_query}'

        get_by = request.args.get('by')
        if get_by is not None:
            filter += f'&by={get_by}'

        get_id = request.args.get('id')
        if get_id is not None:
            filter += f'&id={get_id}'

        get_is_admin = request.args.get('is_admin')
        if get_is_admin is not None:
            filter += f'&is_admin={get_is_admin}'

        get_order_by = request.args.get('order_by')
        if get_order_by is not None:
            filter += f'&order_by={get_order_by}'
        # res = db_users(ip, user_id, get_query, get_by, get_id, get_is_admin, get_order_by)
        res = request_get(
            'users'
            f'?ip={ip}'
            f'&user_id={user_id}'
            f'{filter}'
        ).json()
        if res['status'] == 'error':
            return send_error(500, res['message'])
        else:
            return send_message(res['message'], res['data'])
    else:
        return send_error(500, token['message'])