Merge pull request #544 from namehillsoftware/bugfix/connection-status-not-updating

davidvedvick · web-flow · commit 817b5f371b37 · 2025-04-28T11:47:59.000-05:00
[Bugfix] Connection Status Not Updating
diff --git a/.github/workflows/build.yml b/.github/workflows/build.yml
@@ -15,3 +15,10 @@ jobs:
     - uses: actions/checkout@v1
     - name: Build and test project blue
       run: sh build-github-pr.sh
+    - name: Upload artifact
+      if: always()
+      uses: actions/upload-artifact@v4
+      with:
+        # Artifact name
+        name: project-blue.build
+        path: projectBlueWater/build/test-results
diff --git a/projectBlueWater/src/main/java/com/lasthopesoftware/bluewater/client/HandheldApplication.kt b/projectBlueWater/src/main/java/com/lasthopesoftware/bluewater/client/HandheldApplication.kt
@@ -343,6 +343,7 @@ fun HandheldApplication(
 				DramaticConnectionInitializationController(
 					connectionSessions,
 				),
+				registerForApplicationMessages,
 			)
 		}
 	}
diff --git a/projectBlueWater/src/main/java/com/lasthopesoftware/bluewater/client/browsing/ReusedViewModelRegistry.kt b/projectBlueWater/src/main/java/com/lasthopesoftware/bluewater/client/browsing/ReusedViewModelRegistry.kt
@@ -101,6 +101,7 @@ class ReusedViewModelRegistry(
 			DramaticConnectionInitializationController(
 				connectionSessions,
 			),
+			registerForApplicationMessages,
 		)
 	}
 
diff --git a/projectBlueWater/src/main/java/com/lasthopesoftware/bluewater/client/browsing/files/details/FileDetailsActivity.kt b/projectBlueWater/src/main/java/com/lasthopesoftware/bluewater/client/browsing/files/details/FileDetailsActivity.kt
@@ -77,6 +77,7 @@ import java.io.IOException
 			DramaticConnectionInitializationController(
 				localApplicationDependencies.connectionSessions,
             ),
+			localApplicationDependencies.registerForApplicationMessages,
 		)
 	}
 
diff --git a/projectBlueWater/src/main/java/com/lasthopesoftware/bluewater/client/connection/session/initialization/ConnectionStatusViewModel.kt b/projectBlueWater/src/main/java/com/lasthopesoftware/bluewater/client/connection/session/initialization/ConnectionStatusViewModel.kt
@@ -11,6 +11,9 @@ import com.lasthopesoftware.bluewater.client.connection.BuildingConnectionStatus
 import com.lasthopesoftware.bluewater.client.connection.BuildingConnectionStatus.SendingWakeSignal
 import com.lasthopesoftware.bluewater.client.connection.libraries.ProvideProgressingLibraryConnections
 import com.lasthopesoftware.bluewater.client.connection.live.LiveServerConnection
+import com.lasthopesoftware.bluewater.client.connection.settings.changes.ObservableConnectionSettingsLibraryStorage
+import com.lasthopesoftware.bluewater.shared.messages.application.RegisterForApplicationMessages
+import com.lasthopesoftware.bluewater.shared.messages.registerReceiver
 import com.lasthopesoftware.bluewater.shared.observables.MutableInteractionState
 import com.lasthopesoftware.promises.extensions.ProgressingPromise
 import com.lasthopesoftware.promises.extensions.ProgressingPromiseProxy
