回忆篇章

1
// https://github.com/SukiSU-Ultra/SukiSU-Ultra/blob/main/manager/app/src/main/java/com/sukisu/ultra/ui/util/KsuCli.kt
2

3
fun getKpmVersion(): String {
4
    val shell = getRootShell()
5
    val cmd = "${getKpmmgrPath()} version"
6
    val result = ShellUtils.fastCmd(shell, cmd)
7
    return result.trim()
8
}
9

10

11
// https://github.com/SukiSU-Ultra/SukiSU-Ultra/blob/main/manager/app/src/main/java/zako/zako/zako/zakoui/activity/util/AppData.kt
12

13
fun getKpmVersionUse(): String {
14
    return try {
15
        if (!rootAvailable()) return ""
16
        val version = getKpmVersion()
17
        if (version.isEmpty()) "" else version
18
    } catch (e: Exception) {
19
        "Error: ${e.message}"
20
    }
21
}

1
// https://github.com/SukiSU-Ultra/SukiSU-Ultra/blob/main/manager/app/src/main/java/zako/zako/zako/zakoui/activity/component/BottomBar.kt
2

3
val kpmVersion = getKpmVersionUse()
4
!kpmVersion.startsWith("Error")

1
// https://github.com/SukiSU-Ultra/SukiSU-Ultra/blob/main/manager/app/src/main/java/zako/zako/zako/zakoui/flash/KernelFlash.kt
2

3
private fun runCommand(su: Boolean, cmd: String): Int {
4
    val process = ProcessBuilder(if (su) "su" else "sh")
5
        .redirectErrorStream(true)
6
        .start()
7

8
    return try {
9
        process.outputStream.bufferedWriter().use { writer ->
10
            writer.write("$cmd\n")
11
            writer.write("exit\n")
12
            writer.flush()
13
        }
14
        process.waitFor()
15
    } finally {
16
        process.destroy()
17
    }
18
}
19

20
private fun runCommandGetOutput(su: Boolean, cmd: String): String? {
21
    val process = ProcessBuilder(if (su) "su" else "sh")
22
        .redirectErrorStream(true)
23
        .start()
24

25
    return try {
26
        process.outputStream.bufferedWriter().use { writer ->
27
            writer.write("$cmd\n")
28
            writer.write("exit\n")
29
            writer.flush()
30
        }
31
        process.inputStream.bufferedReader().use { reader ->
32
            reader.readText().trim()
33
        }
34
    } catch (_: Exception) {
35
        ""
36
    } finally {
37
        process.destroy()
38
    }
39
}
40

41
private fun rootAvailable(): Boolean {
42
    return try {
43
        val process = Runtime.getRuntime().exec("su -c id")
44
        val exitValue = process.waitFor()
45
        exitValue == 0
46
    } catch (_: Exception) {
47
        false
48
    }
49
}

1
// https://github.com/SukiSU-Ultra/SukiSU-Ultra/blob/main/manager/app/src/main/java/io/sukisu/ultra/UltraShellHelper.java
2

3
public static boolean isPathExists(String path) {
4
    return runCmd("file " + path).contains("No such file or directory");
5
}
6

7
public static void CopyFileTo(String path, String target) {
8
    runCmd("cp -f " + path + " " + target);
9
}

1
// https://github.com/SukiSU-Ultra/SukiSU-Ultra/blob/main/manager/app/src/main/java/io/sukisu/ultra/UltraToolInstall.java
2

3
private static final String OUTSIDE_KPMMGR_PATH = "/data/adb/ksu/bin/kpmmgr";
4
private static final String OUTSIDE_SUSFSD_PATH = "/data/adb/ksu/bin/susfsd";
5
public static void tryToInstall() {
6
    String kpmmgrPath = getKpmmgrPath();
7
    if (UltraShellHelper.isPathExists(OUTSIDE_KPMMGR_PATH)) {
8
        UltraShellHelper.CopyFileTo(kpmmgrPath, OUTSIDE_KPMMGR_PATH);
9
        UltraShellHelper.runCmd("chmod a+rx " + OUTSIDE_KPMMGR_PATH);
10
    }
11
    String SuSFSDaemonPath = getSuSFSDaemonPath();
12
    if (UltraShellHelper.isPathExists(OUTSIDE_SUSFSD_PATH)) {
13
        UltraShellHelper.CopyFileTo(SuSFSDaemonPath, OUTSIDE_SUSFSD_PATH);
14
        UltraShellHelper.runCmd("chmod a+rx " + OUTSIDE_SUSFSD_PATH);
15
    }
16
}

