Release/v1.7.10

Release/v1.7.10

Author: WMC001

.github/dependabot.yml

@@ -0,0 +1,36 @@
+version: 2
+
+updates:
+  - package-ecosystem: "npm"
+    directory: "/frontend"
+    schedule:
+      interval: "weekly"
+    open-pull-requests-limit: 5
+    labels:
+      - "dependencies"
+
+  - package-ecosystem: "npm"
+    directory: "/doc"
+    schedule:
+      interval: "weekly"
+    open-pull-requests-limit: 2
+    labels:
+      - "dependencies"
+
+  - package-ecosystem: "pip"
+    directory: "/backend"
+    schedule:
+      interval: "weekly"
+    open-pull-requests-limit: 5
+    labels:
+      - "dependencies"
+
+  - package-ecosystem: "pip"
+    directory: "/sdk"
+    schedule:
+      interval: "weekly"
+    open-pull-requests-limit: 5
+    labels:
+      - "dependencies"
+
+

.github/workflows/codeql.yml

@@ -99,4 +99,4 @@ jobs:
     - name: Perform CodeQL Analysis
       uses: github/codeql-action/analyze@v3
       with:
-        category: "/language:${{matrix.language}}"
+        category: "/language:${{matrix.language}}"

backend/apps/agent_app.py

@@ -17,7 +17,8 @@
     list_all_agent_info_impl,
     run_agent_stream,
     stop_agent_tasks,
-    get_agent_call_relationship_impl
+    get_agent_call_relationship_impl,
+    clear_agent_new_mark_impl
 )
 from utils.auth_utils import get_current_user_info, get_current_user_id
 
