APIv1 cbv

app/api/v1.py

@@ -1,6 +1,10 @@
-from fastapi import APIRouter
+from fastapi import APIRouter, Depends
+from fastapi_utils.cbv import cbv
+from starlette.responses import JSONResponse, Response
 
-from app.api.models import Request, Response
+from app.api.models import Request
+from app.core.core import WebhookProcessor
+from app.core.injects import AutowireSupport
 
 router = APIRouter()
 
@@ -10,10 +14,14 @@ async def root():
   return {"message": "Witaj w API v1"}
 
 
-@router.get("/health", summary="Health check")
+@cbv(router)
-async def health():
+class APIv1:
-  return {"status": "ok"}
+  webhook_service: WebhookProcessor = Depends(AutowireSupport.webhook_processor)
 
-@router.post("/ci", summary="CI Webhook")
+  @router.get("/health", summary="Health check")
-async def ci(request: Request):
+  async def health(self) -> JSONResponse:
-  return Response(200)
+    return JSONResponse({"status": "ok"})
+
+  @router.post("/ci", summary="CI Webhook")
+  async def ci(self, request: Request):
+    return Response(status_code=201)

app/core/injects.py

@@ -0,0 +1,10 @@
+from injectable import inject
+
+from app.core.core import WebhookProcessor
+
+
+class AutowireSupport:
+
+  @staticmethod
+  def webhook_processor():
+    return inject(WebhookProcessor)

app/model/webhook.py

@@ -0,0 +1,11 @@
+from dataclasses import dataclass
+from typing import List
+
+
+@dataclass
+class WebhookRequest:
+  _id: str
+  commit: str
+  message: str
+  started: str
+  files: List[str]