@@ -10,7 +10,6 @@ import (
1010 mdbv1 "github.com/mongodb/mongodb-kubernetes-operator/api/v1"
1111 "github.com/mongodb/mongodb-kubernetes-operator/pkg/automationconfig"
1212 kubeClient "github.com/mongodb/mongodb-kubernetes-operator/pkg/kube/client"
13- mdbClient "github.com/mongodb/mongodb-kubernetes-operator/pkg/kube/client"
1413 "github.com/mongodb/mongodb-kubernetes-operator/pkg/kube/configmap"
1514 "github.com/mongodb/mongodb-kubernetes-operator/pkg/kube/secret"
1615 "github.com/stretchr/testify/assert"
@@ -24,7 +23,7 @@ func TestStatefulSet_IsCorrectlyConfiguredWithTLS(t *testing.T) {
2423 mdb := newTestReplicaSetWithTLS ()
2524 mgr := kubeClient .NewManager (& mdb )
2625
27- client := mdbClient .NewClient (mgr .GetClient ())
26+ client := kubeClient .NewClient (mgr .GetClient ())
2827 err := createTLSSecret (client , mdb , "CERT" , "KEY" , "" )
2928 assert .NoError (t , err )
3029 err = createTLSConfigMap (client , mdb )
@@ -127,7 +126,7 @@ func TestStatefulSet_IsCorrectlyConfiguredWithPrometheusTLS(t *testing.T) {
127126 }
128127
129128 mgr := kubeClient .NewManager (& mdb )
130- cli := mdbClient .NewClient (mgr .GetClient ())
129+ cli := kubeClient .NewClient (mgr .GetClient ())
131130
132131 err := secret .CreateOrUpdate (mgr .Client ,
133132 secret .Builder ().
@@ -160,7 +159,7 @@ func TestStatefulSet_IsCorrectlyConfiguredWithTLSAfterChangingExistingVolumes(t
160159 mdb := newTestReplicaSetWithTLS ()
161160 mgr := kubeClient .NewManager (& mdb )
162161
163- cli := mdbClient .NewClient (mgr .GetClient ())
162+ cli := kubeClient .NewClient (mgr .GetClient ())
164163 err := createTLSSecret (cli , mdb , "CERT" , "KEY" , "" )
165164 assert .NoError (t , err )
166165
@@ -206,7 +205,7 @@ func TestStatefulSet_IsCorrectlyConfiguredWithTLSAfterChangingExistingVolumes(t
206205
207206func TestAutomationConfig_IsCorrectlyConfiguredWithTLS (t * testing.T ) {
208207 createAC := func (mdb mdbv1.MongoDBCommunity ) automationconfig.AutomationConfig {
209- client := mdbClient .NewClient (kubeClient .NewManager (& mdb ).GetClient ())
208+ client := kubeClient .NewClient (kubeClient .NewManager (& mdb ).GetClient ())
210209 err := createTLSSecret (client , mdb , "CERT" , "KEY" , "" )
211210 assert .NoError (t , err )
212211 err = createTLSConfigMap (client , mdb )
@@ -277,7 +276,7 @@ func TestAutomationConfig_IsCorrectlyConfiguredWithTLS(t *testing.T) {
277276func TestTLSOperatorSecret (t * testing.T ) {
278277 t .Run ("Secret is created if it doesn't exist" , func (t * testing.T ) {
279278 mdb := newTestReplicaSetWithTLS ()
280- c := mdbClient .NewClient (kubeClient .NewManager (& mdb ).GetClient ())
279+ c := kubeClient .NewClient (kubeClient .NewManager (& mdb ).GetClient ())
281280 err := createTLSSecret (c , mdb , "CERT" , "KEY" , "" )
282281 assert .NoError (t , err )
283282 err = createTLSConfigMap (c , mdb )
@@ -298,7 +297,7 @@ func TestTLSOperatorSecret(t *testing.T) {
298297
299298 t .Run ("Secret is updated if it already exists" , func (t * testing.T ) {
300299 mdb := newTestReplicaSetWithTLS ()
301- k8sclient := mdbClient .NewClient (kubeClient .NewManager (& mdb ).GetClient ())
300+ k8sclient := kubeClient .NewClient (kubeClient .NewManager (& mdb ).GetClient ())
302301 err := createTLSSecret (k8sclient , mdb , "CERT" , "KEY" , "" )
303302 assert .NoError (t , err )
304303 err = createTLSConfigMap (k8sclient , mdb )
@@ -349,7 +348,7 @@ func TestCombineCertificateAndKey(t *testing.T) {
349348func TestPemSupport (t * testing.T ) {
350349 t .Run ("Success if only pem is provided" , func (t * testing.T ) {
351350 mdb := newTestReplicaSetWithTLS ()
352- c := mdbClient .NewClient (kubeClient .NewManager (& mdb ).GetClient ())
351+ c := kubeClient .NewClient (kubeClient .NewManager (& mdb ).GetClient ())
353352 err := createTLSSecret (c , mdb , "" , "" , "CERT\n KEY" )
354353 assert .NoError (t , err )
355354 err = createTLSConfigMap (c , mdb )
@@ -369,7 +368,7 @@ func TestPemSupport(t *testing.T) {
369368 })
370369 t .Run ("Success if pem is equal to cert+key" , func (t * testing.T ) {
371370 mdb := newTestReplicaSetWithTLS ()
372- c := mdbClient .NewClient (kubeClient .NewManager (& mdb ).GetClient ())
371+ c := kubeClient .NewClient (kubeClient .NewManager (& mdb ).GetClient ())
373372 err := createTLSSecret (c , mdb , "CERT" , "KEY" , "CERT\n KEY" )
374373 assert .NoError (t , err )
375374 err = createTLSConfigMap (c , mdb )
@@ -389,7 +388,7 @@ func TestPemSupport(t *testing.T) {
389388 })
390389 t .Run ("Failure if pem is different from cert+key" , func (t * testing.T ) {
391390 mdb := newTestReplicaSetWithTLS ()
392- c := mdbClient .NewClient (kubeClient .NewManager (& mdb ).GetClient ())
391+ c := kubeClient .NewClient (kubeClient .NewManager (& mdb ).GetClient ())
393392 err := createTLSSecret (c , mdb , "CERT1" , "KEY1" , "CERT\n KEY" )
394393 assert .NoError (t , err )
395394 err = createTLSConfigMap (c , mdb )
@@ -437,7 +436,7 @@ func TestTLSConfig_ReferencesToCACertAreValidated(t *testing.T) {
437436 mdb := newTestReplicaSetWithTLSCaCertificateReferences (tc .caConfigMap , tc .caCertificateSecret )
438437
439438 mgr := kubeClient .NewManager (& mdb )
440- cli := mdbClient .NewClient (mgr .GetClient ())
439+ cli := kubeClient .NewClient (mgr .GetClient ())
441440 err := createTLSSecret (cli , mdb , "cert" , "key" , "pem" )
442441
443442 assert .NoError (t , err )
0 commit comments