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)
}