Support execute commands in magiskhide env

Credits to #1454

app/build.gradle

@@ -19,16 +19,14 @@ android {
         multiDexEnabled true
         versionName configProps['appVersion']
         versionCode configProps['appVersionCode'] as Integer
-        javaCompileOptions {
-            annotationProcessorOptions {
-                argument('butterknife.debuggable', 'false')
-            }
-        }
     }
 
     buildTypes {
         release {
-            proguardFiles getDefaultProguardFile('proguard-android-optimize.txt'), 'proguard-rules.pro'
+            minifyEnabled true
+            shrinkResources true
+            proguardFiles getDefaultProguardFile('proguard-android-optimize.txt'),
+                    'proguard-rules.pro', 'proguard-kotlin.pro'
         }
     }
 
@@ -47,6 +45,10 @@ android {
     }
 }
 
+androidExtensions {
+    experimental = true
+}
+
 dependencies {
     implementation fileTree(include: ['*.jar'], dir: 'libs')
     implementation project(':net')
@@ -58,26 +60,43 @@ dependencies {
     implementation 'com.github.skoumalcz:teanity:0.3.3'
     implementation 'com.ncapdevi:frag-nav:3.2.0'
 
-    def markwonVersion = '3.0.1'
-    implementation "ru.noties.markwon:core:${markwonVersion}"
-    implementation "ru.noties.markwon:html:${markwonVersion}"
-    implementation "ru.noties.markwon:image-svg:${markwonVersion}"
+    def vMarkwon = '3.0.1'
+    implementation "ru.noties.markwon:core:${vMarkwon}"
+    implementation "ru.noties.markwon:html:${vMarkwon}"
+    implementation "ru.noties.markwon:image-svg:${vMarkwon}"
 
-    def libsuVersion = '2.5.0'
-    implementation "com.github.topjohnwu.libsu:core:${libsuVersion}"
-    implementation "com.github.topjohnwu.libsu:io:${libsuVersion}"
+    def vLibsu = '2.5.0'
+    implementation "com.github.topjohnwu.libsu:core:${vLibsu}"
+    implementation "com.github.topjohnwu.libsu:io:${vLibsu}"
 
-    def koin = "2.0.0-rc-2"
-    implementation "org.koin:koin-core:${koin}"
-    implementation "org.koin:koin-android:${koin}"
-    implementation "org.koin:koin-androidx-viewmodel:${koin}"
+    def vKoin = "2.0.1"
+    implementation "org.koin:koin-core:${vKoin}"
+    implementation "org.koin:koin-android:${vKoin}"
+    implementation "org.koin:koin-androidx-viewmodel:${vKoin}"
+
+    def vRetrofit = "2.5.0"
+    implementation "com.squareup.retrofit2:retrofit:${vRetrofit}"
+    implementation "com.squareup.retrofit2:converter-moshi:${vRetrofit}"
+    implementation "com.squareup.retrofit2:adapter-rxjava2:${vRetrofit}"
+
+    def vOkHttp = "3.12.0"
+    implementation "com.squareup.okhttp3:okhttp:${vOkHttp}"
+    implementation "com.squareup.okhttp3:logging-interceptor:${vOkHttp}"
+
+    def vMoshi = "1.8.0"
+    implementation "com.squareup.moshi:moshi:${vMoshi}"
+
+    def vKotshi = "2.0.1"
+    implementation "se.ansman.kotshi:api:${vKotshi}"
+    kapt "se.ansman.kotshi:compiler:${vKotshi}"
 
     implementation 'androidx.constraintlayout:constraintlayout:1.1.3'
+    implementation 'androidx.browser:browser:1.0.0'
     implementation 'androidx.preference:preference:1.0.0'
     implementation 'androidx.recyclerview:recyclerview:1.1.0-alpha05'
     implementation 'androidx.cardview:cardview:1.0.0'
-    implementation 'com.google.android.material:material:1.1.0-alpha06'
     implementation 'androidx.work:work-runtime:2.0.1'
     implementation 'androidx.transition:transition:1.2.0-alpha01'
     implementation 'androidx.multidex:multidex:2.0.1'
+    implementation 'com.google.android.material:material:1.1.0-alpha06'
 }

app/proguard-kotlin.pro

@@ -0,0 +1,20 @@
+## So every class is case insensitive to avoid some bizare problems
+-dontusemixedcaseclassnames
+
+## If reflection issues come up uncomment this, that should temporarily fix it
+#-keep class kotlin.** { *; }
+#-keep class kotlin.Metadata { *; }
+#-keepclassmembers class kotlin.Metadata {
+#    public <methods>;
+#}
+
+## Never warn about Kotlin, it should work as-is
+-dontwarn kotlin.**
+
+## Removes runtime null checks - doesn't really matter if it crashes on kotlin or java NPE
+-assumenosideeffects class kotlin.jvm.internal.Intrinsics {
+    static void checkParameterIsNotNull(java.lang.Object, java.lang.String);
+}
+
+## Useless option for dex
+-dontpreverify

app/proguard-rules.pro

@@ -16,6 +16,9 @@
 #   public *;
 #}
 
+# Retrofit classes
+-keep,allowobfuscation class com.topjohnwu.magisk.data.network.*
+
 # Snet
 -keepclassmembers class com.topjohnwu.magisk.utils.ISafetyNetHelper { *; }
 -keep,allowobfuscation interface com.topjohnwu.magisk.utils.ISafetyNetHelper$Callback
@@ -35,6 +38,7 @@
 -keepclassmembers class com.topjohnwu.signing.BootSigner { *; }
 
 # Strip logging
+-assumenosideeffects class timber.log.Timber.Tree { *; }
 -assumenosideeffects class com.topjohnwu.magisk.utils.Logger {
   public *** debug(...);
 }

app/src/main/java/com/topjohnwu/magisk/App.kt

@@ -4,22 +4,18 @@ import android.annotation.SuppressLint
 import android.app.Activity
 import android.app.Application
 import android.content.Context
-import android.content.SharedPreferences
 import android.content.res.Configuration
 import android.os.AsyncTask
 import android.os.Build
 import android.os.Bundle
 import androidx.appcompat.app.AppCompatDelegate
 import androidx.multidex.MultiDex
-import com.topjohnwu.magisk.data.database.MagiskDB
-import com.topjohnwu.magisk.data.database.RepoDatabaseHelper
 import com.topjohnwu.magisk.di.koinModules
 import com.topjohnwu.magisk.utils.LocaleManager
 import com.topjohnwu.magisk.utils.RootUtils
 import com.topjohnwu.magisk.utils.inject
 import com.topjohnwu.net.Networking
 import com.topjohnwu.superuser.Shell
-import org.koin.android.ext.android.inject
 import org.koin.android.ext.koin.androidContext
 import org.koin.core.context.startKoin
 import timber.log.Timber
@@ -29,13 +25,6 @@ open class App : Application(), Application.ActivityLifecycleCallbacks {
 
     lateinit var protectedContext: Context
 
-    @Deprecated("Use dependency injection")
-    val prefs: SharedPreferences by inject()
-    @Deprecated("Use dependency injection")
-    val DB: MagiskDB by inject()
-    @Deprecated("Use dependency injection")
-    val repoDB: RepoDatabaseHelper by inject()
-
     @Volatile
     private var foreground: Activity? = null
 

app/src/main/java/com/topjohnwu/magisk/ClassMap.java

@@ -1,31 +0,0 @@
-package com.topjohnwu.magisk;
-
-import com.topjohnwu.magisk.model.download.DownloadModuleService;
-import com.topjohnwu.magisk.model.receiver.GeneralReceiver;
-import com.topjohnwu.magisk.model.update.UpdateCheckService;
-import com.topjohnwu.magisk.ui.MainActivity;
-import com.topjohnwu.magisk.ui.SplashActivity;
-import com.topjohnwu.magisk.ui.flash.FlashActivity;
-import com.topjohnwu.magisk.ui.surequest.SuRequestActivity;
-
-import java.util.HashMap;
-import java.util.Map;
-
-public class ClassMap {
-    private static Map<Class, Class> classMap = new HashMap<>();
-
-    static {
-        classMap.put(App.class, a.e.class);
-        classMap.put(MainActivity.class, a.b.class);
-        classMap.put(SplashActivity.class, a.c.class);
-        classMap.put(FlashActivity.class, a.f.class);
-        classMap.put(UpdateCheckService.class, a.g.class);
-        classMap.put(GeneralReceiver.class, a.h.class);
-        classMap.put(DownloadModuleService.class, a.j.class);
-        classMap.put(SuRequestActivity.class, a.m.class);
-    }
-    
-    public static <T> Class<T> get(Class c) {
-        return classMap.get(c);
-    }
-}

app/src/main/java/com/topjohnwu/magisk/ClassMap.kt

@@ -0,0 +1,27 @@
+package com.topjohnwu.magisk
+
+import com.topjohnwu.magisk.model.download.DownloadModuleService
+import com.topjohnwu.magisk.model.receiver.GeneralReceiver
+import com.topjohnwu.magisk.model.update.UpdateCheckService
+import com.topjohnwu.magisk.ui.MainActivity
+import com.topjohnwu.magisk.ui.SplashActivity
+import com.topjohnwu.magisk.ui.flash.FlashActivity
+import com.topjohnwu.magisk.ui.surequest.SuRequestActivity
+
+object ClassMap {
+    private val map = mapOf(
+        App::class.java to a.e::class.java,
+        MainActivity::class.java to a.b::class.java,
+        SplashActivity::class.java to a.c::class.java,
+        FlashActivity::class.java to a.f::class.java,
+        UpdateCheckService::class.java to a.g::class.java,
+        GeneralReceiver::class.java to a.h::class.java,
+        DownloadModuleService::class.java to a.j::class.java,
+        SuRequestActivity::class.java to a.m::class.java
+    )
+
+    @JvmStatic
+    operator fun get(c: Class<*>): Class<*>? {
+        return map.getOrElse(c) { null } //as? Class<T>
+    }
+}

app/src/main/java/com/topjohnwu/magisk/ConfigLeanback.kt

@@ -0,0 +1,52 @@
+package com.topjohnwu.magisk
+
+import android.content.Context
+import android.content.SharedPreferences
+import androidx.annotation.AnyThread
+import androidx.annotation.WorkerThread
+import com.skoumal.teanity.extensions.subscribeK
+import com.topjohnwu.magisk.data.repository.SettingRepository
+import com.topjohnwu.magisk.data.repository.StringRepository
+import com.topjohnwu.magisk.di.Protected
+import com.topjohnwu.magisk.utils.inject
+
+object ConfigLeanback {
+
+    @JvmStatic
+    val protectedContext: Context by inject(Protected)
+    @JvmStatic
+    val prefs: SharedPreferences by inject()
+
+    private val settingRepo: SettingRepository by inject()
+    private val stringRepo: StringRepository by inject()
+
+    @JvmStatic
+    @AnyThread
+    fun put(key: String, value: Int) {
+        settingRepo.put(key, value).subscribeK()
+    }
+
+    @JvmStatic
+    @WorkerThread
+    fun get(key: String, defaultValue: Int): Int =
+        settingRepo.fetch(key, defaultValue).blockingGet()
+
+    @JvmStatic
+    @AnyThread
+    fun put(key: String, value: String?) {
+        val task = value?.let { stringRepo.put(key, it) } ?: stringRepo.delete(key)
+        task.subscribeK()
+    }
+
+    @JvmStatic
+    @WorkerThread
+    fun get(key: String, defaultValue: String?): String =
+        stringRepo.fetch(key, defaultValue.orEmpty()).blockingGet()
+
+    @JvmStatic
+    @AnyThread
+    fun delete(key: String) {
+        settingRepo.delete(key).subscribeK()
+    }
+
+}

app/src/main/java/com/topjohnwu/magisk/Const.java

@@ -1,102 +0,0 @@
-package com.topjohnwu.magisk;
-
-import android.os.Environment;
-import android.os.Process;
-
-import java.io.File;
-
-public class Const {
-
-    public static final String DEBUG_TAG = "MagiskManager";
-
-    // APK content
-    public static final String ANDROID_MANIFEST = "AndroidManifest.xml";
-
-    public static final String SU_KEYSTORE_KEY = "su_key";
-
-    // Paths
-    public static final String MAGISK_PATH = "/sbin/.magisk/img";
-    public static final File EXTERNAL_PATH;
-    public static File MAGISK_DISABLE_FILE;
-
-    static {
-        MAGISK_DISABLE_FILE = new File("xxx");
-        EXTERNAL_PATH = Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS);
-        EXTERNAL_PATH.mkdirs();
-    }
-
-    public static final String TMP_FOLDER_PATH = "/dev/tmp";
-    public static final String MAGISK_LOG = "/cache/magisk.log";
-    public static final String MANAGER_CONFIGS = ".tmp.magisk.config";
-
-    // Versions
-    public static final int UPDATE_SERVICE_VER = 1;
-    public static final int SNET_EXT_VER = 12;
-
-    public static final int USER_ID = Process.myUid() / 100000;
-
-    // Generic
-    public static final String MAGISK_INSTALL_LOG_FILENAME = "magisk_install_log_%s.log";
-
-    public static final class MAGISK_VER {
-        public static final int MIN_SUPPORT = 18000;
-    }
-
-    public static class ID {
-        public static final int FETCH_ZIP = 2;
-        public static final int SELECT_BOOT = 3;
-
-        // notifications
-        public static final int MAGISK_UPDATE_NOTIFICATION_ID = 4;
-        public static final int APK_UPDATE_NOTIFICATION_ID = 5;
-        public static final int DTBO_NOTIFICATION_ID = 7;
-        public static final int HIDE_MANAGER_NOTIFICATION_ID = 8;
-        public static final String UPDATE_NOTIFICATION_CHANNEL = "update";
-        public static final String PROGRESS_NOTIFICATION_CHANNEL = "progress";
-        public static final String CHECK_MAGISK_UPDATE_WORKER_ID = "magisk_update";
-    }
-
-    public static class Url {
-        private static String getRaw(String where, String name) {
-            return String.format("https://raw.githubusercontent.com/topjohnwu/magisk_files/%s/%s", where, name);
-        }
-        public static final String STABLE_URL = getRaw("master", "stable.json");
-        public static final String BETA_URL = getRaw("master", "beta.json");
-        public static final String CANARY_URL = getRaw("master", "canary_builds/release.json");
-        public static final String CANARY_DEBUG_URL = getRaw("master", "canary_builds/canary.json");
-        public static final String REPO_URL = "https://api.github.com/users/Magisk-Modules-Repo/repos?per_page=100&sort=pushed&page=%d";
-        public static final String FILE_URL = "https://raw.githubusercontent.com/Magisk-Modules-Repo/%s/master/%s";
-        public static final String ZIP_URL = "https://github.com/Magisk-Modules-Repo/%s/archive/master.zip";
-        public static final String MODULE_INSTALLER = "https://raw.githubusercontent.com/topjohnwu/Magisk/master/scripts/module_installer.sh";
-        public static final String PAYPAL_URL = "https://www.paypal.me/topjohnwu";
-        public static final String PATREON_URL = "https://www.patreon.com/topjohnwu";
-        public static final String TWITTER_URL = "https://twitter.com/topjohnwu";
-        public static final String XDA_THREAD = "http://forum.xda-developers.com/showthread.php?t=3432382";
-        public static final String SOURCE_CODE_URL = "https://github.com/topjohnwu/Magisk";
-        public static final String SNET_URL = getRaw("b66b1a914978e5f4c4bbfd74a59f4ad371bac107", "snet.apk");
-        public static final String BOOTCTL_URL = getRaw("9c5dfc1b8245c0b5b524901ef0ff0f8335757b77", "bootctl");
-    }
-
-    public static class Key {
-        // others
-        public static final String LINK_KEY = "Link";
-        public static final String IF_NONE_MATCH = "If-None-Match";
-        // intents
-        public static final String OPEN_SECTION = "section";
-        public static final String INTENT_SET_NAME = "filename";
-        public static final String INTENT_SET_LINK = "link";
-        public static final String FLASH_ACTION = "action";
-        public static final String BROADCAST_MANAGER_UPDATE = "manager_update";
-        public static final String BROADCAST_REBOOT = "reboot";
-    }
-
-    public static class Value {
-        public static final String FLASH_ZIP = "flash";
-        public static final String PATCH_FILE = "patch";
-        public static final String FLASH_MAGISK = "magisk";
-        public static final String FLASH_INACTIVE_SLOT = "slot";
-        public static final String UNINSTALL = "uninstall";
-    }
-
-
-}

app/src/main/java/com/topjohnwu/magisk/Const.kt

@@ -0,0 +1,105 @@
+package com.topjohnwu.magisk
+
+import android.os.Environment
+import android.os.Process
+
+import java.io.File
+
+object Const {
+
+    const val DEBUG_TAG = "MagiskManager"
+
+    // APK content
+    const val ANDROID_MANIFEST = "AndroidManifest.xml"
+
+    const val SU_KEYSTORE_KEY = "su_key"
+
+    // Paths
+    const val MAGISK_PATH = "/sbin/.magisk/img"
+    @JvmField
+    val EXTERNAL_PATH: File =
+        Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS)
+    @JvmField
+    var MAGISK_DISABLE_FILE: File = File("xxx")
+
+    const val TMP_FOLDER_PATH = "/dev/tmp"
+    const val MAGISK_LOG = "/cache/magisk.log"
+    const val MANAGER_CONFIGS = ".tmp.magisk.config"
+
+    // Versions
+    const val UPDATE_SERVICE_VER = 1
+    const val SNET_EXT_VER = 12
+
+    @JvmField
+    val USER_ID = Process.myUid() / 100000
+
+    // Generic
+    const val MAGISK_INSTALL_LOG_FILENAME = "magisk_install_log_%s.log"
+
+    init {
+        EXTERNAL_PATH.mkdirs()
+    }
+
+    object MagiskVersion {
+        const val MIN_SUPPORT = 18000
+    }
+
+    object ID {
+        const val FETCH_ZIP = 2
+        const val SELECT_BOOT = 3
+
+        // notifications
+        const val MAGISK_UPDATE_NOTIFICATION_ID = 4
+        const val APK_UPDATE_NOTIFICATION_ID = 5
+        const val DTBO_NOTIFICATION_ID = 7
+        const val HIDE_MANAGER_NOTIFICATION_ID = 8
+        const val UPDATE_NOTIFICATION_CHANNEL = "update"
+        const val PROGRESS_NOTIFICATION_CHANNEL = "progress"
+        const val CHECK_MAGISK_UPDATE_WORKER_ID = "magisk_update"
+    }
+
+    object Url {
+        @Deprecated("This shouldn't be used. There's literally no need for it")
+        const val REPO_URL =
+            "https://api.github.com/users/Magisk-Modules-Repo/repos?per_page=100&sort=pushed&page=%d"
+        const val FILE_URL = "https://raw.githubusercontent.com/Magisk-Modules-Repo/%s/master/%s"
+        const val ZIP_URL = "https://github.com/Magisk-Modules-Repo/%s/archive/master.zip"
+        const val MODULE_INSTALLER =
+            "https://raw.githubusercontent.com/topjohnwu/Magisk/master/scripts/module_installer.sh"
+        const val PAYPAL_URL = "https://www.paypal.me/topjohnwu"
+        const val PATREON_URL = "https://www.patreon.com/topjohnwu"
+        const val TWITTER_URL = "https://twitter.com/topjohnwu"
+        const val XDA_THREAD = "http://forum.xda-developers.com/showthread.php?t=3432382"
+        const val SOURCE_CODE_URL = "https://github.com/topjohnwu/Magisk"
+        @JvmField
+        val SNET_URL = getRaw("b66b1a914978e5f4c4bbfd74a59f4ad371bac107", "snet.apk")
+        @JvmField
+        val BOOTCTL_URL = getRaw("9c5dfc1b8245c0b5b524901ef0ff0f8335757b77", "bootctl")
+
+        private fun getRaw(where: String, name: String) =
+            "https://raw.githubusercontent.com/topjohnwu/magisk_files/%s/%s".format(where, name)
+    }
+
+    object Key {
+        // others
+        const val LINK_KEY = "Link"
+        const val IF_NONE_MATCH = "If-None-Match"
+        // intents
+        const val OPEN_SECTION = "section"
+        const val INTENT_SET_NAME = "filename"
+        const val INTENT_SET_LINK = "link"
+        const val FLASH_ACTION = "action"
+        const val BROADCAST_MANAGER_UPDATE = "manager_update"
+        const val BROADCAST_REBOOT = "reboot"
+    }
+
+    object Value {
+        const val FLASH_ZIP = "flash"
+        const val PATCH_FILE = "patch"
+        const val FLASH_MAGISK = "magisk"
+        const val FLASH_INACTIVE_SLOT = "slot"
+        const val UNINSTALL = "uninstall"
+    }
+
+
+}