@@ -22,13 +25,13 @@ import com.namehillsoftware.handoff.promises.response.ImmediateResponse
 
 class ConnectionStatusViewModel(
 	private val stringResources: GetStringResources,
-	private val libraryConnectionProvider: ProvideProgressingLibraryConnections
+	private val libraryConnectionProvider: ProvideProgressingLibraryConnections,
+	messages: RegisterForApplicationMessages,
 ) :
 	ViewModel(),
 	TrackConnectionStatus,
 	ProvideProgressingLibraryConnections
 {
-
 	@Volatile
 	private var promisedConnectionCheck = ProgressingPromise<BuildingConnectionStatus, LiveServerConnection?>(null as LiveServerConnection?)
 
@@ -38,6 +41,11 @@ class ConnectionStatusViewModel(
 	@Volatile
 	private var testedLibraryId: LibraryId? = null
 
+	private val connectionSettingsChangedSubscription = messages.registerReceiver { c: ObservableConnectionSettingsLibraryStorage.ConnectionSettingsUpdated ->
+		if (c.libraryId == testedLibraryId)
+			testedLibraryId = null
+	}
+
 	private val mutableIsGettingConnection = MutableInteractionState(false)
 	private val mutableConnectionStatus = MutableInteractionState("")
 
@@ -46,6 +54,10 @@ class ConnectionStatusViewModel(
 	var isCancelled = false
 		private set
 
+	override fun onCleared() {
+		connectionSettingsChangedSubscription.close()
+	}
+
 	override fun initializeConnection(libraryId: LibraryId): Promise<Boolean> = Promise.Proxy { cp ->
 		promiseLibraryConnection(libraryId)
 			.also(cp::doCancel)
@@ -80,8 +92,8 @@ class ConnectionStatusViewModel(
 			override fun respond(connections: LiveServerConnection?) {
 				if (initializingLibraryId != libraryId) return
 
-				testedLibraryId = libraryId
 				val isConnected = connections != null
+				testedLibraryId = libraryId.takeIf { isConnected }
 				mutableConnectionStatus.value =
 					if (isConnected) stringResources.connected else stringResources.gettingLibraryFailed
 			}
diff --git a/projectBlueWater/src/main/java/com/lasthopesoftware/bluewater/client/playback/nowplaying/view/NowPlayingTvApplication.kt b/projectBlueWater/src/main/java/com/lasthopesoftware/bluewater/client/playback/nowplaying/view/NowPlayingTvApplication.kt
@@ -722,6 +722,7 @@ fun NowPlayingTvApplication(
 				DramaticConnectionInitializationController(
 					connectionSessions,
 				),
+				registerForApplicationMessages,
 			)
 		}
 	}
diff --git a/projectBlueWater/src/test/java/com/lasthopesoftware/bluewater/client/connection/session/GivenALibrary/AndItsConnectionIsStillAlive/when ensuring a different connection is working.kt b/projectBlueWater/src/test/java/com/lasthopesoftware/bluewater/client/connection/session/GivenALibrary/AndItsConnectionIsStillAlive/when ensuring a different connection is working.kt
@@ -7,6 +7,7 @@ import com.lasthopesoftware.bluewater.client.connection.session.initialization.C
 import com.lasthopesoftware.bluewater.shared.promises.extensions.DeferredProgressingPromise
 import com.lasthopesoftware.bluewater.shared.promises.extensions.toExpiringFuture
 import com.lasthopesoftware.promises.extensions.ProgressingPromise
+import com.lasthopesoftware.resources.RecordingApplicationMessageBus
 import com.lasthopesoftware.resources.strings.FakeStringResources
 import io.mockk.every
 import io.mockk.mockk
@@ -29,7 +30,8 @@ class `when ensuring a different connection is working` {
 				mockk {
 					every { promiseLibraryConnection(LibraryId(originalLibraryId)) } returns ProgressingPromise(mockk<LiveServerConnection>())
 					every { promiseLibraryConnection(LibraryId(libraryId)) } returns deferredProgressingPromise
-				}
+				},
+				RecordingApplicationMessageBus(),
 			)
 		)
 	}
