From d013afbf50757d3b634f3cf440213fb1d9d83c63 Mon Sep 17 00:00:00 2001
From: Arty Bishop <bishop.arty@gmail.com>
Date: Mon, 15 Mar 2021 18:10:05 +0000
Subject: [PATCH] Added isNetworkAvailable extension function

---
 app/src/main/AndroidManifest.xml              |  1 +
 .../rtbishop/look4sat/utility/Extensions.kt   | 28 +++++++++++++++++++
 2 files changed, 29 insertions(+)

diff --git a/app/src/main/AndroidManifest.xml b/app/src/main/AndroidManifest.xml
index d0c562cb..88b972cc 100644
--- a/app/src/main/AndroidManifest.xml
+++ b/app/src/main/AndroidManifest.xml
@@ -3,6 +3,7 @@
     package="com.rtbishop.look4sat">
 
     <uses-permission android:name="android.permission.ACCESS_FINE_LOCATION" />
+    <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
     <uses-permission android:name="android.permission.INTERNET" />
 
     <application
diff --git a/app/src/main/java/com/rtbishop/look4sat/utility/Extensions.kt b/app/src/main/java/com/rtbishop/look4sat/utility/Extensions.kt
index dbcfd1de..d68bf90a 100644
--- a/app/src/main/java/com/rtbishop/look4sat/utility/Extensions.kt
+++ b/app/src/main/java/com/rtbishop/look4sat/utility/Extensions.kt
@@ -17,6 +17,11 @@
  */
 package com.rtbishop.look4sat.utility
 
+import android.content.Context
+import android.net.ConnectivityManager
+import android.net.Network
+import android.net.NetworkCapabilities
+import android.net.NetworkRequest
 import android.os.Bundle
 import androidx.annotation.IdRes
 import androidx.navigation.NavController
@@ -24,6 +29,10 @@ import androidx.navigation.NavOptions
 import androidx.navigation.Navigator
 import com.github.amsacode.predict4java.GroundStationPosition
 import com.github.amsacode.predict4java.Satellite
+import kotlinx.coroutines.ExperimentalCoroutinesApi
+import kotlinx.coroutines.channels.awaitClose
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.callbackFlow
 import java.util.concurrent.TimeUnit
 
 fun Long.formatForTimer(): String {
@@ -55,3 +64,22 @@ fun NavController.navigateSafe(
         navigate(resId, args, navOptions, navExtras)
     }
 }
+
+@ExperimentalCoroutinesApi
+fun Context.isNetworkAvailableFlow(): Flow<Boolean> = callbackFlow {
+    val callback = object : ConnectivityManager.NetworkCallback() {
+        override fun onAvailable(network: Network) {
+            offer(true)
+        }
+
+        override fun onLost(network: Network) {
+            offer(false)
+        }
+    }
+    val manager = getSystemService(Context.CONNECTIVITY_SERVICE) as ConnectivityManager
+    manager.registerNetworkCallback(NetworkRequest.Builder().run {
+        addCapability(NetworkCapabilities.NET_CAPABILITY_INTERNET)
+        build()
+    }, callback)
+    awaitClose { manager.unregisterNetworkCallback(callback) }
+}