forked from kyma-project/kyma
/
secret_resolver.go
39 lines (32 loc) · 1014 Bytes
/
secret_resolver.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
package k8s
import (
"context"
"github.com/golang/glog"
"github.com/kyma-project/kyma/components/ui-api-layer/internal/gqlschema"
"github.com/pkg/errors"
apierrors "k8s.io/apimachinery/pkg/api/errors"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/client-go/kubernetes/typed/core/v1"
)
func newSecretResolver(secretGetter v1.SecretsGetter) *secretResolver {
return &secretResolver{
converter: secretConverter{},
secretGetter: secretGetter,
}
}
type secretResolver struct {
secretGetter v1.SecretsGetter
converter secretConverter
}
func (r *secretResolver) SecretQuery(ctx context.Context, name, env string) (*gqlschema.Secret, error) {
secret, err := r.secretGetter.Secrets(env).Get(name, metav1.GetOptions{})
switch {
case apierrors.IsNotFound(err):
return nil, nil
case err != nil:
glog.Error(
errors.Wrapf(err, "while getting secret [name: %s, environment: %s]", name, env))
return nil, errors.New("cannot get Secret")
}
return r.converter.ToGQL(secret), nil
}