provider_test.go 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705
  1. /*
  2. Copyright © The ESO Authors
  3. Licensed under the Apache License, Version 2.0 (the "License");
  4. you may not use this file except in compliance with the License.
  5. You may obtain a copy of the License at
  6. https://www.apache.org/licenses/LICENSE-2.0
  7. Unless required by applicable law or agreed to in writing, software
  8. distributed under the License is distributed on an "AS IS" BASIS,
  9. WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  10. See the License for the specific language governing permissions and
  11. limitations under the License.
  12. */
  13. package secretserver
  14. import (
  15. "context"
  16. "math/rand"
  17. "testing"
  18. "github.com/DelineaXPM/tss-sdk-go/v3/server"
  19. "github.com/stretchr/testify/assert"
  20. corev1 "k8s.io/api/core/v1"
  21. kubeErrors "k8s.io/apimachinery/pkg/api/errors"
  22. metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
  23. kubeClient "sigs.k8s.io/controller-runtime/pkg/client"
  24. clientfake "sigs.k8s.io/controller-runtime/pkg/client/fake"
  25. esv1 "github.com/external-secrets/external-secrets/apis/externalsecrets/v1"
  26. v1 "github.com/external-secrets/external-secrets/apis/meta/v1"
  27. )
  28. func TestDoesConfigDependOnNamespace(t *testing.T) {
  29. tests := map[string]struct {
  30. cfg esv1.SecretServerProvider
  31. want bool
  32. }{
  33. "true when Username references a secret without explicit namespace": {
  34. cfg: esv1.SecretServerProvider{
  35. Username: &esv1.SecretServerProviderRef{
  36. SecretRef: &v1.SecretKeySelector{Name: "foo"},
  37. },
  38. Password: &esv1.SecretServerProviderRef{SecretRef: nil},
  39. },
  40. want: true,
  41. },
  42. "true when password references a secret without explicit namespace": {
  43. cfg: esv1.SecretServerProvider{
  44. Username: &esv1.SecretServerProviderRef{SecretRef: nil},
  45. Password: &esv1.SecretServerProviderRef{
  46. SecretRef: &v1.SecretKeySelector{Name: "foo"},
  47. },
  48. },
  49. want: true,
  50. },
  51. "false when neither Username or Password reference a secret": {
  52. cfg: esv1.SecretServerProvider{
  53. Username: &esv1.SecretServerProviderRef{SecretRef: nil},
  54. Password: &esv1.SecretServerProviderRef{SecretRef: nil},
  55. },
  56. want: false,
  57. },
  58. }
  59. for name, tc := range tests {
  60. t.Run(name, func(t *testing.T) {
  61. got := doesConfigDependOnNamespace(&tc.cfg)
  62. assert.Equal(t, tc.want, got)
  63. })
  64. }
  65. }
  66. func TestValidateStore(t *testing.T) {
  67. validSecretRefUsingValue := makeSecretRefUsingValue("foo")
  68. ambiguousSecretRef := &esv1.SecretServerProviderRef{
  69. SecretRef: &v1.SecretKeySelector{Name: "foo"}, Value: "foo",
  70. }
  71. testURL := "https://example.com"
  72. tests := map[string]struct {
  73. cfg esv1.SecretServerProvider
  74. want error
  75. }{
  76. "invalid without username": {
  77. cfg: esv1.SecretServerProvider{
  78. Username: nil,
  79. Password: validSecretRefUsingValue,
  80. ServerURL: testURL,
  81. },
  82. want: errEmptyUserName,
  83. },
  84. "invalid without password": {
  85. cfg: esv1.SecretServerProvider{
  86. Username: validSecretRefUsingValue,
  87. Password: nil,
  88. ServerURL: testURL,
  89. },
  90. want: errEmptyPassword,
  91. },
  92. "invalid without serverURL": {
  93. cfg: esv1.SecretServerProvider{
  94. Username: validSecretRefUsingValue,
  95. Password: validSecretRefUsingValue,
  96. /*ServerURL: testURL,*/
  97. },
  98. want: errEmptyServerURL,
  99. },
  100. "invalid with ambiguous Username": {
  101. cfg: esv1.SecretServerProvider{
  102. Username: ambiguousSecretRef,
  103. Password: validSecretRefUsingValue,
  104. ServerURL: testURL,
  105. },
  106. want: errSecretRefAndValueConflict,
  107. },
  108. "invalid with ambiguous Password": {
  109. cfg: esv1.SecretServerProvider{
  110. Username: validSecretRefUsingValue,
  111. Password: ambiguousSecretRef,
  112. ServerURL: testURL,
  113. },
  114. want: errSecretRefAndValueConflict,
  115. },
  116. "invalid with invalid Username": {
  117. cfg: esv1.SecretServerProvider{
  118. Username: makeSecretRefUsingValue(""),
  119. Password: validSecretRefUsingValue,
  120. ServerURL: testURL,
  121. },
  122. want: errSecretRefAndValueMissing,
  123. },
  124. "invalid with invalid Password": {
  125. cfg: esv1.SecretServerProvider{
  126. Username: validSecretRefUsingValue,
  127. Password: makeSecretRefUsingValue(""),
  128. ServerURL: testURL,
  129. },
  130. want: errSecretRefAndValueMissing,
  131. },
  132. "valid with tenant/clientID/clientSecret": {
  133. cfg: esv1.SecretServerProvider{
  134. Username: validSecretRefUsingValue,
  135. Password: validSecretRefUsingValue,
  136. ServerURL: testURL,
  137. },
  138. want: nil,
  139. },
  140. }
  141. for name, tc := range tests {
  142. t.Run(name, func(t *testing.T) {
  143. s := esv1.SecretStore{
  144. Spec: esv1.SecretStoreSpec{
  145. Provider: &esv1.SecretStoreProvider{
  146. SecretServer: &tc.cfg,
  147. },
  148. },
  149. }
  150. p := &Provider{}
  151. _, got := p.ValidateStore(&s)
  152. assert.Equal(t, tc.want, got)
  153. })
  154. }
  155. }
  156. func TestNewClient(t *testing.T) {
  157. userNameKey := "username"
  158. userNameValue := "foo"
  159. passwordKey := passwordSlug
  160. passwordValue := generateRandomString()
  161. domain := "domain1"
  162. clientSecret := &corev1.Secret{
  163. ObjectMeta: metav1.ObjectMeta{Name: "foo", Namespace: "default"},
  164. Data: map[string][]byte{
  165. userNameKey: []byte(userNameValue),
  166. passwordKey: []byte(passwordValue),
  167. },
  168. }
  169. validProvider := &esv1.SecretServerProvider{
  170. Username: makeSecretRefUsingRef(clientSecret.Name, userNameKey),
  171. Password: makeSecretRefUsingRef(clientSecret.Name, passwordKey),
  172. ServerURL: "https://example.com",
  173. }
  174. clientSecretWithDomain := &corev1.Secret{
  175. ObjectMeta: metav1.ObjectMeta{Name: "with-domain", Namespace: "default"},
  176. Data: map[string][]byte{
  177. userNameKey: []byte(userNameValue),
  178. passwordKey: []byte(passwordValue),
  179. domain: []byte(domain),
  180. },
  181. }
  182. validProviderWithDomain := &esv1.SecretServerProvider{
  183. Username: makeSecretRefUsingRef(clientSecretWithDomain.Name, userNameKey),
  184. Password: makeSecretRefUsingRef(clientSecretWithDomain.Name, passwordKey),
  185. Domain: domain,
  186. ServerURL: "https://example.com",
  187. }
  188. // Valid test CA certificate
  189. testCABundle := []byte(`-----BEGIN CERTIFICATE-----
  190. MIIDHTCCAgWgAwIBAgIRAKC4yxy9QGocND+6avTf7BgwDQYJKoZIhvcNAQELBQAw
  191. EjEQMA4GA1UEChMHQWNtZSBDbzAeFw0yMTAzMjAyMDA4MDhaFw0yMTAzMjAyMDM4
  192. MDhaMBIxEDAOBgNVBAoTB0FjbWUgQ28wggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAw
  193. ggEKAoIBAQC3o6/JdZEqNbqNRkopHhJtJG5c4qS5d0tQ/kZYpfD/v/izAYum4Nzj
  194. aG15owr92/11W0pxPUliRLti3y6iScTs+ofm2D7p4UXj/Fnho/2xoWSOoWAodgvW
  195. Y8jh8A0LQALZiV/9QsrJdXZdS47DYZLsQ3z9yFC/CdXkg1l7AQ3fIVGKdrQBr9kE
  196. 1gEDqnKfRxXI8DEQKXr+CKPUwCAytegmy0SHp53zNAvY+kopHytzmJpXLoEhxq4e
  197. ugHe52vXHdh/HJ9VjNp0xOH1waAgAGxHlltCW0PVd5AJ0SXROBS/a3V9sZCbCrJa
  198. YOOonQSEswveSv6PcG9AHvpNPot2Xs6hAgMBAAGjbjBsMA4GA1UdDwEB/wQEAwIC
  199. pDATBgNVHSUEDDAKBggrBgEFBQcDATAPBgNVHRMBAf8EBTADAQH/MB0GA1UdDgQW
  200. BBR00805mrpoonp95RmC3B6oLl+cGTAVBgNVHREEDjAMggpnb29ibGUuY29tMA0G
  201. CSqGSIb3DQEBCwUAA4IBAQAipc1b6JrEDayPjpz5GM5krcI8dCWVd8re0a9bGjjN
  202. ioWGlu/eTr5El0ffwCNZ2WLmL9rewfHf/bMvYz3ioFZJ2OTxfazqYXNggQz6cMfa
  203. lbedDCdt5XLVX2TyerGvFram+9Uyvk3l0uM7rZnwAmdirG4Tv94QRaD3q4xTj/c0
  204. mv+AggtK0aRFb9o47z/BypLdk5mhbf3Mmr88C8XBzEnfdYyf4JpTlZrYLBmDCu5d
  205. 9RLLsjXxhag8xqMtd1uLUM8XOTGzVWacw8iGY+CTtBKqyA+AE6/bDwZvEwVtsKtC
  206. QJ85ioEpy00NioqcF0WyMZH80uMsPycfpnl5uF7RkW8u
  207. -----END CERTIFICATE-----`)
  208. caSecretName := "ca-secret"
  209. caSecretKey := "ca.crt"
  210. caSecret := &corev1.Secret{
  211. ObjectMeta: metav1.ObjectMeta{Name: caSecretName, Namespace: "default"},
  212. Data: map[string][]byte{
  213. caSecretKey: testCABundle,
  214. },
  215. }
  216. caConfigMapName := "ca-configmap"
  217. caConfigMapKey := "ca.crt"
  218. caConfigMap := &corev1.ConfigMap{
  219. ObjectMeta: metav1.ObjectMeta{Name: caConfigMapName, Namespace: "default"},
  220. Data: map[string]string{
  221. caConfigMapKey: string(testCABundle),
  222. },
  223. }
  224. tests := map[string]struct {
  225. store esv1.GenericStore // leave nil for namespaced store
  226. provider *esv1.SecretServerProvider // discarded when store is set
  227. kube kubeClient.Client
  228. errCheck func(t *testing.T, err error)
  229. }{
  230. "missing provider config": {
  231. provider: nil,
  232. errCheck: func(t *testing.T, err error) {
  233. assert.ErrorIs(t, err, errInvalidSpec)
  234. },
  235. },
  236. "namespace-dependent cluster secret store": {
  237. store: &esv1.ClusterSecretStore{
  238. TypeMeta: metav1.TypeMeta{Kind: esv1.ClusterSecretStoreKind},
  239. Spec: esv1.SecretStoreSpec{
  240. Provider: &esv1.SecretStoreProvider{
  241. SecretServer: validProvider,
  242. },
  243. },
  244. },
  245. errCheck: func(t *testing.T, err error) {
  246. assert.ErrorIs(t, err, errClusterStoreRequiresNamespace)
  247. },
  248. },
  249. "dangling password ref": {
  250. provider: &esv1.SecretServerProvider{
  251. Username: validProvider.Username,
  252. Password: makeSecretRefUsingRef("typo", passwordKey),
  253. ServerURL: validProvider.ServerURL,
  254. },
  255. kube: clientfake.NewClientBuilder().WithObjects(clientSecret).Build(),
  256. errCheck: func(t *testing.T, err error) {
  257. assert.True(t, kubeErrors.IsNotFound(err))
  258. },
  259. },
  260. "dangling username ref": {
  261. provider: &esv1.SecretServerProvider{
  262. Username: makeSecretRefUsingRef("typo", userNameKey),
  263. Password: validProvider.Password,
  264. ServerURL: validProvider.ServerURL,
  265. },
  266. kube: clientfake.NewClientBuilder().WithObjects(clientSecret).Build(),
  267. errCheck: func(t *testing.T, err error) {
  268. assert.True(t, kubeErrors.IsNotFound(err))
  269. },
  270. },
  271. "secret ref without name": {
  272. provider: &esv1.SecretServerProvider{
  273. Username: makeSecretRefUsingRef("", userNameKey),
  274. Password: validProvider.Password,
  275. ServerURL: validProvider.ServerURL,
  276. },
  277. kube: clientfake.NewClientBuilder().WithObjects(clientSecret).Build(),
  278. errCheck: func(t *testing.T, err error) {
  279. assert.ErrorIs(t, err, errMissingSecretName)
  280. },
  281. },
  282. "secret ref without key": {
  283. provider: &esv1.SecretServerProvider{
  284. Username: validProvider.Password,
  285. Password: makeSecretRefUsingRef(clientSecret.Name, ""),
  286. ServerURL: validProvider.ServerURL,
  287. },
  288. kube: clientfake.NewClientBuilder().WithObjects(clientSecret).Build(),
  289. errCheck: func(t *testing.T, err error) {
  290. assert.ErrorIs(t, err, errMissingSecretKey)
  291. },
  292. },
  293. "secret ref with non-existent keys": {
  294. provider: &esv1.SecretServerProvider{
  295. Username: makeSecretRefUsingRef(clientSecret.Name, "typo"),
  296. Password: makeSecretRefUsingRef(clientSecret.Name, passwordKey),
  297. ServerURL: validProvider.ServerURL,
  298. },
  299. kube: clientfake.NewClientBuilder().WithObjects(clientSecret).Build(),
  300. errCheck: func(t *testing.T, err error) {
  301. assert.EqualError(t, err, "cannot find secret data for key: \"typo\"")
  302. },
  303. },
  304. "valid secret refs": {
  305. provider: validProvider,
  306. kube: clientfake.NewClientBuilder().WithObjects(clientSecret).Build(),
  307. },
  308. "secret values": {
  309. provider: &esv1.SecretServerProvider{
  310. Username: makeSecretRefUsingValue(userNameValue),
  311. Password: makeSecretRefUsingValue(passwordValue),
  312. ServerURL: validProvider.ServerURL,
  313. },
  314. kube: clientfake.NewClientBuilder().WithObjects(clientSecret).Build(),
  315. },
  316. "cluster secret store": {
  317. store: &esv1.ClusterSecretStore{
  318. TypeMeta: metav1.TypeMeta{Kind: esv1.ClusterSecretStoreKind},
  319. Spec: esv1.SecretStoreSpec{
  320. Provider: &esv1.SecretStoreProvider{
  321. SecretServer: &esv1.SecretServerProvider{
  322. Username: makeSecretRefUsingNamespacedRef(clientSecret.Namespace, clientSecret.Name, userNameKey),
  323. Password: makeSecretRefUsingNamespacedRef(clientSecret.Namespace, clientSecret.Name, passwordKey),
  324. ServerURL: validProvider.ServerURL,
  325. },
  326. },
  327. },
  328. },
  329. kube: clientfake.NewClientBuilder().WithObjects(clientSecret).Build(),
  330. },
  331. "cluster secret store with domain": {
  332. store: &esv1.ClusterSecretStore{
  333. TypeMeta: metav1.TypeMeta{Kind: esv1.ClusterSecretStoreKind},
  334. Spec: esv1.SecretStoreSpec{
  335. Provider: &esv1.SecretStoreProvider{
  336. SecretServer: &esv1.SecretServerProvider{
  337. Username: makeSecretRefUsingNamespacedRef(clientSecretWithDomain.Namespace, clientSecretWithDomain.Name, userNameKey),
  338. Password: makeSecretRefUsingNamespacedRef(clientSecretWithDomain.Namespace, clientSecretWithDomain.Name, passwordKey),
  339. Domain: validProviderWithDomain.Domain,
  340. ServerURL: validProviderWithDomain.ServerURL,
  341. },
  342. },
  343. },
  344. },
  345. kube: clientfake.NewClientBuilder().WithObjects(clientSecret, clientSecretWithDomain).Build(),
  346. },
  347. "valid with CABundle and CAProvider using Secret": {
  348. provider: &esv1.SecretServerProvider{
  349. Username: validProvider.Username,
  350. Password: validProvider.Password,
  351. ServerURL: validProvider.ServerURL,
  352. CABundle: testCABundle,
  353. CAProvider: &esv1.CAProvider{
  354. Type: esv1.CAProviderTypeSecret,
  355. Name: caSecretName,
  356. Key: caSecretKey,
  357. },
  358. },
  359. kube: clientfake.NewClientBuilder().WithObjects(clientSecret, caSecret).Build(),
  360. },
  361. "valid with CABundle and CAProvider using ConfigMap": {
  362. provider: &esv1.SecretServerProvider{
  363. Username: validProvider.Username,
  364. Password: validProvider.Password,
  365. ServerURL: validProvider.ServerURL,
  366. CABundle: testCABundle,
  367. CAProvider: &esv1.CAProvider{
  368. Type: esv1.CAProviderTypeConfigMap,
  369. Name: caConfigMapName,
  370. Key: caConfigMapKey,
  371. },
  372. },
  373. kube: clientfake.NewClientBuilder().WithObjects(clientSecret, caConfigMap).Build(),
  374. },
  375. "CABundle without CAProvider is ignored": {
  376. provider: &esv1.SecretServerProvider{
  377. Username: validProvider.Username,
  378. Password: validProvider.Password,
  379. ServerURL: validProvider.ServerURL,
  380. CABundle: testCABundle,
  381. },
  382. kube: clientfake.NewClientBuilder().WithObjects(clientSecret).Build(),
  383. },
  384. "CAProvider without CABundle is ignored": {
  385. provider: &esv1.SecretServerProvider{
  386. Username: validProvider.Username,
  387. Password: validProvider.Password,
  388. ServerURL: validProvider.ServerURL,
  389. CAProvider: &esv1.CAProvider{
  390. Type: esv1.CAProviderTypeSecret,
  391. Name: caSecretName,
  392. Key: caSecretKey,
  393. },
  394. },
  395. kube: clientfake.NewClientBuilder().WithObjects(clientSecret, caSecret).Build(),
  396. },
  397. "invalid CABundle format with CAProvider": {
  398. provider: &esv1.SecretServerProvider{
  399. Username: validProvider.Username,
  400. Password: validProvider.Password,
  401. ServerURL: validProvider.ServerURL,
  402. CABundle: []byte("invalid certificate data"),
  403. CAProvider: &esv1.CAProvider{
  404. Type: esv1.CAProviderTypeSecret,
  405. Name: caSecretName,
  406. Key: caSecretKey,
  407. },
  408. },
  409. kube: clientfake.NewClientBuilder().WithObjects(clientSecret, caSecret).Build(),
  410. errCheck: func(t *testing.T, err error) {
  411. assert.Error(t, err)
  412. assert.Contains(t, err.Error(), "failed to decode ca bundle")
  413. },
  414. },
  415. "missing CAProvider Secret with valid CABundle": {
  416. provider: &esv1.SecretServerProvider{
  417. Username: validProvider.Username,
  418. Password: validProvider.Password,
  419. ServerURL: validProvider.ServerURL,
  420. CABundle: testCABundle,
  421. CAProvider: &esv1.CAProvider{
  422. Type: esv1.CAProviderTypeSecret,
  423. Name: "non-existent-secret",
  424. Key: caSecretKey,
  425. },
  426. },
  427. kube: clientfake.NewClientBuilder().WithObjects(clientSecret).Build(),
  428. // CABundle takes precedence, so even if the secret doesn't exist, CABundle is used
  429. },
  430. "only CAProvider without CABundle is ignored": {
  431. provider: &esv1.SecretServerProvider{
  432. Username: validProvider.Username,
  433. Password: validProvider.Password,
  434. ServerURL: validProvider.ServerURL,
  435. CAProvider: &esv1.CAProvider{
  436. Type: esv1.CAProviderTypeSecret,
  437. Name: caSecretName,
  438. Key: caSecretKey,
  439. },
  440. },
  441. kube: clientfake.NewClientBuilder().WithObjects(clientSecret, caSecret).Build(),
  442. // No error expected because both CABundle AND CAProvider must be set for TLS config
  443. },
  444. "cluster secret store with CABundle and CAProvider": {
  445. store: &esv1.ClusterSecretStore{
  446. TypeMeta: metav1.TypeMeta{Kind: esv1.ClusterSecretStoreKind},
  447. Spec: esv1.SecretStoreSpec{
  448. Provider: &esv1.SecretStoreProvider{
  449. SecretServer: &esv1.SecretServerProvider{
  450. Username: makeSecretRefUsingNamespacedRef(clientSecret.Namespace, clientSecret.Name, userNameKey),
  451. Password: makeSecretRefUsingNamespacedRef(clientSecret.Namespace, clientSecret.Name, passwordKey),
  452. ServerURL: validProvider.ServerURL,
  453. CABundle: testCABundle,
  454. CAProvider: &esv1.CAProvider{
  455. Type: esv1.CAProviderTypeSecret,
  456. Name: caSecretName,
  457. Key: caSecretKey,
  458. Namespace: new("default"),
  459. },
  460. },
  461. },
  462. },
  463. },
  464. kube: clientfake.NewClientBuilder().WithObjects(clientSecret, caSecret).Build(),
  465. },
  466. }
  467. for name, tc := range tests {
  468. t.Run(name, func(t *testing.T) {
  469. p := &Provider{}
  470. store := tc.store
  471. if store == nil {
  472. store = &esv1.SecretStore{
  473. TypeMeta: metav1.TypeMeta{Kind: esv1.SecretStoreKind},
  474. Spec: esv1.SecretStoreSpec{
  475. Provider: &esv1.SecretStoreProvider{
  476. SecretServer: tc.provider,
  477. },
  478. },
  479. }
  480. }
  481. sc, err := p.NewClient(context.Background(), store, tc.kube, clientSecret.Namespace)
  482. if tc.errCheck == nil {
  483. assert.NoError(t, err)
  484. delineaClient, ok := sc.(*client)
  485. assert.True(t, ok)
  486. secretServerClient, ok := delineaClient.api.(*server.Server)
  487. assert.True(t, ok)
  488. expectedCredentials := server.UserCredential{
  489. Username: userNameValue,
  490. Password: passwordValue,
  491. }
  492. if name == "cluster secret store with domain" {
  493. expectedCredentials.Domain = domain
  494. }
  495. assert.Equal(t, expectedCredentials, secretServerClient.Configuration.Credentials)
  496. } else {
  497. assert.Nil(t, sc)
  498. tc.errCheck(t, err)
  499. }
  500. })
  501. }
  502. }
  503. func makeSecretRefUsingNamespacedRef(namespace, name, key string) *esv1.SecretServerProviderRef {
  504. return &esv1.SecretServerProviderRef{
  505. SecretRef: &v1.SecretKeySelector{Namespace: new(namespace), Name: name, Key: key},
  506. }
  507. }
  508. func makeSecretRefUsingValue(val string) *esv1.SecretServerProviderRef {
  509. return &esv1.SecretServerProviderRef{Value: val}
  510. }
  511. func makeSecretRefUsingRef(name, key string) *esv1.SecretServerProviderRef {
  512. return &esv1.SecretServerProviderRef{
  513. SecretRef: &v1.SecretKeySelector{Name: name, Key: key},
  514. }
  515. }
  516. func generateRandomString() string {
  517. var letters = []rune("abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789")
  518. b := make([]rune, 10)
  519. for i := range b {
  520. b[i] = letters[rand.Intn(len(letters))]
  521. }
  522. return string(b)
  523. }
  524. // TestValidateStoreSecretRef tests the validateStoreSecretRef function.
  525. func TestValidateStoreSecretRef(t *testing.T) {
  526. tests := map[string]struct {
  527. store esv1.GenericStore
  528. ref *esv1.SecretServerProviderRef
  529. wantErr error
  530. }{
  531. "valid secret ref for SecretStore": {
  532. store: &esv1.SecretStore{
  533. ObjectMeta: metav1.ObjectMeta{
  534. Name: "test-store",
  535. Namespace: "default",
  536. },
  537. },
  538. ref: &esv1.SecretServerProviderRef{
  539. SecretRef: &v1.SecretKeySelector{
  540. Name: "secret-name",
  541. Key: "secret-key",
  542. },
  543. },
  544. wantErr: nil,
  545. },
  546. "error when secret ref missing name": {
  547. store: &esv1.SecretStore{
  548. ObjectMeta: metav1.ObjectMeta{
  549. Name: "test-store",
  550. Namespace: "default",
  551. },
  552. },
  553. ref: &esv1.SecretServerProviderRef{
  554. SecretRef: &v1.SecretKeySelector{
  555. Name: "",
  556. Key: "secret-key",
  557. },
  558. },
  559. wantErr: errMissingSecretName,
  560. },
  561. "error when secret ref missing key": {
  562. store: &esv1.SecretStore{
  563. ObjectMeta: metav1.ObjectMeta{
  564. Name: "test-store",
  565. Namespace: "default",
  566. },
  567. },
  568. ref: &esv1.SecretServerProviderRef{
  569. SecretRef: &v1.SecretKeySelector{
  570. Name: "secret-name",
  571. Key: "",
  572. },
  573. },
  574. wantErr: errMissingSecretKey,
  575. },
  576. "error when both value and secret ref are set": {
  577. store: &esv1.SecretStore{
  578. ObjectMeta: metav1.ObjectMeta{
  579. Name: "test-store",
  580. Namespace: "default",
  581. },
  582. },
  583. ref: &esv1.SecretServerProviderRef{
  584. SecretRef: &v1.SecretKeySelector{
  585. Name: "secret-name",
  586. Key: "secret-key",
  587. },
  588. Value: "some-value",
  589. },
  590. wantErr: errSecretRefAndValueConflict,
  591. },
  592. }
  593. for name, tc := range tests {
  594. t.Run(name, func(t *testing.T) {
  595. err := validateStoreSecretRef(tc.store, tc.ref)
  596. if tc.wantErr == nil {
  597. assert.NoError(t, err)
  598. } else {
  599. assert.ErrorIs(t, err, tc.wantErr)
  600. }
  601. })
  602. }
  603. }
  604. // TestCapabilities tests the Capabilities function.
  605. func TestCapabilities(t *testing.T) {
  606. tests := map[string]struct {
  607. want esv1.SecretStoreCapabilities
  608. }{
  609. "returns ReadWrite capability": {
  610. want: esv1.SecretStoreReadWrite,
  611. },
  612. }
  613. for name, tc := range tests {
  614. t.Run(name, func(t *testing.T) {
  615. p := &Provider{}
  616. got := p.Capabilities()
  617. assert.Equal(t, tc.want, got)
  618. // Edge: call Capabilities on nil Provider
  619. var nilP *Provider
  620. assert.Equal(t, esv1.SecretStoreReadWrite, nilP.Capabilities())
  621. })
  622. }
  623. }
  624. // TestNewProvider tests the NewProvider function.
  625. func TestNewProvider(t *testing.T) {
  626. tests := map[string]struct {
  627. want esv1.Provider
  628. }{
  629. "creates a new provider instance": {
  630. want: &Provider{},
  631. },
  632. }
  633. for name, tc := range tests {
  634. t.Run(name, func(t *testing.T) {
  635. got := NewProvider()
  636. assert.NotNil(t, got)
  637. assert.IsType(t, tc.want, got)
  638. // Edge: call NewProvider multiple times
  639. got2 := NewProvider()
  640. assert.IsType(t, tc.want, got2)
  641. })
  642. }
  643. }
  644. // TestProviderSpec tests the ProviderSpec function.
  645. func TestProviderSpec(t *testing.T) {
  646. tests := map[string]struct {
  647. wantType *esv1.SecretStoreProvider
  648. }{
  649. "returns correct provider spec": {
  650. wantType: &esv1.SecretStoreProvider{
  651. SecretServer: &esv1.SecretServerProvider{},
  652. },
  653. },
  654. }
  655. for name, tc := range tests {
  656. t.Run(name, func(t *testing.T) {
  657. got := ProviderSpec()
  658. assert.NotNil(t, got)
  659. assert.NotNil(t, got.SecretServer)
  660. assert.IsType(t, tc.wantType, got)
  661. // Ensure ProviderSpec returns a fresh instance (no shared mutable state)
  662. // Mutate the returned object and verify a subsequent call is unaffected.
  663. got.SecretServer.ServerURL = "http://modified.local"
  664. got2 := ProviderSpec()
  665. assert.IsType(t, tc.wantType, got2)
  666. // If ProviderSpec reused a shared object, this would be equal.
  667. assert.NotEqual(t, got.SecretServer.ServerURL, got2.SecretServer.ServerURL)
  668. })
  669. }
  670. }