117 lines
4.3 KiB
Kotlin
117 lines
4.3 KiB
Kotlin
package org.amnezia.vpn.util.net
|
|
|
|
import android.content.Context
|
|
import android.net.ConnectivityManager
|
|
import android.net.ConnectivityManager.NetworkCallback
|
|
import android.net.Network
|
|
import android.net.NetworkCapabilities
|
|
import android.net.NetworkCapabilities.NET_CAPABILITY_INTERNET
|
|
import android.net.NetworkCapabilities.NET_CAPABILITY_VALIDATED
|
|
import android.net.NetworkRequest
|
|
import android.os.Build
|
|
import android.os.Handler
|
|
import androidx.core.content.getSystemService
|
|
import kotlin.LazyThreadSafetyMode.NONE
|
|
import kotlinx.coroutines.delay
|
|
import org.amnezia.vpn.util.Log
|
|
|
|
private const val TAG = "NetworkState"
|
|
|
|
class NetworkState(
|
|
private val context: Context,
|
|
private val onNetworkChange: () -> Unit
|
|
) {
|
|
private var currentNetwork: Network? = null
|
|
private var validated: Boolean = false
|
|
private var isListenerBound = false
|
|
|
|
private val handler: Handler by lazy(NONE) {
|
|
Handler(context.mainLooper)
|
|
}
|
|
|
|
private val connectivityManager: ConnectivityManager by lazy(NONE) {
|
|
context.getSystemService<ConnectivityManager>()!!
|
|
}
|
|
|
|
private val networkRequest: NetworkRequest by lazy(NONE) {
|
|
NetworkRequest.Builder()
|
|
.addCapability(NET_CAPABILITY_INTERNET)
|
|
.build()
|
|
}
|
|
|
|
private val networkCallback: NetworkCallback by lazy(NONE) {
|
|
object : NetworkCallback() {
|
|
override fun onAvailable(network: Network) {
|
|
Log.d(TAG, "onAvailable: $network")
|
|
}
|
|
|
|
override fun onCapabilitiesChanged(network: Network, networkCapabilities: NetworkCapabilities) {
|
|
Log.d(TAG, "onCapabilitiesChanged: $network, $networkCapabilities")
|
|
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
|
|
checkNetworkState(network, networkCapabilities)
|
|
} else {
|
|
handler.post {
|
|
checkNetworkState(network, networkCapabilities)
|
|
}
|
|
}
|
|
}
|
|
|
|
private fun checkNetworkState(network: Network, networkCapabilities: NetworkCapabilities) {
|
|
if (currentNetwork == null) {
|
|
currentNetwork = network
|
|
validated = networkCapabilities.hasCapability(NET_CAPABILITY_VALIDATED)
|
|
} else {
|
|
if (currentNetwork != network) {
|
|
currentNetwork = network
|
|
validated = false
|
|
}
|
|
if (!validated) {
|
|
validated = networkCapabilities.hasCapability(NET_CAPABILITY_VALIDATED)
|
|
if (validated) onNetworkChange()
|
|
}
|
|
}
|
|
}
|
|
|
|
override fun onBlockedStatusChanged(network: Network, blocked: Boolean) {
|
|
Log.d(TAG, "onBlockedStatusChanged: $network, $blocked")
|
|
}
|
|
|
|
override fun onLost(network: Network) {
|
|
Log.d(TAG, "onLost: $network")
|
|
}
|
|
}
|
|
}
|
|
|
|
suspend fun bindNetworkListener() {
|
|
if (isListenerBound) return
|
|
Log.d(TAG, "Bind network listener")
|
|
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.S) {
|
|
connectivityManager.registerBestMatchingNetworkCallback(networkRequest, networkCallback, handler)
|
|
} else if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
|
|
try {
|
|
connectivityManager.requestNetwork(networkRequest, networkCallback, handler)
|
|
} catch (e: SecurityException) {
|
|
Log.e(TAG, "Failed to bind network listener: $e")
|
|
// Android 11 bug: https://issuetracker.google.com/issues/175055271
|
|
if (e.message?.startsWith("Package android does not belong to") == true) {
|
|
delay(1000)
|
|
connectivityManager.requestNetwork(networkRequest, networkCallback, handler)
|
|
} else {
|
|
throw e
|
|
}
|
|
}
|
|
} else {
|
|
connectivityManager.requestNetwork(networkRequest, networkCallback)
|
|
}
|
|
isListenerBound = true
|
|
}
|
|
|
|
fun unbindNetworkListener() {
|
|
if (!isListenerBound) return
|
|
Log.d(TAG, "Unbind network listener")
|
|
connectivityManager.unregisterNetworkCallback(networkCallback)
|
|
isListenerBound = false
|
|
currentNetwork = null
|
|
validated = false
|
|
}
|
|
}
|