Merge pull request #102 from SoyBeansLab/feature/contest_crud

contestのCRUDを実装

src/domain/Contest/contest.py

@@ -28,8 +28,8 @@ def __init__(
         description: str,
         top_content: str,
         problem_number: int,
-        created_at: Optional[datetime],
-        updated_at: Optional[datetime],
+        created_at: Optional[datetime] = None,
+        updated_at: Optional[datetime] = None,
     ):
         super().__init__(
             contest_id=contest_id,
@@ -41,8 +41,6 @@ def __init__(
             description=description,
             top_content=top_content,
             problem_number=problem_number,
-            created_at=created_at,
-            updated_at=updated_at,
         )
 
     @staticmethod

src/domain/Contest/database/contest_repository.py

@@ -48,3 +48,65 @@ def find(self, contest_id: str) -> Contest:
         if len(row) == 0:
             return None
         return Contest(*row)
+
+    def store(self, contest: Contest) -> None:
+        return self.sqlhandler.execute(
+            """
+                INSERT INTO contests (
+                    contest_id,
+                    contest_name,
+                    contest_start_date,
+                    contest_finish_date,
+                    contest_time,
+                    writer,
+                    description,
+                    top_content,
+                    problem_number
+                )
+                VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s)
+            """,
+            contest.contest_id,
+            contest.contest_name,
+            contest.contest_start_date,
+            contest.contest_finish_date,
+            contest.contest_time,
+            contest.writer,
+            contest.description,
+            contest.top_content,
+            contest.problem_number,
+        )
+
+    def update(self, contest_id: str, contest: Contest) -> None:
+        return self.sqlhandler.execute(
+            """
+                UPDATE contests SET
+                    contest_id = %s,
+                    contest_name = %s,
+                    contest_start_date = %s,
+                    contest_finish_date = %s,
+                    contest_time = %s,
+                    writer = %s,
+                    description = %s,
+                    top_content = %s,
+                    problem_number = %s
+                WHERE contest_id = %s
+            """,
+            contest_id,
+            contest.contest_name,
+            contest.contest_start_date,
+            contest.contest_finish_date,
+            contest.contest_time,
+            contest.writer,
+            contest.description,
+            contest.top_content,
+            contest.problem_number,
+            contest_id,
+        )
+
+    def delete(self, contest_id: str) -> None:
+        return self.sqlhandler.execute(
+            """
+                DELETE FROM contests WHERE contest_id = %s
+            """,
+            contest_id,
+        )

src/domain/Contest/usecase/contest_interactor.py

@@ -22,3 +22,12 @@ def current_contests(self) -> List[Contest]:
 
     def recent_contests(self) -> List[Contest]:
         return self.repository.find_recent()
+
+    def store(self, contest: Contest) -> None:
+        return self.repository.store(contest)
+
+    def update(self, contest_id: str, contest: Contest) -> None:
+        return self.repository.update(contest_id, contest)
+
+    def delete(self, contest_id: str) -> None:
+        return self.repository.delete(contest_id)

src/domain/Contest/usecase/contest_repository.py

@@ -24,3 +24,15 @@ def find_recent(self) -> List[Contest]:
     @abstractmethod
     def find(self, contest_id: str) -> Contest:
         raise NotImplementedError()
+
+    @abstractmethod
+    def store(self, contest: Contest) -> None:
+        raise NotImplementedError
+
+    @abstractmethod
+    def update(self, contest_id: str, contest: Contest) -> None:
+        raise NotImplementedError
+
+    @abstractmethod
+    def delete(self, contest_id: str) -> None:
+        raise NotImplementedError

src/infrastructure/waf/fastapi/router.py

@@ -32,12 +32,34 @@ def set_route_contest(api: FastAPI) -> None:
         status_code=200,
         tags=["contests"],
     )
+    api.add_api_route(
+        "/contests",
+        contest_controller.store,
+        status_code=201,
+        methods=["POST"],
+        tags=["contests"],
+    )
     api.add_api_route(
         "/contests/{contest_id}",
         contest_controller.contest,
+        status_code=200,
         methods=["GET"],
         tags=["contests"],
     )
+    api.add_api_route(
+        "/contests/{contest_id}",
+        contest_controller.update,
+        status_code=200,
+        methods=["PUT"],
+        tags=["contests"],
+    )
+    api.add_api_route(
+        "/contests/{contest_id}",
+        contest_controller.delete,
+        status_code=200,
+        methods=["DELETE"],
+        tags=["contests"],
+    )
 
 
 def set_route_problem(api: FastAPI) -> None:

src/interface/controllers/contest_controller.py

@@ -1,3 +1,4 @@
+from domain.Contest.contest import Contest
 from domain.Contest.database.contest_repository import ContestRepository
 from domain.Contest.usecase.contest_interactor import ContestInteractor
 
@@ -38,3 +39,21 @@ async def contest(self, contest_id: str):
         res_data = contest.as_json()
         resp = {"contest": res_data}
         return resp
+
+    async def store(self, contest: Contest):
+        self.interactor.store(contest)
+        resp = {}
+
+        return resp
+
+    async def update(self, contest_id: str, contest: Contest):
+        self.interactor.update(contest_id, contest)
+        resp = {}
+
+        return resp
+
+    async def delete(self, contest_id: str):
+        self.interactor.delete(contest_id)
+        resp = {}
+
+        return resp