Show updates as soon as it is available (1ce7aa85) · Commits · e / os / App Lounge

app/src/main/java/foundation/e/apps/updates/model/OutdatedApplicationsFileReader.kt

+29 −33

Original line number	Diff line number	Diff line
		@@ -18,53 +18,28 @@
		package foundation.e.apps.updates.model

		import android.content.Context
		import android.content.pm.PackageManager
		import android.os.AsyncTask
		import foundation.e.apps.application.model.Application
		import foundation.e.apps.application.model.State
		import foundation.e.apps.applicationmanager.ApplicationManager
		import foundation.e.apps.utils.Common
		import foundation.e.apps.utils.Constants
		import foundation.e.apps.utils.Execute
		import java.io.BufferedReader
		import java.io.InputStreamReader

		class OutdatedApplicationsFileReader(private val applicationManager: ApplicationManager,
		class OutdatedApplicationsFileReader(private val packageManager: PackageManager,
		private val applicationManager: ApplicationManager,
		private val callback: UpdatesModelInterface) :
		AsyncTask<Context, Void, ArrayList<Application>>() {
		override fun doInBackground(vararg context: Context): ArrayList<Application> {
		val applications = ArrayList<Application>()
		var totalLines = 0
		var requestsComplete = 0
		val blocker = Object()
		try {
		context[0].openFileInput(Constants.OUTDATED_APPLICATIONS_FILENAME).use {
		BufferedReader(InputStreamReader(it)).forEachLine {
		totalLines++
		}
		}
		if (totalLines > 0) {
		context[0].openFileInput(Constants.OUTDATED_APPLICATIONS_FILENAME).use {
		BufferedReader(InputStreamReader(it)).forEachLine { packageName ->
		Execute({
		val installedApplications = getInstalledApplications()
		installedApplications.forEach { packageName ->
		val application = applicationManager.findOrCreateApp(packageName)
		val error = application.assertBasicData(context[0])
		if (error == null) {
		if (application.state == State.NOT_UPDATED) {
		applications.add(application)
		}
		}
		}, {
		requestsComplete++
		if (requestsComplete == totalLines) {
		synchronized(blocker) {
		blocker.notify()
		}
		}
		})
		}
		synchronized(blocker) {
		blocker.wait()
		}
		}
		verifyApplication(application, applications, context)
		}
		} catch (exception: Exception) {
		exception.printStackTrace()
		@@ -75,4 +50,25 @@ class OutdatedApplicationsFileReader(private val applicationManager: Application
		override fun onPostExecute(result: ArrayList<Application>) {
		callback.onAppsFound(result)
		}

		private fun getInstalledApplications(): ArrayList<String> {
		val result = ArrayList<String>()
		packageManager.getInstalledApplications(0).forEach { app ->
		if (!Common.isSystemApp(packageManager, app.packageName)) {
		result.add(app.packageName)
		}
		}
		return result
		}

		private fun verifyApplication(application: Application, apps: ArrayList<Application>,
		context: Array<out Context>) {
		val error = application.assertBasicData(context[0])
		if (error == null && application.state == State.NOT_UPDATED) {
		apps.add(application)
		} else {
		application.decrementUses()
		}
		}

		}

app/src/main/java/foundation/e/apps/updates/model/UpdatesModel.kt

+1 −1

Original line number	Diff line number	Diff line
		@@ -33,7 +33,7 @@ class UpdatesModel : UpdatesModelInterface {

		override fun loadApplicationList(context: Context) {
		if (Common.isNetworkAvailable(context)) {
		OutdatedApplicationsFileReader(applicationManager!!, this)
		OutdatedApplicationsFileReader(context.packageManager,applicationManager!!, this)
		.executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR, context)
		} else {
		screenError.value = Error.NO_INTERNET