| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136 |
- /*
- 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 utils
- import (
- // nolint:gosec
- "crypto/md5"
- "fmt"
- "reflect"
- "strings"
- "unicode"
- esv1beta1 "github.com/external-secrets/external-secrets/apis/externalsecrets/v1beta1"
- esmeta "github.com/external-secrets/external-secrets/apis/meta/v1"
- )
- // MergeByteMap merges map of byte slices.
- func MergeByteMap(dst, src map[string][]byte) map[string][]byte {
- for k, v := range src {
- dst[k] = v
- }
- return dst
- }
- // ConvertKeys converts a secret map into a valid key.
- // Replaces any non-alphanumeric characters depending on convert strategy.
- func ConvertKeys(strategy esv1beta1.ExternalSecretConversionStrategy, in map[string][]byte) (map[string][]byte, error) {
- out := make(map[string][]byte, len(in))
- for k, v := range in {
- key := convert(strategy, k)
- if _, exists := out[key]; exists {
- return nil, fmt.Errorf("secret name collision during conversion: %s", key)
- }
- out[key] = v
- }
- return out, nil
- }
- func convert(strategy esv1beta1.ExternalSecretConversionStrategy, str string) string {
- rs := []rune(str)
- newName := make([]string, len(rs))
- for rk, rv := range rs {
- if !unicode.IsNumber(rv) &&
- !unicode.IsLetter(rv) &&
- rv != '-' &&
- rv != '.' &&
- rv != '_' {
- switch strategy {
- case esv1beta1.ExternalSecretConversionDefault:
- newName[rk] = "_"
- case esv1beta1.ExternalSecretConversionUnicode:
- newName[rk] = fmt.Sprintf("_U%04x_", rv)
- }
- } else {
- newName[rk] = string(rv)
- }
- }
- return strings.Join(newName, "")
- }
- // MergeStringMap performs a deep clone from src to dest.
- func MergeStringMap(dest, src map[string]string) {
- for k, v := range src {
- dest[k] = v
- }
- }
- // IsNil checks if an Interface is nil.
- func IsNil(i interface{}) bool {
- if i == nil {
- return true
- }
- value := reflect.ValueOf(i)
- if value.Type().Kind() == reflect.Ptr {
- return value.IsNil()
- }
- return false
- }
- // ObjectHash calculates md5 sum of the data contained in the secret.
- // nolint:gosec
- func ObjectHash(object interface{}) string {
- textualVersion := fmt.Sprintf("%+v", object)
- return fmt.Sprintf("%x", md5.Sum([]byte(textualVersion)))
- }
- func ErrorContains(out error, want string) bool {
- if out == nil {
- return want == ""
- }
- if want == "" {
- return false
- }
- return strings.Contains(out.Error(), want)
- }
- // ValidateSecretSelector just checks if the namespace field is present/absent
- // depending on the secret store type.
- // We MUST NOT check the name or key property here. It MAY be defaulted by the provider.
- func ValidateSecretSelector(store esv1beta1.GenericStore, ref esmeta.SecretKeySelector) error {
- clusterScope := store.GetObjectKind().GroupVersionKind().Kind == esv1beta1.ClusterSecretStoreKind
- if clusterScope && ref.Namespace == nil {
- return fmt.Errorf("cluster scope requires namespace")
- }
- if !clusterScope && ref.Namespace != nil {
- return fmt.Errorf("namespace not allowed with namespaced SecretStore")
- }
- return nil
- }
- // ValidateServiceAccountSelector just checks if the namespace field is present/absent
- // depending on the secret store type.
- // We MUST NOT check the name or key property here. It MAY be defaulted by the provider.
- func ValidateServiceAccountSelector(store esv1beta1.GenericStore, ref esmeta.ServiceAccountSelector) error {
- clusterScope := store.GetObjectKind().GroupVersionKind().Kind == esv1beta1.ClusterSecretStoreKind
- if clusterScope && ref.Namespace == nil {
- return fmt.Errorf("cluster scope requires namespace")
- }
- if !clusterScope && ref.Namespace != nil {
- return fmt.Errorf("namespace not allowed with namespaced SecretStore")
- }
- return nil
- }
|