Method handleSub

internal/serverapi/sub.go:29–96

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

}

func (a *subAPI) handleSub(w http.ResponseWriter, r *http.Request) {
	if r.Method != http.MethodGet {
		http.NotFound(w, r)
		return
	}

	// 从路径提取 token：/sub/{token}
	userID := strings.TrimPrefix(r.URL.Path, "/sub/")
	userID = strings.TrimSuffix(userID, "/")
	if userID == "" {
		http.NotFound(w, r)
		return
	}

	user, err := a.users.GetUserBySubToken(userID)
	if err != nil {
		http.NotFound(w, r)
		return
	}

	// 异步记录订阅访问日志（无论用户状态如何，均记录）
	go func() {
		ip := realIP(r)
		ua := r.Header.Get("User-Agent")
		if err := a.users.LogSubAccess(user.ID, ip, ua); err != nil {
			log.Printf("sub access log: %v", err)
		}
	}()

	// 非活跃用户（disabled / expired / limited / on_hold）返回空订阅。
	// 仍携带 Subscription-Userinfo header，让客户端能展示流量/到期信息。
	if !user.EffectiveEnabled() {
		w.Header().Set("Subscription-Userinfo", buildUserinfo(user))
		w.Header().Set("Content-Type", "text/plain; charset=utf-8")
		w.WriteHeader(http.StatusOK)
		_, _ = w.Write([]byte(base64.StdEncoding.EncodeToString(nil)))
		return
	}

	// 收集该用户所有节点的全部订阅链接（跳过已禁用节点）
	accesses, err := a.users.ListActiveUserInboundsByUser(user.ID)
	if err != nil {
		http.Error(w, "internal error", http.StatusInternalServerError)
		return
	}

	// 构建用户排除的 host 集合
	excludedIDs, _ := a.users.ListHostExclusionsByUser(user.ID)
	excluded := make(map[string]bool, len(excludedIDs))
	for _, id := range excludedIDs {
		excluded[id] = true
	}

	links := subscription.BuildLinks(accesses, a.inbounds, user, excluded)

	// Subscription-Userinfo header（客户端如 v2rayN 用于显示流量信息）
	w.Header().Set("Subscription-Userinfo", buildUserinfo(user))
	w.Header().Set("Content-Type", "text/plain; charset=utf-8")