@@ -148,6 +149,21 @@ async def import_agent_api(request: AgentImportRequest, authorization: Optional[
             status_code=HTTPStatus.INTERNAL_SERVER_ERROR, detail="Agent import error.")
 
 
+@agent_config_router.put("/clear_new/{agent_id}")
+async def clear_agent_new_mark_api(agent_id: int, authorization: Optional[str] = Header(None)):
+    """
+    Clear the NEW mark for an agent
+    """
+    try:
+        user_id, tenant_id, _ = get_current_user_info(authorization)
+        affected_rows = await clear_agent_new_mark_impl(agent_id, tenant_id, user_id)
+        return {"message": "Agent NEW mark cleared successfully", "affected_rows": affected_rows}
+    except Exception as e:
+        logger.error(f"Failed to clear agent NEW mark: {str(e)}")
+        raise HTTPException(
+            status_code=HTTPStatus.INTERNAL_SERVER_ERROR, detail="Failed to clear agent NEW mark.")
+
+
 @agent_config_router.post("/check_name")
 async def check_agent_name_batch_api(request: AgentNameBatchCheckRequest, authorization: Optional[str] = Header(None)):
     """

backend/apps/config_app.py

@@ -21,6 +21,7 @@
 from apps.voice_app import voice_config_router as voice_router
 from apps.tenant_app import router as tenant_router
 from apps.group_app import router as group_router
+from apps.user_app import router as user_router
 from apps.invitation_app import router as invitation_router
 from consts.const import IS_SPEED_MODE
 
@@ -64,6 +65,7 @@
 app.include_router(remote_mcp_router)
 app.include_router(tenant_router)
 app.include_router(group_router)
+app.include_router(user_router)
 app.include_router(invitation_router)
 
 # Initialize monitoring for the application

backend/apps/group_app.py

@@ -10,14 +10,15 @@
 
 from consts.model import (
     GroupCreateRequest, GroupUpdateRequest,
-    GroupUserRequest, GroupListRequest, SetDefaultGroupRequest
+    GroupUserRequest, GroupListRequest, SetDefaultGroupRequest,
+    GroupMembersUpdateRequest
 )
 from consts.exceptions import NotFoundException, ValidationError, UnauthorizedError
 from services.group_service import (
     create_group, get_group_info, update_group, delete_group,
     add_user_to_single_group, remove_user_from_single_group, get_group_users,
     add_user_to_groups, get_tenant_default_group_id, set_tenant_default_group_id,
-    get_groups_by_tenant
+    get_groups_by_tenant, update_group_members
 )
 from services.tenant_service import get_tenant_info
 from utils.auth_utils import get_current_user_id
@@ -140,11 +141,13 @@ async def get_groups_endpoint(
     try:
         # Validate tenant exists
         get_tenant_info(request.tenant_id)
-        # Get groups under given tenant with pagination
+        # Get groups under given tenant with pagination and sorting
         result = get_groups_by_tenant(
             tenant_id=request.tenant_id,
             page=request.page,
-            page_size=request.page_size
+            page_size=request.page_size,
+            sort_by=request.sort_by,
+            sort_order=request.sort_order
         )
 
         return JSONResponse(
@@ -486,6 +489,70 @@ async def get_group_users_endpoint(group_id: int) -> JSONResponse:
         )
 
 
+@router.put("/{group_id}/members")
+async def update_group_members_endpoint(
+    group_id: int,
+    request: GroupMembersUpdateRequest,
+    authorization: Optional[str] = Header(None)
+) -> JSONResponse:
+    """
+    Update group members by setting the exact list of users.
+
+    Args:
+        group_id: Group identifier
+        request: Request containing the list of user IDs to set as group members
+        authorization: Bearer token for authentication
+
+    Returns:
+        JSONResponse: Update results with counts
+    """
+    try:
+        # Get current user ID from token
+        current_user_id, _ = get_current_user_id(authorization)
+
+        # Update group members
+        result = update_group_members(
+            group_id=group_id,
+            user_ids=request.user_ids,
+            current_user_id=current_user_id
+        )
+
+        logger.info(f"Updated group {group_id} members by user {current_user_id}: {result}")
+
+        return JSONResponse(
+            status_code=HTTPStatus.OK,
+            content={
+                "message": "Group members updated successfully",
+                "data": result
+            }
+        )
+
+    except NotFoundException as exc:
+        logger.warning(f"Group not found for member update: {group_id}")
+        raise HTTPException(
+            status_code=HTTPStatus.NOT_FOUND,
+            detail=str(exc)
+        )
+    except ValidationError as exc:
+        logger.warning(f"Group members update validation error: {str(exc)}")
+        raise HTTPException(
+            status_code=HTTPStatus.BAD_REQUEST,
+            detail=str(exc)
+        )
+    except UnauthorizedError as exc:
+        logger.warning(f"Unauthorized group members update attempt: {str(exc)}")
+        raise HTTPException(
+            status_code=HTTPStatus.UNAUTHORIZED,
+            detail=str(exc)
+        )
+    except Exception as exc:
+        logger.error(f"Unexpected error during group members update: {str(exc)}")
+        raise HTTPException(
+            status_code=HTTPStatus.INTERNAL_SERVER_ERROR,
+            detail="Failed to update group members"
+        )
+
+
 @router.post("/members/batch")
 async def add_user_to_groups_endpoint(
     request: GroupUserRequest,

backend/apps/invitation_app.py

@@ -48,7 +48,9 @@ async def list_invitations_endpoint(
             tenant_id=request.tenant_id,
             page=request.page,
             page_size=request.page_size,
-            user_id=user_id
+            user_id=user_id,
+            sort_by=request.sort_by,
+            sort_order=request.sort_order
         )
 
         logger.info(f"User {user_id} retrieved invitation list (tenant: {request.tenant_id or 'all'}, page: {request.page}, size: {request.page_size})")

backend/apps/remote_mcp_app.py

@@ -7,14 +7,15 @@
 
 from consts.const import NEXENT_MCP_DOCKER_IMAGE, ENABLE_UPLOAD_IMAGE
 from consts.exceptions import MCPConnectionError, MCPNameIllegal, MCPContainerError
-from consts.model import MCPConfigRequest
+from consts.model import MCPConfigRequest, MCPUpdateRequest
 from services.remote_mcp_service import (
     add_remote_mcp_server_list,
     delete_remote_mcp_server_list,
     get_remote_mcp_server_list,
     check_mcp_health_and_update_db,
     delete_mcp_by_container_id,
     upload_and_start_mcp_image,
+    update_remote_mcp_server_list,
 )
 from database.remote_mcp_db import check_mcp_name_exists
 from services.tool_configuration_service import get_tool_from_remote_mcp_server
@@ -107,6 +108,38 @@ async def delete_remote_proxies(
                             detail="Failed to delete remote MCP proxy")
 
 
+@router.put("/update")
+async def update_remote_proxy(
+    update_data: MCPUpdateRequest,
+    authorization: Optional[str] = Header(None)
+):
+    """ Used to update an existing remote MCP server """
+    try:
+        user_id, tenant_id = get_current_user_id(authorization)
+        await update_remote_mcp_server_list(
+            update_data=update_data,
+            tenant_id=tenant_id,
+            user_id=user_id
+        )
+        return JSONResponse(
+            status_code=HTTPStatus.OK,
+            content={"message": "Successfully updated remote MCP proxy",
+                     "status": "success"}
+        )
+    except MCPNameIllegal as e:
+        logger.error(f"Failed to update remote MCP proxy: {e}")
+        raise HTTPException(status_code=HTTPStatus.CONFLICT,
+                            detail=str(e))
+    except MCPConnectionError as e:
+        logger.error(f"Failed to update remote MCP proxy: {e}")
+        raise HTTPException(status_code=HTTPStatus.SERVICE_UNAVAILABLE,
+                            detail=str(e))
+    except Exception as e:
+        logger.error(f"Failed to update remote MCP proxy: {e}")
+        raise HTTPException(status_code=HTTPStatus.INTERNAL_SERVER_ERROR,
+                            detail="Failed to update remote MCP proxy")
+
+
 @router.get("/list")
 async def get_remote_proxies(
     authorization: Optional[str] = Header(None)