ProfessionalUwU/tachiyomi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fixes to the extension updates notifcation

Browse Source
This commit is contained in:
Jay 2020-01-05 22:19:30 -08:00
parent f66c84091a
commit 5261864aba
1 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
app/src/main/java/eu/kanade/tachiyomi/extension/ExtensionUpdateJob.kt
View File

@ -1,6 +1,7 @@
package eu.kanade.tachiyomi.extension package eu.kanade.tachiyomi.extension
import androidx.core.app.NotificationCompat
import androidx.core.app.NotificationManagerCompat import androidx.core.app.NotificationManagerCompat
import androidx.core.content.ContextCompat import androidx.core.content.ContextCompat
import com.evernote.android.job.Job import com.evernote.android.job.Job
@ -11,7 +12,6 @@ import eu.kanade.tachiyomi.data.notification.NotificationReceiver
import eu.kanade.tachiyomi.data.notification.Notifications import eu.kanade.tachiyomi.data.notification.Notifications
import eu.kanade.tachiyomi.util.notification import eu.kanade.tachiyomi.util.notification
import rx.Observable import rx.Observable
import rx.Subscription
import rx.schedulers.Schedulers import rx.schedulers.Schedulers
import timber.log.Timber import timber.log.Timber
import uy.kohesive.injekt.Injekt import uy.kohesive.injekt.Injekt
@ -20,16 +20,12 @@ import java.util.concurrent.TimeUnit
class ExtensionUpdateJob : Job() { class ExtensionUpdateJob : Job() {
var subscription:Subscription? = null
override fun onRunJob(params: Params): Result { override fun onRunJob(params: Params): Result {
val extensionManager: ExtensionManager = Injekt.get() val extensionManager: ExtensionManager = Injekt.get()
extensionManager.findAvailableExtensions() extensionManager.findAvailableExtensions()
subscription?.unsubscribe()
// Update favorite manga. Destroy service when completed or in case of an error. // Update favorite manga. Destroy service when completed or in case of an error.
subscription = Observable.defer { Observable.defer {
extensionManager.getInstalledExtensionsObservable().map { list -> extensionManager.getInstalledExtensionsObservable().map { list ->
val pendingUpdates = list.filter { it.hasUpdate } val pendingUpdates = list.filter { it.hasUpdate }
if (pendingUpdates.isNotEmpty()) { if (pendingUpdates.isNotEmpty()) {
@ -48,6 +44,7 @@ class ExtensionUpdateJob : Job() {
) )
} else names.joinToString(", ") } else names.joinToString(", ")
setContentText(extNames) setContentText(extNames)
setStyle(NotificationCompat.BigTextStyle().bigText(extNames))
setSmallIcon(R.drawable.ic_extension_update) setSmallIcon(R.drawable.ic_extension_update)
color = ContextCompat.getColor(context, R.color.colorAccentLight) color = ContextCompat.getColor(context, R.color.colorAccentLight)
setContentIntent( setContentIntent(
@ -59,7 +56,6 @@ class ExtensionUpdateJob : Job() {
}) })
} }
} }
subscription?.unsubscribe()
Result.SUCCESS Result.SUCCESS
} }
}.subscribeOn(Schedulers.io()) }.subscribeOn(Schedulers.io())