bugfix get flow -> get flow by appid

This commit is contained in:
2024-12-09 16:54:51 +09:00
parent b874d0c776
commit a3df6c4b37
2 changed files with 12 additions and 7 deletions

View File

@@ -236,22 +236,24 @@ async def action_data(
raise APIException('platform:actions',request.url._url,f"Error occurred while get actions:",e) raise APIException('platform:actions',request.url._url,f"Error occurred while get actions:",e)
@r.get( @r.get(
"/flow/{flowid}", "/flow/{appid}",tags=["App"],
response_model=Flow, response_model=ApiReturnModel[List[Flow|None]],
response_model_exclude_none=True, response_model_exclude_none=True,
) )
async def flow_details( async def flow_details(
request: Request, request: Request,
flowid: str, appid: str,
user=Depends(get_current_active_user),
db=Depends(get_db), db=Depends(get_db),
): ):
try: try:
app = get_flow(db, flowid) domain = domainService.get_default_domain(db, user.id)
return app if not domain:
return ApiReturnModel(data = None)
return ApiReturnModel(data = appService.get_flow(db, domain.url, appid,user.id))
except Exception as e: except Exception as e:
raise APIException('platform:flow',request.url._url,f"Error occurred while get flow by flowid:",e) raise APIException('platform:flow',request.url._url,f"Error occurred while get flow by flowid:",e)
@r.get( @r.get(
"/flows/{appid}", "/flows/{appid}",
response_model=List[Flow|None], response_model=List[Flow|None],

View File

@@ -153,7 +153,7 @@ class dbapp(crudbase):
updateuserid = userid, updateuserid = userid,
createuserid = userid createuserid = userid
) )
db.add(flow) db.add(db_flow)
db.commit() db.commit()
db.refresh(db_app) db.refresh(db_app)
@@ -174,6 +174,9 @@ class dbapp(crudbase):
def get_appversions(self,db: Session, domainurl:str,appid:str): def get_appversions(self,db: Session, domainurl:str,appid:str):
return paginate(db,dbappversion.get_appversions(domainurl,appid)) return paginate(db,dbappversion.get_appversions(domainurl,appid))
def get_flow(self,db: Session, domainurl: str, appid:str,userid:int):
return dbflow.get_flows_by_appid(db,domainurl,appid)
def create_flow(self,db: Session, domainurl: str, flow: schemas.FlowIn,userid:int): def create_flow(self,db: Session, domainurl: str, flow: schemas.FlowIn,userid:int):
return dbflow.create_flow(db,domainurl,flow,userid) return dbflow.create_flow(db,domainurl,flow,userid)