Method handleNodes

internal/serverapi/api.go:155–203

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

}

func (a *API) handleNodes(w http.ResponseWriter, r *http.Request) {
	switch r.Method {
	case http.MethodGet:
		items, err := a.store.List()
		if err != nil {
			writeJSON(w, http.StatusInternalServerError, map[string]any{"error": err.Error()})
			return
		}
		out := make([]map[string]any, 0, len(items))
		for _, n := range items {
			out = append(out, a.nodeWithOnline(n))
		}
		writeJSON(w, http.StatusOK, map[string]any{"nodes": out})
	case http.MethodPost:
		var req upsertNodeRequest
		if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
			writeJSON(w, http.StatusBadRequest, map[string]any{"error": "invalid json body"})
			return
		}
		if req.Name == "" {
			writeJSON(w, http.StatusBadRequest, map[string]any{"error": "name is required"})
			return
		}
		if strings.TrimSpace(req.ID) == "" {
			req.ID = idgen.NextString()
		}
		node, err := a.store.Upsert(nodes.Node{
			ID:           req.ID,
			Name:         req.Name,
			BaseURL:      strings.TrimRight(req.BaseURL, "/"),
			ExpireAt:     parseExpireAt(req.ExpireAt),
			PanelURL:     req.PanelURL,
			Remark:       req.Remark,
			IPOverride:   strings.TrimSpace(req.IPOverride),
			Disabled:     req.Disabled,
			ACMEEmail:    req.ACMEEmail,
			PanelDomain:  req.PanelDomain,
			ExtraProxies: req.ExtraProxies,
			HTTPSPort:    req.HTTPSPort,
		})
		if err != nil {
			writeJSON(w, http.StatusInternalServerError, map[string]any{"error": err.Error()})
			return
		}
		writeJSON(w, http.StatusOK, node)
	default:
		writeMethodNotAllowed(w, http.MethodGet+", "+http.MethodPost)
	}
}

func (a *API) handleNodeRoutes(w http.ResponseWriter, r *http.Request) {
	path := strings.TrimPrefix(r.URL.Path, "/v1/nodes/")