caspervk/AndroidAPS
1
0
Fork 0
Code Releases Activity

NSC: improve profile sync

Browse source
This commit is contained in:
Milos Kozak 2023-09-14 20:20:08 +02:00
parent d2247dc9bc
commit 471ed28a04
2 changed files with 9 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
plugins/sync/src/main/java/info/nightscout/plugins/sync/nsclient/services/NSClientService.kt
View file

@ -199,6 +199,10 @@ import javax.inject.Inject
.toObservable(EventOfflineChange::class.java) .toObservable(EventOfflineChange::class.java)
.observeOn(aapsSchedulers.io) .observeOn(aapsSchedulers.io)
.subscribe({ resend("EventOfflineChange") }, fabricPrivacy::logException) .subscribe({ resend("EventOfflineChange") }, fabricPrivacy::logException)
disposable += rxBus
.toObservable(EventProfileStoreChanged::class.java)
.observeOn(aapsSchedulers.io)
.subscribe({ resend("EventProfileStoreChanged") }, fabricPrivacy::logException)
} }
override fun onDestroy() { override fun onDestroy() {

5
plugins/sync/src/main/java/info/nightscout/plugins/sync/nsclientV3/NSClientV3Plugin.kt
View file

@ -72,6 +72,7 @@ import info.nightscout.rx.events.EventNSClientNewLog
import info.nightscout.rx.events.EventNewHistoryData import info.nightscout.rx.events.EventNewHistoryData
import info.nightscout.rx.events.EventOfflineChange import info.nightscout.rx.events.EventOfflineChange
import info.nightscout.rx.events.EventPreferenceChange import info.nightscout.rx.events.EventPreferenceChange
import info.nightscout.rx.events.EventProfileStoreChanged
import info.nightscout.rx.events.EventProfileSwitchChanged import info.nightscout.rx.events.EventProfileSwitchChanged
import info.nightscout.rx.events.EventSWSyncStatus import info.nightscout.rx.events.EventSWSyncStatus
import info.nightscout.rx.events.EventTempTargetChange import info.nightscout.rx.events.EventTempTargetChange
@ -250,6 +251,10 @@ class NSClientV3Plugin @Inject constructor(
.toObservable(EventOfflineChange::class.java) .toObservable(EventOfflineChange::class.java)
.observeOn(aapsSchedulers.io) .observeOn(aapsSchedulers.io)
.subscribe({ executeUpload("EventOfflineChange", forceNew = false) }, fabricPrivacy::logException) .subscribe({ executeUpload("EventOfflineChange", forceNew = false) }, fabricPrivacy::logException)
disposable += rxBus
.toObservable(EventProfileStoreChanged::class.java)
.observeOn(aapsSchedulers.io)
.subscribe({ executeUpload("EventProfileStoreChanged", forceNew = false) }, fabricPrivacy::logException)
runLoop = Runnable { runLoop = Runnable {
var refreshInterval = T.mins(5).msecs() var refreshInterval = T.mins(5).msecs()