91 lines
2.0 KiB
Go
91 lines
2.0 KiB
Go
|
package api
|
||
|
|
|
||
|
|
import (
|
||
|
|
"context"
|
||
|
|
"encoding/json"
|
||
|
|
"fmt"
|
||
|
|
"net/http"
|
||
|
|
|
||
|
|
"github.com/google/uuid"
|
||
|
|
"github.com/gorilla/mux"
|
||
|
|
"go.signoz.io/signoz/ee/query-service/model"
|
||
|
|
)
|
||
|
|
|
||
|
|
func (ah *APIHandler) listDomainsByOrg(w http.ResponseWriter, r *http.Request) {
|
||
|
|
orgId := mux.Vars(r)["orgId"]
|
||
|
|
domains, apierr := ah.AppDao().ListDomains(context.Background(), orgId)
|
||
|
|
if apierr != nil {
|
||
|
|
RespondError(w, apierr, domains)
|
||
|
|
return
|
||
|
|
}
|
||
|
|
ah.Respond(w, domains)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (ah *APIHandler) postDomain(w http.ResponseWriter, r *http.Request) {
|
||
|
|
ctx := context.Background()
|
||
|
|
|
||
|
|
req := model.OrgDomain{}
|
||
|
|
|
||
|
|
if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
|
||
|
|
RespondError(w, model.BadRequest(err), nil)
|
||
|
|
return
|
||
|
|
}
|
||
|
|
|
||
|
|
if err := req.ValidNew(); err != nil {
|
||
|
|
RespondError(w, model.BadRequest(err), nil)
|
||
|
|
return
|
||
|
|
}
|
||
|
|
|
||
|
|
if apierr := ah.AppDao().CreateDomain(ctx, &req); apierr != nil {
|
||
|
|
RespondError(w, apierr, nil)
|
||
|
|
return
|
||
|
|
}
|
||
|
|
|
||
|
|
ah.Respond(w, &req)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (ah *APIHandler) putDomain(w http.ResponseWriter, r *http.Request) {
|
||
|
|
ctx := context.Background()
|
||
|
|
|
||
|
|
domainIdStr := mux.Vars(r)["id"]
|
||
|
|
domainId, err := uuid.Parse(domainIdStr)
|
||
|
|
if err != nil {
|
||
|
|
RespondError(w, model.BadRequest(err), nil)
|
||
|
|
return
|
||
|
|
}
|
||
|
|
|
||
|
|
req := model.OrgDomain{Id: domainId}
|
||
|
|
if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
|
||
|
|
RespondError(w, model.BadRequest(err), nil)
|
||
|
|
return
|
||
|
|
}
|
||
|
|
req.Id = domainId
|
||
|
|
if err := req.Valid(nil); err != nil {
|
||
|
|
RespondError(w, model.BadRequest(err), nil)
|
||
|
|
}
|
||
|
|
|
||
|
|
if apierr := ah.AppDao().UpdateDomain(ctx, &req); apierr != nil {
|
||
|
|
RespondError(w, apierr, nil)
|
||
|
|
return
|
||
|
|
}
|
||
|
|
|
||
|
|
ah.Respond(w, &req)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (ah *APIHandler) deleteDomain(w http.ResponseWriter, r *http.Request) {
|
||
|
|
domainIdStr := mux.Vars(r)["id"]
|
||
|
|
|
||
|
|
domainId, err := uuid.Parse(domainIdStr)
|
||
|
|
if err != nil {
|
||
|
|
RespondError(w, model.BadRequest(fmt.Errorf("invalid domain id")), nil)
|
||
|
|
return
|
||
|
|
}
|
||
|
|
|
||
|
|
apierr := ah.AppDao().DeleteDomain(context.Background(), domainId)
|
||
|
|
if apierr != nil {
|
||
|
|
RespondError(w, apierr, nil)
|
||
|
|
return
|
||
|
|
}
|
||
|
|
ah.Respond(w, nil)
|
||
|
|
}
|