app/src/main/java/com/topjohnwu/magisk/Constants.kt

@@ -0,0 +1,20 @@
+package com.topjohnwu.magisk
+
+import android.os.Process
+
+object Constants {
+
+    // Paths
+    val MAGISK_PATH = "/sbin/.magisk/img"
+    val MAGISK_LOG = "/cache/magisk.log"
+
+    val USER_ID get() = Process.myUid() / 100000
+
+    const val SNET_REVISION = "b66b1a914978e5f4c4bbfd74a59f4ad371bac107"
+    const val BOOTCTL_REVISION = "9c5dfc1b8245c0b5b524901ef0ff0f8335757b77"
+
+    const val GITHUB_URL = "https://github.com/"
+    const val GITHUB_API_URL = "https://api.github.com/"
+    const val GITHUB_RAW_API_URL = "https://raw.githubusercontent.com/"
+
+}

app/src/main/java/com/topjohnwu/magisk/KConfig.kt

@@ -0,0 +1,47 @@
+package com.topjohnwu.magisk
+
+import android.content.Context
+import com.topjohnwu.magisk.KConfig.UpdateChannel.STABLE
+import com.topjohnwu.magisk.di.Protected
+import com.topjohnwu.magisk.model.preference.PreferenceModel
+import com.topjohnwu.magisk.utils.inject
+
+object KConfig : PreferenceModel() {
+
+    override val context: Context by inject(Protected)
+    override val fileName: String = "${context.packageName}_preferences"
+
+    private var internalUpdateChannel by preference(Config.Key.UPDATE_CHANNEL, STABLE.id.toString())
+    var useCustomTabs by preference("useCustomTabs", true)
+    @JvmStatic
+    var customUpdateChannel by preference(Config.Key.CUSTOM_CHANNEL, "")
+
+    @JvmStatic
+    var updateChannel: UpdateChannel
+        get() = UpdateChannel.byId(internalUpdateChannel.toIntOrNull() ?: STABLE.id)
+        set(value) {
+            internalUpdateChannel = value.id.toString()
+        }
+
+    internal const val DEFAULT_CHANNEL = "topjohnwu/magisk_files"
+
+    enum class UpdateChannel(val id: Int) {
+
+        STABLE(Config.Value.STABLE_CHANNEL),
+        BETA(Config.Value.BETA_CHANNEL),
+        CANARY(Config.Value.CANARY_CHANNEL),
+        CANARY_DEBUG(Config.Value.CANARY_DEBUG_CHANNEL),
+        CUSTOM(Config.Value.CUSTOM_CHANNEL);
+
+        companion object {
+            fun byId(id: Int) = when (id) {
+                Config.Value.STABLE_CHANNEL -> STABLE
+                Config.Value.BETA_CHANNEL -> BETA
+                Config.Value.CUSTOM_CHANNEL -> CUSTOM
+                Config.Value.CANARY_CHANNEL -> CANARY
+                Config.Value.CANARY_DEBUG_CHANNEL -> CANARY_DEBUG
+                else -> STABLE
+            }
+        }
+    }
+}

