keyvault_test.go 83 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727
  1. /*
  2. Licensed under the Apache License, Version 2.0 (the "License");
  3. you may not use this file except in compliance with the License.
  4. You may obtain a copy of the License at
  5. http://www.apache.org/licenses/LICENSE-2.0
  6. Unless required by applicable law or agreed to in writing, software
  7. distributed under the License is distributed on an "AS IS" BASIS,
  8. WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  9. See the License for the specific language governing permissions and
  10. limitations under the License.
  11. */
  12. package keyvault
  13. import (
  14. "context"
  15. "encoding/base64"
  16. "encoding/json"
  17. "errors"
  18. "fmt"
  19. "reflect"
  20. "testing"
  21. "github.com/Azure/azure-sdk-for-go/services/keyvault/2016-10-01/keyvault"
  22. "github.com/Azure/go-autorest/autorest"
  23. corev1 "k8s.io/api/core/v1"
  24. pointer "k8s.io/utils/ptr"
  25. esv1beta1 "github.com/external-secrets/external-secrets/apis/externalsecrets/v1beta1"
  26. v1 "github.com/external-secrets/external-secrets/apis/meta/v1"
  27. "github.com/external-secrets/external-secrets/pkg/provider/azure/keyvault/fake"
  28. testingfake "github.com/external-secrets/external-secrets/pkg/provider/testing/fake"
  29. "github.com/external-secrets/external-secrets/pkg/utils"
  30. )
  31. type secretManagerTestCase struct {
  32. mockClient *fake.AzureMockClient
  33. secretName string
  34. secretVersion string
  35. serviceURL string
  36. ref *esv1beta1.ExternalSecretDataRemoteRef
  37. refFind *esv1beta1.ExternalSecretFind
  38. apiErr error
  39. setErr error
  40. deleteErr error
  41. pushData esv1beta1.PushSecretData
  42. secretOutput keyvault.SecretBundle
  43. setSecretOutput keyvault.SecretBundle
  44. keyOutput keyvault.KeyBundle
  45. createKeyOutput keyvault.KeyBundle
  46. certOutput keyvault.CertificateBundle
  47. importOutput keyvault.CertificateBundle
  48. listOutput keyvault.SecretListResultIterator
  49. deleteKeyOutput keyvault.DeletedKeyBundle
  50. deleteCertificateOutput keyvault.DeletedCertificateBundle
  51. deleteSecretOutput keyvault.DeletedSecretBundle
  52. expectError string
  53. setValue []byte
  54. expectedSecret string
  55. // for testing secretmap
  56. expectedData map[string][]byte
  57. expectedExistence bool
  58. // for testing pushing multi-key k8s secrets
  59. secret *corev1.Secret
  60. }
  61. func makeValidSecretManagerTestCase() *secretManagerTestCase {
  62. secretString := "Hello World!"
  63. smtc := secretManagerTestCase{
  64. mockClient: &fake.AzureMockClient{},
  65. secretName: "MySecret",
  66. secretVersion: "",
  67. ref: makeValidRef(),
  68. refFind: makeValidFind(),
  69. secretOutput: keyvault.SecretBundle{Value: &secretString},
  70. serviceURL: "",
  71. apiErr: nil,
  72. expectError: "",
  73. expectedSecret: secretString,
  74. expectedData: map[string][]byte{},
  75. }
  76. smtc.mockClient.WithValue(smtc.serviceURL, smtc.secretName, smtc.secretVersion, smtc.secretOutput, smtc.apiErr)
  77. return &smtc
  78. }
  79. func makeValidSecretManagerTestCaseCustom(tweaks ...func(smtc *secretManagerTestCase)) *secretManagerTestCase {
  80. smtc := makeValidSecretManagerTestCase()
  81. for _, fn := range tweaks {
  82. fn(smtc)
  83. }
  84. smtc.mockClient.WithValue(smtc.serviceURL, smtc.secretName, smtc.secretVersion, smtc.secretOutput, smtc.apiErr)
  85. smtc.mockClient.WithKey(smtc.serviceURL, smtc.secretName, smtc.secretVersion, smtc.keyOutput, smtc.apiErr)
  86. smtc.mockClient.WithCertificate(smtc.serviceURL, smtc.secretName, smtc.secretVersion, smtc.certOutput, smtc.apiErr)
  87. smtc.mockClient.WithList(smtc.serviceURL, smtc.listOutput, smtc.apiErr)
  88. smtc.mockClient.WithImportCertificate(smtc.importOutput, smtc.setErr)
  89. smtc.mockClient.WithImportKey(smtc.createKeyOutput, smtc.setErr)
  90. smtc.mockClient.WithSetSecret(smtc.setSecretOutput, smtc.setErr)
  91. smtc.mockClient.WithDeleteCertificate(smtc.deleteCertificateOutput, smtc.deleteErr)
  92. smtc.mockClient.WithDeleteKey(smtc.deleteKeyOutput, smtc.deleteErr)
  93. smtc.mockClient.WithDeleteSecret(smtc.deleteSecretOutput, smtc.deleteErr)
  94. return smtc
  95. }
  96. const (
  97. jwkPubRSA = `{"kid":"ex","kty":"RSA","key_ops":["sign","verify","wrapKey","unwrapKey","encrypt","decrypt"],"n":"p2VQo8qCfWAZmdWBVaYuYb-a-tWWm78K6Sr9poCvNcmv8rUPSLACxitQWR8gZaSH1DklVkqz-Ed8Cdlf8lkDg4Ex5tkB64jRdC1Uvn4CDpOH6cp-N2s8hTFLqy9_YaDmyQS7HiqthOi9oVjil1VMeWfaAbClGtFt6UnKD0Vb_DvLoWYQSqlhgBArFJi966b4E1pOq5Ad02K8pHBDThlIIx7unibLehhDU6q3DCwNH_OOLx6bgNtmvGYJDd1cywpkLQ3YzNCUPWnfMBJRP3iQP_WI21uP6cvo0DqBPBM4wvVzHbCT0vnIflwkbgEWkq1FprqAitZlop9KjLqzjp9vyQ","e":"AQAB"}`
  98. jwkPubEC = `{"kid":"https://example.vault.azure.net/keys/ec-p-521/e3d0e9c179b54988860c69c6ae172c65","kty":"EC","key_ops":["sign","verify"],"crv":"P-521","x":"AedOAtb7H7Oz1C_cPKI_R4CN_eai5nteY6KFW07FOoaqgQfVCSkQDK22fCOiMT_28c8LZYJRsiIFz_IIbQUW7bXj","y":"AOnchHnmBphIWXvanmMAmcCDkaED6ycW8GsAl9fQ43BMVZTqcTkJYn6vGnhn7MObizmkNSmgZYTwG-vZkIg03HHs"}`
  99. jsonTestString = `{"Name": "External", "LastName": "Secret", "Address": { "Street": "Myroad st.", "CP": "J4K4T4" } }`
  100. jsonSingleTestString = `{"Name": "External", "LastName": "Secret" }`
  101. jsonTagTestString = `{"tagname":"tagvalue","tagname2":"tagvalue2"}`
  102. keyName = "key/keyname"
  103. certName = "cert/certname"
  104. secretString = "changedvalue"
  105. unexpectedError = "[%d] unexpected error: %s, expected: '%s'"
  106. unexpectedSecretData = "[%d] unexpected secret data: expected %#v, got %#v"
  107. errorNoTag = "tag something does not exist"
  108. errNotManaged = "not managed by external-secrets"
  109. errNoPermission = "No Permissions"
  110. errAPI = "unexpected api error"
  111. something = "something"
  112. tagname = "tagname"
  113. tagname2 = "tagname2"
  114. tagvalue = "tagvalue"
  115. tagvalue2 = "tagvalue2"
  116. secretName = "example-1"
  117. testsecret = "test-secret"
  118. fakeURL = "noop"
  119. foo = "foo"
  120. bar = "bar"
  121. errStore = "Azure.ValidateStore() error = %v, wantErr %v"
  122. )
  123. func getTagMap() map[string]*string {
  124. tag1 := "tagname"
  125. tag2 := "tagname2"
  126. value1 := "tagvalue"
  127. value2 := "tagvalue2"
  128. tagMap := make(map[string]*string)
  129. tagMap[tag1] = &value1
  130. tagMap[tag2] = &value2
  131. return tagMap
  132. }
  133. func newKVJWK(b []byte) *keyvault.JSONWebKey {
  134. var key keyvault.JSONWebKey
  135. err := json.Unmarshal(b, &key)
  136. if err != nil {
  137. panic(err)
  138. }
  139. return &key
  140. }
  141. func TestAzureKeyVaultDeleteSecret(t *testing.T) {
  142. unsupportedType := func(smtc *secretManagerTestCase) {
  143. smtc.pushData = testingfake.PushSecretData{
  144. RemoteKey: "yadayada/foo",
  145. }
  146. smtc.expectError = "secret type 'yadayada' is not supported"
  147. }
  148. secretSuccess := func(smtc *secretManagerTestCase) {
  149. smtc.pushData = testingfake.PushSecretData{
  150. RemoteKey: secretName,
  151. }
  152. smtc.secretOutput = keyvault.SecretBundle{
  153. Tags: map[string]*string{
  154. "managed-by": pointer.To("external-secrets"),
  155. },
  156. Value: pointer.To("foo"),
  157. }
  158. smtc.deleteSecretOutput = keyvault.DeletedSecretBundle{}
  159. }
  160. secretNotFound := func(smtc *secretManagerTestCase) {
  161. smtc.pushData = testingfake.PushSecretData{
  162. RemoteKey: secretName,
  163. }
  164. smtc.apiErr = autorest.DetailedError{StatusCode: 404, Method: "GET", Message: "Not Found"}
  165. smtc.deleteErr = autorest.DetailedError{StatusCode: 404, Method: "DELETE", Message: "Not Found"}
  166. }
  167. secretNotManaged := func(smtc *secretManagerTestCase) {
  168. smtc.pushData = testingfake.PushSecretData{
  169. RemoteKey: secretName,
  170. }
  171. smtc.secretOutput = keyvault.SecretBundle{
  172. Value: pointer.To("foo"),
  173. }
  174. smtc.expectError = errNotManaged
  175. smtc.deleteErr = autorest.DetailedError{StatusCode: 500, Method: "DELETE", Message: "Shouldnt happen"}
  176. }
  177. secretUnexpectedError := func(smtc *secretManagerTestCase) {
  178. smtc.pushData = testingfake.PushSecretData{
  179. RemoteKey: secretName,
  180. }
  181. smtc.expectError = "boom"
  182. smtc.apiErr = fmt.Errorf("boom")
  183. }
  184. secretNoDeletePermissions := func(smtc *secretManagerTestCase) {
  185. smtc.pushData = testingfake.PushSecretData{
  186. RemoteKey: secretName,
  187. }
  188. smtc.secretOutput = keyvault.SecretBundle{
  189. Tags: map[string]*string{
  190. "managed-by": pointer.To("external-secrets"),
  191. },
  192. Value: pointer.To("foo"),
  193. }
  194. smtc.expectError = errNoPermission
  195. smtc.deleteErr = autorest.DetailedError{StatusCode: 403, Method: "DELETE", Message: errNoPermission}
  196. }
  197. secretNoGetPermissions := func(smtc *secretManagerTestCase) {
  198. smtc.pushData = testingfake.PushSecretData{
  199. RemoteKey: secretName,
  200. }
  201. smtc.expectError = errNoPermission
  202. smtc.apiErr = autorest.DetailedError{StatusCode: 403, Method: "GET", Message: errNoPermission}
  203. }
  204. certificateSuccess := func(smtc *secretManagerTestCase) {
  205. smtc.pushData = testingfake.PushSecretData{
  206. RemoteKey: certName,
  207. }
  208. smtc.certOutput = keyvault.CertificateBundle{
  209. Tags: map[string]*string{
  210. "managed-by": pointer.To("external-secrets"),
  211. },
  212. }
  213. smtc.deleteCertificateOutput = keyvault.DeletedCertificateBundle{}
  214. }
  215. certNotFound := func(smtc *secretManagerTestCase) {
  216. smtc.pushData = testingfake.PushSecretData{
  217. RemoteKey: certName,
  218. }
  219. smtc.apiErr = autorest.DetailedError{StatusCode: 404, Method: "GET", Message: "Certificate Not Found"}
  220. smtc.deleteErr = autorest.DetailedError{StatusCode: 404, Method: "DELETE", Message: "Not Found"}
  221. }
  222. certNotManaged := func(smtc *secretManagerTestCase) {
  223. smtc.pushData = testingfake.PushSecretData{
  224. RemoteKey: certName,
  225. }
  226. smtc.certOutput = keyvault.CertificateBundle{}
  227. smtc.expectError = errNotManaged
  228. smtc.deleteErr = autorest.DetailedError{StatusCode: 500, Method: "DELETE", Message: "Shouldnt happen"}
  229. }
  230. certUnexpectedError := func(smtc *secretManagerTestCase) {
  231. smtc.pushData = testingfake.PushSecretData{
  232. RemoteKey: certName,
  233. }
  234. smtc.expectError = "crash"
  235. smtc.apiErr = fmt.Errorf("crash")
  236. }
  237. certNoDeletePermissions := func(smtc *secretManagerTestCase) {
  238. smtc.pushData = testingfake.PushSecretData{
  239. RemoteKey: certName,
  240. }
  241. smtc.certOutput = keyvault.CertificateBundle{
  242. Tags: map[string]*string{
  243. "managed-by": pointer.To("external-secrets"),
  244. },
  245. }
  246. smtc.expectError = "No certificate delete Permissions"
  247. smtc.deleteErr = autorest.DetailedError{StatusCode: 403, Method: "DELETE", Message: "No certificate delete Permissions"}
  248. }
  249. certNoGetPermissions := func(smtc *secretManagerTestCase) {
  250. smtc.pushData = testingfake.PushSecretData{
  251. RemoteKey: certName,
  252. }
  253. smtc.expectError = "No certificate get Permissions"
  254. smtc.apiErr = autorest.DetailedError{StatusCode: 403, Method: "GET", Message: "No certificate get Permissions"}
  255. }
  256. keySuccess := func(smtc *secretManagerTestCase) {
  257. smtc.pushData = testingfake.PushSecretData{
  258. RemoteKey: keyName,
  259. }
  260. smtc.keyOutput = keyvault.KeyBundle{
  261. Tags: map[string]*string{
  262. "managed-by": pointer.To("external-secrets"),
  263. },
  264. }
  265. smtc.deleteKeyOutput = keyvault.DeletedKeyBundle{}
  266. }
  267. keyNotFound := func(smtc *secretManagerTestCase) {
  268. smtc.pushData = testingfake.PushSecretData{
  269. RemoteKey: keyName,
  270. }
  271. smtc.apiErr = autorest.DetailedError{StatusCode: 404, Method: "GET", Message: "Not Found"}
  272. smtc.deleteErr = autorest.DetailedError{StatusCode: 404, Method: "DELETE", Message: "Not Found"}
  273. }
  274. keyNotManaged := func(smtc *secretManagerTestCase) {
  275. smtc.pushData = testingfake.PushSecretData{
  276. RemoteKey: keyName,
  277. }
  278. smtc.keyOutput = keyvault.KeyBundle{}
  279. smtc.expectError = errNotManaged
  280. smtc.deleteErr = autorest.DetailedError{StatusCode: 500, Method: "DELETE", Message: "Shouldnt happen"}
  281. }
  282. keyUnexpectedError := func(smtc *secretManagerTestCase) {
  283. smtc.pushData = testingfake.PushSecretData{
  284. RemoteKey: keyName,
  285. }
  286. smtc.expectError = "tls timeout"
  287. smtc.apiErr = fmt.Errorf("tls timeout")
  288. }
  289. keyNoDeletePermissions := func(smtc *secretManagerTestCase) {
  290. smtc.pushData = testingfake.PushSecretData{
  291. RemoteKey: keyName,
  292. }
  293. smtc.keyOutput = keyvault.KeyBundle{
  294. Tags: map[string]*string{
  295. "managed-by": pointer.To("external-secrets"),
  296. },
  297. }
  298. smtc.expectError = errNoPermission
  299. smtc.deleteErr = autorest.DetailedError{StatusCode: 403, Method: "DELETE", Message: errNoPermission}
  300. }
  301. keyNoGetPermissions := func(smtc *secretManagerTestCase) {
  302. smtc.pushData = testingfake.PushSecretData{
  303. RemoteKey: keyName,
  304. }
  305. smtc.expectError = errNoPermission
  306. smtc.apiErr = autorest.DetailedError{StatusCode: 403, Method: "GET", Message: errNoPermission}
  307. }
  308. successCases := []*secretManagerTestCase{
  309. makeValidSecretManagerTestCaseCustom(unsupportedType),
  310. makeValidSecretManagerTestCaseCustom(secretSuccess),
  311. makeValidSecretManagerTestCaseCustom(secretNotFound),
  312. makeValidSecretManagerTestCaseCustom(secretNotManaged),
  313. makeValidSecretManagerTestCaseCustom(secretUnexpectedError),
  314. makeValidSecretManagerTestCaseCustom(secretNoDeletePermissions),
  315. makeValidSecretManagerTestCaseCustom(secretNoGetPermissions),
  316. makeValidSecretManagerTestCaseCustom(certificateSuccess),
  317. makeValidSecretManagerTestCaseCustom(certNotFound),
  318. makeValidSecretManagerTestCaseCustom(certNotManaged),
  319. makeValidSecretManagerTestCaseCustom(certUnexpectedError),
  320. makeValidSecretManagerTestCaseCustom(certNoDeletePermissions),
  321. makeValidSecretManagerTestCaseCustom(certNoGetPermissions),
  322. makeValidSecretManagerTestCaseCustom(keySuccess),
  323. makeValidSecretManagerTestCaseCustom(keyNotFound),
  324. makeValidSecretManagerTestCaseCustom(keyNotManaged),
  325. makeValidSecretManagerTestCaseCustom(keyUnexpectedError),
  326. makeValidSecretManagerTestCaseCustom(keyNoDeletePermissions),
  327. makeValidSecretManagerTestCaseCustom(keyNoGetPermissions),
  328. }
  329. sm := Azure{
  330. provider: &esv1beta1.AzureKVProvider{VaultURL: pointer.To(fakeURL)},
  331. }
  332. for k, v := range successCases {
  333. sm.baseClient = v.mockClient
  334. err := sm.DeleteSecret(context.Background(), v.pushData)
  335. if !utils.ErrorContains(err, v.expectError) {
  336. if err == nil {
  337. t.Errorf("[%d] unexpected error: <nil>, expected: '%s'", k, v.expectError)
  338. } else {
  339. t.Errorf("[%d] unexpected error: '%s', expected: '%s'", k, err.Error(), v.expectError)
  340. }
  341. }
  342. }
  343. }
  344. func TestAzureKeyVaultPushSecret(t *testing.T) {
  345. p12Cert, _ := base64.StdEncoding.DecodeString("MIIQaQIBAzCCEC8GCSqGSIb3DQEHAaCCECAEghAcMIIQGDCCBk8GCSqGSIb3DQEHBqCCBkAwggY8AgEAMIIGNQYJKoZIhvcNAQcBMBwGCiqGSIb3DQEMAQYwDgQIoJ3l+zBtWI8CAggAgIIGCBqkhjPsUaowPQrDumYb2OySFN7Jt91IbIeCt1W3Lk99ueJbZ4+xNUiOD+ZDLLJJI/EDtq+0b+TgWHjx92q/IEUj2woQV2rg1W8EW815MmstyD0YRnw7KvoEKBH+CsWiR/JcC/IVoiV1od0dWFfWGSBtWY5xLiaBWUX6xV8zcBVz1fkB+pHOofkStW2up6G2sQos1WwIptAvz6VpS16xLUmZ1whZZvPhqz1GPfexJSavBWEe7YcoxVd/q8LLGQmQCfV7zXwyUX3WnHATkesYPMSTDPuRWXMOrJRjy2zinQP5XweNY2DeZ2bRV6y3v8eQlQNmKBXteNj5H5lJFkOD7BA6xwYlzj3KGB37Qf7kl6R46liT2tlYp/T9eX1ejC0GqICOroPrAy1J5/r9Jlst/39K20omD7M7DGbnqhEWNUeXoXpT6m/UiXLA+0ns5TBZqt4gwC8n8qgjYVvuxvn5tY3gERzkCa6PYzxBfasjM47hHEbsQ1gQORan7OQqTBjbwjeFC4ObMc4u48qxi/cyzMsPgbgE9pQoz2eF5BC6qcJr5mxL/0RWK+Zpn0or9tK4vqf2czLKrWsMcl5sfShSELXY3+jAsUscMbo0LfRgTwsVZGPgOC1cKJlGky734WFj2l9dHVxiRInz6yuWobIT/fmlvPUhjEXNPc0p7vrPvU3/susH+zilbSrp0rY9Y8t70ixGsHPbSHTk8MapukoFnKy2RxcYZQ4cLLMRBo0BA+ugAO7/pa2qGYawzl+U6ydmBftSxTs2gm4SjDnKWoe67r0Q1FHQEWd6rCA40dzAEiCmClCSqzggDKJYnxqub3sqh3Z2Ap9EEZdWBb/Qxryw5h5H3HAOblwudftsyaXsNPf6nDrknANHZyuwkWuh5XYSkKfG8mz6B8+l5A217nYWn0P4i1+WYgnyojJ+m/ZnaNy1+pWXHy1IugoRkfZaVp3NDmwgjK+dnu6rL3/XhJbXlrOk3UEYImX1yMzIWDv/urdWr3bR/cfwM3XwVUy55QUayLIzxRWfWOLuZ8+ZKw8cJ5YGNUa9AgQ3Fs6Lfp7Qn11SdG4adCEJl6DhsugwZokfy6JqBAv0ywbZ94LKvRc1ItM/crfy/5Io1+GsinnF7lsybsZJFGB6tVNWzgZh92dluzUKIRppMG1ZhUmq/4yaJgZsXYDkAxuPWQ2iSpldijmeuBnr/Oct1BpTwM5ogUS3WCHyZajfS/vIGTzz/q8+VnR9W57hvBKulSCS7G06QsFOvr6yOexb9bJJtgsu1sGjqXqyw0SKbFU9AMRunRVezp/r1LwJ+O/8O4ZCB40o3kSJM4tFvj80zVIz8VoWME7JjwAt04v+o9evavxt6p5yaSpH6pzHbvP6cT6YnJqQbYA9J/sDyLt5caq3/OeiJe4tb1pXmJ6dtwFxFygobKnGZjHsL+yRHrIPvNaqztGRzTu5gwEddMZ38nE0IGOhPVnE6WQC1admI/KUUdVOOATD6kJxSwGYGxpsWXX0KOcy9vb3ykeafmHoJU2S64KpxClH8BfOn7Bn4ypab7rNHs76FmqZYmTV9rjHdCgMqI62pB0TKK925q/RQuX+Rn/8J4mMOOjbDQwlndYbljWq0b9tbcTHpZntnmN/KZbydggrKwb0A9PonIGxqoPs+/MrJtCmlgjhjjHE8N3a10apN/NmN/B4TlfBAr47a/2eelTX642kU2DJ2f00mEeDvwY1lkRCjx+80EiY7nUj9cFfPptNdyQbiVDthkS0rXSbyobDgt53g7KU6/UvTdaRWK5Ks9Q5NZ9c44RaHJ/Y7ukWFrsZDCpcQ2v3gn0A9mQPoZGvziMd1Mh7pOJNR2jrpmodGA9j6MMVuYFKu0GbheEhf++UrDOti40GXcPO+o1NAbTClXeIhDEl81cE1rrK+pPvZEB9m/FV7Osp8NmHQDY+z2rPKa5luO6g77/HM9fJrEGBv19ByQcOFuvOQi0RICUp5sIJD+GO3TBGO7WANpUZvB2cezkBbTa/sVAINTXSD007tOo4WfJTBrQbXAbpQ+04B/2yolFvtbYL4rOcMIIJwQYJKoZIhvcNAQcBoIIJsgSCCa4wggmqMIIJpgYLKoZIhvcNAQwKAQKgggluMIIJajAcBgoqhkiG9w0BDAEDMA4ECM7kJUu/1hDPAgIIAASCCUgs+wJaAYsjcSK7oETqGlVmKzCLwkqvstEYmYlJDihNrj0MWHQqmMP/sfdrnqIHVrLnl3vWRN0CBEtzPZGIM5BqYW1puS8mHXowz+8epz6TLRDpiKM2M29+BfAmTkZwlppfuKpu2MoXgd3LLspAQT10pLjoP66OSj+PfUpCbU82+YjjK7PSxog5OrYmuf4Tfohl8bWcFj6mIiaUYiVuF7mRLq3oUY5mE61EjMGp118JKVCG/8sS4MRZ69ulowDZEdrPOCvXzG+gK3bjeMW4aboIaIZ7UxoUy/AYQNdcYjAiUIRWrZx3s7UMa90R7ZvpWRYEEenko95WEUezaing2vVdImMphmjOIpP0Fkm+WTIQHoznE2+ppET1MtIwLyB0PjLptjFtK5orXNqplFWsN6+X5B6ATG0KCwKcsX7fmrkbDpO3B/suVAGk4SdQsV4xrlHhUneUl4hiZ6v2M9MIC+ZMRuGxmuej7znRxV6IRuVVIOqWuwGVVOQpGC4sCOc2Ej0WQeHQCxVK4EWlGL7JE9ux4Ds//40LC2mUihJXiG01ZI/v6eez1GrPeoOeTtHU7+5N7eU4f00S0XSVQGOhUwlp1E9c7DkSPA4lJ7MfTYUFLeP4R+ITpXXbdco65mwH2WFWPbTAKG1rabHj2D5DvHEoBZEsgcD4klhPnZIEBh6gFg67MZB9XNiofSiLzeSKDgfyeTG1MCctUWTa+vy1mrue4rREuRQMC4h0NMyPJ4LlVYutFfEncH2iGmB8t4CVM5CzZ0hXqDxHEgddU02ix/aIzizXqWgpPN0vkHp/Hv+/wyRvjwuiljmE8otRRFMinoIigmLKQKueJQpLWAZAvBjmCZdKTG8sjJAeo0ufOJQdi/EuCmDWR3YkXKi/RX7ub6cnc9hFb+zDGiplLPTyYqOnEPVut8fdA0kmUuAkelLpSbJcv6h3/tS/IJzH2vMCz26J152UaY6Zh0AqD1hl+wA5q5qgDER0jeFY11KypNfEgYxNhr/BcvuNYvN1/1T/wuvEIviMYhJPaSXXbtqpBzIjpkvxOzm9LeC9wqRM1Gq1HrSHwUUeRl8AeMpsRmcmRRy222ZM7p6b0T90l/AKcPLmNxQVYTy5+DeWMC/YaBFHPVMiakKEmPZjeR3Vbb63EJ5DCoAN3xh6NmpANXmXAl7z6ID0hVjNV/Ji8Y+tuJczh0IyMQncDBRw76cdup9QIk2D/pKcj9M7ul2Jx2xwBqntJbvFQqjhIhaSzLKMQtaC+qgcL/C/ANFey8IN5zUUver9RdYyEnRNf4OPl/mq7kUs8znnu5wGGOyxHuvHMFUtJfuII3P7YDSltK2QP1uhefhMfEvNYL9QqosN3740nQ8TCPvZFzzoBC8Psn6OvNXnWipz3WCZ+5u+fOXzawpNKvPHWz/D4O4dmMu9/DpxKb8UOLv/+YFEkqkGNDhS91dgyI672JqC4TQ9ijmNwtdgQt+OtOmllUO3cRP5I4nxCLjAJ5bBYmFV7kSdfWJEjkeCUGMKmwP88sXxeAV0D7qGFG0kdNgMow7WE8AI+lKo8bgBpmR8LQlD0Zt/LBlgGk1uOXolXTNaEGXUMj7h3zS46C3qR/UraHTq+vaNrLqY3qYJaVXdvhhShVDEhH6jLFFYJYCBtWCnhZ3lKkFJnIY+n+25lEQNMwR4sNOLxmUP+kzkt6qSjTRj+u1gK4NptkhFck7lFigAlHozlzg1mnKPvXcD2w3B+Qt6smAQb31rxD6P/byFVEjMFFH1LHNaSrmJNt2/Hmlgd1+2lmVieHF0OnptCDt/MxGjlZYD9/MHBDvWC6LgyGAGL3hub/C/wX5ngOYNq7SZJ1xPsonppKsWD/ixwlzXKu0MQS05CjMqnJCUW7YWl8F+2c2WcAnKA8MN4oONJbv29afj35I/mInT20PptaUH3vJg1VrbU4gWyJWw2/ap63Y2mTMwF2MRuuvIZQTlSwAXHaSZT1weqNX37NFVQLEx1GIiMSBXu+ogZEZWuKwlzB2F2OQ4DuhWgxmTA8Fh0md/IG0sc96wBb3E1Jj80UOeIMIsOO3nCA5Wa5+btUaVueIqGHM9L3IGn2jk/PdidEW5Anp7aT8f8korjBKNF/qc7Hk0V0QDvzxXbuHIE2neoZVemgPteu4tFFI5N/wtXAp3BBQi1ozdqWaBBT/fbYiWesp6fe83f6KNaVXTnjGUnkv4ougvZDi99e+plpSFgjMv180/kfyC57PfX/KLbuK6M6nmVykZSzBdxGqe7V2JUR32dYNRZeiNI6PZO2HumyM7/h8adcP2yw9NseW9D4M2wihsY/ozcU/N+Fv+/WDMd+p7Ekl7oN/PERRZcL5bpjq+Oh7cv5mIH443K/tUni1wVrs8Njft/VQfubU2HY0UcFuX0IHc8/yp9NhqFgdMVTLQWTW9RRkl/9XleMco7qqEdhJCK8dHFBAwsK6SB6aUtY4rpopltVKbgnmAmCwkMcg9Q3Bx9DFJ0SVgqQdrNnJ0koJE9BWG96SreVBW+BOCqYED9sZI7DBFc/Hnb3pDwmqV2gr4gl+bzzHfOQwADVDIe6OcT0b3t4iOVhpd6G1LT/df4IdZLxcXi5PPbpwvjFmo8jJpT8DKya0KjW3E25Q6+qQQ9vZzc4d31yUog30tGJun1HHg1A+3KSo67awfgxG7er/viMe+Nx1dLPVlj+wi3X1JJvZlBXJ4yhfaSnzOa5u1ZxAGTz1OuHYkz7USuyJlf5qYV/oCyyypwaQ5DUpzcISgQGdOe4HVA6gTMLHWbX05MCHdfBFRa64c92/nxA0OS4m8xruRgsZwxwLDtG2IHXxcA/Tfam0Rqd5+UfWWyxLSHF3/u5gpLARwPsH59Tb28MhFmVFsELOHt1VoTntQU0qJ4ZljyUwP7Y3u0TmGhj0bEv3s7eqntKUz7zpGnLyxbu1tef4EJvFMYLBNIkkB3bb68i2HCXkoLJRyRH6VT3j9ahea/acgt5U8WASlMH41jURGFdCBWHdk+aIkyqDrJ9KtZFT6h88vUWt9iiAgJInLTL+tJ2j3dMHVvT0WkcAt8w6uXLYT7AGAbKjetqwLiU6JEXfCdZfUVQG50ztLwcfuTlzCO4d9vhkiuy/NIpH9NoONGwCYSfYyx+ycxZjMnLSsJcgys2aANdLGpLnQhy3WY8QxJTAjBgkqhkiG9w0BCRUxFgQUilZxcWgYWs3WodyrZQAAsliFtB4wMTAhMAkGBSsOAwIaBQAEFLCnG3FfSE655zJaBGibla7sAnVEBAguHlNaj8V3VQICCAA=")
  346. goodKey, _ := base64.StdEncoding.DecodeString("LS0tLS1CRUdJTiBQUklWQVRFIEtFWS0tLS0tCk1JSUpRZ0lCQURBTkJna3Foa2lHOXcwQkFRRUZBQVNDQ1N3d2dna29BZ0VBQW9JQ0FRQ1pITzRvNkpteU9aZGYKQXQ3RFdqR2tHdzdENVVIU1BHZXQyTjg2cnBGWXcrZThnL3dSeDBnZDBzRk9pelBBREdjcnpmdWE5Z3ZFcDRWcwpXb2FHbmN3UXhqdnMrZ1orWmQ2UkVPNHRLNzRURmYxaWZibmowUHE2OENlQlFpaG8xbDNwM2UwQy8yemVJMjNiCnZWRHZlMm13VXE5aDY4UTFFUmdWMU1LaWJHU1Naak5DQzdkRGFQWmpKazViMFlWVFdxREViemREVnh2ZVVMNVIKcUZnL0RKQTMzVnE2VFQzQ2U5RjBIcEorb3graSs4cUxmWU5qZExSUDZlbEtLTU5naVhhNTFvdnQ5MjF4UkVGdgpYRXYvTUtqWTlhNkppNndIRSs0NmdvbFY4V2puK2xMRkRKVHh6WEFEN2p2NzVzaHY0WEczdFlaQ2J4cTMzZ2JtCm96c0VQZ3lTRGtCMm5zc0tIUEFhSVNPaWpjNDhiSXhwbDVocFJPWUZFblJDWnhablhQNjdLZVF1VWZXQkpoVWcKYWltc0JRK3p6cFB6ZjVUbjRnVExkWll2NU41V1V2djJJdUF5Qktha0ZhR1ZYTzFpZ2FDeVQvUTNBcEE2ZGx4Sgo1VW44SzY4dS9KSGFmWWZ5engwVnVoZk5zbmtiWkxWSEZsR2Rxd3JrU0tCWSs1eS9WWlpkeC9hSHNWWndVN3ZECmNlaGxlWlFNNGV2cm5tMUY3dk5xSHBUK3BHSnpNVWVUNGZMVFpabTBra1Y3ZXl5RGRMMDFEWXRXQk1TM2NEb1EKdU5vWElBMCtDeFZPOHcxcC9wbXF2UFQ3cmpad2pwYkVMUkp3MWs4R3ozU2FKb2VqaFBzWC9xNzNGWWdBc09PRApwTXJuK3ZpU2U0ZnJmR0VmZlEvYXJUVE5qK1BUb3dJREFRQUJBb0lDQUM3ek1CUmJQc1huNHdLL1hvK0ltTEE1Cm04MTEvemo0VE5LQ0xmRlFsa0VoMFcxOUMwNW9UVFRYNjI2cVFMUWpHWC9WS2RIYW9NRXNuVDBjaFNQQ1AxRGwKZUhxeU1FdVI4UzJLZzM1V2EzSnV5OFBueVppUi9GQldVOGJQQXBVakpxa1A1QjJITlZyb2drZGZSZklwWmI4cgptNXZyTDc4Vi9zeXk4UHZkUVBtalhSUmpnMDZvWU9VR1dnRE52cFJRdGZ1R0h1d0hTZ1JodmZwTUpNTXdsd2lLClY4Zkk1NmM3VUg3SzRTRHo1RCtWOWdYUDl2b0lUMEl4OTlkRnFLTnhnM1o0MDIrazcycE1BOFNpQ0t1M3dBN0gKUnozbUZsb1ZRbmV1ajI1TEdHQUo0bGVLQkNJaFhMZlgxWXpvdDQyWEU4ZkJZZW45SjdRNTRPUFlLY0NqUmpjSgp1M2NkamtIbmFWVFc1dDdLTDFuYVAxRmF0S0ZxSjY1V1Y0c3pxWDhPVkpzbWhLalNsNUhqTk1VeERuaFUraWRTCmsxaGNaa00zOWd2RGR1ekRHeHF0L2hHMWNJS3VtamxZb01WNDV4VWFoVHdhTjZnamlrTUxNdFgrb2c0MVAxU3cKa09hZTZ4enJFQmU1eXhqSnVDWFJzK2FFOXZhTmpIWmpnSTNKREJ0enNjeCtvRFZBMXoxWVBpR2t1NXBNYmxYUQpFMWlRQnlJOVRjeHMrazN0NWdIQ0d3Z2lOcXVnOVZJaXY1cTQ2R2VGRVdnQS8wZ2hEZ0hIRnNRSDJ4VEpGU2d6ClluTkRVNlZtQ1RYZEQ0QU5jS085Z0loQzdxYk9iazlUeS9zZkZIQjBrYUdCVjFFZGZ3a0R4LytYdXRacHNUN3IKdkl6SUVDd2JPTEUzZCtLb1grUUJBb0lCQVFESG9SVU42U1VmQ3I4Z2FsOFM3UDhscU1kZnhsQVNRcWRqOHY2WAp3V1o1MFJKVE9TRmxqN3dlb2FnTStDT3pEUHpoU3pMbE4vcVdnK2h1RFJGcXBWb08xTmlrZVdvZEVwajFyZG5qCmlLeFlEVUJKNjFCMk5GT3R6Qm9CZUgyOFpDR3dRUW93clZSNUh5dUlqOTRhTzBiRlNUWEJTdWx2d3NQeDZhR2cKaTV2Q0VITHB6ODZKV1BzcjYwSmxVSDk2Z2U3NXJNZEFuRTJ1UE5JVlRnR2grMHpOenZ2a21yZHRYRVR4QXpFZwo5d0RaNVFZTUNYTGVjV0RxaWtmQUpoaUFJTjdVWEtvajN0b1ZMMzh6Sm95WmNWT3ZLaVRIQXY1MCtyNGhVTzhiCjJmL1J2VllKMngybnJuSVR4L0s2Y2N3UUttb1dFNmJRdmg4SXJGTEI3aWN2cVJzUEFvSUJBUURFV1VGemRyRHgKN2w4VGg2bVV5ZlBIWWtOUU0vdDBqM3l3RDROQ2JuSlEvZGd2OGNqMVhGWTNkOWptdWZreGtrQ01WVC8rcVNrOQp1cm1JVVJDeGo5ZDJZcUtMYXZVcUVFWCtNVStIZ0VDOW4yTHluN0xXdVNyK2dFWVdkNllXUVNSVXpoS0xaN2RUCnliTnhmcnNtczNFSVJEZTkwcFV4ZGJ0eWpJSTlZd1NaRDdMUHVOQmc1cWNaTW1xWG9vSnQxdnJld1JINncwam8KM1pxTWMrVGFtNGxYc0xmU0pqTlAzd2IzZEE0ZDFvWWFIb29WWTVyK0dER1F5YnVKYllQZSt6d01NTkJhZ2dTVQpCL3J5NlBldVBTWVJnby9kTlR2TERDamJjbytXdFpncjRJaWxCVmpCbmwycEhzakVHYjZDV2Q2bXZCdlk3SWM5ClM3cXJLUGQrWE00dEFvSUJBR08wRkN2cWNkdmJKakl1Ym1XcGNKV0NnbkZYUHM2Zjg3Sjd2cVJVdDdYSHNmdFcKNFZNMFFxU1o0TEQ1amZyelZhbkFRUjh5b2psaWtFZkd4eGdZbGE0cXFEa2RXdDVDVjVyOHhZSmExSmoxcFZKRgo4TjNZcktKMCtkZ2FNZEpSd0hHalNrK2RnajhzVGpYYWhQZGMrNisxTE4vcFprV25aTzRCM2ZPdFJwSGFYVXBoCnU2bmxneTBnUnYwTEEyQlFYT2JlWUhYb212T1c5T1luRzdHbkxXanRJK205VERlV2llaEZ5OWZIQmVuTjlRTTIKQk9VTWczY2dzVTFLdVpuazBPWUhrZ0p3WDBPTmdWNHV0ckk4WTZ0c3hRbVFlVDQ3clpJK05lNFhKeW0rQXFiUgpoVEltY2x0bTFkaEExY2FOS0liMk1hNjRCZy95NFRKeW02ZTJNZ2tDZ2dFQkFKTGt5NmljVllqSjh1dGpoU1ZCCmFWWHpWN1M3RHhhRytwdWxIMmdseFBSKzFLd1owV1J1N2ptVk9mcHppOURnUDlZOU9TRkdZUXBEbGVZNzc2ZEgKbThSL3ltZFBYNWRXa1dhNGNXMUlNQ2N0QlJQTEVqcStVVUlScVYzSnFjSGdmbFBMeitmbmNpb0hMbTVzaDR0TwpsL085Ulk2SDZ3SVR1R2JjWTl1VkpxMTBKeXhzY2NqdEJubzlVNjJaOE1aSUhXdGxPaFJHNFZjRjQwZk10Snd2CjNMSjBEVEgxVGxJazRzdGlVZVZVeHdMbmNocktaL3hORVZmbTlKeStCL2hjTVBKVjJxcTd0cjBnczBmanJ0ajEKK25NRElLbzMxMEh6R09ZRWNSUXBTMjBZRUdLVSsyL3ZFTmNqcHNPL0Z0M2lha2FIV0xZVFRxSTI4N0oxZGFOZAp2d2tDZ2dFQUNqWTJIc0ErSlQvWlU1Q0k1NlFRNmlMTkdJeFNUYkxUMGJNbGNWTDJraGFFNTRMVGtld0I5enFTCk5xNVFacUhxbGk2anZiKzM4Q1FPUWxPWmd6clVtZlhIemNWQ1FwMUk1RjRmSGkyWUVVa3FJL2dWdlVGMUxCNUUKZE1KR1FZa3Jick83Qjc0eE50RUV3Mmh3UFUwcTRmby92eFZXV0pFdTNoMGpSL0llMDA3UGtPZ0p1K1R5ZWZBNwpQVkM4OFlQbmsyZ3ArUFpRdDljanhOL0V4enRweDZ4cUJzT0MvQWZIYU5BdFA0azM5MVc5NjN3eHVwbUE5SkdiCk4yM0NCRmVIZDJmTUViTWJuWDk1Q1NYNjNJVWNaNVRhZTdwQS9OZ094YkdzaGRSMHdFZldTMGNyT1VTdGt6aE0KT3lCekNZSk53d3Bld3cyOFpIMGgybHh6VVRHWStRPT0KLS0tLS1FTkQgUFJJVkFURSBLRVktLS0tLQo=")
  347. goodSecret := "old"
  348. secretKey := "fakeSecretKey"
  349. typeNotSupported := func(smtc *secretManagerTestCase) {
  350. smtc.pushData = testingfake.PushSecretData{
  351. SecretKey: secretKey,
  352. RemoteKey: "badtype/secret",
  353. }
  354. smtc.expectError = "secret type badtype not supported"
  355. }
  356. secretSuccess := func(smtc *secretManagerTestCase) {
  357. smtc.setValue = []byte("secret")
  358. smtc.pushData = testingfake.PushSecretData{
  359. SecretKey: secretKey,
  360. RemoteKey: secretName,
  361. }
  362. smtc.secretOutput = keyvault.SecretBundle{
  363. Tags: map[string]*string{
  364. "managed-by": pointer.To("external-secrets"),
  365. },
  366. Value: &goodSecret,
  367. }
  368. }
  369. secretNoChange := func(smtc *secretManagerTestCase) {
  370. smtc.setValue = []byte(goodSecret)
  371. smtc.pushData = testingfake.PushSecretData{
  372. SecretKey: secretKey,
  373. RemoteKey: secretName,
  374. }
  375. smtc.secretOutput = keyvault.SecretBundle{
  376. Tags: map[string]*string{
  377. "managed-by": pointer.To("external-secrets"),
  378. },
  379. Value: &goodSecret,
  380. }
  381. }
  382. secretWrongTags := func(smtc *secretManagerTestCase) {
  383. smtc.setValue = []byte(goodSecret)
  384. smtc.pushData = testingfake.PushSecretData{
  385. SecretKey: secretKey,
  386. RemoteKey: secretName,
  387. }
  388. smtc.secretOutput = keyvault.SecretBundle{
  389. Tags: map[string]*string{
  390. "managed-by": pointer.To("nope"),
  391. },
  392. Value: &goodSecret,
  393. }
  394. smtc.expectError = errNotManaged
  395. }
  396. wholeSecretNoKey := func(smtc *secretManagerTestCase) {
  397. wholeSecretMap := map[string][]byte{"key1": []byte(`value1`), "key2": []byte(`value2`)}
  398. wholeSecretString := `{"key1": "value1", "key2": "value2" }`
  399. wholeSecret := &corev1.Secret{Data: wholeSecretMap}
  400. smtc.secret = wholeSecret
  401. smtc.pushData = testingfake.PushSecretData{
  402. RemoteKey: secretName,
  403. }
  404. smtc.secretOutput = keyvault.SecretBundle{
  405. Tags: map[string]*string{
  406. "managed-by": pointer.To("external-secrets"),
  407. },
  408. Value: &wholeSecretString,
  409. }
  410. smtc.expectedData = wholeSecretMap
  411. }
  412. secretNoTags := func(smtc *secretManagerTestCase) {
  413. smtc.setValue = []byte(goodSecret)
  414. smtc.pushData = testingfake.PushSecretData{
  415. SecretKey: secretKey,
  416. RemoteKey: secretName,
  417. }
  418. smtc.secretOutput = keyvault.SecretBundle{
  419. Tags: map[string]*string{},
  420. Value: &goodSecret,
  421. }
  422. smtc.expectError = errNotManaged
  423. }
  424. secretNotFound := func(smtc *secretManagerTestCase) {
  425. smtc.setValue = []byte(goodSecret)
  426. smtc.pushData = testingfake.PushSecretData{
  427. SecretKey: secretKey,
  428. RemoteKey: secretName,
  429. }
  430. smtc.apiErr = autorest.DetailedError{StatusCode: 404, Method: "GET", Message: "Not Found"}
  431. }
  432. failedGetSecret := func(smtc *secretManagerTestCase) {
  433. smtc.setValue = []byte(goodSecret)
  434. smtc.pushData = testingfake.PushSecretData{
  435. SecretKey: secretKey,
  436. RemoteKey: secretName,
  437. }
  438. smtc.apiErr = autorest.DetailedError{StatusCode: 403, Method: "GET", Message: "Forbidden"}
  439. smtc.expectError = errAPI
  440. }
  441. failedNotParseableError := func(smtc *secretManagerTestCase) {
  442. smtc.setValue = []byte(goodSecret)
  443. smtc.pushData = testingfake.PushSecretData{
  444. SecretKey: secretKey,
  445. RemoteKey: secretName,
  446. }
  447. smtc.apiErr = fmt.Errorf("crash")
  448. smtc.expectError = "crash"
  449. }
  450. failedSetSecret := func(smtc *secretManagerTestCase) {
  451. smtc.setValue = []byte(goodSecret)
  452. smtc.pushData = testingfake.PushSecretData{
  453. SecretKey: secretKey,
  454. RemoteKey: secretName,
  455. }
  456. smtc.apiErr = autorest.DetailedError{StatusCode: 404, Method: "GET", Message: "Not Found"}
  457. smtc.setErr = autorest.DetailedError{StatusCode: 403, Method: "POST", Message: "Forbidden"}
  458. smtc.expectError = "could not set secret example-1: #POST: Forbidden: StatusCode=403"
  459. }
  460. keySuccess := func(smtc *secretManagerTestCase) {
  461. smtc.setValue = goodKey
  462. smtc.pushData = testingfake.PushSecretData{
  463. SecretKey: secretKey,
  464. RemoteKey: keyName,
  465. }
  466. smtc.keyOutput = keyvault.KeyBundle{
  467. Tags: map[string]*string{
  468. "managed-by": pointer.To(managerLabel),
  469. },
  470. Key: &keyvault.JSONWebKey{},
  471. }
  472. }
  473. symmetricKeySuccess := func(smtc *secretManagerTestCase) {
  474. smtc.setValue = []byte("secret")
  475. smtc.pushData = testingfake.PushSecretData{
  476. SecretKey: secretKey,
  477. RemoteKey: keyName,
  478. }
  479. smtc.keyOutput = keyvault.KeyBundle{
  480. Tags: map[string]*string{
  481. "managed-by": pointer.To(managerLabel),
  482. },
  483. Key: &keyvault.JSONWebKey{},
  484. }
  485. }
  486. RSAKeySuccess := func(smtc *secretManagerTestCase) {
  487. smtc.setValue, _ = base64.StdEncoding.DecodeString("LS0tLS1CRUdJTiBSU0EgUFJJVkFURSBLRVktLS0tLQpNSUlKS1FJQkFBS0NBZ0VBdmIxYjM2YlpyaFNFYm5YWGtRL1pjR3VLY05HMDBGa2U1SkVOaWU4UzFHTG1uK1N0CndmdittVFRUN2xyVkdpVkplV3ZhQnRkMUVLRll0aWdlVlhJQjA0MllzeHRmMlM5WkNzNlUxaFZDWFZQc3BobEUKOUVyOHNHa0Ewa1lKdmxWejR2eFA2NTNzNjFGYTBpclRvUGlJTFZwMU1jdGRxVnB0VnJFV1JadzQ2NEF4MzhNNgpCMjFvN2NaUmlZN3VGZTA4UEllbEd3VGc0cHJRdEg2VXVuK09BV3MrNFNDTU5xT2xDRkNzSDBLK0NZZUMyZmpXClplaURsbjBTUDdkZ3puMmJsbk9VQzZ0Z3VtQ3grdW1ISVdmV1hzUDVQR0hoWFBwYlpGbDA4ZktaelNqbytCOWkKVzVsbWhrRE1HM0dsU0JPMmEvcEtjck1uTFVWbE15OVdWLy9LUmw3ZWFtdmJ5dWFzSnZHbVJ4L3d1NXlpYVhwSwprZG4xL0E2VFhBRnVvbU4xb3NvaGVyMjR2MHZ0YzBGZmxJM3h4WVpVTXIwazhLV0VlM1Nhdk83NkdrZTJhbEppCnVtZ20wTmhtK2pqNmlXajl1V1ZzV215MmFDMHc0aTRDS1d2YU56K0NDek5kWk8vcFpPTmlmTzVSSUZpZ2RzTVgKUHgvWU5nSkVKdmEyUVZ2MU9kcWZTdW1CMS8zRldFYmg5V2tFYXRGOElJRDI5TS9qVktiRm9BaktYeVZhUTI5eQpOOFRWR3Axc2pzOW5sSWdjN0JRUFhBZTVPQUExdnc5SWV4N09QZjhPZENBbDluQzlEaDdaK3MyV2lOVlRxb2dwCk1VbE1GUWxGVXpMWGVCUmp0ay9rL3lWT20yWkhBT2RuR1k4bSthRWlTV0ExYXhpa0RYMG9HWjhjbHFzQ0F3RUEKQVFLQ0FnRUFwZDZBRG9pQ0M1aU1IVFNQZXBUc2RVYk9BOHFQMHdQVjZlS1VmMXlzalZiWVhqYy9Yekc0Wko2MgpGc3o1TnA0YUdUZWJwaGQ4azBrNWtDU0tRQkFtWUphTVF5ZFBKMElwQ1RXSEQ1QU9NQ0JKNVBwNk9VWEVtVU55CklHQng3QjR2N09LOXl6Q0lDVDlac2hrV1lNWmo1YUlLaWJsSzY5M05iOWZuckhyaGw1NjkrdXRrTTFJR1JMYjIKV05iR2RBeXNlQTNzM0Mzcm1xM1VmYldhdDE4QytXS1QyYUxtY0cybXZCb3FIam51Zjg0aktnSkxDMU8wbFQ1SgpVY0l4c3RKRHpjYkVTVjlNZENKTDlSbHB0RjVlSFFJZFJCZ2ROM2IxcGtnOTM3VkJsd1NJaFVDS2I2RXU2M2FCCitBdmxmWmtlQkU4Ti9pOTN0Qy9TUkdqQmhyUnFVcEVOOVYrOHBJczVxTE5keC9RanF4TEpMMUtwMXQ0L0hVTkEKOVVTZVNrVDZTZ09OZ1NnQktCemFCYzUyTXRoWWYrZDk2YTJkN0N0dCt1amJBT0JKTkdKMytGenJoc3pzUTMzWQpkalBWTGQxSzBQSHZ0WDNrSWRKbFNWSmYxS3d5bDVKVm1Cck1wb2ZDQ2dsNnhyR0puYVJPb1A3bDZNb1BFZ21hClNRWWFIQVIvVGIzM2lBeTNLdlBuUkNMQlM2MEJCYitIcVd3c0RhczM0Uk9WUE05bUI2ZldkTUo0TG5kZmVpZm0KTGZ3Sy9GMXpRdFRaczNpYUYyMGEvY0EvdjRENWJCUldYSEQvTDA3Mks5TGxoMGNRRFVZY1V1ZUdwRWUycEZHRApxa1pCL08wSXNBOXAyTnNCekdvRWl1eHJwd0JBaXpiOUdCcU9DZUlGS1hKeU5heGU3YUVDZ2dFQkFOeG9zQ2cyCngwTWQzajRtWVhvWVpMMVBOUklwNlpuN2VLbThzK0tIRFdMUTlXWmtFbUwyODNXNzJFd2dDbmc2VjdsUHVYVlEKVTJXR0xjNDNvUU95U3JlNEZXbnZhTVhnWk42Wis2T0wvQ1J2VHZSbFhVNXJlYVNCT2tyZUJYK1g2dFo2Q1dORgpLWjkxTERvVVR5TlJVTTFUL3lwbS85SlE4MTJ1VUxnYUlQZGl5cCtPYmRoZWdBUE5CS0lxR3Nva0tKRlpjRDNyCjRwSVdHT0U3RVJrbU14MnFZMk54VGtuUGxOVUJzR01jS25qeTdycER5WmpDR0U3eldoRE5XRGdMUkJOc1liaHIKa0p4ZlNVVlBOb2RLaE8xVHQ3bDJRMnplcWxlV05pcktRbWdMY3JJRU9MRUdYcEY3U250eEx3N1pvYWlQU0FWWApQMTVqNXNkZlUzV1ZOdzhDZ2dFQkFOeGcyOGw5TllHUmwwU1JCZFJEakJhV21IK0pWYWdpdG0zNnorcnB1MWdZClZ4dFJ0N0FGTzF1QVphTys1aWd1d0JKcFhSUWJXVmZUcWppaTM1bUV2UENkZjhPcTZBQVlzeXg5WXVmUUdOUnEKZG1VNlcvdWhCMnVURDBrL0dQdjVFb2hBTlRjQmkyS1ROS2p0S1Z2bHFtbWZ4Tis5YTl4NjVEdWRHWUFRNGplNwpGaHZJSlU5WFA5VnRUc0ZGL1dqbE54enJNQURqSzNJekRvQTMwaU1XQXZkeTFjUDgxUzJzeGtwa0ZoL1QrNVVFCjYwZkNOSGFFemtQWWhKUmxYaUZtWXpqc3AyWjZpUERyMllHd1FWbURoMFFGeFVqZnoxdk1ONFdnVlVVeDlmNnUKR3QxeDdHblZFSGhzQ0VjQlFCUkhFbzJRcXY0VDVXbmNTNUVTN2hqK1JxVUNnZ0VBRDVUVEJ6VEFKMjJBSFpLbgpCM09jQTRvSzdXckxHZGllTWhtbCtkaWtTSjBQREJyODljUVJkL3c4a1QwZW9GczNnbUV4Y2lxb2lwL09zeXBaCmxxSlBCK2ZhazYrYUQ0c0tkbllhUlBpTGJhUDB4L0EyaFdteG9zQ0Q5M0Qwb0kyRHkzKzdGQ3A2Zzh4THdSdFkKY04yNXdab3ppckxYV08zaUZuaFJPb0tXWEFhKzNrSzZYelpuQkYzRSt4WFE2UU5mWHM4YzBUUFF3NVVPVXpYUwp3cDFodGJJcTdvZS9DaGJEcGI5RjBldlcwTkFUc2xWQ2Rpc2FmdEpUUnFiTm1zQ3BJbHBpR2lCNGk2VnN6NXFHCjkwOThVQzYvNlR1RURyazYvNUFkNmk1OFBWQzUzZjNRYUN0VUdpTEdKQzNmTHNTUjJoR3UvTG1yUUNmOTA1QlkKblJKY1h3S0NBUUVBbjJkQUV5SUtEY3B0akI4S0JGdEhmUjg0OXljeldnYWh4ak5oS1I0ZmNMMUtaR3hiWFdxcgpZS2dpM0tvOGVGdzRlaGpVUnJMeGtPRjlnckhzNG5KczUrNUVlQmVxOEVidGN3VFBBYlkzLzQxeVRnNUVjbUlyCnA5Z2Jlbk8xY3F6YWhzdEtzcHJmWTFIdkNURmlkU0pPZlZBZmEyYnNHZkthRzdTcXVVTjlIYXFwZHpieUpjMksKVXFwYUNOckRUWmhlb1FCTkhKYzAyY21zZDNubytZLzJYVjRtMlRpTVNobHE1R3c0eEpUa3FRbUIxY25YZ05MWApENlFSWWZWZ2ZQQStYUEp3czJOMm9pMDJpdVFlb016T2pwbE45a1JOREsxT2k4MUpZRitlKzdTYm9nbkJZMXZHCktoU2FlQ0dqWkFkMG1BbElaYmVtZlVmbk1PeHNaSStvTVFLQ0FRQmdETzBkTEt2Z3k0OFFwNzdzU3FkeGRRdTEKb2pqYm9rMGY4VVo5ZDJZWWl1WHMwb0k2WFQ4cmpESmJYUGZSUmFVUU1JYWRrL1VZOWxRdHZRRThHbW9aR2ozbgpXYTVXWGVkcUR3YUR4aHpmVnZQUzFMVm1VdkhsbllPWVBVT0JPc1ZUaU4yWXk1L0Y5WEpxMWRlVW0xVnVOZCs1ClVuK3d0YWVHVGR5K1pyQjF2RUFRT3M3R1REVFI2MjgwV1BPZ1JsenVRejhkYllYR29iajJrd3N1empCa0EvSjAKc2dkeEF0dExBWmIzQlVSQ2NmenkrdHJCd0Y3S1ZYek5EQnhmcit3MklRR0hINXR5NmNvcExTVDNXb2Y4WVRuTQpMdHBCVDNZTmgwTm5hS25HTlRGc3pZRldIRlJqSjRZU1BrcW85TkdWa0tiblZyOTllMDFjLys1VjBYY00KLS0tLS1FTkQgUlNBIFBSSVZBVEUgS0VZLS0tLS0K")
  488. smtc.pushData = testingfake.PushSecretData{
  489. SecretKey: secretKey,
  490. RemoteKey: keyName,
  491. }
  492. smtc.keyOutput = keyvault.KeyBundle{
  493. Tags: map[string]*string{
  494. "managed-by": pointer.To(managerLabel),
  495. },
  496. Key: &keyvault.JSONWebKey{},
  497. }
  498. }
  499. ECKeySuccess := func(smtc *secretManagerTestCase) {
  500. smtc.setValue, _ = base64.StdEncoding.DecodeString("LS0tLS1CRUdJTiBFQyBQUklWQVRFIEtFWS0tLS0tCk1JR2tBZ0VCQkRBWTk0L0NYOGo4UDNBakZXUkZYR0pWMFNWT1ErU1ZpV01nd0VFdy9rV2ZXcHF1OGtidllVTnAKVTQyN1Fubk5NV3VnQndZRks0RUVBQ0toWkFOaUFBU1FyOXAvcytDWHpFY2RUZ2t0aVFhTkxuVzJnNmQ1QkF4cQpBQXNaQms2UW11WngrZTZMUUdra080Uit0SVVaZCtWTGJlV3pLeEl3dk9xSVA3bkp0QldtTjZ4N3JsMjJibnhNCm5QWVQyNy9wSXM1RTk1L2dPV2RhOGMyUStHQTd5RTQ9Ci0tLS0tRU5EIEVDIFBSSVZBVEUgS0VZLS0tLS0K")
  501. smtc.pushData = testingfake.PushSecretData{
  502. SecretKey: secretKey,
  503. RemoteKey: keyName,
  504. }
  505. smtc.keyOutput = keyvault.KeyBundle{
  506. Tags: map[string]*string{
  507. "managed-by": pointer.To(managerLabel),
  508. },
  509. Key: &keyvault.JSONWebKey{},
  510. }
  511. }
  512. invalidKey := func(smtc *secretManagerTestCase) {
  513. smtc.setValue, _ = base64.StdEncoding.DecodeString("LS0tLS1CRUdJTiBDRVJUSUZJQ0FURS0tLS0tCk1JSUZhekNDQTFPZ0F3SUJBZ0lVUHZKZ21wcTBKUWVRNkJuL0hmVTcvUDhRTFlFd0RRWUpLb1pJaHZjTkFRRUwKQlFBd1JURUxNQWtHQTFVRUJoTUNRVlV4RXpBUkJnTlZCQWdNQ2xOdmJXVXRVM1JoZEdVeElUQWZCZ05WQkFvTQpHRWx1ZEdWeWJtVjBJRmRwWkdkcGRITWdVSFI1SUV4MFpEQWVGdzB5TWpBMk1UY3lNREEwTWpSYUZ3MHlNekEyCk1UY3lNREEwTWpSYU1FVXhDekFKQmdOVkJBWVRBa0ZWTVJNd0VRWURWUVFJREFwVGIyMWxMVk4wWVhSbE1TRXcKSHdZRFZRUUtEQmhKYm5SbGNtNWxkQ0JYYVdSbmFYUnpJRkIwZVNCTWRHUXdnZ0lpTUEwR0NTcUdTSWIzRFFFQgpBUVVBQTRJQ0R3QXdnZ0lLQW9JQ0FRRGlEditEVENBL0xaZjZiNnlVYnliQUxlSUViOHh0aHd1dnRFZk5aZ1dOClN3ZWNMZXY0QXF1N3lSUWRidlQ1cnRKOGs3TnJ0TUE0RDNVN1BQamkwOXVpdjFnSGRockY0VlloTjhiRFllc1UKaEpxZXZSVFBVQ0hRek9xMmNhT3ViRnBUN3JxN3lsMVFTQTFlbkptMUQxNnc0UnlJcEtTLzhvVDNQaGtXM1YydwpkWmFjblZSV1RXZE5MTy9iVWdseDd1YzJMS0wwd2pIMzNSbkZiWUUrTTdiZFVDUXlsSXFwcDM2ZWNvL0Y1Ym1xCjdRdzJ2VkRENENGY0g5aUp4N1FDYjc4Skp5WWlMNzRycjJNVXVzMzR5RlhpMUk5RDR0ajdtQTM2VmNHRk9OZUsKdEtLMnlOYWNrWm1VeTlLQUdGWnIxU2c0ODZTcWw2Y2VpTlAvVGpsb3dQaDNMOTFHOEUxaGJSM3dDS2J6MUR1bQpmaEZOSUdNZmNERkNRcXpEUlU4OEpuUlcyYnF2bGpGanFla0NkcncyeHcrOWp1K1NieXkxeVlrN3ZSM015ZHovCmJ1YUY1S29YUlVzUzhxOHIwSEg1TVAzR3ZYVVY3eXU4bE5kUUtzMXhnVVpmL2JYM0ZjS2xjazhNU3ZZbjNMQWoKbDNRNHMwMXZQY1JnaUMyTUZmajlzV0pueW16YVhYUk1qNFpaY0RuVHlFUmhOcHpXSmNMelh3bFcydTVKdkpVTQpRVEdxUlpXYkErMHF5Y0dBOENBTHRRTXc2ZU5sLzI0Mlo5ZnZ0U0JPc3VkWTdEWTFXckFTWTNhbVV1WWU4RjFBCjhNMlg2N0xBc1lGNkY5YW9JNk00S2dVSXdHYm81OGFVTU1qdzJibGkzdHZIaVNSSjduejFXU1VGOHZnZThIYkEKcFFJREFRQUJvMU13VVRBZEJnTlZIUTRFRmdRVWd0Y0xTUXpaUkRmQkFsSWh5b2pJTHNLYXBwc3dId1lEVlIwagpCQmd3Rm9BVWd0Y0xTUXpaUkRmQkFsSWh5b2pJTHNLYXBwc3dEd1lEVlIwVEFRSC9CQVV3QXdFQi96QU5CZ2txCmhraUc5dzBCQVFzRkFBT0NBZ0VBcy96OWNOT1ZSUzZFMmJVZm9GZS9lQW5OZlJjTmNaaW05VkdCWUFtRjc0MDgKSVEvVjhDK3g3cEloR1NGZ2VFNncxS1BRVXF0Z3dldUxFK0psOVhEYlAvMUdhcmgvN0xDWTVBUXk5eEdTVTNkcAp5VWs3SWE2a0wxRENkS3M0dXdGZ24wVjE1SytSM01Ud2FsemhVb1NVS2tDYVVSeU4vNTZXYk9OanhzRUhUbFhnClBBTEVYKzZVNDMzdktkYnNZdTJXZ2hXSmNwMytSZkI2MU90VmdvYTJYaThhL2pSbFpKVUJ1ZURESGEwVTE0L2EKaFRKcVdQWElROFlTY1BCbndsTzFyRjJkaEtMU0hiczZBd3d6VEVHUE5SUVpGRXF4YTJlb3VvV0NWUmxHTGVueQpMcWxnb1FSQ1pGRTdNNnBJazE5b0ZwV2tTSmNXYjFRMjJRWE03SFdKNjNtM2VBRjBUNThXcE45UzBsYXFNbnZCClZxNVpueUs1YVNDNjV3MGp1YzJteWM2K1RyUmNQSmM0UHJCY3VSZ0gvS1M1bkQvVFlKSStOSVBjU0NVZ2VKWFgKR003THNZanVuY1pCQmJkbFByRXJJN3pkYVNGdVJJbWYrSmh3T2p4OThSZjg3WkQ3d05pRmtzd1ZQYWZFQzFXQQoxc3ZMZDI0Nk0vR3I0RFVDK2Y2MUx4eFNKUkRWMDNySmdsZnY2cWlrL3hjaVlKU2lDdkZzR0hqYzBJaEtyTXBNCnFKRW03dWQxK3VTM3NHWTR6SkVUMUhleEJudjJ4RVlESjZhbGErV3FsNDdZTllSNm4yNlAvUWpNYjdSSGE1ZWMKUEhPMW5HaTY5L1U1dmVMRVlmZmtIV01qSTlKa1dhQzFiREcrMDl0clpSdXNUQWJCZHhqbWxzZ3o0UUFDeFd3PQotLS0tLUVORCBDRVJUSUZJQ0FURS0tLS0tCg==")
  514. smtc.pushData = testingfake.PushSecretData{
  515. SecretKey: secretKey,
  516. RemoteKey: keyName,
  517. }
  518. smtc.keyOutput = keyvault.KeyBundle{
  519. Tags: map[string]*string{
  520. "managed-by": pointer.To(managerLabel),
  521. },
  522. Key: &keyvault.JSONWebKey{},
  523. }
  524. smtc.expectError = "could not load private key keyname: key type CERTIFICATE is not supported"
  525. }
  526. noTags := func(smtc *secretManagerTestCase) {
  527. smtc.setValue = goodKey
  528. smtc.pushData = testingfake.PushSecretData{
  529. SecretKey: secretKey,
  530. RemoteKey: keyName,
  531. }
  532. smtc.keyOutput = keyvault.KeyBundle{
  533. Tags: map[string]*string{},
  534. Key: &keyvault.JSONWebKey{},
  535. }
  536. smtc.expectError = errNotManaged
  537. }
  538. wrongTags := func(smtc *secretManagerTestCase) {
  539. smtc.setValue = goodKey
  540. smtc.pushData = testingfake.PushSecretData{
  541. SecretKey: secretKey,
  542. RemoteKey: keyName,
  543. }
  544. smtc.keyOutput = keyvault.KeyBundle{
  545. Tags: map[string]*string{
  546. "managed-by": pointer.To("internal-secrets"),
  547. },
  548. Key: &keyvault.JSONWebKey{},
  549. }
  550. smtc.expectError = errNotManaged
  551. }
  552. errorGetKey := func(smtc *secretManagerTestCase) {
  553. smtc.setValue = goodKey
  554. smtc.pushData = testingfake.PushSecretData{
  555. SecretKey: secretKey,
  556. RemoteKey: keyName,
  557. }
  558. smtc.apiErr = autorest.DetailedError{StatusCode: 403, Method: "GET", Message: "Forbidden"}
  559. smtc.expectError = errAPI
  560. }
  561. keyNotFound := func(smtc *secretManagerTestCase) {
  562. smtc.setValue = goodKey
  563. smtc.pushData = testingfake.PushSecretData{
  564. SecretKey: secretKey,
  565. RemoteKey: keyName,
  566. }
  567. smtc.apiErr = autorest.DetailedError{StatusCode: 404, Method: "GET", Message: "Not Found"}
  568. smtc.expectError = ""
  569. }
  570. importKeyFailed := func(smtc *secretManagerTestCase) {
  571. smtc.setValue = goodKey
  572. smtc.pushData = testingfake.PushSecretData{
  573. SecretKey: secretKey,
  574. RemoteKey: keyName,
  575. }
  576. smtc.apiErr = autorest.DetailedError{StatusCode: 404, Method: "GET", Message: "Not Found"}
  577. smtc.setErr = autorest.DetailedError{StatusCode: 403, Method: "POST", Message: "Forbidden"}
  578. smtc.expectError = "could not import key keyname: #POST: Forbidden: StatusCode=403"
  579. }
  580. certP12Success := func(smtc *secretManagerTestCase) {
  581. smtc.setValue = p12Cert
  582. smtc.pushData = testingfake.PushSecretData{
  583. SecretKey: secretKey,
  584. RemoteKey: certName,
  585. }
  586. smtc.certOutput = keyvault.CertificateBundle{
  587. X509Thumbprint: pointer.To("123"),
  588. Tags: map[string]*string{
  589. "managed-by": pointer.To("external-secrets"),
  590. },
  591. }
  592. }
  593. certPEMSuccess := func(smtc *secretManagerTestCase) {
  594. pemCert, _ := base64.StdEncoding.DecodeString("LS0tLS1CRUdJTiBDRVJUSUZJQ0FURS0tLS0tCk1JSUZwekNDQTQrZ0F3SUJBZ0lVTUhhVDZtZG8vd2Urbit0NFB2R0JZaUdDSXE0d0RRWUpLb1pJaHZjTkFRRUwKQlFBd1l6RUxNQWtHQTFVRUJoTUNRVlV4RXpBUkJnTlZCQWdNQ2xOdmJXVXRVM1JoZEdVeElUQWZCZ05WQkFvTQpHRWx1ZEdWeWJtVjBJRmRwWkdkcGRITWdVSFI1SUV4MFpERWNNQm9HQTFVRUF3d1RZVzV2ZEdobGNpMW1iMjh0ClltRnlMbU52YlRBZUZ3MHlNakEyTURreE56UTFNelphRncweU16QTJNRGt4TnpRMU16WmFNR014Q3pBSkJnTlYKQkFZVEFrRlZNUk13RVFZRFZRUUlEQXBUYjIxbExWTjBZWFJsTVNFd0h3WURWUVFLREJoSmJuUmxjbTVsZENCWAphV1JuYVhSeklGQjBlU0JNZEdReEhEQWFCZ05WQkFNTUUyRnViM1JvWlhJdFptOXZMV0poY2k1amIyMHdnZ0lpCk1BMEdDU3FHU0liM0RRRUJBUVVBQTRJQ0R3QXdnZ0lLQW9JQ0FRQ1pITzRvNkpteU9aZGZBdDdEV2pHa0d3N0QKNVVIU1BHZXQyTjg2cnBGWXcrZThnL3dSeDBnZDBzRk9pelBBREdjcnpmdWE5Z3ZFcDRWc1dvYUduY3dReGp2cworZ1orWmQ2UkVPNHRLNzRURmYxaWZibmowUHE2OENlQlFpaG8xbDNwM2UwQy8yemVJMjNidlZEdmUybXdVcTloCjY4UTFFUmdWMU1LaWJHU1Naak5DQzdkRGFQWmpKazViMFlWVFdxREViemREVnh2ZVVMNVJxRmcvREpBMzNWcTYKVFQzQ2U5RjBIcEorb3graSs4cUxmWU5qZExSUDZlbEtLTU5naVhhNTFvdnQ5MjF4UkVGdlhFdi9NS2pZOWE2SgppNndIRSs0NmdvbFY4V2puK2xMRkRKVHh6WEFEN2p2NzVzaHY0WEczdFlaQ2J4cTMzZ2Jtb3pzRVBneVNEa0IyCm5zc0tIUEFhSVNPaWpjNDhiSXhwbDVocFJPWUZFblJDWnhablhQNjdLZVF1VWZXQkpoVWdhaW1zQlErenpwUHoKZjVUbjRnVExkWll2NU41V1V2djJJdUF5Qktha0ZhR1ZYTzFpZ2FDeVQvUTNBcEE2ZGx4SjVVbjhLNjh1L0pIYQpmWWZ5engwVnVoZk5zbmtiWkxWSEZsR2Rxd3JrU0tCWSs1eS9WWlpkeC9hSHNWWndVN3ZEY2VobGVaUU00ZXZyCm5tMUY3dk5xSHBUK3BHSnpNVWVUNGZMVFpabTBra1Y3ZXl5RGRMMDFEWXRXQk1TM2NEb1F1Tm9YSUEwK0N4Vk8KOHcxcC9wbXF2UFQ3cmpad2pwYkVMUkp3MWs4R3ozU2FKb2VqaFBzWC9xNzNGWWdBc09PRHBNcm4rdmlTZTRmcgpmR0VmZlEvYXJUVE5qK1BUb3dJREFRQUJvMU13VVRBZEJnTlZIUTRFRmdRVWJPQk14azJ5UkNkR1N4eEZGMzBUCkZORFhHS3N3SHdZRFZSMGpCQmd3Rm9BVWJPQk14azJ5UkNkR1N4eEZGMzBURk5EWEdLc3dEd1lEVlIwVEFRSC8KQkFVd0F3RUIvekFOQmdrcWhraUc5dzBCQVFzRkFBT0NBZ0VBQXdudUtxOThOQ2hUMlUzU2RSNEFVem1MTjFCVwowNHIwMTA3TjlKdW9LbzJycjhoZ21mRmd0MDgrdFNDYzR5ajZSNStyY1hudXpqeEZLaWJVYnFncFpvd0pSSGEyCjF0NUJicEwxeWcybGZyZnhIb3YvRjh0VnNTbUE4d3loNlVpV1J3RTlrdlBXUm5LblR1a3Y1enpzcVNsTlNpbG0KNDl6UTdTV05sK0lBRnkvc3dacnRKUTEwVlQ5czRuUGVHM29XUU1vdE9QUCtsbFNpeW5LTFpxUTRnU0tSaTNmZQpQTGlXcHQ5WGZYb0dVQ0VqN3E1cGhibExQZ2RLVUNyaEdQMW4yalltWHNjV0xNeWtBbmEyMGNobHJxVlluQ2E4CkpVcDRMZnRGRHA4OVlUb1hPRkhuRm1uTkN2Y0lyRGZGeURmaGw0VU1GcEswT1VLcVRUeFdhSzl1cU9JcGFySXMKS1l3c3ArZkxlV0xiUTZrR2Ztbk81aURSZCtvT2hyTllvb1RaVks5ZlFSNXJEMmU0QitlYTByelFGWEFBVWpKNQpPWGFieGJEclErT01landjNEhxcXN4enRKZ0QyYVAyZUsyL0w1UFdQdWcwRSsxZzhBQlpmVmJvaC9NM01IZ2J6ClBnYVRxZ3V6R0Zka0czRVh1K09oR2JVMC8rNzdWTW5aaTJJUVpuL2F3R1VhN1grTVAwQkR2alZZNWtWcE1aMWgKYzJDbERqZ3hOc0xHdGlrTzRjV2I1c1FSUjJHWU0zZE1rNTBWUWN0SjVScXNSczZwT0NYRFhFM1JlVlFqNGhOQgplV3ZhRFdRMktteU9haTU1ZGJEcmxKK251ODNPbUNwNTlSelA1azU4WmFEWG5sQzM4VXdUdDBxMUQ3K3pGMHRzCjFHOTMydUVCSFdZSHVPQT0KLS0tLS1FTkQgQ0VSVElGSUNBVEUtLS0tLQo=")
  595. smtc.setValue = pemCert
  596. smtc.pushData = testingfake.PushSecretData{
  597. SecretKey: secretKey,
  598. RemoteKey: certName,
  599. }
  600. smtc.certOutput = keyvault.CertificateBundle{
  601. X509Thumbprint: pointer.To("123"),
  602. Tags: map[string]*string{
  603. "managed-by": pointer.To("external-secrets"),
  604. },
  605. }
  606. }
  607. certPEMWithGarbageSuccess := func(smtc *secretManagerTestCase) {
  608. pemCert, _ := base64.StdEncoding.DecodeString("LS0tLS1CRUdJTiBSU0EgUFJJVkFURSBLRVktLS0tLQpNSUlFb3dJQkFBS0NBUUVBNWNXTTdWYnd2dGtxWXVLd1lrVUhlSXRMQnd2eUd2ekhzODQwbDZpT00rZXZneEVXCmcydFAvb3NYeG1Rb1ZOdDJLUXRScEwweTh4K3JhWHhRRm5VTlJEc3pHSEkyWTdmWnVVRWd0M2FQQVhmUUlMNm0KazdJaWQ0VmZUdlpLTFhNbnB6dEduNVlaTVBxak0yU3k3ZWY5ZjJMNkxuamNwRkRNZFBqN25vd0pxcTdMb3kxcAo2aU1xeHNyRGY1RXloRHdGUVhiZHRQM0pPNmpjSDY4UUVsVkE0eVR5RHR4WXpxSS9mb0pIM2tGZStHSmJwS0FNCnlNQXRwVkphS2F6VGVnTCtWZnc1MFV2czFLT3A3L1ZxZXVCd2FpZDhtWkhYWDFRUE44RE9VUmJRbkhoVUp1Y3UKZlIyNVdlbHhqWUtOMGdGWFE1bHo5MXY1TmVlTnhQWkhRbkZ2NVFJREFRQUJBb0lCQUNQR2FuYlp2b280amR6dgpwcjdtT0krUVFKSk1UZG5kMmNvcEpROG44MXdwaXE1Qmp0dlBiWmtZVnc5UXNPYmxkTFJYU3RMM2ttTkFYeFFCCmd3YThHdUN3eHZmYmNKUitINncwYzcrYytnOGtkSWRrcDlML1BWYVdzWXc5MUxiVzR5bXFsUWhyK21naDNoODIKWXBXZ05Wd01NUi9qT1pkcjdTbVpTclFZNGJodFN6eFlDOE5Vc0hwL1JaR3FqejdILzRyR1B5dEpTMjFVYVMzegpabXBLdHcrRm81ZVF5UW5lUVUyL2dmNkxTV3JUZjI5Y3NXSEVlMUpRWHZzYlA1enAxbGEzRjBXczEvOUNyT0VNCnFsbUNWNFRXWXR1Nno1a2k2Y1c1enkybEVLSnpCYTVqT0ZqRGtqREFzRm1IZmNydXlMbVVqZUU2MWlPZjAycXQKV1Z5MkZZRUNnWUVBNmRRdFgxTDNmaVpKdFUzd0lkVytxVkZSeEFwMUd6RG5TaEJBQmg0SDA5eHFhMzc2RXovSgpYUmdrV0xLZTU0VUdnZi9ZTzJDTkRkSzVGZmw1MHNrN1hDeGJPRzZITTNSRytxZjQ0MXUzQWd6L0ppa3QyOFBMCmZ2dUJYRG91a1hQUUVvWHR1cHNHaFJLRUxleWhZTHNJSzZNWndJQnFBQThGV200cWc1b2RPazBDZ1lFQSs0N2sKaXNHMWRxaFdnUk1Fc1ZBVG9SeW9ITDBXYVFpbkhXUWQ4ZFBDZ1BDNzJqbmZQdmZ2THZnUEVEeEMxTk41VEJNUQpwOHliS2EvOEZOVzV0VkpQdXdsSGlveURKdHZVVFQ1UVZtVmtOa21LZllZR1h0dVlqQUVtaVJWL0JSRVZQSG0yCnYvTjBLRHA2YVRTQXAxdm10czZoQ0I0ZGNSeXkyNnNTdG5XcUova0NnWUEwRHlBMjYrTGNQQ3dHNko1QStqU2oKdjg0amhteUNMRVlpVURIZzZzaTFXNHA1K21BMDd1dW5CVnY2UDNKdmUwZHlwQUtCWGNLcHhET2U5OWN1bmN6UQpmYk9sZ2I0cUw0WXFBa0hBWk1mKzllUE1uRGh3aUV3RExuMmppZlNhUDUyZ3NoNjJnQk5ZaDBIVWM2Mk9PclhiCitVa2ZlYmVmNGJoQVpPeWtOaWl4dFFLQmdFNm1MRm9kbWlpUkZRcWg4Wk9tWDV5OW91bnBUSHBtVkNsaVJlSjMKdkpZbnJmUGFxQ3U5eExCQXFpVC9VajNNS0Y1YWo1aUc1ZlF3cTNXd0pMSEdIRnR6MlVRK0RqczErN2h5eFJkZAo5K2pwTVQxeGk4aFlpK2NwN094ckpoMWxhK2hPZlk2aUJTMFdxM0w5RVVSQi9XNG1TRDZMZTlVRGpnQVVDbk8xCmNnK3hBb0dCQU9YVktjTzFpS3UrZWNCZUxFMVV0M2JUcUFCL2tCcFRkdVZZbTh3Mld0b1BUQ2tqUTZNc2o5ZWcKRjJ0R0pwbUV0djZ6NnMzbmo1TmhSWlYyWDh0WjMxWHViVkdVQUt4aGprSnlPQnBuczk3bTlxZUMxRHlFcDlMaQp6RnFpQ1VMWVp1c1JObzVTWVRCcHBCbmFPN1ArODhFMnFmV3Fob0h6b1dYNWk1a2dpK0tXCi0tLS0tRU5EIFJTQSBQUklWQVRFIEtFWS0tLS0tCi0tLS0tQkVHSU4gQ0VSVElGSUNBVEUtLS0tLQpNSUlGcHpDQ0E0K2dBd0lCQWdJVU1IYVQ2bWRvL3dlK24rdDRQdkdCWWlHQ0lxNHdEUVlKS29aSWh2Y05BUUVMCkJRQXdZekVMTUFrR0ExVUVCaE1DUVZVeEV6QVJCZ05WQkFnTUNsTnZiV1V0VTNSaGRHVXhJVEFmQmdOVkJBb00KR0VsdWRHVnlibVYwSUZkcFpHZHBkSE1nVUhSNUlFeDBaREVjTUJvR0ExVUVBd3dUWVc1dmRHaGxjaTFtYjI4dApZbUZ5TG1OdmJUQWVGdzB5TWpBMk1Ea3hOelExTXpaYUZ3MHlNekEyTURreE56UTFNelphTUdNeEN6QUpCZ05WCkJBWVRBa0ZWTVJNd0VRWURWUVFJREFwVGIyMWxMVk4wWVhSbE1TRXdId1lEVlFRS0RCaEpiblJsY201bGRDQlgKYVdSbmFYUnpJRkIwZVNCTWRHUXhIREFhQmdOVkJBTU1FMkZ1YjNSb1pYSXRabTl2TFdKaGNpNWpiMjB3Z2dJaQpNQTBHQ1NxR1NJYjNEUUVCQVFVQUE0SUNEd0F3Z2dJS0FvSUNBUUNaSE80bzZKbXlPWmRmQXQ3RFdqR2tHdzdECjVVSFNQR2V0Mk44NnJwRll3K2U4Zy93UngwZ2Qwc0ZPaXpQQURHY3J6ZnVhOWd2RXA0VnNXb2FHbmN3UXhqdnMKK2daK1pkNlJFTzR0Szc0VEZmMWlmYm5qMFBxNjhDZUJRaWhvMWwzcDNlMEMvMnplSTIzYnZWRHZlMm13VXE5aAo2OFExRVJnVjFNS2liR1NTWmpOQ0M3ZERhUFpqSms1YjBZVlRXcURFYnpkRFZ4dmVVTDVScUZnL0RKQTMzVnE2ClRUM0NlOUYwSHBKK294K2krOHFMZllOamRMUlA2ZWxLS01OZ2lYYTUxb3Z0OTIxeFJFRnZYRXYvTUtqWTlhNkoKaTZ3SEUrNDZnb2xWOFdqbitsTEZESlR4elhBRDdqdjc1c2h2NFhHM3RZWkNieHEzM2dibW96c0VQZ3lTRGtCMgpuc3NLSFBBYUlTT2lqYzQ4Ykl4cGw1aHBST1lGRW5SQ1p4Wm5YUDY3S2VRdVVmV0JKaFVnYWltc0JRK3p6cFB6CmY1VG40Z1RMZFpZdjVONVdVdnYySXVBeUJLYWtGYUdWWE8xaWdhQ3lUL1EzQXBBNmRseEo1VW44SzY4dS9KSGEKZllmeXp4MFZ1aGZOc25rYlpMVkhGbEdkcXdya1NLQlkrNXkvVlpaZHgvYUhzVlp3VTd2RGNlaGxlWlFNNGV2cgpubTFGN3ZOcUhwVCtwR0p6TVVlVDRmTFRaWm0wa2tWN2V5eURkTDAxRFl0V0JNUzNjRG9RdU5vWElBMCtDeFZPCjh3MXAvcG1xdlBUN3JqWndqcGJFTFJKdzFrOEd6M1NhSm9lamhQc1gvcTczRllnQXNPT0RwTXJuK3ZpU2U0ZnIKZkdFZmZRL2FyVFROaitQVG93SURBUUFCbzFNd1VUQWRCZ05WSFE0RUZnUVViT0JNeGsyeVJDZEdTeHhGRjMwVApGTkRYR0tzd0h3WURWUjBqQkJnd0ZvQVViT0JNeGsyeVJDZEdTeHhGRjMwVEZORFhHS3N3RHdZRFZSMFRBUUgvCkJBVXdBd0VCL3pBTkJna3Foa2lHOXcwQkFRc0ZBQU9DQWdFQUF3bnVLcTk4TkNoVDJVM1NkUjRBVXptTE4xQlcKMDRyMDEwN045SnVvS28ycnI4aGdtZkZndDA4K3RTQ2M0eWo2UjUrcmNYbnV6anhGS2liVWJxZ3Bab3dKUkhhMgoxdDVCYnBMMXlnMmxmcmZ4SG92L0Y4dFZzU21BOHd5aDZVaVdSd0U5a3ZQV1JuS25UdWt2NXp6c3FTbE5TaWxtCjQ5elE3U1dObCtJQUZ5L3N3WnJ0SlExMFZUOXM0blBlRzNvV1FNb3RPUFArbGxTaXluS0xacVE0Z1NLUmkzZmUKUExpV3B0OVhmWG9HVUNFajdxNXBoYmxMUGdkS1VDcmhHUDFuMmpZbVhzY1dMTXlrQW5hMjBjaGxycVZZbkNhOApKVXA0TGZ0RkRwODlZVG9YT0ZIbkZtbk5DdmNJckRmRnlEZmhsNFVNRnBLME9VS3FUVHhXYUs5dXFPSXBhcklzCktZd3NwK2ZMZVdMYlE2a0dmbW5PNWlEUmQrb09ock5Zb29UWlZLOWZRUjVyRDJlNEIrZWEwcnpRRlhBQVVqSjUKT1hhYnhiRHJRK09NZWp3YzRIcXFzeHp0SmdEMmFQMmVLMi9MNVBXUHVnMEUrMWc4QUJaZlZib2gvTTNNSGdiegpQZ2FUcWd1ekdGZGtHM0VYdStPaEdiVTAvKzc3Vk1uWmkySVFabi9hd0dVYTdYK01QMEJEdmpWWTVrVnBNWjFoCmMyQ2xEamd4TnNMR3Rpa080Y1diNXNRUlIyR1lNM2RNazUwVlFjdEo1UnFzUnM2cE9DWERYRTNSZVZRajRoTkIKZVd2YURXUTJLbXlPYWk1NWRiRHJsSitudTgzT21DcDU5UnpQNWs1OFphRFhubEMzOFV3VHQwcTFENyt6RjB0cwoxRzkzMnVFQkhXWUh1T0E9Ci0tLS0tRU5EIENFUlRJRklDQVRFLS0tLS0K")
  609. smtc.setValue = pemCert
  610. smtc.pushData = testingfake.PushSecretData{
  611. SecretKey: secretKey,
  612. RemoteKey: certName,
  613. }
  614. smtc.certOutput = keyvault.CertificateBundle{
  615. X509Thumbprint: pointer.To("123"),
  616. Tags: map[string]*string{
  617. "managed-by": pointer.To("external-secrets"),
  618. },
  619. }
  620. }
  621. certDERSuccess := func(smtc *secretManagerTestCase) {
  622. derCert, _ := base64.StdEncoding.DecodeString("MIIFpzCCA4+gAwIBAgIUMHaT6mdo/we+n+t4PvGBYiGCIq4wDQYJKoZIhvcNAQELBQAwYzELMAkGA1UEBhMCQVUxEzARBgNVBAgMClNvbWUtU3RhdGUxITAfBgNVBAoMGEludGVybmV0IFdpZGdpdHMgUHR5IEx0ZDEcMBoGA1UEAwwTYW5vdGhlci1mb28tYmFyLmNvbTAeFw0yMjA2MDkxNzQ1MzZaFw0yMzA2MDkxNzQ1MzZaMGMxCzAJBgNVBAYTAkFVMRMwEQYDVQQIDApTb21lLVN0YXRlMSEwHwYDVQQKDBhJbnRlcm5ldCBXaWRnaXRzIFB0eSBMdGQxHDAaBgNVBAMME2Fub3RoZXItZm9vLWJhci5jb20wggIiMA0GCSqGSIb3DQEBAQUAA4ICDwAwggIKAoICAQCZHO4o6JmyOZdfAt7DWjGkGw7D5UHSPGet2N86rpFYw+e8g/wRx0gd0sFOizPADGcrzfua9gvEp4VsWoaGncwQxjvs+gZ+Zd6REO4tK74TFf1ifbnj0Pq68CeBQiho1l3p3e0C/2zeI23bvVDve2mwUq9h68Q1ERgV1MKibGSSZjNCC7dDaPZjJk5b0YVTWqDEbzdDVxveUL5RqFg/DJA33Vq6TT3Ce9F0HpJ+ox+i+8qLfYNjdLRP6elKKMNgiXa51ovt921xREFvXEv/MKjY9a6Ji6wHE+46golV8Wjn+lLFDJTxzXAD7jv75shv4XG3tYZCbxq33gbmozsEPgySDkB2nssKHPAaISOijc48bIxpl5hpROYFEnRCZxZnXP67KeQuUfWBJhUgaimsBQ+zzpPzf5Tn4gTLdZYv5N5WUvv2IuAyBKakFaGVXO1igaCyT/Q3ApA6dlxJ5Un8K68u/JHafYfyzx0VuhfNsnkbZLVHFlGdqwrkSKBY+5y/VZZdx/aHsVZwU7vDcehleZQM4evrnm1F7vNqHpT+pGJzMUeT4fLTZZm0kkV7eyyDdL01DYtWBMS3cDoQuNoXIA0+CxVO8w1p/pmqvPT7rjZwjpbELRJw1k8Gz3SaJoejhPsX/q73FYgAsOODpMrn+viSe4frfGEffQ/arTTNj+PTowIDAQABo1MwUTAdBgNVHQ4EFgQUbOBMxk2yRCdGSxxFF30TFNDXGKswHwYDVR0jBBgwFoAUbOBMxk2yRCdGSxxFF30TFNDXGKswDwYDVR0TAQH/BAUwAwEB/zANBgkqhkiG9w0BAQsFAAOCAgEAAwnuKq98NChT2U3SdR4AUzmLN1BW04r0107N9JuoKo2rr8hgmfFgt08+tSCc4yj6R5+rcXnuzjxFKibUbqgpZowJRHa21t5BbpL1yg2lfrfxHov/F8tVsSmA8wyh6UiWRwE9kvPWRnKnTukv5zzsqSlNSilm49zQ7SWNl+IAFy/swZrtJQ10VT9s4nPeG3oWQMotOPP+llSiynKLZqQ4gSKRi3fePLiWpt9XfXoGUCEj7q5phblLPgdKUCrhGP1n2jYmXscWLMykAna20chlrqVYnCa8JUp4LftFDp89YToXOFHnFmnNCvcIrDfFyDfhl4UMFpK0OUKqTTxWaK9uqOIparIsKYwsp+fLeWLbQ6kGfmnO5iDRd+oOhrNYooTZVK9fQR5rD2e4B+ea0rzQFXAAUjJ5OXabxbDrQ+OMejwc4HqqsxztJgD2aP2eK2/L5PWPug0E+1g8ABZfVboh/M3MHgbzPgaTqguzGFdkG3EXu+OhGbU0/+77VMnZi2IQZn/awGUa7X+MP0BDvjVY5kVpMZ1hc2ClDjgxNsLGtikO4cWb5sQRR2GYM3dMk50VQctJ5RqsRs6pOCXDXE3ReVQj4hNBeWvaDWQ2KmyOai55dbDrlJ+nu83OmCp59RzP5k58ZaDXnlC38UwTt0q1D7+zF0ts1G932uEBHWYHuOA=")
  623. smtc.setValue = derCert
  624. smtc.pushData = testingfake.PushSecretData{
  625. SecretKey: secretKey,
  626. RemoteKey: certName,
  627. }
  628. smtc.certOutput = keyvault.CertificateBundle{
  629. X509Thumbprint: pointer.To("123"),
  630. Tags: map[string]*string{
  631. "managed-by": pointer.To("external-secrets"),
  632. },
  633. }
  634. }
  635. certImportCertificateError := func(smtc *secretManagerTestCase) {
  636. smtc.setErr = errors.New("error")
  637. smtc.setValue = p12Cert
  638. smtc.pushData = testingfake.PushSecretData{
  639. SecretKey: secretKey,
  640. RemoteKey: certName,
  641. }
  642. smtc.certOutput = keyvault.CertificateBundle{
  643. X509Thumbprint: pointer.To("123"),
  644. Tags: map[string]*string{
  645. "managed-by": pointer.To("external-secrets"),
  646. },
  647. }
  648. smtc.expectError = "could not import certificate certname: error"
  649. }
  650. certFingerprintMatches := func(smtc *secretManagerTestCase) {
  651. smtc.setErr = errors.New("error")
  652. cert, _ := base64.StdEncoding.DecodeString("MIIFpzCCA4+gAwIBAgIUMHaT6mdo/we+n+t4PvGBYiGCIq4wDQYJKoZIhvcNAQELBQAwYzELMAkGA1UEBhMCQVUxEzARBgNVBAgMClNvbWUtU3RhdGUxITAfBgNVBAoMGEludGVybmV0IFdpZGdpdHMgUHR5IEx0ZDEcMBoGA1UEAwwTYW5vdGhlci1mb28tYmFyLmNvbTAeFw0yMjA2MDkxNzQ1MzZaFw0yMzA2MDkxNzQ1MzZaMGMxCzAJBgNVBAYTAkFVMRMwEQYDVQQIDApTb21lLVN0YXRlMSEwHwYDVQQKDBhJbnRlcm5ldCBXaWRnaXRzIFB0eSBMdGQxHDAaBgNVBAMME2Fub3RoZXItZm9vLWJhci5jb20wggIiMA0GCSqGSIb3DQEBAQUAA4ICDwAwggIKAoICAQCZHO4o6JmyOZdfAt7DWjGkGw7D5UHSPGet2N86rpFYw+e8g/wRx0gd0sFOizPADGcrzfua9gvEp4VsWoaGncwQxjvs+gZ+Zd6REO4tK74TFf1ifbnj0Pq68CeBQiho1l3p3e0C/2zeI23bvVDve2mwUq9h68Q1ERgV1MKibGSSZjNCC7dDaPZjJk5b0YVTWqDEbzdDVxveUL5RqFg/DJA33Vq6TT3Ce9F0HpJ+ox+i+8qLfYNjdLRP6elKKMNgiXa51ovt921xREFvXEv/MKjY9a6Ji6wHE+46golV8Wjn+lLFDJTxzXAD7jv75shv4XG3tYZCbxq33gbmozsEPgySDkB2nssKHPAaISOijc48bIxpl5hpROYFEnRCZxZnXP67KeQuUfWBJhUgaimsBQ+zzpPzf5Tn4gTLdZYv5N5WUvv2IuAyBKakFaGVXO1igaCyT/Q3ApA6dlxJ5Un8K68u/JHafYfyzx0VuhfNsnkbZLVHFlGdqwrkSKBY+5y/VZZdx/aHsVZwU7vDcehleZQM4evrnm1F7vNqHpT+pGJzMUeT4fLTZZm0kkV7eyyDdL01DYtWBMS3cDoQuNoXIA0+CxVO8w1p/pmqvPT7rjZwjpbELRJw1k8Gz3SaJoejhPsX/q73FYgAsOODpMrn+viSe4frfGEffQ/arTTNj+PTowIDAQABo1MwUTAdBgNVHQ4EFgQUbOBMxk2yRCdGSxxFF30TFNDXGKswHwYDVR0jBBgwFoAUbOBMxk2yRCdGSxxFF30TFNDXGKswDwYDVR0TAQH/BAUwAwEB/zANBgkqhkiG9w0BAQsFAAOCAgEAAwnuKq98NChT2U3SdR4AUzmLN1BW04r0107N9JuoKo2rr8hgmfFgt08+tSCc4yj6R5+rcXnuzjxFKibUbqgpZowJRHa21t5BbpL1yg2lfrfxHov/F8tVsSmA8wyh6UiWRwE9kvPWRnKnTukv5zzsqSlNSilm49zQ7SWNl+IAFy/swZrtJQ10VT9s4nPeG3oWQMotOPP+llSiynKLZqQ4gSKRi3fePLiWpt9XfXoGUCEj7q5phblLPgdKUCrhGP1n2jYmXscWLMykAna20chlrqVYnCa8JUp4LftFDp89YToXOFHnFmnNCvcIrDfFyDfhl4UMFpK0OUKqTTxWaK9uqOIparIsKYwsp+fLeWLbQ6kGfmnO5iDRd+oOhrNYooTZVK9fQR5rD2e4B+ea0rzQFXAAUjJ5OXabxbDrQ+OMejwc4HqqsxztJgD2aP2eK2/L5PWPug0E+1g8ABZfVboh/M3MHgbzPgaTqguzGFdkG3EXu+OhGbU0/+77VMnZi2IQZn/awGUa7X+MP0BDvjVY5kVpMZ1hc2ClDjgxNsLGtikO4cWb5sQRR2GYM3dMk50VQctJ5RqsRs6pOCXDXE3ReVQj4hNBeWvaDWQ2KmyOai55dbDrlJ+nu83OmCp59RzP5k58ZaDXnlC38UwTt0q1D7+zF0ts1G932uEBHWYHuOA=")
  653. smtc.setValue = p12Cert
  654. smtc.pushData = testingfake.PushSecretData{
  655. SecretKey: secretKey,
  656. RemoteKey: certName,
  657. }
  658. smtc.certOutput = keyvault.CertificateBundle{
  659. Cer: &cert,
  660. Tags: map[string]*string{
  661. "managed-by": pointer.To("external-secrets"),
  662. },
  663. }
  664. }
  665. certNotManagedByES := func(smtc *secretManagerTestCase) {
  666. smtc.setValue = p12Cert
  667. smtc.pushData = testingfake.PushSecretData{
  668. SecretKey: secretKey,
  669. RemoteKey: certName,
  670. }
  671. smtc.certOutput = keyvault.CertificateBundle{
  672. X509Thumbprint: pointer.To("123"),
  673. Tags: map[string]*string{
  674. "managed-by": pointer.To("foobar"),
  675. },
  676. }
  677. smtc.expectError = "certificate certname: not managed by external-secrets"
  678. }
  679. certNoManagerTags := func(smtc *secretManagerTestCase) {
  680. smtc.setValue = p12Cert
  681. smtc.pushData = testingfake.PushSecretData{
  682. SecretKey: secretKey,
  683. RemoteKey: certName,
  684. }
  685. smtc.certOutput = keyvault.CertificateBundle{
  686. X509Thumbprint: pointer.To("123"),
  687. }
  688. smtc.expectError = "certificate certname: not managed by external-secrets"
  689. }
  690. certNotACertificate := func(smtc *secretManagerTestCase) {
  691. smtc.setValue = []byte("foobar")
  692. smtc.pushData = testingfake.PushSecretData{
  693. SecretKey: secretKey,
  694. RemoteKey: certName,
  695. }
  696. smtc.certOutput = keyvault.CertificateBundle{
  697. X509Thumbprint: pointer.To("123"),
  698. }
  699. smtc.expectError = "value from secret is not a valid certificate: could not parse certificate value as PKCS#12, DER or PEM"
  700. }
  701. certNoPermissions := func(smtc *secretManagerTestCase) {
  702. smtc.apiErr = autorest.DetailedError{
  703. StatusCode: 403,
  704. Method: "GET",
  705. Message: "Insufficient Permissions",
  706. }
  707. smtc.setValue = p12Cert
  708. smtc.pushData = testingfake.PushSecretData{
  709. SecretKey: secretKey,
  710. RemoteKey: certName,
  711. }
  712. smtc.certOutput = keyvault.CertificateBundle{
  713. X509Thumbprint: pointer.To("123"),
  714. }
  715. smtc.expectError = errAPI
  716. }
  717. successCases := []*secretManagerTestCase{
  718. makeValidSecretManagerTestCaseCustom(certP12Success),
  719. makeValidSecretManagerTestCaseCustom(certPEMSuccess),
  720. makeValidSecretManagerTestCaseCustom(certPEMWithGarbageSuccess),
  721. makeValidSecretManagerTestCaseCustom(certDERSuccess),
  722. makeValidSecretManagerTestCaseCustom(certImportCertificateError),
  723. makeValidSecretManagerTestCaseCustom(certFingerprintMatches),
  724. makeValidSecretManagerTestCaseCustom(certNotManagedByES),
  725. makeValidSecretManagerTestCaseCustom(certNoManagerTags),
  726. makeValidSecretManagerTestCaseCustom(certNotACertificate),
  727. makeValidSecretManagerTestCaseCustom(certNoPermissions),
  728. makeValidSecretManagerTestCaseCustom(keySuccess),
  729. makeValidSecretManagerTestCaseCustom(symmetricKeySuccess),
  730. makeValidSecretManagerTestCaseCustom(RSAKeySuccess),
  731. makeValidSecretManagerTestCaseCustom(ECKeySuccess),
  732. makeValidSecretManagerTestCaseCustom(invalidKey),
  733. makeValidSecretManagerTestCaseCustom(errorGetKey),
  734. makeValidSecretManagerTestCaseCustom(keyNotFound),
  735. makeValidSecretManagerTestCaseCustom(importKeyFailed),
  736. makeValidSecretManagerTestCaseCustom(noTags),
  737. makeValidSecretManagerTestCaseCustom(wrongTags),
  738. makeValidSecretManagerTestCaseCustom(secretSuccess),
  739. makeValidSecretManagerTestCaseCustom(secretNoChange),
  740. makeValidSecretManagerTestCaseCustom(secretWrongTags),
  741. makeValidSecretManagerTestCaseCustom(secretNoTags),
  742. makeValidSecretManagerTestCaseCustom(secretNotFound),
  743. makeValidSecretManagerTestCaseCustom(failedGetSecret),
  744. makeValidSecretManagerTestCaseCustom(failedNotParseableError),
  745. makeValidSecretManagerTestCaseCustom(failedSetSecret),
  746. makeValidSecretManagerTestCaseCustom(typeNotSupported),
  747. makeValidSecretManagerTestCaseCustom(wholeSecretNoKey),
  748. }
  749. sm := Azure{
  750. provider: &esv1beta1.AzureKVProvider{VaultURL: pointer.To(fakeURL)},
  751. }
  752. for k, v := range successCases {
  753. sm.baseClient = v.mockClient
  754. if v.secret == nil {
  755. v.secret = &corev1.Secret{
  756. Data: map[string][]byte{
  757. secretKey: v.setValue,
  758. },
  759. }
  760. }
  761. err := sm.PushSecret(context.Background(), v.secret, v.pushData)
  762. if !utils.ErrorContains(err, v.expectError) {
  763. if err == nil {
  764. t.Errorf("[%d] unexpected error: <nil>, expected: '%s'", k, v.expectError)
  765. } else {
  766. t.Errorf("[%d] unexpected error: %s, expected: '%s'", k, err.Error(), v.expectError)
  767. }
  768. }
  769. if len(v.expectedData) > 0 {
  770. sm.baseClient = v.mockClient
  771. out, err := sm.GetSecretMap(context.Background(), *v.ref)
  772. if !utils.ErrorContains(err, v.expectError) {
  773. t.Errorf("[%d] unexpected error: %s, expected: '%s'", k, err.Error(), v.expectError)
  774. }
  775. if err == nil && !reflect.DeepEqual(out, v.expectedData) {
  776. t.Errorf("[%d] unexpected secret data: expected %#v, got %#v", k, v.expectedData, out)
  777. }
  778. }
  779. }
  780. }
  781. // test the sm<->azurekv interface
  782. // make sure correct values are passed and errors are handled accordingly.
  783. func TestAzureKeyVaultSecretManagerGetSecret(t *testing.T) {
  784. secretString := "changedvalue"
  785. secretCertificate := "certificate_value"
  786. tagMap := getTagMap()
  787. // good case
  788. setSecretString := func(smtc *secretManagerTestCase) {
  789. smtc.expectedSecret = secretString
  790. smtc.secretOutput = keyvault.SecretBundle{
  791. Value: &secretString,
  792. }
  793. }
  794. // good case
  795. secretNotFound := func(smtc *secretManagerTestCase) {
  796. smtc.expectedSecret = ""
  797. smtc.apiErr = autorest.DetailedError{StatusCode: 404}
  798. smtc.expectError = esv1beta1.NoSecretError{}.Error()
  799. }
  800. certNotFound := func(smtc *secretManagerTestCase) {
  801. smtc.expectedSecret = ""
  802. smtc.secretName = certName
  803. smtc.apiErr = autorest.DetailedError{StatusCode: 404}
  804. smtc.expectError = esv1beta1.NoSecretError{}.Error()
  805. }
  806. keyNotFound := func(smtc *secretManagerTestCase) {
  807. smtc.expectedSecret = ""
  808. smtc.secretName = keyName
  809. smtc.apiErr = autorest.DetailedError{StatusCode: 404}
  810. smtc.expectError = esv1beta1.NoSecretError{}.Error()
  811. }
  812. setSecretStringWithVersion := func(smtc *secretManagerTestCase) {
  813. smtc.expectedSecret = secretString
  814. smtc.secretOutput = keyvault.SecretBundle{
  815. Value: &secretString,
  816. }
  817. smtc.ref.Version = "v1"
  818. smtc.secretVersion = smtc.ref.Version
  819. }
  820. setSecretWithProperty := func(smtc *secretManagerTestCase) {
  821. jsonString := jsonTestString
  822. smtc.expectedSecret = "External"
  823. smtc.secretOutput = keyvault.SecretBundle{
  824. Value: &jsonString,
  825. }
  826. smtc.ref.Property = "Name"
  827. }
  828. badSecretWithProperty := func(smtc *secretManagerTestCase) {
  829. jsonString := jsonTestString
  830. smtc.expectedSecret = ""
  831. smtc.secretOutput = keyvault.SecretBundle{
  832. Value: &jsonString,
  833. }
  834. smtc.ref.Property = "Age"
  835. smtc.expectError = fmt.Sprintf("property %s does not exist in key %s", smtc.ref.Property, smtc.ref.Key)
  836. smtc.apiErr = errors.New(smtc.expectError)
  837. }
  838. // // good case: key set
  839. setPubRSAKey := func(smtc *secretManagerTestCase) {
  840. smtc.secretName = keyName
  841. smtc.expectedSecret = jwkPubRSA
  842. smtc.keyOutput = keyvault.KeyBundle{
  843. Key: newKVJWK([]byte(jwkPubRSA)),
  844. }
  845. smtc.ref.Key = smtc.secretName
  846. }
  847. // // good case: key set
  848. setPubECKey := func(smtc *secretManagerTestCase) {
  849. smtc.secretName = keyName
  850. smtc.expectedSecret = jwkPubEC
  851. smtc.keyOutput = keyvault.KeyBundle{
  852. Key: newKVJWK([]byte(jwkPubEC)),
  853. }
  854. smtc.ref.Key = smtc.secretName
  855. }
  856. // // good case: key set
  857. setCertificate := func(smtc *secretManagerTestCase) {
  858. byteArrString := []byte(secretCertificate)
  859. smtc.secretName = certName
  860. smtc.expectedSecret = secretCertificate
  861. smtc.certOutput = keyvault.CertificateBundle{
  862. Cer: &byteArrString,
  863. }
  864. smtc.ref.Key = smtc.secretName
  865. }
  866. badSecretType := func(smtc *secretManagerTestCase) {
  867. smtc.secretName = "name"
  868. smtc.expectedSecret = ""
  869. smtc.expectError = fmt.Sprintf("unknown Azure Keyvault object Type for %s", smtc.secretName)
  870. smtc.ref.Key = fmt.Sprintf("example/%s", smtc.secretName)
  871. }
  872. setSecretWithTag := func(smtc *secretManagerTestCase) {
  873. smtc.ref.MetadataPolicy = esv1beta1.ExternalSecretMetadataPolicyFetch
  874. smtc.ref.Property = tagname
  875. smtc.secretOutput = keyvault.SecretBundle{
  876. Value: &secretString, Tags: tagMap,
  877. }
  878. smtc.expectedSecret = tagvalue
  879. }
  880. badSecretWithTag := func(smtc *secretManagerTestCase) {
  881. smtc.ref.MetadataPolicy = esv1beta1.ExternalSecretMetadataPolicyFetch
  882. smtc.ref.Property = something
  883. smtc.expectedSecret = ""
  884. smtc.expectError = errorNoTag
  885. smtc.apiErr = errors.New(smtc.expectError)
  886. }
  887. setSecretWithNoSpecificTag := func(smtc *secretManagerTestCase) {
  888. smtc.ref.MetadataPolicy = esv1beta1.ExternalSecretMetadataPolicyFetch
  889. smtc.secretOutput = keyvault.SecretBundle{
  890. Value: &secretString, Tags: tagMap,
  891. }
  892. smtc.expectedSecret = jsonTagTestString
  893. }
  894. setSecretWithNoTags := func(smtc *secretManagerTestCase) {
  895. smtc.ref.MetadataPolicy = esv1beta1.ExternalSecretMetadataPolicyFetch
  896. smtc.secretOutput = keyvault.SecretBundle{}
  897. smtc.expectedSecret = "{}"
  898. }
  899. setCertWithTag := func(smtc *secretManagerTestCase) {
  900. byteArrString := []byte(secretCertificate)
  901. smtc.secretName = certName
  902. smtc.certOutput = keyvault.CertificateBundle{
  903. Cer: &byteArrString, Tags: tagMap,
  904. }
  905. smtc.ref.MetadataPolicy = esv1beta1.ExternalSecretMetadataPolicyFetch
  906. smtc.ref.Property = tagname
  907. smtc.expectedSecret = tagvalue
  908. smtc.ref.Key = smtc.secretName
  909. }
  910. badCertWithTag := func(smtc *secretManagerTestCase) {
  911. byteArrString := []byte(secretCertificate)
  912. smtc.secretName = certName
  913. smtc.ref.Key = smtc.secretName
  914. smtc.certOutput = keyvault.CertificateBundle{
  915. Cer: &byteArrString,
  916. }
  917. smtc.ref.MetadataPolicy = esv1beta1.ExternalSecretMetadataPolicyFetch
  918. smtc.ref.Property = something
  919. smtc.expectedSecret = ""
  920. smtc.expectError = errorNoTag
  921. smtc.apiErr = errors.New(smtc.expectError)
  922. }
  923. setCertWithNoSpecificTag := func(smtc *secretManagerTestCase) {
  924. byteArrString := []byte(secretCertificate)
  925. smtc.secretName = certName
  926. smtc.ref.Key = smtc.secretName
  927. smtc.certOutput = keyvault.CertificateBundle{
  928. Cer: &byteArrString, Tags: tagMap,
  929. }
  930. smtc.ref.MetadataPolicy = esv1beta1.ExternalSecretMetadataPolicyFetch
  931. smtc.expectedSecret = jsonTagTestString
  932. }
  933. setCertWithNoTags := func(smtc *secretManagerTestCase) {
  934. byteArrString := []byte(secretCertificate)
  935. smtc.secretName = certName
  936. smtc.ref.Key = smtc.secretName
  937. smtc.certOutput = keyvault.CertificateBundle{
  938. Cer: &byteArrString,
  939. }
  940. smtc.ref.MetadataPolicy = esv1beta1.ExternalSecretMetadataPolicyFetch
  941. smtc.expectedSecret = "{}"
  942. }
  943. setKeyWithTag := func(smtc *secretManagerTestCase) {
  944. smtc.secretName = keyName
  945. smtc.keyOutput = keyvault.KeyBundle{
  946. Key: newKVJWK([]byte(jwkPubRSA)), Tags: tagMap,
  947. }
  948. smtc.ref.MetadataPolicy = esv1beta1.ExternalSecretMetadataPolicyFetch
  949. smtc.ref.Property = tagname
  950. smtc.expectedSecret = tagvalue
  951. smtc.ref.Key = smtc.secretName
  952. }
  953. badKeyWithTag := func(smtc *secretManagerTestCase) {
  954. smtc.secretName = keyName
  955. smtc.ref.Key = smtc.secretName
  956. smtc.keyOutput = keyvault.KeyBundle{
  957. Key: newKVJWK([]byte(jwkPubRSA)), Tags: tagMap,
  958. }
  959. smtc.ref.MetadataPolicy = esv1beta1.ExternalSecretMetadataPolicyFetch
  960. smtc.ref.Property = something
  961. smtc.expectedSecret = ""
  962. smtc.expectError = errorNoTag
  963. smtc.apiErr = errors.New(smtc.expectError)
  964. }
  965. setKeyWithNoSpecificTag := func(smtc *secretManagerTestCase) {
  966. smtc.secretName = keyName
  967. smtc.ref.Key = smtc.secretName
  968. smtc.keyOutput = keyvault.KeyBundle{
  969. Key: newKVJWK([]byte(jwkPubRSA)), Tags: tagMap,
  970. }
  971. smtc.ref.MetadataPolicy = esv1beta1.ExternalSecretMetadataPolicyFetch
  972. smtc.expectedSecret = jsonTagTestString
  973. }
  974. setKeyWithNoTags := func(smtc *secretManagerTestCase) {
  975. smtc.secretName = keyName
  976. smtc.ref.Key = smtc.secretName
  977. smtc.keyOutput = keyvault.KeyBundle{
  978. Key: newKVJWK([]byte(jwkPubRSA)),
  979. }
  980. smtc.ref.MetadataPolicy = esv1beta1.ExternalSecretMetadataPolicyFetch
  981. smtc.expectedSecret = "{}"
  982. }
  983. badPropertyTag := func(smtc *secretManagerTestCase) {
  984. smtc.ref.Property = tagname
  985. smtc.expectedSecret = ""
  986. smtc.expectError = "property tagname does not exist in key test-secret"
  987. smtc.apiErr = errors.New(smtc.expectError)
  988. }
  989. fetchSingleTag := func(smtc *secretManagerTestCase) {
  990. jsonString := jsonTestString
  991. smtc.expectedSecret = bar
  992. smtc.ref.MetadataPolicy = esv1beta1.ExternalSecretMetadataPolicyFetch
  993. secretTags := map[string]*string{}
  994. tagValue := bar
  995. secretTags[foo] = &tagValue
  996. smtc.secretOutput = keyvault.SecretBundle{
  997. Value: &jsonString,
  998. Tags: secretTags,
  999. }
  1000. smtc.ref.Property = foo
  1001. }
  1002. fetchJSONTag := func(smtc *secretManagerTestCase) {
  1003. jsonString := jsonTestString
  1004. smtc.ref.MetadataPolicy = esv1beta1.ExternalSecretMetadataPolicyFetch
  1005. secretTags := map[string]*string{}
  1006. tagValue := "{\"key\":\"value\"}"
  1007. secretTags[foo] = &tagValue
  1008. smtc.secretOutput = keyvault.SecretBundle{
  1009. Value: &jsonString,
  1010. Tags: secretTags,
  1011. }
  1012. smtc.ref.Property = foo
  1013. smtc.expectedSecret = tagValue
  1014. }
  1015. fetchDottedJSONTag := func(smtc *secretManagerTestCase) {
  1016. jsonString := jsonTestString
  1017. smtc.ref.MetadataPolicy = esv1beta1.ExternalSecretMetadataPolicyFetch
  1018. secretTags := map[string]*string{}
  1019. tagValue := "{\"key\":\"value\"}"
  1020. secretTags[foo] = &tagValue
  1021. smtc.secretOutput = keyvault.SecretBundle{
  1022. Value: &jsonString,
  1023. Tags: secretTags,
  1024. }
  1025. smtc.ref.Property = "foo.key"
  1026. smtc.expectedSecret = "value"
  1027. }
  1028. fetchNestedJSONTag := func(smtc *secretManagerTestCase) {
  1029. jsonString := jsonTestString
  1030. smtc.ref.MetadataPolicy = esv1beta1.ExternalSecretMetadataPolicyFetch
  1031. secretTags := map[string]*string{}
  1032. tagValue := "{\"key\":\"value\", \"nested\": {\"foo\":\"bar\"}}"
  1033. secretTags["foo"] = &tagValue
  1034. smtc.secretOutput = keyvault.SecretBundle{
  1035. Value: &jsonString,
  1036. Tags: secretTags,
  1037. }
  1038. smtc.ref.Property = "foo.nested"
  1039. smtc.expectedSecret = "{\"foo\":\"bar\"}"
  1040. }
  1041. fetchNestedDottedJSONTag := func(smtc *secretManagerTestCase) {
  1042. jsonString := jsonTestString
  1043. smtc.ref.MetadataPolicy = esv1beta1.ExternalSecretMetadataPolicyFetch
  1044. secretTags := map[string]*string{}
  1045. tagValue := "{\"key\":\"value\", \"nested\": {\"foo\":\"bar\"}}"
  1046. secretTags[foo] = &tagValue
  1047. smtc.secretOutput = keyvault.SecretBundle{
  1048. Value: &jsonString,
  1049. Tags: secretTags,
  1050. }
  1051. smtc.ref.Property = "foo.nested.foo"
  1052. smtc.expectedSecret = bar
  1053. }
  1054. fetchDottedKeyJSONTag := func(smtc *secretManagerTestCase) {
  1055. jsonString := jsonTestString
  1056. smtc.ref.MetadataPolicy = esv1beta1.ExternalSecretMetadataPolicyFetch
  1057. secretTags := map[string]*string{}
  1058. tagValue := "{\"foo.json\":\"bar\"}"
  1059. secretTags[foo] = &tagValue
  1060. smtc.secretOutput = keyvault.SecretBundle{
  1061. Value: &jsonString,
  1062. Tags: secretTags,
  1063. }
  1064. smtc.ref.Property = "foo.foo.json"
  1065. smtc.expectedSecret = bar
  1066. }
  1067. fetchDottedSecretJSONTag := func(smtc *secretManagerTestCase) {
  1068. jsonString := "{\"foo.json\":\"bar\"}"
  1069. smtc.secretOutput = keyvault.SecretBundle{
  1070. Value: &jsonString,
  1071. }
  1072. smtc.ref.Property = "foo.json"
  1073. smtc.expectedSecret = bar
  1074. }
  1075. successCases := []*secretManagerTestCase{
  1076. makeValidSecretManagerTestCase(),
  1077. makeValidSecretManagerTestCaseCustom(setSecretString),
  1078. makeValidSecretManagerTestCaseCustom(setSecretStringWithVersion),
  1079. makeValidSecretManagerTestCaseCustom(setSecretWithProperty),
  1080. makeValidSecretManagerTestCaseCustom(badSecretWithProperty),
  1081. makeValidSecretManagerTestCaseCustom(setPubRSAKey),
  1082. makeValidSecretManagerTestCaseCustom(setPubECKey),
  1083. makeValidSecretManagerTestCaseCustom(secretNotFound),
  1084. makeValidSecretManagerTestCaseCustom(certNotFound),
  1085. makeValidSecretManagerTestCaseCustom(keyNotFound),
  1086. makeValidSecretManagerTestCaseCustom(setCertificate),
  1087. makeValidSecretManagerTestCaseCustom(badSecretType),
  1088. makeValidSecretManagerTestCaseCustom(setSecretWithTag),
  1089. makeValidSecretManagerTestCaseCustom(badSecretWithTag),
  1090. makeValidSecretManagerTestCaseCustom(setSecretWithNoSpecificTag),
  1091. makeValidSecretManagerTestCaseCustom(setSecretWithNoTags),
  1092. makeValidSecretManagerTestCaseCustom(setCertWithTag),
  1093. makeValidSecretManagerTestCaseCustom(badCertWithTag),
  1094. makeValidSecretManagerTestCaseCustom(setCertWithNoSpecificTag),
  1095. makeValidSecretManagerTestCaseCustom(setCertWithNoTags),
  1096. makeValidSecretManagerTestCaseCustom(setKeyWithTag),
  1097. makeValidSecretManagerTestCaseCustom(badKeyWithTag),
  1098. makeValidSecretManagerTestCaseCustom(setKeyWithNoSpecificTag),
  1099. makeValidSecretManagerTestCaseCustom(setKeyWithNoTags),
  1100. makeValidSecretManagerTestCaseCustom(badPropertyTag),
  1101. makeValidSecretManagerTestCaseCustom(fetchSingleTag),
  1102. makeValidSecretManagerTestCaseCustom(fetchJSONTag),
  1103. makeValidSecretManagerTestCaseCustom(fetchDottedJSONTag),
  1104. makeValidSecretManagerTestCaseCustom(fetchNestedJSONTag),
  1105. makeValidSecretManagerTestCaseCustom(fetchNestedDottedJSONTag),
  1106. makeValidSecretManagerTestCaseCustom(fetchDottedKeyJSONTag),
  1107. makeValidSecretManagerTestCaseCustom(fetchDottedSecretJSONTag),
  1108. }
  1109. sm := Azure{
  1110. provider: &esv1beta1.AzureKVProvider{VaultURL: pointer.To(fakeURL)},
  1111. }
  1112. for k, v := range successCases {
  1113. sm.baseClient = v.mockClient
  1114. out, err := sm.GetSecret(context.Background(), *v.ref)
  1115. if !utils.ErrorContains(err, v.expectError) {
  1116. t.Errorf("[%d] unexpected error: %s, expected: '%s'", k, err.Error(), v.expectError)
  1117. }
  1118. if string(out) != v.expectedSecret {
  1119. t.Errorf("[%d] unexpected secret: expected %s, got %s", k, v.expectedSecret, string(out))
  1120. }
  1121. }
  1122. }
  1123. func TestAzureKeyVaultSecretManagerGetSecretMap(t *testing.T) {
  1124. secretString := "changedvalue"
  1125. secretCertificate := "certificate_value"
  1126. tagMap := getTagMap()
  1127. badSecretString := func(smtc *secretManagerTestCase) {
  1128. smtc.expectedSecret = secretString
  1129. smtc.secretOutput = keyvault.SecretBundle{
  1130. Value: &secretString,
  1131. }
  1132. smtc.expectError = "error unmarshalling json data: invalid character 'c' looking for beginning of value"
  1133. }
  1134. setSecretJSON := func(smtc *secretManagerTestCase) {
  1135. jsonString := jsonSingleTestString
  1136. smtc.secretOutput = keyvault.SecretBundle{
  1137. Value: &jsonString,
  1138. }
  1139. smtc.expectedData["Name"] = []byte("External")
  1140. smtc.expectedData["LastName"] = []byte("Secret")
  1141. }
  1142. setSecretJSONWithProperty := func(smtc *secretManagerTestCase) {
  1143. jsonString := jsonTestString
  1144. smtc.secretOutput = keyvault.SecretBundle{
  1145. Value: &jsonString,
  1146. }
  1147. smtc.ref.Property = "Address"
  1148. smtc.expectedData["Street"] = []byte("Myroad st.")
  1149. smtc.expectedData["CP"] = []byte("J4K4T4")
  1150. }
  1151. badSecretWithProperty := func(smtc *secretManagerTestCase) {
  1152. jsonString := jsonTestString
  1153. smtc.expectedSecret = ""
  1154. smtc.secretOutput = keyvault.SecretBundle{
  1155. Value: &jsonString,
  1156. }
  1157. smtc.ref.Property = "Age"
  1158. smtc.expectError = fmt.Sprintf("property %s does not exist in key %s", smtc.ref.Property, smtc.ref.Key)
  1159. smtc.apiErr = errors.New(smtc.expectError)
  1160. }
  1161. badPubRSAKey := func(smtc *secretManagerTestCase) {
  1162. smtc.secretName = keyName
  1163. smtc.expectedSecret = jwkPubRSA
  1164. smtc.keyOutput = keyvault.KeyBundle{
  1165. Key: newKVJWK([]byte(jwkPubRSA)),
  1166. }
  1167. smtc.ref.Key = smtc.secretName
  1168. smtc.expectError = "cannot get use dataFrom to get key secret"
  1169. }
  1170. badCertificate := func(smtc *secretManagerTestCase) {
  1171. byteArrString := []byte(secretCertificate)
  1172. smtc.secretName = certName
  1173. smtc.expectedSecret = secretCertificate
  1174. smtc.certOutput = keyvault.CertificateBundle{
  1175. Cer: &byteArrString,
  1176. }
  1177. smtc.ref.Key = smtc.secretName
  1178. smtc.expectError = "cannot get use dataFrom to get certificate secret"
  1179. }
  1180. badSecretType := func(smtc *secretManagerTestCase) {
  1181. smtc.secretName = "name"
  1182. smtc.expectedSecret = ""
  1183. smtc.expectError = fmt.Sprintf("unknown Azure Keyvault object Type for %s", smtc.secretName)
  1184. smtc.ref.Key = fmt.Sprintf("example/%s", smtc.secretName)
  1185. }
  1186. setSecretTags := func(smtc *secretManagerTestCase) {
  1187. smtc.ref.MetadataPolicy = esv1beta1.ExternalSecretMetadataPolicyFetch
  1188. smtc.secretOutput = keyvault.SecretBundle{
  1189. Tags: tagMap,
  1190. }
  1191. smtc.expectedData[testsecret+"_"+tagname] = []byte(tagvalue)
  1192. smtc.expectedData[testsecret+"_"+tagname2] = []byte(tagvalue2)
  1193. }
  1194. setSecretWithJSONTag := func(smtc *secretManagerTestCase) {
  1195. tagJSONMap := make(map[string]*string)
  1196. tagJSONData := `{"keyname":"keyvalue","x":"y"}`
  1197. tagJSONMap["json"] = &tagJSONData
  1198. smtc.ref.MetadataPolicy = esv1beta1.ExternalSecretMetadataPolicyFetch
  1199. smtc.secretOutput = keyvault.SecretBundle{
  1200. Value: &secretString, Tags: tagJSONMap,
  1201. }
  1202. smtc.expectedData[testsecret+"_json_keyname"] = []byte("keyvalue")
  1203. smtc.expectedData[testsecret+"_json_x"] = []byte("y")
  1204. }
  1205. setSecretWithNoTags := func(smtc *secretManagerTestCase) {
  1206. smtc.ref.MetadataPolicy = esv1beta1.ExternalSecretMetadataPolicyFetch
  1207. tagMapTestEmpty := make(map[string]*string)
  1208. smtc.secretOutput = keyvault.SecretBundle{
  1209. Tags: tagMapTestEmpty,
  1210. }
  1211. smtc.expectedSecret = ""
  1212. }
  1213. nestedJSONNoProperty := func(smtc *secretManagerTestCase) {
  1214. jsonString := jsonTestString
  1215. smtc.expectedSecret = ""
  1216. smtc.secretOutput = keyvault.SecretBundle{
  1217. Value: &jsonString,
  1218. }
  1219. smtc.ref.Property = ""
  1220. smtc.expectedData["Name"] = []byte("External")
  1221. smtc.expectedData["LastName"] = []byte("Secret")
  1222. smtc.expectedData["Address"] = []byte(`{ "Street": "Myroad st.", "CP": "J4K4T4" }`)
  1223. }
  1224. setNestedJSONTag := func(smtc *secretManagerTestCase) {
  1225. secretTags := map[string]*string{}
  1226. tagValue := `{"foo":"bar","nested.tag":{"foo":"bar"}}`
  1227. bug := "1137"
  1228. secretTags["dev"] = &tagValue
  1229. secretTags["bug"] = &bug
  1230. smtc.ref.MetadataPolicy = esv1beta1.ExternalSecretMetadataPolicyFetch
  1231. smtc.secretOutput = keyvault.SecretBundle{
  1232. Tags: secretTags,
  1233. }
  1234. smtc.ref.Property = "dev"
  1235. smtc.expectedData[testsecret+"_dev"] = []byte(tagValue)
  1236. }
  1237. successCases := []*secretManagerTestCase{
  1238. makeValidSecretManagerTestCaseCustom(badSecretString),
  1239. makeValidSecretManagerTestCaseCustom(setSecretJSON),
  1240. makeValidSecretManagerTestCaseCustom(setSecretJSONWithProperty),
  1241. makeValidSecretManagerTestCaseCustom(badSecretWithProperty),
  1242. makeValidSecretManagerTestCaseCustom(badPubRSAKey),
  1243. makeValidSecretManagerTestCaseCustom(badCertificate),
  1244. makeValidSecretManagerTestCaseCustom(badSecretType),
  1245. makeValidSecretManagerTestCaseCustom(setSecretTags),
  1246. makeValidSecretManagerTestCaseCustom(setSecretWithJSONTag),
  1247. makeValidSecretManagerTestCaseCustom(setSecretWithNoTags),
  1248. makeValidSecretManagerTestCaseCustom(nestedJSONNoProperty),
  1249. makeValidSecretManagerTestCaseCustom(setNestedJSONTag),
  1250. }
  1251. sm := Azure{
  1252. provider: &esv1beta1.AzureKVProvider{VaultURL: pointer.To(fakeURL)},
  1253. }
  1254. for k, v := range successCases {
  1255. sm.baseClient = v.mockClient
  1256. out, err := sm.GetSecretMap(context.Background(), *v.ref)
  1257. if !utils.ErrorContains(err, v.expectError) {
  1258. t.Errorf("[%d] unexpected error: %s, expected: '%s'", k, err.Error(), v.expectError)
  1259. }
  1260. if err == nil && !reflect.DeepEqual(out, v.expectedData) {
  1261. t.Errorf("[%d] unexpected secret data: expected %#v, got %#v", k, v.expectedData, out)
  1262. }
  1263. }
  1264. }
  1265. func TestAzureKeyVaultSecretManagerGetAllSecrets(t *testing.T) {
  1266. secretString := secretString
  1267. secretName := secretName
  1268. wrongName := "not-valid"
  1269. environment := "dev"
  1270. author := "seb"
  1271. enabled := true
  1272. getNextPage := func(ctx context.Context, list keyvault.SecretListResult) (result keyvault.SecretListResult, err error) {
  1273. return keyvault.SecretListResult{
  1274. Value: nil,
  1275. NextLink: nil,
  1276. }, nil
  1277. }
  1278. setOneSecretByName := func(smtc *secretManagerTestCase) {
  1279. enabledAtt := keyvault.SecretAttributes{
  1280. Enabled: &enabled,
  1281. }
  1282. secretItem := keyvault.SecretItem{
  1283. ID: &secretName,
  1284. Attributes: &enabledAtt,
  1285. }
  1286. secretList := make([]keyvault.SecretItem, 0)
  1287. secretList = append(secretList, secretItem)
  1288. list := keyvault.SecretListResult{
  1289. Value: &secretList,
  1290. }
  1291. resultPage := keyvault.NewSecretListResultPage(list, getNextPage)
  1292. smtc.listOutput = keyvault.NewSecretListResultIterator(resultPage)
  1293. smtc.expectedSecret = secretString
  1294. smtc.secretOutput = keyvault.SecretBundle{
  1295. Value: &secretString,
  1296. }
  1297. smtc.expectedData[secretName] = []byte(secretString)
  1298. }
  1299. setTwoSecretsByName := func(smtc *secretManagerTestCase) {
  1300. enabledAtt := keyvault.SecretAttributes{
  1301. Enabled: &enabled,
  1302. }
  1303. secretItemOne := keyvault.SecretItem{
  1304. ID: &secretName,
  1305. Attributes: &enabledAtt,
  1306. }
  1307. secretItemTwo := keyvault.SecretItem{
  1308. ID: &wrongName,
  1309. Attributes: &enabledAtt,
  1310. }
  1311. secretList := make([]keyvault.SecretItem, 1)
  1312. secretList = append(secretList, secretItemOne, secretItemTwo)
  1313. list := keyvault.SecretListResult{
  1314. Value: &secretList,
  1315. }
  1316. resultPage := keyvault.NewSecretListResultPage(list, getNextPage)
  1317. smtc.listOutput = keyvault.NewSecretListResultIterator(resultPage)
  1318. smtc.expectedSecret = secretString
  1319. smtc.secretOutput = keyvault.SecretBundle{
  1320. Value: &secretString,
  1321. }
  1322. smtc.expectedData[secretName] = []byte(secretString)
  1323. }
  1324. setOneSecretByTag := func(smtc *secretManagerTestCase) {
  1325. enabledAtt := keyvault.SecretAttributes{
  1326. Enabled: &enabled,
  1327. }
  1328. secretItem := keyvault.SecretItem{
  1329. ID: &secretName,
  1330. Attributes: &enabledAtt,
  1331. Tags: map[string]*string{"environment": &environment},
  1332. }
  1333. secretList := make([]keyvault.SecretItem, 0)
  1334. secretList = append(secretList, secretItem)
  1335. list := keyvault.SecretListResult{
  1336. Value: &secretList,
  1337. }
  1338. resultPage := keyvault.NewSecretListResultPage(list, getNextPage)
  1339. smtc.listOutput = keyvault.NewSecretListResultIterator(resultPage)
  1340. smtc.expectedSecret = secretString
  1341. smtc.secretOutput = keyvault.SecretBundle{
  1342. Value: &secretString,
  1343. }
  1344. smtc.refFind.Tags = map[string]string{"environment": environment}
  1345. smtc.expectedData[secretName] = []byte(secretString)
  1346. }
  1347. setTwoSecretsByTag := func(smtc *secretManagerTestCase) {
  1348. enabled := true
  1349. enabledAtt := keyvault.SecretAttributes{
  1350. Enabled: &enabled,
  1351. }
  1352. secretItem := keyvault.SecretItem{
  1353. ID: &secretName,
  1354. Attributes: &enabledAtt,
  1355. Tags: map[string]*string{"environment": &environment, "author": &author},
  1356. }
  1357. secretList := make([]keyvault.SecretItem, 0)
  1358. secretList = append(secretList, secretItem)
  1359. list := keyvault.SecretListResult{
  1360. Value: &secretList,
  1361. }
  1362. resultPage := keyvault.NewSecretListResultPage(list, getNextPage)
  1363. smtc.listOutput = keyvault.NewSecretListResultIterator(resultPage)
  1364. smtc.expectedSecret = secretString
  1365. smtc.secretOutput = keyvault.SecretBundle{
  1366. Value: &secretString,
  1367. }
  1368. smtc.refFind.Tags = map[string]string{"environment": environment, "author": author}
  1369. smtc.expectedData[secretName] = []byte(secretString)
  1370. }
  1371. successCases := []*secretManagerTestCase{
  1372. makeValidSecretManagerTestCaseCustom(setOneSecretByName),
  1373. makeValidSecretManagerTestCaseCustom(setTwoSecretsByName),
  1374. makeValidSecretManagerTestCaseCustom(setOneSecretByTag),
  1375. makeValidSecretManagerTestCaseCustom(setTwoSecretsByTag),
  1376. }
  1377. sm := Azure{
  1378. provider: &esv1beta1.AzureKVProvider{VaultURL: pointer.To(fakeURL)},
  1379. }
  1380. for k, v := range successCases {
  1381. sm.baseClient = v.mockClient
  1382. out, err := sm.GetAllSecrets(context.Background(), *v.refFind)
  1383. if !utils.ErrorContains(err, v.expectError) {
  1384. t.Errorf(unexpectedError, k, err.Error(), v.expectError)
  1385. }
  1386. if err == nil && !reflect.DeepEqual(out, v.expectedData) {
  1387. t.Errorf(unexpectedSecretData, k, v.expectedData, out)
  1388. }
  1389. }
  1390. }
  1391. func makeValidRef() *esv1beta1.ExternalSecretDataRemoteRef {
  1392. return &esv1beta1.ExternalSecretDataRemoteRef{
  1393. Key: "test-secret",
  1394. Version: "default",
  1395. Property: "",
  1396. }
  1397. }
  1398. func makeValidFind() *esv1beta1.ExternalSecretFind {
  1399. return &esv1beta1.ExternalSecretFind{
  1400. Name: &esv1beta1.FindName{
  1401. RegExp: "^example",
  1402. },
  1403. Tags: map[string]string{},
  1404. }
  1405. }
  1406. func TestValidateStore(t *testing.T) {
  1407. type args struct {
  1408. store *esv1beta1.SecretStore
  1409. }
  1410. tests := []struct {
  1411. name string
  1412. args args
  1413. wantErr bool
  1414. }{
  1415. {
  1416. name: "storeIsNil",
  1417. wantErr: true,
  1418. },
  1419. {
  1420. name: "specIsNil",
  1421. wantErr: true,
  1422. args: args{
  1423. store: &esv1beta1.SecretStore{},
  1424. },
  1425. },
  1426. {
  1427. name: "providerIsNil",
  1428. wantErr: true,
  1429. args: args{
  1430. store: &esv1beta1.SecretStore{
  1431. Spec: esv1beta1.SecretStoreSpec{},
  1432. },
  1433. },
  1434. },
  1435. {
  1436. name: "azureKVIsNil",
  1437. wantErr: true,
  1438. args: args{
  1439. store: &esv1beta1.SecretStore{
  1440. Spec: esv1beta1.SecretStoreSpec{
  1441. Provider: &esv1beta1.SecretStoreProvider{},
  1442. },
  1443. },
  1444. },
  1445. },
  1446. {
  1447. name: "empty auth",
  1448. wantErr: false,
  1449. args: args{
  1450. store: &esv1beta1.SecretStore{
  1451. Spec: esv1beta1.SecretStoreSpec{
  1452. Provider: &esv1beta1.SecretStoreProvider{
  1453. AzureKV: &esv1beta1.AzureKVProvider{},
  1454. },
  1455. },
  1456. },
  1457. },
  1458. },
  1459. {
  1460. name: "empty client id",
  1461. wantErr: false,
  1462. args: args{
  1463. store: &esv1beta1.SecretStore{
  1464. Spec: esv1beta1.SecretStoreSpec{
  1465. Provider: &esv1beta1.SecretStoreProvider{
  1466. AzureKV: &esv1beta1.AzureKVProvider{
  1467. AuthSecretRef: &esv1beta1.AzureKVAuth{},
  1468. },
  1469. },
  1470. },
  1471. },
  1472. },
  1473. },
  1474. {
  1475. name: "invalid client id",
  1476. wantErr: true,
  1477. args: args{
  1478. store: &esv1beta1.SecretStore{
  1479. Spec: esv1beta1.SecretStoreSpec{
  1480. Provider: &esv1beta1.SecretStoreProvider{
  1481. AzureKV: &esv1beta1.AzureKVProvider{
  1482. AuthSecretRef: &esv1beta1.AzureKVAuth{
  1483. ClientID: &v1.SecretKeySelector{
  1484. Namespace: pointer.To("invalid"),
  1485. },
  1486. },
  1487. },
  1488. },
  1489. },
  1490. },
  1491. },
  1492. },
  1493. {
  1494. name: "invalid client secret",
  1495. wantErr: true,
  1496. args: args{
  1497. store: &esv1beta1.SecretStore{
  1498. Spec: esv1beta1.SecretStoreSpec{
  1499. Provider: &esv1beta1.SecretStoreProvider{
  1500. AzureKV: &esv1beta1.AzureKVProvider{
  1501. AuthSecretRef: &esv1beta1.AzureKVAuth{
  1502. ClientSecret: &v1.SecretKeySelector{
  1503. Namespace: pointer.To("invalid"),
  1504. },
  1505. },
  1506. },
  1507. },
  1508. },
  1509. },
  1510. },
  1511. },
  1512. }
  1513. for _, tt := range tests {
  1514. t.Run(tt.name, func(t *testing.T) {
  1515. a := &Azure{}
  1516. if tt.name == "storeIsNil" {
  1517. if _, err := a.ValidateStore(nil); (err != nil) != tt.wantErr {
  1518. t.Errorf(errStore, err, tt.wantErr)
  1519. }
  1520. } else if _, err := a.ValidateStore(tt.args.store); (err != nil) != tt.wantErr {
  1521. t.Errorf(errStore, err, tt.wantErr)
  1522. }
  1523. })
  1524. }
  1525. }
  1526. func TestAzureKeyVaultSecretExists(t *testing.T) {
  1527. unsupportedType := func(smtc *secretManagerTestCase) {
  1528. smtc.pushData = testingfake.PushSecretData{
  1529. RemoteKey: "yadayada/foo",
  1530. }
  1531. smtc.expectError = "secret type 'yadayada' is not supported"
  1532. }
  1533. secretFound := func(smtc *secretManagerTestCase) {
  1534. smtc.pushData = testingfake.PushSecretData{
  1535. RemoteKey: secretName,
  1536. }
  1537. smtc.secretOutput = keyvault.SecretBundle{
  1538. Tags: map[string]*string{
  1539. "managed-by": pointer.To("external-secrets"),
  1540. },
  1541. Value: pointer.To("foo"),
  1542. }
  1543. smtc.expectedExistence = true
  1544. }
  1545. secretFoundNoUsefulTags := func(smtc *secretManagerTestCase) {
  1546. smtc.pushData = testingfake.PushSecretData{
  1547. RemoteKey: secretName,
  1548. }
  1549. smtc.secretOutput = keyvault.SecretBundle{
  1550. Tags: map[string]*string{
  1551. "someTag": pointer.To("someUselessValue"),
  1552. },
  1553. Value: pointer.To("foo"),
  1554. }
  1555. smtc.expectedExistence = true
  1556. }
  1557. secretNotFound := func(smtc *secretManagerTestCase) {
  1558. smtc.pushData = testingfake.PushSecretData{
  1559. RemoteKey: secretName,
  1560. }
  1561. smtc.apiErr = autorest.DetailedError{StatusCode: 404, Method: "GET", Message: "Not Found"}
  1562. smtc.expectedExistence = false
  1563. }
  1564. testCases := []*secretManagerTestCase{
  1565. makeValidSecretManagerTestCaseCustom(unsupportedType),
  1566. makeValidSecretManagerTestCaseCustom(secretFound),
  1567. makeValidSecretManagerTestCaseCustom(secretFoundNoUsefulTags),
  1568. makeValidSecretManagerTestCaseCustom(secretNotFound),
  1569. }
  1570. sm := Azure{
  1571. provider: &esv1beta1.AzureKVProvider{VaultURL: pointer.To(fakeURL)},
  1572. }
  1573. for k, tc := range testCases {
  1574. sm.baseClient = tc.mockClient
  1575. exists, err := sm.SecretExists(context.Background(), tc.pushData)
  1576. if !utils.ErrorContains(err, tc.expectError) {
  1577. if err == nil {
  1578. t.Errorf("[%d] unexpected error: <nil>, expected: '%s'", k, tc.expectError)
  1579. } else {
  1580. t.Errorf("[%d] unexpected error: '%s', expected: '%s'", k, err.Error(), tc.expectError)
  1581. }
  1582. }
  1583. if exists != tc.expectedExistence {
  1584. t.Errorf("[%d] unexpected existence result: expected %t, got %t", k, tc.expectedExistence, exists)
  1585. }
  1586. }
  1587. }