mirror of
https://github.com/hanzoai/o11y.git
synced 2026-10-15 12:58:33 +00:00
zeekay
b36a8788a5
Full rebrand of the SigNoz observability platform: - Go module: github.com/SigNoz/signoz → github.com/hanzoai/o11y - Frontend: @signozhq/* → @hanzo/o11y-*, posthog-js → @hanzo/insights - Docker: signoz/* → ghcr.io/hanzoai/o11y* - ClickHouse → Hanzo Datastore (hanzoai/datastore) - Env vars: SIGNOZ_* → HANZO_* - DB tables: signoz_* → o11y_* - All branding, URLs, docs updated - 2172 files changed
61 lines
1.5 KiB
Go
61 lines
1.5 KiB
Go
package implpromote
|
|
|
|
import (
|
|
"net/http"
|
|
|
|
"github.com/hanzoai/o11y/pkg/errors"
|
|
"github.com/hanzoai/o11y/pkg/http/binding"
|
|
"github.com/hanzoai/o11y/pkg/http/render"
|
|
"github.com/hanzoai/o11y/pkg/modules/promote"
|
|
"github.com/hanzoai/o11y/pkg/types/authtypes"
|
|
"github.com/hanzoai/o11y/pkg/types/promotetypes"
|
|
)
|
|
|
|
type handler struct {
|
|
module promote.Module
|
|
}
|
|
|
|
func NewHandler(module promote.Module) promote.Handler {
|
|
return &handler{module: module}
|
|
}
|
|
|
|
func (h *handler) HandlePromoteAndIndexPaths(w http.ResponseWriter, r *http.Request) {
|
|
// TODO(Nitya): Use in multi tenant setup
|
|
_, err := authtypes.ClaimsFromContext(r.Context())
|
|
if err != nil {
|
|
render.Error(w, errors.NewInternalf(errors.CodeInternal, "failed to get org id from context"))
|
|
return
|
|
}
|
|
|
|
var req []*promotetypes.PromotePath
|
|
if err := binding.JSON.BindBody(r.Body, &req); err != nil {
|
|
render.Error(w, err)
|
|
return
|
|
}
|
|
|
|
err = h.module.PromoteAndIndexPaths(r.Context(), req...)
|
|
if err != nil {
|
|
render.Error(w, err)
|
|
return
|
|
}
|
|
|
|
render.Success(w, http.StatusCreated, nil)
|
|
}
|
|
|
|
func (h *handler) ListPromotedAndIndexedPaths(w http.ResponseWriter, r *http.Request) {
|
|
// TODO(Nitya): Use in multi tenant setup
|
|
_, err := authtypes.ClaimsFromContext(r.Context())
|
|
if err != nil {
|
|
render.Error(w, errors.NewInternalf(errors.CodeInternal, "failed to get org id from context"))
|
|
return
|
|
}
|
|
|
|
paths, err := h.module.ListPromotedAndIndexedPaths(r.Context())
|
|
if err != nil {
|
|
render.Error(w, err)
|
|
return
|
|
}
|
|
|
|
render.Success(w, http.StatusOK, paths)
|
|
}
|