# -*- coding: utf-8 -*-

"""A command line application for managing BEL Commons.

Run with ``python -m bel_commons`` or simply as ``bel-commons``.
"""

import datetime
import json
import logging
import multiprocessing
import os
from typing import Optional, TextIO

import click
import sys
import time
from bio2bel import get_version as get_bio2bel_version
from flask import Flask
from tabulate import tabulate

from pybel import BELGraph, from_bel_script
from pybel.cli import connection_option, graph_pickle_argument
from pybel.manager.models import (
    Author, Citation, Edge, Evidence, Namespace, NamespaceEntry, Network, Node, author_citation, edge_annotation,
    network_edge, network_node,
)
from pybel.version import get_version as pybel_version
from .manager import WebManager
from .manager_utils import insert_graph
from .models import (
    Assembly, EdgeComment, EdgeVote, Experiment, NetworkOverlap, Omic, Project, Query, Report, Role,
    User, UserQuery, assembly_network, projects_networks, projects_users, users_networks,
)
from .tools_compat import get_tools_version
from .version import get_version as get_bel_commons_version

logger = logging.getLogger('bel_commons')


def _iterate_user_strings(manager_: WebManager) -> str:
    """Iterate over strings to print describing users."""
    return [
        (
            user.id,
            user.email,
            user.password,
            ','.join(sorted(r.name for r in user.roles)),
            user.name or ''
        )
        for user in manager_.session.query(User).all()
    ]


def _set_logging_level(level: int) -> None:
    logging.basicConfig(level=level, format="%(asctime)s - %(levelname)s - %(name)s - %(message)s", datefmt='%H:%M:%S')

    pybel_logger = logging.getLogger('pybel')
    pybel_logger.setLevel(level)

    pbt_logger = logging.getLogger('pybel_tools')
    pbt_logger.setLevel(level)

    pbw_logger = logging.getLogger('bel_commons')
    pbw_logger.setLevel(level)

    logging.getLogger('bio2bel_hgnc').setLevel(level)
    logging.getLogger('bio2bel_mirtarbase').setLevel(level)
    logging.getLogger('bio2bel_chebi').setLevel(level)


def _set_debug_param(debug: int) -> None:
    if debug == 1:
        _set_logging_level(logging.INFO)
        logger.info('Logging at logging.INFO')
    elif debug == 2:
        _set_logging_level(logging.DEBUG)
        logger.info('Logging at logging.DEBUG')

    logging.getLogger('passlib.registry').setLevel(logging.WARNING)


def number_of_workers() -> int:
    """Calculate the default number of workers."""
    return (multiprocessing.cpu_count() * 2) + 1


def make_gunicorn_app(app: Flask, host: str, port: str, workers: int):
    """Make a GUnicorn App.

    :rtype: gunicorn.app.base.BaseApplication
    """
    import gunicorn.app.base

    class StandaloneApplication(gunicorn.app.base.BaseApplication):
        def __init__(self, options=None):
            self.options = options or {}
            self.application = app
            super().__init__()

        def load_config(self):
            for key, value in self.options.items():
                if key in self.cfg.settings and value is not None:
                    self.cfg.set(key.lower(), value)

        def load(self):
            return self.application

    return StandaloneApplication({
        'bind': f'{host}:{port}',
        'workers': workers,
    })


_main_help = f"""BEL Commons Command Line Interface on {sys.executable}
with PyBEL v{pybel_version()}, PyBEL Tools v{get_tools_version()},
Bio2BEL v{get_bio2bel_version()}, and BEL Commons v{get_bel_commons_version()}
"""


@click.group(help=_main_help)
@click.version_option()
def main():
    """Run the BEL Commons command line interface."""


@main.command()
@click.option('--host', type=str, default='0.0.0.0', help='Flask host.', show_default=True)
@click.option('--port', type=int, default=5000, help='Flask port.', show_default=True)
@click.option('-v', '--debug', count=True, help="Turn on debugging. More v's, more debugging")
@click.option('--with-gunicorn', is_flag=True)
@click.option('-w', '--workers', type=int, default=number_of_workers(), help='Number of workers')
def run(host, port, debug, with_gunicorn: bool, workers: int):
    """Run the web application."""
    _set_debug_param(debug)

    from bel_commons.wsgi import flask_app

    if with_gunicorn:
        gunicorn_app = make_gunicorn_app(flask_app, host, port, workers)
        gunicorn_app.run()
    else:
        flask_app.run(host=host, port=port)