1
// https://github.com/SukiSU-Ultra/SukiSU-Ultra/blob/main/manager/app/src/main/java/com/sukisu/ultra/Kernels.kt
2

3
data class KernelVersion(val major: Int, val patchLevel: Int, val subLevel: Int) {
4
    override fun toString(): String = "$major.$patchLevel.$subLevel"
5
    fun isGKI(): Boolean = when {
6
        major > 5 -> true
7
        major == 5 && patchLevel >= 10 -> true
8
        else -> false
9
    }
10
    fun isGKI1(): Boolean = (major == 4 && patchLevel >= 19) || (major == 5 && patchLevel < 10)
11
}

1
// https://github.com/SukiSU-Ultra/SukiSU-Ultra/blob/main/manager/app/src/main/java/com/sukisu/ultra/ui/util/SuSFSModuleScripts.kt
2

3
private const val LOG_DIR = "/data/adb/ksu/log"
4

5
// 清理残留脚本生成
6
private fun StringBuilder.generateCleanupResidueSection() {
7
    appendLine("# 清理工具残留文件")
8
    appendLine("echo \"$(get_current_time): 开始清理工具残留\" >> \"${'$'}LOG_FILE\"")
9
    appendLine()
10

11
    // 定义清理函数
12
    appendLine("""
13
    cleanup_path() {
14
        local path="$1"
15
        local desc="$2"
16
        local current="$3"
17
        local total="$4"
18

19
        if [ -n "${'$'}desc" ]; then
20
            echo "$(get_current_time): [${'$'}current/${'$'}total] 清理: ${'$'}path (${'$'}desc)" >> "${'$'}LOG_FILE"
21
         else
22
            echo "$(get_current_time): [${'$'}current/${'$'}total] 清理: ${'$'}path" >> "${'$'}LOG_FILE"
23
        fi
24

25
        if rm -rf "${'$'}path" 2>/dev/null; then
26
            echo "$(get_current_time): ✓ 成功清理: ${'$'}path" >> "${'$'}LOG_FILE"
27
        else
28
            echo "$(get_current_time): ✗ 清理失败或不存在: ${'$'}path" >> "${'$'}LOG_FILE"
29
        fi
30
     }
31
""".trimIndent())
32

33
    appendLine()
34
    appendLine("# 开始清理各种工具残留")
35
    appendLine("TOTAL=33")
36
    appendLine()
37

38
    val cleanupPaths = listOf(
39
        "/data/local/stryker/" to "Stryker残留",
40
        "/data/system/AppRetention" to "AppRetention残留",
41
        "/data/local/tmp/luckys" to "Luck Tool残留",
42
        "/data/local/tmp/HyperCeiler" to "西米露残留",
43
        "/data/local/tmp/simpleHook" to "simple Hook残留",
44
        "/data/local/tmp/DisabledAllGoogleServices" to "谷歌省电模块残留",
45
        "/data/local/MIO" to "解包软件",
46
        "/data/DNA" to "解包软件",
47
        "/data/local/tmp/cleaner_starter" to "质感清理残留",
48
        "/data/local/tmp/byyang" to "",
49
        "/data/local/tmp/mount_mask" to "",
50
        "/data/local/tmp/mount_mark" to "",
51
        "/data/local/tmp/scriptTMP" to "",
52
        "/data/local/luckys" to "",
53
        "/data/local/tmp/horae_control.log" to "",
54
        "/data/gpu_freq_table.conf" to "",
55
        "/storage/emulated/0/Download/advanced/" to "",
56
        "/storage/emulated/0/Documents/advanced/" to "爱玩机",
57
        "/storage/emulated/0/Android/naki/" to "旧版asoulopt",
58
        "/data/swap_config.conf" to "scene附加模块2",
59
        "/data/local/tmp/resetprop" to "",
60
        "/dev/cpuset/AppOpt/" to "AppOpt模块",
61
        "/storage/emulated/0/Android/Clash/" to "Clash for Magisk模块",
62
        "/storage/emulated/0/Android/Yume-Yunyun/" to "网易云后台优化模块",
63
        "/data/local/tmp/Surfing_update" to "Surfing模块缓存",
64
        "/data/encore/custom_default_cpu_gov" to "encore模块",
65
        "/data/encore/default_cpu_gov" to "encore模块",
66
        "/data/local/tmp/yshell" to "",
67
        "/data/local/tmp/encore_logo.png" to "",
68
        "/storage/emulated/legacy/" to "",
69
        "/storage/emulated/elgg/" to "",
70
        "/data/system/junge/" to "",
71
        "/data/local/tmp/mount_namespace" to "挂载命名空间残留"
72
    )
73

74
    cleanupPaths.forEachIndexed { index, (path, desc) ->
75
        val current = index + 1
76
        appendLine("cleanup_path '$path' '$desc' $current \$TOTAL")
77
    }
78

79
    appendLine()
80
    appendLine("echo \"$(get_current_time): 工具残留清理完成\" >> \"${'$'}LOG_FILE\"")
81
    appendLine()
82
}

