#!/usr/bin/env python3
import atexit
import sys
from os import environ
from threading import Thread

from oauth2_client.credentials_manager import OAuthError

from getpass import getpass

import web.app
from ChargeControl import ChargeControls
from MyLogger import my_logger
import argparse
from MyLogger import logger
from MyPSACC import MyPSACC
from utils import is_port_in_use
from web.app import start_app, save_config

parser = argparse.ArgumentParser()


def parse_args():
    parser = argparse.ArgumentParser()
    parser.add_argument("-f", "--config", help="config file, default file: config.json", type=argparse.FileType('r'),
                        default="config.json")
    parser.add_argument("-c", "--charge-control", help="enable charge control, default charge_config.json",
                        const="charge_config.json", nargs='?', metavar='charge config file')
    parser.add_argument("-d", "--debug", help="enable debug", const=10, default=20, nargs='?',
                        metavar='Debug level number')
    parser.add_argument("-l", "--listen", help="change server listen address", default="127.0.0.1", metavar="IP")
    parser.add_argument("-p", "--port", help="change server listen port", default="5000")
    parser.add_argument("-r", "--record", help="save vehicle data to db", action='store_true')
    parser.add_argument("-R", "--refresh", help="refresh vehicles status every x min", type=int)
    parser.add_argument("-m", "--mail", default=environ.get('USER_EMAIL', None), help="set the email address")
    parser.add_argument("-P", "--password", default=environ.get('USER_PASSWORD', None), help="set the password")
    parser.add_argument("--remote-disable", help="disable remote control", action='store_true')
    parser.add_argument("--offline", help="offline limited mode", action='store_true')
    parser.add_argument("-b", "--base-path", help="base path for web app", default="/")
    parser.parse_args()
    return parser


if __name__ == "__main__":
    if sys.version_info < (3, 6):
        raise RuntimeError("This application requires Python 3.6+")
    parser = parse_args()
    args = parser.parse_args()
    try:
        args.debug = int(args.debug)
    except ValueError:
        pass
    my_logger(handler_level=args.debug)
    if is_port_in_use(args.listen, int(args.port)):
        logger.error(" Address already in use")
        exit(1)
    logger.info("server start")
    if args.config:
        config_name = args.config.name
    else:
        config_name = "config.json"
    web.app.myp = MyPSACC.load_config(name=config_name)
    atexit.register(web.app.myp.save_config)
    if args.record:
        web.app.myp.set_record(True)
    if args.offline:
        logger.info("offline mode")
    else:
        try:
            web.app.myp.refresh_token()
        except OAuthError:
            if args.mail and args.password:
                client_email = args.mail
                client_password = args.password
            else:
                client_email = input(f"{web.app.myp.get_app_name()} email: ")
                client_password = getpass(f"{web.app.myp.get_app_name()} password: ")
            web.app.myp.connect(client_email, client_password)
        logger.info(str(web.app.myp.get_vehicles()))
        if args.remote_disable:
            logger.info("mqtt disabled")
        else:
            web.app.myp.start_mqtt()
        if args.refresh or args.charge_control:
            if args.refresh:
                web.app.myp.info_refresh_rate = args.refresh * 60
            if args.charge_control:
                web.app.chc = ChargeControls.load_config(web.app.myp, name=args.charge_control)
                web.app.chc.init()
            t2 = Thread(target=web.app.myp.refresh_vehicle_info)
            t2.setDaemon(True)
            t2.start()

    save_config(web.app.myp, config_name)
    t1 = Thread(target=start_app, args=["My car info", args.base_path, logger.level < 20, args.listen, int(args.port)])
    t1.setDaemon(True)
    t1.start()