@main.command()
@click.option('-c', '--concurrency', type=int, default=1)
@click.option('-b', '--broker', default='amqp://guest:guest@localhost:5672//')
@click.option('--debug', default='INFO', type=click.Choice(['INFO', 'DEBUG']))
def worker(concurrency, broker, debug):
    """Run the celery worker."""
    from bel_commons.wsgi import flask_app
    from bel_commons.celery_worker import celery_app

    if celery_app is None:
        click.secho('Celery is not configured', fg='red')
        return sys.exit(1)

    with flask_app.app_context():
        from celery.bin import worker

        pybel_worker = worker.worker(app=celery_app)
        pybel_worker.run(
            broker=broker,
            loglevel=debug,
            traceback=True,
            concurrency=concurrency,
        )


@main.group()
@connection_option
@click.pass_context
def manage(ctx, connection: str):
    """Manage the database."""
    ctx.obj = WebManager(connection=connection)
    ctx.obj.bind()
    ctx.obj.create_all()


@manage.command()
@click.option('-f', '--file', type=click.File('r'), default=sys.stdout, help='Input user/role file')
@click.pass_obj
def load(manager: WebManager, file: TextIO):
    """Load dumped stuff for loading later (in lieu of having proper migrations)."""
    ds = manager.user_datastore

    for line in file:
        line = line.strip().split('\t')
        email, password = line[:2]
        u = manager.user_datastore.find_user(email=email)

        if not u:
            u = ds.create_user(
                email=email,
                password=password,

                confirmed_at=datetime.datetime.now()
            )

            if 4 <= len(line):
                u.name = line[3]

            click.echo(f'added {u}')
            ds.commit()

            if 3 <= len(line):
                for role_name in line[2].strip().split(','):
                    r = ds.find_or_create_role(name=role_name.strip())
                    ds.add_role_to_user(u, r)

    ds.commit()


@manage.command()
@click.option('-u', '--user-dump', type=click.File('w'), default=sys.stdout, help='Place to dump user data')
@click.confirmation_option()
@click.pass_obj
def drop(manager: WebManager, user_dump):
    """Drop the database."""
    click.echo(f'Dumping users to {user_dump}')
    for s in _iterate_user_strings(manager):
        click.echo('\t'.join(s), file=user_dump)
    click.echo('Done dumping users')
    click.echo('Dropping database')
    manager.drop_all()
    click.echo('Done dropping database')


@manage.command()
@click.pass_obj
def freedom(manager: WebManager):
    """Make all networks public."""
    # TODO: use update(Report).filter_by(public=False).values(public=True)
    for report in manager.session.query(Report).filter_by(public=False):
        report.public = True
    manager.session.commit()


@manage.group()
def networks():
    """Parse, upload, and manage networks."""


@networks.command()
@click.option('-p', '--path', type=click.Path(file_okay=True, dir_okay=False, exists=True))
@click.option('--public', is_flag=True)
@click.pass_obj
def parse(manager: WebManager, path: str, public: bool):
    """Parses a BEL script and uploads."""
    t = time.time()
    graph = from_bel_script(path, manager=manager)
    logger.info('parsing done in %.2f seconds', time.time() - t)
    insert_graph(manager, graph, public=public, use_tqdm=True)


@networks.command()
@graph_pickle_argument
@click.option('--public', is_flag=True)
@click.pass_obj
def upload(manager: WebManager, graph: BELGraph, public: bool):
    """Upload a graph."""
    insert_graph(manager, graph, public=public, use_tqdm=True)


@networks.command()  # noqa:F811
@click.pass_obj
def ls(manager: WebManager):
    """List network names, versions, and optionally, descriptions."""
    manager.sanitize()
    click.echo(tabulate(
        [
            (n.id, n.name, n.version, n.report.user, n.report.public, n.report.number_nodes, n.report.number_edges)
            for n in manager.list_networks()
        ],
        headers=['id', 'name', 'version', 'owner', 'public', 'nodes', 'edges'],
    ))


@manage.group()
def users():
    """Manage users."""


