프로젝트 전체조회 로직 추가

Author: choisungwook

README.md

@@ -10,4 +10,30 @@ docker run --name=postegresql -d \
 -e POSTGRES_PASSWORD=password \
 -e POSTGRES_DB=jcp \
 postgres:12-alpine
+```
+
+* kubernetes serviceaccount
+```sh
+kubectl create ns jcp
+```
+
+```yaml
+apiVersion: v1
+kind: ServiceAccount
+metadata:
+  name: admin
+  namespace: jcp
+---
+apiVersion: rbac.authorization.k8s.io/v1
+kind: ClusterRoleBinding
+metadata:
+  name: admin
+roleRef:
+  apiGroup: rbac.authorization.k8s.io
+  kind: ClusterRole
+  name: cluster-admin
+subjects:
+- kind: ServiceAccount
+  name: admin
+  namespace: jcp
 ```

app/.env

@@ -1,6 +1,6 @@
-LOCAL_POSTGRESQL_HOST="192.168.10.10:31850"
-LOCAL_POSTGRESQL_USER="root"
-LOCAL_POSTGRESQL_PASSWORD="password"
+LOCAL_POSTGRESQL_HOST="127.0.0.1:31850"
+LOCAL_POSTGRESQL_USER="postgresadmin"
+LOCAL_POSTGRESQL_PASSWORD="admin123"
 LOCAL_POSTGRESQL_DB="jcp"
 
 DEV_POSTGRESQL_HOST="postgres.infra.svc:5432"

app/api/project.py

@@ -11,15 +11,35 @@
 from logger import log
 
 router = APIRouter(
-    prefix="/api/v1/project",
+    prefix="/api/v1",
     tags=["project"]
 )
 
-@router.get("/")
-async def project(
+@router.get("/projects")
+async def getAll(db: Session = Depends(get_db)):
+    """프로젝트 전체조회"""
+    log.info("============= /project/getALL is called ============= ")
+    project_manager = ProjectManager()
+
+    try:
+        status_code, detail = project_manager.getProjectALL(db=db)
+    except Exception as e:
+        log.error(f"[프로젝트 전체조회 서비스 호출오류] 예기치 못한 오류: {e}")
+        return JSONResponse(
+            status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
+            content=""
+        )
+
+    return JSONResponse(
+        status_code=status_code,
+        content=detail.dict()
+    )
+
+@router.get("/project")
+async def get(
     name: str = None, db: Session = Depends(get_db)
     ):
-    """프로젝트 조회"""
+    """프로젝트 단일조회"""
     log.info("============= /project/ is called ============= ")
     project_manager = ProjectManager()
 
@@ -45,7 +65,7 @@ async def project(
         content=dict(detail)
     )
 
-@router.post("/")
+@router.post("/project")
 async def create(
     request: RequestCreateProject, db: Session = Depends(get_db)
     ):
@@ -66,7 +86,7 @@ async def create(
         content=dict(detail)
     )
 
-@router.delete("/")
+@router.delete("/project")
 async def delete(
     request: RequestDeleteProject, db: Session = Depends(get_db)
     ):

app/domain/project/crud.py

@@ -51,7 +51,7 @@ def deleteProject(request: RequestDeleteProject, db: Session):
         raise RuntimeError(e)
 
 def getProject(request: RequestGetProject, db: Session):
-    """프로젝트 조회"""
+    """프로젝트 단일조회"""
     try:
         statement = text("""
         SELECT id, name, description 
@@ -71,3 +71,21 @@ def getProject(request: RequestGetProject, db: Session):
         raise RuntimeError(e)
     else:
         return row
+
+def getProjectALL(db: Session):
+    """프로젝트 전체조회"""
+    try:
+        statement = text("""
+        SELECT id, name, description 
+        from projects
+        """)
+        rows = db.execute(statement, {})
+        log.info(f"get projectALL success")
+    except exc.IntegrityError as e:
+        log.error(f"[-] {e}이 project table에 없습니다.: {e}")
+        raise RuntimeError(e)
+    except Exception as e:
+        log.error(f"[-] other error: {e}")
+        raise RuntimeError(e)
+    else:
+        return rows

app/domain/project/schemas.py

@@ -1,4 +1,5 @@
 from pydantic import BaseModel
+from typing import List
 
 
 class RequestGetProject(BaseModel):
@@ -7,11 +8,20 @@ class RequestGetProject(BaseModel):
     name: str
 
 class ResponseGetProject(BaseModel):
-    """프로젝트 조회 응답"""
+    """프로젝트 단일조회 응답"""
     id: str
     name: str
     error_detail: str
 
+class ProjectInfo(BaseModel):
+    id: str
+    name: str
+
+class ResponseGetProjectALL(BaseModel):
+    """프로젝트 전체조회 응답"""
+    results: List[ProjectInfo]
+    error_detail: str
+
 class RequestCreateProject(BaseModel):
     """프로젝트 생성 요청"""
     user_id: int = 1  # 테스트 user_id

app/domain/project/service.py

@@ -6,7 +6,9 @@
     RequestDeleteProject,
     ResponseDeleteProject,
     ResponseGetProject,
-    RequestGetProject
+    RequestGetProject,
+    ResponseGetProjectALL,
+    ProjectInfo
 )
 import domain.project.crud as project_crud
 from logger import log
@@ -101,10 +103,10 @@ def deleteProject(self, request: RequestDeleteProject, db) -> (int, ResponseDele
                )
 
     def getProject(self, request: RequestGetProject, db) -> (int, ResponseGetProject):
-        """프로젝트 조회"""
+        """프로젝트 단일조회"""
 
         try:
-            result = project_crud.getProject(requset=request, db=db)
+            result = project_crud.getProject(request=request, db=db)
         except Exception as e:
             log.error(f"[프로젝트 조회 오류] {request.name} 조회 실패 -> 데이터베이스 오류: {e}")
             return status.HTTP_500_INTERNAL_SERVER_ERROR, \
@@ -134,6 +136,34 @@ def getProject(self, request: RequestGetProject, db) -> (int, ResponseGetProject
                    error_detail=""
                )
 
+    def getProjectALL(self, db) -> (int, ResponseGetProjectALL):
+        """프로젝트 전체조회"""
+        try:
+            rows = project_crud.getProjectALL(db=db)
+        except Exception as e:
+            log.error(f"[프로젝트 전체 조회 오류] 조회 실패 -> 데이터베이스 오류: {e}")
+            return status.HTTP_500_INTERNAL_SERVER_ERROR, \
+                   ResponseGetProjectALL(
+                       results=[],
+                       error_detail="프로젝트 조회를 실패했습니다."
+                   )
+
+        projects = []
+        for row in rows:
+            project = dict(row)
+            projects.append(
+                ProjectInfo(
+                    id=project["id"],
+                    name=project["name"]
+                )
+            )
+
+        return status.HTTP_200_OK, \
+               ResponseGetProjectALL(
+                   results=projects,
+                   error_detail=""
+               )
+
     def createProjectValid(self, namespace: str) -> bool:
         """
         프로젝트 생성 유효성 검사