tests: lower timeout value to get test results faster

open200 · Jul 23, 2024 · 03fe34c · 03fe34c
1 parent 69e606f
commit 03fe34c
Show file tree

Hide file tree

Showing 62 changed files with 256 additions and 95 deletions.
diff --git a/xesar-connect/src/test/kotlin/com/open200/xesar/connect/command/AddEvvaComponentTest.kt b/xesar-connect/src/test/kotlin/com/open200/xesar/connect/command/AddEvvaComponentTest.kt
@@ -28,6 +28,7 @@ class AddEvvaComponentTest :
         val container = MosquittoContainer.container()
         val config = MosquittoContainer.config(container)
         listener(container.perProject())
+        val requestConfig = XesarConnect.RequestConfig(50L)
         test("add evva component returning no event") {
             coEvery { config.uuidGenerator.generateId() }
                 .returns(UUID.fromString("00000000-1281-40ae-89d7-5c541d77a757"))
@@ -67,7 +68,8 @@ class AddEvvaComponentTest :
                     val addEvvaComponentEventPair =
                         api.addEvvaComponentAsync(
                             UUID.fromString("2d52bd95-18ba-4e46-8f00-0fc4c1e3f9be"),
-                            ComponentType.Cylinder)
+                            ComponentType.Cylinder,
+                            requestConfig)
                     shouldThrow<OptionalEventException> {
                         addEvvaComponentEventPair.evvaComponentAddedDeferred.await()
                     }
@@ -130,7 +132,8 @@ class AddEvvaComponentTest :
                     val addEvvaComponentEventPair =
                         api.addEvvaComponentAsync(
                             UUID.fromString("43edc7cf-80ab-4486-86db-41cda2c7a2cd"),
-                            ComponentType.Cylinder)
+                            ComponentType.Cylinder,
+                            requestConfig)
 
                     shouldThrow<OptionalEventException> {
                         addEvvaComponentEventPair.evvaComponentAddedDeferred.await()
@@ -208,7 +211,8 @@ class AddEvvaComponentTest :
                     val addEvvaComponentEventPair =
                         api.addEvvaComponentAsync(
                             UUID.fromString("43edc7cf-80ab-4486-86db-41cda2c7a2cd"),
-                            ComponentType.Cylinder)
+                            ComponentType.Cylinder,
+                            requestConfig)
                     val installationPointChanged =
                         addEvvaComponentEventPair.installationPointChangedDeferred.await()
                     installationPointChanged.aggregateId.shouldBeEqual(
@@ -287,7 +291,8 @@ class AddEvvaComponentTest :
                         val addEvvaComponentEventPair =
                             api.addEvvaComponentAsync(
                                 UUID.fromString("43edc7cf-80ab-4486-86db-41cda2c7a2cd"),
-                                ComponentType.Cylinder)
+                                ComponentType.Cylinder,
+                                requestConfig)
                         val installationPointChanged =
                             addEvvaComponentEventPair.installationPointChangedDeferred.await()
                         installationPointChanged.aggregateId.shouldBeEqual(
@@ -358,7 +363,8 @@ class AddEvvaComponentTest :
                     val addEvvaComponentEventPair =
                         api.addEvvaComponentAsync(
                             UUID.fromString("2d52bd95-18ba-4e46-8f00-0fc4c1e3f9be"),
-                            ComponentType.Cylinder)
+                            ComponentType.Cylinder,
+                            requestConfig)
 
                     shouldThrow<ParsingException> {
                         addEvvaComponentEventPair.installationPointChangedDeferred.await()
@@ -440,7 +446,8 @@ class AddEvvaComponentTest :
                     val addEvvaComponentEventPair =
                         api.addEvvaComponentAsync(
                             UUID.fromString("2d52bd95-18ba-4e46-8f00-0fc4c1e3f9be"),
-                            ComponentType.Cylinder)
+                            ComponentType.Cylinder,
+                            requestConfig)
                     val test = addEvvaComponentEventPair.installationPointChangedDeferred.await()
                     test.aggregateId.shouldBeEqual(
                         UUID.fromString("43edc7cf-80ab-4486-86db-41cda2c7a2cd"))