@users.command()
@click.pass_obj
def ls(manager: WebManager):
    """Lists all users."""
    click.echo(tabulate(
        _iterate_user_strings(manager),
        headers=['id', 'email', 'password', 'roles', 'name'],
    ))


@users.command()
@click.argument('email')
@click.argument('password')
@click.option('-a', '--admin', is_flag=True, help="Add admin role")
@click.pass_obj
def add(manager: WebManager, email: str, password: str, admin: bool):
    """Create a new user."""
    ds = manager.user_datastore
    try:
        user = ds.create_user(email=email, password=password, confirmed_at=datetime.datetime.now())

        if admin:
            admin_role = ds.find_or_create_role('admin')
            ds.add_role_to_user(user, admin_role)

        ds.commit()
    except Exception:
        logger.exception(f"Couldn't create user {email}")


@users.command()
@click.argument('email')
@click.pass_obj
def rm(manager: WebManager, email: str):
    """Delete a user."""
    ds = manager.user_datastore
    user_ = ds.find_user(email=email)
    ds.delete_user(user_)
    ds.commit()


@users.command()
@click.argument('email')
@click.pass_obj
def make_admin(manager: WebManager, email: str):
    """Make a given user an admin."""
    ds = manager.user_datastore

    try:
        admin = ds.find_or_create_role('admin')
        ds.add_role_to_user(email, ds)
        ds.commit()
    except Exception:
        logger.exception("Couldn't make admin")


@users.command()
@click.argument('email')
@click.argument('role')
@click.pass_obj
def add_role(manager: WebManager, email: str, role: str):
    """Add a role to a user."""
    ds = manager.user_datastore
    try:
        ds.add_role_to_user(email, role)
        ds.commit()
    except Exception:
        logger.exception(f"Couldn't assign {email} as {role}")


@manage.group()
def roles():
    """Manage roles."""


@roles.command()
@click.argument('name')
@click.option('-d', '--description')
@click.pass_obj
def add(manager: WebManager, name: str, description: Optional[str]):
    """Create a new role."""
    ds = manager.user_datastore
    try:
        ds.create_role(name=name, description=description)
        ds.commit()
    except Exception:
        logger.exception(f"Couldn't create role {name}")


@roles.command()
@click.argument('name')
@click.pass_obj
def rm(manager: WebManager, name: str):
    """Delete a user."""
    ds = manager.user_datastore
    user = ds.find_role(name)
    if user:
        ds.delete(user)
        ds.commit()


@roles.command()
@click.pass_obj
def ls(manager: WebManager):
    """List roles."""
    click.echo('\t'.join(('id', 'name', 'description')))
    for role in manager.session.query(Role).all():
        click.echo('\t'.join((str(role.id), role.name, role.description)))


@manage.group()
def projects():
    """Manage projects."""


@projects.command()
@click.pass_obj
def ls(manager: WebManager):
    """List projects."""
    click.echo('\t'.join(('id', 'name', 'users')))
    for project in manager.session.query(Project).all():
        click.echo('\t'.join((str(project.id), project.name, ','.join(map(str, project.users)))))


@projects.command()
@click.option('-o', '--output', type=click.File('w'), default=sys.stdout)
@click.pass_obj
def export(manager: WebManager, output: TextIO):
    """Export projects as a JSON file."""
    json.dump(
        [
            project.to_json()
            for project in manager.session.query(Project).all()
        ],
        output,
    )


@manage.group()
def queries():
    """Manage queries."""


@queries.command()
@click.option('--query-id', type=int)
@click.option('-y', '--yes', is_flag=True)
@click.pass_obj
def drop(manager: WebManager, query_id: Optional[int], yes: bool):
    """Drops either a single or all Experiment models"""
    if query_id is not None:
        manager.session.query(query_id).get(query_id).delete()
        manager.session.commit()

    elif yes or click.confirm(f'Drop all Query models in {manager.connection}?'):
        manager.session.query(Query).delete()
        manager.session.commit()


@queries.command()
@click.option('-l', '--limit', type=int, default=10, help='Limit, defaults to 10.')
@click.option('-o', '--offset', type=int)
@click.pass_obj
def ls(manager: WebManager, limit: int, offset: Optional[int]):
    """List queries."""
    click.echo('\t'.join(('id', 'created', 'assembly')))

    q = manager.session.query(Query).order_by(Query.created.desc())

    if limit:
        q = q.limit(limit)

    if offset:
        q = q.offset(offset)

    for query in q.all():
        click.echo('\t'.join(map(str, (query.id, query.created, query.assembly))))


