diff --git a/apps/manager/service.py b/apps/manager/service.py index 101f8bdb097e2cc964c8d7aec63aaac1ca0cf760..839bf0646d1e278b652ec31f58c2ab4401937b6b 100644 --- a/apps/manager/service.py +++ b/apps/manager/service.py @@ -116,7 +116,7 @@ class ServiceCenterManager: description=endpoint.description, call_id="api", path="test path", - ).model_dump(), + ).model_dump(exclude_none=True, by_alias=True), ) yaml_hash = "hash" # TODO: 计算 OpenAPI YAML 文件的哈希值 # 存入数据库 @@ -129,7 +129,7 @@ class ServiceCenterManager: openapi_spec=data, ) service_collection = MongoDB.get_collection("service") - await service_collection.insert_one(service_pool.model_dump()) + await service_collection.insert_one(service_pool.model_dump(exclude_none=True, by_alias=True)) # 返回服务ID return service_id @@ -165,7 +165,7 @@ class ServiceCenterManager: description=endpoint.description, call_id="api", path="test path", - ).model_dump(), + ).model_dump(exclude_none=True, by_alias=True), ) yaml_hash = "hash" # TODO: 计算 OpenAPI YAML 文件的哈希值 # 更新数据库 @@ -179,7 +179,7 @@ class ServiceCenterManager: ) await service_collection.update_one( {"_id": service_id}, - {"$set": service_pool.model_dump()}, + {"$set": service_pool.model_dump(exclude_none=True, by_alias=True)}, ) # 返回服务ID return service_id @@ -276,7 +276,7 @@ class ServiceCenterManager: service_pool_store.favorites.remove(user_sub) await service_collection.update_one( {"_id": service_id}, - {"$set": service_pool_store.model_dump()}, + {"$set": service_pool_store.model_dump(exclude_none=True, by_alias=True)}, ) return True diff --git a/apps/routers/service.py b/apps/routers/service.py index 57ae3892be8f82aab66dc0dcf3bc372ffdbf08d0..f0ac576c3adf1482cb094302606470f9df26a361 100644 --- a/apps/routers/service.py +++ b/apps/routers/service.py @@ -125,7 +125,7 @@ async def update_service( # noqa: PLR0911 if not data.service_id: try: service_id = await ServiceCenterManager.create_service(user_sub, data.data) - except ValueError as e: + except ValueError as e: # OpenAPI YAML 接口字段不完整 return JSONResponse( status_code=status.HTTP_400_BAD_REQUEST, content=ResponseData( @@ -148,7 +148,7 @@ async def update_service( # noqa: PLR0911 try: service_id = await ServiceCenterManager.update_service(user_sub, data.service_id, data.data) except ValueError as e: - if str(e).startswith("Endpoint error"): + if str(e).startswith("Endpoint error"): # OpenAPI YAML 接口字段不完整 return JSONResponse( status_code=status.HTTP_400_BAD_REQUEST, content=ResponseData(