Method handleInboundRoutes

internal/serverapi/inbounds.go:95–179

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

}

func (a *inboundAPI) handleInboundRoutes(w http.ResponseWriter, r *http.Request) {
	path := strings.TrimPrefix(r.URL.Path, "/v1/inbounds/")
	parts := strings.SplitN(path, "/", 2)
	id := parts[0]
	if id == "" {
		writeJSON(w, http.StatusNotFound, map[string]any{"error": "inbound id is required"})
		return
	}

	// Sub-routes: /v1/inbounds/{id}/users
	if len(parts) == 2 && parts[1] == "users" {
		a.handleInboundUsers(w, r, id)
		return
	}

	switch r.Method {
	case http.MethodGet:
		item, err := a.store.GetInbound(id)
		if err != nil {
			writeInboundError(w, err)
			return
		}
		writeJSON(w, http.StatusOK, item)
	case http.MethodPut:
		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
		}
		req.ID = id
		if req.Protocol != "" && !supportedProtocol(req.Protocol) {
			writeJSON(w, http.StatusBadRequest, map[string]any{"error": "unsupported protocol"})
			return
		}
		// 合并现有字段
		existing, err := a.store.GetInbound(id)
		if err != nil {
			writeInboundError(w, err)
			return
		}
		if req.NodeID == "" {
			req.NodeID = existing.NodeID
		}
		if req.Protocol == "" {
			req.Protocol = existing.Protocol
		}
		if req.Tag == "" {
			req.Tag = existing.Tag
		}
		if req.Port == 0 {
			req.Port = existing.Port
		}
		trimInbound(&req)
		nodeChanged := req.NodeID != existing.NodeID
		item, err := a.store.UpsertInbound(req)
		if err != nil {
			internalError(w, r, err)
			return