app/src/main/java/com/topjohnwu/magisk/data/database/LogDao.kt

@@ -0,0 +1,34 @@
+package com.topjohnwu.magisk.data.database
+
+import com.topjohnwu.magisk.Config
+import com.topjohnwu.magisk.data.database.base.*
+import com.topjohnwu.magisk.model.entity.MagiskLog
+import com.topjohnwu.magisk.model.entity.toLog
+import com.topjohnwu.magisk.model.entity.toMap
+import java.util.concurrent.TimeUnit
+
+class LogDao : BaseDao() {
+
+    override val table = DatabaseDefinition.Table.LOG
+
+    fun deleteOutdated(
+        suTimeout: Long = Config.suLogTimeout * TimeUnit.DAYS.toMillis(1)
+    ) = query<Delete> {
+        condition {
+            lessThan("time", suTimeout.toString())
+        }
+    }.ignoreElement()
+
+    fun deleteAll() = query<Delete> {}.ignoreElement()
+
+    fun fetchAll() = query<Select> {
+        orderBy("time", Order.DESC)
+    }.flattenAsFlowable { it }
+        .map { it.toLog() }
+        .toList()
+
+    fun put(log: MagiskLog) = query<Insert> {
+        values(log.toMap())
+    }.ignoreElement()
+
+}

