【ADD]update mcp count at mcp market
This commit is contained in:
@@ -19,7 +19,7 @@ from app.models import mcp_market_config_model
|
|||||||
from app.models.user_model import User
|
from app.models.user_model import User
|
||||||
from app.schemas import mcp_market_config_schema
|
from app.schemas import mcp_market_config_schema
|
||||||
from app.schemas.response_schema import ApiResponse
|
from app.schemas.response_schema import ApiResponse
|
||||||
from app.services import mcp_market_config_service
|
from app.services import mcp_market_config_service, mcp_market_service
|
||||||
|
|
||||||
# Obtain a dedicated API logger
|
# Obtain a dedicated API logger
|
||||||
api_logger = get_api_logger()
|
api_logger = get_api_logger()
|
||||||
@@ -115,6 +115,17 @@ async def get_mcp_servers(
|
|||||||
"has_next": True if page * pagesize < total else False
|
"has_next": True if page * pagesize < total else False
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
# 5. Update mck_market.mcp_count
|
||||||
|
db_mcp_market = mcp_market_service.get_mcp_market_by_id(db, mcp_market_id=db_mcp_market_config.mcp_market_id, current_user=current_user)
|
||||||
|
if not db_mcp_market:
|
||||||
|
api_logger.warning(f"The mcp market does not exist or access is denied: mcp_market_id={db_mcp_market_config.mcp_market_id}")
|
||||||
|
raise HTTPException(
|
||||||
|
status_code=status.HTTP_404_NOT_FOUND,
|
||||||
|
detail="The mcp market does not exist or access is denied"
|
||||||
|
)
|
||||||
|
db_mcp_market.mcp_count = total
|
||||||
|
db.commit()
|
||||||
|
db.refresh(db_mcp_market)
|
||||||
return success(data=result, msg="Query of mcp servers list successful")
|
return success(data=result, msg="Query of mcp servers list successful")
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user