Refactor RxPermissions

Author: li2

app/src/main/java/me/li2/android/commonsample/MainActivity.kt

@@ -1,14 +1,15 @@
 package me.li2.android.commonsample
 
+import android.hardware.Sensor
 import android.os.Bundle
 import android.widget.Button
 import androidx.appcompat.app.AppCompatActivity
 import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers
 import io.reactivex.rxjava3.disposables.Disposable
 import io.reactivex.rxjava3.schedulers.Schedulers
-import me.li2.android.common.rx.bluetoothStateChanges
-import me.li2.android.common.rx.sdcardStateChanges
+import me.li2.android.common.bluetooth.bluetoothStateChanges
 import me.li2.android.common.rx.subscribeOnLifecycle
+import me.li2.android.common.sdcard.sdcardStateChanges
 import me.li2.android.common.sensor.sensorChanges
 import timber.log.Timber.d
 import java.util.concurrent.TimeUnit
@@ -33,7 +34,7 @@ class MainActivity : AppCompatActivity() {
     }
 
     private fun trySensorChangesFlowable() {
-        sensorDisposable = sensorChanges()
+        sensorDisposable = sensorChanges(Sensor.TYPE_LINEAR_ACCELERATION)
             .doOnSubscribe { d("doOnSubscribe") }
             .doOnCancel { d("doOnCancel") }
             .throttleFirst(5, TimeUnit.SECONDS)

common/src/main/java/me/li2/android/common/rx/RxBluetooth.kt renamed to common/src/main/java/me/li2/android/common/bluetooth/BluetoothStateChangesObservable.kt

@@ -4,13 +4,15 @@
  */
 @file:Suppress("unused")
 
-package me.li2.android.common.rx
+package me.li2.android.common.bluetooth
 
 import android.annotation.SuppressLint
 import android.bluetooth.BluetoothAdapter.*
 import android.content.Context
 import androidx.fragment.app.FragmentActivity
 import io.reactivex.rxjava3.core.Observable
+import me.li2.android.common.framework.PermissionResult
+import me.li2.android.common.framework.checkAndRequestBluetoothPermission
 import me.li2.android.common.framework.onBroadcast
 import me.li2.android.common.logic.orFalse
 

common/src/main/java/me/li2/android/common/framework/RxPermissions.kt

@@ -0,0 +1,85 @@
+/*
+ * Created by Weiyi Li on 16/03/20.
+ * https://github.com/li2
+ */
+@file:Suppress("unused")
+
+package me.li2.android.common.framework
+
+import android.Manifest.permission.*
+import android.app.Activity
+import android.content.Context
+import android.content.DialogInterface
+import android.content.pm.PackageManager.PERMISSION_GRANTED
+import androidx.appcompat.app.AlertDialog
+import androidx.core.content.ContextCompat
+import com.tbruyelle.rxpermissions2.RxPermissions
+import hu.akarnokd.rxjava3.bridge.RxJavaBridge
+import io.reactivex.rxjava3.core.Observable
+import me.li2.android.common.framework.PermissionResult.*
+import me.li2.android.common.rx.buttonClicks
+
+enum class PermissionResult {
+    GRANTED,
+    DENIED,
+    DENIED_NOT_ASK_AGAIN,
+}
+
+fun Context.isPermissionGranted(permission: String): Boolean {
+    return ContextCompat.checkSelfPermission(this, permission) == PERMISSION_GRANTED
+}
+
+fun Activity.requestPermission(permission: String): Observable<PermissionResult> =
+    requestPermissions(listOf(permission))
+
+fun Activity.requestPermissions(permissions: List<String>): Observable<PermissionResult> =
+    // todo remove RxJavaBridge when RxPermissions migrated to RxJava3
+    RxJavaBridge
+        .toV3Observable(RxPermissions(this).requestEach(*permissions.toTypedArray()))
+        .map { permission ->
+            when {
+                // permission is granted
+                permission.granted -> GRANTED
+                // Denied permission without ask never again
+                permission.shouldShowRequestPermissionRationale -> DENIED
+                // Denied permission with ask never again, need to go to the settings
+                else -> DENIED_NOT_ASK_AGAIN
+            }
+        }
+
+fun Activity.checkAndRequestPermission(
+    permission: String,
+    prompt: AlertDialog? = null
+): Observable<PermissionResult> {
+    return Observable.just(isPermissionGranted(permission))
+        .flatMap { granted ->
+            when {
+                !granted && prompt != null -> {
+                    prompt.also { it.show() }.buttonClicks().flatMap { which ->
+                        if (which == DialogInterface.BUTTON_POSITIVE) {
+                            requestPermission(permission)
+                        } else {
+                            Observable.just(DENIED)
+                        }
+                    }
+                }
+                !granted && prompt == null -> requestPermission(permission)
+                else -> Observable.just(GRANTED)
+            }
+        }
+}
+
+/*
+ * ACCESS_FINE_LOCATION for both NETWORK_PROVIDER and GPS_PROVIDER
+ * ACCESS_COARSE_LOCATION only for NETWORK_PROVIDER.
+ */
+fun Context.isLocationPermissionGranted(): Boolean = isPermissionGranted(ACCESS_FINE_LOCATION)
+
+fun Activity.checkAndRequestLocationPermission(prompt: AlertDialog? = null): Observable<PermissionResult> =
+    checkAndRequestPermission(ACCESS_FINE_LOCATION, prompt)
+
+fun Activity.checkAndRequestCameraPermission(prompt: AlertDialog? = null): Observable<PermissionResult> =
+    checkAndRequestPermission(CAMERA, prompt)
+
+fun Activity.checkAndRequestBluetoothPermission(prompt: AlertDialog? = null): Observable<PermissionResult> =
+    checkAndRequestPermission(BLUETOOTH, prompt)