Created
February 16, 2023 14:59
-
-
Save giovanileitevitor/24a5dc0caa859f786bdd46951c6e5f4a to your computer and use it in GitHub Desktop.
Observe internet connection type (with livedate)
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
//USAGE | |
private lateinit var connectionLiveData: ConnectionLiveData | |
override fun onCreate(savedInstanceState: Bundle?) { | |
super.onCreate(savedInstanceState) | |
binding = ActivityInternetConnectionTestBinding.inflate(layoutInflater) | |
setContentView(binding.root) | |
connectionLiveData = ConnectionLiveData(this) | |
connectionLiveData.observe(this) { isNetworkAvailable -> | |
isNetworkAvailable?.let { | |
updateUI(it) | |
} | |
} | |
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
//Utility class | |
const val TAG = "MyTagConnectionManager" | |
class ConnectionLiveData(context: Context) : LiveData<Boolean>() { | |
private lateinit var networkCallback: ConnectivityManager.NetworkCallback | |
private val connectivityManager = | |
context.getSystemService(CONNECTIVITY_SERVICE) as ConnectivityManager | |
private val validNetworks: MutableSet<Network> = HashSet() | |
private fun checkValidNetworks() { | |
postValue(validNetworks.size > 0) | |
} | |
override fun onActive() { | |
networkCallback = createNetworkCallback() | |
val networkRequest = NetworkRequest.Builder() | |
.addCapability(NET_CAPABILITY_INTERNET) | |
.build() | |
connectivityManager.registerNetworkCallback(networkRequest, networkCallback) | |
} | |
override fun onInactive() { | |
connectivityManager.unregisterNetworkCallback(networkCallback) | |
} | |
private fun createNetworkCallback() = object : ConnectivityManager.NetworkCallback() { | |
override fun onAvailable(network: Network) { | |
Log.d(TAG, "onAvailable: $network") | |
val networkCapabilities = connectivityManager.getNetworkCapabilities(network) | |
val hasInternetCapability = networkCapabilities?.hasCapability(NET_CAPABILITY_INTERNET) | |
Log.d(TAG, "onAvailable: ${network}, $hasInternetCapability") | |
if (hasInternetCapability == true) { | |
// Check if this network actually has internet | |
CoroutineScope(Dispatchers.IO).launch { | |
val hasInternet = DoesNetworkHaveInternet.execute(network.socketFactory) | |
if (hasInternet) { | |
withContext(Dispatchers.Main) { | |
Log.d(TAG, "onAvailable: adding network. $network") | |
validNetworks.add(network) | |
checkValidNetworks() | |
} | |
} | |
} | |
} | |
} | |
override fun onLost(network: Network) { | |
Log.d(TAG, "onLost: $network") | |
validNetworks.remove(network) | |
checkValidNetworks() | |
} | |
} | |
object DoesNetworkHaveInternet { | |
fun execute(socketFactory: SocketFactory): Boolean { | |
// Make sure to execute this on a background thread. | |
return try { | |
Log.d(TAG, "PINGING Google...") | |
val socket = socketFactory.createSocket() ?: throw IOException("Socket is null.") | |
socket.connect(InetSocketAddress("8.8.8.8", 53), 1500) | |
socket.close() | |
Log.d(TAG, "PING success.") | |
true | |
} catch (e: IOException) { | |
Log.e(TAG, "No Internet Connection. $e") | |
false | |
} | |
} | |
} | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment