Don't swallow CancellationException

[sproctor]

Add checks that the coroutine is still active in places that can catch CancellationException

What kind of change does this PR introduce?

Bug fix

What is the current behavior?

#889

What is the new behavior?

Throws a CancellationException in Exception handling logic. See: https://medium.com/better-programming/the-silent-killer-thats-crashing-your-coroutines-9171d1e8f79b and Kotlin/kotlinx.coroutines#3658 for the rationale.

[jan-tennert]

Were you able to test if this fixes the problem in #889?

[sproctor]

It fixes #889. The overall behavior seems to be better, but I'm not sure if it was these changes or something else. I'm still getting:

ClosedReceiveChannelException: Channel was closed
Error while listening for messages. Trying again in 7s

I think that might be unavoidable when the access token expires while connected. I guess I could add some logic to close the connection and refresh the token before it expires if this turns out to be problematic.

Thanks for your help and your work on this.

[jan-tennert]

I think that might be unavoidable when the access token expires while connected. I guess I could add some logic to close the connection and refresh the token before it expires if this turns out to be problematic.

Well under normal circumstances, this should not happen as this is already handled:

supabase-kt/Realtime/src/commonMain/kotlin/io/github/jan/supabase/realtime/RealtimeImpl.kt

Lines 96 to 109 in c4163bb

	supabaseClient.pluginManager.getPluginOrNull(Auth)?.sessionStatus?.collect {
	if(status.value == Realtime.Status.CONNECTED) {
	when(it) {
	is SessionStatus.Authenticated -> setAuth(it.session.accessToken)
	is SessionStatus.NotAuthenticated -> {
	if(config.disconnectOnSessionLoss) {
	Realtime.logger.w { "No auth session found, disconnecting from realtime websocket"}
	disconnect()
	}
	}
	else -> {}
	}
	}
	}

The tokens are refreshed via the Auth plugin 20% before their expiration time and Realtime waits for any refreshes or session changes

[jan-tennert]

Thanks!