app/src/main/java/com/topjohnwu/magisk/data/database/MagiskDB.java

@@ -1,190 +0,0 @@
-package com.topjohnwu.magisk.data.database;
-
-import android.content.ContentValues;
-import android.content.Context;
-import android.content.pm.PackageManager;
-import android.text.TextUtils;
-
-import com.topjohnwu.magisk.Config;
-import com.topjohnwu.magisk.Const;
-import com.topjohnwu.magisk.model.entity.Policy;
-import com.topjohnwu.magisk.model.entity.SuLogEntry;
-import com.topjohnwu.magisk.utils.LocaleManager;
-import com.topjohnwu.magisk.utils.Utils;
-import com.topjohnwu.superuser.Shell;
-
-import java.text.DateFormat;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.Date;
-import java.util.List;
-import java.util.Map;
-
-public class MagiskDB {
-
-    private static final String POLICY_TABLE = "policies";
-    private static final String LOG_TABLE = "logs";
-    private static final String SETTINGS_TABLE = "settings";
-    private static final String STRINGS_TABLE = "strings";
-
-    private PackageManager pm;
-
-    public MagiskDB(Context context) {
-        pm = context.getPackageManager();
-    }
-
-    public void deletePolicy(Policy policy) {
-        deletePolicy(policy.uid);
-    }
-
-    private List<String> rawSQL(String fmt, Object... args) {
-        return Shell.su("magisk --sqlite '" + Utils.fmt(fmt, args) + "'").exec().getOut();
-    }
-
-    private List<ContentValues> SQL(String fmt, Object... args) {
-        List<ContentValues> list = new ArrayList<>();
-        for (String raw : rawSQL(fmt, args)) {
-            ContentValues values = new ContentValues();
-            String[] cols = raw.split("\\|");
-            for (String col : cols) {
-                String[] pair = col.split("=", 2);
-                if (pair.length != 2)
-                    continue;
-                values.put(pair[0], pair[1]);
-            }
-            list.add(values);
-        }
-        return list;
-    }
-
-    private String toSQL(ContentValues values) {
-        StringBuilder keys = new StringBuilder(), vals = new StringBuilder();
-        keys.append('(');
-        vals.append("VALUES(");
-        boolean first = true;
-        for (Map.Entry<String, Object> entry : values.valueSet()) {
-            if (!first) {
-                keys.append(',');
-                vals.append(',');
-            } else {
-                first = false;
-            }
-            keys.append(entry.getKey());
-            vals.append('"');
-            vals.append(entry.getValue());
-            vals.append('"');
-        }
-        keys.append(')');
-        vals.append(')');
-        keys.append(vals);
-        return keys.toString();
-    }
-
-    public void clearOutdated() {
-        rawSQL(
-                "DELETE FROM %s WHERE until > 0 AND until < %d;" +
-                        "DELETE FROM %s WHERE time < %d",
-                POLICY_TABLE, System.currentTimeMillis() / 1000,
-                LOG_TABLE, System.currentTimeMillis() - Config.suLogTimeout * 86400000
-        );
-    }
-
-    public void deletePolicy(String pkg) {
-        rawSQL("DELETE FROM %s WHERE package_name=\"%s\"", POLICY_TABLE, pkg);
-    }
-
-    public void deletePolicy(int uid) {
-        rawSQL("DELETE FROM %s WHERE uid=%d", POLICY_TABLE, uid);
-    }
-
-    public Policy getPolicy(int uid) {
-        List<ContentValues> res =
-                SQL("SELECT * FROM %s WHERE uid=%d", POLICY_TABLE, uid);
-        if (!res.isEmpty()) {
-            try {
-                return new Policy(res.get(0), pm);
-            } catch (PackageManager.NameNotFoundException e) {
-                deletePolicy(uid);
-            }
-        }
-        return null;
-    }
-
-    public void updatePolicy(Policy policy) {
-        rawSQL("REPLACE INTO %s %s", POLICY_TABLE, toSQL(policy.getContentValues()));
-    }
-
-    public List<Policy> getPolicyList() {
-        List<Policy> list = new ArrayList<>();
-        for (ContentValues values : SQL("SELECT * FROM %s WHERE uid/100000=%d", POLICY_TABLE, Const.USER_ID)) {
-            try {
-                list.add(new Policy(values, pm));
-            } catch (PackageManager.NameNotFoundException e) {
-                deletePolicy(values.getAsInteger("uid"));
-            }
-        }
-        Collections.sort(list);
-        return list;
-    }
-
-    public List<List<SuLogEntry>> getLogs() {
-        List<List<SuLogEntry>> ret = new ArrayList<>();
-        List<SuLogEntry> list = null;
-        String dateString = null, newString;
-        for (ContentValues values : SQL("SELECT * FROM %s ORDER BY time DESC", LOG_TABLE)) {
-            Date date = new Date(values.getAsLong("time"));
-            newString = DateFormat.getDateInstance(DateFormat.MEDIUM, LocaleManager.locale).format(date);
-            if (!TextUtils.equals(dateString, newString)) {
-                dateString = newString;
-                list = new ArrayList<>();
-                ret.add(list);
-            }
-            list.add(new SuLogEntry(values));
-        }
-        return ret;
-    }
-
-    public void addLog(SuLogEntry log) {
-        rawSQL("INSERT INTO %s %s", LOG_TABLE, toSQL(log.getContentValues()));
-    }
-
-    public void clearLogs() {
-        rawSQL("DELETE FROM %s", LOG_TABLE);
-    }
-
-    public void rmSettings(String key) {
-        rawSQL("DELETE FROM %s WHERE key=\"%s\"", SETTINGS_TABLE, key);
-    }
-
-    public void setSettings(String key, int value) {
-        ContentValues data = new ContentValues();
-        data.put("key", key);
-        data.put("value", value);
-        rawSQL("REPLACE INTO %s %s", SETTINGS_TABLE, toSQL(data));
-    }
-
-    public int getSettings(String key, int defaultValue) {
-        List<ContentValues> res = SQL("SELECT value FROM %s WHERE key=\"%s\"", SETTINGS_TABLE, key);
-        if (res.isEmpty())
-            return defaultValue;
-        return res.get(0).getAsInteger("value");
-    }
-
-    public void setStrings(String key, String value) {
-        if (value == null) {
-            rawSQL("DELETE FROM %s WHERE key=\"%s\"", STRINGS_TABLE, key);
-            return;
-        }
-        ContentValues data = new ContentValues();
-        data.put("key", key);
-        data.put("value", value);
-        rawSQL("REPLACE INTO %s %s", STRINGS_TABLE, toSQL(data));
-    }
-
-    public String getStrings(String key, String defaultValue) {
-        List<ContentValues> res = SQL("SELECT value FROM %s WHERE key=\"%s\"", STRINGS_TABLE, key);
-        if (res.isEmpty())
-            return defaultValue;
-        return res.get(0).getAsString("value");
-    }
-}

