Method ApplyNodes

internal/panel/handler.go:536–568

(nodeIDs []string)

}

func (h *Handler) ApplyNodes(nodeIDs []string) {
	for _, nodeID := range nodeIDs {
		go func(id string) {
			client, err := h.dial(id)
			if err != nil {
				log.Printf("applyNodes: dial %s: %v", id, err)
				return
			}
			nodeInbounds, err := h.ibStore.ListInboundsByNode(id)
			if err != nil {
				log.Printf("applyNodes: list inbounds %s: %v", id, err)
				return
			}
			userAccesses, err := h.userStore.ListUserInboundsByNode(id)
			if err != nil {
				log.Printf("applyNodes: list user accesses %s: %v", id, err)
				return
			}
			userIDs := collectUserIDs(userAccesses)
			userMap, err := h.userStore.GetUsersByIDs(userIDs)
			if err != nil {
				log.Printf("applyNodes: get users %s: %v", id, err)
				return
			}
			n, _ := h.nodeStore.Get(id)
			ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
			defer cancel()
			if _, _, err := jobs.ApplyNodeUsers(ctx, client, nodeInbounds, userAccesses, userMap, h.ibStore, h.outboundStore, h.applyOpts, n); err != nil {
				log.Printf("applyNodes: apply %s: %v", id, err)
			}
		}(nodeID)
	}
}

// SyncUserInbounds reconciles a user's inbound assignments. Exported for payment webhook use.
func (h *Handler) SyncUserInbounds(userID string, selectedInboundIDs []string) ([]string, error) {