mirrors/aniyomi
1
0
Fork 0
mirror of https://github.com/aniyomiorg/aniyomi.git synced 2024-11-28 17:19:00 +03:00
Code Issues Projects Releases Packages Wiki Activity

add auto-update tracker for anime

Browse source
This commit is contained in:
jmir1 2021-05-25 19:18:59 +02:00
parent 0381149e95
commit bf21664cc6
1 changed files with 39 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

40
app/src/main/java/eu/kanade/tachiyomi/ui/watcher/WatcherActivity.kt
View file

@ -28,12 +28,16 @@ import eu.kanade.tachiyomi.data.database.models.Episode
import eu.kanade.tachiyomi.data.download.AnimeDownloadManager
import eu.kanade.tachiyomi.data.download.model.AnimeDownload
import eu.kanade.tachiyomi.data.preference.PreferencesHelper
import eu.kanade.tachiyomi.data.track.TrackManager
import eu.kanade.tachiyomi.source.AnimeSource
import eu.kanade.tachiyomi.source.AnimeSourceManager
import eu.kanade.tachiyomi.ui.anime.episode.EpisodeItem
import eu.kanade.tachiyomi.util.lang.launchIO
import eu.kanade.tachiyomi.util.view.hideBar
import kotlinx.coroutines.async
import kotlinx.coroutines.awaitAll
import rx.schedulers.Schedulers
import timber.log.Timber
import uy.kohesive.injekt.Injekt
import uy.kohesive.injekt.api.get
import java.util.Date
@ -256,7 +260,9 @@ class WatcherActivity : AppCompatActivity() {
val episodes = listOf(EpisodeItem(episode, anime))
launchIO {
db.updateEpisodesProgress(episodes).executeAsBlocking()
if (preferences.autoUpdateTrack()) {
updateTrackEpisodeSeen(episode)
}
if (preferences.removeAfterMarkedAsRead()) {
launchIO {
try {
@ -278,6 +284,38 @@ class WatcherActivity : AppCompatActivity() {
}
}
private fun updateTrackEpisodeSeen(episode: Episode) {
val anime = intent.getSerializableExtra("anime_anime") as? Anime ?: return
val episodeSeen = episode.episode_number.toInt()
val trackManager = Injekt.get<TrackManager>()
launchIO {
db.getTracks(anime).executeAsBlocking()
.mapNotNull { track ->
val service = trackManager.getService(track.sync_id)
if (service != null && service.isLogged && episodeSeen > track.last_episode_seen) {
track.last_episode_seen = episodeSeen
// We want these to execute even if the presenter is destroyed and leaks
// for a while. The view can still be garbage collected.
async {
runCatching {
service.update(track)
db.insertTrack(track).executeAsBlocking()
}
}
} else {
null
}
}
.awaitAll()
.mapNotNull { it.exceptionOrNull() }
.forEach { Timber.w(it) }
}
}
companion object {
fun newIntent(context: Context, anime: Anime, episode: Episode, episodeList: List<EpisodeItem>, url: String): Intent {
return Intent(context, WatcherActivity::class.java).apply {