Method handleHosts

internal/serverapi/inbounds.go:183–230

─── Host handlers ────────────────────────────────────────────────────────────

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

// ─── Host handlers ────────────────────────────────────────────────────────────

func (a *inboundAPI) handleHosts(w http.ResponseWriter, r *http.Request) {
	switch r.Method {
	case http.MethodGet:
		inboundID := r.URL.Query().Get("inbound_id")
		var items []inbounds.Host
		var err error
		if inboundID != "" {
			items, err = a.store.ListHostsByInbound(inboundID)
		} else {
			items, err = a.store.ListHosts()
		}
		if err != nil {
			internalError(w, r, err)
			return
		}
		writeJSON(w, http.StatusOK, map[string]any{"hosts": items})
	case http.MethodPost:
		var req inbounds.Host
		if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
			writeJSON(w, http.StatusBadRequest, map[string]any{"error": "invalid json body"})
			return
		}
		if req.InboundID == "" || req.Address == "" {
			writeJSON(w, http.StatusBadRequest, map[string]any{"error": "inbound_id and address are required"})
			return
		}
		if _, err := a.store.GetInbound(req.InboundID); err != nil {
			writeInboundError(w, err)
			return
		}
		if req.ID == "" {
			req.ID = idgen.NextString()
		}
		if req.Security == "" {
			req.Security = "none"
		}
		trimHost(&req)
		item, err := a.store.UpsertHost(req)
		if err != nil {
			internalError(w, r, err)
			return
		}
		a.triggerHostNodeSync(item)
		writeJSON(w, http.StatusOK, item)
	default:
		writeMethodNotAllowed(w, http.MethodGet+", "+http.MethodPost)
	}
}

func (a *inboundAPI) handleHostRoutes(w http.ResponseWriter, r *http.Request) {
	id := strings.TrimPrefix(r.URL.Path, "/v1/hosts/")