v1.4.5 (#174)v1.4.5

* Update/kau (#125)

* Update logger

* Clean imports and bring back reactive libs

* Update dependencies and make billing async

* Misc (#128)

* Update null

* Attempt to improve transparent theme backgrounds

* Update menu

* Move injections to visible method and reduce offset

* Update searchview and logging

* Clean temp strings and add network states

* Move console blacklist to web state

* Change some logs to info

* Move glide loader to onCreate (#135)

* Remove commit number increments (#139)

* Fix/misc (#140)

* Add canadian locale to toLowerCase

* Add try catch to JsAssets

* Disable error throwing for bad search subject

* Log more throwables quietly

* Check internet connection before fetching username

* Remove name check in frost notifications

* Add activity lifecycle logger

* Add rxjava to lib showcase

* Move network checker to io thread (#150)

* Update dependency

* Blank

* Feature/jsoup debugger (#152)

* Create debugger

* Update debugger content

* Create debugging logic

* Finalize and test debugger

* Add reload listener

* Fix/pro crash without play store (#155)

* Update changelog

* Check if iab service exists

* Add checker before launching play store request

* Separate strings

* Enhancement/message notifications (#157)

* Map message notifs to the headless html extractor

* Update strings

* Bring im notifs out of alpha

* Update changelog

* Remove confirmation dialog (#159)

* Separate message notifications and add click intents (#171)

* Separate message notifications and add click intent for group notifications

* Add comments and finalize

* Feature/scroll down on message thread (#172)

* Add hook for scroll

* Update changelog

* Add custom navdrawer layout (#173)

* Add faq for auto play

* Update changelog

* Fix page banner bg (#163)

1 files changed, 43 insertions, 0 deletions

diff --git a/app/src/main/kotlin/com/pitchedapps/frost/activities/BaseActivity.kt b/app/src/main/kotlin/com/pitchedapps/frost/activities/BaseActivity.kt
index 77a20d04..c7ca5ec7 100644
--- a/app/src/main/kotlin/com/pitchedapps/frost/activities/BaseActivity.kt
+++ b/app/src/main/kotlin/com/pitchedapps/frost/activities/BaseActivity.kt
@@ -2,10 +2,16 @@ package com.pitchedapps.frost.activities
 
 import android.os.Bundle
 import ca.allanwang.kau.internal.KauBaseActivity
+import com.github.pwittchen.reactivenetwork.library.rx2.Connectivity
+import com.github.pwittchen.reactivenetwork.library.rx2.ReactiveNetwork
 import com.pitchedapps.frost.R
+import com.pitchedapps.frost.utils.L
 import com.pitchedapps.frost.utils.Prefs
 import com.pitchedapps.frost.utils.materialDialogThemed
 import com.pitchedapps.frost.utils.setFrostTheme
+import io.reactivex.android.schedulers.AndroidSchedulers
+import io.reactivex.disposables.Disposable
+import io.reactivex.schedulers.Schedulers
 
 /**
  * Created by Allan Wang on 2017-06-12.
@@ -29,4 +35,41 @@ abstract class BaseActivity : KauBaseActivity() {
         setFrostTheme()
     }
 
+    private var networkDisposable: Disposable? = null
+    private var networkConsumer: ((Connectivity) -> Unit)? = null
+
+    fun setNetworkObserver(consumer: (connectivity: Connectivity) -> Unit) {
+        this.networkConsumer = consumer
+    }
+
+    fun observeNetworkConnectivity() {
+        val consumer = networkConsumer ?: return
+        networkDisposable = ReactiveNetwork.observeNetworkConnectivity(applicationContext)
+                .subscribeOn(Schedulers.io())
+                .observeOn(AndroidSchedulers.mainThread())
+                .subscribe {
+                    connectivity: Connectivity ->
+                    connectivity.apply {
+                        L.d("Network connectivity changed: isAvailable: $isAvailable isRoaming: $isRoaming")
+                        consumer(connectivity)
+                    }
+                }
+    }
+
+    fun disposeNetworkConnectivity() {
+        if (!(networkDisposable?.isDisposed ?: true))
+            networkDisposable?.dispose()
+        networkDisposable = null
+    }
+
+    override fun onResume() {
+        super.onResume()
+        disposeNetworkConnectivity()
+        observeNetworkConnectivity()
+    }
+
+    override fun onPause() {
+        super.onPause()
+        disposeNetworkConnectivity()
+    }
 }
\ No newline at end of file