fix tests

ServiceStack · Oct 3, 2023 · fb8d7a4 · fb8d7a4
1 parent cc7d8c6
commit fb8d7a4
Showing 1 changed file with 18 additions and 10 deletions.
diff --git a/ServiceStack/tests/ServiceStack.WebHost.Endpoints.Tests/AutoQueryCrudTests.cs b/ServiceStack/tests/ServiceStack.WebHost.Endpoints.Tests/AutoQueryCrudTests.cs
@@ -1033,12 +1033,14 @@ public void Can_CreateRockstarAuditTenant_OneWay()
             };
 
             authClient.SendOneWay(createRequest);
+
+            ExecUtils.RetryUntilTrue(() => {
+                    using var d = appHost.GetDbConnection();
+                    return d.Exists<RockstarAuditTenant>(x => x.FirstName == nameof(CreateRockstarAuditTenant));
+                },
+                TimeSpan.FromSeconds(2));
 
             using var db = appHost.GetDbConnection();
-
-            ExecUtils.RetryUntilTrue(() => 
-                db.Exists<RockstarAuditTenant>(x => x.FirstName == nameof(CreateRockstarAuditTenant)),
-                TimeSpan.FromSeconds(2));
             var result = db.Single<RockstarAuditTenant>(x => x.FirstName == nameof(CreateRockstarAuditTenant));
 
             var updateRequest = new UpdateRockstarAuditTenant {
@@ -1048,8 +1050,10 @@ public void Can_CreateRockstarAuditTenant_OneWay()
             };
             authClient.SendOneWay(updateRequest);
 
-            ExecUtils.RetryUntilTrue(() => 
-                    db.Exists<RockstarAuditTenant>(x => x.FirstName == nameof(UpdateRockstarAuditTenant)),
+            ExecUtils.RetryUntilTrue(() => {
+                    using var d = appHost.GetDbConnection();
+                    return d.Exists<RockstarAuditTenant>(x => x.FirstName == nameof(UpdateRockstarAuditTenant));
+                },
                 TimeSpan.FromSeconds(2));
             result = db.Single<RockstarAuditTenant>(x => x.FirstName == nameof(UpdateRockstarAuditTenant));
 
@@ -1066,8 +1070,10 @@ public void Can_CreateRockstarAuditTenant_OneWay()
             };
             authClient.SendOneWay(patchRequest);
 
-            ExecUtils.RetryUntilTrue(() => 
-                    db.Exists<RockstarAuditTenant>(x => x.FirstName == nameof(PatchRockstarAuditTenant)),
+            ExecUtils.RetryUntilTrue(() => {
+                    using var d = appHost.GetDbConnection();
+                    return d.Exists<RockstarAuditTenant>(x => x.FirstName == nameof(PatchRockstarAuditTenant));
+                },
                 TimeSpan.FromSeconds(2));
             result = db.Single<RockstarAuditTenant>(x => x.FirstName == nameof(PatchRockstarAuditTenant));
 
@@ -1081,8 +1087,10 @@ public void Can_CreateRockstarAuditTenant_OneWay()
                 Id = result.Id,
             });
 
-            ExecUtils.RetryUntilTrue(() => 
-                    !db.Exists<RockstarAuditTenant>(x => x.FirstName == nameof(PatchRockstarAuditTenantMq)),
+            ExecUtils.RetryUntilTrue(() => {
+                    using var d = appHost.GetDbConnection();
+                    return !d.Exists<RockstarAuditTenant>(x => x.FirstName == nameof(PatchRockstarAuditTenantMq));
+                },
                 TimeSpan.FromSeconds(2));
 
             Assert.That(db.Exists<RockstarAuditTenant>(x => x.FirstName == nameof(PatchRockstarAuditTenantMq)), Is.False);