|
|
@@ -641,81 +641,260 @@ final class BaseAPSManager: APSManager, Injectable {
|
|
|
|
|
|
storage.save(enacted, as: OpenAPS.Enact.enacted)
|
|
|
|
|
|
- // Add to tdd.json:
|
|
|
- //
|
|
|
- let preferences = settingsManager.preferences
|
|
|
- let currentTDD = enacted.tdd ?? 0
|
|
|
- let file = OpenAPS.Monitor.tdd
|
|
|
- let tdd = TDD(
|
|
|
- TDD: currentTDD,
|
|
|
- timestamp: Date(),
|
|
|
- id: UUID().uuidString
|
|
|
- )
|
|
|
- var uniqEvents: [TDD] = []
|
|
|
- storage.transaction { storage in
|
|
|
- storage.append(tdd, to: file, uniqBy: \.id)
|
|
|
- uniqEvents = storage.retrieve(file, as: [TDD].self)?
|
|
|
- .filter { $0.timestamp.addingTimeInterval(14.days.timeInterval) > Date() }
|
|
|
- .sorted { $0.timestamp > $1.timestamp } ?? []
|
|
|
-
|
|
|
- var total: Decimal = 0
|
|
|
- var indeces: Decimal = 0
|
|
|
-
|
|
|
- for uniqEvent in uniqEvents {
|
|
|
- if uniqEvent.TDD > 0 {
|
|
|
- total += uniqEvent.TDD
|
|
|
- indeces += 1
|
|
|
- }
|
|
|
- }
|
|
|
+ // Create a tdd.json
|
|
|
+ tdd(enacted_: enacted)
|
|
|
|
|
|
- let entriesPast2hours = storage.retrieve(file, as: [TDD].self)?
|
|
|
- .filter { $0.timestamp.addingTimeInterval(2.hours.timeInterval) > Date() }
|
|
|
- .sorted { $0.timestamp > $1.timestamp } ?? []
|
|
|
+ // Create a dailyStats.json
|
|
|
+ dailyStats()
|
|
|
|
|
|
- var totalAmount: Decimal = 0
|
|
|
- var nrOfIndeces: Decimal = 0
|
|
|
-
|
|
|
- for entry in entriesPast2hours {
|
|
|
- if entry.TDD > 0 {
|
|
|
- totalAmount += entry.TDD
|
|
|
- nrOfIndeces += 1
|
|
|
- }
|
|
|
+ debug(.apsManager, "Suggestion enacted. Received: \(received)")
|
|
|
+ DispatchQueue.main.async {
|
|
|
+ self.broadcaster.notify(EnactedSuggestionObserver.self, on: .main) {
|
|
|
+ $0.enactedSuggestionDidUpdate(enacted)
|
|
|
}
|
|
|
+ }
|
|
|
+ nightscout.uploadStatus()
|
|
|
+ }
|
|
|
+ }
|
|
|
|
|
|
- if indeces == 0 {
|
|
|
- indeces = 1
|
|
|
+ func tdd(enacted_: Suggestion) {
|
|
|
+ // Add to tdd.json:
|
|
|
+ let preferences = settingsManager.preferences
|
|
|
+ let currentTDD = enacted_.tdd ?? 0
|
|
|
+ let file = OpenAPS.Monitor.tdd
|
|
|
+ let tdd = TDD(
|
|
|
+ TDD: currentTDD,
|
|
|
+ timestamp: Date(),
|
|
|
+ id: UUID().uuidString
|
|
|
+ )
|
|
|
+ var uniqEvents: [TDD] = []
|
|
|
+ storage.transaction { storage in
|
|
|
+ storage.append(tdd, to: file, uniqBy: \.id)
|
|
|
+ uniqEvents = storage.retrieve(file, as: [TDD].self)?
|
|
|
+ .filter { $0.timestamp.addingTimeInterval(14.days.timeInterval) > Date() }
|
|
|
+ .sorted { $0.timestamp > $1.timestamp } ?? []
|
|
|
+ var total: Decimal = 0
|
|
|
+ var indeces: Decimal = 0
|
|
|
+ for uniqEvent in uniqEvents {
|
|
|
+ if uniqEvent.TDD > 0 {
|
|
|
+ total += uniqEvent.TDD
|
|
|
+ indeces += 1
|
|
|
}
|
|
|
-
|
|
|
- if nrOfIndeces == 0 {
|
|
|
- nrOfIndeces = 1
|
|
|
+ }
|
|
|
+ let entriesPast2hours = storage.retrieve(file, as: [TDD].self)?
|
|
|
+ .filter { $0.timestamp.addingTimeInterval(2.hours.timeInterval) > Date() }
|
|
|
+ .sorted { $0.timestamp > $1.timestamp } ?? []
|
|
|
+ var totalAmount: Decimal = 0
|
|
|
+ var nrOfIndeces: Decimal = 0
|
|
|
+ for entry in entriesPast2hours {
|
|
|
+ if entry.TDD > 0 {
|
|
|
+ totalAmount += entry.TDD
|
|
|
+ nrOfIndeces += 1
|
|
|
}
|
|
|
+ }
|
|
|
+ if indeces == 0 {
|
|
|
+ indeces = 1
|
|
|
+ }
|
|
|
+ if nrOfIndeces == 0 {
|
|
|
+ nrOfIndeces = 1
|
|
|
+ }
|
|
|
+ let average14 = total / indeces
|
|
|
+ let average2hours = totalAmount / nrOfIndeces
|
|
|
+ let weight = preferences.weightPercentage
|
|
|
+ let weighted_average = weight * average2hours + (1 - weight) * average14
|
|
|
+ let averages = TDD_averages(
|
|
|
+ average_total_data: average14,
|
|
|
+ weightedAverage: weighted_average,
|
|
|
+ past2hoursAverage: average2hours,
|
|
|
+ date: Date()
|
|
|
+ )
|
|
|
+ storage.save(averages, as: OpenAPS.Monitor.tdd_averages)
|
|
|
+ storage.save(Array(uniqEvents), as: file)
|
|
|
+ }
|
|
|
+ }
|
|
|
|
|
|
- let average14 = total / indeces
|
|
|
- let average2hours = totalAmount / nrOfIndeces
|
|
|
- let weight = preferences.weightPercentage
|
|
|
- let weighted_average = weight * average2hours + (1 - weight) * average14
|
|
|
+ func dailyStats() {
|
|
|
+ // Add to dailyStats.JSON
|
|
|
+ let preferences = settingsManager.preferences
|
|
|
+ let glucose = storage.retrieve(OpenAPS.Monitor.glucose, as: [BloodGlucose].self)
|
|
|
+ let carbs = storage.retrieve(OpenAPS.Monitor.carbHistory, as: [CarbsEntry].self)
|
|
|
+ let tdds = storage.retrieve(OpenAPS.Monitor.tdd, as: [TDD].self)
|
|
|
+ let currentTDD = tdds?[0].TDD
|
|
|
+ var bg: Decimal = 0
|
|
|
+ var nr_bgs: Decimal = 0
|
|
|
+
|
|
|
+ for entry in glucose! {
|
|
|
+ if entry.glucose! > 0 {
|
|
|
+ bg += Decimal(entry.glucose!)
|
|
|
+ nr_bgs += 1
|
|
|
+ }
|
|
|
+ }
|
|
|
|
|
|
- let averages = TDD_averages(
|
|
|
- average_total_data: average14,
|
|
|
- weightedAverage: weighted_average,
|
|
|
- past2hoursAverage: average2hours,
|
|
|
- date: Date()
|
|
|
- )
|
|
|
- storage.save(averages, as: OpenAPS.Monitor.tdd_averages)
|
|
|
- storage.save(Array(uniqEvents), as: file)
|
|
|
+ var carbTotal: Decimal = 0
|
|
|
+
|
|
|
+ for each in carbs! {
|
|
|
+ if each.carbs != 0 {
|
|
|
+ carbTotal += each.carbs
|
|
|
}
|
|
|
- // End of tdd.json
|
|
|
+ }
|
|
|
|
|
|
- debug(.apsManager, "Suggestion enacted. Received: \(received)")
|
|
|
- DispatchQueue.main.async {
|
|
|
- self.broadcaster.notify(EnactedSuggestionObserver.self, on: .main) {
|
|
|
- $0.enactedSuggestionDidUpdate(enacted)
|
|
|
+ var bgAvg = bg / nr_bgs
|
|
|
+ // Round to two decimals
|
|
|
+ bgAvg = Decimal(round(Double(bgAvg)))
|
|
|
+
|
|
|
+ var algo_ = "oref0"
|
|
|
+ if preferences.enableChris, preferences.useNewFormula {
|
|
|
+ algo_ = "Dynamic ISF, Logarithmic Formula"
|
|
|
+ } else if !preferences.useNewFormula, preferences.enableChris {
|
|
|
+ algo_ = "Dynamic ISF, Original Formula"
|
|
|
+ }
|
|
|
+
|
|
|
+ let af = preferences.adjustmentFactor
|
|
|
+ let insulin_type = preferences.curve
|
|
|
+
|
|
|
+ var buildDate: Date {
|
|
|
+ if let infoPath = Bundle.main.path(forResource: "Info", ofType: "plist"),
|
|
|
+ let infoAttr = try? FileManager.default.attributesOfItem(atPath: infoPath),
|
|
|
+ let infoDate = infoAttr[.modificationDate] as? Date
|
|
|
+ {
|
|
|
+ return infoDate
|
|
|
+ }
|
|
|
+ return Date()
|
|
|
+ }
|
|
|
+
|
|
|
+ let nsObject: AnyObject? = Bundle.main.infoDictionary!["CFBundleShortVersionString"] as AnyObject
|
|
|
+ let version = nsObject as! String
|
|
|
+ let build = Bundle.main.infoDictionary?["CFBundleVersion"] as? String
|
|
|
+ let branch = Bundle.main.infoDictionary?["NSHumanReadableCopyright"] as? String
|
|
|
+ let pump_ = pumpManager?.localizedTitle ?? ""
|
|
|
+ let cgm = settingsManager.settings.cgm
|
|
|
+ let file = OpenAPS.Monitor.dailyStats
|
|
|
+ let date_ = Date()
|
|
|
+ var iPa: Decimal = 75
|
|
|
+ if preferences.useCustomPeakTime {
|
|
|
+ iPa = preferences.insulinPeakTime
|
|
|
+ } else if preferences.curve.rawValue == "rapid-acting" {
|
|
|
+ iPa = 65
|
|
|
+ } else if preferences.curve.rawValue == "ultra-rapid" {
|
|
|
+ iPa = 50
|
|
|
+ }
|
|
|
+
|
|
|
+ let dailystat = DailyStats(
|
|
|
+ date: date_,
|
|
|
+ FAX_Build_Version: version,
|
|
|
+ FAX_Build_Number: build ?? "1",
|
|
|
+ FAX_Branch: branch ?? "N/A",
|
|
|
+ FAX_Build_Date: buildDate,
|
|
|
+ Algorithm: algo_,
|
|
|
+ AdjustmentFactor: af,
|
|
|
+ Pump: pump_,
|
|
|
+ CGM: cgm.rawValue,
|
|
|
+ insulinType: insulin_type.rawValue,
|
|
|
+ peakActivityTime: iPa,
|
|
|
+ TDD: currentTDD ?? 0,
|
|
|
+ Carbs_24h: carbTotal,
|
|
|
+ Hypoglucemias_Percentage: tir().hypos,
|
|
|
+ TIR_Percentage: tir().TIR,
|
|
|
+ Hyperglucemias_Percentage: tir().hypers,
|
|
|
+ BG_daily_Average_mg_dl: bgAvg,
|
|
|
+ id: UUID().uuidString
|
|
|
+ )
|
|
|
+
|
|
|
+ var newEntries: [DailyStats] = []
|
|
|
+
|
|
|
+ // If file is empty
|
|
|
+ let file_3 = loadFileFromStorage(name: OpenAPS.Monitor.dailyStats)
|
|
|
+ var isJSONempty = false
|
|
|
+ if file_3.rawJSON.isEmpty {
|
|
|
+ print("Empty")
|
|
|
+ isJSONempty = true
|
|
|
+ }
|
|
|
+
|
|
|
+ let now = Date()
|
|
|
+ let calender = Calendar.current
|
|
|
+
|
|
|
+ // If current local time is 23:41 or later
|
|
|
+ if calender.component(.hour, from: now) > 22,
|
|
|
+ calender.component(.minute, from: now) > 40
|
|
|
+ {
|
|
|
+ if isJSONempty {
|
|
|
+ storage.save(dailystat, as: file)
|
|
|
+ } else {
|
|
|
+ storage.transaction { storage in
|
|
|
+ storage.append(dailystat, to: file, uniqBy: \.id)
|
|
|
+ newEntries = storage.retrieve(file, as: [DailyStats].self)?
|
|
|
+ .sorted { $0.date > $1.date } ?? []
|
|
|
+ .filter { $0.date.addingTimeInterval(1.days.timeInterval) < now }
|
|
|
+ storage.save(Array(newEntries), as: file)
|
|
|
}
|
|
|
}
|
|
|
- nightscout.uploadStatus()
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ // Time In Range (%)
|
|
|
+ func tir() -> (hypos: Decimal, hypers: Decimal, TIR: Decimal) {
|
|
|
+ let glucose = storage.retrieve(OpenAPS.Monitor.glucose, as: [BloodGlucose].self)
|
|
|
+ let length_ = glucose!.count
|
|
|
+ let endIndex = length_ - 1
|
|
|
+
|
|
|
+ let fullTime = glucose![0].date - glucose![endIndex].date
|
|
|
+
|
|
|
+ // If empty json
|
|
|
+ guard fullTime != 0 else {
|
|
|
+ return (0, 0, 0)
|
|
|
+ }
|
|
|
+
|
|
|
+ var timeInHypo: Decimal = 0
|
|
|
+ var timeInHyper: Decimal = 0
|
|
|
+ var hypos: Decimal = 0
|
|
|
+ var hypers: Decimal = 0
|
|
|
+ var i = -1
|
|
|
+
|
|
|
+ var lastIndex = false
|
|
|
+
|
|
|
+ while i < endIndex {
|
|
|
+ i += 1
|
|
|
+
|
|
|
+ let currentTime = glucose![i].date
|
|
|
+ var previousTime = currentTime
|
|
|
+
|
|
|
+ if i + 1 <= endIndex {
|
|
|
+ previousTime = glucose![i + 1].date
|
|
|
+ } else {
|
|
|
+ lastIndex = true
|
|
|
+ }
|
|
|
+
|
|
|
+ if glucose![i].glucose! < 72, !lastIndex {
|
|
|
+ timeInHypo += currentTime - previousTime
|
|
|
+ } else if glucose![i].glucose! > 180, !lastIndex {
|
|
|
+ timeInHyper += currentTime - previousTime
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if timeInHypo == 0 {
|
|
|
+ hypos = 0
|
|
|
+ } else { hypos = (timeInHypo / fullTime) * 100
|
|
|
+ }
|
|
|
+
|
|
|
+ if timeInHyper == 0 {
|
|
|
+ hypers = 0
|
|
|
+ } else { hypers = (timeInHyper / fullTime) * 100
|
|
|
+ }
|
|
|
+
|
|
|
+ // round to 1 decimal
|
|
|
+ let hypoRounded = round(Double(hypos) * 10) / 10
|
|
|
+ let hyperRounded = round(Double(hypers) * 10) / 10
|
|
|
+ let TIRrounded = round((100 - (hypoRounded + hyperRounded)) * 10) / 10
|
|
|
+
|
|
|
+ print("TIR: \(TIRrounded) %, Hypos: \(hypoRounded) %, Hypers: \(hyperRounded) %")
|
|
|
+
|
|
|
+ return (Decimal(hypoRounded), Decimal(hyperRounded), Decimal(TIRrounded))
|
|
|
+ }
|
|
|
+
|
|
|
+ private func loadFileFromStorage(name: String) -> RawJSON {
|
|
|
+ storage.retrieveRaw(name) ?? OpenAPS.defaults(for: name)
|
|
|
+ }
|
|
|
+
|
|
|
private func processError(_ error: Error) {
|
|
|
warning(.apsManager, "\(error.localizedDescription)")
|
|
|
lastError.send(error)
|
Jon B.M