Method handleNodeApply

internal/serverapi/api.go:602–645

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

}

func (a *API) handleNodeApply(w http.ResponseWriter, r *http.Request, nodeID string) {
	if r.Method != http.MethodPost {
		writeMethodNotAllowed(w, http.MethodPost)
		return
	}
	if a.usersStore == nil || a.inboundStore == nil {
		writeJSON(w, http.StatusInternalServerError, map[string]any{"error": "stores not configured"})
		return
	}
	client, err := a.clientFor(nodeID)
	if err != nil {
		writeNodeError(w, err)
		return
	}
	nodeInbounds, err := a.inboundStore.ListInboundsByNode(nodeID)
	if err != nil {
		writeJSON(w, http.StatusInternalServerError, map[string]any{"error": err.Error()})
		return
	}
	userAccesses, err := a.usersStore.ListUserInboundsByNode(nodeID)
	if err != nil {
		writeJSON(w, http.StatusInternalServerError, map[string]any{"error": err.Error()})
		return
	}
	userIDs := collectNodeUserIDs(userAccesses)
	userMap, err := a.usersStore.GetUsersByIDs(userIDs)
	if err != nil {
		writeJSON(w, http.StatusInternalServerError, map[string]any{"error": err.Error()})
		return
	}
	node, err := a.store.Get(nodeID)
	if err != nil {
		writeJSON(w, http.StatusInternalServerError, map[string]any{"error": err.Error()})
		return
	}
	ctx, cancel := context.WithTimeout(r.Context(), 60*time.Second)
	defer cancel()
	status, _, err := jobs.ApplyNodeUsers(ctx, client, nodeInbounds, userAccesses, userMap, a.inboundStore, a.outboundStore, a.applyOpts, node)
	if err != nil {
		writeJSON(w, http.StatusUnprocessableEntity, map[string]any{"error": err.Error()})
		return
	}
	writeJSON(w, http.StatusOK, status)
}

// TriggerNodeSync 异步触发指定节点的 NodeGate sync。