@@ -243,7 +243,8 @@ var _ = Describe("Atlas Database User", Label("int", "AtlasDatabaseUser", "prote
243
243
244
244
By ("Giving user readWrite permissions" , func () {
245
245
// Adding the role allowing read/write
246
- _ , err := retry .RetryUpdateOnConflict (context .Background (), k8sClient , client .ObjectKeyFromObject (testDBUser1 ), func (user * akov2.AtlasDatabaseUser ) {
246
+ var err error
247
+ testDBUser1 , err = retry .RetryUpdateOnConflict (context .Background (), k8sClient , client .ObjectKeyFromObject (testDBUser1 ), func (user * akov2.AtlasDatabaseUser ) {
247
248
user .WithRole ("readWriteAnyDatabase" , "admin" , "" )
248
249
})
249
250
Expect (err ).NotTo (HaveOccurred ())
@@ -318,7 +319,8 @@ var _ = Describe("Atlas Database User", Label("int", "AtlasDatabaseUser", "prote
318
319
})
319
320
320
321
By ("Removing database user scope for first deployment" , func () {
321
- _ , err := retry .RetryUpdateOnConflict (context .Background (), k8sClient , client .ObjectKeyFromObject (testDBUser1 ), func (user * akov2.AtlasDatabaseUser ) {
322
+ var err error
323
+ testDBUser1 , err = retry .RetryUpdateOnConflict (context .Background (), k8sClient , client .ObjectKeyFromObject (testDBUser1 ), func (user * akov2.AtlasDatabaseUser ) {
322
324
user .Spec .Scopes = nil
323
325
})
324
326
Expect (err ).NotTo (HaveOccurred ())
@@ -476,7 +478,8 @@ var _ = Describe("Atlas Database User", Label("int", "AtlasDatabaseUser", "prote
476
478
Expect (k8sClient .Get (context .Background (), client .ObjectKeyFromObject (testDBUser1 ), testDBUser1 )).To (Succeed ())
477
479
oldName := testDBUser1 .Spec .Username
478
480
479
- _ , err := retry .RetryUpdateOnConflict (context .Background (), k8sClient , client .ObjectKeyFromObject (testDBUser1 ), func (user * akov2.AtlasDatabaseUser ) {
481
+ var err error
482
+ testDBUser1 , err = retry .RetryUpdateOnConflict (context .Background (), k8sClient , client .ObjectKeyFromObject (testDBUser1 ), func (user * akov2.AtlasDatabaseUser ) {
480
483
user .WithAtlasUserName ("new-user" )
481
484
})
482
485
Expect (err ).NotTo (HaveOccurred ())
@@ -507,7 +510,8 @@ var _ = Describe("Atlas Database User", Label("int", "AtlasDatabaseUser", "prote
507
510
})
508
511
509
512
By ("Scoping user to one cluster, a stale secret is removed" , func () {
510
- _ , err := retry .RetryUpdateOnConflict (context .Background (), k8sClient , client .ObjectKeyFromObject (testDBUser1 ), func (user * akov2.AtlasDatabaseUser ) {
513
+ var err error
514
+ testDBUser1 , err = retry .RetryUpdateOnConflict (context .Background (), k8sClient , client .ObjectKeyFromObject (testDBUser1 ), func (user * akov2.AtlasDatabaseUser ) {
511
515
user .ClearScopes ().WithScope (akov2 .DeploymentScopeType , testDeployment .GetDeploymentName ())
512
516
})
513
517
Expect (err ).NotTo (HaveOccurred ())
@@ -570,7 +574,8 @@ var _ = Describe("Atlas Database User", Label("int", "AtlasDatabaseUser", "prote
570
574
By ("Fixing the user date expiration" , func () {
571
575
after := time .Now ().UTC ().Add (time .Hour * 10 ).Format ("2006-01-02T15:04:05" )
572
576
573
- _ , err := retry .RetryUpdateOnConflict (context .Background (), k8sClient , client .ObjectKeyFromObject (testDBUser1 ), func (user * akov2.AtlasDatabaseUser ) {
577
+ var err error
578
+ testDBUser1 , err = retry .RetryUpdateOnConflict (context .Background (), k8sClient , client .ObjectKeyFromObject (testDBUser1 ), func (user * akov2.AtlasDatabaseUser ) {
574
579
user .Spec .DeleteAfterDate = after
575
580
})
576
581
Expect (err ).NotTo (HaveOccurred ())
@@ -585,7 +590,8 @@ var _ = Describe("Atlas Database User", Label("int", "AtlasDatabaseUser", "prote
585
590
By ("Expiring the User" , func () {
586
591
before := time .Now ().UTC ().Add (time .Minute * - 5 ).Format ("2006-01-02T15:04:05" )
587
592
588
- _ , err := retry .RetryUpdateOnConflict (context .Background (), k8sClient , client .ObjectKeyFromObject (testDBUser1 ), func (user * akov2.AtlasDatabaseUser ) {
593
+ var err error
594
+ testDBUser1 , err = retry .RetryUpdateOnConflict (context .Background (), k8sClient , client .ObjectKeyFromObject (testDBUser1 ), func (user * akov2.AtlasDatabaseUser ) {
589
595
user .Spec .DeleteAfterDate = before
590
596
})
591
597
Expect (err ).NotTo (HaveOccurred ())
@@ -625,9 +631,10 @@ var _ = Describe("Atlas Database User", Label("int", "AtlasDatabaseUser", "prote
625
631
})
626
632
627
633
By ("Skipping reconciliation" , func () {
628
- _ , err := retry .RetryUpdateOnConflict (context .Background (), k8sClient , client .ObjectKeyFromObject (testDBUser1 ), func (user * akov2.AtlasDatabaseUser ) {
634
+ var err error
635
+ testDBUser1 , err = retry .RetryUpdateOnConflict (context .Background (), k8sClient , client .ObjectKeyFromObject (testDBUser1 ), func (user * akov2.AtlasDatabaseUser ) {
629
636
user .ObjectMeta .Annotations = map [string ]string {customresource .ReconciliationPolicyAnnotation : customresource .ReconciliationPolicySkip }
630
- user .Spec .Roles = append (testDBUser1 .Spec .Roles , akov2.RoleSpec {
637
+ user .Spec .Roles = append (user .Spec .Roles , akov2.RoleSpec {
631
638
RoleName : "new-role" ,
632
639
DatabaseName : "new-database" ,
633
640
CollectionName : "new-collection" ,
0 commit comments