@@ -502,7 +509,8 @@ class AddEvvaComponentTest :
                     val addEvvaComponentEventPair =
                         api.addEvvaComponentAsync(
                             UUID.fromString("2d52bd95-18ba-4e46-8f00-0fc4c1e3f9be"),
-                            ComponentType.Cylinder)
+                            ComponentType.Cylinder,
+                            requestConfig)
                     val installationPointChanged =
                         addEvvaComponentEventPair.installationPointChangedDeferred.await()
                     installationPointChanged.aggregateId.shouldBeEqual(

diff --git a/...kotlin/com/open200/xesar/connect/command/AddInstallationPointAuthorizationToMediumTest.kt b/...kotlin/com/open200/xesar/connect/command/AddInstallationPointAuthorizationToMediumTest.kt
@@ -23,6 +23,7 @@ class AddInstallationPointAuthorizationToMediumTest :
         val container = MosquittoContainer.container()
         val config = MosquittoContainer.config(container)
         listener(container.perProject())
+        val requestConfig = XesarConnect.RequestConfig(50L)
 
         test("add installation point authorization to medium") {
             coEvery { config.uuidGenerator.generateId() }
@@ -80,7 +81,8 @@ class AddInstallationPointAuthorizationToMediumTest :
                     val result =
                         api.addInstallationPointAuthorizationToMediumAsync(
                             UUID.fromString("43edc7cf-80ab-4486-86db-41cda2c7a2cd"),
-                            authorizationData)
+                            authorizationData,
+                            requestConfig)
                     result
                         .await()
                         .id

diff --git a/...nnect/src/test/kotlin/com/open200/xesar/connect/command/AddInstallationPointToZoneTest.kt b/...nnect/src/test/kotlin/com/open200/xesar/connect/command/AddInstallationPointToZoneTest.kt
@@ -23,6 +23,7 @@ class AddInstallationPointToZoneTest :
         val container = MosquittoContainer.container()
         val config = MosquittoContainer.config(container)
         listener(container.perProject())
+        val requestConfig = XesarConnect.RequestConfig(50L)
 
         test("add installation point to zone") {
             coEvery { config.uuidGenerator.generateId() }
@@ -73,7 +74,8 @@ class AddInstallationPointToZoneTest :
                     val result =
                         api.addInstallationPointToZoneAsync(
                                 UUID.fromString("43edc7cf-80ab-4486-86db-41cda2c7a2cd"),
-                                UUID.fromString("2d52bd95-18ba-4e46-8f00-0fc4c1e3f9be"))
+                                UUID.fromString("2d52bd95-18ba-4e46-8f00-0fc4c1e3f9be"),
+                                requestConfig)
                             .await()
                     result.addedInstallationPoints.size.shouldBeEqual(1)
                     result.aggregateId.shouldBeEqual(

diff --git a/...ect/src/test/kotlin/com/open200/xesar/connect/command/AddZoneAuthorizationToMediumTest.kt b/...ect/src/test/kotlin/com/open200/xesar/connect/command/AddZoneAuthorizationToMediumTest.kt
@@ -23,6 +23,7 @@ class AddZoneAuthorizationToMediumTest :
         val container = MosquittoContainer.container()
         val config = MosquittoContainer.config(container)
         listener(container.perProject())
+        val requestConfig = XesarConnect.RequestConfig(50L)
 
         test("add installation point authorization to medium") {
             coEvery { config.uuidGenerator.generateId() }
@@ -80,7 +81,8 @@ class AddZoneAuthorizationToMediumTest :
                     val result =
                         api.addZoneAuthorizationToMediumAsync(
                                 UUID.fromString("43edc7cf-80ab-4486-86db-41cda2c7a2cd"),
-                                authorizationData)
+                                authorizationData,
+                                requestConfig)
                             .await()
                     result.id.shouldBeEqual(UUID.fromString("43edc7cf-80ab-4486-86db-41cda2c7a2cd"))
                 }

diff --git a/...c/test/kotlin/com/open200/xesar/connect/command/AssignAuthorizationProfileToMediumTest.kt b/...c/test/kotlin/com/open200/xesar/connect/command/AssignAuthorizationProfileToMediumTest.kt
@@ -27,6 +27,8 @@ class AssignAuthorizationProfileToMediumTest :
         val container = MosquittoContainer.container()
         val config = MosquittoContainer.config(container)
         listener(container.perProject())
+        val requestConfig = XesarConnect.RequestConfig(50L)
+
         test("assign authorization profile to medium returning no event") {
             coEvery { config.uuidGenerator.generateId() }
                 .returns(UUID.fromString("00000000-1281-40ae-89d7-5c541d77a757"))
@@ -65,7 +67,7 @@ class AssignAuthorizationProfileToMediumTest :
                     val assignAuthorizationProfileToMediumResult =
                         api.assignAuthorizationProfileToMediumAsync(
                             UUID.fromString("2d52bd95-18ba-4e46-8f00-0fc4c1e3f9be"),
-                        )
+                            requestConfig = requestConfig)
                     shouldThrow<OptionalEventException> {
                         assignAuthorizationProfileToMediumResult.mediumChangedDeferred.await()
                     }
@@ -130,7 +132,7 @@ class AssignAuthorizationProfileToMediumTest :
                     val assignAuthorizationProfileToMediumResult =
                         api.assignAuthorizationProfileToMediumAsync(
                             UUID.fromString("43edc7cf-80ab-4486-86db-41cda2c7a2cd"),
-                        )
+                            requestConfig = requestConfig)
 
                     shouldThrow<OptionalEventException> {
                         assignAuthorizationProfileToMediumResult.mediumChangedDeferred.await()
@@ -211,7 +213,7 @@ class AssignAuthorizationProfileToMediumTest :
                     val assignAuthorizationProfileToMediumResult =
                         api.assignAuthorizationProfileToMediumAsync(
                             UUID.fromString("43edc7cf-80ab-4486-86db-41cda2c7a2cd"),
-                        )
+                            requestConfig = requestConfig)
                     val mediumChanged =
                         assignAuthorizationProfileToMediumResult.mediumChangedDeferred.await()
                     mediumChanged.id.shouldBeEqual(
@@ -293,7 +295,7 @@ class AssignAuthorizationProfileToMediumTest :
                         val assignAuthorizationProfileToMediumResult =
                             api.assignAuthorizationProfileToMediumAsync(
                                 UUID.fromString("43edc7cf-80ab-4486-86db-41cda2c7a2cd"),
-                            )
+                                requestConfig = requestConfig)
                         val MediumAuthorizationProfileChanged =
                             assignAuthorizationProfileToMediumResult
                                 .mediumAuthorizationProfileChangedDeferred
