Method syncGroupForUser

internal/serverapi/usergroup.go:336–382

syncGroupForUser 同步指定用户在指定组的 inbound 记录： 先删除旧的组记录，再按 inboundIDs 重建，返回受影响的 nodeIDs。 若用户已通过其他途径持有相同 inbound，复用其凭据保持密码不变。

(groupID, userID string, inboundIDs []string)

// 先删除旧的组记录，再按 inboundIDs 重建，返回受影响的 nodeIDs。
// 若用户已通过其他途径持有相同 inbound，复用其凭据保持密码不变。
func (a *userGroupAPI) syncGroupForUser(groupID, userID string, inboundIDs []string) ([]string, error) {
	// 先获取现有 user_inbounds，用于复用凭据（保证切换来源时密码不变）
	existing, _ := a.userStore.ListUserInboundsByUser(userID)
	credsByInbound := make(map[string]users.UserInbound, len(existing))
	for _, acc := range existing {
		if _, ok := credsByInbound[acc.InboundID]; !ok {
			credsByInbound[acc.InboundID] = acc // 优先保留先找到的（直接分配排在前）
		}
	}

	// 删除旧的组记录
	if err := a.userStore.DeleteGroupUserInbounds(userID, groupID); err != nil {
		return nil, err
	}
	affectedNodes := make(map[string]struct{})
	for _, ibID := range inboundIDs {
		ib, err := a.ibStore.GetInbound(ibID)
		if err != nil {
			continue // inbound 不存在则跳过
		}
		uuid := randomUUID()
		secret := generateGroupSecret(ib.Protocol, ib.Method)
		if prev, ok := credsByInbound[ibID]; ok {
			uuid = prev.UUID
			secret = prev.Secret
		}
		acc := users.UserInbound{
			ID:        idgen.NextString(),
			UserID:    userID,
			InboundID: ibID,
			NodeID:    ib.NodeID,
			UUID:      uuid,
			Secret:    secret,
			GroupID:   groupID,
			CreatedAt: time.Now().UTC(),
		}
		if _, err := a.userStore.UpsertGroupUserInbound(acc); err != nil {
			return nil, err
		}
		affectedNodes[ib.NodeID] = struct{}{}
	}
	out := make([]string, 0, len(affectedNodes))
	for nid := range affectedNodes {
		out = append(out, nid)
	}
	return out, nil
}

// generateGroupSecret 根据协议和方法生成适当的密钥。
func generateGroupSecret(protocol, method string) string {