MangaPresenter: Fix state updates when opening a new manga entry (#7379)
(cherry picked from commit 0e0c1dcdc5f42b0a63d5b865c9aba29db4ab18a6) # Conflicts: # app/src/main/java/eu/kanade/tachiyomi/ui/manga/MangaPresenter.kt
This commit is contained in:
Ivan Iskandar
Jobobby04
parent
a3dd6b523a
commit
3fa1c24f8d
@ -32,7 +32,6 @@ import eu.kanade.tachiyomi.data.download.DownloadManager
|
||||
import eu.kanade.tachiyomi.data.download.model.Download
|
||||
import eu.kanade.tachiyomi.data.library.CustomMangaManager
|
||||
import eu.kanade.tachiyomi.data.preference.PreferencesHelper
|
||||
import eu.kanade.tachiyomi.data.saver.ImageSaver
|
||||
import eu.kanade.tachiyomi.data.track.EnhancedTrackService
|
||||
import eu.kanade.tachiyomi.data.track.TrackManager
|
||||
import eu.kanade.tachiyomi.data.track.TrackService
|
||||
@ -84,6 +83,7 @@ import kotlinx.coroutines.flow.collectLatest
|
||||
import kotlinx.coroutines.flow.combine
|
||||
import kotlinx.coroutines.flow.launchIn
|
||||
import kotlinx.coroutines.flow.onEach
|
||||
import kotlinx.coroutines.flow.update
|
||||
import kotlinx.coroutines.supervisorScope
|
||||
import kotlinx.coroutines.withContext
|
||||
import logcat.LogPriority
|
||||
@ -152,8 +152,6 @@ class MangaPresenter(
|
||||
|
||||
private val loggedServices by lazy { trackManager.services.filter { it.isLogged } }
|
||||
|
||||
private val imageSaver: ImageSaver by injectLazy()
|
||||
|
||||
private var trackSubscription: Subscription? = null
|
||||
private var searchTrackerJob: Job? = null
|
||||
private var refreshTrackersJob: Job? = null
|
||||
@ -194,6 +192,13 @@ class MangaPresenter(
|
||||
this(pair.first, pair.second, flatMetadata)
|
||||
}
|
||||
|
||||
/**
|
||||
* Helper function to update the UI state only if it's currently in success state
|
||||
*/
|
||||
private fun updateSuccessState(func: (MangaScreenState.Success) -> MangaScreenState.Success) {
|
||||
_state.update { if (it is MangaScreenState.Success) func(it) else it }
|
||||
}
|
||||
|
||||
override fun onCreate(savedState: Bundle?) {
|
||||
super.onCreate(savedState)
|
||||
|
||||
@ -253,49 +258,50 @@ class MangaPresenter(
|
||||
// SY <--
|
||||
.collectLatest { (manga, chapters, flatMetadata, mergedData) ->
|
||||
val chapterItems = chapters.toChapterItems(manga, mergedData)
|
||||
val currentState = _state.value
|
||||
_state.value = when (currentState) {
|
||||
// Initialize success state
|
||||
MangaScreenState.Loading -> {
|
||||
val source = Injekt.get<SourceManager>().getOrStub(manga.source)
|
||||
MangaScreenState.Success(
|
||||
manga = manga,
|
||||
source = source,
|
||||
dateRelativeTime = if (source.isEhBasedSource()) 0 else preferences.relativeTime().get(),
|
||||
dateFormat = if (source.isEhBasedSource()) {
|
||||
MetadataUtil.EX_DATE_FORMAT
|
||||
} else {
|
||||
preferences.dateFormat()
|
||||
},
|
||||
isFromSource = isFromSource,
|
||||
trackingAvailable = trackManager.hasLoggedServices(),
|
||||
chapters = chapterItems,
|
||||
meta = raiseMetadata(flatMetadata, source),
|
||||
mergedData = mergedData,
|
||||
showRecommendationsInOverflow = preferences.recommendsInOverflow().get(),
|
||||
showMergeWithAnother = smartSearched,
|
||||
).also {
|
||||
getTrackingObservable(manga)
|
||||
.subscribeLatestCache(
|
||||
{ _, count ->
|
||||
successState?.let {
|
||||
_state.value = it.copy(trackingCount = count)
|
||||
}
|
||||
},
|
||||
{ _, error -> logcat(LogPriority.ERROR, error) },
|
||||
)
|
||||
_state.update { currentState ->
|
||||
when (currentState) {
|
||||
// Initialize success state
|
||||
MangaScreenState.Loading -> {
|
||||
val source = Injekt.get<SourceManager>().getOrStub(manga.source)
|
||||
MangaScreenState.Success(
|
||||
manga = manga,
|
||||
source = source,
|
||||
dateRelativeTime = if (source.isEhBasedSource()) 0 else preferences.relativeTime().get(),
|
||||
dateFormat = if (source.isEhBasedSource()) {
|
||||
MetadataUtil.EX_DATE_FORMAT
|
||||
} else {
|
||||
preferences.dateFormat()
|
||||
},
|
||||
isFromSource = isFromSource,
|
||||
trackingAvailable = trackManager.hasLoggedServices(),
|
||||
chapters = chapterItems,
|
||||
meta = raiseMetadata(flatMetadata, source),
|
||||
mergedData = mergedData,
|
||||
showRecommendationsInOverflow = preferences.recommendsInOverflow().get(),
|
||||
showMergeWithAnother = smartSearched,
|
||||
).also {
|
||||
getTrackingObservable(manga)
|
||||
.subscribeLatestCache(
|
||||
{ _, count ->
|
||||
successState?.let {
|
||||
_state.value = it.copy(trackingCount = count)
|
||||
}
|
||||
},
|
||||
{ _, error -> logcat(LogPriority.ERROR, error) },
|
||||
)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Update state
|
||||
is MangaScreenState.Success -> currentState.copy(
|
||||
manga = manga,
|
||||
chapters = chapterItems,
|
||||
// SY -->
|
||||
meta = raiseMetadata(flatMetadata, currentState.source),
|
||||
mergedData = mergedData,
|
||||
// SY <--
|
||||
)
|
||||
// Update state
|
||||
is MangaScreenState.Success -> currentState.copy(
|
||||
manga = manga,
|
||||
chapters = chapterItems,
|
||||
// SY -->
|
||||
meta = raiseMetadata(flatMetadata, currentState.source),
|
||||
mergedData = mergedData,
|
||||
// SY <--
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
fetchTrackers()
|
||||
@ -309,17 +315,13 @@ class MangaPresenter(
|
||||
|
||||
preferences.incognitoMode()
|
||||
.asImmediateFlow { incognito ->
|
||||
successState?.let {
|
||||
_state.value = it.copy(isIncognitoMode = incognito)
|
||||
}
|
||||
updateSuccessState { it.copy(isIncognitoMode = incognito) }
|
||||
}
|
||||
.launchIn(presenterScope)
|
||||
|
||||
preferences.downloadedOnly()
|
||||
.asImmediateFlow { downloadedOnly ->
|
||||
successState?.let {
|
||||
_state.value = it.copy(isDownloadedOnlyMode = downloadedOnly)
|
||||
}
|
||||
updateSuccessState { it.copy(isDownloadedOnlyMode = downloadedOnly) }
|
||||
}
|
||||
.launchIn(presenterScope)
|
||||
}
|
||||
@ -353,17 +355,18 @@ class MangaPresenter(
|
||||
*/
|
||||
private fun fetchMangaFromSource(manualFetch: Boolean = false) {
|
||||
if (fetchMangaJob?.isActive == true) return
|
||||
val successState = successState ?: return
|
||||
fetchMangaJob = presenterScope.launchIO {
|
||||
_state.value = successState.copy(isRefreshingInfo = true)
|
||||
updateSuccessState { it.copy(isRefreshingInfo = true) }
|
||||
try {
|
||||
val networkManga = successState.source.getMangaDetails(successState.manga.toMangaInfo())
|
||||
updateManga.awaitUpdateFromSource(successState.manga, networkManga, manualFetch)
|
||||
successState?.let {
|
||||
val networkManga = it.source.getMangaDetails(it.manga.toMangaInfo())
|
||||
updateManga.awaitUpdateFromSource(it.manga, networkManga, manualFetch)
|
||||
}
|
||||
} catch (e: Throwable) {
|
||||
this@MangaPresenter.xLogE("Error getting manga details", e)
|
||||
withUIContext { view?.onFetchMangaInfoError(e) }
|
||||
}
|
||||
_state.value = successState.copy(isRefreshingInfo = false)
|
||||
updateSuccessState { it.copy(isRefreshingInfo = false) }
|
||||
}
|
||||
}
|
||||
|
||||
@ -417,7 +420,9 @@ class MangaPresenter(
|
||||
manga = manga.copy()
|
||||
}
|
||||
|
||||
_state.value = state.copy(manga = manga)
|
||||
updateSuccessState { successState ->
|
||||
successState.copy(manga = manga)
|
||||
}
|
||||
}
|
||||
|
||||
suspend fun smartSearchMerge(context: Context, manga: DomainManga, originalMangaId: Long): Manga {
|
||||
@ -750,15 +755,16 @@ class MangaPresenter(
|
||||
}
|
||||
|
||||
private fun updateDownloadState(download: Download) {
|
||||
val successState = successState ?: return
|
||||
val modifiedIndex = successState.chapters.indexOfFirst { it.chapter.id == download.chapter.id }
|
||||
if (modifiedIndex >= 0) {
|
||||
updateSuccessState { successState ->
|
||||
val modifiedIndex = successState.chapters.indexOfFirst { it.chapter.id == download.chapter.id }
|
||||
if (modifiedIndex < 0) return@updateSuccessState successState
|
||||
|
||||
val newChapters = successState.chapters.toMutableList().apply {
|
||||
val item = removeAt(modifiedIndex)
|
||||
.copy(downloadState = download.status, downloadProgress = download.progress)
|
||||
add(modifiedIndex, item)
|
||||
}
|
||||
_state.value = successState.copy(chapters = newChapters)
|
||||
successState.copy(chapters = newChapters)
|
||||
}
|
||||
}
|
||||
|
||||
@ -794,32 +800,33 @@ class MangaPresenter(
|
||||
*/
|
||||
private fun fetchChaptersFromSource(manualFetch: Boolean = false) {
|
||||
if (fetchChaptersJob?.isActive == true) return
|
||||
val successState = successState ?: return
|
||||
|
||||
fetchChaptersJob = presenterScope.launchIO {
|
||||
_state.value = successState.copy(isRefreshingChapter = true)
|
||||
updateSuccessState { it.copy(isRefreshingChapter = true) }
|
||||
try {
|
||||
if (successState.source !is MergedSource) {
|
||||
val chapters = successState.source.getChapterList(successState.manga.toMangaInfo())
|
||||
.map { it.toSChapter() }
|
||||
successState?.let { successState ->
|
||||
if (successState.source !is MergedSource) {
|
||||
val chapters = successState.source.getChapterList(successState.manga.toMangaInfo())
|
||||
.map { it.toSChapter() }
|
||||
|
||||
val (newChapters, _) = syncChaptersWithSource.await(
|
||||
chapters,
|
||||
successState.manga,
|
||||
successState.source,
|
||||
)
|
||||
val (newChapters, _) = syncChaptersWithSource.await(
|
||||
chapters,
|
||||
successState.manga,
|
||||
successState.source,
|
||||
)
|
||||
|
||||
if (manualFetch) {
|
||||
val dbChapters = newChapters.map { it.toDbChapter() }
|
||||
downloadNewChapters(dbChapters)
|
||||
if (manualFetch) {
|
||||
val dbChapters = newChapters.map { it.toDbChapter() }
|
||||
downloadNewChapters(dbChapters)
|
||||
}
|
||||
} else {
|
||||
successState.source.fetchChaptersForMergedManga(successState.manga, manualFetch, true, dedupe)
|
||||
Unit
|
||||
}
|
||||
} else {
|
||||
successState.source.fetchChaptersForMergedManga(successState.manga, manualFetch, true, dedupe)
|
||||
}
|
||||
} catch (e: Throwable) {
|
||||
withUIContext { view?.onFetchChaptersError(e) }
|
||||
}
|
||||
_state.value = successState.copy(isRefreshingChapter = false)
|
||||
updateSuccessState { it.copy(isRefreshingChapter = false) }
|
||||
}
|
||||
}
|
||||
|
||||
@ -926,26 +933,27 @@ class MangaPresenter(
|
||||
* @param chapters the list of chapters to delete.
|
||||
*/
|
||||
fun deleteChapters(chapters: List<DomainChapter>) {
|
||||
val successState = successState ?: return
|
||||
launchIO {
|
||||
val chapters2 = chapters.map { it.toDbChapter() }
|
||||
try {
|
||||
val deletedIds = downloadManager
|
||||
.deleteChapters(chapters2, successState.manga.toDbManga(), successState.source)
|
||||
.map { it.id }
|
||||
val deletedChapters = successState.chapters.filter { deletedIds.contains(it.chapter.id) }
|
||||
if (deletedChapters.isEmpty()) return@launchIO
|
||||
updateSuccessState { successState ->
|
||||
val deletedIds = downloadManager
|
||||
.deleteChapters(chapters2, successState.manga.toDbManga(), successState.source)
|
||||
.map { it.id }
|
||||
val deletedChapters = successState.chapters.filter { deletedIds.contains(it.chapter.id) }
|
||||
if (deletedChapters.isEmpty()) return@updateSuccessState successState
|
||||
|
||||
// TODO: Don't do this fake status update
|
||||
val newChapters = successState.chapters.toMutableList().apply {
|
||||
deletedChapters.forEach {
|
||||
val index = indexOf(it)
|
||||
val toAdd = removeAt(index)
|
||||
.copy(downloadState = Download.State.NOT_DOWNLOADED, downloadProgress = 0)
|
||||
add(index, toAdd)
|
||||
// TODO: Don't do this fake status update
|
||||
val newChapters = successState.chapters.toMutableList().apply {
|
||||
deletedChapters.forEach {
|
||||
val index = indexOf(it)
|
||||
val toAdd = removeAt(index)
|
||||
.copy(downloadState = Download.State.NOT_DOWNLOADED, downloadProgress = 0)
|
||||
add(index, toAdd)
|
||||
}
|
||||
}
|
||||
successState.copy(chapters = newChapters)
|
||||
}
|
||||
_state.value = successState.copy(chapters = newChapters)
|
||||
} catch (e: Throwable) {
|
||||
logcat(LogPriority.ERROR, e)
|
||||
}
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user