Move more things around

data/src/main/java/tachiyomi/data/chapter/ChapterRepositoryImpl.kt

@@ -1,9 +1,9 @@
 package tachiyomi.data.chapter
 
-import eu.kanade.tachiyomi.util.system.logcat
-import eu.kanade.tachiyomi.util.toLong
 import kotlinx.coroutines.flow.Flow
 import logcat.LogPriority
+import tachiyomi.core.util.lang.toLong
+import tachiyomi.core.util.system.logcat
 import tachiyomi.data.DatabaseHandler
 import tachiyomi.domain.chapter.model.Chapter
 import tachiyomi.domain.chapter.model.ChapterUpdate

data/src/main/java/tachiyomi/data/history/HistoryRepositoryImpl.kt

@@ -1,8 +1,8 @@
 package tachiyomi.data.history
 
-import eu.kanade.tachiyomi.util.system.logcat
 import kotlinx.coroutines.flow.Flow
 import logcat.LogPriority
+import tachiyomi.core.util.system.logcat
 import tachiyomi.data.DatabaseHandler
 import tachiyomi.domain.history.model.HistoryUpdate
 import tachiyomi.domain.history.model.HistoryWithRelations

data/src/main/java/tachiyomi/data/manga/MangaRepositoryImpl.kt

@@ -1,9 +1,9 @@
 package tachiyomi.data.manga
 
-import eu.kanade.tachiyomi.util.system.logcat
-import eu.kanade.tachiyomi.util.toLong
 import kotlinx.coroutines.flow.Flow
 import logcat.LogPriority
+import tachiyomi.core.util.lang.toLong
+import tachiyomi.core.util.system.logcat
 import tachiyomi.data.DatabaseHandler
 import tachiyomi.data.listOfStringsAdapter
 import tachiyomi.data.updateStrategyAdapter

data/src/main/java/tachiyomi/data/source/SourceDataRepositoryImpl.kt

@@ -0,0 +1,23 @@
+package tachiyomi.data.source
+
+import kotlinx.coroutines.flow.Flow
+import tachiyomi.data.DatabaseHandler
+import tachiyomi.domain.source.model.SourceData
+import tachiyomi.domain.source.repository.SourceDataRepository
+
+class SourceDataRepositoryImpl(
+    private val handler: DatabaseHandler,
+) : SourceDataRepository {
+
+    override fun subscribeAll(): Flow<List<SourceData>> {
+        return handler.subscribeToList { sourcesQueries.findAll(sourceDataMapper) }
+    }
+
+    override suspend fun getSourceData(id: Long): SourceData? {
+        return handler.awaitOneOrNull { sourcesQueries.findOne(id, sourceDataMapper) }
+    }
+
+    override suspend fun upsertSourceData(id: Long, lang: String, name: String) {
+        handler.await { sourcesQueries.upsert(id, lang, name) }
+    }
+}

data/src/main/java/tachiyomi/data/source/SourceMapper.kt

@@ -0,0 +1,7 @@
+package tachiyomi.data.source
+
+import tachiyomi.domain.source.model.SourceData
+
+val sourceDataMapper: (Long, String, String) -> SourceData = { id, lang, name ->
+    SourceData(id, lang, name)
+}