DB連動実装

backend/app/api/api_v1/routers/platform.py

@@ -3,6 +3,7 @@ from app.db import Base,engine
 from app.db.session import get_db
 from app.db.crud import *
 from app.db.schemas import *
+from typing import List
 
 platform_router = r = APIRouter()
 
@@ -91,7 +92,21 @@ async def flow_details(
 ):
     app = get_flow(db, flowid)
     return app
-  
+
+
+@r.get(
+    "/flows/{appid}",
+    response_model=List[Flow],
+    response_model_exclude_none=True,
+)
+async def flow_list(
+    request: Request,
+    appid: str,
+    db=Depends(get_db),
+):
+    flows = get_flows_by_app(db, appid)
+    return flows
+    
 
 @r.post("/flow", response_model=Flow, response_model_exclude_none=True)
 async def flow_create(

backend/app/db/crud.py

@@ -173,4 +173,10 @@ def get_flow(db: Session, flowid: str):
     flow = db.query(models.Flow).filter(models.Flow.flowid == flowid).first()
     if not flow:
         raise HTTPException(status_code=404, detail="Data not found")
-    return flow
+    return flow
+
+def get_flows_by_app(db: Session, appid: str):
+    flows = db.query(models.Flow).filter(models.Flow.appid == appid).all()
+    if not flows:
+        raise HTTPException(status_code=404, detail="Data not found")
+    return flows