# Python imports
import os

# Lib imports
from flask import redirect
from flask import request
from flask import render_template
from flask import send_from_directory

# App imports
                                            # Get from __init__
from core import app
from core import db
from core import Favorites
from core import oidc

from core.utils import MessageHandler       # Get simple message processor



json_message = MessageHandler()



@app.route('/', methods=['GET', 'POST'])
def home():
    if request.method == 'GET':
        view               = get_view()
        _dot_dots          = view.get_dot_dots()
        _current_directory = view.get_current_directory()
        return render_template('pages/index.html', current_directory = _current_directory, dot_dots = _dot_dots)

    return render_template('error.html', title = 'Error!',
                            message = 'Must use GET request type...')



@app.route('/api/list-files/<_hash>', methods=['GET', 'POST'])
def listFiles(_hash = None):
    if request.method == 'POST':
        view     = get_view()
        dot_dots = view.get_dot_dots()

        if dot_dots[0][1] == _hash:    # Refresh
            view.load_directory()
        elif dot_dots[1][1] == _hash:  # Pop from dir
            view.pop_from_path()

        msg       = "Log in with an Admin privlidged user to view the requested path!"
        is_locked = view.is_folder_locked(_hash)
        if is_locked and not oidc.user_loggedin:
            return json_message.create("danger", msg)
        elif is_locked and oidc.user_loggedin:
            isAdmin = oidc.user_getfield("isAdmin")
            if isAdmin != "yes" :
                return json_message.create("danger", msg)

        if dot_dots[0][1] != _hash and dot_dots[1][1] != _hash:
            path = view.get_path_part_from_hash(_hash)
            view.push_to_path(path)

        error_msg = view.get_error_message()
        if error_msg:
            view.unset_error_message()
            return json_message.create("danger", error_msg)

        sub_path = view.get_current_sub_path()
        files    = view.get_files_formatted()
        fave     = db.session.query(Favorites).filter_by(link = sub_path).first()
        in_fave  = "true" if fave else "false"
        files.update({'in_fave': in_fave})
        return files
    else:
        msg = "Can't manage the request type..."
        return json_message.create("danger", msg)



@app.route('/api/file-manager-action/<_type>/<_hash>', methods=['GET', 'POST'])
def fileManagerAction(_type, _hash = None):
    view = get_view()

    if _type == "reset-path" and _hash == "None":
        view.set_to_home()
        msg = "Returning to home directory..."
        return json_message.create("success", msg)

    folder = view.get_current_directory()
    file   = view.get_path_part_from_hash(_hash)
    fpath  = os.path.join(folder, file)
    logger.debug(fpath)

    if _type == "files":
        logger.debug(f"Downloading:\n\tDirectory: {folder}\n\tFile: {file}")
        return send_from_directory(directory=folder, filename=file)
    if _type == "remux":
        # NOTE: Need to actually implimint a websocket to communicate back to client that remux has completed.
        # As is, the remux thread hangs until completion and client tries waiting until server reaches connection timeout.
        # I.E....this is stupid but for now works better than nothing
        good_result = view.remux_video(_hash, fpath)
        if good_result:
            return '{"path":"static/remuxs/' + _hash + '.mp4"}'
        else:
            msg = "Remuxing: Remux failed or took too long; please, refresh the page and try again..."
            return json_message.create("success", msg)

    if _type == "remux":
        stream_target = view.remux_video(_hash, fpath)


    # NOTE: Positionally protecting actions further down that are privlidged
    #       Be aware of ordering!
    msg = "Log in with an Admin privlidged user to do this action!"
    if not oidc.user_loggedin:
        return json_message.create("danger", msg)
    elif oidc.user_loggedin:
        isAdmin = oidc.user_getfield("isAdmin")
        if isAdmin != "yes" :
            return json_message.create("danger", msg)


    if _type == "run-locally":
        msg = "Opened media..."
        view.open_file_locally(fpath)
        return json_message.create("success", msg)