1
// https://github.com/SukiSU-Ultra/SukiSU-Ultra/blob/main/manager/app/src/main/java/com/sukisu/ultra/ui/util/SuSFSManager.kt
2

3
private const val MODULE_PATH = "/data/adb/modules/$MODULE_ID"
4

5
private fun getSuSFSTargetPath(): String = "/data/adb/ksu/bin/${getSuSFSBinaryName()}"
6

7
// 槽位信息获取
8
suspend fun getCurrentSlotInfo(): List<SlotInfo> = withContext(Dispatchers.IO) {
9
    try {
10
        val slotInfoList = mutableListOf<SlotInfo>()
11
        val shell = Shell.getShell()
12

13
        listOf("boot_a", "boot_b").forEach { slot ->
14
            val unameCmd =
15
                "strings -n 20 /dev/block/by-name/$slot | awk '/Linux version/ && ++c==2 {print $3; exit}'"
16
            val buildTimeCmd = "strings -n 20 /dev/block/by-name/$slot | sed -n '/Linux version.*#/{s/.*#/#/p;q}'"
17

18
            val uname = runCmd(shell, unameCmd).trim()
19
            val buildTime = runCmd(shell, buildTimeCmd).trim()
20

21
            if (uname.isNotEmpty() && buildTime.isNotEmpty()) {
22
                slotInfoList.add(SlotInfo(slot, uname.ifEmpty { "unknown" }, buildTime.ifEmpty { "unknown" }))
23
            }
24
        }
25

26
        slotInfoList
27
    } catch (e: Exception) {
28
        e.printStackTrace()
29
        emptyList()
30
    }
31
}
32

33
 /**
34
 * 模块管理
35
 */
36
private suspend fun updateMagiskModule(context: Context): Boolean {
37
    return removeMagiskModule() && createMagiskModule(context)
38
}
39

40
/**
41
 * 模块创建方法
42
 */
43
private suspend fun createMagiskModule(context: Context): Boolean = withContext(Dispatchers.IO) {
44
    try {
45
        val config = getCurrentModuleConfig(context)
46

47
        // 创建模块目录
48
        if (!runCmdWithResult("mkdir -p $MODULE_PATH").isSuccess) return@withContext false
49

50
        // 创建module.prop
51
        val moduleProp = ScriptGenerator.generateModuleProp(MODULE_ID)
52
        if (!runCmdWithResult("cat > $MODULE_PATH/module.prop << 'EOF'\n$moduleProp\nEOF").isSuccess) return@withContext false
53

54
        // 生成并创建所有脚本文件
55
        val scripts = ScriptGenerator.generateAllScripts(config)
56

57
        scripts.all { (filename, content) ->
58
            runCmdWithResult("cat > $MODULE_PATH/$filename << 'EOF'\n$content\nEOF").isSuccess &&
59
                    runCmdWithResult("chmod 755 $MODULE_PATH/$filename").isSuccess
60
        }
61
    } catch (e: Exception) {
62
        e.printStackTrace()
63
        false
64
    }
65
}
66

