mirror of
https://github.com/Suwayomi/TachideskJUI.git
synced 2025-12-10 06:42:05 +01:00
Add Old naming to REST interactions
This commit is contained in:
@@ -8,20 +8,20 @@ package ca.gosyer.jui.data
|
|||||||
|
|
||||||
import ca.gosyer.jui.core.lang.addSuffix
|
import ca.gosyer.jui.core.lang.addSuffix
|
||||||
import ca.gosyer.jui.data.settings.SettingsRepositoryImpl
|
import ca.gosyer.jui.data.settings.SettingsRepositoryImpl
|
||||||
import ca.gosyer.jui.domain.backup.service.BackupRepository
|
import ca.gosyer.jui.domain.backup.service.BackupRepositoryOld
|
||||||
import ca.gosyer.jui.domain.category.service.CategoryRepository
|
import ca.gosyer.jui.domain.category.service.CategoryRepositoryOld
|
||||||
import ca.gosyer.jui.domain.chapter.service.ChapterRepository
|
import ca.gosyer.jui.domain.chapter.service.ChapterRepositoryOld
|
||||||
import ca.gosyer.jui.domain.download.service.DownloadRepository
|
import ca.gosyer.jui.domain.download.service.DownloadRepositoryOld
|
||||||
import ca.gosyer.jui.domain.extension.service.ExtensionRepository
|
import ca.gosyer.jui.domain.extension.service.ExtensionRepositoryOld
|
||||||
import ca.gosyer.jui.domain.global.service.GlobalRepository
|
import ca.gosyer.jui.domain.global.service.GlobalRepositoryOld
|
||||||
import ca.gosyer.jui.domain.library.service.LibraryRepository
|
import ca.gosyer.jui.domain.library.service.LibraryRepositoryOld
|
||||||
import ca.gosyer.jui.domain.manga.service.MangaRepository
|
import ca.gosyer.jui.domain.manga.service.MangaRepositoryOld
|
||||||
import ca.gosyer.jui.domain.server.Http
|
import ca.gosyer.jui.domain.server.Http
|
||||||
import ca.gosyer.jui.domain.server.service.ServerPreferences
|
import ca.gosyer.jui.domain.server.service.ServerPreferences
|
||||||
import ca.gosyer.jui.domain.settings.service.SettingsRepository
|
import ca.gosyer.jui.domain.settings.service.SettingsRepository
|
||||||
import ca.gosyer.jui.domain.settings.service.SettingsRepositoryOld
|
import ca.gosyer.jui.domain.settings.service.SettingsRepositoryOld
|
||||||
import ca.gosyer.jui.domain.source.service.SourceRepository
|
import ca.gosyer.jui.domain.source.service.SourceRepositoryOld
|
||||||
import ca.gosyer.jui.domain.updates.service.UpdatesRepository
|
import ca.gosyer.jui.domain.updates.service.UpdatesRepositoryOld
|
||||||
import com.apollographql.apollo3.ApolloClient
|
import com.apollographql.apollo3.ApolloClient
|
||||||
import com.apollographql.apollo3.annotations.ApolloExperimental
|
import com.apollographql.apollo3.annotations.ApolloExperimental
|
||||||
import com.apollographql.apollo3.network.ktorClient
|
import com.apollographql.apollo3.network.ktorClient
|
||||||
@@ -57,37 +57,37 @@ interface DataComponent {
|
|||||||
.build()
|
.build()
|
||||||
|
|
||||||
@Provides
|
@Provides
|
||||||
fun backupRepository(ktorfit: Ktorfit) = ktorfit.create<BackupRepository>()
|
fun backupRepositoryOld(ktorfit: Ktorfit) = ktorfit.create<BackupRepositoryOld>()
|
||||||
|
|
||||||
@Provides
|
@Provides
|
||||||
fun categoryRepository(ktorfit: Ktorfit) = ktorfit.create<CategoryRepository>()
|
fun categoryRepositoryOld(ktorfit: Ktorfit) = ktorfit.create<CategoryRepositoryOld>()
|
||||||
|
|
||||||
@Provides
|
@Provides
|
||||||
fun chapterRepository(ktorfit: Ktorfit) = ktorfit.create<ChapterRepository>()
|
fun chapterRepositoryOld(ktorfit: Ktorfit) = ktorfit.create<ChapterRepositoryOld>()
|
||||||
|
|
||||||
@Provides
|
@Provides
|
||||||
fun downloadRepository(ktorfit: Ktorfit) = ktorfit.create<DownloadRepository>()
|
fun downloadRepositoryOld(ktorfit: Ktorfit) = ktorfit.create<DownloadRepositoryOld>()
|
||||||
|
|
||||||
@Provides
|
@Provides
|
||||||
fun extensionRepository(ktorfit: Ktorfit) = ktorfit.create<ExtensionRepository>()
|
fun extensionRepositoryOld(ktorfit: Ktorfit) = ktorfit.create<ExtensionRepositoryOld>()
|
||||||
|
|
||||||
@Provides
|
@Provides
|
||||||
fun globalRepository(ktorfit: Ktorfit) = ktorfit.create<GlobalRepository>()
|
fun globalRepositoryOld(ktorfit: Ktorfit) = ktorfit.create<GlobalRepositoryOld>()
|
||||||
|
|
||||||
@Provides
|
@Provides
|
||||||
fun libraryRepository(ktorfit: Ktorfit) = ktorfit.create<LibraryRepository>()
|
fun libraryRepositoryOld(ktorfit: Ktorfit) = ktorfit.create<LibraryRepositoryOld>()
|
||||||
|
|
||||||
@Provides
|
@Provides
|
||||||
fun mangaRepository(ktorfit: Ktorfit) = ktorfit.create<MangaRepository>()
|
fun mangaRepositoryOld(ktorfit: Ktorfit) = ktorfit.create<MangaRepositoryOld>()
|
||||||
|
|
||||||
@Provides
|
@Provides
|
||||||
fun settingsRepositoryOld(ktorfit: Ktorfit) = ktorfit.create<SettingsRepositoryOld>()
|
fun settingsRepositoryOld(ktorfit: Ktorfit) = ktorfit.create<SettingsRepositoryOld>()
|
||||||
|
|
||||||
@Provides
|
@Provides
|
||||||
fun sourceRepository(ktorfit: Ktorfit) = ktorfit.create<SourceRepository>()
|
fun sourceRepositoryOld(ktorfit: Ktorfit) = ktorfit.create<SourceRepositoryOld>()
|
||||||
|
|
||||||
@Provides
|
@Provides
|
||||||
fun updatesRepository(ktorfit: Ktorfit) = ktorfit.create<UpdatesRepository>()
|
fun updatesRepositoryOld(ktorfit: Ktorfit) = ktorfit.create<UpdatesRepositoryOld>()
|
||||||
|
|
||||||
@Provides
|
@Provides
|
||||||
fun settingsRepository(apolloClient: ApolloClient): SettingsRepository = SettingsRepositoryImpl(apolloClient)
|
fun settingsRepository(apolloClient: ApolloClient): SettingsRepository = SettingsRepositoryImpl(apolloClient)
|
||||||
|
|||||||
@@ -6,7 +6,7 @@
|
|||||||
|
|
||||||
package ca.gosyer.jui.domain.backup.interactor
|
package ca.gosyer.jui.domain.backup.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.backup.service.BackupRepository
|
import ca.gosyer.jui.domain.backup.service.BackupRepositoryOld
|
||||||
import io.ktor.client.request.HttpRequestBuilder
|
import io.ktor.client.request.HttpRequestBuilder
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.singleOrNull
|
import kotlinx.coroutines.flow.singleOrNull
|
||||||
@@ -16,7 +16,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class ExportBackupFile
|
class ExportBackupFile
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val backupRepository: BackupRepository,
|
private val backupRepositoryOld: BackupRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
block: HttpRequestBuilder.() -> Unit = {},
|
block: HttpRequestBuilder.() -> Unit = {},
|
||||||
@@ -28,7 +28,7 @@ class ExportBackupFile
|
|||||||
}
|
}
|
||||||
.singleOrNull()
|
.singleOrNull()
|
||||||
|
|
||||||
fun asFlow(block: HttpRequestBuilder.() -> Unit = {}) = backupRepository.exportBackupFile(block)
|
fun asFlow(block: HttpRequestBuilder.() -> Unit = {}) = backupRepositoryOld.exportBackupFile(block)
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -6,7 +6,7 @@
|
|||||||
|
|
||||||
package ca.gosyer.jui.domain.backup.interactor
|
package ca.gosyer.jui.domain.backup.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.backup.service.BackupRepository
|
import ca.gosyer.jui.domain.backup.service.BackupRepositoryOld
|
||||||
import io.ktor.client.request.HttpRequestBuilder
|
import io.ktor.client.request.HttpRequestBuilder
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.singleOrNull
|
import kotlinx.coroutines.flow.singleOrNull
|
||||||
@@ -17,7 +17,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class ImportBackupFile
|
class ImportBackupFile
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val backupRepository: BackupRepository,
|
private val backupRepositoryOld: BackupRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
file: Path,
|
file: Path,
|
||||||
@@ -33,7 +33,7 @@ class ImportBackupFile
|
|||||||
fun asFlow(
|
fun asFlow(
|
||||||
file: Path,
|
file: Path,
|
||||||
block: HttpRequestBuilder.() -> Unit = {},
|
block: HttpRequestBuilder.() -> Unit = {},
|
||||||
) = backupRepository.importBackupFile(BackupRepository.buildBackupFormData(file), block)
|
) = backupRepositoryOld.importBackupFile(BackupRepositoryOld.buildBackupFormData(file), block)
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -6,7 +6,7 @@
|
|||||||
|
|
||||||
package ca.gosyer.jui.domain.backup.interactor
|
package ca.gosyer.jui.domain.backup.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.backup.service.BackupRepository
|
import ca.gosyer.jui.domain.backup.service.BackupRepositoryOld
|
||||||
import io.ktor.client.request.HttpRequestBuilder
|
import io.ktor.client.request.HttpRequestBuilder
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.singleOrNull
|
import kotlinx.coroutines.flow.singleOrNull
|
||||||
@@ -17,7 +17,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class ValidateBackupFile
|
class ValidateBackupFile
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val backupRepository: BackupRepository,
|
private val backupRepositoryOld: BackupRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
file: Path,
|
file: Path,
|
||||||
@@ -33,7 +33,7 @@ class ValidateBackupFile
|
|||||||
fun asFlow(
|
fun asFlow(
|
||||||
file: Path,
|
file: Path,
|
||||||
block: HttpRequestBuilder.() -> Unit = {},
|
block: HttpRequestBuilder.() -> Unit = {},
|
||||||
) = backupRepository.validateBackupFile(BackupRepository.buildBackupFormData(file), block)
|
) = backupRepositoryOld.validateBackupFile(BackupRepositoryOld.buildBackupFormData(file), block)
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -25,7 +25,7 @@ import okio.FileSystem
|
|||||||
import okio.Path
|
import okio.Path
|
||||||
import okio.buffer
|
import okio.buffer
|
||||||
|
|
||||||
interface BackupRepository {
|
interface BackupRepositoryOld {
|
||||||
@Multipart
|
@Multipart
|
||||||
@POST("api/v1/backup/import/file")
|
@POST("api/v1/backup/import/file")
|
||||||
fun importBackupFile(
|
fun importBackupFile(
|
||||||
@@ -8,7 +8,7 @@ package ca.gosyer.jui.domain.category.interactor
|
|||||||
|
|
||||||
import ca.gosyer.jui.domain.ServerListeners
|
import ca.gosyer.jui.domain.ServerListeners
|
||||||
import ca.gosyer.jui.domain.category.model.Category
|
import ca.gosyer.jui.domain.category.model.Category
|
||||||
import ca.gosyer.jui.domain.category.service.CategoryRepository
|
import ca.gosyer.jui.domain.category.service.CategoryRepositoryOld
|
||||||
import ca.gosyer.jui.domain.manga.model.Manga
|
import ca.gosyer.jui.domain.manga.model.Manga
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
@@ -20,7 +20,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class AddMangaToCategory
|
class AddMangaToCategory
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val categoryRepository: CategoryRepository,
|
private val categoryRepositoryOld: CategoryRepositoryOld,
|
||||||
private val serverListeners: ServerListeners,
|
private val serverListeners: ServerListeners,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
@@ -49,7 +49,7 @@ class AddMangaToCategory
|
|||||||
mangaId: Long,
|
mangaId: Long,
|
||||||
categoryId: Long,
|
categoryId: Long,
|
||||||
) = if (categoryId != 0L) {
|
) = if (categoryId != 0L) {
|
||||||
categoryRepository.addMangaToCategory(mangaId, categoryId)
|
categoryRepositoryOld.addMangaToCategory(mangaId, categoryId)
|
||||||
.map { serverListeners.updateCategoryManga(categoryId) }
|
.map { serverListeners.updateCategoryManga(categoryId) }
|
||||||
} else {
|
} else {
|
||||||
flow {
|
flow {
|
||||||
@@ -62,7 +62,7 @@ class AddMangaToCategory
|
|||||||
manga: Manga,
|
manga: Manga,
|
||||||
category: Category,
|
category: Category,
|
||||||
) = if (category.id != 0L) {
|
) = if (category.id != 0L) {
|
||||||
categoryRepository.addMangaToCategory(manga.id, category.id)
|
categoryRepositoryOld.addMangaToCategory(manga.id, category.id)
|
||||||
.map { serverListeners.updateCategoryManga(category.id) }
|
.map { serverListeners.updateCategoryManga(category.id) }
|
||||||
} else {
|
} else {
|
||||||
flow {
|
flow {
|
||||||
|
|||||||
@@ -6,7 +6,7 @@
|
|||||||
|
|
||||||
package ca.gosyer.jui.domain.category.interactor
|
package ca.gosyer.jui.domain.category.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.category.service.CategoryRepository
|
import ca.gosyer.jui.domain.category.service.CategoryRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -15,7 +15,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class CreateCategory
|
class CreateCategory
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val categoryRepository: CategoryRepository,
|
private val categoryRepositoryOld: CategoryRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
name: String,
|
name: String,
|
||||||
@@ -27,7 +27,7 @@ class CreateCategory
|
|||||||
}
|
}
|
||||||
.collect()
|
.collect()
|
||||||
|
|
||||||
fun asFlow(name: String) = categoryRepository.createCategory(name)
|
fun asFlow(name: String) = categoryRepositoryOld.createCategory(name)
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -7,7 +7,7 @@
|
|||||||
package ca.gosyer.jui.domain.category.interactor
|
package ca.gosyer.jui.domain.category.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.category.model.Category
|
import ca.gosyer.jui.domain.category.model.Category
|
||||||
import ca.gosyer.jui.domain.category.service.CategoryRepository
|
import ca.gosyer.jui.domain.category.service.CategoryRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -16,7 +16,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class DeleteCategory
|
class DeleteCategory
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val categoryRepository: CategoryRepository,
|
private val categoryRepositoryOld: CategoryRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
categoryId: Long,
|
categoryId: Long,
|
||||||
@@ -38,9 +38,9 @@ class DeleteCategory
|
|||||||
}
|
}
|
||||||
.collect()
|
.collect()
|
||||||
|
|
||||||
fun asFlow(categoryId: Long) = categoryRepository.deleteCategory(categoryId)
|
fun asFlow(categoryId: Long) = categoryRepositoryOld.deleteCategory(categoryId)
|
||||||
|
|
||||||
fun asFlow(category: Category) = categoryRepository.deleteCategory(category.id)
|
fun asFlow(category: Category) = categoryRepositoryOld.deleteCategory(category.id)
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -6,7 +6,7 @@
|
|||||||
|
|
||||||
package ca.gosyer.jui.domain.category.interactor
|
package ca.gosyer.jui.domain.category.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.category.service.CategoryRepository
|
import ca.gosyer.jui.domain.category.service.CategoryRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.map
|
import kotlinx.coroutines.flow.map
|
||||||
import kotlinx.coroutines.flow.singleOrNull
|
import kotlinx.coroutines.flow.singleOrNull
|
||||||
@@ -16,7 +16,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class GetCategories
|
class GetCategories
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val categoryRepository: CategoryRepository,
|
private val categoryRepositoryOld: CategoryRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
dropDefault: Boolean = false,
|
dropDefault: Boolean = false,
|
||||||
@@ -29,7 +29,7 @@ class GetCategories
|
|||||||
.singleOrNull()
|
.singleOrNull()
|
||||||
|
|
||||||
fun asFlow(dropDefault: Boolean = false) =
|
fun asFlow(dropDefault: Boolean = false) =
|
||||||
categoryRepository.getCategories()
|
categoryRepositoryOld.getCategories()
|
||||||
.map { categories ->
|
.map { categories ->
|
||||||
if (dropDefault) {
|
if (dropDefault) {
|
||||||
categories.filterNot { it.name.equals("default", true) }
|
categories.filterNot { it.name.equals("default", true) }
|
||||||
|
|||||||
@@ -6,7 +6,7 @@
|
|||||||
|
|
||||||
package ca.gosyer.jui.domain.category.interactor
|
package ca.gosyer.jui.domain.category.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.category.service.CategoryRepository
|
import ca.gosyer.jui.domain.category.service.CategoryRepositoryOld
|
||||||
import ca.gosyer.jui.domain.manga.model.Manga
|
import ca.gosyer.jui.domain.manga.model.Manga
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.singleOrNull
|
import kotlinx.coroutines.flow.singleOrNull
|
||||||
@@ -16,7 +16,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class GetMangaCategories
|
class GetMangaCategories
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val categoryRepository: CategoryRepository,
|
private val categoryRepositoryOld: CategoryRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
mangaId: Long,
|
mangaId: Long,
|
||||||
@@ -38,9 +38,9 @@ class GetMangaCategories
|
|||||||
}
|
}
|
||||||
.singleOrNull()
|
.singleOrNull()
|
||||||
|
|
||||||
fun asFlow(mangaId: Long) = categoryRepository.getMangaCategories(mangaId)
|
fun asFlow(mangaId: Long) = categoryRepositoryOld.getMangaCategories(mangaId)
|
||||||
|
|
||||||
fun asFlow(manga: Manga) = categoryRepository.getMangaCategories(manga.id)
|
fun asFlow(manga: Manga) = categoryRepositoryOld.getMangaCategories(manga.id)
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -8,7 +8,7 @@ package ca.gosyer.jui.domain.category.interactor
|
|||||||
|
|
||||||
import ca.gosyer.jui.domain.ServerListeners
|
import ca.gosyer.jui.domain.ServerListeners
|
||||||
import ca.gosyer.jui.domain.category.model.Category
|
import ca.gosyer.jui.domain.category.model.Category
|
||||||
import ca.gosyer.jui.domain.category.service.CategoryRepository
|
import ca.gosyer.jui.domain.category.service.CategoryRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.singleOrNull
|
import kotlinx.coroutines.flow.singleOrNull
|
||||||
import kotlinx.coroutines.flow.take
|
import kotlinx.coroutines.flow.take
|
||||||
@@ -18,7 +18,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class GetMangaListFromCategory
|
class GetMangaListFromCategory
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val categoryRepository: CategoryRepository,
|
private val categoryRepositoryOld: CategoryRepositoryOld,
|
||||||
private val serverListeners: ServerListeners,
|
private val serverListeners: ServerListeners,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
@@ -45,12 +45,12 @@ class GetMangaListFromCategory
|
|||||||
|
|
||||||
fun asFlow(categoryId: Long) =
|
fun asFlow(categoryId: Long) =
|
||||||
serverListeners.combineCategoryManga(
|
serverListeners.combineCategoryManga(
|
||||||
categoryRepository.getMangaFromCategory(categoryId),
|
categoryRepositoryOld.getMangaFromCategory(categoryId),
|
||||||
) { categoryId == it }
|
) { categoryId == it }
|
||||||
|
|
||||||
fun asFlow(category: Category) =
|
fun asFlow(category: Category) =
|
||||||
serverListeners.combineCategoryManga(
|
serverListeners.combineCategoryManga(
|
||||||
categoryRepository.getMangaFromCategory(category.id),
|
categoryRepositoryOld.getMangaFromCategory(category.id),
|
||||||
) { category.id == it }
|
) { category.id == it }
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
|
|||||||
@@ -7,7 +7,7 @@
|
|||||||
package ca.gosyer.jui.domain.category.interactor
|
package ca.gosyer.jui.domain.category.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.category.model.Category
|
import ca.gosyer.jui.domain.category.model.Category
|
||||||
import ca.gosyer.jui.domain.category.service.CategoryRepository
|
import ca.gosyer.jui.domain.category.service.CategoryRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -16,7 +16,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class ModifyCategory
|
class ModifyCategory
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val categoryRepository: CategoryRepository,
|
private val categoryRepositoryOld: CategoryRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
categoryId: Long,
|
categoryId: Long,
|
||||||
@@ -45,7 +45,7 @@ class ModifyCategory
|
|||||||
fun asFlow(
|
fun asFlow(
|
||||||
categoryId: Long,
|
categoryId: Long,
|
||||||
name: String,
|
name: String,
|
||||||
) = categoryRepository.modifyCategory(
|
) = categoryRepositoryOld.modifyCategory(
|
||||||
categoryId = categoryId,
|
categoryId = categoryId,
|
||||||
name = name,
|
name = name,
|
||||||
)
|
)
|
||||||
@@ -53,7 +53,7 @@ class ModifyCategory
|
|||||||
fun asFlow(
|
fun asFlow(
|
||||||
category: Category,
|
category: Category,
|
||||||
name: String? = null,
|
name: String? = null,
|
||||||
) = categoryRepository.modifyCategory(
|
) = categoryRepositoryOld.modifyCategory(
|
||||||
categoryId = category.id,
|
categoryId = category.id,
|
||||||
name = name ?: category.name,
|
name = name ?: category.name,
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -8,7 +8,7 @@ package ca.gosyer.jui.domain.category.interactor
|
|||||||
|
|
||||||
import ca.gosyer.jui.domain.ServerListeners
|
import ca.gosyer.jui.domain.ServerListeners
|
||||||
import ca.gosyer.jui.domain.category.model.Category
|
import ca.gosyer.jui.domain.category.model.Category
|
||||||
import ca.gosyer.jui.domain.category.service.CategoryRepository
|
import ca.gosyer.jui.domain.category.service.CategoryRepositoryOld
|
||||||
import ca.gosyer.jui.domain.manga.model.Manga
|
import ca.gosyer.jui.domain.manga.model.Manga
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
@@ -20,7 +20,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class RemoveMangaFromCategory
|
class RemoveMangaFromCategory
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val categoryRepository: CategoryRepository,
|
private val categoryRepositoryOld: CategoryRepositoryOld,
|
||||||
private val serverListeners: ServerListeners,
|
private val serverListeners: ServerListeners,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
@@ -49,7 +49,7 @@ class RemoveMangaFromCategory
|
|||||||
mangaId: Long,
|
mangaId: Long,
|
||||||
categoryId: Long,
|
categoryId: Long,
|
||||||
) = if (categoryId != 0L) {
|
) = if (categoryId != 0L) {
|
||||||
categoryRepository.removeMangaFromCategory(mangaId, categoryId)
|
categoryRepositoryOld.removeMangaFromCategory(mangaId, categoryId)
|
||||||
.map { serverListeners.updateCategoryManga(categoryId) }
|
.map { serverListeners.updateCategoryManga(categoryId) }
|
||||||
} else {
|
} else {
|
||||||
flow {
|
flow {
|
||||||
@@ -62,7 +62,7 @@ class RemoveMangaFromCategory
|
|||||||
manga: Manga,
|
manga: Manga,
|
||||||
category: Category,
|
category: Category,
|
||||||
) = if (category.id != 0L) {
|
) = if (category.id != 0L) {
|
||||||
categoryRepository.removeMangaFromCategory(manga.id, category.id)
|
categoryRepositoryOld.removeMangaFromCategory(manga.id, category.id)
|
||||||
.map { serverListeners.updateCategoryManga(category.id) }
|
.map { serverListeners.updateCategoryManga(category.id) }
|
||||||
} else {
|
} else {
|
||||||
flow {
|
flow {
|
||||||
|
|||||||
@@ -6,7 +6,7 @@
|
|||||||
|
|
||||||
package ca.gosyer.jui.domain.category.interactor
|
package ca.gosyer.jui.domain.category.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.category.service.CategoryRepository
|
import ca.gosyer.jui.domain.category.service.CategoryRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -15,7 +15,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class ReorderCategory
|
class ReorderCategory
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val categoryRepository: CategoryRepository,
|
private val categoryRepositoryOld: CategoryRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
to: Int,
|
to: Int,
|
||||||
@@ -31,7 +31,7 @@ class ReorderCategory
|
|||||||
fun asFlow(
|
fun asFlow(
|
||||||
to: Int,
|
to: Int,
|
||||||
from: Int,
|
from: Int,
|
||||||
) = categoryRepository.reorderCategory(to, from)
|
) = categoryRepositoryOld.reorderCategory(to, from)
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -7,7 +7,7 @@
|
|||||||
package ca.gosyer.jui.domain.category.interactor
|
package ca.gosyer.jui.domain.category.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.category.model.Category
|
import ca.gosyer.jui.domain.category.model.Category
|
||||||
import ca.gosyer.jui.domain.category.service.CategoryRepository
|
import ca.gosyer.jui.domain.category.service.CategoryRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
import kotlinx.coroutines.flow.flow
|
import kotlinx.coroutines.flow.flow
|
||||||
@@ -17,7 +17,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class UpdateCategoryMeta
|
class UpdateCategoryMeta
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val categoryRepository: CategoryRepository,
|
private val categoryRepositoryOld: CategoryRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
category: Category,
|
category: Category,
|
||||||
@@ -35,7 +35,7 @@ class UpdateCategoryMeta
|
|||||||
example: Int = category.meta.example,
|
example: Int = category.meta.example,
|
||||||
) = flow {
|
) = flow {
|
||||||
if (example != category.meta.example) {
|
if (example != category.meta.example) {
|
||||||
categoryRepository.updateCategoryMeta(
|
categoryRepositoryOld.updateCategoryMeta(
|
||||||
category.id,
|
category.id,
|
||||||
"example",
|
"example",
|
||||||
example.toString(),
|
example.toString(),
|
||||||
|
|||||||
@@ -18,7 +18,7 @@ import de.jensklingenberg.ktorfit.http.Path
|
|||||||
import io.ktor.client.statement.HttpResponse
|
import io.ktor.client.statement.HttpResponse
|
||||||
import kotlinx.coroutines.flow.Flow
|
import kotlinx.coroutines.flow.Flow
|
||||||
|
|
||||||
interface CategoryRepository {
|
interface CategoryRepositoryOld {
|
||||||
@GET("api/v1/manga/{mangaId}/category/")
|
@GET("api/v1/manga/{mangaId}/category/")
|
||||||
fun getMangaCategories(
|
fun getMangaCategories(
|
||||||
@Path("mangaId") mangaId: Long,
|
@Path("mangaId") mangaId: Long,
|
||||||
@@ -11,7 +11,7 @@ import ca.gosyer.jui.domain.chapter.model.Chapter
|
|||||||
import ca.gosyer.jui.domain.chapter.model.ChapterBatchEditInput
|
import ca.gosyer.jui.domain.chapter.model.ChapterBatchEditInput
|
||||||
import ca.gosyer.jui.domain.chapter.model.ChapterChange
|
import ca.gosyer.jui.domain.chapter.model.ChapterChange
|
||||||
import ca.gosyer.jui.domain.chapter.model.MangaChapterBatchEditInput
|
import ca.gosyer.jui.domain.chapter.model.MangaChapterBatchEditInput
|
||||||
import ca.gosyer.jui.domain.chapter.service.ChapterRepository
|
import ca.gosyer.jui.domain.chapter.service.ChapterRepositoryOld
|
||||||
import ca.gosyer.jui.domain.manga.model.Manga
|
import ca.gosyer.jui.domain.manga.model.Manga
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
@@ -23,7 +23,7 @@ import kotlin.jvm.JvmName
|
|||||||
class BatchUpdateChapter
|
class BatchUpdateChapter
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val chapterRepository: ChapterRepository,
|
private val chapterRepositoryOld: ChapterRepositoryOld,
|
||||||
private val serverListeners: ServerListeners,
|
private val serverListeners: ServerListeners,
|
||||||
) {
|
) {
|
||||||
@JvmName("awaitChapters")
|
@JvmName("awaitChapters")
|
||||||
@@ -222,7 +222,7 @@ class BatchUpdateChapter
|
|||||||
lastPageRead: Int? = null,
|
lastPageRead: Int? = null,
|
||||||
delete: Boolean? = null,
|
delete: Boolean? = null,
|
||||||
) = if (mangaId != null) {
|
) = if (mangaId != null) {
|
||||||
chapterRepository.batchUpdateChapter(
|
chapterRepositoryOld.batchUpdateChapter(
|
||||||
mangaId,
|
mangaId,
|
||||||
MangaChapterBatchEditInput(
|
MangaChapterBatchEditInput(
|
||||||
chapterIds = chapterIds,
|
chapterIds = chapterIds,
|
||||||
@@ -235,7 +235,7 @@ class BatchUpdateChapter
|
|||||||
),
|
),
|
||||||
)
|
)
|
||||||
} else {
|
} else {
|
||||||
chapterRepository.batchUpdateChapter(
|
chapterRepositoryOld.batchUpdateChapter(
|
||||||
ChapterBatchEditInput(
|
ChapterBatchEditInput(
|
||||||
chapterIds = chapterIds,
|
chapterIds = chapterIds,
|
||||||
change = ChapterChange(
|
change = ChapterChange(
|
||||||
|
|||||||
@@ -8,7 +8,7 @@ package ca.gosyer.jui.domain.chapter.interactor
|
|||||||
|
|
||||||
import ca.gosyer.jui.domain.ServerListeners
|
import ca.gosyer.jui.domain.ServerListeners
|
||||||
import ca.gosyer.jui.domain.chapter.model.Chapter
|
import ca.gosyer.jui.domain.chapter.model.Chapter
|
||||||
import ca.gosyer.jui.domain.chapter.service.ChapterRepository
|
import ca.gosyer.jui.domain.chapter.service.ChapterRepositoryOld
|
||||||
import ca.gosyer.jui.domain.manga.model.Manga
|
import ca.gosyer.jui.domain.manga.model.Manga
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
@@ -19,7 +19,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class DeleteChapterDownload
|
class DeleteChapterDownload
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val chapterRepository: ChapterRepository,
|
private val chapterRepositoryOld: ChapterRepositoryOld,
|
||||||
private val serverListeners: ServerListeners,
|
private val serverListeners: ServerListeners,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
@@ -57,17 +57,17 @@ class DeleteChapterDownload
|
|||||||
fun asFlow(
|
fun asFlow(
|
||||||
mangaId: Long,
|
mangaId: Long,
|
||||||
index: Int,
|
index: Int,
|
||||||
) = chapterRepository.deleteChapterDownload(mangaId, index)
|
) = chapterRepositoryOld.deleteChapterDownload(mangaId, index)
|
||||||
.onEach { serverListeners.updateChapters(mangaId, index) }
|
.onEach { serverListeners.updateChapters(mangaId, index) }
|
||||||
|
|
||||||
fun asFlow(
|
fun asFlow(
|
||||||
manga: Manga,
|
manga: Manga,
|
||||||
index: Int,
|
index: Int,
|
||||||
) = chapterRepository.deleteChapterDownload(manga.id, index)
|
) = chapterRepositoryOld.deleteChapterDownload(manga.id, index)
|
||||||
.onEach { serverListeners.updateChapters(manga.id, index) }
|
.onEach { serverListeners.updateChapters(manga.id, index) }
|
||||||
|
|
||||||
fun asFlow(chapter: Chapter) =
|
fun asFlow(chapter: Chapter) =
|
||||||
chapterRepository.deleteChapterDownload(chapter.mangaId, chapter.index)
|
chapterRepositoryOld.deleteChapterDownload(chapter.mangaId, chapter.index)
|
||||||
.onEach { serverListeners.updateChapters(chapter.mangaId, chapter.index) }
|
.onEach { serverListeners.updateChapters(chapter.mangaId, chapter.index) }
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
|
|||||||
@@ -8,7 +8,7 @@ package ca.gosyer.jui.domain.chapter.interactor
|
|||||||
|
|
||||||
import ca.gosyer.jui.domain.ServerListeners
|
import ca.gosyer.jui.domain.ServerListeners
|
||||||
import ca.gosyer.jui.domain.chapter.model.Chapter
|
import ca.gosyer.jui.domain.chapter.model.Chapter
|
||||||
import ca.gosyer.jui.domain.chapter.service.ChapterRepository
|
import ca.gosyer.jui.domain.chapter.service.ChapterRepositoryOld
|
||||||
import ca.gosyer.jui.domain.manga.model.Manga
|
import ca.gosyer.jui.domain.manga.model.Manga
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.singleOrNull
|
import kotlinx.coroutines.flow.singleOrNull
|
||||||
@@ -19,7 +19,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class GetChapter
|
class GetChapter
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val chapterRepository: ChapterRepository,
|
private val chapterRepositoryOld: ChapterRepositoryOld,
|
||||||
private val serverListeners: ServerListeners,
|
private val serverListeners: ServerListeners,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
@@ -61,7 +61,7 @@ class GetChapter
|
|||||||
mangaId: Long,
|
mangaId: Long,
|
||||||
index: Int,
|
index: Int,
|
||||||
) = serverListeners.combineChapters(
|
) = serverListeners.combineChapters(
|
||||||
chapterRepository.getChapter(mangaId, index),
|
chapterRepositoryOld.getChapter(mangaId, index),
|
||||||
indexPredate = { id, chapterIndexes ->
|
indexPredate = { id, chapterIndexes ->
|
||||||
id == mangaId && (chapterIndexes == null || index in chapterIndexes)
|
id == mangaId && (chapterIndexes == null || index in chapterIndexes)
|
||||||
},
|
},
|
||||||
@@ -72,7 +72,7 @@ class GetChapter
|
|||||||
manga: Manga,
|
manga: Manga,
|
||||||
index: Int,
|
index: Int,
|
||||||
) = serverListeners.combineChapters(
|
) = serverListeners.combineChapters(
|
||||||
chapterRepository.getChapter(manga.id, index),
|
chapterRepositoryOld.getChapter(manga.id, index),
|
||||||
indexPredate = { id, chapterIndexes ->
|
indexPredate = { id, chapterIndexes ->
|
||||||
id == manga.id && (chapterIndexes == null || index in chapterIndexes)
|
id == manga.id && (chapterIndexes == null || index in chapterIndexes)
|
||||||
},
|
},
|
||||||
@@ -81,7 +81,7 @@ class GetChapter
|
|||||||
|
|
||||||
fun asFlow(chapter: Chapter) =
|
fun asFlow(chapter: Chapter) =
|
||||||
serverListeners.combineChapters(
|
serverListeners.combineChapters(
|
||||||
chapterRepository.getChapter(chapter.mangaId, chapter.index),
|
chapterRepositoryOld.getChapter(chapter.mangaId, chapter.index),
|
||||||
indexPredate = { id, chapterIndexes ->
|
indexPredate = { id, chapterIndexes ->
|
||||||
id == chapter.mangaId && (chapterIndexes == null || chapter.index in chapterIndexes)
|
id == chapter.mangaId && (chapterIndexes == null || chapter.index in chapterIndexes)
|
||||||
},
|
},
|
||||||
|
|||||||
@@ -7,7 +7,7 @@
|
|||||||
package ca.gosyer.jui.domain.chapter.interactor
|
package ca.gosyer.jui.domain.chapter.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.chapter.model.Chapter
|
import ca.gosyer.jui.domain.chapter.model.Chapter
|
||||||
import ca.gosyer.jui.domain.chapter.service.ChapterRepository
|
import ca.gosyer.jui.domain.chapter.service.ChapterRepositoryOld
|
||||||
import ca.gosyer.jui.domain.manga.model.Manga
|
import ca.gosyer.jui.domain.manga.model.Manga
|
||||||
import io.ktor.client.request.HttpRequestBuilder
|
import io.ktor.client.request.HttpRequestBuilder
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
@@ -18,7 +18,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class GetChapterPage
|
class GetChapterPage
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val chapterRepository: ChapterRepository,
|
private val chapterRepositoryOld: ChapterRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
mangaId: Long,
|
mangaId: Long,
|
||||||
@@ -63,20 +63,20 @@ class GetChapterPage
|
|||||||
index: Int,
|
index: Int,
|
||||||
pageNum: Int,
|
pageNum: Int,
|
||||||
block: HttpRequestBuilder.() -> Unit,
|
block: HttpRequestBuilder.() -> Unit,
|
||||||
) = chapterRepository.getPage(mangaId, index, pageNum, block)
|
) = chapterRepositoryOld.getPage(mangaId, index, pageNum, block)
|
||||||
|
|
||||||
fun asFlow(
|
fun asFlow(
|
||||||
manga: Manga,
|
manga: Manga,
|
||||||
index: Int,
|
index: Int,
|
||||||
pageNum: Int,
|
pageNum: Int,
|
||||||
block: HttpRequestBuilder.() -> Unit,
|
block: HttpRequestBuilder.() -> Unit,
|
||||||
) = chapterRepository.getPage(manga.id, index, pageNum, block)
|
) = chapterRepositoryOld.getPage(manga.id, index, pageNum, block)
|
||||||
|
|
||||||
fun asFlow(
|
fun asFlow(
|
||||||
chapter: Chapter,
|
chapter: Chapter,
|
||||||
pageNum: Int,
|
pageNum: Int,
|
||||||
block: HttpRequestBuilder.() -> Unit,
|
block: HttpRequestBuilder.() -> Unit,
|
||||||
) = chapterRepository.getPage(chapter.mangaId, chapter.index, pageNum, block)
|
) = chapterRepositoryOld.getPage(chapter.mangaId, chapter.index, pageNum, block)
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -7,7 +7,7 @@
|
|||||||
package ca.gosyer.jui.domain.chapter.interactor
|
package ca.gosyer.jui.domain.chapter.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.ServerListeners
|
import ca.gosyer.jui.domain.ServerListeners
|
||||||
import ca.gosyer.jui.domain.chapter.service.ChapterRepository
|
import ca.gosyer.jui.domain.chapter.service.ChapterRepositoryOld
|
||||||
import ca.gosyer.jui.domain.manga.model.Manga
|
import ca.gosyer.jui.domain.manga.model.Manga
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.singleOrNull
|
import kotlinx.coroutines.flow.singleOrNull
|
||||||
@@ -18,7 +18,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class GetChapters
|
class GetChapters
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val chapterRepository: ChapterRepository,
|
private val chapterRepositoryOld: ChapterRepositoryOld,
|
||||||
private val serverListeners: ServerListeners,
|
private val serverListeners: ServerListeners,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
@@ -45,14 +45,14 @@ class GetChapters
|
|||||||
|
|
||||||
fun asFlow(mangaId: Long) =
|
fun asFlow(mangaId: Long) =
|
||||||
serverListeners.combineChapters(
|
serverListeners.combineChapters(
|
||||||
chapterRepository.getChapters(mangaId),
|
chapterRepositoryOld.getChapters(mangaId),
|
||||||
indexPredate = { id, _ -> id == mangaId },
|
indexPredate = { id, _ -> id == mangaId },
|
||||||
idPredate = { id, _ -> id == mangaId },
|
idPredate = { id, _ -> id == mangaId },
|
||||||
)
|
)
|
||||||
|
|
||||||
fun asFlow(manga: Manga) =
|
fun asFlow(manga: Manga) =
|
||||||
serverListeners.combineChapters(
|
serverListeners.combineChapters(
|
||||||
chapterRepository.getChapters(manga.id),
|
chapterRepositoryOld.getChapters(manga.id),
|
||||||
indexPredate = { id, _ -> id == manga.id },
|
indexPredate = { id, _ -> id == manga.id },
|
||||||
idPredate = { id, _ -> id == manga.id },
|
idPredate = { id, _ -> id == manga.id },
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -7,7 +7,7 @@
|
|||||||
package ca.gosyer.jui.domain.chapter.interactor
|
package ca.gosyer.jui.domain.chapter.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.ServerListeners
|
import ca.gosyer.jui.domain.ServerListeners
|
||||||
import ca.gosyer.jui.domain.chapter.service.ChapterRepository
|
import ca.gosyer.jui.domain.chapter.service.ChapterRepositoryOld
|
||||||
import ca.gosyer.jui.domain.manga.model.Manga
|
import ca.gosyer.jui.domain.manga.model.Manga
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.onEach
|
import kotlinx.coroutines.flow.onEach
|
||||||
@@ -18,7 +18,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class RefreshChapters
|
class RefreshChapters
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val chapterRepository: ChapterRepository,
|
private val chapterRepositoryOld: ChapterRepositoryOld,
|
||||||
private val serverListeners: ServerListeners,
|
private val serverListeners: ServerListeners,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
@@ -42,11 +42,11 @@ class RefreshChapters
|
|||||||
.singleOrNull()
|
.singleOrNull()
|
||||||
|
|
||||||
fun asFlow(mangaId: Long) =
|
fun asFlow(mangaId: Long) =
|
||||||
chapterRepository.getChapters(mangaId, true)
|
chapterRepositoryOld.getChapters(mangaId, true)
|
||||||
.onEach { serverListeners.updateChapters(mangaId) }
|
.onEach { serverListeners.updateChapters(mangaId) }
|
||||||
|
|
||||||
fun asFlow(manga: Manga) =
|
fun asFlow(manga: Manga) =
|
||||||
chapterRepository.getChapters(manga.id, true)
|
chapterRepositoryOld.getChapters(manga.id, true)
|
||||||
.onEach { serverListeners.updateChapters(manga.id) }
|
.onEach { serverListeners.updateChapters(manga.id) }
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
|
|||||||
@@ -8,7 +8,7 @@ package ca.gosyer.jui.domain.chapter.interactor
|
|||||||
|
|
||||||
import ca.gosyer.jui.domain.ServerListeners
|
import ca.gosyer.jui.domain.ServerListeners
|
||||||
import ca.gosyer.jui.domain.chapter.model.Chapter
|
import ca.gosyer.jui.domain.chapter.model.Chapter
|
||||||
import ca.gosyer.jui.domain.chapter.service.ChapterRepository
|
import ca.gosyer.jui.domain.chapter.service.ChapterRepositoryOld
|
||||||
import ca.gosyer.jui.domain.manga.model.Manga
|
import ca.gosyer.jui.domain.manga.model.Manga
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
@@ -19,7 +19,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class UpdateChapterBookmarked
|
class UpdateChapterBookmarked
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val chapterRepository: ChapterRepository,
|
private val chapterRepositoryOld: ChapterRepositoryOld,
|
||||||
private val serverListeners: ServerListeners,
|
private val serverListeners: ServerListeners,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
@@ -61,7 +61,7 @@ class UpdateChapterBookmarked
|
|||||||
mangaId: Long,
|
mangaId: Long,
|
||||||
index: Int,
|
index: Int,
|
||||||
bookmarked: Boolean,
|
bookmarked: Boolean,
|
||||||
) = chapterRepository.updateChapter(
|
) = chapterRepositoryOld.updateChapter(
|
||||||
mangaId = mangaId,
|
mangaId = mangaId,
|
||||||
chapterIndex = index,
|
chapterIndex = index,
|
||||||
bookmarked = bookmarked,
|
bookmarked = bookmarked,
|
||||||
@@ -71,7 +71,7 @@ class UpdateChapterBookmarked
|
|||||||
manga: Manga,
|
manga: Manga,
|
||||||
index: Int,
|
index: Int,
|
||||||
bookmarked: Boolean,
|
bookmarked: Boolean,
|
||||||
) = chapterRepository.updateChapter(
|
) = chapterRepositoryOld.updateChapter(
|
||||||
mangaId = manga.id,
|
mangaId = manga.id,
|
||||||
chapterIndex = index,
|
chapterIndex = index,
|
||||||
bookmarked = bookmarked,
|
bookmarked = bookmarked,
|
||||||
@@ -80,7 +80,7 @@ class UpdateChapterBookmarked
|
|||||||
fun asFlow(
|
fun asFlow(
|
||||||
chapter: Chapter,
|
chapter: Chapter,
|
||||||
bookmarked: Boolean,
|
bookmarked: Boolean,
|
||||||
) = chapterRepository.updateChapter(
|
) = chapterRepositoryOld.updateChapter(
|
||||||
mangaId = chapter.mangaId,
|
mangaId = chapter.mangaId,
|
||||||
chapterIndex = chapter.index,
|
chapterIndex = chapter.index,
|
||||||
bookmarked = bookmarked,
|
bookmarked = bookmarked,
|
||||||
|
|||||||
@@ -8,7 +8,7 @@ package ca.gosyer.jui.domain.chapter.interactor
|
|||||||
|
|
||||||
import ca.gosyer.jui.domain.ServerListeners
|
import ca.gosyer.jui.domain.ServerListeners
|
||||||
import ca.gosyer.jui.domain.chapter.model.Chapter
|
import ca.gosyer.jui.domain.chapter.model.Chapter
|
||||||
import ca.gosyer.jui.domain.chapter.service.ChapterRepository
|
import ca.gosyer.jui.domain.chapter.service.ChapterRepositoryOld
|
||||||
import ca.gosyer.jui.domain.manga.model.Manga
|
import ca.gosyer.jui.domain.manga.model.Manga
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
@@ -19,7 +19,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class UpdateChapterLastPageRead
|
class UpdateChapterLastPageRead
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val chapterRepository: ChapterRepository,
|
private val chapterRepositoryOld: ChapterRepositoryOld,
|
||||||
private val serverListeners: ServerListeners,
|
private val serverListeners: ServerListeners,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
@@ -61,7 +61,7 @@ class UpdateChapterLastPageRead
|
|||||||
mangaId: Long,
|
mangaId: Long,
|
||||||
index: Int,
|
index: Int,
|
||||||
lastPageRead: Int,
|
lastPageRead: Int,
|
||||||
) = chapterRepository.updateChapter(
|
) = chapterRepositoryOld.updateChapter(
|
||||||
mangaId = mangaId,
|
mangaId = mangaId,
|
||||||
chapterIndex = index,
|
chapterIndex = index,
|
||||||
lastPageRead = lastPageRead,
|
lastPageRead = lastPageRead,
|
||||||
@@ -71,7 +71,7 @@ class UpdateChapterLastPageRead
|
|||||||
manga: Manga,
|
manga: Manga,
|
||||||
index: Int,
|
index: Int,
|
||||||
lastPageRead: Int,
|
lastPageRead: Int,
|
||||||
) = chapterRepository.updateChapter(
|
) = chapterRepositoryOld.updateChapter(
|
||||||
mangaId = manga.id,
|
mangaId = manga.id,
|
||||||
chapterIndex = index,
|
chapterIndex = index,
|
||||||
lastPageRead = lastPageRead,
|
lastPageRead = lastPageRead,
|
||||||
@@ -80,7 +80,7 @@ class UpdateChapterLastPageRead
|
|||||||
fun asFlow(
|
fun asFlow(
|
||||||
chapter: Chapter,
|
chapter: Chapter,
|
||||||
lastPageRead: Int,
|
lastPageRead: Int,
|
||||||
) = chapterRepository.updateChapter(
|
) = chapterRepositoryOld.updateChapter(
|
||||||
mangaId = chapter.mangaId,
|
mangaId = chapter.mangaId,
|
||||||
chapterIndex = chapter.index,
|
chapterIndex = chapter.index,
|
||||||
lastPageRead = lastPageRead,
|
lastPageRead = lastPageRead,
|
||||||
|
|||||||
@@ -8,7 +8,7 @@ package ca.gosyer.jui.domain.chapter.interactor
|
|||||||
|
|
||||||
import ca.gosyer.jui.domain.ServerListeners
|
import ca.gosyer.jui.domain.ServerListeners
|
||||||
import ca.gosyer.jui.domain.chapter.model.Chapter
|
import ca.gosyer.jui.domain.chapter.model.Chapter
|
||||||
import ca.gosyer.jui.domain.chapter.service.ChapterRepository
|
import ca.gosyer.jui.domain.chapter.service.ChapterRepositoryOld
|
||||||
import ca.gosyer.jui.domain.manga.model.Manga
|
import ca.gosyer.jui.domain.manga.model.Manga
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
@@ -19,7 +19,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class UpdateChapterMarkPreviousRead
|
class UpdateChapterMarkPreviousRead
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val chapterRepository: ChapterRepository,
|
private val chapterRepositoryOld: ChapterRepositoryOld,
|
||||||
private val serverListeners: ServerListeners,
|
private val serverListeners: ServerListeners,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
@@ -57,7 +57,7 @@ class UpdateChapterMarkPreviousRead
|
|||||||
fun asFlow(
|
fun asFlow(
|
||||||
mangaId: Long,
|
mangaId: Long,
|
||||||
index: Int,
|
index: Int,
|
||||||
) = chapterRepository.updateChapter(
|
) = chapterRepositoryOld.updateChapter(
|
||||||
mangaId = mangaId,
|
mangaId = mangaId,
|
||||||
chapterIndex = index,
|
chapterIndex = index,
|
||||||
markPreviousRead = true,
|
markPreviousRead = true,
|
||||||
@@ -66,14 +66,14 @@ class UpdateChapterMarkPreviousRead
|
|||||||
fun asFlow(
|
fun asFlow(
|
||||||
manga: Manga,
|
manga: Manga,
|
||||||
index: Int,
|
index: Int,
|
||||||
) = chapterRepository.updateChapter(
|
) = chapterRepositoryOld.updateChapter(
|
||||||
mangaId = manga.id,
|
mangaId = manga.id,
|
||||||
chapterIndex = index,
|
chapterIndex = index,
|
||||||
markPreviousRead = true,
|
markPreviousRead = true,
|
||||||
).onEach { serverListeners.updateChapters(manga.id, index) }
|
).onEach { serverListeners.updateChapters(manga.id, index) }
|
||||||
|
|
||||||
fun asFlow(chapter: Chapter) =
|
fun asFlow(chapter: Chapter) =
|
||||||
chapterRepository.updateChapter(
|
chapterRepositoryOld.updateChapter(
|
||||||
mangaId = chapter.mangaId,
|
mangaId = chapter.mangaId,
|
||||||
chapterIndex = chapter.index,
|
chapterIndex = chapter.index,
|
||||||
markPreviousRead = true,
|
markPreviousRead = true,
|
||||||
|
|||||||
@@ -8,7 +8,7 @@ package ca.gosyer.jui.domain.chapter.interactor
|
|||||||
|
|
||||||
import ca.gosyer.jui.domain.ServerListeners
|
import ca.gosyer.jui.domain.ServerListeners
|
||||||
import ca.gosyer.jui.domain.chapter.model.Chapter
|
import ca.gosyer.jui.domain.chapter.model.Chapter
|
||||||
import ca.gosyer.jui.domain.chapter.service.ChapterRepository
|
import ca.gosyer.jui.domain.chapter.service.ChapterRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
import kotlinx.coroutines.flow.flow
|
import kotlinx.coroutines.flow.flow
|
||||||
@@ -18,7 +18,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class UpdateChapterMeta
|
class UpdateChapterMeta
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val chapterRepository: ChapterRepository,
|
private val chapterRepositoryOld: ChapterRepositoryOld,
|
||||||
private val serverListeners: ServerListeners,
|
private val serverListeners: ServerListeners,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
@@ -37,7 +37,7 @@ class UpdateChapterMeta
|
|||||||
pageOffset: Int = chapter.meta.juiPageOffset,
|
pageOffset: Int = chapter.meta.juiPageOffset,
|
||||||
) = flow {
|
) = flow {
|
||||||
if (pageOffset != chapter.meta.juiPageOffset) {
|
if (pageOffset != chapter.meta.juiPageOffset) {
|
||||||
chapterRepository.updateChapterMeta(
|
chapterRepositoryOld.updateChapterMeta(
|
||||||
chapter.mangaId,
|
chapter.mangaId,
|
||||||
chapter.index,
|
chapter.index,
|
||||||
"juiPageOffset",
|
"juiPageOffset",
|
||||||
|
|||||||
@@ -8,7 +8,7 @@ package ca.gosyer.jui.domain.chapter.interactor
|
|||||||
|
|
||||||
import ca.gosyer.jui.domain.ServerListeners
|
import ca.gosyer.jui.domain.ServerListeners
|
||||||
import ca.gosyer.jui.domain.chapter.model.Chapter
|
import ca.gosyer.jui.domain.chapter.model.Chapter
|
||||||
import ca.gosyer.jui.domain.chapter.service.ChapterRepository
|
import ca.gosyer.jui.domain.chapter.service.ChapterRepositoryOld
|
||||||
import ca.gosyer.jui.domain.manga.model.Manga
|
import ca.gosyer.jui.domain.manga.model.Manga
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
@@ -19,7 +19,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class UpdateChapterRead
|
class UpdateChapterRead
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val chapterRepository: ChapterRepository,
|
private val chapterRepositoryOld: ChapterRepositoryOld,
|
||||||
private val serverListeners: ServerListeners,
|
private val serverListeners: ServerListeners,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
@@ -61,7 +61,7 @@ class UpdateChapterRead
|
|||||||
mangaId: Long,
|
mangaId: Long,
|
||||||
index: Int,
|
index: Int,
|
||||||
read: Boolean,
|
read: Boolean,
|
||||||
) = chapterRepository.updateChapter(
|
) = chapterRepositoryOld.updateChapter(
|
||||||
mangaId = mangaId,
|
mangaId = mangaId,
|
||||||
chapterIndex = index,
|
chapterIndex = index,
|
||||||
read = read,
|
read = read,
|
||||||
@@ -71,7 +71,7 @@ class UpdateChapterRead
|
|||||||
manga: Manga,
|
manga: Manga,
|
||||||
index: Int,
|
index: Int,
|
||||||
read: Boolean,
|
read: Boolean,
|
||||||
) = chapterRepository.updateChapter(
|
) = chapterRepositoryOld.updateChapter(
|
||||||
mangaId = manga.id,
|
mangaId = manga.id,
|
||||||
chapterIndex = index,
|
chapterIndex = index,
|
||||||
read = read,
|
read = read,
|
||||||
@@ -80,7 +80,7 @@ class UpdateChapterRead
|
|||||||
fun asFlow(
|
fun asFlow(
|
||||||
chapter: Chapter,
|
chapter: Chapter,
|
||||||
read: Boolean,
|
read: Boolean,
|
||||||
) = chapterRepository.updateChapter(
|
) = chapterRepositoryOld.updateChapter(
|
||||||
mangaId = chapter.mangaId,
|
mangaId = chapter.mangaId,
|
||||||
chapterIndex = chapter.index,
|
chapterIndex = chapter.index,
|
||||||
read = read,
|
read = read,
|
||||||
|
|||||||
@@ -24,7 +24,7 @@ import io.ktor.client.request.HttpRequestBuilder
|
|||||||
import io.ktor.client.statement.HttpResponse
|
import io.ktor.client.statement.HttpResponse
|
||||||
import kotlinx.coroutines.flow.Flow
|
import kotlinx.coroutines.flow.Flow
|
||||||
|
|
||||||
interface ChapterRepository {
|
interface ChapterRepositoryOld {
|
||||||
@GET("api/v1/manga/{mangaId}/chapters")
|
@GET("api/v1/manga/{mangaId}/chapters")
|
||||||
fun getChapters(
|
fun getChapters(
|
||||||
@Path("mangaId") mangaId: Long,
|
@Path("mangaId") mangaId: Long,
|
||||||
@@ -7,7 +7,7 @@
|
|||||||
package ca.gosyer.jui.domain.download.interactor
|
package ca.gosyer.jui.domain.download.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.download.model.DownloadEnqueue
|
import ca.gosyer.jui.domain.download.model.DownloadEnqueue
|
||||||
import ca.gosyer.jui.domain.download.service.DownloadRepository
|
import ca.gosyer.jui.domain.download.service.DownloadRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -16,7 +16,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class BatchChapterDownload
|
class BatchChapterDownload
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val downloadRepository: DownloadRepository,
|
private val downloadRepositoryOld: DownloadRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
chapterIds: List<Long>,
|
chapterIds: List<Long>,
|
||||||
@@ -38,9 +38,9 @@ class BatchChapterDownload
|
|||||||
}
|
}
|
||||||
.collect()
|
.collect()
|
||||||
|
|
||||||
fun asFlow(chapterIds: List<Long>) = downloadRepository.batchDownload(DownloadEnqueue(chapterIds))
|
fun asFlow(chapterIds: List<Long>) = downloadRepositoryOld.batchDownload(DownloadEnqueue(chapterIds))
|
||||||
|
|
||||||
fun asFlow(vararg chapterIds: Long) = downloadRepository.batchDownload(DownloadEnqueue(chapterIds.asList()))
|
fun asFlow(vararg chapterIds: Long) = downloadRepositoryOld.batchDownload(DownloadEnqueue(chapterIds.asList()))
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -6,7 +6,7 @@
|
|||||||
|
|
||||||
package ca.gosyer.jui.domain.download.interactor
|
package ca.gosyer.jui.domain.download.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.download.service.DownloadRepository
|
import ca.gosyer.jui.domain.download.service.DownloadRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -15,7 +15,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class ClearDownloadQueue
|
class ClearDownloadQueue
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val downloadRepository: DownloadRepository,
|
private val downloadRepositoryOld: DownloadRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(onError: suspend (Throwable) -> Unit = {}) =
|
suspend fun await(onError: suspend (Throwable) -> Unit = {}) =
|
||||||
asFlow()
|
asFlow()
|
||||||
@@ -25,7 +25,7 @@ class ClearDownloadQueue
|
|||||||
}
|
}
|
||||||
.collect()
|
.collect()
|
||||||
|
|
||||||
fun asFlow() = downloadRepository.clearDownloadQueue()
|
fun asFlow() = downloadRepositoryOld.clearDownloadQueue()
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -7,7 +7,7 @@
|
|||||||
package ca.gosyer.jui.domain.download.interactor
|
package ca.gosyer.jui.domain.download.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.chapter.model.Chapter
|
import ca.gosyer.jui.domain.chapter.model.Chapter
|
||||||
import ca.gosyer.jui.domain.download.service.DownloadRepository
|
import ca.gosyer.jui.domain.download.service.DownloadRepositoryOld
|
||||||
import ca.gosyer.jui.domain.manga.model.Manga
|
import ca.gosyer.jui.domain.manga.model.Manga
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
@@ -17,7 +17,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class QueueChapterDownload
|
class QueueChapterDownload
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val downloadRepository: DownloadRepository,
|
private val downloadRepositoryOld: DownloadRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
mangaId: Long,
|
mangaId: Long,
|
||||||
@@ -54,14 +54,14 @@ class QueueChapterDownload
|
|||||||
fun asFlow(
|
fun asFlow(
|
||||||
mangaId: Long,
|
mangaId: Long,
|
||||||
index: Int,
|
index: Int,
|
||||||
) = downloadRepository.queueChapterDownload(mangaId, index)
|
) = downloadRepositoryOld.queueChapterDownload(mangaId, index)
|
||||||
|
|
||||||
fun asFlow(
|
fun asFlow(
|
||||||
manga: Manga,
|
manga: Manga,
|
||||||
index: Int,
|
index: Int,
|
||||||
) = downloadRepository.queueChapterDownload(manga.id, index)
|
) = downloadRepositoryOld.queueChapterDownload(manga.id, index)
|
||||||
|
|
||||||
fun asFlow(chapter: Chapter) = downloadRepository.queueChapterDownload(chapter.mangaId, chapter.index)
|
fun asFlow(chapter: Chapter) = downloadRepositoryOld.queueChapterDownload(chapter.mangaId, chapter.index)
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -7,7 +7,7 @@
|
|||||||
package ca.gosyer.jui.domain.download.interactor
|
package ca.gosyer.jui.domain.download.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.chapter.model.Chapter
|
import ca.gosyer.jui.domain.chapter.model.Chapter
|
||||||
import ca.gosyer.jui.domain.download.service.DownloadRepository
|
import ca.gosyer.jui.domain.download.service.DownloadRepositoryOld
|
||||||
import ca.gosyer.jui.domain.manga.model.Manga
|
import ca.gosyer.jui.domain.manga.model.Manga
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
@@ -17,7 +17,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class ReorderChapterDownload
|
class ReorderChapterDownload
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val downloadRepository: DownloadRepository,
|
private val downloadRepositoryOld: DownloadRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
mangaId: Long,
|
mangaId: Long,
|
||||||
@@ -58,18 +58,18 @@ class ReorderChapterDownload
|
|||||||
mangaId: Long,
|
mangaId: Long,
|
||||||
index: Int,
|
index: Int,
|
||||||
to: Int,
|
to: Int,
|
||||||
) = downloadRepository.reorderChapterDownload(mangaId, index, to)
|
) = downloadRepositoryOld.reorderChapterDownload(mangaId, index, to)
|
||||||
|
|
||||||
fun asFlow(
|
fun asFlow(
|
||||||
manga: Manga,
|
manga: Manga,
|
||||||
index: Int,
|
index: Int,
|
||||||
to: Int,
|
to: Int,
|
||||||
) = downloadRepository.reorderChapterDownload(manga.id, index, to)
|
) = downloadRepositoryOld.reorderChapterDownload(manga.id, index, to)
|
||||||
|
|
||||||
fun asFlow(
|
fun asFlow(
|
||||||
chapter: Chapter,
|
chapter: Chapter,
|
||||||
to: Int,
|
to: Int,
|
||||||
) = downloadRepository.reorderChapterDownload(chapter.mangaId, chapter.index, to)
|
) = downloadRepositoryOld.reorderChapterDownload(chapter.mangaId, chapter.index, to)
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -6,7 +6,7 @@
|
|||||||
|
|
||||||
package ca.gosyer.jui.domain.download.interactor
|
package ca.gosyer.jui.domain.download.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.download.service.DownloadRepository
|
import ca.gosyer.jui.domain.download.service.DownloadRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -15,7 +15,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class StartDownloading
|
class StartDownloading
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val downloadRepository: DownloadRepository,
|
private val downloadRepositoryOld: DownloadRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(onError: suspend (Throwable) -> Unit = {}) =
|
suspend fun await(onError: suspend (Throwable) -> Unit = {}) =
|
||||||
asFlow()
|
asFlow()
|
||||||
@@ -25,7 +25,7 @@ class StartDownloading
|
|||||||
}
|
}
|
||||||
.collect()
|
.collect()
|
||||||
|
|
||||||
fun asFlow() = downloadRepository.startDownloading()
|
fun asFlow() = downloadRepositoryOld.startDownloading()
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -7,7 +7,7 @@
|
|||||||
package ca.gosyer.jui.domain.download.interactor
|
package ca.gosyer.jui.domain.download.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.chapter.model.Chapter
|
import ca.gosyer.jui.domain.chapter.model.Chapter
|
||||||
import ca.gosyer.jui.domain.download.service.DownloadRepository
|
import ca.gosyer.jui.domain.download.service.DownloadRepositoryOld
|
||||||
import ca.gosyer.jui.domain.manga.model.Manga
|
import ca.gosyer.jui.domain.manga.model.Manga
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
@@ -17,7 +17,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class StopChapterDownload
|
class StopChapterDownload
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val downloadRepository: DownloadRepository,
|
private val downloadRepositoryOld: DownloadRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
mangaId: Long,
|
mangaId: Long,
|
||||||
@@ -54,14 +54,14 @@ class StopChapterDownload
|
|||||||
fun asFlow(
|
fun asFlow(
|
||||||
mangaId: Long,
|
mangaId: Long,
|
||||||
index: Int,
|
index: Int,
|
||||||
) = downloadRepository.stopChapterDownload(mangaId, index)
|
) = downloadRepositoryOld.stopChapterDownload(mangaId, index)
|
||||||
|
|
||||||
fun asFlow(
|
fun asFlow(
|
||||||
manga: Manga,
|
manga: Manga,
|
||||||
index: Int,
|
index: Int,
|
||||||
) = downloadRepository.stopChapterDownload(manga.id, index)
|
) = downloadRepositoryOld.stopChapterDownload(manga.id, index)
|
||||||
|
|
||||||
fun asFlow(chapter: Chapter) = downloadRepository.stopChapterDownload(chapter.mangaId, chapter.index)
|
fun asFlow(chapter: Chapter) = downloadRepositoryOld.stopChapterDownload(chapter.mangaId, chapter.index)
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -6,7 +6,7 @@
|
|||||||
|
|
||||||
package ca.gosyer.jui.domain.download.interactor
|
package ca.gosyer.jui.domain.download.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.download.service.DownloadRepository
|
import ca.gosyer.jui.domain.download.service.DownloadRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -15,7 +15,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class StopDownloading
|
class StopDownloading
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val downloadRepository: DownloadRepository,
|
private val downloadRepositoryOld: DownloadRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(onError: suspend (Throwable) -> Unit = {}) =
|
suspend fun await(onError: suspend (Throwable) -> Unit = {}) =
|
||||||
asFlow()
|
asFlow()
|
||||||
@@ -25,7 +25,7 @@ class StopDownloading
|
|||||||
}
|
}
|
||||||
.collect()
|
.collect()
|
||||||
|
|
||||||
fun asFlow() = downloadRepository.stopDownloading()
|
fun asFlow() = downloadRepositoryOld.stopDownloading()
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -17,7 +17,7 @@ import de.jensklingenberg.ktorfit.http.Path
|
|||||||
import io.ktor.client.statement.HttpResponse
|
import io.ktor.client.statement.HttpResponse
|
||||||
import kotlinx.coroutines.flow.Flow
|
import kotlinx.coroutines.flow.Flow
|
||||||
|
|
||||||
interface DownloadRepository {
|
interface DownloadRepositoryOld {
|
||||||
@GET("api/v1/downloads/start")
|
@GET("api/v1/downloads/start")
|
||||||
fun startDownloading(): Flow<HttpResponse>
|
fun startDownloading(): Flow<HttpResponse>
|
||||||
|
|
||||||
@@ -6,7 +6,7 @@
|
|||||||
|
|
||||||
package ca.gosyer.jui.domain.extension.interactor
|
package ca.gosyer.jui.domain.extension.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.extension.service.ExtensionRepository
|
import ca.gosyer.jui.domain.extension.service.ExtensionRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.singleOrNull
|
import kotlinx.coroutines.flow.singleOrNull
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -15,7 +15,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class GetExtensionList
|
class GetExtensionList
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val extensionRepository: ExtensionRepository,
|
private val extensionRepositoryOld: ExtensionRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(onError: suspend (Throwable) -> Unit = {}) =
|
suspend fun await(onError: suspend (Throwable) -> Unit = {}) =
|
||||||
asFlow()
|
asFlow()
|
||||||
@@ -25,7 +25,7 @@ class GetExtensionList
|
|||||||
}
|
}
|
||||||
.singleOrNull()
|
.singleOrNull()
|
||||||
|
|
||||||
fun asFlow() = extensionRepository.getExtensionList()
|
fun asFlow() = extensionRepositoryOld.getExtensionList()
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -7,7 +7,7 @@
|
|||||||
package ca.gosyer.jui.domain.extension.interactor
|
package ca.gosyer.jui.domain.extension.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.extension.model.Extension
|
import ca.gosyer.jui.domain.extension.model.Extension
|
||||||
import ca.gosyer.jui.domain.extension.service.ExtensionRepository
|
import ca.gosyer.jui.domain.extension.service.ExtensionRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -16,7 +16,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class InstallExtension
|
class InstallExtension
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val extensionRepository: ExtensionRepository,
|
private val extensionRepositoryOld: ExtensionRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
extension: Extension,
|
extension: Extension,
|
||||||
@@ -28,7 +28,7 @@ class InstallExtension
|
|||||||
}
|
}
|
||||||
.collect()
|
.collect()
|
||||||
|
|
||||||
fun asFlow(extension: Extension) = extensionRepository.installExtension(extension.pkgName)
|
fun asFlow(extension: Extension) = extensionRepositoryOld.installExtension(extension.pkgName)
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -6,7 +6,7 @@
|
|||||||
|
|
||||||
package ca.gosyer.jui.domain.extension.interactor
|
package ca.gosyer.jui.domain.extension.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.extension.service.ExtensionRepository
|
import ca.gosyer.jui.domain.extension.service.ExtensionRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -16,7 +16,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class InstallExtensionFile
|
class InstallExtensionFile
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val extensionRepository: ExtensionRepository,
|
private val extensionRepositoryOld: ExtensionRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
path: Path,
|
path: Path,
|
||||||
@@ -28,7 +28,7 @@ class InstallExtensionFile
|
|||||||
}
|
}
|
||||||
.collect()
|
.collect()
|
||||||
|
|
||||||
fun asFlow(path: Path) = extensionRepository.installExtension(ExtensionRepository.buildExtensionFormData(path))
|
fun asFlow(path: Path) = extensionRepositoryOld.installExtension(ExtensionRepositoryOld.buildExtensionFormData(path))
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -7,7 +7,7 @@
|
|||||||
package ca.gosyer.jui.domain.extension.interactor
|
package ca.gosyer.jui.domain.extension.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.extension.model.Extension
|
import ca.gosyer.jui.domain.extension.model.Extension
|
||||||
import ca.gosyer.jui.domain.extension.service.ExtensionRepository
|
import ca.gosyer.jui.domain.extension.service.ExtensionRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -16,7 +16,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class UninstallExtension
|
class UninstallExtension
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val extensionRepository: ExtensionRepository,
|
private val extensionRepositoryOld: ExtensionRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
extension: Extension,
|
extension: Extension,
|
||||||
@@ -28,7 +28,7 @@ class UninstallExtension
|
|||||||
}
|
}
|
||||||
.collect()
|
.collect()
|
||||||
|
|
||||||
fun asFlow(extension: Extension) = extensionRepository.uninstallExtension(extension.pkgName)
|
fun asFlow(extension: Extension) = extensionRepositoryOld.uninstallExtension(extension.pkgName)
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -7,7 +7,7 @@
|
|||||||
package ca.gosyer.jui.domain.extension.interactor
|
package ca.gosyer.jui.domain.extension.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.extension.model.Extension
|
import ca.gosyer.jui.domain.extension.model.Extension
|
||||||
import ca.gosyer.jui.domain.extension.service.ExtensionRepository
|
import ca.gosyer.jui.domain.extension.service.ExtensionRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -16,7 +16,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class UpdateExtension
|
class UpdateExtension
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val extensionRepository: ExtensionRepository,
|
private val extensionRepositoryOld: ExtensionRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
extension: Extension,
|
extension: Extension,
|
||||||
@@ -28,7 +28,7 @@ class UpdateExtension
|
|||||||
}
|
}
|
||||||
.collect()
|
.collect()
|
||||||
|
|
||||||
fun asFlow(extension: Extension) = extensionRepository.updateExtension(extension.pkgName)
|
fun asFlow(extension: Extension) = extensionRepositoryOld.updateExtension(extension.pkgName)
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -26,7 +26,7 @@ import kotlinx.coroutines.flow.Flow
|
|||||||
import okio.FileSystem
|
import okio.FileSystem
|
||||||
import okio.buffer
|
import okio.buffer
|
||||||
|
|
||||||
interface ExtensionRepository {
|
interface ExtensionRepositoryOld {
|
||||||
@GET("api/v1/extension/list")
|
@GET("api/v1/extension/list")
|
||||||
fun getExtensionList(): Flow<List<Extension>>
|
fun getExtensionList(): Flow<List<Extension>>
|
||||||
|
|
||||||
@@ -6,7 +6,7 @@
|
|||||||
|
|
||||||
package ca.gosyer.jui.domain.global.interactor
|
package ca.gosyer.jui.domain.global.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.global.service.GlobalRepository
|
import ca.gosyer.jui.domain.global.service.GlobalRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.singleOrNull
|
import kotlinx.coroutines.flow.singleOrNull
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -15,7 +15,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class GetGlobalMeta
|
class GetGlobalMeta
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val globalRepository: GlobalRepository,
|
private val globalRepositoryOld: GlobalRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(onError: suspend (Throwable) -> Unit = {}) =
|
suspend fun await(onError: suspend (Throwable) -> Unit = {}) =
|
||||||
asFlow()
|
asFlow()
|
||||||
@@ -25,7 +25,7 @@ class GetGlobalMeta
|
|||||||
}
|
}
|
||||||
.singleOrNull()
|
.singleOrNull()
|
||||||
|
|
||||||
fun asFlow() = globalRepository.getGlobalMeta()
|
fun asFlow() = globalRepositoryOld.getGlobalMeta()
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -7,7 +7,7 @@
|
|||||||
package ca.gosyer.jui.domain.global.interactor
|
package ca.gosyer.jui.domain.global.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.global.model.GlobalMeta
|
import ca.gosyer.jui.domain.global.model.GlobalMeta
|
||||||
import ca.gosyer.jui.domain.global.service.GlobalRepository
|
import ca.gosyer.jui.domain.global.service.GlobalRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
import kotlinx.coroutines.flow.flow
|
import kotlinx.coroutines.flow.flow
|
||||||
@@ -17,7 +17,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class UpdateGlobalMeta
|
class UpdateGlobalMeta
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val globalRepository: GlobalRepository,
|
private val globalRepositoryOld: GlobalRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
globalMeta: GlobalMeta,
|
globalMeta: GlobalMeta,
|
||||||
@@ -35,7 +35,7 @@ class UpdateGlobalMeta
|
|||||||
example: Int = globalMeta.example,
|
example: Int = globalMeta.example,
|
||||||
) = flow {
|
) = flow {
|
||||||
if (example != globalMeta.example) {
|
if (example != globalMeta.example) {
|
||||||
globalRepository.updateGlobalMeta(
|
globalRepositoryOld.updateGlobalMeta(
|
||||||
"example",
|
"example",
|
||||||
example.toString(),
|
example.toString(),
|
||||||
).collect()
|
).collect()
|
||||||
|
|||||||
@@ -14,7 +14,7 @@ import de.jensklingenberg.ktorfit.http.PATCH
|
|||||||
import io.ktor.client.statement.HttpResponse
|
import io.ktor.client.statement.HttpResponse
|
||||||
import kotlinx.coroutines.flow.Flow
|
import kotlinx.coroutines.flow.Flow
|
||||||
|
|
||||||
interface GlobalRepository {
|
interface GlobalRepositoryOld {
|
||||||
@GET("api/v1/meta")
|
@GET("api/v1/meta")
|
||||||
fun getGlobalMeta(): Flow<GlobalMeta>
|
fun getGlobalMeta(): Flow<GlobalMeta>
|
||||||
|
|
||||||
@@ -7,7 +7,7 @@
|
|||||||
package ca.gosyer.jui.domain.library.interactor
|
package ca.gosyer.jui.domain.library.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.ServerListeners
|
import ca.gosyer.jui.domain.ServerListeners
|
||||||
import ca.gosyer.jui.domain.library.service.LibraryRepository
|
import ca.gosyer.jui.domain.library.service.LibraryRepositoryOld
|
||||||
import ca.gosyer.jui.domain.manga.model.Manga
|
import ca.gosyer.jui.domain.manga.model.Manga
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.onEach
|
import kotlinx.coroutines.flow.onEach
|
||||||
@@ -18,7 +18,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class AddMangaToLibrary
|
class AddMangaToLibrary
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val libraryRepository: LibraryRepository,
|
private val libraryRepositoryOld: LibraryRepositoryOld,
|
||||||
private val serverListeners: ServerListeners,
|
private val serverListeners: ServerListeners,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
@@ -42,11 +42,11 @@ class AddMangaToLibrary
|
|||||||
.singleOrNull()
|
.singleOrNull()
|
||||||
|
|
||||||
fun asFlow(mangaId: Long) =
|
fun asFlow(mangaId: Long) =
|
||||||
libraryRepository.addMangaToLibrary(mangaId)
|
libraryRepositoryOld.addMangaToLibrary(mangaId)
|
||||||
.onEach { serverListeners.updateManga(mangaId) }
|
.onEach { serverListeners.updateManga(mangaId) }
|
||||||
|
|
||||||
fun asFlow(manga: Manga) =
|
fun asFlow(manga: Manga) =
|
||||||
libraryRepository.addMangaToLibrary(manga.id)
|
libraryRepositoryOld.addMangaToLibrary(manga.id)
|
||||||
.onEach { serverListeners.updateManga(manga.id) }
|
.onEach { serverListeners.updateManga(manga.id) }
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
|
|||||||
@@ -7,7 +7,7 @@
|
|||||||
package ca.gosyer.jui.domain.library.interactor
|
package ca.gosyer.jui.domain.library.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.ServerListeners
|
import ca.gosyer.jui.domain.ServerListeners
|
||||||
import ca.gosyer.jui.domain.library.service.LibraryRepository
|
import ca.gosyer.jui.domain.library.service.LibraryRepositoryOld
|
||||||
import ca.gosyer.jui.domain.manga.model.Manga
|
import ca.gosyer.jui.domain.manga.model.Manga
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.onEach
|
import kotlinx.coroutines.flow.onEach
|
||||||
@@ -18,7 +18,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class RemoveMangaFromLibrary
|
class RemoveMangaFromLibrary
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val libraryRepository: LibraryRepository,
|
private val libraryRepositoryOld: LibraryRepositoryOld,
|
||||||
private val serverListeners: ServerListeners,
|
private val serverListeners: ServerListeners,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
@@ -42,11 +42,11 @@ class RemoveMangaFromLibrary
|
|||||||
.singleOrNull()
|
.singleOrNull()
|
||||||
|
|
||||||
fun asFlow(mangaId: Long) =
|
fun asFlow(mangaId: Long) =
|
||||||
libraryRepository.removeMangaFromLibrary(mangaId)
|
libraryRepositoryOld.removeMangaFromLibrary(mangaId)
|
||||||
.onEach { serverListeners.updateManga(mangaId) }
|
.onEach { serverListeners.updateManga(mangaId) }
|
||||||
|
|
||||||
fun asFlow(manga: Manga) =
|
fun asFlow(manga: Manga) =
|
||||||
libraryRepository.removeMangaFromLibrary(manga.id)
|
libraryRepositoryOld.removeMangaFromLibrary(manga.id)
|
||||||
.onEach { serverListeners.updateManga(manga.id) }
|
.onEach { serverListeners.updateManga(manga.id) }
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
|
|||||||
@@ -12,7 +12,7 @@ import de.jensklingenberg.ktorfit.http.Path
|
|||||||
import io.ktor.client.statement.HttpResponse
|
import io.ktor.client.statement.HttpResponse
|
||||||
import kotlinx.coroutines.flow.Flow
|
import kotlinx.coroutines.flow.Flow
|
||||||
|
|
||||||
interface LibraryRepository {
|
interface LibraryRepositoryOld {
|
||||||
@GET("api/v1/manga/{mangaId}/library")
|
@GET("api/v1/manga/{mangaId}/library")
|
||||||
fun addMangaToLibrary(
|
fun addMangaToLibrary(
|
||||||
@Path("mangaId") mangaId: Long,
|
@Path("mangaId") mangaId: Long,
|
||||||
@@ -8,7 +8,7 @@ package ca.gosyer.jui.domain.manga.interactor
|
|||||||
|
|
||||||
import ca.gosyer.jui.domain.ServerListeners
|
import ca.gosyer.jui.domain.ServerListeners
|
||||||
import ca.gosyer.jui.domain.manga.model.Manga
|
import ca.gosyer.jui.domain.manga.model.Manga
|
||||||
import ca.gosyer.jui.domain.manga.service.MangaRepository
|
import ca.gosyer.jui.domain.manga.service.MangaRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.singleOrNull
|
import kotlinx.coroutines.flow.singleOrNull
|
||||||
import kotlinx.coroutines.flow.take
|
import kotlinx.coroutines.flow.take
|
||||||
@@ -18,7 +18,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class GetManga
|
class GetManga
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val mangaRepository: MangaRepository,
|
private val mangaRepositoryOld: MangaRepositoryOld,
|
||||||
private val serverListeners: ServerListeners,
|
private val serverListeners: ServerListeners,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
@@ -45,12 +45,12 @@ class GetManga
|
|||||||
|
|
||||||
fun asFlow(mangaId: Long) =
|
fun asFlow(mangaId: Long) =
|
||||||
serverListeners.combineMangaUpdates(
|
serverListeners.combineMangaUpdates(
|
||||||
mangaRepository.getManga(mangaId),
|
mangaRepositoryOld.getManga(mangaId),
|
||||||
) { mangaId in it }
|
) { mangaId in it }
|
||||||
|
|
||||||
fun asFlow(manga: Manga) =
|
fun asFlow(manga: Manga) =
|
||||||
serverListeners.combineMangaUpdates(
|
serverListeners.combineMangaUpdates(
|
||||||
mangaRepository.getManga(manga.id),
|
mangaRepositoryOld.getManga(manga.id),
|
||||||
) { manga.id in it }
|
) { manga.id in it }
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
|
|||||||
@@ -8,7 +8,7 @@ package ca.gosyer.jui.domain.manga.interactor
|
|||||||
|
|
||||||
import ca.gosyer.jui.domain.ServerListeners
|
import ca.gosyer.jui.domain.ServerListeners
|
||||||
import ca.gosyer.jui.domain.manga.model.Manga
|
import ca.gosyer.jui.domain.manga.model.Manga
|
||||||
import ca.gosyer.jui.domain.manga.service.MangaRepository
|
import ca.gosyer.jui.domain.manga.service.MangaRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.singleOrNull
|
import kotlinx.coroutines.flow.singleOrNull
|
||||||
import kotlinx.coroutines.flow.take
|
import kotlinx.coroutines.flow.take
|
||||||
@@ -18,7 +18,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class GetMangaFull
|
class GetMangaFull
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val mangaRepository: MangaRepository,
|
private val mangaRepositoryOld: MangaRepositoryOld,
|
||||||
private val serverListeners: ServerListeners,
|
private val serverListeners: ServerListeners,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
@@ -45,12 +45,12 @@ class GetMangaFull
|
|||||||
|
|
||||||
fun asFlow(mangaId: Long) =
|
fun asFlow(mangaId: Long) =
|
||||||
serverListeners.combineMangaUpdates(
|
serverListeners.combineMangaUpdates(
|
||||||
mangaRepository.getMangaFull(mangaId),
|
mangaRepositoryOld.getMangaFull(mangaId),
|
||||||
) { mangaId in it }
|
) { mangaId in it }
|
||||||
|
|
||||||
fun asFlow(manga: Manga) =
|
fun asFlow(manga: Manga) =
|
||||||
serverListeners.combineMangaUpdates(
|
serverListeners.combineMangaUpdates(
|
||||||
mangaRepository.getMangaFull(manga.id),
|
mangaRepositoryOld.getMangaFull(manga.id),
|
||||||
) { manga.id in it }
|
) { manga.id in it }
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
|
|||||||
@@ -8,7 +8,7 @@ package ca.gosyer.jui.domain.manga.interactor
|
|||||||
|
|
||||||
import ca.gosyer.jui.domain.ServerListeners
|
import ca.gosyer.jui.domain.ServerListeners
|
||||||
import ca.gosyer.jui.domain.manga.model.Manga
|
import ca.gosyer.jui.domain.manga.model.Manga
|
||||||
import ca.gosyer.jui.domain.manga.service.MangaRepository
|
import ca.gosyer.jui.domain.manga.service.MangaRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.onEach
|
import kotlinx.coroutines.flow.onEach
|
||||||
import kotlinx.coroutines.flow.singleOrNull
|
import kotlinx.coroutines.flow.singleOrNull
|
||||||
@@ -19,7 +19,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class RefreshManga
|
class RefreshManga
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val mangaRepository: MangaRepository,
|
private val mangaRepositoryOld: MangaRepositoryOld,
|
||||||
private val serverListeners: ServerListeners,
|
private val serverListeners: ServerListeners,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
@@ -44,9 +44,9 @@ class RefreshManga
|
|||||||
}
|
}
|
||||||
.singleOrNull()
|
.singleOrNull()
|
||||||
|
|
||||||
fun asFlow(mangaId: Long) = mangaRepository.getManga(mangaId, true).onEach { serverListeners.updateManga(mangaId) }
|
fun asFlow(mangaId: Long) = mangaRepositoryOld.getManga(mangaId, true).onEach { serverListeners.updateManga(mangaId) }
|
||||||
|
|
||||||
fun asFlow(manga: Manga) = mangaRepository.getManga(manga.id, true).onEach { serverListeners.updateManga(manga.id) }
|
fun asFlow(manga: Manga) = mangaRepositoryOld.getManga(manga.id, true).onEach { serverListeners.updateManga(manga.id) }
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -8,7 +8,7 @@ package ca.gosyer.jui.domain.manga.interactor
|
|||||||
|
|
||||||
import ca.gosyer.jui.domain.ServerListeners
|
import ca.gosyer.jui.domain.ServerListeners
|
||||||
import ca.gosyer.jui.domain.manga.model.Manga
|
import ca.gosyer.jui.domain.manga.model.Manga
|
||||||
import ca.gosyer.jui.domain.manga.service.MangaRepository
|
import ca.gosyer.jui.domain.manga.service.MangaRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.onEach
|
import kotlinx.coroutines.flow.onEach
|
||||||
import kotlinx.coroutines.flow.singleOrNull
|
import kotlinx.coroutines.flow.singleOrNull
|
||||||
@@ -19,7 +19,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class RefreshMangaFull
|
class RefreshMangaFull
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val mangaRepository: MangaRepository,
|
private val mangaRepositoryOld: MangaRepositoryOld,
|
||||||
private val serverListeners: ServerListeners,
|
private val serverListeners: ServerListeners,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
@@ -44,9 +44,9 @@ class RefreshMangaFull
|
|||||||
}
|
}
|
||||||
.singleOrNull()
|
.singleOrNull()
|
||||||
|
|
||||||
fun asFlow(mangaId: Long) = mangaRepository.getMangaFull(mangaId, true).onEach { serverListeners.updateManga(mangaId) }
|
fun asFlow(mangaId: Long) = mangaRepositoryOld.getMangaFull(mangaId, true).onEach { serverListeners.updateManga(mangaId) }
|
||||||
|
|
||||||
fun asFlow(manga: Manga) = mangaRepository.getMangaFull(manga.id, true).onEach { serverListeners.updateManga(manga.id) }
|
fun asFlow(manga: Manga) = mangaRepositoryOld.getMangaFull(manga.id, true).onEach { serverListeners.updateManga(manga.id) }
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -8,7 +8,7 @@ package ca.gosyer.jui.domain.manga.interactor
|
|||||||
|
|
||||||
import ca.gosyer.jui.domain.ServerListeners
|
import ca.gosyer.jui.domain.ServerListeners
|
||||||
import ca.gosyer.jui.domain.manga.model.Manga
|
import ca.gosyer.jui.domain.manga.model.Manga
|
||||||
import ca.gosyer.jui.domain.manga.service.MangaRepository
|
import ca.gosyer.jui.domain.manga.service.MangaRepositoryOld
|
||||||
import io.ktor.http.decodeURLQueryComponent
|
import io.ktor.http.decodeURLQueryComponent
|
||||||
import io.ktor.http.encodeURLQueryComponent
|
import io.ktor.http.encodeURLQueryComponent
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
@@ -20,7 +20,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class UpdateMangaMeta
|
class UpdateMangaMeta
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val mangaRepository: MangaRepository,
|
private val mangaRepositoryOld: MangaRepositoryOld,
|
||||||
private val serverListeners: ServerListeners,
|
private val serverListeners: ServerListeners,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
@@ -39,7 +39,7 @@ class UpdateMangaMeta
|
|||||||
readerMode: String = manga.meta.juiReaderMode.decodeURLQueryComponent(),
|
readerMode: String = manga.meta.juiReaderMode.decodeURLQueryComponent(),
|
||||||
) = flow {
|
) = flow {
|
||||||
if (readerMode.encodeURLQueryComponent() != manga.meta.juiReaderMode) {
|
if (readerMode.encodeURLQueryComponent() != manga.meta.juiReaderMode) {
|
||||||
mangaRepository.updateMangaMeta(
|
mangaRepositoryOld.updateMangaMeta(
|
||||||
manga.id,
|
manga.id,
|
||||||
"juiReaderMode",
|
"juiReaderMode",
|
||||||
readerMode,
|
readerMode,
|
||||||
|
|||||||
@@ -19,7 +19,7 @@ import io.ktor.client.statement.HttpResponse
|
|||||||
import io.ktor.utils.io.ByteReadChannel
|
import io.ktor.utils.io.ByteReadChannel
|
||||||
import kotlinx.coroutines.flow.Flow
|
import kotlinx.coroutines.flow.Flow
|
||||||
|
|
||||||
interface MangaRepository {
|
interface MangaRepositoryOld {
|
||||||
@GET("api/v1/manga/{mangaId}/")
|
@GET("api/v1/manga/{mangaId}/")
|
||||||
fun getManga(
|
fun getManga(
|
||||||
@Path("mangaId") mangaId: Long,
|
@Path("mangaId") mangaId: Long,
|
||||||
@@ -7,7 +7,7 @@
|
|||||||
package ca.gosyer.jui.domain.source.interactor
|
package ca.gosyer.jui.domain.source.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.source.model.Source
|
import ca.gosyer.jui.domain.source.model.Source
|
||||||
import ca.gosyer.jui.domain.source.service.SourceRepository
|
import ca.gosyer.jui.domain.source.service.SourceRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.singleOrNull
|
import kotlinx.coroutines.flow.singleOrNull
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -16,7 +16,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class GetFilterList
|
class GetFilterList
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val sourceRepository: SourceRepository,
|
private val sourceRepositoryOld: SourceRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
source: Source,
|
source: Source,
|
||||||
@@ -43,12 +43,12 @@ class GetFilterList
|
|||||||
fun asFlow(
|
fun asFlow(
|
||||||
source: Source,
|
source: Source,
|
||||||
reset: Boolean,
|
reset: Boolean,
|
||||||
) = sourceRepository.getFilterList(source.id, reset)
|
) = sourceRepositoryOld.getFilterList(source.id, reset)
|
||||||
|
|
||||||
fun asFlow(
|
fun asFlow(
|
||||||
sourceId: Long,
|
sourceId: Long,
|
||||||
reset: Boolean,
|
reset: Boolean,
|
||||||
) = sourceRepository.getFilterList(sourceId, reset)
|
) = sourceRepositoryOld.getFilterList(sourceId, reset)
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -7,7 +7,7 @@
|
|||||||
package ca.gosyer.jui.domain.source.interactor
|
package ca.gosyer.jui.domain.source.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.source.model.Source
|
import ca.gosyer.jui.domain.source.model.Source
|
||||||
import ca.gosyer.jui.domain.source.service.SourceRepository
|
import ca.gosyer.jui.domain.source.service.SourceRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.singleOrNull
|
import kotlinx.coroutines.flow.singleOrNull
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -16,7 +16,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class GetLatestManga
|
class GetLatestManga
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val sourceRepository: SourceRepository,
|
private val sourceRepositoryOld: SourceRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
source: Source,
|
source: Source,
|
||||||
@@ -43,12 +43,12 @@ class GetLatestManga
|
|||||||
fun asFlow(
|
fun asFlow(
|
||||||
source: Source,
|
source: Source,
|
||||||
page: Int,
|
page: Int,
|
||||||
) = sourceRepository.getLatestManga(source.id, page)
|
) = sourceRepositoryOld.getLatestManga(source.id, page)
|
||||||
|
|
||||||
fun asFlow(
|
fun asFlow(
|
||||||
sourceId: Long,
|
sourceId: Long,
|
||||||
page: Int,
|
page: Int,
|
||||||
) = sourceRepository.getLatestManga(sourceId, page)
|
) = sourceRepositoryOld.getLatestManga(sourceId, page)
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -7,7 +7,7 @@
|
|||||||
package ca.gosyer.jui.domain.source.interactor
|
package ca.gosyer.jui.domain.source.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.source.model.Source
|
import ca.gosyer.jui.domain.source.model.Source
|
||||||
import ca.gosyer.jui.domain.source.service.SourceRepository
|
import ca.gosyer.jui.domain.source.service.SourceRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.singleOrNull
|
import kotlinx.coroutines.flow.singleOrNull
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -16,7 +16,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class GetPopularManga
|
class GetPopularManga
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val sourceRepository: SourceRepository,
|
private val sourceRepositoryOld: SourceRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
source: Source,
|
source: Source,
|
||||||
@@ -43,12 +43,12 @@ class GetPopularManga
|
|||||||
fun asFlow(
|
fun asFlow(
|
||||||
source: Source,
|
source: Source,
|
||||||
page: Int,
|
page: Int,
|
||||||
) = sourceRepository.getPopularManga(source.id, page)
|
) = sourceRepositoryOld.getPopularManga(source.id, page)
|
||||||
|
|
||||||
fun asFlow(
|
fun asFlow(
|
||||||
sourceId: Long,
|
sourceId: Long,
|
||||||
page: Int,
|
page: Int,
|
||||||
) = sourceRepository.getPopularManga(sourceId, page)
|
) = sourceRepositoryOld.getPopularManga(sourceId, page)
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -9,7 +9,7 @@ package ca.gosyer.jui.domain.source.interactor
|
|||||||
import ca.gosyer.jui.domain.source.model.Source
|
import ca.gosyer.jui.domain.source.model.Source
|
||||||
import ca.gosyer.jui.domain.source.model.sourcefilters.SourceFilterChange
|
import ca.gosyer.jui.domain.source.model.sourcefilters.SourceFilterChange
|
||||||
import ca.gosyer.jui.domain.source.model.sourcefilters.SourceFilterData
|
import ca.gosyer.jui.domain.source.model.sourcefilters.SourceFilterData
|
||||||
import ca.gosyer.jui.domain.source.service.SourceRepository
|
import ca.gosyer.jui.domain.source.service.SourceRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.singleOrNull
|
import kotlinx.coroutines.flow.singleOrNull
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -18,7 +18,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class GetQuickSearchManga
|
class GetQuickSearchManga
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val sourceRepository: SourceRepository,
|
private val sourceRepositoryOld: SourceRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
source: Source,
|
source: Source,
|
||||||
@@ -51,7 +51,7 @@ class GetQuickSearchManga
|
|||||||
searchTerm: String?,
|
searchTerm: String?,
|
||||||
page: Int,
|
page: Int,
|
||||||
filters: List<SourceFilterChange>?,
|
filters: List<SourceFilterChange>?,
|
||||||
) = sourceRepository.getQuickSearchResults(
|
) = sourceRepositoryOld.getQuickSearchResults(
|
||||||
source.id,
|
source.id,
|
||||||
page,
|
page,
|
||||||
SourceFilterData(
|
SourceFilterData(
|
||||||
@@ -65,7 +65,7 @@ class GetQuickSearchManga
|
|||||||
searchTerm: String?,
|
searchTerm: String?,
|
||||||
page: Int,
|
page: Int,
|
||||||
filters: List<SourceFilterChange>?,
|
filters: List<SourceFilterChange>?,
|
||||||
) = sourceRepository.getQuickSearchResults(
|
) = sourceRepositoryOld.getQuickSearchResults(
|
||||||
sourceId,
|
sourceId,
|
||||||
page,
|
page,
|
||||||
SourceFilterData(
|
SourceFilterData(
|
||||||
|
|||||||
@@ -7,7 +7,7 @@
|
|||||||
package ca.gosyer.jui.domain.source.interactor
|
package ca.gosyer.jui.domain.source.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.source.model.Source
|
import ca.gosyer.jui.domain.source.model.Source
|
||||||
import ca.gosyer.jui.domain.source.service.SourceRepository
|
import ca.gosyer.jui.domain.source.service.SourceRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.singleOrNull
|
import kotlinx.coroutines.flow.singleOrNull
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -16,7 +16,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class GetSearchManga
|
class GetSearchManga
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val sourceRepository: SourceRepository,
|
private val sourceRepositoryOld: SourceRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
source: Source,
|
source: Source,
|
||||||
@@ -48,7 +48,7 @@ class GetSearchManga
|
|||||||
source: Source,
|
source: Source,
|
||||||
searchTerm: String?,
|
searchTerm: String?,
|
||||||
page: Int,
|
page: Int,
|
||||||
) = sourceRepository.getSearchResults(
|
) = sourceRepositoryOld.getSearchResults(
|
||||||
source.id,
|
source.id,
|
||||||
searchTerm?.ifBlank { null },
|
searchTerm?.ifBlank { null },
|
||||||
page,
|
page,
|
||||||
@@ -58,7 +58,7 @@ class GetSearchManga
|
|||||||
sourceId: Long,
|
sourceId: Long,
|
||||||
searchTerm: String?,
|
searchTerm: String?,
|
||||||
page: Int,
|
page: Int,
|
||||||
) = sourceRepository.getSearchResults(
|
) = sourceRepositoryOld.getSearchResults(
|
||||||
sourceId,
|
sourceId,
|
||||||
searchTerm?.ifBlank { null },
|
searchTerm?.ifBlank { null },
|
||||||
page,
|
page,
|
||||||
|
|||||||
@@ -6,7 +6,7 @@
|
|||||||
|
|
||||||
package ca.gosyer.jui.domain.source.interactor
|
package ca.gosyer.jui.domain.source.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.source.service.SourceRepository
|
import ca.gosyer.jui.domain.source.service.SourceRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.singleOrNull
|
import kotlinx.coroutines.flow.singleOrNull
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -15,7 +15,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class GetSourceList
|
class GetSourceList
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val sourceRepository: SourceRepository,
|
private val sourceRepositoryOld: SourceRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(onError: suspend (Throwable) -> Unit = {}) =
|
suspend fun await(onError: suspend (Throwable) -> Unit = {}) =
|
||||||
asFlow()
|
asFlow()
|
||||||
@@ -25,7 +25,7 @@ class GetSourceList
|
|||||||
}
|
}
|
||||||
.singleOrNull()
|
.singleOrNull()
|
||||||
|
|
||||||
fun asFlow() = sourceRepository.getSourceList()
|
fun asFlow() = sourceRepositoryOld.getSourceList()
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -7,7 +7,7 @@
|
|||||||
package ca.gosyer.jui.domain.source.interactor
|
package ca.gosyer.jui.domain.source.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.source.model.Source
|
import ca.gosyer.jui.domain.source.model.Source
|
||||||
import ca.gosyer.jui.domain.source.service.SourceRepository
|
import ca.gosyer.jui.domain.source.service.SourceRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.singleOrNull
|
import kotlinx.coroutines.flow.singleOrNull
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -16,7 +16,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class GetSourceSettings
|
class GetSourceSettings
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val sourceRepository: SourceRepository,
|
private val sourceRepositoryOld: SourceRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
source: Source,
|
source: Source,
|
||||||
@@ -38,9 +38,9 @@ class GetSourceSettings
|
|||||||
}
|
}
|
||||||
.singleOrNull()
|
.singleOrNull()
|
||||||
|
|
||||||
fun asFlow(source: Source) = sourceRepository.getSourceSettings(source.id)
|
fun asFlow(source: Source) = sourceRepositoryOld.getSourceSettings(source.id)
|
||||||
|
|
||||||
fun asFlow(sourceId: Long) = sourceRepository.getSourceSettings(sourceId)
|
fun asFlow(sourceId: Long) = sourceRepositoryOld.getSourceSettings(sourceId)
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -8,7 +8,7 @@ package ca.gosyer.jui.domain.source.interactor
|
|||||||
|
|
||||||
import ca.gosyer.jui.domain.source.model.Source
|
import ca.gosyer.jui.domain.source.model.Source
|
||||||
import ca.gosyer.jui.domain.source.model.sourcefilters.SourceFilterChange
|
import ca.gosyer.jui.domain.source.model.sourcefilters.SourceFilterChange
|
||||||
import ca.gosyer.jui.domain.source.service.SourceRepository
|
import ca.gosyer.jui.domain.source.service.SourceRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
import kotlinx.serialization.encodeToString
|
import kotlinx.serialization.encodeToString
|
||||||
@@ -19,7 +19,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class SetSourceFilter
|
class SetSourceFilter
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val sourceRepository: SourceRepository,
|
private val sourceRepositoryOld: SourceRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
source: Source,
|
source: Source,
|
||||||
@@ -85,7 +85,7 @@ class SetSourceFilter
|
|||||||
source: Source,
|
source: Source,
|
||||||
filterIndex: Int,
|
filterIndex: Int,
|
||||||
filter: Any,
|
filter: Any,
|
||||||
) = sourceRepository.setFilter(
|
) = sourceRepositoryOld.setFilter(
|
||||||
source.id,
|
source.id,
|
||||||
SourceFilterChange(filterIndex, filter),
|
SourceFilterChange(filterIndex, filter),
|
||||||
)
|
)
|
||||||
@@ -94,7 +94,7 @@ class SetSourceFilter
|
|||||||
sourceId: Long,
|
sourceId: Long,
|
||||||
filterIndex: Int,
|
filterIndex: Int,
|
||||||
filter: Any,
|
filter: Any,
|
||||||
) = sourceRepository.setFilter(
|
) = sourceRepositoryOld.setFilter(
|
||||||
sourceId,
|
sourceId,
|
||||||
SourceFilterChange(filterIndex, filter),
|
SourceFilterChange(filterIndex, filter),
|
||||||
)
|
)
|
||||||
@@ -104,7 +104,7 @@ class SetSourceFilter
|
|||||||
filterIndex: Int,
|
filterIndex: Int,
|
||||||
childFilterIndex: Int,
|
childFilterIndex: Int,
|
||||||
filter: Any,
|
filter: Any,
|
||||||
) = sourceRepository.setFilter(
|
) = sourceRepositoryOld.setFilter(
|
||||||
source.id,
|
source.id,
|
||||||
SourceFilterChange(filterIndex, Json.encodeToString(SourceFilterChange(childFilterIndex, filter))),
|
SourceFilterChange(filterIndex, Json.encodeToString(SourceFilterChange(childFilterIndex, filter))),
|
||||||
)
|
)
|
||||||
@@ -114,7 +114,7 @@ class SetSourceFilter
|
|||||||
filterIndex: Int,
|
filterIndex: Int,
|
||||||
childFilterIndex: Int,
|
childFilterIndex: Int,
|
||||||
filter: Any,
|
filter: Any,
|
||||||
) = sourceRepository.setFilter(
|
) = sourceRepositoryOld.setFilter(
|
||||||
sourceId,
|
sourceId,
|
||||||
SourceFilterChange(filterIndex, Json.encodeToString(SourceFilterChange(childFilterIndex, filter))),
|
SourceFilterChange(filterIndex, Json.encodeToString(SourceFilterChange(childFilterIndex, filter))),
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -8,7 +8,7 @@ package ca.gosyer.jui.domain.source.interactor
|
|||||||
|
|
||||||
import ca.gosyer.jui.domain.source.model.Source
|
import ca.gosyer.jui.domain.source.model.Source
|
||||||
import ca.gosyer.jui.domain.source.model.sourcepreference.SourcePreferenceChange
|
import ca.gosyer.jui.domain.source.model.sourcepreference.SourcePreferenceChange
|
||||||
import ca.gosyer.jui.domain.source.service.SourceRepository
|
import ca.gosyer.jui.domain.source.service.SourceRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -17,7 +17,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class SetSourceSetting
|
class SetSourceSetting
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val sourceRepository: SourceRepository,
|
private val sourceRepositoryOld: SourceRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
source: Source,
|
source: Source,
|
||||||
@@ -49,7 +49,7 @@ class SetSourceSetting
|
|||||||
source: Source,
|
source: Source,
|
||||||
settingIndex: Int,
|
settingIndex: Int,
|
||||||
setting: Any,
|
setting: Any,
|
||||||
) = sourceRepository.setSourceSetting(
|
) = sourceRepositoryOld.setSourceSetting(
|
||||||
source.id,
|
source.id,
|
||||||
SourcePreferenceChange(settingIndex, setting),
|
SourcePreferenceChange(settingIndex, setting),
|
||||||
)
|
)
|
||||||
@@ -58,7 +58,7 @@ class SetSourceSetting
|
|||||||
sourceId: Long,
|
sourceId: Long,
|
||||||
settingIndex: Int,
|
settingIndex: Int,
|
||||||
setting: Any,
|
setting: Any,
|
||||||
) = sourceRepository.setSourceSetting(
|
) = sourceRepositoryOld.setSourceSetting(
|
||||||
sourceId,
|
sourceId,
|
||||||
SourcePreferenceChange(settingIndex, setting),
|
SourcePreferenceChange(settingIndex, setting),
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -22,7 +22,7 @@ import de.jensklingenberg.ktorfit.http.Query
|
|||||||
import io.ktor.client.statement.HttpResponse
|
import io.ktor.client.statement.HttpResponse
|
||||||
import kotlinx.coroutines.flow.Flow
|
import kotlinx.coroutines.flow.Flow
|
||||||
|
|
||||||
interface SourceRepository {
|
interface SourceRepositoryOld {
|
||||||
@GET("api/v1/source/list")
|
@GET("api/v1/source/list")
|
||||||
fun getSourceList(): Flow<List<Source>>
|
fun getSourceList(): Flow<List<Source>>
|
||||||
|
|
||||||
@@ -6,7 +6,7 @@
|
|||||||
|
|
||||||
package ca.gosyer.jui.domain.updates.interactor
|
package ca.gosyer.jui.domain.updates.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.updates.service.UpdatesRepository
|
import ca.gosyer.jui.domain.updates.service.UpdatesRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.singleOrNull
|
import kotlinx.coroutines.flow.singleOrNull
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -15,7 +15,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class GetRecentUpdates
|
class GetRecentUpdates
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val updatesRepository: UpdatesRepository,
|
private val updatesRepositoryOld: UpdatesRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
pageNum: Int,
|
pageNum: Int,
|
||||||
@@ -27,7 +27,7 @@ class GetRecentUpdates
|
|||||||
}
|
}
|
||||||
.singleOrNull()
|
.singleOrNull()
|
||||||
|
|
||||||
fun asFlow(pageNum: Int) = updatesRepository.getRecentUpdates(pageNum)
|
fun asFlow(pageNum: Int) = updatesRepositoryOld.getRecentUpdates(pageNum)
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -7,7 +7,7 @@
|
|||||||
package ca.gosyer.jui.domain.updates.interactor
|
package ca.gosyer.jui.domain.updates.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.category.model.Category
|
import ca.gosyer.jui.domain.category.model.Category
|
||||||
import ca.gosyer.jui.domain.updates.service.UpdatesRepository
|
import ca.gosyer.jui.domain.updates.service.UpdatesRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -16,7 +16,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class UpdateCategory
|
class UpdateCategory
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val updatesRepository: UpdatesRepository,
|
private val updatesRepositoryOld: UpdatesRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(
|
suspend fun await(
|
||||||
categoryId: Long,
|
categoryId: Long,
|
||||||
@@ -38,9 +38,9 @@ class UpdateCategory
|
|||||||
}
|
}
|
||||||
.collect()
|
.collect()
|
||||||
|
|
||||||
fun asFlow(categoryId: Long) = updatesRepository.updateCategory(categoryId)
|
fun asFlow(categoryId: Long) = updatesRepositoryOld.updateCategory(categoryId)
|
||||||
|
|
||||||
fun asFlow(category: Category) = updatesRepository.updateCategory(category.id)
|
fun asFlow(category: Category) = updatesRepositoryOld.updateCategory(category.id)
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -6,7 +6,7 @@
|
|||||||
|
|
||||||
package ca.gosyer.jui.domain.updates.interactor
|
package ca.gosyer.jui.domain.updates.interactor
|
||||||
|
|
||||||
import ca.gosyer.jui.domain.updates.service.UpdatesRepository
|
import ca.gosyer.jui.domain.updates.service.UpdatesRepositoryOld
|
||||||
import kotlinx.coroutines.flow.catch
|
import kotlinx.coroutines.flow.catch
|
||||||
import kotlinx.coroutines.flow.collect
|
import kotlinx.coroutines.flow.collect
|
||||||
import me.tatarka.inject.annotations.Inject
|
import me.tatarka.inject.annotations.Inject
|
||||||
@@ -15,7 +15,7 @@ import org.lighthousegames.logging.logging
|
|||||||
class UpdateLibrary
|
class UpdateLibrary
|
||||||
@Inject
|
@Inject
|
||||||
constructor(
|
constructor(
|
||||||
private val updatesRepository: UpdatesRepository,
|
private val updatesRepositoryOld: UpdatesRepositoryOld,
|
||||||
) {
|
) {
|
||||||
suspend fun await(onError: suspend (Throwable) -> Unit = {}) =
|
suspend fun await(onError: suspend (Throwable) -> Unit = {}) =
|
||||||
asFlow()
|
asFlow()
|
||||||
@@ -25,7 +25,7 @@ class UpdateLibrary
|
|||||||
}
|
}
|
||||||
.collect()
|
.collect()
|
||||||
|
|
||||||
fun asFlow() = updatesRepository.updateLibrary()
|
fun asFlow() = updatesRepositoryOld.updateLibrary()
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = logging()
|
private val log = logging()
|
||||||
|
|||||||
@@ -15,7 +15,7 @@ import de.jensklingenberg.ktorfit.http.Path
|
|||||||
import io.ktor.client.statement.HttpResponse
|
import io.ktor.client.statement.HttpResponse
|
||||||
import kotlinx.coroutines.flow.Flow
|
import kotlinx.coroutines.flow.Flow
|
||||||
|
|
||||||
interface UpdatesRepository {
|
interface UpdatesRepositoryOld {
|
||||||
@GET("api/v1/update/recentChapters/{pageNum}/")
|
@GET("api/v1/update/recentChapters/{pageNum}/")
|
||||||
fun getRecentUpdates(
|
fun getRecentUpdates(
|
||||||
@Path("pageNum") pageNum: Int,
|
@Path("pageNum") pageNum: Int,
|
||||||
Reference in New Issue
Block a user