@@ -368,7 +370,7 @@ class AssignAuthorizationProfileToMediumTest :
                     val assignAuthorizationProfileToMediumResult =
                         api.assignAuthorizationProfileToMediumAsync(
                             UUID.fromString("2d52bd95-18ba-4e46-8f00-0fc4c1e3f9be"),
-                        )
+                            requestConfig = requestConfig)
 
                     shouldThrow<ParsingException> {
                         assignAuthorizationProfileToMediumResult.mediumChangedDeferred.await()
@@ -448,7 +450,7 @@ class AssignAuthorizationProfileToMediumTest :
                     val assignAuthorizationProfileToMediumResult =
                         api.assignAuthorizationProfileToMediumAsync(
                             UUID.fromString("2d52bd95-18ba-4e46-8f00-0fc4c1e3f9be"),
-                        )
+                            requestConfig = requestConfig)
                     val test =
                         assignAuthorizationProfileToMediumResult
                             .mediumAuthorizationProfileChangedDeferred
@@ -517,7 +519,7 @@ class AssignAuthorizationProfileToMediumTest :
                         val assignAuthorizationProfileToMediumResult =
                             api.assignAuthorizationProfileToMediumAsync(
                                 UUID.fromString("2d52bd95-18ba-4e46-8f00-0fc4c1e3f9be"),
-                            )
+                                requestConfig = requestConfig)
                         val mediumAuthorizationProfileChanged =
                             assignAuthorizationProfileToMediumResult.mediumChangedDeferred.await()
                         mediumAuthorizationProfileChanged.id.shouldBeEqual(

diff --git a/xesar-connect/src/test/kotlin/com/open200/xesar/connect/command/AssignPersonToMediumTest.kt b/xesar-connect/src/test/kotlin/com/open200/xesar/connect/command/AssignPersonToMediumTest.kt
@@ -23,6 +23,7 @@ class AssignPersonToMediumTest :
         val container = MosquittoContainer.container()
         val config = MosquittoContainer.config(container)
         listener(container.perProject())
+        val requestConfig = XesarConnect.RequestConfig(50L)
 
         test("assign person to medium") {
             coEvery { config.uuidGenerator.generateId() }
@@ -70,7 +71,8 @@ class AssignPersonToMediumTest :
                     val result =
                         api.assignPersonToMediumAsync(
                                 UUID.fromString("43edc7cf-80ab-4486-86db-41cda2c7a2cd"),
-                                UUID.fromString("2d52bd95-18ba-4e46-8f00-0fc4c1e3f9be"))
+                                UUID.fromString("2d52bd95-18ba-4e46-8f00-0fc4c1e3f9be"),
+                                requestConfig)
                             .await()
 
                     result.id.shouldBeEqual(UUID.fromString("43edc7cf-80ab-4486-86db-41cda2c7a2cd"))

diff --git a/...nnect/src/test/kotlin/com/open200/xesar/connect/command/ChangeAuthorizationProfileTest.kt b/...nnect/src/test/kotlin/com/open200/xesar/connect/command/ChangeAuthorizationProfileTest.kt
@@ -28,6 +28,8 @@ class ChangeAuthorizationProfileTest :
         val container = MosquittoContainer.container()
         val config = MosquittoContainer.config(container)
         listener(container.perProject())
+        val requestConfig = XesarConnect.RequestConfig(50L)
+
         test("change authorization profile returning no event") {
             coEvery { config.uuidGenerator.generateId() }
                 .returns(UUID.fromString("00000000-1281-40ae-89d7-5c541d77a757"))
@@ -73,7 +75,8 @@ class ChangeAuthorizationProfileTest :
                             "new description",
                             null,
                             UUID.fromString("2d52bd95-18ba-4e46-8f00-0fc4c1e3f9be"),
-                            emptyList())
+                            emptyList(),
+                            requestConfig)
 
                     shouldThrow<OptionalEventException> {
                         changeAuthorizationProfileResult.authorizationProfileAccessChangedDeferred
@@ -151,7 +154,8 @@ class ChangeAuthorizationProfileTest :
                             "new description",
                             null,
                             UUID.fromString("2d52bd95-18ba-4e46-8f00-0fc4c1e3f9be"),
-                            emptyList())
+                            emptyList(),
+                            requestConfig)
 
                     shouldThrow<OptionalEventException> {
                         changeAuthorizationProfileResult.authorizationProfileAccessChangedDeferred
@@ -239,7 +243,8 @@ class ChangeAuthorizationProfileTest :
                             "new description",
                             null,
                             UUID.fromString("2d52bd95-18ba-4e46-8f00-0fc4c1e3f9be"),
-                            emptyList())
+                            emptyList(),
+                            requestConfig)
                     val authorizationProfileInfoChanged =
                         changeAuthorizationProfileResult.authorizationProfileInfoChangedDeferred
                             .await()
