| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763 |
- /*
- 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 oracle
- import (
- "context"
- "crypto/rand"
- "crypto/rsa"
- "crypto/x509"
- "encoding/base64"
- "encoding/pem"
- "fmt"
- "reflect"
- "strings"
- "testing"
- "time"
- "github.com/oracle/oci-go-sdk/v65/common"
- "github.com/oracle/oci-go-sdk/v65/secrets"
- "github.com/oracle/oci-go-sdk/v65/vault"
- "github.com/stretchr/testify/assert"
- corev1 "k8s.io/api/core/v1"
- metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
- "k8s.io/apimachinery/pkg/runtime"
- "k8s.io/utils/ptr"
- clientfake "sigs.k8s.io/controller-runtime/pkg/client/fake"
- esv1alpha1 "github.com/external-secrets/external-secrets/apis/externalsecrets/v1alpha1"
- esv1beta1 "github.com/external-secrets/external-secrets/apis/externalsecrets/v1beta1"
- esmeta "github.com/external-secrets/external-secrets/apis/meta/v1"
- fakeoracle "github.com/external-secrets/external-secrets/pkg/provider/oracle/fake"
- testingfake "github.com/external-secrets/external-secrets/pkg/provider/testing/fake"
- )
- const (
- vaultOCID = "vault-OCID"
- region = "some-region"
- tenant = "a-tenant"
- userOCID = "user-OCID"
- secretKey = "key"
- secretName = "name"
- )
- type vaultTestCase struct {
- mockClient *fakeoracle.OracleMockClient
- apiInput *secrets.GetSecretBundleByNameRequest
- apiOutput *secrets.GetSecretBundleByNameResponse
- ref *esv1beta1.ExternalSecretDataRemoteRef
- apiErr error
- expectError string
- expectedSecret string
- // for testing secretmap
- expectedData map[string][]byte
- }
- func makeValidVaultTestCase() *vaultTestCase {
- smtc := vaultTestCase{
- mockClient: &fakeoracle.OracleMockClient{},
- apiInput: makeValidAPIInput(),
- ref: makeValidRef(),
- apiOutput: makeValidAPIOutput(),
- apiErr: nil,
- expectError: "",
- expectedSecret: "",
- expectedData: map[string][]byte{},
- }
- smtc.mockClient.WithValue(*smtc.apiInput, *smtc.apiOutput, smtc.apiErr)
- return &smtc
- }
- func makeValidRef() *esv1beta1.ExternalSecretDataRemoteRef {
- return &esv1beta1.ExternalSecretDataRemoteRef{
- Key: "test-secret",
- Version: "default",
- }
- }
- func makeValidAPIInput() *secrets.GetSecretBundleByNameRequest {
- return &secrets.GetSecretBundleByNameRequest{
- SecretName: ptr.To("test-secret"),
- VaultId: ptr.To("test-vault"),
- }
- }
- func makeValidAPIOutput() *secrets.GetSecretBundleByNameResponse {
- return &secrets.GetSecretBundleByNameResponse{
- SecretBundle: secrets.SecretBundle{},
- }
- }
- func makeValidVaultTestCaseCustom(tweaks ...func(smtc *vaultTestCase)) *vaultTestCase {
- smtc := makeValidVaultTestCase()
- for _, fn := range tweaks {
- fn(smtc)
- }
- smtc.mockClient.WithValue(*smtc.apiInput, *smtc.apiOutput, smtc.apiErr)
- return smtc
- }
- // This case can be shared by both GetSecret and GetSecretMap tests.
- // bad case: set apiErr.
- var setAPIErr = func(smtc *vaultTestCase) {
- smtc.apiErr = fmt.Errorf("oh no")
- smtc.expectError = "oh no"
- }
- var setNilMockClient = func(smtc *vaultTestCase) {
- smtc.mockClient = nil
- smtc.expectError = errUninitalizedOracleProvider
- }
- func TestOracleVaultGetSecret(t *testing.T) {
- secretValue := "changedvalue"
- // good case: default version is set
- // key is passed in, output is sent back
- setSecretString := func(smtc *vaultTestCase) {
- smtc.apiOutput = &secrets.GetSecretBundleByNameResponse{
- SecretBundle: secrets.SecretBundle{
- SecretId: ptr.To("test-id"),
- VersionNumber: ptr.To(int64(1)),
- SecretBundleContent: secrets.Base64SecretBundleContentDetails{
- Content: ptr.To(base64.StdEncoding.EncodeToString([]byte(secretValue))),
- },
- },
- }
- smtc.expectedSecret = secretValue
- }
- successCases := []*vaultTestCase{
- makeValidVaultTestCaseCustom(setAPIErr),
- makeValidVaultTestCaseCustom(setNilMockClient),
- makeValidVaultTestCaseCustom(setSecretString),
- }
- sm := VaultManagementService{}
- for k, v := range successCases {
- sm.Client = v.mockClient
- fmt.Println(*v.ref)
- out, err := sm.GetSecret(context.Background(), *v.ref)
- if !ErrorContains(err, v.expectError) {
- t.Errorf("[%d] unexpected error: %s, expected: '%s'", k, err.Error(), v.expectError)
- }
- if string(out) != v.expectedSecret {
- t.Errorf("[%d] unexpected secret: expected %s, got %s", k, v.expectedSecret, string(out))
- }
- }
- }
- func TestGetSecretMap(t *testing.T) {
- // good case: default version & deserialization
- setDeserialization := func(smtc *vaultTestCase) {
- smtc.apiOutput.SecretBundleContent = secrets.Base64SecretBundleContentDetails{
- Content: ptr.To(base64.StdEncoding.EncodeToString([]byte(`{"foo":"bar"}`))),
- }
- smtc.expectedData["foo"] = []byte("bar")
- }
- // bad case: invalid json
- setInvalidJSON := func(smtc *vaultTestCase) {
- smtc.apiOutput.SecretBundleContent = secrets.Base64SecretBundleContentDetails{
- Content: ptr.To(base64.StdEncoding.EncodeToString([]byte(`-----------------`))),
- }
- smtc.expectError = "unable to unmarshal secret"
- }
- successCases := []*vaultTestCase{
- makeValidVaultTestCaseCustom(setDeserialization),
- makeValidVaultTestCaseCustom(setInvalidJSON),
- makeValidVaultTestCaseCustom(setNilMockClient),
- makeValidVaultTestCaseCustom(setAPIErr),
- }
- sm := VaultManagementService{}
- for k, v := range successCases {
- sm.Client = v.mockClient
- out, err := sm.GetSecretMap(context.Background(), *v.ref)
- if !ErrorContains(err, v.expectError) {
- t.Errorf("[%d] unexpected error: %s, expected: '%s'", k, err.Error(), v.expectError)
- }
- if err == nil && !reflect.DeepEqual(out, v.expectedData) {
- t.Errorf("[%d] unexpected secret data: expected %#v, got %#v", k, v.expectedData, out)
- }
- }
- }
- func ErrorContains(out error, want string) bool {
- if out == nil {
- return want == ""
- }
- if want == "" {
- return false
- }
- return strings.Contains(out.Error(), want)
- }
- type storeModifier func(*esv1beta1.SecretStore) *esv1beta1.SecretStore
- func makeSecretStore(vault, region string, fn ...storeModifier) *esv1beta1.SecretStore {
- store := &esv1beta1.SecretStore{
- Spec: esv1beta1.SecretStoreSpec{
- Provider: &esv1beta1.SecretStoreProvider{
- Oracle: &esv1beta1.OracleProvider{
- Vault: vault,
- Region: region,
- },
- },
- },
- }
- for _, f := range fn {
- store = f(store)
- }
- return store
- }
- func withSecretAuth(user, tenancy string) storeModifier {
- return func(store *esv1beta1.SecretStore) *esv1beta1.SecretStore {
- store.Spec.Provider.Oracle.Auth = &esv1beta1.OracleAuth{
- User: user,
- Tenancy: tenancy,
- }
- return store
- }
- }
- func withPrivateKey(name, key string, namespace *string) storeModifier {
- return func(store *esv1beta1.SecretStore) *esv1beta1.SecretStore {
- store.Spec.Provider.Oracle.Auth.SecretRef.PrivateKey = esmeta.SecretKeySelector{
- Name: name,
- Key: key,
- Namespace: namespace,
- }
- return store
- }
- }
- func withFingerprint(name, key string, namespace *string) storeModifier {
- return func(store *esv1beta1.SecretStore) *esv1beta1.SecretStore {
- store.Spec.Provider.Oracle.Auth.SecretRef.Fingerprint = esmeta.SecretKeySelector{
- Name: name,
- Key: key,
- Namespace: namespace,
- }
- return store
- }
- }
- type ValidateStoreTestCase struct {
- store *esv1beta1.SecretStore
- err error
- }
- func TestValidateStore(t *testing.T) {
- namespace := "my-namespace"
- testCases := []ValidateStoreTestCase{
- {
- store: makeSecretStore("", region),
- err: fmt.Errorf("vault cannot be empty"),
- },
- {
- store: makeSecretStore(vaultOCID, ""),
- err: fmt.Errorf("region cannot be empty"),
- },
- {
- store: makeSecretStore(vaultOCID, region, withSecretAuth("", tenant)),
- err: fmt.Errorf("user cannot be empty"),
- },
- {
- store: makeSecretStore(vaultOCID, region, withSecretAuth(userOCID, "")),
- err: fmt.Errorf("tenant cannot be empty"),
- },
- {
- store: makeSecretStore(vaultOCID, region, withSecretAuth(userOCID, tenant), withPrivateKey("", secretKey, nil)),
- err: fmt.Errorf("privateKey.name cannot be empty"),
- },
- {
- store: makeSecretStore(vaultOCID, region, withSecretAuth(userOCID, tenant), withPrivateKey(secretName, secretKey, &namespace)),
- err: fmt.Errorf("namespace not allowed with namespaced SecretStore"),
- },
- {
- store: makeSecretStore(vaultOCID, region, withSecretAuth(userOCID, tenant), withPrivateKey(secretName, "", nil)),
- err: fmt.Errorf("privateKey.key cannot be empty"),
- },
- {
- store: makeSecretStore(vaultOCID, region, withSecretAuth(userOCID, tenant), withPrivateKey(secretName, secretKey, nil), withFingerprint("", secretKey, nil)),
- err: fmt.Errorf("fingerprint.name cannot be empty"),
- },
- {
- store: makeSecretStore(vaultOCID, region, withSecretAuth(userOCID, tenant), withPrivateKey(secretName, secretKey, nil), withFingerprint(secretName, secretKey, &namespace)),
- err: fmt.Errorf("namespace not allowed with namespaced SecretStore"),
- },
- {
- store: makeSecretStore(vaultOCID, region, withSecretAuth(userOCID, tenant), withPrivateKey(secretName, secretKey, nil), withFingerprint(secretName, "", nil)),
- err: fmt.Errorf("fingerprint.key cannot be empty"),
- },
- {
- store: makeSecretStore(vaultOCID, region),
- err: nil,
- },
- }
- p := VaultManagementService{}
- for _, tc := range testCases {
- err := p.ValidateStore(tc.store)
- if tc.err != nil && err != nil && err.Error() != tc.err.Error() {
- t.Errorf("test failed! want %v, got %v", tc.err, err)
- } else if tc.err == nil && err != nil {
- t.Errorf("want nil got err %v", err)
- } else if tc.err != nil && err == nil {
- t.Errorf("want err %v got nil", tc.err)
- }
- }
- }
- func TestVaultManagementService_NewClient(t *testing.T) {
- t.Parallel()
- namespace := "default"
- authSecretName := "oracle-auth"
- auth := &esv1beta1.OracleAuth{
- User: "user",
- Tenancy: "tenancy",
- SecretRef: esv1beta1.OracleSecretRef{
- PrivateKey: esmeta.SecretKeySelector{
- Name: authSecretName,
- Key: "privateKey",
- },
- Fingerprint: esmeta.SecretKeySelector{
- Name: authSecretName,
- Key: "fingerprint",
- },
- },
- }
- tests := []struct {
- desc string
- secretStore *esv1beta1.SecretStore
- expectedErr string
- }{
- {
- desc: "no retry settings",
- secretStore: &esv1beta1.SecretStore{
- Spec: esv1beta1.SecretStoreSpec{
- Provider: &esv1beta1.SecretStoreProvider{
- Oracle: &esv1beta1.OracleProvider{
- Vault: vaultOCID,
- Region: region,
- Auth: auth,
- },
- },
- },
- },
- },
- {
- desc: "fill all the retry settings",
- secretStore: &esv1beta1.SecretStore{
- Spec: esv1beta1.SecretStoreSpec{
- Provider: &esv1beta1.SecretStoreProvider{
- Oracle: &esv1beta1.OracleProvider{
- Vault: vaultOCID,
- Region: region,
- Auth: auth,
- },
- },
- RetrySettings: &esv1beta1.SecretStoreRetrySettings{
- RetryInterval: ptr.To("1s"),
- MaxRetries: ptr.To(int32(5)),
- },
- },
- },
- },
- {
- desc: "partially configure the retry settings - retry interval",
- secretStore: &esv1beta1.SecretStore{
- Spec: esv1beta1.SecretStoreSpec{
- Provider: &esv1beta1.SecretStoreProvider{
- Oracle: &esv1beta1.OracleProvider{
- Vault: vaultOCID,
- Region: region,
- Auth: auth,
- },
- },
- RetrySettings: &esv1beta1.SecretStoreRetrySettings{
- RetryInterval: ptr.To("1s"),
- },
- },
- },
- },
- {
- desc: "partially configure the retry settings - max retries",
- secretStore: &esv1beta1.SecretStore{
- Spec: esv1beta1.SecretStoreSpec{
- Provider: &esv1beta1.SecretStoreProvider{
- Oracle: &esv1beta1.OracleProvider{
- Vault: vaultOCID,
- Region: region,
- Auth: auth,
- },
- },
- RetrySettings: &esv1beta1.SecretStoreRetrySettings{
- MaxRetries: ptr.To(int32(5)),
- },
- },
- },
- },
- {
- desc: "auth secret does not exist",
- secretStore: &esv1beta1.SecretStore{
- Spec: esv1beta1.SecretStoreSpec{
- Provider: &esv1beta1.SecretStoreProvider{
- Oracle: &esv1beta1.OracleProvider{
- Vault: vaultOCID,
- Region: region,
- Auth: &esv1beta1.OracleAuth{
- User: "user",
- Tenancy: "tenancy",
- SecretRef: esv1beta1.OracleSecretRef{
- PrivateKey: esmeta.SecretKeySelector{
- Name: "non-existing-secret",
- Key: "privateKey",
- },
- Fingerprint: esmeta.SecretKeySelector{
- Name: "non-existing-secret",
- Key: "fingerprint",
- },
- },
- },
- },
- },
- RetrySettings: &esv1beta1.SecretStoreRetrySettings{
- RetryInterval: ptr.To("invalid"),
- },
- },
- },
- expectedErr: `could not fetch SecretAccessKey secret: secrets "non-existing-secret"`,
- },
- {
- desc: "invalid retry interval",
- secretStore: &esv1beta1.SecretStore{
- Spec: esv1beta1.SecretStoreSpec{
- Provider: &esv1beta1.SecretStoreProvider{
- Oracle: &esv1beta1.OracleProvider{
- Vault: vaultOCID,
- Region: region,
- Auth: auth,
- },
- },
- RetrySettings: &esv1beta1.SecretStoreRetrySettings{
- RetryInterval: ptr.To("invalid"),
- },
- },
- },
- expectedErr: "cannot setup new oracle client: time: invalid duration",
- },
- }
- for _, tc := range tests {
- t.Run(tc.desc, func(t *testing.T) {
- provider := &VaultManagementService{
- Client: &fakeoracle.OracleMockClient{},
- KmsVaultClient: nil,
- vault: vaultOCID,
- }
- pk, err := rsa.GenerateKey(rand.Reader, 2048)
- if err != nil {
- t.Fatalf("failed to create a private key: %v", err)
- }
- schema := runtime.NewScheme()
- if err := corev1.AddToScheme(schema); err != nil {
- t.Fatalf("failed to add to schema: %v", err)
- }
- builder := clientfake.NewClientBuilder().WithRuntimeObjects(&corev1.Secret{
- ObjectMeta: metav1.ObjectMeta{
- Name: authSecretName,
- Namespace: namespace,
- },
- Data: map[string][]byte{
- "privateKey": pem.EncodeToMemory(&pem.Block{
- Type: "RSA PRIVATE KEY",
- Bytes: x509.MarshalPKCS1PrivateKey(pk),
- }),
- "fingerprint": []byte("fingerprint"),
- },
- })
- _, err = provider.NewClient(context.Background(), tc.secretStore, builder.Build(), namespace)
- if err != nil {
- if tc.expectedErr == "" {
- t.Fatalf("failed to call NewClient: %v", err)
- }
- if !strings.Contains(err.Error(), tc.expectedErr) {
- t.Fatalf("received an unexpected error: %q should have contained %q", err.Error(), tc.expectedErr)
- }
- return
- }
- if tc.expectedErr != "" {
- t.Fatalf("expeceted to receive an error but got nil")
- }
- })
- }
- }
- func TestOracleVaultGetAllSecrets(t *testing.T) {
- var testCases = map[string]struct {
- vms *VaultManagementService
- ref esv1beta1.ExternalSecretFind
- result map[string][]byte
- }{
- "filters secrets that don't match the pattern": {
- &VaultManagementService{
- Client: &fakeoracle.OracleMockClient{
- SecretBundles: map[string]secrets.SecretBundle{
- s1id: s1bundle,
- s2id: s2bundle,
- },
- },
- VaultClient: &fakeoracle.OracleMockVaultClient{
- SecretSummaries: []vault.SecretSummary{
- s1summary,
- s2summary,
- },
- },
- },
- esv1beta1.ExternalSecretFind{
- Name: &esv1beta1.FindName{
- RegExp: "^test.*",
- },
- },
- map[string][]byte{
- s1id: []byte(s1id),
- },
- },
- "filters secrets that are deleting": {
- &VaultManagementService{
- Client: &fakeoracle.OracleMockClient{
- SecretBundles: map[string]secrets.SecretBundle{
- s1id: s1bundle,
- s2id: s2bundle,
- s3id: s3bundle,
- },
- },
- VaultClient: &fakeoracle.OracleMockVaultClient{
- SecretSummaries: []vault.SecretSummary{
- s1summary,
- s2summary,
- s3summary,
- },
- },
- },
- esv1beta1.ExternalSecretFind{
- Name: &esv1beta1.FindName{
- RegExp: ".*",
- },
- },
- map[string][]byte{
- s1id: []byte(s1id),
- s2id: []byte(s2id),
- },
- },
- }
- for name, testCase := range testCases {
- t.Run(name, func(t *testing.T) {
- result, err := testCase.vms.GetAllSecrets(context.Background(), testCase.ref)
- assert.NoError(t, err)
- assert.EqualValues(t, testCase.result, result)
- })
- }
- }
- func TestOracleVaultPushSecret(t *testing.T) {
- testSecretKey := "test-secret-key"
- var testCases = map[string]struct {
- vms *VaultManagementService
- data testingfake.PushSecretData
- validator func(service *VaultManagementService) bool
- content string
- }{
- "create a secret if not exists": {
- &VaultManagementService{
- Client: &fakeoracle.OracleMockClient{
- SecretBundles: map[string]secrets.SecretBundle{
- s2id: s2bundle,
- },
- },
- VaultClient: &fakeoracle.OracleMockVaultClient{},
- },
- testingfake.PushSecretData{
- SecretKey: testSecretKey,
- RemoteKey: s1id,
- },
- func(vms *VaultManagementService) bool {
- return vms.VaultClient.(*fakeoracle.OracleMockVaultClient).CreatedCount == 1
- },
- "created",
- },
- "update a secret if exists": {
- &VaultManagementService{
- Client: &fakeoracle.OracleMockClient{
- SecretBundles: map[string]secrets.SecretBundle{
- s1id: s1bundle,
- s2id: s2bundle,
- },
- },
- VaultClient: &fakeoracle.OracleMockVaultClient{},
- },
- testingfake.PushSecretData{
- SecretKey: testSecretKey,
- RemoteKey: s1id,
- },
- func(vms *VaultManagementService) bool {
- return vms.VaultClient.(*fakeoracle.OracleMockVaultClient).UpdatedCount == 1
- },
- "updated",
- },
- "neither create nor update if secret content is unchanged": {
- &VaultManagementService{
- Client: &fakeoracle.OracleMockClient{
- SecretBundles: map[string]secrets.SecretBundle{
- s1id: s1bundle,
- s2id: s2bundle,
- },
- },
- VaultClient: &fakeoracle.OracleMockVaultClient{},
- },
- testingfake.PushSecretData{
- SecretKey: testSecretKey,
- RemoteKey: s1id,
- },
- func(vms *VaultManagementService) bool {
- return vms.VaultClient.(*fakeoracle.OracleMockVaultClient).UpdatedCount == 0 &&
- vms.VaultClient.(*fakeoracle.OracleMockVaultClient).CreatedCount == 0
- },
- s1id,
- },
- }
- for name, testCase := range testCases {
- t.Run(name, func(t *testing.T) {
- s := &corev1.Secret{Data: map[string][]byte{testSecretKey: []byte(testCase.content)}}
- err := testCase.vms.PushSecret(context.Background(), s, testCase.data)
- assert.NoError(t, err)
- assert.True(t, testCase.validator(testCase.vms))
- })
- }
- }
- func TestOracleVaultDeleteSecret(t *testing.T) {
- var testCases = map[string]struct {
- vms *VaultManagementService
- remoteRef esv1beta1.PushSecretRemoteRef
- validator func(service *VaultManagementService) bool
- }{
- "do not delete if secret not found": {
- &VaultManagementService{
- Client: &fakeoracle.OracleMockClient{
- SecretBundles: map[string]secrets.SecretBundle{
- s1id: s1bundle,
- },
- },
- VaultClient: &fakeoracle.OracleMockVaultClient{},
- },
- esv1alpha1.PushSecretRemoteRef{
- RemoteKey: s2id,
- },
- func(vms *VaultManagementService) bool {
- return vms.VaultClient.(*fakeoracle.OracleMockVaultClient).DeletedCount == 0
- },
- },
- "do not delete if secret os already deleting": {
- &VaultManagementService{
- Client: &fakeoracle.OracleMockClient{
- SecretBundles: map[string]secrets.SecretBundle{
- s1id: s1bundle,
- s3id: s3bundle,
- },
- },
- VaultClient: &fakeoracle.OracleMockVaultClient{},
- },
- esv1alpha1.PushSecretRemoteRef{
- RemoteKey: s3id,
- },
- func(vms *VaultManagementService) bool {
- return vms.VaultClient.(*fakeoracle.OracleMockVaultClient).DeletedCount == 0
- },
- },
- "delete existing secret": {
- &VaultManagementService{
- Client: &fakeoracle.OracleMockClient{
- SecretBundles: map[string]secrets.SecretBundle{
- s1id: s1bundle,
- s3id: s3bundle,
- },
- },
- VaultClient: &fakeoracle.OracleMockVaultClient{},
- },
- esv1alpha1.PushSecretRemoteRef{
- RemoteKey: s1id,
- },
- func(vms *VaultManagementService) bool {
- return vms.VaultClient.(*fakeoracle.OracleMockVaultClient).DeletedCount == 1
- },
- },
- }
- for name, testCase := range testCases {
- t.Run(name, func(t *testing.T) {
- err := testCase.vms.DeleteSecret(context.Background(), testCase.remoteRef)
- assert.NoError(t, err)
- assert.True(t, testCase.validator(testCase.vms))
- })
- }
- }
- var (
- s1id = "test1"
- s2id = "mysecret"
- s3id = "deleting"
- s1bundle = makeSecretBundle(s1id, false)
- s2bundle = makeSecretBundle(s2id, false)
- s3bundle = makeSecretBundle(s3id, true)
- s1summary = makeSecretSummary(s1id, false)
- s2summary = makeSecretSummary(s2id, false)
- s3summary = makeSecretSummary(s3id, true)
- )
- func makeSecretBundle(id string, deleting bool) secrets.SecretBundle {
- var deletionTime *common.SDKTime
- if deleting {
- deletionTime = &common.SDKTime{
- Time: time.Now(),
- }
- }
- return secrets.SecretBundle{
- SecretId: &id,
- SecretBundleContent: secrets.Base64SecretBundleContentDetails{
- Content: ptr.To(base64.StdEncoding.EncodeToString([]byte(id))),
- },
- TimeOfDeletion: deletionTime,
- }
- }
- func makeSecretSummary(id string, deleting bool) vault.SecretSummary {
- var deletionTime *common.SDKTime
- if deleting {
- deletionTime = &common.SDKTime{
- Time: time.Now(),
- }
- }
- return vault.SecretSummary{
- Id: &id,
- SecretName: &id,
- TimeOfDeletion: deletionTime,
- }
- }
|