Method handleGroupSync

internal/serverapi/usergroup.go:298–331

handleGroupSync 同步用户组所有成员的 inbound 记录。

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

// handleGroupSync 同步用户组所有成员的 inbound 记录。
func (a *userGroupAPI) handleGroupSync(w http.ResponseWriter, r *http.Request, groupID string) {
	if r.Method != http.MethodPost {
		writeMethodNotAllowed(w, http.MethodPost)
		return
	}
	g, err := a.ugStore.GetUserGroup(groupID)
	if err != nil {
		writeUserGroupError(w, err)
		return
	}
	inboundIDs := parseCommaList(g.InboundIDs)
	memberIDs, err := a.ugStore.ListGroupMembers(groupID)
	if err != nil {
		internalError(w, r, err)
		return
	}
	affectedNodeIDs := make(map[string]struct{})
	for _, uid := range memberIDs {
		nodeIDs, err := a.syncGroupForUser(groupID, uid, inboundIDs)
		if err != nil {
			internalError(w, r, err)
			return
		}
		for _, nid := range nodeIDs {
			affectedNodeIDs[nid] = struct{}{}
		}
	}
	nodes := make([]string, 0, len(affectedNodeIDs))
	for nid := range affectedNodeIDs {
		nodes = append(nodes, nid)
	}
	a.applyNodes(nodes)
	writeJSON(w, http.StatusOK, map[string]any{"synced_members": len(memberIDs), "affected_nodes": nodes})
}

// syncGroupForUser 同步指定用户在指定组的 inbound 记录：
// 先删除旧的组记录，再按 inboundIDs 重建，返回受影响的 nodeIDs。