@@ -329,7 +334,8 @@ class ChangeAuthorizationProfileTest :
                                 "new description",
                                 null,
                                 UUID.fromString("2d52bd95-18ba-4e46-8f00-0fc4c1e3f9be"),
-                                emptyList())
+                                emptyList(),
+                                requestConfig)
                         val authorizationProfileInfoChanged =
                             changeAuthorizationProfileResult.authorizationProfileInfoChangedDeferred
                                 .await()
@@ -414,7 +420,8 @@ class ChangeAuthorizationProfileTest :
                             "new description",
                             null,
                             UUID.fromString("2d52bd95-18ba-4e46-8f00-0fc4c1e3f9be"),
-                            emptyList())
+                            emptyList(),
+                            requestConfig)
 
                     shouldThrow<ParsingException> {
                         changeAuthorizationProfileResult.authorizationProfileAccessChangedDeferred
@@ -509,7 +516,8 @@ class ChangeAuthorizationProfileTest :
                             "new description",
                             null,
                             UUID.fromString("2d52bd95-18ba-4e46-8f00-0fc4c1e3f9be"),
-                            emptyList())
+                            emptyList(),
+                            requestConfig)
                     val authorizationProfileInfoChanged =
                         changeAuthorizationProfileResult.authorizationProfileInfoChangedDeferred
                             .await()
