Method handleInbounds

internal/serverapi/inbounds.go:42–93

─── Inbound handlers ────────────────────────────────────────────────────────

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

// ─── Inbound handlers ────────────────────────────────────────────────────────

func (a *inboundAPI) handleInbounds(w http.ResponseWriter, r *http.Request) {
	switch r.Method {
	case http.MethodGet:
		var items []inbounds.Inbound
		var err error
		if nodeID := r.URL.Query().Get("node_id"); nodeID != "" {
			items, err = a.store.ListInboundsByNode(nodeID)
		} else {
			items, err = a.store.ListInbounds()
		}
		if err != nil {
			internalError(w, r, err)
			return
		}
		userCounts, err := a.userStore.CountUsersByInbound()
		if err != nil {
			internalError(w, r, err)
			return
		}
		writeJSON(w, http.StatusOK, map[string]any{"inbounds": items, "user_counts": userCounts})
	case http.MethodPost:
		var req inbounds.Inbound
		if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
			writeJSON(w, http.StatusBadRequest, map[string]any{"error": "invalid json body"})
			return
		}
		if req.NodeID == "" || req.Protocol == "" || req.Port == 0 {
			writeJSON(w, http.StatusBadRequest, map[string]any{"error": "node_id, protocol and port are required"})
			return
		}
		if !supportedProtocol(req.Protocol) {
			writeJSON(w, http.StatusBadRequest, map[string]any{"error": "unsupported protocol"})
			return
		}
		if req.ID == "" {
			req.ID = idgen.NextString()
		}
		if req.Tag == "" {
			req.Tag = fmt.Sprintf("%s-%d", req.Protocol, req.Port)
		}
		trimInbound(&req)
		item, err := a.store.UpsertInbound(req)
		if err != nil {
			internalError(w, r, err)
			return
		}
		a.applyInboundNode(item.NodeID)
		writeJSON(w, http.StatusOK, item)
	default:
		writeMethodNotAllowed(w, http.MethodGet+", "+http.MethodPost)
	}
}

func (a *inboundAPI) handleInboundRoutes(w http.ResponseWriter, r *http.Request) {
	path := strings.TrimPrefix(r.URL.Path, "/v1/inbounds/")