Extract legacy import for database

Faltenreich · Nov 24, 2024 · 631f1ec · 631f1ec
1 parent e78b2a4
commit 631f1ec
Show file tree

Hide file tree

Showing 3 changed files with 91 additions and 79 deletions.
diff --git a/...c/commonMain/kotlin/com/faltenreich/diaguard/backup/legacy/ImportLegacyDatabaseUseCase.kt b/...c/commonMain/kotlin/com/faltenreich/diaguard/backup/legacy/ImportLegacyDatabaseUseCase.kt
@@ -0,0 +1,87 @@
+package com.faltenreich.diaguard.backup.legacy
+
+import com.faltenreich.diaguard.entry.EntryRepository
+import com.faltenreich.diaguard.entry.tag.EntryTagRepository
+import com.faltenreich.diaguard.food.FoodRepository
+import com.faltenreich.diaguard.food.eaten.FoodEatenRepository
+import com.faltenreich.diaguard.measurement.property.MeasurementPropertyRepository
+import com.faltenreich.diaguard.measurement.value.MeasurementValueRepository
+import com.faltenreich.diaguard.shared.database.DatabaseKey
+import com.faltenreich.diaguard.shared.logging.Logger
+import com.faltenreich.diaguard.tag.TagRepository
+
+class ImportLegacyDatabaseUseCase(
+    private val legacyRepository: LegacyRepository,
+    private val entryRepository: EntryRepository,
+    private val propertyRepository: MeasurementPropertyRepository,
+    private val valueRepository: MeasurementValueRepository,
+    private val foodRepository: FoodRepository,
+    private val foodEatenRepository: FoodEatenRepository,
+    private val tagRepository: TagRepository,
+    private val entryTagRepository: EntryTagRepository,
+) {
+
+    suspend operator fun invoke() {
+
+        val properties = propertyRepository.getAll()
+
+        val entries = legacyRepository.getEntries().associateWith { legacy ->
+            val id = entryRepository.create(legacy)
+            checkNotNull(entryRepository.getById(id))
+        }
+        Logger.info("Imported ${entries.size} entries from legacy")
+
+        val food = legacyRepository.getFood().associateWith { legacy ->
+            // TODO: Skip redundant food by uuid/serverId
+            val id = foodRepository.create(legacy)
+            checkNotNull(foodRepository.getById(id))
+        }
+        Logger.info("Imported ${food.size} food from legacy")
+
+        val tags = legacyRepository.getTags().associateWith { legacy ->
+            val id = tagRepository.create(legacy)
+            checkNotNull(tagRepository.getById(id))
+        }
+        Logger.info("Imported ${tags.size} tags from legacy")
+
+        val values = legacyRepository.getMeasurementValues()
+        values.forEach { legacy ->
+            legacy.property = properties.firstOrNull {
+                it.key == legacy.propertyKey
+            } ?: error("No property found for key ${legacy.propertyKey}")
+            legacy.entry = entries.entries.firstOrNull {
+                it.key.id == legacy.entryId
+            }?.value ?: error("No entry found for id ${legacy.entryId}")
+            valueRepository.create(legacy)
+        }
+        Logger.info("Imported ${values.size} values from legacy")
+
+        val foodEaten = legacyRepository.getFoodEaten()
+        foodEaten.forEach { legacy ->
+            legacy.food = food.entries.firstOrNull {
+                it.key.id == legacy.foodId
+            }?.value ?: error("No food found for id ${legacy.foodId}")
+            legacy.entry = entries.entries.firstOrNull { entry ->
+                // FIXME: Null due to skipped values with value of zero
+                val value = values.firstOrNull {
+                    it.propertyKey == DatabaseKey.MeasurementProperty.MEAL && it.id == legacy.mealId
+                } ?: error("No meal value found with mealId ${legacy.mealId}")
+                entry.key.id == value.entryId
+            }?.value ?: error("No entry found for mealId ${legacy.mealId}")
+            foodEatenRepository.create(legacy)
+        }
+        Logger.info("Imported ${foodEaten.size} food eaten from legacy")
+
+        val entryTags = legacyRepository.getEntryTags()
+        entryTags.forEach { legacy ->
+            legacy.entry = entries.entries.firstOrNull {
+                it.key.id == legacy.entryId
+            }?.value ?: error("No entry found for id ${legacy.entryId}")
+            legacy.tag = tags.entries.firstOrNull {
+                it.key.id == legacy.entryId
+            }?.value ?: error("No tag found for id ${legacy.tagId}")
+            entryTagRepository.create(legacy)
+        }
+        Logger.info("Imported ${entryTags.size} entry tags from legacy")
+    }
+}
diff --git a/shared/src/commonMain/kotlin/com/faltenreich/diaguard/backup/legacy/ImportLegacyUseCase.kt b/shared/src/commonMain/kotlin/com/faltenreich/diaguard/backup/legacy/ImportLegacyUseCase.kt
@@ -1,90 +1,14 @@
 package com.faltenreich.diaguard.backup.legacy
 