67
private suspend fun removeMagiskModule(): Boolean = withContext(Dispatchers.IO) {
68
    try {
69
        runCmdWithResult("rm -rf $MODULE_PATH").isSuccess
70
    } catch (e: Exception) {
71
        e.printStackTrace()
72
        false
73
    }
74
}

1
suspend fun backupModules(context: Context, snackBarHost: SnackbarHostState, uri: Uri) {
2
    withContext(Dispatchers.IO) {
3
        try {
4
            val busyboxPath = "/data/adb/ksu/bin/busybox"
5
            val moduleDir = "/data/adb/modules"
6

7
            // 直接将tar输出重定向到用户选择的文件
8
            val command = """
9
                cd "$moduleDir" &&
10
                $busyboxPath tar -cz ./* > /proc/self/fd/1
11
            """.trimIndent()
12

13
            val process = Runtime.getRuntime().exec(arrayOf("su", "-c", command))
14

15
            // 直接将tar输出写入到用户选择的文件
16
            context.contentResolver.openOutputStream(uri)?.use { output ->
17
                process.inputStream.copyTo(output)
18
            }
19

20
            val error = BufferedReader(InputStreamReader(process.errorStream)).readText()
21
            if (process.exitValue() != 0) {
22
                throw IOException(context.getString(R.string.command_execution_failed, error))
23
            }
24

25
            withContext(Dispatchers.Main) {
26
                snackBarHost.showSnackbar(
27
                    context.getString(R.string.backup_success),
28
                    duration = SnackbarDuration.Long
29
                )
30
            }
31

32
        } catch (e: Exception) {
33
            Log.e("Backup", context.getString(R.string.backup_failed, ""), e)
34
            withContext(Dispatchers.Main) {
35
                snackBarHost.showSnackbar(
36
                    context.getString(R.string.backup_failed, e.message),
37
                    duration = SnackbarDuration.Long
38
                )
39
            }
40
        }
41
    }
42
}
43

44
suspend fun restoreModules(
45
    context: Context,
46
    snackBarHost: SnackbarHostState,
47
    uri: Uri,
48
    showConfirmDialog: (Boolean) -> Unit,
49
    confirmResult: CompletableDeferred<Boolean>
50
) {
51
    // 显示确认对话框
52
    withContext(Dispatchers.Main) {
53
        showConfirmDialog(true)
54
    }
55

56
    val userConfirmed = confirmResult.await()
57
    if (!userConfirmed) return
58

59
    withContext(Dispatchers.IO) {
60
        try {
61
            val busyboxPath = "/data/adb/ksu/bin/busybox"
62
            val moduleDir = "/data/adb/modules"
63

64
            // 直接从用户选择的文件读取并解压
65
            val process = Runtime.getRuntime().exec(arrayOf("su", "-c", "$busyboxPath tar -xz -C $moduleDir"))
66

67
            context.contentResolver.openInputStream(uri)?.use { input ->
68
                input.copyTo(process.outputStream)
69
            }
70
            process.outputStream.close()
71

72
            process.waitFor()
73

74
            val error = BufferedReader(InputStreamReader(process.errorStream)).readText()
75
            if (process.exitValue() != 0) {
76
                throw IOException(context.getString(R.string.command_execution_failed, error))
77
            }
78

79
            withContext(Dispatchers.Main) {
80
                val snackbarResult = snackBarHost.showSnackbar(
81
                    message = context.getString(R.string.restore_success),
82
                    actionLabel = context.getString(R.string.restart_now),
83
                    duration = SnackbarDuration.Long
84
                )
85
                if (snackbarResult == SnackbarResult.ActionPerformed) {
86
                    reboot()
87
                }
88
            }
89

90
        } catch (e: Exception) {
91
            Log.e("Restore", context.getString(R.string.restore_failed, ""), e)
92
            withContext(Dispatchers.Main) {
93
                snackBarHost.showSnackbar(
94
                    message = context.getString(
95
                        R.string.restore_failed,
96
                        e.message ?: context.getString(R.string.unknown_error)
97
                    ),
98
                    duration = SnackbarDuration.Long
99
                )
100
            }
101
        }
102
    }
103
}
104