diff --git a/projectBlueWater/src/test/java/com/lasthopesoftware/bluewater/client/connection/session/GivenALibrary/AndItsConnectionSettingsChange/when calling the status check again.kt b/projectBlueWater/src/test/java/com/lasthopesoftware/bluewater/client/connection/session/GivenALibrary/AndItsConnectionSettingsChange/when calling the status check again.kt
@@ -0,0 +1,102 @@
+package com.lasthopesoftware.bluewater.client.connection.session.GivenALibrary.AndItsConnectionSettingsChange
+
+import com.lasthopesoftware.bluewater.client.browsing.library.repository.LibraryId
+import com.lasthopesoftware.bluewater.client.connection.BuildingConnectionStatus
+import com.lasthopesoftware.bluewater.client.connection.live.LiveServerConnection
+import com.lasthopesoftware.bluewater.client.connection.session.initialization.ConnectionStatusViewModel
+import com.lasthopesoftware.bluewater.client.connection.settings.changes.ObservableConnectionSettingsLibraryStorage
+import com.lasthopesoftware.bluewater.shared.observables.toCloseable
+import com.lasthopesoftware.bluewater.shared.promises.extensions.DeferredProgressingPromise
+import com.lasthopesoftware.bluewater.shared.promises.extensions.toExpiringFuture
+import com.lasthopesoftware.promises.extensions.ProgressingPromise
+import com.lasthopesoftware.resources.RecordingApplicationMessageBus
+import com.lasthopesoftware.resources.strings.FakeStringResources
+import io.mockk.every
+import io.mockk.mockk
+import org.assertj.core.api.Assertions.assertThat
+import org.junit.jupiter.api.BeforeAll
+import org.junit.jupiter.api.Test
+
+class `when calling the status check again` {
+	companion object {
+		private const val libraryId = 355
+	}
+
+	private val mut by lazy {
+		val deferredProgressingPromise =
+            DeferredProgressingPromise<BuildingConnectionStatus, LiveServerConnection?>()
+
+		val messageBus = RecordingApplicationMessageBus()
+
+		Triple(
+			messageBus,
+			deferredProgressingPromise,
+            ConnectionStatusViewModel(
+                FakeStringResources(
+					gettingLibrary = "VgssfPlPnn1",
+					connectingToServerLibrary = "9M8CP4o3",
+					connected = "3DJCi8HY8",
+				),
+                mockk {
+                    every { promiseLibraryConnection(LibraryId(libraryId)) } returns
+						ProgressingPromise(mockk<LiveServerConnection>()) andThen
+						deferredProgressingPromise
+                },
+				messageBus,
+            )
+		)
+	}
+
+	private val isConnectingHistory = mutableListOf<Boolean>()
+	private val connectionStatuses = mutableListOf<String>()
+
+	private var firstPromisedLibraryConnection: ProgressingPromise<BuildingConnectionStatus, LiveServerConnection?>? = null
+	private var secondPromisedLibraryConnection: ProgressingPromise<BuildingConnectionStatus, LiveServerConnection?>? = null
+
+	private var firstLibraryConnection: LiveServerConnection? = null
+	private var secondLibraryConnection: LiveServerConnection? = null
+
+	@BeforeAll
+	fun act() {
+		val (messageBus, secondDeferredPromise, viewModel) = mut
+
+		viewModel.connectionStatus.subscribe { status -> connectionStatuses.add(status.value) }.toCloseable().use {
+			viewModel.isGettingConnection.subscribe { isConnecting -> isConnectingHistory.add(isConnecting.value) }.toCloseable().use {
+				firstPromisedLibraryConnection = viewModel.promiseLibraryConnection(LibraryId(libraryId))
+
+				messageBus.sendMessage(
+					ObservableConnectionSettingsLibraryStorage.ConnectionSettingsUpdated(LibraryId(libraryId))
+				)
+
+				secondPromisedLibraryConnection = viewModel.promiseLibraryConnection(LibraryId(libraryId))
+
+				secondDeferredPromise.sendProgressUpdate(BuildingConnectionStatus.BuildingConnection)
+				secondDeferredPromise.sendProgressUpdate(BuildingConnectionStatus.SendingWakeSignal)
+				secondDeferredPromise.sendResolution(mockk())
+
+				firstLibraryConnection = firstPromisedLibraryConnection?.toExpiringFuture()?.get()
+				secondLibraryConnection = secondPromisedLibraryConnection?.toExpiringFuture()?.get()
+			}
+		}
+	}
+
+	@Test
+	fun `then is connecting status history is correct`() {
+		assertThat(isConnectingHistory).containsExactly(false, true, false, true, false)
+	}
+
+	@Test
+	fun `then the connecting statuses are correct`() {
+		assertThat(connectionStatuses).containsExactly("", "3DJCi8HY8", "", "9M8CP4o3", "", "3DJCi8HY8")
+	}
+
+	@Test
+	fun `then the correct connection is returned`() {
+		assertThat(firstLibraryConnection).isNotNull
+	}
+
+	@Test
+	fun `then the correct second connection is returned`() {
+		assertThat(secondLibraryConnection).isNotNull
+	}
+}
diff --git a/projectBlueWater/src/test/java/com/lasthopesoftware/bluewater/client/connection/session/GivenALibrary/AndTheConnectionIsBeingInitialized/when calling the status check again with another library.kt b/projectBlueWater/src/test/java/com/lasthopesoftware/bluewater/client/connection/session/GivenALibrary/AndTheConnectionIsBeingInitialized/when calling the status check again with another library.kt
@@ -9,6 +9,7 @@ import com.lasthopesoftware.bluewater.shared.observables.toCloseable
 import com.lasthopesoftware.bluewater.shared.promises.extensions.DeferredProgressingPromise
 import com.lasthopesoftware.bluewater.shared.promises.extensions.toExpiringFuture
 import com.lasthopesoftware.promises.extensions.ProgressingPromise