-import com.faltenreich.diaguard.entry.EntryRepository
-import com.faltenreich.diaguard.entry.tag.EntryTagRepository
-import com.faltenreich.diaguard.food.FoodRepository
-import com.faltenreich.diaguard.food.eaten.FoodEatenRepository
-import com.faltenreich.diaguard.measurement.property.MeasurementPropertyRepository
-import com.faltenreich.diaguard.measurement.value.MeasurementValueRepository
-import com.faltenreich.diaguard.shared.database.DatabaseKey
-import com.faltenreich.diaguard.shared.logging.Logger
-import com.faltenreich.diaguard.tag.TagRepository
-
 class ImportLegacyUseCase(
     private val importPreferences: ImportLegacyPreferencesUseCase,
-    private val legacyRepository: LegacyRepository,
-    private val entryRepository: EntryRepository,
-    private val propertyRepository: MeasurementPropertyRepository,
-    private val valueRepository: MeasurementValueRepository,
-    private val foodRepository: FoodRepository,
-    private val foodEatenRepository: FoodEatenRepository,
-    private val tagRepository: TagRepository,
-    private val entryTagRepository: EntryTagRepository,
+    private val importDatabase: ImportLegacyDatabaseUseCase,
 ) {
 
     suspend operator fun invoke() {
         importPreferences()
+        // TODO: Re-enable
         return
-
-        val properties = propertyRepository.getAll()
-
-        val entries = legacyRepository.getEntries().associateWith { legacy ->
-            val id = entryRepository.create(legacy)
-            checkNotNull(entryRepository.getById(id))
-        }
-        Logger.info("Imported ${entries.size} entries from legacy")
-
-        val food = legacyRepository.getFood().associateWith { legacy ->
-            // TODO: Skip redundant food by uuid/serverId
-            val id = foodRepository.create(legacy)
-            checkNotNull(foodRepository.getById(id))
-        }
-        Logger.info("Imported ${food.size} food from legacy")
-
-        val tags = legacyRepository.getTags().associateWith { legacy ->
-            val id = tagRepository.create(legacy)
-            checkNotNull(tagRepository.getById(id))
-        }
-        Logger.info("Imported ${tags.size} tags from legacy")
-
-        val values = legacyRepository.getMeasurementValues()
-        values.forEach { legacy ->
-            legacy.property = properties.firstOrNull {
-                it.key == legacy.propertyKey
-            } ?: error("No property found for key ${legacy.propertyKey}")
-            legacy.entry = entries.entries.firstOrNull {
-                it.key.id == legacy.entryId
-            }?.value ?: error("No entry found for id ${legacy.entryId}")
-            valueRepository.create(legacy)
-        }
-        Logger.info("Imported ${values.size} values from legacy")
-
-        val foodEaten = legacyRepository.getFoodEaten()
-        foodEaten.forEach { legacy ->
-            legacy.food = food.entries.firstOrNull {
-                it.key.id == legacy.foodId
-            }?.value ?: error("No food found for id ${legacy.foodId}")
-            legacy.entry = entries.entries.firstOrNull { entry ->
-                // FIXME: Null due to skipped values with value of zero
-                val value = values.firstOrNull {
-                    it.propertyKey == DatabaseKey.MeasurementProperty.MEAL && it.id == legacy.mealId
-                } ?: error("No meal value found with mealId ${legacy.mealId}")
-                entry.key.id == value.entryId
-            }?.value ?: error("No entry found for mealId ${legacy.mealId}")
-            foodEatenRepository.create(legacy)
-        }
-        Logger.info("Imported ${foodEaten.size} food eaten from legacy")
-
-        val entryTags = legacyRepository.getEntryTags()
-        entryTags.forEach { legacy ->
-            legacy.entry = entries.entries.firstOrNull {
-                it.key.id == legacy.entryId
-            }?.value ?: error("No entry found for id ${legacy.entryId}")
-            legacy.tag = tags.entries.firstOrNull {
-                it.key.id == legacy.entryId
-            }?.value ?: error("No tag found for id ${legacy.tagId}")
-            entryTagRepository.create(legacy)
-        }
-        Logger.info("Imported ${entryTags.size} entry tags from legacy")
+        importDatabase()
     }
 }
diff --git a/shared/src/commonMain/kotlin/com/faltenreich/diaguard/backup/legacy/LegacyModule.kt b/shared/src/commonMain/kotlin/com/faltenreich/diaguard/backup/legacy/LegacyModule.kt
@@ -19,5 +19,6 @@ fun legacyModule() = module {
     factoryOf(::LegacyRepository)
 
     factoryOf(::ImportLegacyPreferencesUseCase)
+    factoryOf(::ImportLegacyDatabaseUseCase)
     factoryOf(::ImportLegacyUseCase)
 }