closes #8: replacing hypercorn with granian

Author: andredias

{{cookiecutter.project_slug}}/entrypoint.sh

@@ -2,11 +2,9 @@
 set -eox pipefail
 
 if [ "$ENV" != 'production' ]; then
-    exec hypercorn --reload --worker-class={{cookiecutter.worker_class}} --bind=0.0.0.0:5000 \
-                   --error-logfile=- --root-path /api \
-                   {{cookiecutter.project_slug}}.main:app
+    exec granian --reload --loop {{cookiecutter.worker_class}} --host 0.0.0.0 --port 5000 \
+                 --url-path-prefix /api --interface asgi {{cookiecutter.project_slug}}.main:app
 else
-    exec hypercorn --worker-class={{cookiecutter.worker_class}} --bind=0.0.0.0:5000 --error-logfile=- \
-                   --error-logfile=- --root-path /api \
-                   {{cookiecutter.project_slug}}.main:app
+    exec granian --loop {{cookiecutter.worker_class}} --host 0.0.0.0 --port 5000 \
+                 --url-path-prefix /api --interface asgi {{cookiecutter.project_slug}}.main:app
 fi

{{cookiecutter.project_slug}}/pyproject.toml

@@ -9,6 +9,7 @@ requires-python = "~={{cookiecutter.python_version}}.0"
 readme = "README.rst"
 dependencies = [
     "fastapi",
+    "granian[reload,uvloop]",
     "hypercorn",
     "loguru",
     "orjson",

{{cookiecutter.project_slug}}/{{cookiecutter.project_slug}}/middleware.py

@@ -4,7 +4,6 @@
 
 from fastapi import Request, Response
 from fastapi.responses import PlainTextResponse
-from hypercorn.logging import AccessLogAtoms
 from loguru import logger
 
 from . import config
@@ -27,26 +26,20 @@ async def log_request_middleware(request: Request, call_next: Callable) -> Respo
             response = PlainTextResponse('Internal Server Error', status_code=500)
         final_time = time()
         elapsed = final_time - start_time
-        response_dict = {
-            'status': response.status_code,
-            'headers': response.headers.raw,
-        }
-        atoms = AccessLogAtoms(request, response_dict, final_time)  # type: ignore
-        try:
-            response_length = int(atoms['B'])
-        except ValueError:
-            response_length = 0
+        response_length = request.headers.get('content-length', 0)
+        query_string = request['query_string'].decode()
+        path_with_qs = request['path'] + ('?' + query_string if query_string else '')
         data = {
-            'remote_ip': request.headers.get('x-forwarded-for') or atoms['h'],
-            'schema': request.headers.get('x-forwarded-proto') or atoms['S'],
-            'protocol': atoms['H'],
-            'method': atoms['m'],
-            'path_with_query': atoms['Uq'],
+            'remote_ip': request.headers.get('x-forwarded-for') or request['client'],
+            'schema': request.headers.get('x-forwarded-proto') or request['scheme'],
+            'protocol': request.get('http_version', 'ws'),
+            'method': request.get('method', 'GET'),
+            'path_with_query': path_with_qs,
             'status_code': response.status_code,
             'response_length': response_length,
             'elapsed': elapsed,
-            'referer': atoms['f'],
-            'user_agent': atoms['a'],
+            'referer': request.headers.get('referer', ''),
+            'user_agent': request.headers.get('user-agent', ''),
         }
         if not exception:
             logger.info('log request', **data)