@manage.group()
def assemblies():
    """Manage assemblies."""


@assemblies.command()
@click.option('--assembly-id', type=int)
@click.option('-y', '--yes', is_flag=True)
@click.pass_obj
def drop(manager: WebManager, assembly_id: Optional[int], yes: bool):
    """Drop either a single or all Assembly models."""
    if assembly_id is not None:
        manager.session.query(assembly_id).get(assembly_id).delete()
        manager.session.commit()

    elif yes or click.confirm(f'Drop all Assembly models in {manager.connection}?'):
        manager.session.query(Assembly).delete()
        manager.session.commit()


@manage.group()
def experiments():
    """Manage experiments."""


@experiments.command()
@click.pass_obj
def ls(manager: WebManager):
    """List experiments."""
    click.echo('\t'.join(('id', 'type', 'omics description', 'completed')))
    for experiment in manager.session.query(Experiment).order_by(Experiment.created.desc()).all():
        click.echo('\t'.join(map(str, (
            experiment.id,
            experiment.type,
            experiment.omic.description,
            experiment.completed
        ))))


@experiments.command()
@click.option('--experiment-id', type=int)
@click.option('-y', '--yes', is_flag=True)
@click.pass_obj
def drop(manager: WebManager, experiment_id: Optional[int], yes: bool):
    """Drop either a single or all Experiment models."""
    if experiment_id is not None:
        manager.session.query(Experiment).get(experiment_id).delete()
        manager.session.commit()

    elif yes or click.confirm(f'Drop all Experiment models in {manager.connection}?'):
        manager.session.query(Experiment).delete()
        manager.session.commit()


@manage.group()
def omics():
    """Manage -omics."""


@omics.command()
@click.pass_obj
def ls(manager: WebManager):
    """List -omics data sets."""
    click.echo('\t'.join(('id', 'name', 'description')))
    for omic in manager.session.query(Omic).all():
        click.echo('\t'.join((str(omic.id), omic.source_name, omic.description)))


@omics.command()
@click.option('--omic-id', type=int)
@click.option('-y', '--yes', is_flag=True)
@click.pass_obj
def drop(manager: WebManager, omic_id: Optional[int], yes: bool):
    """Drop either a single or all -omics models."""
    if omic_id is not None:
        manager.session.query(Omic).get(omic_id).delete()
        manager.session.commit()

    elif yes or click.confirm(f'Drop all Omic models in {manager.connection}?'):
        manager.session.query(Omic).delete()
        manager.session.commit()


@manage.command()
@click.pass_obj
def summarize(manager: WebManager):
    """Summarize the contents of the database."""
    click.echo(f'Users: {manager.count_users()}')
    click.echo('Roles: {}'.format(manager.session.query(Role).count()))
    click.echo('Projects: {}'.format(manager.session.query(Project).count()))
    click.echo('Reports: {}'.format(manager.session.query(Report).count()))
    click.echo('Assemblies: {}'.format(manager.session.query(Assembly).count()))
    click.echo('Votes: {}'.format(manager.session.query(EdgeVote).count()))
    click.echo('Comments: {}'.format(manager.session.query(EdgeComment).count()))
    click.echo('Queries: {}'.format(manager.session.query(Query).count()))
    click.echo('Omics: {}'.format(manager.session.query(Omic).count()))
    click.echo('Experiments: {}'.format(manager.session.query(Experiment).count()))


_default_bms_dir = os.path.join(os.path.expanduser('~'), 'dev', 'bms')
_default_omics_dir = os.path.join(os.path.expanduser('~'), 'dev', 'bel-commons-manuscript', 'data')

omics_dir = (
    _default_omics_dir
    if os.path.exists(_default_omics_dir)
    else os.environ.get('BEL_COMMONS_EXAMPLES_OMICS_DATA_DIR')
)
bms_dir = (
    _default_bms_dir
    if os.path.exists(_default_bms_dir)
    else os.environ.get('BMS_BASE')
)