105
suspend fun backupAllowlist(context: Context, snackBarHost: SnackbarHostState, uri: Uri) {
106
    withContext(Dispatchers.IO) {
107
        try {
108
            val allowlistPath = "/data/adb/ksu/.allowlist"
109

110
            // 直接复制文件到用户选择的位置
111
            val process = Runtime.getRuntime().exec(arrayOf("su", "-c", "cat $allowlistPath"))
112

113
            context.contentResolver.openOutputStream(uri)?.use { output ->
114
                process.inputStream.copyTo(output)
115
            }
116

117
            val error = BufferedReader(InputStreamReader(process.errorStream)).readText()
118
            if (process.exitValue() != 0) {
119
                throw IOException(context.getString(R.string.command_execution_failed, error))
120
            }
121

122
            withContext(Dispatchers.Main) {
123
                snackBarHost.showSnackbar(
124
                    context.getString(R.string.allowlist_backup_success),
125
                    duration = SnackbarDuration.Long
126
                )
127
            }
128

129
        } catch (e: Exception) {
130
            Log.e("AllowlistBackup", context.getString(R.string.allowlist_backup_failed, ""), e)
131
            withContext(Dispatchers.Main) {
132
                snackBarHost.showSnackbar(
133
                    context.getString(R.string.allowlist_backup_failed, e.message),
134
                    duration = SnackbarDuration.Long
135
                )
136
            }
137
        }
138
    }
139
}
140

141
suspend fun restoreAllowlist(
142
    context: Context,
143
    snackBarHost: SnackbarHostState,
144
    uri: Uri,
145
    showConfirmDialog: (Boolean) -> Unit,
146
    confirmResult: CompletableDeferred<Boolean>
147
) {
148
    // 显示确认对话框
149
    withContext(Dispatchers.Main) {
150
        showConfirmDialog(true)
151
    }
152

153
    val userConfirmed = confirmResult.await()
154
    if (!userConfirmed) return
155

156
    withContext(Dispatchers.IO) {
157
        try {
158
            val allowlistPath = "/data/adb/ksu/.allowlist"
159

160
            // 直接从用户选择的文件读取并写入到目标位置
161
            val process = Runtime.getRuntime().exec(arrayOf("su", "-c", "cat > $allowlistPath"))
162

163
            context.contentResolver.openInputStream(uri)?.use { input ->
164
                input.copyTo(process.outputStream)
165
            }
166
            process.outputStream.close()
167

168
            process.waitFor()
169

170
            val error = BufferedReader(InputStreamReader(process.errorStream)).readText()
171
            if (process.exitValue() != 0) {
172
                throw IOException(context.getString(R.string.command_execution_failed, error))
173
            }
174

175
            withContext(Dispatchers.Main) {
176
                snackBarHost.showSnackbar(
177
                    context.getString(R.string.allowlist_restore_success),
178
                    duration = SnackbarDuration.Long
179
                )
180
            }
181

182
        } catch (e: Exception) {
183
            Log.e("AllowlistRestore", context.getString(R.string.allowlist_restore_failed, ""), e)
184
            withContext(Dispatchers.Main) {
185
                snackBarHost.showSnackbar(
186
                    context.getString(R.string.allowlist_restore_failed, e.message),
187
                    duration = SnackbarDuration.Long
188
                )
189
            }
190
        }
191
    }
192
}
193

194
private fun reboot() {
195
    Runtime.getRuntime().exec(arrayOf("su", "-c", "reboot"))
196
}

