import datetime

import simplejson as json

from odoo import http
from odoo.exceptions import AccessDenied
from odoo.http import Response, request

from .validator import validator

return_fields = ["id", "login", "name", "company_id"]


class JwtHttp:
    def get_state(self):
        return {"d": request.session.db}

    def parse_request(self):
        http_method = request.httprequest.method
        try:
            body = http.request.params
        except Exception:
            body = {}

        headers = dict(list(request.httprequest.headers.items()))
        if "wsgi.input" in headers:
            del headers["wsgi.input"]
        if "wsgi.errors" in headers:
            del headers["wsgi.errors"]
        if "HTTP_AUTHORIZATION" in headers:
            headers["Authorization"] = headers["HTTP_AUTHORIZATION"]

        # extract token
        token = ""
        if "Authorization" in headers:
            try:
                # Bearer token_string
                token = headers["Authorization"].split(" ")[1]
            except Exception:
                pass

        return http_method, body, headers, token

    def date2str(self, d, f="%Y-%m-%d %H:%M:%S"):
        """
        Convert datetime to string
            :param self:
            :param d: datetime object
            :param f='%Y-%m-%d%H:%M:%S': string format
        """
        try:
            s = d.strftime(f)
        except Exception:
            s = None

        return s

    def response(self, success=True, message=None, data=None, code=200):
        """
        Create a HTTP Response for controller
            :param success=True indicate this response is successful or not
            :param message=None message string
            :param data=None data to return
            :param code=200 http status code
        """

        payload = json.dumps(
            {
                "success": success,
                "message": message,
                "data": data,
            }
        )

        return Response(
            payload,
            status=code,
            headers=[
                ("Content-Type", "application/json"),
            ],
        )

    def response_500(self, message="Internal Server Error", data=None):
        return self.response(success=False, message=message, data=data, code=500)

    def response_401(self, message="401 Unauthorized", data=None):
        return self.response(success=False, message=message, data=data, code=401)

    def response_404(self, message="404 Not Found", data=None):
        return self.response(success=False, message=message, data=data, code=404)

    def response_403(self, message="403 Forbidden", data=None):
        return self.response(success=False, message=message, data=data, code=403)

    def errcode(self, code, message=None):
        return self.response(success=False, code=code, message=message)

    def do_login(self, login, password):
        # get current db
        state = self.get_state()
        try:
            uid = request.session.authenticate(state["d"], login, password)
        except AccessDenied:
            return self.response_401()
        if not uid:
            return self.response_401()

        # login success, generate token
        user = request.env.user.read(return_fields)[0]
        exp = datetime.datetime.utcnow() + datetime.timedelta(minutes=3)
        token = validator.create_token(user, exp)

        return self.response(
            data={"user": user, "exp": json.dumps(exp.isoformat()), "token": token}
        )

    def do_logout(self, token):
        request.session.logout()
        request.env["jwt_provider.access_token"].sudo().search(
            [("token", "=", token)]
        ).unlink()
        return self.response()

    def cleanup(self):
        # Clean up things after success request
        # use logout here to make request as stateless as possible
        request.session.logout()
        return self.response()


jwt_http = JwtHttp()