if omics_dir is not None or bms_dir is not None:
    @manage.group()
    def examples():
        """Load examples."""


    if omics_dir is not None:
        @examples.command(help='Load omics from {}'.format(omics_dir))
        @click.option('-r', '--reload', is_flag=True, help='Reload')
        @click.pass_obj
        def load_omics(manager: WebManager, reload: bool):
            """Load omics."""
            from .resources.load_omics import main
            _set_logging_level(logging.INFO)
            main(manager, reload=reload)

    if bms_dir is not None:
        @examples.command()
        @click.option('--skip-cbn', is_flag=True)
        @click.pass_obj
        def load_networks(manager: WebManager, skip_cbn: bool):
            """Load networks."""
            from .resources.load_networks import load_bms, load_cbn
            _set_logging_level(logging.INFO)
            load_bms(manager)

            if not skip_cbn:
                load_cbn(manager)

    if omics_dir is not None and bms_dir is not None:
        @examples.command()
        @click.option('--reload-omics', is_flag=True, help='Reload')
        @click.option('-p', '--permutations', type=int, default=25, show_default=True)
        @click.option('--skip-bio2bel', is_flag=True)
        @click.option('--skip-cbn', is_flag=True)
        @click.pass_obj
        def load(manager: WebManager, reload_omics, permutations, skip_bio2bel, skip_cbn):
            """Load omics, networks, and experiments."""
            from .resources.load_omics import main as load_omics_main
            from .resources.load_networks import load_bms, load_bio2bel, load_cbn
            from .resources.load_experiments import main as load_experiments_main

            _set_logging_level(logging.INFO)

            load_omics_main(manager, reload=reload_omics)
            load_bms(manager)
            load_experiments_main(manager, permutations=permutations)

            if not skip_bio2bel:
                load_bio2bel(manager)

            if not skip_cbn:
                load_cbn(manager)


        @examples.command()
        @click.option('-p', '--permutations', type=int, help='Number of permutations to run. Defaults to 25.',
                      default=25)
        @click.pass_obj
        def load_experiments(manager: WebManager, permutations):
            """Load experiments."""
            from .resources.load_experiments import main
            _set_logging_level(logging.INFO)
            main(manager, permutations=permutations)


@manage.command()
@click.confirmation_option()
@click.option('-m', '--drop-most', is_flag=True)
@click.option('-a', '--drop-all', is_flag=True)
@click.pass_obj
def wasteland(manager: WebManager, drop_most: bool, drop_all: bool):
    """Drop the models specific to BEL Commons."""
    for table in [Experiment, UserQuery, Query]:
        _drop_table(manager, table)

    _drop_mn_table(manager, assembly_network)
    _drop_mn_table(manager, users_networks)
    _drop_mn_table(manager, projects_networks)
    _drop_mn_table(manager, projects_users)

    for table in [Assembly, Report, EdgeVote, EdgeComment, NetworkOverlap, Project]:
        _drop_table(manager, table)

    if drop_most or drop_all:
        _drop_mn_table(manager, edge_annotation)
        _drop_mn_table(manager, network_edge)
        _drop_table(manager, Edge)

        _drop_mn_table(manager, network_node)
        _drop_table(manager, Node)

        _drop_table(manager, Network)

    if drop_all:
        _drop_table(manager, Evidence)
        _drop_mn_table(manager, author_citation)
        _drop_table(manager, Citation)
        _drop_table(manager, Author)
        _drop_table(manager, NamespaceEntry)
        _drop_table(manager, Namespace)


def _drop_table(manager: WebManager, table_cls):
    click.secho(f'{table_cls.__tablename__}', fg='green')

    # click.secho(f'  truncating {manager.session.query(table_cls).count()} records', fg='blue')
    manager.session.query(table_cls).delete()
    manager.session.commit()

    click.secho('  dropping', fg='blue')
    table_cls.__table__.drop()
    manager.session.commit()


def _drop_mn_table(manager: WebManager, table_cls):
    click.secho(f'{table_cls}', fg='green')

    # click.secho(f'  truncating {manager.session.query(table_cls).count()} records', fg='blue')
    table_cls.delete()
    manager.session.commit()

    click.secho('  dropping', fg='blue')
    table_cls.drop()
    manager.session.commit()


if __name__ == '__main__':
    main()
