"""Application.

The API application is a `flask` application. It provides simple features such
as registering a url for a specific handlers.
"""

from abacus_common_logic.connectors.database import db
from abacus_common_logic.marshalling.custom_fields import ma
from abacus_common_logic.utils.users import set_flask_user_details_from_headers
from flask import Flask
from owslogger import flask_logger
from owsrequest import flask_request
from owsresponse import response
from owsresponse.adaptors.flask import flaskify
from werkzeug.exceptions import HTTPException, InternalServerError

from ledger.logic.exceptions import LogicError


def create_app(config):
    """Create an app."""
    app = Flask(config.SERVICE_NAME)
    app.config.from_object(config)
    app.url_map.strict_slashes = False
    setup_application_log(app, config)
    setup_owsrequest(app, config)
    setup_db(app, config)
    setup_marshmallow(app)
    register_blueprints(app)
    register_error_handlers(app)
    register_request_handler(app)
    return app


def setup_owsrequest(app, config):
    """Set up request framework."""
    try:
        import uwsgi

        uwsgiRunning = True
    except ImportError:
        uwsgiRunning = False

    flask_request.set_rules_validator(app, 'ledger/access_rules.yml')
    flask_request.setup(
        app,
        config.ENVIRONMENT,
        add_request_context=True,
        label_profile=True,
        verify_access=False,
        rules_file=None,
        access_log_only=config.ONLY_LOG_ACCESS_ERRORS,
        exclude_paths=[config.HEALTH_CHECK],
        uwsgi_cache_enabled=uwsgiRunning,
    )


def setup_application_log(app, config):
    """Set up the application log."""
    flask_logger.setup(
        app,
        config.ENVIRONMENT,
        config.LOGGER_NAME,
        config.LOGGER_LEVEL,
        config.SERVICE_NAME,
        config.SERVICE_VERSION,
        exclude_paths=[config.HEALTH_CHECK],
    )


def setup_db(app, config):
    """Set up the database."""
    app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
    app.config['SQLALCHEMY_DATABASE_URI'] = (
        'mysql+pymysql://{}:{}@{}:{}/{}?charset=UTF8MB4'.format(
            config.MYSQL_DB_USER,
            config.MYSQL_DB_PASS,
            config.MYSQL_DB_HOST,
            config.MYSQL_DB_PORT,
            config.MYSQL_DB_NAME,
        )
    )
    db.init_app(app)


def setup_marshmallow(app):
    """Set up marshmallow."""
    ma.init_app(app)


def register_blueprints(app):
    """Register blueprints."""
    from ledger.blueprints.base import base_api
    from ledger.blueprints.bulk_ledgers import bulk_api
    from ledger.blueprints.ledger_account import ledger_account_api
    from ledger.blueprints.ledger_account_contract import ledger_account_contract_api
    from ledger.blueprints.ledger_accounting_run_balance import (
        ledger_accounting_run_balance_api,
    )
    from ledger.blueprints.ledger_accounting_run_vat import (
        ledger_accounting_run_vat_api,
    )
    from ledger.blueprints.ledger_adjustment import ledger_adjustment_api
    from ledger.blueprints.ledger_adjustment_applied import (
        ledger_adjustment_applied_api,
    )
    from ledger.blueprints.ledger_contract_advance_applied import (
        ledger_contract_advance_applied_api,
    )
    from ledger.blueprints.ledger_contract_flowthrough import (
        ledger_contract_flowthrough_api,
    )
    from ledger.blueprints.ledger_correction import ledger_correction_api
    from ledger.blueprints.ledger_reserve_release import ledger_reserve_release_api
    from ledger.blueprints.ledger_reserve_release_schedule import (
        ledger_reserve_release_schedule_api,
    )
    from ledger.blueprints.ledger_reserve_taken import ledger_reserve_taken_api
    from ledger.blueprints.ledger_vat_summary import ledger_vat_summary_api
    from ledger.blueprints.reference_adjustment_type import (
        reference_adjustment_type_api,
    )
    from ledger.blueprints.reference_vat_rate import reference_vat_rate_api

    app.register_blueprint(base_api)
    app.register_blueprint(bulk_api)
    app.register_blueprint(ledger_account_api)
    app.register_blueprint(ledger_account_contract_api)
    app.register_blueprint(ledger_accounting_run_balance_api)
    app.register_blueprint(ledger_accounting_run_vat_api)
    app.register_blueprint(ledger_adjustment_api)
    app.register_blueprint(ledger_adjustment_applied_api)
    app.register_blueprint(ledger_correction_api)
    app.register_blueprint(ledger_contract_advance_applied_api)
    app.register_blueprint(ledger_contract_flowthrough_api)
    app.register_blueprint(ledger_reserve_release_api)
    app.register_blueprint(ledger_reserve_release_schedule_api)
    app.register_blueprint(ledger_reserve_taken_api)
    app.register_blueprint(reference_adjustment_type_api)
    app.register_blueprint(reference_vat_rate_api)
    app.register_blueprint(ledger_vat_summary_api)


def register_error_handlers(app):
    """Register error handlers."""

    def logic_error_handler(error):
        """Handle logic errors."""
        return flaskify(
            response.create_error_response(message=str(error), status=400, code='error')
        )

    app.register_error_handler(LogicError, logic_error_handler)

    def http_error_handler(error):
        """Handle http errors."""
        return flaskify(
            response.create_error_response(
                message=error.description, status=error.code, code='error'
            )
        )

    app.register_error_handler(HTTPException, http_error_handler)

    def exception_handler(_):
        """Handle exceptions."""
        message = (
            'The server encountered an internal error '
            'and was unable to complete your request.'
        )
        return flaskify(response.create_fatal_response(message))

    app.register_error_handler(InternalServerError, exception_handler)


def register_request_handler(app):
    """Register function to preprocess request data."""

    @app.before_request
    def before_request_start():
        """Parse the user info in the header into flask.g."""
        set_flask_user_details_from_headers()