@@ -587,7 +595,8 @@ class ChangeAuthorizationProfileTest :
                             "new description",
                             null,
                             UUID.fromString("2d52bd95-18ba-4e46-8f00-0fc4c1e3f9be"),
-                            emptyList())
+                            emptyList(),
+                            requestConfig)
                     val authorizationProfileInfoChanged =
                         changeAuthorizationProfileResult.authorizationProfileInfoChangedDeferred
                             .await()

diff --git a/...t/src/test/kotlin/com/open200/xesar/connect/command/ChangeAuthorizationTimeProfileTest.kt b/...t/src/test/kotlin/com/open200/xesar/connect/command/ChangeAuthorizationTimeProfileTest.kt
@@ -23,6 +23,7 @@ class ChangeAuthorizationTimeProfileTest :
         val container = MosquittoContainer.container()
         val config = MosquittoContainer.config(container)
         listener(container.perProject())
+        val requestConfig = XesarConnect.RequestConfig(50L)
 
         test("change authorization time profile") {
             coEvery { config.uuidGenerator.generateId() }
@@ -81,7 +82,7 @@ class ChangeAuthorizationTimeProfileTest :
                                 timeProfileName = "timeProfileName",
                                 timeSeries = TimeProfileFixture.timeSeries,
                                 exceptionTimeSeries = TimeProfileFixture.exceptionTimeSerie,
-                            )
+                                requestConfig = requestConfig)
                             .await()
                     result.id.shouldBeEqual(UUID.fromString("43edc7cf-80ab-4486-86db-41cda2c7a2cd"))
                     result.exceptionTimeSeries.shouldBeEqual(TimeProfileFixture.exceptionTimeSerie)

diff --git a/xesar-connect/src/test/kotlin/com/open200/xesar/connect/command/ChangeCalendarTest.kt b/xesar-connect/src/test/kotlin/com/open200/xesar/connect/command/ChangeCalendarTest.kt
@@ -24,6 +24,7 @@ class ChangeCalendarTest :
         val container = MosquittoContainer.container()
         val config = MosquittoContainer.config(container)
         listener(container.perProject())
+        val requestConfig = XesarConnect.RequestConfig(50L)
 
         test("change calendar") {
             coEvery { config.uuidGenerator.generateId() }
@@ -73,7 +74,8 @@ class ChangeCalendarTest :
                         api.changeCalendarAsync(
                                 UUID.fromString("43edc7cf-80ab-4486-86db-41cda2c7a2cd"),
                                 "calendarName",
-                                specialDays = listOf(LocalDate.parse("2018-02-25")))
+                                specialDays = listOf(LocalDate.parse("2018-02-25")),
+                                requestConfig)
                             .await()
                     result.name.shouldBeEqual("calendarName")
                     result.id.shouldBeEqual(

diff --git a/xesar-connect/src/test/kotlin/com/open200/xesar/connect/command/ChangeCodingStationTest.kt b/xesar-connect/src/test/kotlin/com/open200/xesar/connect/command/ChangeCodingStationTest.kt
@@ -23,6 +23,7 @@ class ChangeCodingStationTest :
         val container = MosquittoContainer.container()
         val config = MosquittoContainer.config(container)
         listener(container.perProject())
+        val requestConfig = XesarConnect.RequestConfig(50L)
 
         test("change coding station") {
             coEvery { config.uuidGenerator.generateId() }
@@ -70,7 +71,8 @@ class ChangeCodingStationTest :
                     val result =
                         api.changeCodingStationAsync(
                                 UUID.fromString("43edc7cf-80ab-4486-86db-41cda2c7a2cd"),
-                                "codingStationName")
+                                "codingStationName",
+                                requestConfig = requestConfig)
                             .await()
                     result.name?.shouldBeEqual("codingStationName")
                     result.id.shouldBeEqual(UUID.fromString("43edc7cf-80ab-4486-86db-41cda2c7a2cd"))