Skip to content

rewrite data loader #439

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
Hamza417 wants to merge 1 commit into
base: master
Choose a base branch
from
Open

rewrite data loader #439

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
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
2 changes: 1 addition & 1 deletion app/src/main/java/app/simple/inure/decorations/views/LineNumberEditText.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@

public class LineNumberEditText extends TypeFaceEditText implements SharedPreferences.OnSharedPreferenceChangeListener {

private final String newline = System.getProperty("line.separator");
private final String newline = System.lineSeparator();
private Rect rect;
private Paint paint;

Expand Down
175 changes: 47 additions & 128 deletions app/src/main/java/app/simple/inure/extensions/viewmodels/PackageUtilsViewModel.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,123 +1,72 @@
package app.simple.inure.extensions.viewmodels

import android.annotation.SuppressLint
import android.app.Application
import android.content.BroadcastReceiver
import android.content.ComponentName
import android.content.Context
import android.content.Intent
import android.content.IntentFilter
import android.content.ServiceConnection
import android.content.pm.ApplicationInfo
import android.content.pm.PackageInfo
import android.content.pm.PackageManager
import android.os.Build
import android.os.DeadObjectException
import android.os.IBinder
import android.util.Log
import androidx.localbroadcastmanager.content.LocalBroadcastManager
import androidx.lifecycle.viewModelScope
import app.simple.inure.R
import app.simple.inure.apk.utils.PackageUtils
import app.simple.inure.apk.utils.PackageUtils.safeApplicationInfo
import app.simple.inure.services.DataLoaderService
import app.simple.inure.util.ArrayUtils
import kotlinx.coroutines.flow.collectLatest
import kotlinx.coroutines.launch

abstract class PackageUtilsViewModel(application: Application) : WrappedViewModel(application) {

private var apps: ArrayList<PackageInfo> = arrayListOf()
private var uninstalledApps: ArrayList<PackageInfo> = arrayListOf()

private var serviceConnection: ServiceConnection? = null

@SuppressLint("StaticFieldLeak") // This is an application context
private var dataLoaderService: DataLoaderService? = null
private var broadcastReceiver: BroadcastReceiver? = null
private var intentFilter: IntentFilter = IntentFilter()
private var serviceConnection: ServiceConnection? = null

init {
intentFilter.addAction(DataLoaderService.APPS_LOADED)
intentFilter.addAction(DataLoaderService.UNINSTALLED_APPS_LOADED)
intentFilter.addAction(DataLoaderService.INSTALLED_APPS_LOADED)
intentFilter.addAction(DataLoaderService.RELOAD_APPS)

serviceConnection = object : ServiceConnection {
override fun onServiceConnected(name: ComponentName?, service: IBinder?) {
dataLoaderService = (service as DataLoaderService.LoaderBinder).getService()
if (dataLoaderService!!.hasDataLoaded()) {
apps = dataLoaderService!!.getInstalledApps()
uninstalledApps = dataLoaderService!!.getUninstalledApps()

onAppsLoaded(apps)
onUninstalledAppsLoaded(uninstalledApps)
} else {
dataLoaderService!!.startLoading()
}
observeServiceFlows()
dataLoaderService?.refresh()
}

override fun onServiceDisconnected(name: ComponentName?) {
dataLoaderService = null
}
}

@Suppress("UNCHECKED_CAST")
broadcastReceiver = object : BroadcastReceiver() {
override fun onReceive(context: Context?, intent: Intent?) {
when (intent?.action) {
DataLoaderService.APPS_LOADED -> {
apps = dataLoaderService!!.getInstalledApps().clone() as ArrayList<PackageInfo>
uninstalledApps = dataLoaderService!!.getUninstalledApps().clone() as ArrayList<PackageInfo>

onAppsLoaded(apps)
onUninstalledAppsLoaded(uninstalledApps)
}

DataLoaderService.UNINSTALLED_APPS_LOADED -> {
uninstalledApps = dataLoaderService!!.getUninstalledApps().clone() as ArrayList<PackageInfo>
onUninstalledAppsLoaded(uninstalledApps)
}

DataLoaderService.INSTALLED_APPS_LOADED -> {
apps = dataLoaderService!!.getInstalledApps().clone() as ArrayList<PackageInfo>
onAppsLoaded(apps)
}
applicationContext().bindService(
Intent(applicationContext(), DataLoaderService::class.java),
serviceConnection!!,
Context.BIND_AUTO_CREATE
)
}

DataLoaderService.RELOAD_APPS -> {
Log.d("DataLoaderService", "Reloading apps")
dataLoaderService!!.refresh()
}
private fun observeServiceFlows() {
viewModelScope.launch {
dataLoaderService?.installedApps?.collectLatest { apps ->
if (apps != null) {
onAppsLoaded(ArrayUtils.deepCopy(apps))
}
}
}
viewModelScope.launch {
dataLoaderService?.uninstalledApps?.collectLatest { apps ->
if (apps != null) {
onUninstalledAppsLoaded(ArrayUtils.deepCopy(apps))
}
}
}

LocalBroadcastManager.getInstance(applicationContext()).registerReceiver(broadcastReceiver!!, intentFilter)
applicationContext().bindService(
Intent(applicationContext(), DataLoaderService::class.java), serviceConnection!!, Context.BIND_AUTO_CREATE)
}

fun getInstalledApps(): ArrayList<PackageInfo> {
return dataLoaderService!!.getInstalledApps()
}

fun getUninstalledApps(): ArrayList<PackageInfo> {
return dataLoaderService!!.getUninstalledApps()
}

fun getCompleteApps(): List<PackageInfo> {
return getInstalledApps() + getUninstalledApps()
}

fun refreshPackageData() {
dataLoaderService!!.refresh()
}

fun refreshUninstalledPackageData() {
dataLoaderService!!.refreshUninstalled()
}

fun refreshInstalledPackageData() {
dataLoaderService!!.refreshInstalled()
dataLoaderService?.refresh()
}

// Utility and helper functions remain unchanged
protected fun PackageManager.isPackageInstalled(packageName: String): Boolean {
while (true) {
try {
Expand All @@ -129,7 +78,7 @@ abstract class PackageUtilsViewModel(application: Application) : WrappedViewMode
return true
} catch (e: PackageManager.NameNotFoundException) {
return false
} catch (e: DeadObjectException) {
} catch (e: android.os.DeadObjectException) {
Log.e("PackageUtilsViewModel", "isPackageInstalled: DeadObjectException")
}
}
Expand All @@ -138,9 +87,9 @@ abstract class PackageUtilsViewModel(application: Application) : WrappedViewMode
protected fun PackageManager.isPackageEnabled(packageName: String): Boolean {
return try {
getPackageInfo(packageName)!!.safeApplicationInfo.enabled
} catch (e: PackageManager.NameNotFoundException) {
} catch (_: PackageManager.NameNotFoundException) {
false
} catch (e: NullPointerException) {
} catch (_: NullPointerException) {
false
}
}
Expand All @@ -149,17 +98,6 @@ abstract class PackageUtilsViewModel(application: Application) : WrappedViewMode
return isPackageInstalled(packageName) && isPackageEnabled(packageName)
}

protected fun PackageManager.getInstalledPackages(flags: Long = PackageUtils.flags): ArrayList<PackageInfo> {
val packageInfoList = ArrayList<PackageInfo>()
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.TIRAMISU) {
packageInfoList.addAll(getInstalledPackages(PackageManager.PackageInfoFlags.of(flags)))
} else {
@Suppress("DEPRECATION")
packageInfoList.addAll(getInstalledPackages(flags.toInt()))
}
return ArrayUtils.deepCopy(packageInfoList)
}

protected fun PackageManager.getPackageInfo(packageName: String): PackageInfo? {
try {
return if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.TIRAMISU) {
Expand All @@ -168,15 +106,14 @@ abstract class PackageUtilsViewModel(application: Application) : WrappedViewMode
try {
@Suppress("DEPRECATION")
getPackageInfo(packageName, PackageUtils.flags.toInt())
} catch (e: RuntimeException) {
} catch (_: RuntimeException) {
@Suppress("DEPRECATION")
getPackageInfo(packageName, PackageManager.GET_META_DATA)
}
}
} catch (e: PackageManager.NameNotFoundException) {
e.printStackTrace()
}

return null
}

Expand All @@ -192,67 +129,49 @@ abstract class PackageUtilsViewModel(application: Application) : WrappedViewMode
} catch (e: PackageManager.NameNotFoundException) {
e.printStackTrace()
}

return null
}

/**
* Fetches the app's name from the package id of the same application
* @param context of the given environment
* @param applicationInfo is [ApplicationInfo] object containing app's
* information
* @return app's name as [String]
*/
protected fun getApplicationName(context: Context, applicationInfo: ApplicationInfo): String {
while (true) {
try {
return context.packageManager.getApplicationLabel(applicationInfo).toString()
} catch (e: PackageManager.NameNotFoundException) {
} catch (_: PackageManager.NameNotFoundException) {
return context.getString(R.string.unknown)
} catch (e: DeadObjectException) {
} catch (_: android.os.DeadObjectException) {
Log.e("PackageUtilsViewModel", "getApplicationName: DeadObjectException")
}
}
}

protected fun ArrayList<PackageInfo>.loadPackageNames(): ArrayList<PackageInfo> {
forEach {
it.safeApplicationInfo.name = getApplicationName(applicationContext(), it.safeApplicationInfo)
}
open fun onUninstalledAppsLoaded(uninstalledApps: ArrayList<PackageInfo>) {
// Override in subclasses
}

return this
open fun onAppsLoaded(apps: ArrayList<PackageInfo>) {
// Override in subclasses
}

open fun onUninstalledAppsLoaded(uninstalledApps: ArrayList<PackageInfo>) {
// Log.d("PackageUtilsViewModel", "onUninstalledAppsLoaded: ${uninstalledApps.size}")
open fun getInstalledApps(): ArrayList<PackageInfo> {
return ArrayUtils.deepCopy(dataLoaderService?.installedApps?.value ?: ArrayList())
}

open fun onAppsLoaded(apps: ArrayList<PackageInfo>) {
// Log.d("PackageUtilsViewModel", "onAppsLoaded: ${apps.size}")
open fun getUninstalledApps(): ArrayList<PackageInfo> {
return ArrayUtils.deepCopy(dataLoaderService?.uninstalledApps?.value ?: ArrayList())
}

override fun onCleared() {
super.onCleared()
try {
serviceConnection?.let {
applicationContext().unbindService(it)
app.applicationContext.unbindService(it)
}
} catch (e: java.lang.IllegalStateException) {
e.printStackTrace()
} catch (e: IllegalArgumentException) {
} catch (e: Exception) {
e.printStackTrace()
}
}

try {
broadcastReceiver?.let {
LocalBroadcastManager.getInstance(applicationContext()).unregisterReceiver(it)
}
} catch (e: java.lang.IllegalStateException) {
e.printStackTrace()
} catch (e: IllegalArgumentException) {
e.printStackTrace()
} catch (e: NullPointerException) {
e.printStackTrace()
}
companion object {
private const val TAG = "PackageUtilsViewModel"
}
}
}
Loading