mirror of
https://github.com/grafana/grafana.git
synced 2025-02-25 18:55:37 -06:00
baed7d6dbe
With Find, if the parent query parameter is empty or not provided, we want to list the top level of the forest.
100 lines
2.5 KiB
Go
100 lines
2.5 KiB
Go
package scope
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"net/http"
|
|
|
|
"k8s.io/apimachinery/pkg/api/errors"
|
|
"k8s.io/apimachinery/pkg/apis/meta/internalversion"
|
|
"k8s.io/apimachinery/pkg/runtime"
|
|
"k8s.io/apimachinery/pkg/runtime/schema"
|
|
"k8s.io/apiserver/pkg/registry/rest"
|
|
|
|
scope "github.com/grafana/grafana/pkg/apis/scope/v0alpha1"
|
|
)
|
|
|
|
type findREST struct {
|
|
scopeNodeStorage *storage
|
|
}
|
|
|
|
var (
|
|
_ rest.Storage = (*findREST)(nil)
|
|
_ rest.SingularNameProvider = (*findREST)(nil)
|
|
_ rest.Connecter = (*findREST)(nil)
|
|
_ rest.Scoper = (*findREST)(nil)
|
|
_ rest.StorageMetadata = (*findREST)(nil)
|
|
)
|
|
|
|
func (r *findREST) New() runtime.Object {
|
|
// This is added as the "ResponseType" regarless what ProducesObject() says :)
|
|
return &scope.TreeResults{}
|
|
}
|
|
|
|
func (r *findREST) Destroy() {}
|
|
|
|
func (r *findREST) NamespaceScoped() bool {
|
|
return true
|
|
}
|
|
|
|
func (r *findREST) GetSingularName() string {
|
|
return "TreeResult" // Used for the
|
|
}
|
|
|
|
func (r *findREST) ProducesMIMETypes(verb string) []string {
|
|
return []string{"application/json"} // and parquet!
|
|
}
|
|
|
|
func (r *findREST) ProducesObject(verb string) interface{} {
|
|
return &scope.TreeResults{}
|
|
}
|
|
|
|
func (r *findREST) ConnectMethods() []string {
|
|
return []string{"GET"}
|
|
}
|
|
|
|
func (r *findREST) NewConnectOptions() (runtime.Object, bool, string) {
|
|
return nil, false, "" // true means you can use the trailing path as a variable
|
|
}
|
|
|
|
func (r *findREST) Connect(ctx context.Context, name string, opts runtime.Object, responder rest.Responder) (http.Handler, error) {
|
|
// See: /pkg/apiserver/builder/helper.go#L34
|
|
// The name is set with a rewriter hack
|
|
if name != "name" {
|
|
return nil, errors.NewNotFound(schema.GroupResource{}, name)
|
|
}
|
|
|
|
return http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {
|
|
parent := req.URL.Query().Get("parent")
|
|
results := &scope.TreeResults{}
|
|
|
|
raw, err := r.scopeNodeStorage.List(ctx, &internalversion.ListOptions{
|
|
Limit: 1000,
|
|
})
|
|
if err != nil {
|
|
responder.Error(err)
|
|
return
|
|
}
|
|
all, ok := raw.(*scope.ScopeNodeList)
|
|
if !ok {
|
|
responder.Error(fmt.Errorf("expected ScopeNodeList"))
|
|
return
|
|
}
|
|
|
|
for _, item := range all.Items {
|
|
if parent != item.Spec.ParentName {
|
|
continue // Someday this will have an index in raw storage on parentName
|
|
}
|
|
results.Items = append(results.Items, scope.TreeItem{
|
|
NodeID: item.Name,
|
|
NodeType: item.Spec.NodeType,
|
|
Title: item.Spec.Title,
|
|
Description: item.Spec.Description,
|
|
LinkType: item.Spec.LinkType,
|
|
LinkID: item.Spec.LinkID,
|
|
})
|
|
}
|
|
responder.Object(200, results)
|
|
}), nil
|
|
}
|