Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions manager/build.gradle.kts
Original file line number Diff line number Diff line change
Expand Up @@ -39,6 +39,7 @@ android {
}

buildFeatures {
aidl = true
compose = true
buildConfig = true
}
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,9 @@
package org.lsposed.lspatch;

interface IShizukuService {
// Executes a shell command and returns the output
String runShellCommand(String cmd) = 1;

// Allows closing the service from the client side
void destroy() = 2;
}
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ class LSPApplication : Application() {
filesDir.mkdir()
tmpApkDir = cacheDir.resolve("apk").also { it.mkdir() }
prefs = lspApp.getSharedPreferences("settings", Context.MODE_PRIVATE)
ShizukuApi.init()
ShizukuApi.init(this)
AppBroadcastReceiver.register(this)
globalScope.launch { LSPPackageManager.fetchAppList() }
}
Expand Down
22 changes: 22 additions & 0 deletions manager/src/main/java/org/lsposed/lspatch/ShizukuService.kt
Original file line number Diff line number Diff line change
@@ -0,0 +1,22 @@
package org.lsposed.lspatch

import org.lsposed.lspatch.IShizukuService
import kotlin.system.exitProcess

class ShizukuService : IShizukuService.Stub() {
override fun runShellCommand(cmd: String): String {
return try {
val process = Runtime.getRuntime().exec(cmd)
val output = process.inputStream.bufferedReader().readText()
val error = process.errorStream.bufferedReader().readText()
process.waitFor()
output + error
} catch (e: Exception) {
e.stackTraceToString()
}
}

override fun destroy() {
exitProcess(0)
}
}
85 changes: 78 additions & 7 deletions manager/src/main/java/org/lsposed/lspatch/util/ShizukuApi.kt
Original file line number Diff line number Diff line change
@@ -1,6 +1,9 @@
package org.lsposed.lspatch.util

import android.content.ComponentName
import android.content.Context
import android.content.IntentSender
import android.content.ServiceConnection
import android.content.pm.*
import android.os.Build
import android.os.IBinder
Expand All @@ -11,12 +14,35 @@ import androidx.compose.runtime.getValue
import androidx.compose.runtime.mutableStateOf
import androidx.compose.runtime.setValue
import dev.rikka.tools.refine.Refine
import kotlinx.coroutines.CompletableDeferred
import kotlinx.coroutines.withTimeoutOrNull
import org.lsposed.lspatch.IShizukuService
import org.lsposed.lspatch.ShizukuService
import rikka.shizuku.Shizuku
import rikka.shizuku.ShizukuBinderWrapper
import rikka.shizuku.SystemServiceHelper

object ShizukuApi {

@Volatile
private var userService: IShizukuService? = null

// This allows us to "await" the service connection
private var userServiceDeferred = CompletableDeferred<IShizukuService>()

private val userServiceConnection = object : ServiceConnection {
override fun onServiceConnected(name: ComponentName, service: IBinder) {
val binder = IShizukuService.Stub.asInterface(service)
userService = binder
userServiceDeferred.complete(binder)
}

override fun onServiceDisconnected(name: ComponentName) {
userService = null
userServiceDeferred = CompletableDeferred()
}
}

private fun IBinder.wrap() = ShizukuBinderWrapper(this)
private fun IInterface.asShizukuBinder() = this.asBinder().wrap()

Expand All @@ -40,14 +66,34 @@ object ShizukuApi {
var isBinderAvailable = false
var isPermissionGranted by mutableStateOf(false)

fun init() {
fun init(context: Context) {
Shizuku.addBinderReceivedListenerSticky {
isBinderAvailable = true
isPermissionGranted = Shizuku.checkSelfPermission() == PackageManager.PERMISSION_GRANTED
if (isPermissionGranted) {
// Trigger the service binding as soon as we have permission
bindUserService(context)
}
}
Shizuku.addBinderDeadListener {
isBinderAvailable = false
isPermissionGranted = false
userService = null
userServiceDeferred = CompletableDeferred()
}
}

private fun bindUserService(context: Context) {
if (userService != null) return
val args = Shizuku.UserServiceArgs(ComponentName(context.packageName, ShizukuService::class.java.name))
.daemon(false)
.processNameSuffix("service")
.debuggable(true)

try {
Shizuku.bindUserService(args, userServiceConnection)
} catch (e: Exception) {
e.printStackTrace()
}
}

Expand All @@ -71,11 +117,36 @@ object ShizukuApi {
packageInstaller.uninstall(packageName, intentSender)
}

fun performDexOptMode(packageName: String): Boolean {
return iPackageManager.performDexOptMode(
packageName,
SystemProperties.getBoolean("dalvik.vm.usejitprofiles", false),
"verify", true, true, null
)
suspend fun performDexOptMode(packageName: String): Boolean {
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.UPSIDE_DOWN_CAKE) { // API 34+
// Wait up to 3 seconds for the service to connect if it hasn't yet
val service = userService ?: withTimeoutOrNull(3000) {
userServiceDeferred.await()
} ?: return false

return try {
val command = "cmd package compile -m speed-profile -f $packageName"
val output = service.runShellCommand(command)
// Return true if output contains "Success"
output.contains("Success")
} catch (e: Exception) {
e.printStackTrace()
false
}
} else {
// Legacy reflection-based method for older versions
return try {
iPackageManager.performDexOptMode(
packageName,
SystemProperties.getBoolean("dalvik.vm.usejitprofiles", false),
"verify",
true,
true,
null
)
} catch (e: Exception) {
false
}
}
}
}