add domainid->flow

This commit is contained in:
2023-11-13 18:02:19 +09:00
parent 55181f2c57
commit 5cb9375db3
4 changed files with 12 additions and 5 deletions

View File

@@ -125,11 +125,12 @@ def get_actions(db: Session):
return actions
def create_flow(db: Session, flow: schemas.FlowBase):
def create_flow(db: Session, domainid: int, flow: schemas.FlowBase):
db_flow = models.Flow(
flowid=flow.flowid,
appid=flow.appid,
eventid=flow.eventid,
domainid=domainid,
name=flow.name,
content=flow.content
)
@@ -176,8 +177,8 @@ def get_flow(db: Session, flowid: str):
raise HTTPException(status_code=404, detail="Data not found")
return flow
def get_flows_by_app(db: Session, appid: str):
flows = db.query(models.Flow).filter(models.Flow.appid == appid).all()
def get_flows_by_app(db: Session, domainid: int, appid: str):
flows = db.query(models.Flow).filter(and_(models.Flow.domainid == domainid,models.Flow.appid == appid)).all()
if not flows:
raise HTTPException(status_code=404, detail="Data not found")
return flows