Method handleAccessApply

internal/serverapi/users.go:511–565

handleAccessApply 将该节点的完整配置重新下发。

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

// handleAccessApply 将该节点的完整配置重新下发。
func (a *userAPI) handleAccessApply(w http.ResponseWriter, r *http.Request, userID, ibID string) {
	if r.Method != http.MethodPost {
		writeMethodNotAllowed(w, http.MethodPost)
		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
	}

	nodeInbounds, err := a.inboundStore.ListInboundsByNode(acc.NodeID)
	if err != nil {
		internalError(w, r, err)
		return
	}
	allAccesses, err := a.users.ListUserInboundsByNode(acc.NodeID)
	if err != nil {
		internalError(w, r, err)
		return
	}
	userIDs := collectUserIDs(allAccesses)
	userMap, err := a.users.GetUsersByIDs(userIDs)
	if err != nil {
		internalError(w, r, err)
		return
	}

	client, err := a.base.clientFor(acc.NodeID)
	if err != nil {
		writeNodeError(w, err)
		return
	}
	accNode, _ := a.base.store.Get(acc.NodeID)
	ctx, cancel := context.WithTimeout(r.Context(), 10*time.Second)
	defer cancel()

	status, config, err := jobs.ApplyNodeUsers(ctx, client, nodeInbounds, allAccesses, userMap, a.inboundStore, a.outboundStore, a.applyOpts, accNode)
	if err != nil {
		writeJSON(w, http.StatusBadGateway, map[string]any{"error": err.Error()})
		return
	}

	writeJSON(w, http.StatusOK, map[string]any{
		"access":       acc,
		"users_count":  len(allAccesses),
		"active_users": len(filterEnabledAccesses(allAccesses, userMap)),
		"node_status":  status,
		"node_config":  json.RawMessage(config),
	})
}

// handleAccessSubscription 返回该节点访问凭据对应的所有订阅链接。
func (a *userAPI) handleAccessSubscription(w http.ResponseWriter, r *http.Request, userID, ibID string) {