Method handleGroupMembers

internal/serverapi/usergroup.go:191–261

handleGroupMembers 处理 /v1/user-groups/{id}/members 的 GET 和 POST 请求。

(w http.ResponseWriter, r *http.Request, groupID string)

// handleGroupMembers 处理 /v1/user-groups/{id}/members 的 GET 和 POST 请求。
func (a *userGroupAPI) handleGroupMembers(w http.ResponseWriter, r *http.Request, groupID string) {
	// 先确认组存在
	if _, err := a.ugStore.GetUserGroup(groupID); err != nil {
		writeUserGroupError(w, err)
		return
	}

	switch r.Method {
	case http.MethodGet:
		memberIDs, err := a.ugStore.ListGroupMembers(groupID)
		if err != nil {
			internalError(w, r, err)
			return
		}
		if len(memberIDs) == 0 {
			writeJSON(w, http.StatusOK, map[string]any{"members": []any{}})
			return
		}
		userMap, err := a.userStore.GetUsersByIDs(memberIDs)
		if err != nil {
			internalError(w, r, err)
			return
		}
		type memberInfo struct {
			UserID   string `json:"user_id"`
			Username string `json:"username"`
		}
		members := make([]memberInfo, 0, len(memberIDs))
		for _, uid := range memberIDs {
			u, ok := userMap[uid]
			if !ok {
				// 用户已删除，清理孤儿记录
				_ = a.ugStore.RemoveMember(groupID, uid)
				continue
			}
			members = append(members, memberInfo{UserID: uid, Username: u.Username})
		}
		writeJSON(w, http.StatusOK, map[string]any{"members": members})

	case http.MethodPost:
		var req struct {
			UserID string `json:"user_id"`
		}
		if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
			writeJSON(w, http.StatusBadRequest, map[string]any{"error": "invalid json body"})
			return
		}
		if req.UserID == "" {
			writeJSON(w, http.StatusBadRequest, map[string]any{"error": "user_id is required"})
			return
		}
		if err := a.ugStore.AddMember(groupID, req.UserID); err != nil {
			internalError(w, r, err)
			return
		}
		// 加入成员后立即同步该成员的 inbound 记录并下发节点配置
		g, err := a.ugStore.GetUserGroup(groupID)
		if err == nil {