summaryrefslogtreecommitdiff
path: root/src/main/kotlin/io/dico/parcels2/defaultimpl/ParcelProviderImpl.kt
diff options
context:
space:
mode:
authorDico <dico.karssiens@gmail.com>2018-08-04 00:13:09 +0100
committerDico <dico.karssiens@gmail.com>2018-08-04 00:13:09 +0100
commit3573f9ade67010e3e538151375faecbec32825c4 (patch)
treefd838b5d2a333730e62d4ae0ebf452dba5822696 /src/main/kotlin/io/dico/parcels2/defaultimpl/ParcelProviderImpl.kt
parent703e02d6b23165003835692b0213a20f0a627e9d (diff)
work on plotme migration
Diffstat (limited to 'src/main/kotlin/io/dico/parcels2/defaultimpl/ParcelProviderImpl.kt')
-rw-r--r--src/main/kotlin/io/dico/parcels2/defaultimpl/ParcelProviderImpl.kt16
1 files changed, 16 insertions, 0 deletions
diff --git a/src/main/kotlin/io/dico/parcels2/defaultimpl/ParcelProviderImpl.kt b/src/main/kotlin/io/dico/parcels2/defaultimpl/ParcelProviderImpl.kt
index 569d18f..f7abccd 100644
--- a/src/main/kotlin/io/dico/parcels2/defaultimpl/ParcelProviderImpl.kt
+++ b/src/main/kotlin/io/dico/parcels2/defaultimpl/ParcelProviderImpl.kt
@@ -60,6 +60,21 @@ class ParcelProviderImpl(val plugin: ParcelsPlugin) : ParcelProvider {
private fun loadStoredData() {
plugin.functionHelper.launchLazilyOnMainThread {
+ val migration = plugin.options.migration
+ if (migration.enabled) {
+ migration.instance?.newInstance()?.apply {
+ logger.warn("Migrating database now...")
+ migrateTo(plugin.storage).join()
+ logger.warn("Migration completed")
+
+ if (migration.disableWhenComplete) {
+ migration.enabled = false
+ plugin.saveOptions()
+ }
+ }
+ }
+
+ logger.info("Loading all parcel data...")
val channel = plugin.storage.readAllParcelData()
do {
val pair = channel.receiveOrNull() ?: break
@@ -67,6 +82,7 @@ class ParcelProviderImpl(val plugin: ParcelsPlugin) : ParcelProvider {
pair.second?.let { parcel.copyDataIgnoringDatabase(it) }
} while (true)
+ logger.info("Loading data completed")
_dataIsLoaded = true
}.start()
}