Method SetOverrides

pkg/overrides/api.go:83–126

SetOverrides updates overrides for a specific tenant

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

// SetOverrides updates overrides for a specific tenant
func (a *API) SetOverrides(w http.ResponseWriter, r *http.Request) {
	userID, _, err := users.ExtractTenantIDFromHTTPRequest(r)
	if err != nil {
		http.Error(w, err.Error(), http.StatusBadRequest)
		return
	}

	var overrides map[string]any
	if err := json.NewDecoder(r.Body).Decode(&overrides); err != nil {
		http.Error(w, ErrInvalidJSON, http.StatusBadRequest)
		return
	}

	// Get allowed limits from runtime config
	allowedLimits, err := a.getAllowedLimitsFromBucket(r.Context())
	if err != nil {
		level.Error(a.logger).Log("msg", "failed to get allowed limits from bucket", "userID", userID, "err", err)
		http.Error(w, "Internal server error", http.StatusInternalServerError)
		return
	}

	// Validate that only allowed limits are being changed
	if err := ValidateOverrides(overrides, allowedLimits); err != nil {
		level.Error(a.logger).Log("msg", "invalid overrides validation", "userID", userID, "err", err)
		http.Error(w, "Invalid overrides", http.StatusBadRequest)
		return
	}

	// Validate that values don't exceed hard limits from runtime config
	if err := a.validateHardLimits(overrides, userID); err != nil {
		level.Error(a.logger).Log("msg", "hard limits validation failed", "userID", userID, "err", err)
		http.Error(w, "Invalid overrides", http.StatusBadRequest)
		return
	}

	// Write overrides to bucket storage
	if err := a.setOverridesToBucket(r.Context(), userID, overrides); err != nil {
		level.Error(a.logger).Log("msg", "failed to set overrides to bucket", "userID", userID, "err", err)
		http.Error(w, "Internal server error", http.StatusInternalServerError)
		return
	}

	w.WriteHeader(http.StatusOK)
}

// DeleteOverrides removes tenant-specific overrides
func (a *API) DeleteOverrides(w http.ResponseWriter, r *http.Request) {