+import com.lasthopesoftware.resources.RecordingApplicationMessageBus
 import com.lasthopesoftware.resources.strings.FakeStringResources
 import io.mockk.every
 import io.mockk.mockk
@@ -40,6 +41,7 @@ class `when calling the status check again with another library` {
 					}
 					every { promiseLibraryConnection(LibraryId(libraryId)) } returns resolvingConnection
 				},
+				RecordingApplicationMessageBus(),
 			)
 		)
 	}
diff --git a/projectBlueWater/src/test/java/com/lasthopesoftware/bluewater/client/connection/session/GivenALibrary/AndTheConnectionIsBeingInitialized/when calling the status check again.kt b/projectBlueWater/src/test/java/com/lasthopesoftware/bluewater/client/connection/session/GivenALibrary/AndTheConnectionIsBeingInitialized/when calling the status check again.kt
@@ -8,6 +8,7 @@ import com.lasthopesoftware.bluewater.shared.observables.toCloseable
 import com.lasthopesoftware.bluewater.shared.promises.extensions.DeferredProgressingPromise
 import com.lasthopesoftware.bluewater.shared.promises.extensions.toExpiringFuture
 import com.lasthopesoftware.promises.extensions.ProgressingPromise
+import com.lasthopesoftware.resources.RecordingApplicationMessageBus
 import com.lasthopesoftware.resources.strings.FakeStringResources
 import io.mockk.every
 import io.mockk.mockk
@@ -29,6 +30,7 @@ class `when calling the status check again` {
 				mockk {
 					every { promiseLibraryConnection(LibraryId(libraryId)) } returns deferredProgressingPromise
 				},
+				RecordingApplicationMessageBus(),
 			)
 		)
 	}
diff --git a/projectBlueWater/src/test/java/com/lasthopesoftware/bluewater/client/connection/session/GivenALibrary/AndTheConnectionIsBeingInitialized/when cancelling the status check.kt b/projectBlueWater/src/test/java/com/lasthopesoftware/bluewater/client/connection/session/GivenALibrary/AndTheConnectionIsBeingInitialized/when cancelling the status check.kt
@@ -6,6 +6,7 @@ import com.lasthopesoftware.bluewater.client.connection.live.LiveServerConnectio
 import com.lasthopesoftware.bluewater.client.connection.session.initialization.ConnectionStatusViewModel
 import com.lasthopesoftware.bluewater.shared.promises.extensions.DeferredProgressingPromise
 import com.lasthopesoftware.bluewater.shared.promises.extensions.toExpiringFuture
