anyproto/anytype-kotlin
1
0
Fork 0
mirror of https://github.com/anyproto/anytype-kotlin.git synced 2025-06-08 05:47:05 +09:00
Code Activity

DROID-2831 Tech | Implement Device.Network.State.Set (#1915)

Browse source
This commit is contained in:
Konstantin Ivanov 2024-12-13 21:42:47 +01:00 • committed by Evgenii Kozlov
parent da52fee2b5
commit 31da9e2333
16 changed files with 204 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

4
device/src/main/AndroidManifest.xml
View file

@ -1 +1,3 @@
<manifest />
<manifest xmlns:android="http://schemas.android.com/apk/res/android">
<uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
</manifest>

105
device/src/main/java/com/anytypeio/anytype/device/network_type/NetworkConnectionStatus.kt Normal file
View file

@ -0,0 +1,105 @@
package com.anytypeio.anytype.device.network_type
import android.content.Context
import android.net.ConnectivityManager
import android.net.Network
import android.net.NetworkCapabilities
import com.anytypeio.anytype.core_models.DeviceNetworkType
import com.anytypeio.anytype.domain.base.AppCoroutineDispatchers
import com.anytypeio.anytype.domain.block.repo.BlockRepository
import com.anytypeio.anytype.domain.device.NetworkConnectionStatus
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.launch
import kotlinx.coroutines.withContext
import timber.log.Timber
class NetworkConnectionStatusImpl(
context: Context,
private val coroutineScope: CoroutineScope,
private val blockRepository: BlockRepository,
private val dispatchers: AppCoroutineDispatchers
) : NetworkConnectionStatus {
private val connectivityManager =
context.getSystemService(Context.CONNECTIVITY_SERVICE) as? ConnectivityManager
private var isMonitoring = false
private val networkCallback = object : ConnectivityManager.NetworkCallback() {
override fun onAvailable(network: Network) {
// Called when the network is available
updateNetworkState(networkCapabilities = getNetworkCapabilities())
}
override fun onLost(network: Network) {
// Called when the network is disconnected
updateNetworkState(networkCapabilities = getNetworkCapabilities())
}
override fun onCapabilitiesChanged(
network: Network,
networkCapabilities: NetworkCapabilities
) {
// Called when the network capabilities (like Wi-Fi vs Cellular) change
updateNetworkState(networkCapabilities)
}
}
override fun start() {
if (!isMonitoring) {
try {
connectivityManager?.registerDefaultNetworkCallback(networkCallback)
isMonitoring = true
updateNetworkState(networkCapabilities = getNetworkCapabilities())
} catch (
e: RuntimeException
) {
Timber.w(e, "Failed to register network callback")
isMonitoring = false
}
}
}
override fun stop() {
if (isMonitoring) {
try {
connectivityManager?.unregisterNetworkCallback(networkCallback)
isMonitoring = false
} catch (e: Throwable) {
Timber.w(e, "Failed to unregister network callback")
isMonitoring = false
}
}
}
private fun updateNetworkState(networkCapabilities: NetworkCapabilities?) {
coroutineScope.launch {
val networkType = mapNetworkType(networkCapabilities)
withContext(dispatchers.io) {
try {
blockRepository.setDeviceNetworkState(networkType)
} catch (
e: Throwable
) {
Timber.w(e, "Failed to update network state")
}
}
}
}
private fun getNetworkCapabilities(): NetworkCapabilities? {
try {
return connectivityManager?.getNetworkCapabilities(connectivityManager.activeNetwork)
} catch (e: Throwable) {
Timber.w(e, "Failed to get network capabilities")
return null
}
}
private fun mapNetworkType(networkCapabilities: NetworkCapabilities?): DeviceNetworkType =
when {
networkCapabilities == null -> DeviceNetworkType.NOT_CONNECTED
networkCapabilities.hasTransport(NetworkCapabilities.TRANSPORT_WIFI) -> DeviceNetworkType.WIFI
networkCapabilities.hasTransport(NetworkCapabilities.TRANSPORT_CELLULAR) -> DeviceNetworkType.CELLULAR
else -> DeviceNetworkType.NOT_CONNECTED
}
}