package resolver // This file will be automatically regenerated based on the schema, any resolver implementations // will be copied through when generating and any unknown code will be moved to the end. // Code generated by github.com/99designs/gqlgen version v0.17.45 import ( "context" "fmt" "edge-infra.dev/pkg/edge/api/graph/model" "github.com/rs/zerolog/log" ) // CreateLabel is the resolver for the createLabel field. func (r *mutationResolver) CreateLabel(ctx context.Context, newLabel *model.LabelInput) (bool, error) { err := r.LabelService.CreateLabel(ctx, newLabel) if err != nil { log.Err(err).Msg("error creating label") return false, err } return true, nil } // UpdateLabel is the resolver for the updateLabel field. func (r *mutationResolver) UpdateLabel(ctx context.Context, newLabel *model.LabelUpdateInput) (bool, error) { err := r.LabelService.UpdateLabel(ctx, newLabel) if err != nil { log.Err(err).Msg("error creating label") return false, err } return true, nil } // DeleteLabel is the resolver for the deleteLabel field. func (r *mutationResolver) DeleteLabel(ctx context.Context, labelEdgeID string) (bool, error) { err := r.LabelService.DeleteLabels(ctx, labelEdgeID) if err != nil { log.Err(err).Msg("error deleting label") return false, err } return true, nil } // AddClusterLabel is the resolver for the addClusterLabel field. func (r *mutationResolver) AddClusterLabel(ctx context.Context, clusterLabelParameters model.NewClusterLabelInput) (bool, error) { r.LabelMutex.Lock() defer r.LabelMutex.Unlock() err := r.LabelService.CreateClusterLabel(ctx, clusterLabelParameters.ClusterEdgeID, clusterLabelParameters.LabelEdgeID) if err != nil { log.Err(err).Msg("error creating cluster label") return false, err } return true, nil } // AddClusterLabels is the resolver for the addClusterLabels field. func (r *mutationResolver) AddClusterLabels(ctx context.Context, clusterEdgeID string, labelEdgeIds []string) (bool, error) { r.LabelMutex.Lock() defer r.LabelMutex.Unlock() err := r.LabelService.CreateClusterLabels(ctx, clusterEdgeID, labelEdgeIds) if err != nil { return false, err } return true, nil } // DeleteClusterLabel is the resolver for the deleteClusterLabel field. func (r *mutationResolver) DeleteClusterLabel(ctx context.Context, clusterLabelParameters model.SearchClusterLabelInput) (bool, error) { r.LabelMutex.Lock() defer r.LabelMutex.Unlock() err := r.LabelService.DeleteClusterLabels(ctx, clusterLabelParameters.ClusterEdgeID, clusterLabelParameters.LabelEdgeID) if err != nil { log.Err(err).Msg("error deleting cluster label") return false, err } return true, nil } // Labels is the resolver for the labels field. func (r *queryResolver) Labels(ctx context.Context, bannerEdgeID *string) ([]*model.Label, error) { return r.LabelService.GetLabels(ctx, bannerEdgeID) } // Label is the resolver for the label field. func (r *queryResolver) Label(ctx context.Context, labelEdgeID *string) (*model.Label, error) { panic(fmt.Errorf("not implemented")) } // ClusterLabels is the resolver for the clusterLabels field. func (r *queryResolver) ClusterLabels(ctx context.Context, clusterLabelParameters model.SearchClusterLabelInput) ([]*model.ClusterLabel, error) { return r.LabelService.GetClusterLabels(ctx, clusterLabelParameters.ClusterEdgeID, clusterLabelParameters.LabelEdgeID) } // LabelTypes is the resolver for the labelTypes field. func (r *queryResolver) LabelTypes(ctx context.Context, bannerEdgeID *string) ([]string, error) { return r.LabelService.GetLabelTypes(ctx, bannerEdgeID) }