+import com.lasthopesoftware.resources.RecordingApplicationMessageBus
 import com.lasthopesoftware.resources.strings.FakeStringResources
 import io.mockk.every
 import io.mockk.mockk
@@ -29,6 +30,7 @@ class `when cancelling the status check` {
                 mockk {
                     every { promiseLibraryConnection(LibraryId(libraryId)) } returns deferredProgressingPromise
                 },
+				RecordingApplicationMessageBus(),
             )
 		)
 	}
diff --git a/projectBlueWater/src/test/java/com/lasthopesoftware/bluewater/client/connection/session/GivenALibrary/AndTheConnectionIsInitialized/AndTheLibraryChanges/when calling the status check again.kt b/projectBlueWater/src/test/java/com/lasthopesoftware/bluewater/client/connection/session/GivenALibrary/AndTheConnectionIsInitialized/AndTheLibraryChanges/when calling the status check again.kt
@@ -8,17 +8,20 @@ import com.lasthopesoftware.bluewater.shared.observables.toCloseable
 import com.lasthopesoftware.bluewater.shared.promises.extensions.DeferredProgressingPromise
 import com.lasthopesoftware.bluewater.shared.promises.extensions.toExpiringFuture
 import com.lasthopesoftware.promises.extensions.ProgressingPromise
+import com.lasthopesoftware.resources.RecordingApplicationMessageBus
 import com.lasthopesoftware.resources.strings.FakeStringResources
 import io.mockk.every
 import io.mockk.mockk
 import org.assertj.core.api.Assertions.assertThat
 import org.junit.jupiter.api.BeforeAll
 import org.junit.jupiter.api.Test
 
-private const val firstLibraryId = 355
-private const val secondLibraryId = 423
-
 class `when calling the status check again` {
+	companion object {
+		private const val firstLibraryId = 355
+		private const val secondLibraryId = 423
+	}
+
 	private val mut by lazy {
 		val firstDeferredProgressingPromise =
             DeferredProgressingPromise<BuildingConnectionStatus, LiveServerConnection?>()
@@ -39,6 +42,7 @@ class `when calling the status check again` {
                     every { promiseLibraryConnection(LibraryId(firstLibraryId)) } returns firstDeferredProgressingPromise
                     every { promiseLibraryConnection(LibraryId(secondLibraryId)) } returns secondDeferredProgressingPromise
                 },
+				RecordingApplicationMessageBus(),
             )
 		)
 	}
diff --git a/projectBlueWater/src/test/java/com/lasthopesoftware/bluewater/client/connection/session/GivenALibrary/AndTheConnectionIsInitialized/when calling the status check again.kt b/projectBlueWater/src/test/java/com/lasthopesoftware/bluewater/client/connection/session/GivenALibrary/AndTheConnectionIsInitialized/when calling the status check again.kt
@@ -7,6 +7,7 @@ import com.lasthopesoftware.bluewater.client.connection.session.initialization.C
 import com.lasthopesoftware.bluewater.shared.observables.toCloseable
 import com.lasthopesoftware.bluewater.shared.promises.extensions.DeferredProgressingPromise
 import com.lasthopesoftware.bluewater.shared.promises.extensions.toExpiringFuture
+import com.lasthopesoftware.resources.RecordingApplicationMessageBus
 import com.lasthopesoftware.resources.strings.FakeStringResources
 import io.mockk.every
 import io.mockk.mockk
@@ -41,6 +42,7 @@ class `when calling the status check again` {
 						secondDeferredProgressingPromise
 					)
 				},
+				RecordingApplicationMessageBus(),
 			)
 		)
 	}
