|
@@ -0,0 +1,182 @@
|
|
|
|
|
+/*
|
|
|
|
|
+Licensed under the Apache License, Version 2.0 (the "License");
|
|
|
|
|
+you may not use this file except in compliance with the License.
|
|
|
|
|
+You may obtain a copy of the License at
|
|
|
|
|
+
|
|
|
|
|
+ http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
|
+
|
|
|
|
|
+Unless required by applicable law or agreed to in writing, software
|
|
|
|
|
+distributed under the License is distributed on an "AS IS" BASIS,
|
|
|
|
|
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
|
|
|
+See the License for the specific language governing permissions and
|
|
|
|
|
+limitations under the License.
|
|
|
|
|
+*/
|
|
|
|
|
+
|
|
|
|
|
+package device42
|
|
|
|
|
+
|
|
|
|
|
+import (
|
|
|
|
|
+ "context"
|
|
|
|
|
+ "fmt"
|
|
|
|
|
+ "time"
|
|
|
|
|
+
|
|
|
|
|
+ corev1 "k8s.io/api/core/v1"
|
|
|
|
|
+ "k8s.io/apimachinery/pkg/types"
|
|
|
|
|
+ kclient "sigs.k8s.io/controller-runtime/pkg/client"
|
|
|
|
|
+ "sigs.k8s.io/controller-runtime/pkg/webhook/admission"
|
|
|
|
|
+
|
|
|
|
|
+ esv1beta1 "github.com/external-secrets/external-secrets/apis/externalsecrets/v1beta1"
|
|
|
|
|
+ "github.com/external-secrets/external-secrets/pkg/utils"
|
|
|
|
|
+)
|
|
|
|
|
+
|
|
|
|
|
+const (
|
|
|
|
|
+ errNotImplemented = "not implemented"
|
|
|
|
|
+ errUninitializedProvider = "unable to get device42 client"
|
|
|
|
|
+ errCredSecretName = "credentials are empty"
|
|
|
|
|
+ errInvalidClusterStoreMissingSAKNamespace = "invalid clusterStore missing SAK namespace"
|
|
|
|
|
+ errFetchSAKSecret = "couldn't find secret on cluster: %w"
|
|
|
|
|
+ errMissingSAK = "missing credentials while setting auth"
|
|
|
|
|
+)
|
|
|
|
|
+
|
|
|
|
|
+type Client interface {
|
|
|
|
|
+ GetSecret(secretID string) (D42Password, error)
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
|
|
+// Device42 Provider struct with reference to a Device42 client.
|
|
|
|
|
+type Device42 struct {
|
|
|
|
|
+ client Client
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
|
|
+func (p *Device42) ValidateStore(esv1beta1.GenericStore) (admission.Warnings, error) {
|
|
|
|
|
+ return nil, nil
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
|
|
+func (p *Device42) Capabilities() esv1beta1.SecretStoreCapabilities {
|
|
|
|
|
+ return esv1beta1.SecretStoreReadOnly
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
|
|
+// Client for interacting with kubernetes.
|
|
|
|
|
+type device42Client struct {
|
|
|
|
|
+ kube kclient.Client
|
|
|
|
|
+ store *esv1beta1.Device42Provider
|
|
|
|
|
+ namespace string
|
|
|
|
|
+ storeKind string
|
|
|
|
|
+}
|
|
|
|
|
+type Provider struct{}
|
|
|
|
|
+
|
|
|
|
|
+func (c *device42Client) getAuth(ctx context.Context) (string, string, error) {
|
|
|
|
|
+ credentialsSecret := &corev1.Secret{}
|
|
|
|
|
+ credentialsSecretName := c.store.Auth.SecretRef.Credentials.Name
|
|
|
|
|
+ if credentialsSecretName == "" {
|
|
|
|
|
+ return "", "", fmt.Errorf(errCredSecretName)
|
|
|
|
|
+ }
|
|
|
|
|
+ objectKey := types.NamespacedName{
|
|
|
|
|
+ Name: credentialsSecretName,
|
|
|
|
|
+ Namespace: c.namespace,
|
|
|
|
|
+ }
|
|
|
|
|
+ // only ClusterStore is allowed to set namespace (and then it's required)
|
|
|
|
|
+ if c.storeKind == esv1beta1.ClusterSecretStoreKind {
|
|
|
|
|
+ if c.store.Auth.SecretRef.Credentials.Namespace == nil {
|
|
|
|
|
+ return "", "", fmt.Errorf(errInvalidClusterStoreMissingSAKNamespace)
|
|
|
|
|
+ }
|
|
|
|
|
+ objectKey.Namespace = *c.store.Auth.SecretRef.Credentials.Namespace
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ err := c.kube.Get(ctx, objectKey, credentialsSecret)
|
|
|
|
|
+ if err != nil {
|
|
|
|
|
+ return "", "", fmt.Errorf(errFetchSAKSecret, err)
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ username := credentialsSecret.Data["username"]
|
|
|
|
|
+ password := credentialsSecret.Data["password"]
|
|
|
|
|
+ if len(username) == 0 || len(password) == 0 {
|
|
|
|
|
+ return "", "", fmt.Errorf(errMissingSAK)
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ return string(username), string(password), nil
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
|
|
+// NewDevice42Provider returns a reference to a new instance of a 'Device42' struct.
|
|
|
|
|
+func NewDevice42Provider() *Device42 {
|
|
|
|
|
+ return &Device42{}
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
|
|
+func (p *Device42) NewClient(ctx context.Context, store esv1beta1.GenericStore, kube kclient.Client, namespace string) (esv1beta1.SecretsClient, error) {
|
|
|
|
|
+ storeSpec := store.GetSpec()
|
|
|
|
|
+ if storeSpec == nil || storeSpec.Provider == nil || storeSpec.Provider.Device42 == nil {
|
|
|
|
|
+ return nil, fmt.Errorf("no store type or wrong store type")
|
|
|
|
|
+ }
|
|
|
|
|
+ storeSpecDevice42 := storeSpec.Provider.Device42
|
|
|
|
|
+
|
|
|
|
|
+ cliStore := device42Client{
|
|
|
|
|
+ kube: kube,
|
|
|
|
|
+ store: storeSpecDevice42,
|
|
|
|
|
+ namespace: namespace,
|
|
|
|
|
+ storeKind: store.GetObjectKind().GroupVersionKind().Kind,
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ username, password, err := cliStore.getAuth(ctx)
|
|
|
|
|
+ if err != nil {
|
|
|
|
|
+ return nil, err
|
|
|
|
|
+ }
|
|
|
|
|
+ // Create a new client using credentials and options
|
|
|
|
|
+ p.client = NewAPI(storeSpecDevice42.Host, username, password, "443")
|
|
|
|
|
+
|
|
|
|
|
+ return p, nil
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
|
|
+func (p *Device42) SecretExists(_ context.Context, _ esv1beta1.PushSecretRemoteRef) (bool, error) {
|
|
|
|
|
+ return false, fmt.Errorf(errNotImplemented)
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
|
|
+func (p *Device42) Validate() (esv1beta1.ValidationResult, error) {
|
|
|
|
|
+ timeout := 15 * time.Second
|
|
|
|
|
+ url := fmt.Sprintf("https://%s:%s", p.client.(*API).baseURL, p.client.(*API).hostPort)
|
|
|
|
|
+
|
|
|
|
|
+ if err := utils.NetworkValidate(url, timeout); err != nil {
|
|
|
|
|
+ return esv1beta1.ValidationResultError, err
|
|
|
|
|
+ }
|
|
|
|
|
+ return esv1beta1.ValidationResultReady, nil
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
|
|
+func (p *Device42) PushSecret(_ context.Context, _ *corev1.Secret, _ esv1beta1.PushSecretData) error {
|
|
|
|
|
+ return fmt.Errorf(errNotImplemented)
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
|
|
+func (p *Device42) GetAllSecrets(_ context.Context, _ esv1beta1.ExternalSecretFind) (map[string][]byte, error) {
|
|
|
|
|
+ return nil, fmt.Errorf(errNotImplemented)
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
|
|
+func (p *Device42) DeleteSecret(_ context.Context, _ esv1beta1.PushSecretRemoteRef) error {
|
|
|
|
|
+ return fmt.Errorf(errNotImplemented)
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
|
|
+func (p *Device42) GetSecret(_ context.Context, ref esv1beta1.ExternalSecretDataRemoteRef) ([]byte, error) {
|
|
|
|
|
+ if utils.IsNil(p.client) {
|
|
|
|
|
+ return nil, fmt.Errorf(errUninitializedProvider)
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ data, err := p.client.GetSecret(ref.Key)
|
|
|
|
|
+ if err != nil {
|
|
|
|
|
+ return nil, err
|
|
|
|
|
+ }
|
|
|
|
|
+ return []byte(data.Password), nil
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
|
|
+func (p *Device42) GetSecretMap(_ context.Context, ref esv1beta1.ExternalSecretDataRemoteRef) (map[string][]byte, error) {
|
|
|
|
|
+ data, err := p.client.GetSecret(ref.Key)
|
|
|
|
|
+ if err != nil {
|
|
|
|
|
+ return nil, fmt.Errorf("error getting secret %s: %w", ref.Key, err)
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ return data.ToMap(), nil
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
|
|
+func (p *Device42) Close(_ context.Context) error {
|
|
|
|
|
+ return nil
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
|
|
+func init() {
|
|
|
|
|
+ esv1beta1.Register(&Device42{}, &esv1beta1.SecretStoreProvider{
|
|
|
|
|
+ Device42: &esv1beta1.Device42Provider{},
|
|
|
|
|
+ })
|
|
|
|
|
+}
|