...
1 package resolver
2
3
4
5
6
7 import (
8 "context"
9 "errors"
10
11 "edge-infra.dev/pkg/edge/api/graph/generated"
12 "edge-infra.dev/pkg/edge/api/graph/model"
13 )
14
15
16 func (r *mutationResolver) CreateArtifactRegistry(ctx context.Context, createArtifactRegistry model.ArtifactRegistryCreateInput) (*model.ArtifactRegistry, error) {
17 return r.ArtifactRegistryService.CreateArtifactRegistryEntry(ctx, &createArtifactRegistry)
18 }
19
20
21 func (r *mutationResolver) UpdateArtifactRegistry(ctx context.Context, registryEdgeID string, updateArtifactRegistry model.ArtifactRegistryUpdateInput) (*model.ArtifactRegistry, error) {
22 return r.ArtifactRegistryService.UpdateArtifactRegistryEntry(ctx, registryEdgeID, &updateArtifactRegistry)
23 }
24
25
26 func (r *mutationResolver) DeleteArtifactRegistry(ctx context.Context, registryEdgeID string) (bool, error) {
27 return r.ArtifactRegistryService.DeleteArtifactRegistryEntry(ctx, registryEdgeID)
28 }
29
30
31 func (r *mutationResolver) CreateClusterArtifactRegistry(ctx context.Context, createClusterArtifactRegistry model.ClusterArtifactRegistryCreateInput) (*model.ClusterArtifactRegistry, error) {
32 return r.ArtifactRegistryService.CreateClusterArtifactRegistryEntry(ctx, &createClusterArtifactRegistry)
33 }
34
35
36 func (r *mutationResolver) DeleteClusterArtifactRegistry(ctx context.Context, clusterRegistryEdgeID string) (bool, error) {
37 return r.ArtifactRegistryService.DeleteClusterArtifactRegistryEntry(ctx, clusterRegistryEdgeID)
38 }
39
40
41 func (r *queryResolver) ArtifactRegistry(ctx context.Context, registryEdgeID string) (*model.ArtifactRegistry, error) {
42 return r.ArtifactRegistryService.GetArtifactRegistry(ctx, registryEdgeID)
43 }
44
45
46 func (r *queryResolver) ArtifactRegistries(ctx context.Context, bannerEdgeID *string, clusterEdgeID *string) ([]*model.ArtifactRegistry, error) {
47 switch {
48 case clusterEdgeID != nil:
49 return r.ArtifactRegistryService.GetArtifactRegistriesForCluster(ctx, *clusterEdgeID)
50 case bannerEdgeID != nil:
51 return r.ArtifactRegistryService.GetArtifactRegistriesForBanner(ctx, *bannerEdgeID)
52 default:
53 return nil, errors.New("must specify banner or cluster Edge ID")
54 }
55 }
56
57
58 func (r *queryResolver) ClusterArtifactRegistry(ctx context.Context, clusterRegistryEdgeID string) (*model.ClusterArtifactRegistry, error) {
59 return r.ArtifactRegistryService.GetClusterArtifactRegistry(ctx, clusterRegistryEdgeID)
60 }
61
62
63 func (r *queryResolver) ClusterArtifactRegistries(ctx context.Context, clusterEdgeID string) ([]*model.ClusterArtifactRegistry, error) {
64 return r.ArtifactRegistryService.GetClusterArtifactRegistries(ctx, clusterEdgeID)
65 }
66
67
68 func (r *Resolver) Mutation() generated.MutationResolver { return &mutationResolver{r} }
69
70 type mutationResolver struct{ *Resolver }
71
View as plain text