|
|
@@ -6,6 +6,7 @@ protocol GlucoseStorage {
|
|
|
func storeGlucose(_ glucose: [BloodGlucose])
|
|
|
func recent() -> [BloodGlucose]
|
|
|
func syncDate() -> Date
|
|
|
+ func filterTooFrequentGlucose(_ glucose: [BloodGlucose]) -> [BloodGlucose]
|
|
|
}
|
|
|
|
|
|
final class BaseGlucoseStorage: GlucoseStorage, Injectable {
|
|
|
@@ -13,15 +14,20 @@ final class BaseGlucoseStorage: GlucoseStorage, Injectable {
|
|
|
@Injected() private var storage: FileStorage!
|
|
|
@Injected() private var broadcaster: Broadcaster!
|
|
|
|
|
|
+ private enum Config {
|
|
|
+ static let filterTime: TimeInterval = 4.75 * 60
|
|
|
+ }
|
|
|
+
|
|
|
init(resolver: Resolver) {
|
|
|
injectServices(resolver)
|
|
|
}
|
|
|
|
|
|
func storeGlucose(_ glucose: [BloodGlucose]) {
|
|
|
processQueue.sync {
|
|
|
+ let filtered = self.filterTooFrequentGlucose(glucose)
|
|
|
let file = OpenAPS.Monitor.glucose
|
|
|
self.storage.transaction { storage in
|
|
|
- storage.append(glucose, to: file, uniqBy: \.dateString)
|
|
|
+ storage.append(filtered, to: file, uniqBy: \.dateString)
|
|
|
let uniqEvents = storage.retrieve(file, as: [BloodGlucose].self)?
|
|
|
.filter { $0.dateString.addingTimeInterval(1.days.timeInterval) > Date() }
|
|
|
.sorted { $0.dateString > $1.dateString } ?? []
|
|
|
@@ -43,12 +49,27 @@ final class BaseGlucoseStorage: GlucoseStorage, Injectable {
|
|
|
else {
|
|
|
return Date().addingTimeInterval(-1.days.timeInterval)
|
|
|
}
|
|
|
- return recent.dateString.addingTimeInterval(1.minutes.timeInterval)
|
|
|
+ return recent.dateString.addingTimeInterval(Config.filterTime)
|
|
|
}
|
|
|
|
|
|
func recent() -> [BloodGlucose] {
|
|
|
storage.retrieve(OpenAPS.Monitor.glucose, as: [BloodGlucose].self)?.reversed() ?? []
|
|
|
}
|
|
|
+
|
|
|
+ func filterTooFrequentGlucose(_ glucose: [BloodGlucose]) -> [BloodGlucose] {
|
|
|
+ var lastDate = recent().first?.dateString ?? .distantPast
|
|
|
+ var filtered: [BloodGlucose] = []
|
|
|
+
|
|
|
+ for entry in glucose.reversed() {
|
|
|
+ guard entry.dateString.addingTimeInterval(-Config.filterTime) > lastDate else {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ filtered.append(entry)
|
|
|
+ lastDate = entry.dateString
|
|
|
+ }
|
|
|
+
|
|
|
+ return filtered
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
protocol GlucoseObserver {
|