|
|
@@ -0,0 +1,147 @@
|
|
|
+/******************************************************************************
|
|
|
+ * Copyright (C) 2022 by nekohasekai <[email protected]> *
|
|
|
+ * *
|
|
|
+ * This program is free software: you can redistribute it and/or modify *
|
|
|
+ * it under the terms of the GNU General Public License as published by *
|
|
|
+ * the Free Software Foundation, either version 3 of the License, or *
|
|
|
+ * (at your option) any later version. *
|
|
|
+ * *
|
|
|
+ * This program is distributed in the hope that it will be useful, *
|
|
|
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of *
|
|
|
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
|
|
|
+ * GNU General Public License for more details. *
|
|
|
+ * *
|
|
|
+ * You should have received a copy of the GNU General Public License *
|
|
|
+ * along with this program. If not, see <http://www.gnu.org/licenses/>. *
|
|
|
+ * *
|
|
|
+ ******************************************************************************/
|
|
|
+
|
|
|
+package io.nekohasekai.sagernet.ui.sai
|
|
|
+
|
|
|
+import android.annotation.SuppressLint
|
|
|
+import android.app.PendingIntent
|
|
|
+import android.content.ContentResolver
|
|
|
+import android.content.Intent
|
|
|
+import android.content.pm.PackageInstaller
|
|
|
+import android.content.pm.PackageManager
|
|
|
+import android.net.Uri
|
|
|
+import android.os.Build
|
|
|
+import android.os.Bundle
|
|
|
+import androidx.documentfile.provider.DocumentFile
|
|
|
+import com.google.android.material.dialog.MaterialAlertDialogBuilder
|
|
|
+import io.nekohasekai.sagernet.R
|
|
|
+import io.nekohasekai.sagernet.ktx.Logs
|
|
|
+import io.nekohasekai.sagernet.ktx.readableMessage
|
|
|
+import io.nekohasekai.sagernet.ui.ThemedActivity
|
|
|
+import java.io.File
|
|
|
+import java.io.InputStream
|
|
|
+import java.util.zip.ZipEntry
|
|
|
+import java.util.zip.ZipInputStream
|
|
|
+
|
|
|
+class SplitAPKsInstallerActivity : ThemedActivity() {
|
|
|
+
|
|
|
+ override val type = Type.Translucent
|
|
|
+
|
|
|
+ override fun onCreate(savedInstanceState: Bundle?) {
|
|
|
+ super.onCreate(savedInstanceState)
|
|
|
+
|
|
|
+ val uri = intent.data
|
|
|
+ if (uri == null) {
|
|
|
+ finish()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ handleUri(uri)
|
|
|
+ }
|
|
|
+
|
|
|
+ fun handleUri(contentUri: Uri) {
|
|
|
+ val document = getDocument(contentUri)
|
|
|
+ if (document == null) {
|
|
|
+ returnError("Failed to get document")
|
|
|
+ return
|
|
|
+ }
|
|
|
+ val documentName = document.name
|
|
|
+ if (documentName == null) {
|
|
|
+ returnError("Failed to get document name")
|
|
|
+ return
|
|
|
+ }
|
|
|
+ Logs.d("Install $documentName")
|
|
|
+ val extension = File(documentName).extension
|
|
|
+
|
|
|
+ if (extension != "apks") {
|
|
|
+ returnError("Not a split apks file")
|
|
|
+ return
|
|
|
+ }
|
|
|
+ runCatching {
|
|
|
+ contentResolver.openInputStream(contentUri)!!.use {
|
|
|
+ handleInputStream(it)
|
|
|
+ }
|
|
|
+ /* }.recoverCatching { ex ->
|
|
|
+ if (ex.message == "only DEFLATED entries can have EXT descriptor") {
|
|
|
+ contentResolver.openInputStream(contentUri)!!.use {
|
|
|
+ copyAndHandleInputStream(it)
|
|
|
+ }
|
|
|
+ } else throw ex*/
|
|
|
+ }.onFailure {
|
|
|
+ Logs.w(it)
|
|
|
+ returnError(it.readableMessage)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ fun returnError(message: String) {
|
|
|
+ MaterialAlertDialogBuilder(this).setTitle(R.string.error_title)
|
|
|
+ .setMessage(message)
|
|
|
+ .setPositiveButton(android.R.string.ok) { _, _ -> finish() }
|
|
|
+ .show()
|
|
|
+ }
|
|
|
+
|
|
|
+ fun handleInputStream(inputStream: InputStream) {
|
|
|
+ val packageInstaller = packageManager.packageInstaller
|
|
|
+ val sessionParams = PackageInstaller.SessionParams(PackageInstaller.SessionParams.MODE_FULL_INSTALL)
|
|
|
+ if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
|
|
|
+ sessionParams.setInstallReason(PackageManager.INSTALL_REASON_USER)
|
|
|
+ }
|
|
|
+ val sessionId = try {
|
|
|
+ packageInstaller.createSession(sessionParams)
|
|
|
+ } catch (e: IllegalStateException) {
|
|
|
+ packageInstaller.mySessions.forEach {
|
|
|
+ packageInstaller.abandonSession(it.sessionId)
|
|
|
+ }
|
|
|
+ packageInstaller.createSession(sessionParams)
|
|
|
+ }
|
|
|
+ Logs.d("Create install session $sessionId")
|
|
|
+ val session = packageInstaller.openSession(sessionId)
|
|
|
+ ZipInputStream(inputStream).use { zip ->
|
|
|
+ var currentZipEntry: ZipEntry
|
|
|
+ while (true) {
|
|
|
+ currentZipEntry = zip.nextEntry ?: break
|
|
|
+ if (currentZipEntry.isDirectory) continue
|
|
|
+ if (!currentZipEntry.name.lowercase().endsWith(".apk")) continue
|
|
|
+ Logs.d("Write ${currentZipEntry.name}")
|
|
|
+ session.openWrite(currentZipEntry.name, 0, currentZipEntry.size).use {
|
|
|
+ zip.copyTo(it)
|
|
|
+ session.fsync(it)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ @SuppressLint("UnspecifiedImmutableFlag") val intent = PendingIntent.getService(
|
|
|
+ applicationContext,
|
|
|
+ 0,
|
|
|
+ Intent(applicationContext, SplitAPKsInstallerService::class.java),
|
|
|
+ 0
|
|
|
+ )
|
|
|
+ session.commit(intent.intentSender)
|
|
|
+ Logs.d("Commit session")
|
|
|
+ session.close()
|
|
|
+ finish()
|
|
|
+ }
|
|
|
+
|
|
|
+ fun getDocument(contentUri: Uri): DocumentFile? {
|
|
|
+ return if (ContentResolver.SCHEME_FILE == contentUri.scheme) {
|
|
|
+ val path: String = contentUri.path ?: return null
|
|
|
+ val file = File(path)
|
|
|
+ if (file.isDirectory) null else DocumentFile.fromFile(file)
|
|
|
+ } else {
|
|
|
+ DocumentFile.fromSingleUri(this, contentUri)
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
世界