...
1 package resolver
2
3
4
5
6
7 import (
8 "context"
9
10 "edge-infra.dev/pkg/edge/api/graph/model"
11 )
12
13
14 func (r *mutationResolver) AddTerminalLabel(ctx context.Context, terminalLabelParameters model.NewTerminalLabelInput) (bool, error) {
15 r.LabelMutex.Lock()
16 defer r.LabelMutex.Unlock()
17 if err := r.TerminalLabelService.CreateTerminalLabel(ctx, terminalLabelParameters.TerminalID, terminalLabelParameters.LabelEdgeID); err != nil {
18 return false, err
19 }
20 return true, nil
21 }
22
23
24 func (r *mutationResolver) AddTerminalLabels(ctx context.Context, terminalID string, labelEdgeIds []string) (bool, error) {
25 r.LabelMutex.Lock()
26 defer r.LabelMutex.Unlock()
27 if err := r.TerminalLabelService.CreateTerminalLabel(ctx, terminalID, labelEdgeIds...); err != nil {
28 return false, err
29 }
30 return true, nil
31 }
32
33
34 func (r *mutationResolver) DeleteTerminalLabel(ctx context.Context, terminalLabelParameters model.SearchTerminalLabelInput) (bool, error) {
35 r.LabelMutex.Lock()
36 defer r.LabelMutex.Unlock()
37 affectedLabels, err := r.TerminalLabelService.DeleteTerminalLabels(ctx, terminalLabelParameters)
38 if err != nil {
39 return false, err
40 }
41
42
43 if err := r.TerminalLabelService.SendUpdatedIENCRAfterDeletion(ctx, affectedLabels); err != nil {
44 return false, err
45 }
46 return true, nil
47 }
48
49
50 func (r *queryResolver) TerminalLabels(ctx context.Context, terminalLabelParameters model.SearchTerminalLabelInput) ([]*model.TerminalLabel, error) {
51 return r.TerminalLabelService.GetTerminalLabels(ctx, terminalLabelParameters)
52 }
53
View as plain text