diff options
author | Dico <dico.karssiens@gmail.com> | 2018-08-04 00:13:09 +0100 |
---|---|---|
committer | Dico <dico.karssiens@gmail.com> | 2018-08-04 00:13:09 +0100 |
commit | 3573f9ade67010e3e538151375faecbec32825c4 (patch) | |
tree | fd838b5d2a333730e62d4ae0ebf452dba5822696 /src/main/kotlin/io/dico/parcels2/defaultimpl/ParcelProviderImpl.kt | |
parent | 703e02d6b23165003835692b0213a20f0a627e9d (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.kt | 16 |
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() } |