|
|
@@ -140,6 +140,9 @@ const (
|
|
|
foo = "foo"
|
|
|
bar = "bar"
|
|
|
errStore = "Azure.ValidateStore() error = %v, wantErr %v"
|
|
|
+ externalSecrets = "external-secrets"
|
|
|
+ notFoundMessage = "Not Found"
|
|
|
+ forbiddenMessage = "Forbidden"
|
|
|
)
|
|
|
|
|
|
func getTagMap() map[string]*string {
|
|
|
@@ -176,7 +179,7 @@ func TestAzureKeyVaultDeleteSecret(t *testing.T) {
|
|
|
}
|
|
|
smtc.secretOutput = keyvault.SecretBundle{
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To("external-secrets"),
|
|
|
+ managedBy: pointer.To(externalSecrets),
|
|
|
},
|
|
|
Value: pointer.To("foo"),
|
|
|
}
|
|
|
@@ -187,8 +190,8 @@ func TestAzureKeyVaultDeleteSecret(t *testing.T) {
|
|
|
smtc.pushData = testingfake.PushSecretData{
|
|
|
RemoteKey: secretName,
|
|
|
}
|
|
|
- smtc.apiErr = autorest.DetailedError{StatusCode: 404, Method: "GET", Message: "Not Found"}
|
|
|
- smtc.deleteErr = autorest.DetailedError{StatusCode: 404, Method: "DELETE", Message: "Not Found"}
|
|
|
+ smtc.apiErr = autorest.DetailedError{StatusCode: 404, Method: "GET", Message: notFoundMessage}
|
|
|
+ smtc.deleteErr = autorest.DetailedError{StatusCode: 404, Method: "DELETE", Message: notFoundMessage}
|
|
|
}
|
|
|
|
|
|
secretNotManaged := func(smtc *secretManagerTestCase) {
|
|
|
@@ -216,7 +219,7 @@ func TestAzureKeyVaultDeleteSecret(t *testing.T) {
|
|
|
}
|
|
|
smtc.secretOutput = keyvault.SecretBundle{
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To("external-secrets"),
|
|
|
+ managedBy: pointer.To(externalSecrets),
|
|
|
},
|
|
|
Value: pointer.To("foo"),
|
|
|
}
|
|
|
@@ -238,7 +241,7 @@ func TestAzureKeyVaultDeleteSecret(t *testing.T) {
|
|
|
}
|
|
|
smtc.certOutput = keyvault.CertificateBundle{
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To("external-secrets"),
|
|
|
+ managedBy: pointer.To(externalSecrets),
|
|
|
},
|
|
|
}
|
|
|
smtc.deleteCertificateOutput = keyvault.DeletedCertificateBundle{}
|
|
|
@@ -248,7 +251,7 @@ func TestAzureKeyVaultDeleteSecret(t *testing.T) {
|
|
|
RemoteKey: certName,
|
|
|
}
|
|
|
smtc.apiErr = autorest.DetailedError{StatusCode: 404, Method: "GET", Message: "Certificate Not Found"}
|
|
|
- smtc.deleteErr = autorest.DetailedError{StatusCode: 404, Method: "DELETE", Message: "Not Found"}
|
|
|
+ smtc.deleteErr = autorest.DetailedError{StatusCode: 404, Method: "DELETE", Message: notFoundMessage}
|
|
|
}
|
|
|
|
|
|
certNotManaged := func(smtc *secretManagerTestCase) {
|
|
|
@@ -274,7 +277,7 @@ func TestAzureKeyVaultDeleteSecret(t *testing.T) {
|
|
|
}
|
|
|
smtc.certOutput = keyvault.CertificateBundle{
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To("external-secrets"),
|
|
|
+ managedBy: pointer.To(externalSecrets),
|
|
|
},
|
|
|
}
|
|
|
smtc.expectError = "No certificate delete Permissions"
|
|
|
@@ -295,7 +298,7 @@ func TestAzureKeyVaultDeleteSecret(t *testing.T) {
|
|
|
}
|
|
|
smtc.keyOutput = keyvault.KeyBundle{
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To("external-secrets"),
|
|
|
+ managedBy: pointer.To(externalSecrets),
|
|
|
},
|
|
|
}
|
|
|
smtc.deleteKeyOutput = keyvault.DeletedKeyBundle{}
|
|
|
@@ -304,8 +307,8 @@ func TestAzureKeyVaultDeleteSecret(t *testing.T) {
|
|
|
smtc.pushData = testingfake.PushSecretData{
|
|
|
RemoteKey: keyName,
|
|
|
}
|
|
|
- smtc.apiErr = autorest.DetailedError{StatusCode: 404, Method: "GET", Message: "Not Found"}
|
|
|
- smtc.deleteErr = autorest.DetailedError{StatusCode: 404, Method: "DELETE", Message: "Not Found"}
|
|
|
+ smtc.apiErr = autorest.DetailedError{StatusCode: 404, Method: "GET", Message: notFoundMessage}
|
|
|
+ smtc.deleteErr = autorest.DetailedError{StatusCode: 404, Method: "DELETE", Message: notFoundMessage}
|
|
|
}
|
|
|
|
|
|
keyNotManaged := func(smtc *secretManagerTestCase) {
|
|
|
@@ -331,7 +334,7 @@ func TestAzureKeyVaultDeleteSecret(t *testing.T) {
|
|
|
}
|
|
|
smtc.keyOutput = keyvault.KeyBundle{
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To("external-secrets"),
|
|
|
+ managedBy: pointer.To(externalSecrets),
|
|
|
},
|
|
|
}
|
|
|
smtc.expectError = errNoPermission
|
|
|
@@ -405,7 +408,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
}
|
|
|
smtc.secretOutput = keyvault.SecretBundle{
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To("external-secrets"),
|
|
|
+ managedBy: pointer.To(externalSecrets),
|
|
|
},
|
|
|
Value: &goodSecret,
|
|
|
}
|
|
|
@@ -418,7 +421,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
}
|
|
|
smtc.secretOutput = keyvault.SecretBundle{
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To("external-secrets"),
|
|
|
+ managedBy: pointer.To(externalSecrets),
|
|
|
},
|
|
|
Value: &goodSecret,
|
|
|
}
|
|
|
@@ -445,7 +448,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
}
|
|
|
smtc.secretOutput = keyvault.SecretBundle{
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To("external-secrets"),
|
|
|
+ managedBy: pointer.To(externalSecrets),
|
|
|
},
|
|
|
Value: &goodSecret,
|
|
|
Attributes: &keyvault.SecretAttributes{
|
|
|
@@ -454,7 +457,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
}
|
|
|
smtc.setSecretOutput = keyvault.SecretBundle{
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To("external-secrets"),
|
|
|
+ managedBy: pointer.To(externalSecrets),
|
|
|
},
|
|
|
Value: &goodSecret,
|
|
|
Attributes: &keyvault.SecretAttributes{
|
|
|
@@ -470,7 +473,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
}
|
|
|
smtc.secretOutput = keyvault.SecretBundle{
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To("nope"),
|
|
|
+ managedBy: pointer.To("nope"),
|
|
|
},
|
|
|
Value: &goodSecret,
|
|
|
}
|
|
|
@@ -486,7 +489,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
}
|
|
|
smtc.secretOutput = keyvault.SecretBundle{
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To("external-secrets"),
|
|
|
+ managedBy: pointer.To(externalSecrets),
|
|
|
},
|
|
|
Value: &wholeSecretString,
|
|
|
}
|
|
|
@@ -512,7 +515,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
SecretKey: secretKey,
|
|
|
RemoteKey: secretName,
|
|
|
}
|
|
|
- smtc.apiErr = autorest.DetailedError{StatusCode: 404, Method: "GET", Message: "Not Found"}
|
|
|
+ smtc.apiErr = autorest.DetailedError{StatusCode: 404, Method: "GET", Message: notFoundMessage}
|
|
|
}
|
|
|
failedGetSecret := func(smtc *secretManagerTestCase) {
|
|
|
smtc.setValue = []byte(goodSecret)
|
|
|
@@ -520,7 +523,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
SecretKey: secretKey,
|
|
|
RemoteKey: secretName,
|
|
|
}
|
|
|
- smtc.apiErr = autorest.DetailedError{StatusCode: 403, Method: "GET", Message: "Forbidden"}
|
|
|
+ smtc.apiErr = autorest.DetailedError{StatusCode: 403, Method: "GET", Message: forbiddenMessage}
|
|
|
smtc.expectError = errAPI
|
|
|
}
|
|
|
failedNotParseableError := func(smtc *secretManagerTestCase) {
|
|
|
@@ -538,8 +541,8 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
SecretKey: secretKey,
|
|
|
RemoteKey: secretName,
|
|
|
}
|
|
|
- smtc.apiErr = autorest.DetailedError{StatusCode: 404, Method: "GET", Message: "Not Found"}
|
|
|
- smtc.setErr = autorest.DetailedError{StatusCode: 403, Method: "POST", Message: "Forbidden"}
|
|
|
+ smtc.apiErr = autorest.DetailedError{StatusCode: 404, Method: "GET", Message: notFoundMessage}
|
|
|
+ smtc.setErr = autorest.DetailedError{StatusCode: 403, Method: "POST", Message: forbiddenMessage}
|
|
|
smtc.expectError = "could not set secret example-1: #POST: Forbidden: StatusCode=403"
|
|
|
}
|
|
|
keySuccess := func(smtc *secretManagerTestCase) {
|
|
|
@@ -550,7 +553,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
}
|
|
|
smtc.keyOutput = keyvault.KeyBundle{
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To(managerLabel),
|
|
|
+ managedBy: pointer.To(managerLabel),
|
|
|
},
|
|
|
Key: &keyvault.JSONWebKey{},
|
|
|
}
|
|
|
@@ -563,7 +566,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
}
|
|
|
smtc.keyOutput = keyvault.KeyBundle{
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To(managerLabel),
|
|
|
+ managedBy: pointer.To(managerLabel),
|
|
|
},
|
|
|
Key: &keyvault.JSONWebKey{},
|
|
|
}
|
|
|
@@ -576,7 +579,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
}
|
|
|
smtc.keyOutput = keyvault.KeyBundle{
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To(managerLabel),
|
|
|
+ managedBy: pointer.To(managerLabel),
|
|
|
},
|
|
|
Key: &keyvault.JSONWebKey{},
|
|
|
}
|
|
|
@@ -589,7 +592,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
}
|
|
|
smtc.keyOutput = keyvault.KeyBundle{
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To(managerLabel),
|
|
|
+ managedBy: pointer.To(managerLabel),
|
|
|
},
|
|
|
Key: &keyvault.JSONWebKey{},
|
|
|
}
|
|
|
@@ -602,7 +605,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
}
|
|
|
smtc.keyOutput = keyvault.KeyBundle{
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To(managerLabel),
|
|
|
+ managedBy: pointer.To(managerLabel),
|
|
|
},
|
|
|
Key: &keyvault.JSONWebKey{},
|
|
|
}
|
|
|
@@ -629,7 +632,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
}
|
|
|
smtc.keyOutput = keyvault.KeyBundle{
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To("internal-secrets"),
|
|
|
+ managedBy: pointer.To("internal-secrets"),
|
|
|
},
|
|
|
Key: &keyvault.JSONWebKey{},
|
|
|
}
|
|
|
@@ -641,7 +644,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
SecretKey: secretKey,
|
|
|
RemoteKey: keyName,
|
|
|
}
|
|
|
- smtc.apiErr = autorest.DetailedError{StatusCode: 403, Method: "GET", Message: "Forbidden"}
|
|
|
+ smtc.apiErr = autorest.DetailedError{StatusCode: 403, Method: "GET", Message: forbiddenMessage}
|
|
|
smtc.expectError = errAPI
|
|
|
}
|
|
|
keyNotFound := func(smtc *secretManagerTestCase) {
|
|
|
@@ -650,7 +653,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
SecretKey: secretKey,
|
|
|
RemoteKey: keyName,
|
|
|
}
|
|
|
- smtc.apiErr = autorest.DetailedError{StatusCode: 404, Method: "GET", Message: "Not Found"}
|
|
|
+ smtc.apiErr = autorest.DetailedError{StatusCode: 404, Method: "GET", Message: notFoundMessage}
|
|
|
smtc.expectError = ""
|
|
|
}
|
|
|
importKeyFailed := func(smtc *secretManagerTestCase) {
|
|
|
@@ -659,8 +662,8 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
SecretKey: secretKey,
|
|
|
RemoteKey: keyName,
|
|
|
}
|
|
|
- smtc.apiErr = autorest.DetailedError{StatusCode: 404, Method: "GET", Message: "Not Found"}
|
|
|
- smtc.setErr = autorest.DetailedError{StatusCode: 403, Method: "POST", Message: "Forbidden"}
|
|
|
+ smtc.apiErr = autorest.DetailedError{StatusCode: 404, Method: "GET", Message: notFoundMessage}
|
|
|
+ smtc.setErr = autorest.DetailedError{StatusCode: 403, Method: "POST", Message: forbiddenMessage}
|
|
|
smtc.expectError = "could not import key keyname: #POST: Forbidden: StatusCode=403"
|
|
|
}
|
|
|
certP12Success := func(smtc *secretManagerTestCase) {
|
|
|
@@ -672,7 +675,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
smtc.certOutput = keyvault.CertificateBundle{
|
|
|
X509Thumbprint: pointer.To("123"),
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To("external-secrets"),
|
|
|
+ managedBy: pointer.To(externalSecrets),
|
|
|
},
|
|
|
}
|
|
|
}
|
|
|
@@ -685,7 +688,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
smtc.certOutput = keyvault.CertificateBundle{
|
|
|
X509Thumbprint: pointer.To("123"),
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To("external-secrets"),
|
|
|
+ managedBy: pointer.To(externalSecrets),
|
|
|
},
|
|
|
}
|
|
|
}
|
|
|
@@ -698,7 +701,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
smtc.certOutput = keyvault.CertificateBundle{
|
|
|
X509Thumbprint: pointer.To("123"),
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To("external-secrets"),
|
|
|
+ managedBy: pointer.To(externalSecrets),
|
|
|
},
|
|
|
}
|
|
|
}
|
|
|
@@ -712,7 +715,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
smtc.certOutput = keyvault.CertificateBundle{
|
|
|
X509Thumbprint: pointer.To("123"),
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To("external-secrets"),
|
|
|
+ managedBy: pointer.To(externalSecrets),
|
|
|
},
|
|
|
}
|
|
|
}
|
|
|
@@ -727,7 +730,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
smtc.certOutput = keyvault.CertificateBundle{
|
|
|
X509Thumbprint: pointer.To("123"),
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To("external-secrets"),
|
|
|
+ managedBy: pointer.To(externalSecrets),
|
|
|
},
|
|
|
}
|
|
|
}
|
|
|
@@ -742,7 +745,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
smtc.certOutput = keyvault.CertificateBundle{
|
|
|
X509Thumbprint: pointer.To("123"),
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To("external-secrets"),
|
|
|
+ managedBy: pointer.To(externalSecrets),
|
|
|
},
|
|
|
}
|
|
|
}
|
|
|
@@ -757,7 +760,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
smtc.certOutput = keyvault.CertificateBundle{
|
|
|
X509Thumbprint: pointer.To("123"),
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To("external-secrets"),
|
|
|
+ managedBy: pointer.To(externalSecrets),
|
|
|
},
|
|
|
}
|
|
|
smtc.expectError = "could not import certificate certname: error"
|
|
|
@@ -774,7 +777,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
smtc.certOutput = keyvault.CertificateBundle{
|
|
|
Cer: &cert,
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To("external-secrets"),
|
|
|
+ managedBy: pointer.To(externalSecrets),
|
|
|
},
|
|
|
}
|
|
|
}
|
|
|
@@ -788,7 +791,7 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
smtc.certOutput = keyvault.CertificateBundle{
|
|
|
X509Thumbprint: pointer.To("123"),
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To("foobar"),
|
|
|
+ managedBy: pointer.To("foobar"),
|
|
|
},
|
|
|
}
|
|
|
smtc.expectError = "certificate certname: not managed by external-secrets"
|
|
|
@@ -888,17 +891,17 @@ func TestAzureKeyVaultPushSecret(t *testing.T) {
|
|
|
if err == nil {
|
|
|
t.Errorf("[%d] unexpected error: <nil>, expected: '%s'", k, v.expectError)
|
|
|
} else {
|
|
|
- t.Errorf("[%d] unexpected error: %s, expected: '%s'", k, err.Error(), v.expectError)
|
|
|
+ t.Errorf(unexpectedError, k, err.Error(), v.expectError)
|
|
|
}
|
|
|
}
|
|
|
if len(v.expectedData) > 0 {
|
|
|
sm.baseClient = v.mockClient
|
|
|
out, err := sm.GetSecretMap(context.Background(), *v.ref)
|
|
|
if !utils.ErrorContains(err, v.expectError) {
|
|
|
- t.Errorf("[%d] unexpected error: %s, expected: '%s'", k, err.Error(), v.expectError)
|
|
|
+ t.Errorf(unexpectedError, 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)
|
|
|
+ t.Errorf(unexpectedSecretData, k, v.expectedData, out)
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
@@ -1271,7 +1274,7 @@ func TestAzureKeyVaultSecretManagerGetSecret(t *testing.T) {
|
|
|
sm.baseClient = v.mockClient
|
|
|
out, err := sm.GetSecret(context.Background(), *v.ref)
|
|
|
if !utils.ErrorContains(err, v.expectError) {
|
|
|
- t.Errorf("[%d] unexpected error: %s, expected: '%s'", k, err.Error(), v.expectError)
|
|
|
+ t.Errorf(unexpectedError, k, err.Error(), v.expectError)
|
|
|
}
|
|
|
if string(out) != v.expectedSecret {
|
|
|
t.Errorf("[%d] unexpected secret: expected %s, got %s", k, v.expectedSecret, string(out))
|
|
|
@@ -1430,10 +1433,10 @@ func TestAzureKeyVaultSecretManagerGetSecretMap(t *testing.T) {
|
|
|
sm.baseClient = v.mockClient
|
|
|
out, err := sm.GetSecretMap(context.Background(), *v.ref)
|
|
|
if !utils.ErrorContains(err, v.expectError) {
|
|
|
- t.Errorf("[%d] unexpected error: %s, expected: '%s'", k, err.Error(), v.expectError)
|
|
|
+ t.Errorf(unexpectedError, 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)
|
|
|
+ t.Errorf(unexpectedSecretData, k, v.expectedData, out)
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
@@ -1734,7 +1737,7 @@ func TestAzureKeyVaultSecretExists(t *testing.T) {
|
|
|
}
|
|
|
smtc.secretOutput = keyvault.SecretBundle{
|
|
|
Tags: map[string]*string{
|
|
|
- "managed-by": pointer.To("external-secrets"),
|
|
|
+ "managed-by": pointer.To(externalSecrets),
|
|
|
},
|
|
|
Value: pointer.To("foo"),
|
|
|
}
|
|
|
@@ -1758,7 +1761,7 @@ func TestAzureKeyVaultSecretExists(t *testing.T) {
|
|
|
smtc.pushData = testingfake.PushSecretData{
|
|
|
RemoteKey: secretName,
|
|
|
}
|
|
|
- smtc.apiErr = autorest.DetailedError{StatusCode: 404, Method: "GET", Message: "Not Found"}
|
|
|
+ smtc.apiErr = autorest.DetailedError{StatusCode: 404, Method: "GET", Message: notFoundMessage}
|
|
|
smtc.expectedExistence = false
|
|
|
}
|
|
|
|