AbstractRunner

Complexity

Total Complexity

1

Size/Duplication

Total Lines	4
Duplicated Lines	0 %

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	run()	0	3	1

import abc
from typing import Type

from werkzeug.serving import run_simple
from werkzeug.wrappers import Request as WSGIRequest
from werkzeug.wrappers import Response as WSGIResponse

from mountapi.core.settings import AbstractSettings
from mountapi.http import RequestData, Request, Response
from mountapi.routing import AbstractRouter


class AbstractRunner(metaclass=abc.ABCMeta):
    @abc.abstractmethod
    def run(self, settings: Type[AbstractSettings]) -> None:
        pass


class Runner(AbstractRunner):
    def __init__(self, router: AbstractRouter) -> None:
        self._router = router

    def run(self, settings: Type[AbstractSettings]) -> None:
        run_simple(
            hostname=settings.hostname,
            port=settings.port,
            application=self._get_wsgi_app(),
            use_reloader=True,
            use_debugger=settings.debug,
        )

    def _get_wsgi_app(self):
        @WSGIRequest.application
        def application(wsgi_request: WSGIRequest) -> WSGIResponse:
            request_data = RequestData(wsgi_request)
            request_func = self._router.dispatch(
                request_data.path, request_data.method
            )
            request = Request(request_data, request_func)
            response = Response(request)
            return response.wsgi()

        return application