flow api add

backend/app/db/crud.py

@@ -121,4 +121,56 @@ def get_actions(db: Session):
     actions = db.query(models.Action).all()
     if not actions:
         raise HTTPException(status_code=404, detail="Data not found")
-    return actions
+    return actions
+
+
+def create_flow(db: Session, flow: schemas.FlowBase):
+    db_flow = models.Flow(
+        flowid=flow.flowid,
+        appid=flow.appid,
+        eventid=flow.eventid,
+        name=flow.name,
+        content=flow.content
+    )
+    db.add(db_flow)
+    db.commit()
+    db.refresh(db_flow)
+    return db_flow
+
+def delete_flow(db: Session, flowid: str):
+    flow = get_flow(db, flowid)
+    if not flow:
+        raise HTTPException(status.HTTP_404_NOT_FOUND, detail="Flow not found")
+    db.delete(flow)
+    db.commit()
+    return flow
+
+
+def edit_flow(
+    db: Session, flow: schemas.FlowBase
+) -> schemas.Flow:
+    db_flow = get_flow(db, flow.flowid)
+    if not db_flow:
+        raise HTTPException(status.HTTP_404_NOT_FOUND, detail="Flow not found")
+    update_data = flow.dict(exclude_unset=True)
+
+    for key, value in update_data.items():
+            setattr(db_flow, key, value)
+
+    db.add(db_flow)
+    db.commit()
+    db.refresh(db_flow)
+    return db_flow
+
+
+def get_flows(db: Session, flowid: str):
+    flows = db.query(models.Flow).all()
+    if not flows:
+        raise HTTPException(status_code=404, detail="Data not found")
+    return flows
+
+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