caspervk/AndroidAPS
1
0
Fork 0
Code Releases Activity

NSCv3: log upload

Browse source
This commit is contained in:
Milos Kozak 2023-01-05 20:51:44 +01:00
parent c25c9cedbf
commit c1c46939ba
3 changed files with 14 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
plugins/sync/src/main/java/info/nightscout/plugins/sync/nsShared/DataSyncSelectorImplementation.kt
View file

@ -20,7 +20,7 @@ class DataSyncSelectorImplementation @Inject constructor(
private val dateUtil: DateUtil,
private val profileFunction: ProfileFunction,
private val activePlugin: ActivePlugin,
private val appRepository: AppRepository,
private val appRepository: AppRepository
) : DataSyncSelector {
class QueueCounter(

11
plugins/sync/src/main/java/info/nightscout/plugins/sync/nsclientV3/workers/DataSyncWorker.kt
View file

@ -6,6 +6,9 @@ import info.nightscout.androidaps.annotations.OpenForTesting
import info.nightscout.core.utils.worker.LoggingWorker
import info.nightscout.interfaces.plugin.ActivePlugin
import info.nightscout.interfaces.sync.DataSyncSelector
import info.nightscout.plugins.sync.nsShared.events.EventNSClientUpdateGUI
import info.nightscout.rx.bus.RxBus
import info.nightscout.rx.events.EventNSClientNewLog
import javax.inject.Inject
@OpenForTesting
@ -15,9 +18,15 @@ class DataSyncWorker(
@Inject lateinit var dataSyncSelector: DataSyncSelector
@Inject lateinit var activePlugin: ActivePlugin
@Inject lateinit var rxBus: RxBus
override fun doWorkAndLog(): Result {
if (activePlugin.activeNsClient?.hasWritePermission == true) dataSyncSelector.doUpload()
if (activePlugin.activeNsClient?.hasWritePermission == true) {
rxBus.send(EventNSClientNewLog("UPL", "Start"))
dataSyncSelector.doUpload()
rxBus.send(EventNSClientNewLog("UPL", "End"))
}
rxBus.send(EventNSClientUpdateGUI())
return Result.success()
}
}

3
plugins/sync/src/test/java/info/nightscout/plugins/sync/nsclientV3/workers/DataSyncWorkerTest.kt
View file

@ -10,6 +10,7 @@ import info.nightscout.core.utils.fabric.FabricPrivacy
import info.nightscout.interfaces.plugin.ActivePlugin
import info.nightscout.interfaces.sync.DataSyncSelector
import info.nightscout.interfaces.sync.NsClient
import info.nightscout.rx.bus.RxBus
import org.junit.jupiter.api.Assertions
import org.junit.jupiter.api.BeforeEach
import org.junit.jupiter.api.Test
@ -26,6 +27,7 @@ internal class DataSyncWorkerTest : TestBase() {
@Mock lateinit var context: ContextWithInjector
@Mock lateinit var activePlugin: ActivePlugin
@Mock lateinit var nsClient: NsClient
@Mock lateinit var rxBus: RxBus
private lateinit var sut: DataSyncWorker
@ -36,6 +38,7 @@ internal class DataSyncWorkerTest : TestBase() {
it.fabricPrivacy = fabricPrivacy
it.dataSyncSelector = dataSyncSelector
it.activePlugin = activePlugin
it.rxBus = rxBus
}
}
}