app/src/main/java/com/topjohnwu/magisk/data/database/PolicyDao.kt

@@ -0,0 +1,69 @@
+package com.topjohnwu.magisk.data.database
+
+import android.content.Context
+import android.content.pm.PackageManager
+import com.topjohnwu.magisk.Constants
+import com.topjohnwu.magisk.data.database.base.*
+import com.topjohnwu.magisk.model.entity.MagiskPolicy
+import com.topjohnwu.magisk.model.entity.toMap
+import com.topjohnwu.magisk.model.entity.toPolicy
+import com.topjohnwu.magisk.utils.now
+import java.util.concurrent.TimeUnit
+
+
+class PolicyDao(
+    private val context: Context
+) : BaseDao() {
+
+    override val table: String = DatabaseDefinition.Table.POLICY
+
+    fun deleteOutdated(
+        nowSeconds: Long = TimeUnit.MILLISECONDS.toSeconds(now)
+    ) = query<Delete> {
+        condition {
+            greaterThan("until", "0")
+            and {
+                lessThan("until", nowSeconds.toString())
+            }
+            or {
+                lessThan("until", "0")
+            }
+        }
+    }.ignoreElement()
+
+    fun delete(packageName: String) = query<Delete> {
+        condition {
+            equals("package_name", packageName)
+        }
+    }.ignoreElement()
+
+    fun delete(uid: Int) = query<Delete> {
+        condition {
+            equals("uid", uid)
+        }
+    }.ignoreElement()
+
+    fun fetch(uid: Int) = query<Select> {
+        condition {
+            equals("uid", uid)
+        }
+    }.map { it.firstOrNull()?.toPolicy(context.packageManager) }
+        .doOnError {
+            if (it is PackageManager.NameNotFoundException) {
+                delete(uid).subscribe()
+            }
+        }
+
+    fun update(policy: MagiskPolicy) = query<Replace> {
+        values(policy.toMap())
+    }.ignoreElement()
+
+    fun fetchAll() = query<Select> {
+        condition {
+            equals("uid/100000", Constants.USER_ID)
+        }
+    }.flattenAsFlowable { it }
+        .map { it.toPolicy(context.packageManager) }
+        .toList()
+
+}

app/src/main/java/com/topjohnwu/magisk/data/database/RepoDatabaseHelper.java

@@ -11,13 +11,15 @@ import com.topjohnwu.magisk.model.entity.Repo;
 import java.util.HashSet;
 import java.util.Set;
 
