Method handleAccessSubscription

internal/serverapi/users.go:568–632

handleAccessSubscription 返回该节点访问凭据对应的所有订阅链接。

(w http.ResponseWriter, r *http.Request, userID, ibID string)

// handleAccessSubscription 返回该节点访问凭据对应的所有订阅链接。
func (a *userAPI) handleAccessSubscription(w http.ResponseWriter, r *http.Request, userID, ibID string) {
	if r.Method != http.MethodGet {
		writeMethodNotAllowed(w, http.MethodGet)
		return
	}
	acc, err := a.users.GetUserInbound(ibID)
	if err != nil {
		writeUserInboundError(w, err)
		return
	}
	if acc.UserID != userID {
		writeJSON(w, http.StatusNotFound, map[string]any{"error": "user inbound not found"})
		return
	}
	user, err := a.users.GetUser(userID)
	if err != nil {
		writeUserError(w, err)
		return
	}

	// 按 InboundID 获取对应的 inbound 列表；旧版记录（InboundID 为空）回退到节点级别
	var ibList []inbounds.Inbound
	if acc.InboundID != "" {
		ib, err := a.inboundStore.GetInbound(acc.InboundID)
		if err != nil {
			internalError(w, r, err)
			return
		}
		ibList = []inbounds.Inbound{ib}
	} else {
		ibList, err = a.inboundStore.ListInboundsByNode(acc.NodeID)
		if err != nil {
			internalError(w, r, err)
			return
		}
	}

	type linkItem struct {
		Protocol string `json:"protocol"`
		Remark   string `json:"remark"`
		Link     string `json:"link"`
	}

	links := make([]linkItem, 0)
	for _, ib := range ibList {
		hosts, err := a.inboundStore.ListHostsByInbound(ib.ID)
		if err != nil {
			continue
		}
		for _, h := range hosts {
			link := subscription.Link(ib, h, acc, user)
			remark := h.Remark
			if remark == "" {
				remark = h.Address
			}
			links = append(links, linkItem{
				Protocol: ib.Protocol,
				Remark:   remark,