|
|
|
|
@ -6,7 +6,6 @@ import android.content.Context.CONNECTIVITY_SERVICE
|
|
|
|
|
import android.net.ConnectivityManager
|
|
|
|
|
import android.net.ConnectivityManager.NetworkCallback
|
|
|
|
|
import android.net.Network
|
|
|
|
|
import android.net.NetworkCapabilities
|
|
|
|
|
import kotlinx.coroutines.GlobalScope
|
|
|
|
|
import kotlinx.coroutines.channels.awaitClose
|
|
|
|
|
import kotlinx.coroutines.flow.SharingStarted
|
|
|
|
|
@ -17,28 +16,26 @@ import javax.inject.Inject
|
|
|
|
|
import javax.inject.Singleton
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Provides a flow that emits `true` when the device has internet connectivity and `false` otherwise.
|
|
|
|
|
* Provides a flow that emits `true` when the device has network connectivity. We won't be sure
|
|
|
|
|
* if there's internet or not, it's by designed so that we don't get false negatives in censorship
|
|
|
|
|
* countries.
|
|
|
|
|
*/
|
|
|
|
|
@Singleton
|
|
|
|
|
class InternetConnectivity @Inject constructor(application: Application) {
|
|
|
|
|
class NetworkConnectivity @Inject constructor(application: Application) {
|
|
|
|
|
val networkAvailable = callbackFlow {
|
|
|
|
|
val connectivityManager = application.getSystemService(ConnectivityManager::class.java)
|
|
|
|
|
|
|
|
|
|
val callback = object : NetworkCallback() {
|
|
|
|
|
override fun onCapabilitiesChanged(
|
|
|
|
|
network: Network,
|
|
|
|
|
networkCapabilities: NetworkCapabilities
|
|
|
|
|
) {
|
|
|
|
|
super.onCapabilitiesChanged(network, networkCapabilities)
|
|
|
|
|
val hasInternet =
|
|
|
|
|
networkCapabilities.hasCapability(NetworkCapabilities.NET_CAPABILITY_VALIDATED)
|
|
|
|
|
Log.v("InternetConnectivity", "Network capabilities changed: hasInternet? $hasInternet")
|
|
|
|
|
trySend(hasInternet)
|
|
|
|
|
override fun onAvailable(network: Network) {
|
|
|
|
|
super.onAvailable(network)
|
|
|
|
|
|
|
|
|
|
Log.v("NetworkConnectivity", "Network become available")
|
|
|
|
|
trySend(true)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
override fun onLost(network: Network) {
|
|
|
|
|
super.onLost(network)
|
|
|
|
|
Log.v("InternetConnectivity", "Network become lost")
|
|
|
|
|
Log.v("NetworkConnectivity", "Network become lost")
|
|
|
|
|
trySend(false)
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
@ -60,15 +57,7 @@ class InternetConnectivity @Inject constructor(application: Application) {
|
|
|
|
|
private fun haveValidNetworkConnection(context: Context): Boolean {
|
|
|
|
|
val cm = context.getSystemService(CONNECTIVITY_SERVICE) as ConnectivityManager
|
|
|
|
|
|
|
|
|
|
// Early exit if we have no active network..
|
|
|
|
|
val activeNetwork = cm.activeNetwork ?: return false
|
|
|
|
|
|
|
|
|
|
// ..otherwise determine what capabilities are available to the active network.
|
|
|
|
|
val networkCapabilities = cm.getNetworkCapabilities(activeNetwork)
|
|
|
|
|
val internetConnectionValid = networkCapabilities != null &&
|
|
|
|
|
networkCapabilities.hasCapability(NetworkCapabilities.NET_CAPABILITY_INTERNET)
|
|
|
|
|
|
|
|
|
|
return internetConnectionValid
|
|
|
|
|
return cm.activeNetwork != null
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
SessionHero01
4 weeks ago
committed by
GitHub