+@Deprecated
 public class RepoDatabaseHelper extends SQLiteOpenHelper {
 
     private static final int DATABASE_VER = 5;
     private static final String TABLE_NAME = "repos";
 
-    private SQLiteDatabase mDb;
+    private final SQLiteDatabase mDb;
 
+    @Deprecated
     public RepoDatabaseHelper(Context context) {
         super(context, "repo.db", null, DATABASE_VER);
         mDb = getWritableDatabase();
@@ -46,32 +48,38 @@ public class RepoDatabaseHelper extends SQLiteOpenHelper {
         onUpgrade(db, 0, DATABASE_VER);
     }
 
+    @Deprecated
     public void clearRepo() {
         mDb.delete(TABLE_NAME, null, null);
     }
 
 
+    @Deprecated
     public void removeRepo(String id) {
-        mDb.delete(TABLE_NAME, "id=?", new String[] { id });
+        mDb.delete(TABLE_NAME, "id=?", new String[]{id});
     }
 
+    @Deprecated
     public void removeRepo(Repo repo) {
         removeRepo(repo.getId());
     }
 
+    @Deprecated
     public void removeRepo(Iterable<String> list) {
         for (String id : list) {
             if (id == null) continue;
-            mDb.delete(TABLE_NAME, "id=?", new String[] { id });
+            mDb.delete(TABLE_NAME, "id=?", new String[]{id});
         }
     }
 
+    @Deprecated
     public void addRepo(Repo repo) {
         mDb.replace(TABLE_NAME, null, repo.getContentValues());
     }
 
+    @Deprecated
     public Repo getRepo(String id) {
-        try (Cursor c = mDb.query(TABLE_NAME, null, "id=?", new String[] { id }, null, null, null)) {
+        try (Cursor c = mDb.query(TABLE_NAME, null, "id=?", new String[]{id}, null, null, null)) {
             if (c.moveToNext()) {
                 return new Repo(c);
             }
@@ -79,10 +87,12 @@ public class RepoDatabaseHelper extends SQLiteOpenHelper {
         return null;
     }
 
+    @Deprecated
     public Cursor getRawCursor() {
         return mDb.query(TABLE_NAME, null, null, null, null, null, null);
     }
 
+    @Deprecated
     public Cursor getRepoCursor() {
         String orderBy = null;
         switch ((int) Config.get(Config.Key.REPO_ORDER)) {
@@ -95,6 +105,7 @@ public class RepoDatabaseHelper extends SQLiteOpenHelper {
         return mDb.query(TABLE_NAME, null, null, null, null, null, orderBy);
     }
 
+    @Deprecated
     public Set<String> getRepoIDSet() {
         HashSet<String> set = new HashSet<>(300);
         try (Cursor c = mDb.query(TABLE_NAME, null, null, null, null, null, null)) {

app/src/main/java/com/topjohnwu/magisk/data/database/SettingsDao.kt

@@ -0,0 +1,21 @@
+package com.topjohnwu.magisk.data.database
+
+import com.topjohnwu.magisk.data.database.base.*
+
+class SettingsDao : BaseDao() {
+
+    override val table = DatabaseDefinition.Table.SETTINGS
+
+    fun delete(key: String) = query<Delete> {
+        condition { equals("key", key) }
+    }.ignoreElement()
+
+    fun put(key: String, value: Int) = query<Insert> {
+        values(key to value.toString())
+    }.ignoreElement()
+
+    fun fetch(key: String, default: Int = -1) = query<Select> {
+        condition { equals("key", key) }
+    }.map { it.firstOrNull()?.values?.firstOrNull()?.toIntOrNull() ?: default }
+
+}

app/src/main/java/com/topjohnwu/magisk/data/database/StringDao.kt

@@ -0,0 +1,22 @@
+package com.topjohnwu.magisk.data.database
+
+import com.topjohnwu.magisk.data.database.base.*
+
+class StringDao : BaseDao() {
+
+    override val table = DatabaseDefinition.Table.STRINGS
+
+    fun delete(key: String) = query<Delete> {
+        condition { equals("key", key) }
+    }.ignoreElement()
+
+    fun put(key: String, value: String) = query<Insert> {
+        values(key to value)
+    }.ignoreElement()
+
+    fun fetch(key: String, default: String = "") = query<Select> {
+        fields("value")
+        condition { equals("key", key) }
+    }.map { it.firstOrNull()?.values?.firstOrNull() ?: default }
+
+}

app/src/main/java/com/topjohnwu/magisk/data/database/base/BaseDao.kt

@@ -0,0 +1,15 @@
+package com.topjohnwu.magisk.data.database.base
+
+abstract class BaseDao {
+
+    abstract val table: String
+
+    inline fun <reified Builder : MagiskQueryBuilder> query(builder: Builder.() -> Unit) =
+        Builder::class.java.newInstance()
+            .apply { table = this@BaseDao.table }
+            .apply(builder)
+            .toString()
+            .let { MagiskQuery(it) }
+            .query()
+
+}

app/src/main/java/com/topjohnwu/magisk/data/database/base/DatabaseDefinition.kt

@@ -0,0 +1,30 @@
+package com.topjohnwu.magisk.data.database.base
+
+import androidx.annotation.AnyThread
+import com.topjohnwu.superuser.Shell
+import io.reactivex.Single
+
+object DatabaseDefinition {
+
+    object Table {
+        const val POLICY = "policies"
+        const val LOG = "logs"
+        const val SETTINGS = "settings"
+        const val STRINGS = "strings"
+    }
+
+}
+
+@AnyThread
+fun MagiskQuery.query() = query.su()
+
+fun String.suRaw() = Single.fromCallable { Shell.su(this).exec().out }
+fun String.su() = suRaw().map { it.toMap() }
+
+fun List<String>.toMap() = map { it.split(Regex("\\|")) }
+    .map { it.toMapInternal() }
+
+private fun List<String>.toMapInternal() = map { it.split("=", limit = 2) }
+    .filter { it.size == 2 }
+    .map { Pair(it[0], it[1]) }
+    .toMap()

app/src/main/java/com/topjohnwu/magisk/data/database/base/MagiskQuery.kt

@@ -0,0 +1,5 @@
+package com.topjohnwu.magisk.data.database.base
+
+inline class MagiskQuery(private val _query: String) {
+    val query get() = "magisk --sqlite '$_query'"
+}

app/src/main/java/com/topjohnwu/magisk/data/database/base/MagiskQueryBuilder.kt

@@ -0,0 +1,163 @@
+package com.topjohnwu.magisk.data.database.base
+
+import androidx.annotation.StringDef
+import com.topjohnwu.magisk.data.database.base.Order.Companion.ASC
+import com.topjohnwu.magisk.data.database.base.Order.Companion.DESC
+
+interface MagiskQueryBuilder {
+
+    val requestType: String
+    var table: String
+
+    companion object {
+        inline operator fun <reified Builder : MagiskQueryBuilder> invoke(builder: Builder.() -> Unit): MagiskQuery =
+            Builder::class.java.newInstance()
+                .apply(builder)
+                .toString()
+                .let {
+                    MagiskQuery(it)
+                }
+    }
+
+}
+
+class Delete : MagiskQueryBuilder {
+    override val requestType: String = "DELETE FROM"
+    override var table = ""
+
+    private var condition = ""
+
+    fun condition(builder: Condition.() -> Unit) {
+        condition = Condition().apply(builder).toString()
+    }
+
+    override fun toString(): String {
+        return StringBuilder()
+            .appendln(requestType)
+            .appendln(table)
+            .appendln(condition)
+            .toString()
+    }
+}
+
+class Select : MagiskQueryBuilder {
+    override val requestType: String get() = "SELECT $fields FROM"
+    override lateinit var table: String
+
+    private var fields = "*"
+    private var condition = ""
+    private var orderField = ""
+
+    fun fields(vararg newFields: String) {
+        if (newFields.isEmpty()) {
+            fields = "*"
+            return
+        }
+        fields = newFields.joinToString(", ")
+    }
+
+    fun condition(builder: Condition.() -> Unit) {
+        condition = Condition().apply(builder).toString()
+    }
+
+    fun orderBy(field: String, @OrderStrict order: String) {
+        orderField = "ORDER BY $field $order"
+    }
+
+    override fun toString(): String {
+        return StringBuilder()
+            .appendln(requestType)
+            .appendln(table)
+            .appendln(condition)
+            .appendln(orderField)
+            .toString()
+            .replace("\n", " ")
+    }
+}
+
+class Replace : Insert() {
+    override val requestType: String = "REPLACE INTO"
+}
+
+open class Insert : MagiskQueryBuilder {
+    override val requestType: String = "INSERT INTO"
+    override lateinit var table: String
+
+    private val keys get() = _values.keys.joinToString(",")
+    private val values get() = _values.values.joinToString(",") { "\"$it\"" }
+    private var _values: Map<String, String> = mapOf()
+
+    fun values(vararg pairs: Pair<String, String>) {
+        _values = pairs.toMap()
+    }
+
+    fun values(values: Map<String, String>) {
+        _values = values
+    }
+
+    override fun toString(): String {
+        return StringBuilder()
+            .appendln(requestType)
+            .appendln(table)
+            .appendln("($keys) VALUES($values)")
+            .toString()
+    }
+}
+
+class Condition {
+
+    private val conditionWord = "WHERE %s"
+    private var condition: String = ""
+
+    fun equals(field: String, value: Any) {
+        condition = when (value) {
+            is String -> "$field=\"$value\""
+            else -> "$field=$value"
+        }
+    }
+
+    fun greaterThan(field: String, value: String) {
+        condition = "$field > $value"
+    }
+
+    fun lessThan(field: String, value: String) {
+        condition = "$field < $value"
+    }
+
+    fun greaterOrEqualTo(field: String, value: String) {
+        condition = "$field >= $value"
+    }
+
+    fun lessOrEqualTo(field: String, value: String) {
+        condition = "$field <= $value"
+    }
+
+    fun and(builder: Condition.() -> Unit) {
+        condition = "($condition AND ${Condition().apply(builder).condition})"
+    }
+
+    fun or(builder: Condition.() -> Unit) {
+        condition = "($condition OR ${Condition().apply(builder).condition})"
+    }
+
+    override fun toString(): String {
+        return conditionWord.format(condition)
+    }
+}
+
+class Order {
+
+    @set:OrderStrict
+    var order = DESC
+    var field = ""
+
+    companion object {
+        const val ASC = "ASC"
+        const val DESC = "DESC"
+    }
+
+}
+
+@StringDef(ASC, DESC)
+@Retention(AnnotationRetention.SOURCE)
+annotation class OrderStrict

app/src/main/java/com/topjohnwu/magisk/data/network/GithubRawApiServices.kt

@@ -0,0 +1,63 @@
+package com.topjohnwu.magisk.data.network
+
+import com.topjohnwu.magisk.Constants
+import com.topjohnwu.magisk.KConfig
+import com.topjohnwu.magisk.model.entity.MagiskConfig
+import io.reactivex.Single
+import okhttp3.ResponseBody
+import retrofit2.http.GET
+import retrofit2.http.Path
+import retrofit2.http.Streaming
+import retrofit2.http.Url
+
+
+interface GithubRawApiServices {
+
+    //region topjohnwu/magisk_files
+
+    @GET("$MAGISK_FILES/master/stable.json")
+    fun fetchConfig(): Single<MagiskConfig>
+
+    @GET("$MAGISK_FILES/master/beta.json")
+    fun fetchBetaConfig(): Single<MagiskConfig>
+
+    @GET("$MAGISK_FILES/master/canary_builds/release.json")
+    fun fetchCanaryConfig(): Single<MagiskConfig>
+
+    @GET("$MAGISK_FILES/master/canary_builds/canary.json")
+    fun fetchCanaryDebugConfig(): Single<MagiskConfig>
+
+    @GET
+    fun fetchCustomConfig(@Url url: String): Single<MagiskConfig>
+
+    @GET("$MAGISK_FILES/{$REVISION}/snet.apk")
+    @Streaming
+    fun fetchSafetynet(@Path(REVISION) revision: String = Constants.SNET_REVISION): Single<ResponseBody>
+
+    @GET("$MAGISK_FILES/{$REVISION}/bootctl")
+    @Streaming
+    fun fetchBootctl(@Path(REVISION) revision: String = Constants.BOOTCTL_REVISION): Single<ResponseBody>
+
+    //endregion
+
+    /**
+     * This method shall be used exclusively for fetching files from urls from previous requests.
+     * Him, who uses it in a wrong way, shall die in an eternal flame.
+     * */
+    @GET
+    @Streaming
+    fun fetchFile(@Url url: String): Single<ResponseBody>
+
+
+    companion object {
+        private const val REVISION = "revision"
+        private const val MODULE = "module"
+        private const val FILE = "file"
+
+
+        private const val MAGISK_FILES = KConfig.DEFAULT_CHANNEL
+        private const val MAGISK_MASTER = "topjohnwu/Magisk/master"
+        private const val MAGISK_MODULES = "Magisk-Modules-Repo"
+    }
+
+}

app/src/main/java/com/topjohnwu/magisk/data/repository/AppRepository.kt

@@ -0,0 +1,15 @@
+package com.topjohnwu.magisk.data.repository
+
+import com.topjohnwu.magisk.data.database.PolicyDao
+import com.topjohnwu.magisk.model.entity.MagiskPolicy
+
+class AppRepository(private val policyDao: PolicyDao) {
+
+    fun deleteOutdated() = policyDao.deleteOutdated()
+    fun delete(packageName: String) = policyDao.delete(packageName)
+    fun delete(uid: Int) = policyDao.delete(uid)
+    fun fetch(uid: Int) = policyDao.fetch(uid)
+    fun fetchAll() = policyDao.fetchAll()
+    fun update(policy: MagiskPolicy) = policyDao.update(policy)
+
+}

app/src/main/java/com/topjohnwu/magisk/data/repository/LogRepository.kt

@@ -0,0 +1,43 @@
+package com.topjohnwu.magisk.data.repository
+
+import com.topjohnwu.magisk.Const
+import com.topjohnwu.magisk.Constants
+import com.topjohnwu.magisk.data.database.LogDao
+import com.topjohnwu.magisk.data.database.base.suRaw
+import com.topjohnwu.magisk.model.entity.MagiskLog
+import com.topjohnwu.magisk.model.entity.WrappedMagiskLog
+import com.topjohnwu.magisk.utils.toSingle
+import com.topjohnwu.superuser.Shell
+import timber.log.Timber
+import java.util.concurrent.TimeUnit
+
+
+class LogRepository(
+    private val logDao: LogDao
+) {
+
+    fun fetchLogs() = logDao.fetchAll()
+        .map { it.sortByDescending { it.date.time }; it }
+        .map { it.wrap() }
+
+    fun fetchMagiskLogs() = "tail -n 5000 ${Constants.MAGISK_LOG}".suRaw()
+        .filter { it.isNotEmpty() }
+        .map { Timber.i(it.toString()); it }
+
+    fun clearLogs() = logDao.deleteAll()
+    fun clearOutdated() = logDao.deleteOutdated()
+
+    fun clearMagiskLogs() = Shell.su("echo -n > " + Const.MAGISK_LOG)
+        .toSingle()
+        .map { it.exec() }
+
+    fun put(log: MagiskLog) = logDao.put(log)
+
+    private fun List<MagiskLog>.wrap(): List<WrappedMagiskLog> {
+        val day = TimeUnit.DAYS.toMillis(1)
+        return groupBy { it.date.time / day }
+            .map { WrappedMagiskLog(it.key * day, it.value) }
+    }
+
+
+}

app/src/main/java/com/topjohnwu/magisk/data/repository/MagiskRepository.kt

@@ -0,0 +1,130 @@
+package com.topjohnwu.magisk.data.repository
+
+import android.content.Context
+import android.content.pm.PackageManager
+import com.topjohnwu.magisk.App
+import com.topjohnwu.magisk.Config
+import com.topjohnwu.magisk.KConfig
+import com.topjohnwu.magisk.data.database.base.su
+import com.topjohnwu.magisk.data.database.base.suRaw
+import com.topjohnwu.magisk.data.network.GithubRawApiServices
+import com.topjohnwu.magisk.model.entity.HideAppInfo
+import com.topjohnwu.magisk.model.entity.HideTarget
+import com.topjohnwu.magisk.model.entity.Version
+import com.topjohnwu.magisk.utils.Utils
+import com.topjohnwu.magisk.utils.inject
+import com.topjohnwu.magisk.utils.toSingle
+import com.topjohnwu.magisk.utils.writeToFile
+import com.topjohnwu.superuser.Shell
+import io.reactivex.Single
+import io.reactivex.functions.BiFunction
+
+class MagiskRepository(
+    private val context: Context,
+    private val apiRaw: GithubRawApiServices,
+    private val packageManager: PackageManager
+) {
+
+    fun fetchMagisk() = fetchConfig()
+        .flatMap { apiRaw.fetchFile(it.magisk.link) }
+        .map { it.writeToFile(context, FILE_MAGISK_ZIP) }
+
+    fun fetchManager() = fetchConfig()
+        .flatMap { apiRaw.fetchFile(it.app.link) }
+        .map { it.writeToFile(context, FILE_MAGISK_APK) }
+
+    fun fetchUninstaller() = fetchConfig()
+        .flatMap { apiRaw.fetchFile(it.uninstaller.link) }
+        .map { it.writeToFile(context, FILE_UNINSTALLER_ZIP) }
+
+    fun fetchSafetynet() = apiRaw
+        .fetchSafetynet()
+        .map { it.writeToFile(context, FILE_SAFETY_NET_APK) }
+
+    fun fetchBootctl() = apiRaw
+        .fetchBootctl()
+        .map { it.writeToFile(context, FILE_BOOTCTL_SH) }
+
+
+    fun fetchConfig() = when (KConfig.updateChannel) {
+        KConfig.UpdateChannel.STABLE -> apiRaw.fetchConfig()
+        KConfig.UpdateChannel.BETA -> apiRaw.fetchBetaConfig()
+        KConfig.UpdateChannel.CANARY -> apiRaw.fetchCanaryConfig()
+        KConfig.UpdateChannel.CANARY_DEBUG -> apiRaw.fetchCanaryDebugConfig()
+        KConfig.UpdateChannel.CUSTOM -> apiRaw.fetchCustomConfig(KConfig.customUpdateChannel)
+    }
+    .doOnSuccess {
+        Config.remoteMagiskVersionCode = it.magisk.versionCode.toIntOrNull() ?: -1
+        Config.magiskLink = it.magisk.link
+        Config.magiskNoteLink = it.magisk.note
+        Config.magiskMD5 = it.magisk.hash
+        Config.remoteManagerVersionCode = it.app.versionCode.toIntOrNull() ?: -1
+        Config.remoteManagerVersionString = it.app.version
+        Config.managerLink = it.app.link
+        Config.managerNoteLink = it.app.note
+        Config.uninstallerLink = it.uninstaller.link
+    }
+
+
+    fun fetchMagiskVersion(): Single<Version> = Single.zip(
+        fetchMagiskVersionName(),
+        fetchMagiskVersionCode(),
+        BiFunction { versionName, versionCode ->
+            Version(versionName, versionCode)
+        }
+    )
+
+
+    fun fetchApps() =
+        Single.fromCallable { packageManager.getInstalledApplications(0) }
+            .flattenAsFlowable { it }
+            .filter { it.enabled && !blacklist.contains(it.packageName) }
+            .map {
+                val label = Utils.getAppLabel(it, packageManager)
+                val icon = it.loadIcon(packageManager)
+                HideAppInfo(it, label, icon)
+            }
+            .filter { it.processes.isNotEmpty() }
+            .toList()
+
+    fun fetchHideTargets() = Shell.su("magiskhide --ls").toSingle()
+        .map { it.exec().out }
+        .flattenAsFlowable { it }
+        .map { HideTarget(it) }
+        .toList()
+
+    private fun fetchMagiskVersionName() = "magisk -v".suRaw()
+        .map { it.first() }
+        .map { it.substring(0 until it.indexOf(":")) }
+        .onErrorReturn { "Unknown" }
+
+    private fun fetchMagiskVersionCode() = "magisk -V".suRaw()
+        .map { it.first() }
+        .map { it.toIntOrNull() ?: -1 }
+        .onErrorReturn { -1 }
+
+    fun toggleHide(isEnabled: Boolean, packageName: String, process: String) =
+        "magiskhide --%s %s %s".format(isEnabled.state, packageName, process).su().ignoreElement()
+
+    private val Boolean.state get() = if (this) "add" else "rm"
+
+    companion object {
+        const val FILE_MAGISK_ZIP = "magisk.zip"
+        const val FILE_MAGISK_APK = "magisk.apk"
+        const val FILE_UNINSTALLER_ZIP = "uninstaller.zip"
+        const val FILE_SAFETY_NET_APK = "safetynet.apk"
+        const val FILE_BOOTCTL_SH = "bootctl"
+
+        private val blacklist = listOf(
+            let { val app: App by inject(); app }.packageName,
+            "android",
+            "com.android.chrome",
+            "com.chrome.beta",
+            "com.chrome.dev",
+            "com.chrome.canary",
+            "com.android.webview",
+            "com.google.android.webview"
+        )
+    }
+
+}

app/src/main/java/com/topjohnwu/magisk/data/repository/SettingRepository.kt

@@ -0,0 +1,11 @@
+package com.topjohnwu.magisk.data.repository
+
+import com.topjohnwu.magisk.data.database.SettingsDao
+
+class SettingRepository(private val settingsDao: SettingsDao) {
+
+    fun fetch(key: String, default: Int) = settingsDao.fetch(key, default)
+    fun put(key: String, value: Int) = settingsDao.put(key, value)
+    fun delete(key: String) = settingsDao.delete(key)
+
+}

app/src/main/java/com/topjohnwu/magisk/data/repository/StringRepository.kt

@@ -0,0 +1,11 @@
+package com.topjohnwu.magisk.data.repository
+
+import com.topjohnwu.magisk.data.database.StringDao
+
+class StringRepository(private val stringDao: StringDao) {
+
+    fun fetch(key: String, default: String) = stringDao.fetch(key, default)
+    fun put(key: String, value: String) = stringDao.put(key, value)
+    fun delete(key: String) = stringDao.delete(key)
+
+}

app/src/main/java/com/topjohnwu/magisk/di/ApplicationModule.kt

@@ -12,8 +12,7 @@ val applicationModule = module {
     factory { get<Context>().resources }
     factory { get<Context>() as App }
     factory { get<Context>().packageManager }
-    single(SUTimeout) {
-        get<App>().protectedContext.getSharedPreferences("su_timeout", 0)
-    }
-    single { PreferenceManager.getDefaultSharedPreferences(get<App>().protectedContext) }
-}
+    factory(Protected) { get<App>().protectedContext }
+    single(SUTimeout) { get<Context>(Protected).getSharedPreferences("su_timeout", 0) }
+    single { PreferenceManager.getDefaultSharedPreferences(get<Context>(Protected)) }
+}

app/src/main/java/com/topjohnwu/magisk/di/DatabaseModule.kt

@@ -1,12 +1,15 @@
 package com.topjohnwu.magisk.di
 
-import com.topjohnwu.magisk.App
-import com.topjohnwu.magisk.data.database.MagiskDB
-import com.topjohnwu.magisk.data.database.RepoDatabaseHelper
+import com.topjohnwu.magisk.data.database.*
+import com.topjohnwu.magisk.tasks.UpdateRepos
 import org.koin.dsl.module
 
 
 val databaseModule = module {
-    single { MagiskDB(get<App>().protectedContext) }
+    single { LogDao() }
+    single { PolicyDao(get()) }
+    single { SettingsDao() }
+    single { StringDao() }
     single { RepoDatabaseHelper(get()) }
+    single { UpdateRepos(get()) }
 }

app/src/main/java/com/topjohnwu/magisk/di/NamedInjection.kt

@@ -2,4 +2,5 @@ package com.topjohnwu.magisk.di
 
 import org.koin.core.qualifier.named
 
-val SUTimeout = named("su_timeout")
+val SUTimeout = named("su_timeout")
+val Protected = named("protected")

app/src/main/java/com/topjohnwu/magisk/di/NetworkingModule.kt

@@ -1,6 +1,69 @@
 package com.topjohnwu.magisk.di
 
+import com.squareup.moshi.JsonAdapter
+import com.squareup.moshi.Moshi
+import com.topjohnwu.magisk.Constants
+import com.topjohnwu.magisk.data.network.GithubRawApiServices
+import okhttp3.OkHttpClient
+import okhttp3.logging.HttpLoggingInterceptor
 import org.koin.dsl.module
+import retrofit2.CallAdapter
+import retrofit2.Converter
+import retrofit2.Retrofit
+import retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory
+import retrofit2.converter.moshi.MoshiConverterFactory
+import se.ansman.kotshi.KotshiJsonAdapterFactory
 
+val networkingModule = module {
+    single { createOkHttpClient() }
+    single { createConverterFactory() }
+    single { createCallAdapterFactory() }
+    single { createRetrofit(get(), get(), get()) }
+    single { createApiService<GithubRawApiServices>(get(), Constants.GITHUB_RAW_API_URL) }
+}
 
-val networkingModule = module {}
+fun createOkHttpClient(): OkHttpClient {
+    val httpLoggingInterceptor = HttpLoggingInterceptor().apply {
+        level = HttpLoggingInterceptor.Level.BODY
+    }
+
+    return OkHttpClient.Builder()
+        .addInterceptor(httpLoggingInterceptor)
+        .build()
+}
+
+fun createConverterFactory(): Converter.Factory {
+    val moshi = Moshi.Builder()
+            .add(JsonAdapterFactory.INSTANCE)
+            .build()
+    return MoshiConverterFactory.create(moshi)
+}
+
+fun createCallAdapterFactory(): CallAdapter.Factory {
+    return RxJava2CallAdapterFactory.create()
+}
+
+fun createRetrofit(
+    okHttpClient: OkHttpClient,
+    converterFactory: Converter.Factory,
+    callAdapterFactory: CallAdapter.Factory
+): Retrofit.Builder {
+    return Retrofit.Builder()
+        .addConverterFactory(converterFactory)
+        .addCallAdapterFactory(callAdapterFactory)
+        .client(okHttpClient)
+}
+
+@KotshiJsonAdapterFactory
+abstract class JsonAdapterFactory : JsonAdapter.Factory {
+    companion object {
+        val INSTANCE: JsonAdapterFactory = KotshiJsonAdapterFactory
+    }
+}
+
+inline fun <reified T> createApiService(retrofitBuilder: Retrofit.Builder, baseUrl: String): T {
+    return retrofitBuilder
+        .baseUrl(baseUrl)
+        .build()
+        .create(T::class.java)
+}