1
// https://github.com/SukiSU-Ultra/SukiSU-Ultra/blob/main/manager/app/src/main/java/com/sukisu/ultra/ui/util/KsuCli.kt
2

3
fun getSuSFS(): String {
4
    val shell = getRootShell()
5
    val result = ShellUtils.fastCmd(shell, "${getSuSFSDaemonPath()} support")
6
    return result
7
}
8

9
fun getSuSFSVersion(): String {
10
    val shell = getRootShell()
11
    val result = ShellUtils.fastCmd(shell, "${getSuSFSDaemonPath()} version")
12
    return result
13
}
14

15
fun getSuSFSVariant(): String {
16
    val shell = getRootShell()
17
    val result = ShellUtils.fastCmd(shell, "${getSuSFSDaemonPath()} variant")
18
    return result
19
}
20

21
fun getSuSFSFeatures(): String {
22
    val shell = getRootShell()
23
    val result = ShellUtils.fastCmd(shell, "${getSuSFSDaemonPath()} features")
24
    return result
25
}
26

27
fun susfsSUS_SU_0(): String {
28
    val shell = getRootShell()
29
    val result = ShellUtils.fastCmd(shell, "${getSuSFSDaemonPath()} sus_su 0")
30
    return result
31
}
32

33
fun susfsSUS_SU_2(): String {
34
    val shell = getRootShell()
35
    val result = ShellUtils.fastCmd(shell, "${getSuSFSDaemonPath()} sus_su 2")
36
    return result
37
}
38

39
fun susfsSUS_SU_Mode(): String {
40
    val shell = getRootShell()
41
    val result = ShellUtils.fastCmd(shell, "${getSuSFSDaemonPath()} sus_su mode")
42
    return result
43
}
44

45
fun loadKpmModule(path: String, args: String? = null): String {
46
    val shell = getRootShell()
47
    val cmd = "${getKpmmgrPath()} load $path ${args ?: ""}"
48
    return ShellUtils.fastCmd(shell, cmd)
49
}
50

51
fun unloadKpmModule(name: String): String {
52
    val shell = getRootShell()
53
    val cmd = "${getKpmmgrPath()} unload $name"
54
    return ShellUtils.fastCmd(shell, cmd)
55
}
56

57
fun getKpmModuleCount(): Int {
58
    val shell = getRootShell()
59
    val cmd = "${getKpmmgrPath()} num"
60
    val result = ShellUtils.fastCmd(shell, cmd)
61
    return result.trim().toIntOrNull() ?: 0
62
}
63

64
fun runCmd(shell: Shell, cmd: String): String {
65
    return shell.newJob()
66
        .add(cmd)
67
        .to(mutableListOf<String>(), null)
68
        .exec().out
69
        .joinToString("\n")
70
}
71

72
fun listKpmModules(): String {
73
    val shell = getRootShell()
74
    val cmd = "${getKpmmgrPath()} list"
75
    return try {
76
        runCmd(shell, cmd).trim()
77
    } catch (e: Exception) {
78
        Log.e(TAG, "Failed to list KPM modules", e)
79
        ""
80
    }
81
}
82

83
fun getKpmModuleInfo(name: String): String {
84
    val shell = getRootShell()
85
    val cmd = "${getKpmmgrPath()} info $name"
86
    return try {
87
        runCmd(shell, cmd).trim()
88
    } catch (e: Exception) {
89
        Log.e(TAG, "Failed to get KPM module info: $name", e)
90
        ""
91
    }
92
}
93

94
fun controlKpmModule(name: String, args: String? = null): Int {
95
    val shell = getRootShell()
96
    val cmd = """${getKpmmgrPath()} control $name "${args ?: ""}"""//" // 由于代码块解析出错，这里忽略掉一个双引号
97
    val result = runCmd(shell, cmd)
98
    return result.trim().toIntOrNull() ?: -1
99
}
100

101
fun getKpmVersion(): String {
102
    val shell = getRootShell()
103
    val cmd = "${getKpmmgrPath()} version"
104
    val result = ShellUtils.fastCmd(shell, cmd)
105
    return result.trim()
106
}