diff --git a/projectBlueWater/src/test/java/com/lasthopesoftware/bluewater/client/connection/session/GivenALibrary/AndTheConnectionIsNotInitialized/when ensuring the connection is working.kt b/projectBlueWater/src/test/java/com/lasthopesoftware/bluewater/client/connection/session/GivenALibrary/AndTheConnectionIsNotInitialized/when ensuring the connection is working.kt
@@ -6,6 +6,7 @@ import com.lasthopesoftware.bluewater.client.connection.live.LiveServerConnectio
 import com.lasthopesoftware.bluewater.client.connection.session.initialization.ConnectionStatusViewModel
 import com.lasthopesoftware.bluewater.shared.promises.extensions.DeferredProgressingPromise
 import com.lasthopesoftware.bluewater.shared.promises.extensions.toExpiringFuture
+import com.lasthopesoftware.resources.RecordingApplicationMessageBus
 import com.lasthopesoftware.resources.strings.FakeStringResources
 import io.mockk.every
 import io.mockk.mockk
@@ -26,7 +27,8 @@ class `when ensuring the connection is working` {
                 FakeStringResources(),
 				mockk {
 					every { promiseLibraryConnection(LibraryId(libraryId)) } returns deferredProgressingPromise
-				}
+				},
+				RecordingApplicationMessageBus(),
             )
 		)
 	}
diff --git a/projectBlueWater/src/test/java/com/lasthopesoftware/bluewater/client/connection/session/GivenALibrary/AndTheReturnedConnectionIsNull/When calling the status check again.kt b/projectBlueWater/src/test/java/com/lasthopesoftware/bluewater/client/connection/session/GivenALibrary/AndTheReturnedConnectionIsNull/When calling the status check again.kt
diff --git a/projectBlueWater/src/test/java/com/lasthopesoftware/bluewater/client/playback/engine/GivenAPlayingPlaybackEngine/AndPlaybackErrors/When Playback is Resumed.kt b/projectBlueWater/src/test/java/com/lasthopesoftware/bluewater/client/playback/engine/GivenAPlayingPlaybackEngine/AndPlaybackErrors/When Playback is Resumed.kt
diff --git a/projectBlueWater/src/test/java/com/lasthopesoftware/bluewater/client/playback/engine/GivenAPlayingPlaybackEngine/AndPlaybackIsInterrupted/When Playback Is Resumed.kt b/projectBlueWater/src/test/java/com/lasthopesoftware/bluewater/client/playback/engine/GivenAPlayingPlaybackEngine/AndPlaybackIsInterrupted/When Playback Is Resumed.kt

Original file line number	Diff line number	Diff line change
`@@ -343,6 +343,7 @@ fun HandheldApplication(`
`343`	`343`	`DramaticConnectionInitializationController(`
`344`	`344`	`connectionSessions,`
`345`	`345`	`),`
	`346`	`+ registerForApplicationMessages,`
`346`	`347`	`)`
`347`	`348`	`}`
`348`	`349`	`}`
Original file line number	Diff line number	Diff line change
`@@ -101,6 +101,7 @@ class ReusedViewModelRegistry(`
`101`	`101`	`DramaticConnectionInitializationController(`
`102`	`102`	`connectionSessions,`
`103`	`103`	`),`
	`104`	`+ registerForApplicationMessages,`
`104`	`105`	`)`
`105`	`106`	`}`
`106`	`107`
Original file line number	Diff line number	Diff line change
`@@ -77,6 +77,7 @@ import java.io.IOException`
`77`	`77`	`DramaticConnectionInitializationController(`
`78`	`78`	`localApplicationDependencies.connectionSessions,`
`79`	`79`	`),`
	`80`	`+ localApplicationDependencies.registerForApplicationMessages,`
`80`	`81`	`)`
`81`	`82`	`}`
`82`	`83`
Original file line number	Diff line number	Diff line change
`@@ -722,6 +722,7 @@ fun NowPlayingTvApplication(`
`722`	`722`	`DramaticConnectionInitializationController(`
`723`	`723`	`connectionSessions,`
`724`	`724`	`),`
	`725`	`+ registerForApplicationMessages,`
