enh: group members endpoint

tjbck · tjbck · commit 01868e856a10 · 2025-12-02T11:24:23.000-05:00
diff --git a/backend/open_webui/models/users.py b/backend/open_webui/models/users.py
@@ -452,6 +452,16 @@ def get_users(
                 "total": total,
             }
 
+    def get_users_by_group_id(self, group_id: str) -> list[UserModel]:
+        with get_db() as db:
+            users = (
+                db.query(User)
+                .join(GroupMember, User.id == GroupMember.user_id)
+                .filter(GroupMember.group_id == group_id)
+                .all()
+            )
+            return [UserModel.model_validate(user) for user in users]
+
     def get_users_by_user_ids(self, user_ids: list[str]) -> list[UserStatusModel]:
         with get_db() as db:
             users = db.query(User).filter(User.id.in_(user_ids)).all()
diff --git a/backend/open_webui/routers/groups.py b/backend/open_webui/routers/groups.py
@@ -3,7 +3,7 @@
 from typing import Optional
 import logging
 
-from open_webui.models.users import Users
+from open_webui.models.users import Users, UserInfoResponse
 from open_webui.models.groups import (
     Groups,
     GroupForm,
@@ -118,6 +118,24 @@ async def export_group_by_id(id: str, user=Depends(get_admin_user)):
         )
 
 
+############################
+# GetUsersInGroupById
+############################
+
+
+@router.post("/id/{id}/users", response_model=list[UserInfoResponse])
+async def get_users_in_group(id: str, user=Depends(get_admin_user)):
+    try:
+        users = Users.get_users_by_group_id(id)
+        return users
+    except Exception as e:
+        log.exception(f"Error adding users to group {id}: {e}")
+        raise HTTPException(
+            status_code=status.HTTP_400_BAD_REQUEST,
+            detail=ERROR_MESSAGES.DEFAULT(e),
+        )
+
+
 ############################
 # UpdateGroupById
 ############################