`725`	`726`	`)`
`726`	`727`	`}`
`727`	`728`	`}`
Original file line number	Diff line number	Diff line change
`@@ -7,6 +7,7 @@ import com.lasthopesoftware.bluewater.client.connection.session.initialization.C`
`7`	`7`	`import com.lasthopesoftware.bluewater.shared.promises.extensions.DeferredProgressingPromise`
`8`	`8`	`import com.lasthopesoftware.bluewater.shared.promises.extensions.toExpiringFuture`
`9`	`9`	`import com.lasthopesoftware.promises.extensions.ProgressingPromise`
	`10`	`+import com.lasthopesoftware.resources.RecordingApplicationMessageBus`
`10`	`11`	`import com.lasthopesoftware.resources.strings.FakeStringResources`
`11`	`12`	`import io.mockk.every`
`12`	`13`	`import io.mockk.mockk`
@@ -29,7 +30,8 @@ class `when ensuring a different connection is working` {
`29`	`30`	`mockk {`
`30`	`31`	`every { promiseLibraryConnection(LibraryId(originalLibraryId)) } returns ProgressingPromise(mockk<LiveServerConnection>())`
`31`	`32`	`every { promiseLibraryConnection(LibraryId(libraryId)) } returns deferredProgressingPromise`
`32`		`- }`
	`33`	`+ },`
	`34`	`+ RecordingApplicationMessageBus(),`
`33`	`35`	`)`
`34`	`36`	`)`
`35`	`37`	`}`
Original file line number	Diff line number	Diff line change
`@@ -9,6 +9,7 @@ import com.lasthopesoftware.bluewater.shared.observables.toCloseable`
`9`	`9`	`import com.lasthopesoftware.bluewater.shared.promises.extensions.DeferredProgressingPromise`
`10`	`10`	`import com.lasthopesoftware.bluewater.shared.promises.extensions.toExpiringFuture`
`11`	`11`	`import com.lasthopesoftware.promises.extensions.ProgressingPromise`
	`12`	`+import com.lasthopesoftware.resources.RecordingApplicationMessageBus`
`12`	`13`	`import com.lasthopesoftware.resources.strings.FakeStringResources`
`13`	`14`	`import io.mockk.every`
`14`	`15`	`import io.mockk.mockk`
@@ -40,6 +41,7 @@ class `when calling the status check again with another library` {
`40`	`41`	`}`
`41`	`42`	`every { promiseLibraryConnection(LibraryId(libraryId)) } returns resolvingConnection`
`42`	`43`	`},`
	`44`	`+ RecordingApplicationMessageBus(),`
`43`	`45`	`)`
`44`	`46`	`)`
`45`	`47`	`}`
Original file line number	Diff line number	Diff line change
`@@ -8,6 +8,7 @@ import com.lasthopesoftware.bluewater.shared.observables.toCloseable`
`8`	`8`	`import com.lasthopesoftware.bluewater.shared.promises.extensions.DeferredProgressingPromise`
`9`	`9`	`import com.lasthopesoftware.bluewater.shared.promises.extensions.toExpiringFuture`
`10`	`10`	`import com.lasthopesoftware.promises.extensions.ProgressingPromise`
	`11`	`+import com.lasthopesoftware.resources.RecordingApplicationMessageBus`
`11`	`12`	`import com.lasthopesoftware.resources.strings.FakeStringResources`
`12`	`13`	`import io.mockk.every`
`13`	`14`	`import io.mockk.mockk`
@@ -29,6 +30,7 @@ class `when calling the status check again` {
`29`	`30`	`mockk {`
`30`	`31`	`every { promiseLibraryConnection(LibraryId(libraryId)) } returns deferredProgressingPromise`
`31`	`32`	`},`
	`33`	`+ RecordingApplicationMessageBus(),`
`32`	`34`	`)`
`33`	`35`	`)`
`34`	`36`	`}`