OpenAPS.swift 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754
  1. import Combine
  2. import CoreData
  3. import Foundation
  4. import JavaScriptCore
  5. final class OpenAPS {
  6. private let jsWorker = JavaScriptWorker()
  7. private let processQueue = DispatchQueue(label: "OpenAPS.processQueue", qos: .utility)
  8. private let storage: FileStorage
  9. let viewContext = CoreDataStack.shared.viewContext
  10. init(storage: FileStorage) {
  11. self.storage = storage
  12. }
  13. func determineBasal(currentTemp: TempBasal, clock: Date = Date()) -> Future<Determination?, Never> {
  14. Future { promise in
  15. self.processQueue.async {
  16. debug(.openAPS, "Start determineBasal")
  17. // clock
  18. self.storage.save(clock, as: Monitor.clock)
  19. // temp_basal
  20. let tempBasal = currentTemp.rawJSON
  21. self.storage.save(tempBasal, as: Monitor.tempBasal)
  22. // meal
  23. let pumpHistory = self.loadFileFromStorage(name: OpenAPS.Monitor.pumpHistory)
  24. let carbs = self.loadFileFromStorage(name: Monitor.carbHistory)
  25. let glucose = self.loadFileFromStorage(name: Monitor.glucose)
  26. let profile = self.loadFileFromStorage(name: Settings.profile)
  27. let basalProfile = self.loadFileFromStorage(name: Settings.basalProfile)
  28. let meal = self.meal(
  29. pumphistory: pumpHistory,
  30. profile: profile,
  31. basalProfile: basalProfile,
  32. clock: clock,
  33. carbs: carbs,
  34. glucose: glucose
  35. )
  36. self.storage.save(meal, as: Monitor.meal)
  37. // iob
  38. let autosens = self.loadFileFromStorage(name: Settings.autosense)
  39. let iob = self.iob(
  40. pumphistory: pumpHistory,
  41. profile: profile,
  42. clock: clock,
  43. autosens: autosens.isEmpty ? .null : autosens
  44. )
  45. self.storage.save(iob, as: Monitor.iob)
  46. // determine-basal
  47. let reservoir = self.loadFileFromStorage(name: Monitor.reservoir)
  48. let preferences = self.loadFileFromStorage(name: Settings.preferences)
  49. // oref2
  50. let oref2_variables = self.oref2()
  51. let orefDetermination = self.determineBasal(
  52. glucose: glucose,
  53. currentTemp: tempBasal,
  54. iob: iob,
  55. profile: profile,
  56. autosens: autosens.isEmpty ? .null : autosens,
  57. meal: meal,
  58. microBolusAllowed: true,
  59. reservoir: reservoir,
  60. pumpHistory: pumpHistory,
  61. preferences: preferences,
  62. basalProfile: basalProfile,
  63. oref2_variables: oref2_variables
  64. )
  65. debug(.openAPS, "SUGGESTED: \(orefDetermination)")
  66. if var determination = Determination(from: orefDetermination) {
  67. determination.timestamp = determination.deliverAt ?? clock
  68. self.storage.save(determination, as: Enact.suggested)
  69. // save to core data asynchronously
  70. self.viewContext.perform {
  71. let newOrefDetermination = OrefDetermination(context: self.viewContext)
  72. newOrefDetermination.id = UUID()
  73. newOrefDetermination.totalDailyDose = determination.tdd as? NSDecimalNumber
  74. newOrefDetermination.insulinSensitivity = determination.isf as? NSDecimalNumber
  75. newOrefDetermination.currentTarget = determination.current_target as? NSDecimalNumber
  76. newOrefDetermination.eventualBG = determination.eventualBG as? NSDecimalNumber
  77. newOrefDetermination.deliverAt = determination.deliverAt
  78. newOrefDetermination.enacted = false
  79. newOrefDetermination.insulinForManualBolus = determination.insulinForManualBolus as? NSDecimalNumber
  80. newOrefDetermination.carbRatio = determination.carbRatio as? NSDecimalNumber
  81. newOrefDetermination.glucose = determination.bg as? NSDecimalNumber
  82. newOrefDetermination.reservoir = determination.reservoir as? NSDecimalNumber
  83. newOrefDetermination.insulinReq = determination.insulinReq as? NSDecimalNumber
  84. newOrefDetermination.temp = determination.temp?.rawValue ?? "absolute"
  85. newOrefDetermination.rate = determination.rate as? NSDecimalNumber
  86. newOrefDetermination.reason = determination.reason
  87. newOrefDetermination.duration = Int16(determination.duration ?? 0)
  88. newOrefDetermination.iob = determination.iob as? NSDecimalNumber
  89. newOrefDetermination.treshold = determination.treshold as? NSDecimalNumber
  90. if let predictions = determination.predictions {
  91. // Create forecasts for each type
  92. ["iob": predictions.iob, "zt": predictions.zt, "cob": predictions.cob, "uam": predictions.uam]
  93. .forEach { type, values in
  94. if let values = values {
  95. let forecast = Forecast(context: self.viewContext)
  96. forecast.type = type
  97. forecast.date = Date() // or use a specific timestamp if available
  98. forecast
  99. .orefDetermination =
  100. newOrefDetermination // Assuming a relationship from Forecast to OrefDetermination
  101. for (index, value) in values.enumerated() {
  102. let forecastValue = ForecastValue(context: self.viewContext)
  103. forecastValue.index = Int32(index)
  104. forecastValue.value = Int32(value)
  105. forecast.addToForecastValues(forecastValue)
  106. }
  107. newOrefDetermination.addToForecasts(forecast)
  108. }
  109. }
  110. }
  111. newOrefDetermination.minDelta = determination.minDelta as? NSDecimalNumber
  112. newOrefDetermination.sensitivityRatio = determination.sensitivityRatio as? NSDecimalNumber
  113. newOrefDetermination.expectedDelta = determination.expectedDelta as? NSDecimalNumber
  114. newOrefDetermination.cob = Int16(Int(determination.cob ?? 0))
  115. newOrefDetermination.manualBolusErrorString = determination.manualBolusErrorString as? NSDecimalNumber
  116. newOrefDetermination.timestampEnacted = nil
  117. newOrefDetermination.tempBasal = determination.insulin?.temp_basal as? NSDecimalNumber
  118. newOrefDetermination.scheduledBasal = determination.insulin?.scheduled_basal as? NSDecimalNumber
  119. newOrefDetermination.bolus = determination.insulin?.bolus as? NSDecimalNumber
  120. newOrefDetermination.smbToDeliver = determination.units as? NSDecimalNumber
  121. newOrefDetermination.carbsRequired = Int16(Int(determination.carbsReq ?? 0))
  122. do {
  123. try self.viewContext.save()
  124. debugPrint(
  125. "OpenAPS: \(CoreDataStack.identifier) \(DebuggingIdentifiers.succeeded) saved determination"
  126. )
  127. } catch {
  128. debugPrint(
  129. "OpenAPS: \(CoreDataStack.identifier) \(DebuggingIdentifiers.failed) error while saving determination"
  130. )
  131. }
  132. }
  133. // MARK: Save to CoreData also. To do: Remove JSON saving
  134. if determination.tdd ?? 0 > 0 {
  135. self.viewContext.perform {
  136. let saveToTDD = TDD(context: self.viewContext)
  137. saveToTDD.timestamp = determination.timestamp ?? Date()
  138. saveToTDD.tdd = (determination.tdd ?? 0) as NSDecimalNumber?
  139. try? self.viewContext.save()
  140. let saveTarget = Target(context: self.viewContext)
  141. saveTarget.current = (determination.current_target ?? 100) as NSDecimalNumber?
  142. try? self.viewContext.save()
  143. }
  144. // self.coredataContext.perform {
  145. // let saveToInsulin = InsulinDistribution(context: self.coredataContext)
  146. //
  147. // saveToInsulin.bolus = (determination.insulin?.bolus ?? 0) as NSDecimalNumber?
  148. // saveToInsulin.scheduledBasal = (determination.insulin?.scheduled_basal ?? 0) as NSDecimalNumber?
  149. // saveToInsulin.tempBasal = (determination.insulin?.temp_basal ?? 0) as NSDecimalNumber?
  150. // saveToInsulin.date = Date()
  151. //
  152. // try? self.coredataContext.save()
  153. // }
  154. }
  155. promise(.success(determination))
  156. } else {
  157. promise(.success(nil))
  158. }
  159. }
  160. }
  161. }
  162. func oref2() -> RawJSON {
  163. viewContext.performAndWait {
  164. let preferences = storage.retrieve(OpenAPS.Settings.preferences, as: Preferences.self)
  165. var hbt_ = preferences?.halfBasalExerciseTarget ?? 160
  166. let wp = preferences?.weightPercentage ?? 1
  167. let smbMinutes = (preferences?.maxSMBBasalMinutes ?? 30) as NSDecimalNumber
  168. let uamMinutes = (preferences?.maxUAMSMBBasalMinutes ?? 30) as NSDecimalNumber
  169. let tenDaysAgo = Date().addingTimeInterval(-10.days.timeInterval)
  170. let twoHoursAgo = Date().addingTimeInterval(-2.hours.timeInterval)
  171. var uniqueEvents = [TDD]()
  172. let requestTDD = TDD.fetchRequest() as NSFetchRequest<TDD>
  173. requestTDD.predicate = NSPredicate(format: "timestamp > %@ AND tdd > 0", tenDaysAgo as NSDate)
  174. let sortTDD = NSSortDescriptor(key: "timestamp", ascending: true)
  175. requestTDD.sortDescriptors = [sortTDD]
  176. try? uniqueEvents = viewContext.fetch(requestTDD)
  177. var sliderArray = [TempTargetsSlider]()
  178. let requestIsEnbled = TempTargetsSlider.fetchRequest() as NSFetchRequest<TempTargetsSlider>
  179. let sortIsEnabled = NSSortDescriptor(key: "date", ascending: false)
  180. requestIsEnbled.sortDescriptors = [sortIsEnabled]
  181. // requestIsEnbled.fetchLimit = 1
  182. try? sliderArray = viewContext.fetch(requestIsEnbled)
  183. var overrideArray = [Override]()
  184. let requestOverrides = Override.fetchRequest() as NSFetchRequest<Override>
  185. let sortOverride = NSSortDescriptor(key: "date", ascending: false)
  186. requestOverrides.sortDescriptors = [sortOverride]
  187. // requestOverrides.fetchLimit = 1
  188. try? overrideArray = viewContext.fetch(requestOverrides)
  189. var tempTargetsArray = [TempTargets]()
  190. let requestTempTargets = TempTargets.fetchRequest() as NSFetchRequest<TempTargets>
  191. let sortTT = NSSortDescriptor(key: "date", ascending: false)
  192. requestTempTargets.sortDescriptors = [sortTT]
  193. requestTempTargets.fetchLimit = 1
  194. try? tempTargetsArray = viewContext.fetch(requestTempTargets)
  195. let total = uniqueEvents.compactMap({ each in each.tdd as? Decimal ?? 0 }).reduce(0, +)
  196. var indeces = uniqueEvents.count
  197. // Only fetch once. Use same (previous) fetch
  198. let twoHoursArray = uniqueEvents.filter({ ($0.timestamp ?? Date()) >= twoHoursAgo })
  199. var nrOfIndeces = twoHoursArray.count
  200. let totalAmount = twoHoursArray.compactMap({ each in each.tdd as? Decimal ?? 0 }).reduce(0, +)
  201. var temptargetActive = tempTargetsArray.first?.active ?? false
  202. let isPercentageEnabled = sliderArray.first?.enabled ?? false
  203. var useOverride = overrideArray.first?.enabled ?? false
  204. var overridePercentage = Decimal(overrideArray.first?.percentage ?? 100)
  205. var unlimited = overrideArray.first?.indefinite ?? true
  206. var disableSMBs = overrideArray.first?.smbIsOff ?? false
  207. let currentTDD = (uniqueEvents.last?.tdd ?? 0) as Decimal
  208. if indeces == 0 {
  209. indeces = 1
  210. }
  211. if nrOfIndeces == 0 {
  212. nrOfIndeces = 1
  213. }
  214. let average2hours = totalAmount / Decimal(nrOfIndeces)
  215. let average14 = total / Decimal(indeces)
  216. let weight = wp
  217. let weighted_average = weight * average2hours + (1 - weight) * average14
  218. var duration: Decimal = 0
  219. var newDuration: Decimal = 0
  220. var overrideTarget: Decimal = 0
  221. if useOverride {
  222. duration = (overrideArray.first?.duration ?? 0) as Decimal
  223. overrideTarget = (overrideArray.first?.target ?? 0) as Decimal
  224. let advancedSettings = overrideArray.first?.advancedSettings ?? false
  225. let addedMinutes = Int(duration)
  226. let date = overrideArray.first?.date ?? Date()
  227. if date.addingTimeInterval(addedMinutes.minutes.timeInterval) < Date(),
  228. !unlimited
  229. {
  230. useOverride = false
  231. let saveToCoreData = Override(context: self.viewContext)
  232. saveToCoreData.enabled = false
  233. saveToCoreData.date = Date()
  234. saveToCoreData.duration = 0
  235. saveToCoreData.indefinite = false
  236. saveToCoreData.percentage = 100
  237. try? self.viewContext.save()
  238. }
  239. }
  240. if !useOverride {
  241. unlimited = true
  242. overridePercentage = 100
  243. duration = 0
  244. overrideTarget = 0
  245. disableSMBs = false
  246. }
  247. if temptargetActive {
  248. var duration_ = 0
  249. var hbt = Double(hbt_)
  250. var dd = 0.0
  251. if temptargetActive {
  252. duration_ = Int(truncating: tempTargetsArray.first?.duration ?? 0)
  253. hbt = tempTargetsArray.first?.hbt ?? Double(hbt_)
  254. let startDate = tempTargetsArray.first?.startDate ?? Date()
  255. let durationPlusStart = startDate.addingTimeInterval(duration_.minutes.timeInterval)
  256. dd = durationPlusStart.timeIntervalSinceNow.minutes
  257. if dd > 0.1 {
  258. hbt_ = Decimal(hbt)
  259. temptargetActive = true
  260. } else {
  261. temptargetActive = false
  262. }
  263. }
  264. }
  265. if currentTDD > 0 {
  266. let averages = Oref2_variables(
  267. average_total_data: average14,
  268. weightedAverage: weighted_average,
  269. past2hoursAverage: average2hours,
  270. date: Date(),
  271. isEnabled: temptargetActive,
  272. presetActive: isPercentageEnabled,
  273. overridePercentage: overridePercentage,
  274. useOverride: useOverride,
  275. duration: duration,
  276. unlimited: unlimited,
  277. hbt: hbt_,
  278. overrideTarget: overrideTarget,
  279. smbIsOff: disableSMBs,
  280. advancedSettings: overrideArray.first?.advancedSettings ?? false,
  281. isfAndCr: overrideArray.first?.isfAndCr ?? false,
  282. isf: overrideArray.first?.isf ?? false,
  283. cr: overrideArray.first?.cr ?? false,
  284. smbIsAlwaysOff: overrideArray.first?.smbIsAlwaysOff ?? false,
  285. start: (overrideArray.first?.start ?? 0) as Decimal,
  286. end: (overrideArray.first?.end ?? 0) as Decimal,
  287. smbMinutes: (overrideArray.first?.smbMinutes ?? smbMinutes) as Decimal,
  288. uamMinutes: (overrideArray.first?.uamMinutes ?? uamMinutes) as Decimal
  289. )
  290. storage.save(averages, as: OpenAPS.Monitor.oref2_variables)
  291. return self.loadFileFromStorage(name: Monitor.oref2_variables)
  292. } else {
  293. let averages = Oref2_variables(
  294. average_total_data: 0,
  295. weightedAverage: 1,
  296. past2hoursAverage: 0,
  297. date: Date(),
  298. isEnabled: temptargetActive,
  299. presetActive: isPercentageEnabled,
  300. overridePercentage: overridePercentage,
  301. useOverride: useOverride,
  302. duration: duration,
  303. unlimited: unlimited,
  304. hbt: hbt_,
  305. overrideTarget: overrideTarget,
  306. smbIsOff: disableSMBs,
  307. advancedSettings: overrideArray.first?.advancedSettings ?? false,
  308. isfAndCr: overrideArray.first?.isfAndCr ?? false,
  309. isf: overrideArray.first?.isf ?? false,
  310. cr: overrideArray.first?.cr ?? false,
  311. smbIsAlwaysOff: overrideArray.first?.smbIsAlwaysOff ?? false,
  312. start: (overrideArray.first?.start ?? 0) as Decimal,
  313. end: (overrideArray.first?.end ?? 0) as Decimal,
  314. smbMinutes: (overrideArray.first?.smbMinutes ?? smbMinutes) as Decimal,
  315. uamMinutes: (overrideArray.first?.uamMinutes ?? uamMinutes) as Decimal
  316. )
  317. storage.save(averages, as: OpenAPS.Monitor.oref2_variables)
  318. return self.loadFileFromStorage(name: Monitor.oref2_variables)
  319. }
  320. }
  321. }
  322. func autosense() -> Future<Autosens?, Never> {
  323. Future { promise in
  324. self.processQueue.async {
  325. debug(.openAPS, "Start autosens")
  326. let pumpHistory = self.loadFileFromStorage(name: OpenAPS.Monitor.pumpHistory)
  327. let carbs = self.loadFileFromStorage(name: Monitor.carbHistory)
  328. let glucose = self.loadFileFromStorage(name: Monitor.glucose)
  329. let profile = self.loadFileFromStorage(name: Settings.profile)
  330. let basalProfile = self.loadFileFromStorage(name: Settings.basalProfile)
  331. let tempTargets = self.loadFileFromStorage(name: Settings.tempTargets)
  332. let autosensResult = self.autosense(
  333. glucose: glucose,
  334. pumpHistory: pumpHistory,
  335. basalprofile: basalProfile,
  336. profile: profile,
  337. carbs: carbs,
  338. temptargets: tempTargets
  339. )
  340. debug(.openAPS, "AUTOSENS: \(autosensResult)")
  341. if var autosens = Autosens(from: autosensResult) {
  342. autosens.timestamp = Date()
  343. self.storage.save(autosens, as: Settings.autosense)
  344. promise(.success(autosens))
  345. } else {
  346. promise(.success(nil))
  347. }
  348. }
  349. }
  350. }
  351. func autotune(categorizeUamAsBasal: Bool = false, tuneInsulinCurve: Bool = false) -> Future<Autotune?, Never> {
  352. Future { promise in
  353. self.processQueue.async {
  354. debug(.openAPS, "Start autotune")
  355. let pumpHistory = self.loadFileFromStorage(name: OpenAPS.Monitor.pumpHistory)
  356. let glucose = self.loadFileFromStorage(name: Monitor.glucose)
  357. let profile = self.loadFileFromStorage(name: Settings.profile)
  358. let pumpProfile = self.loadFileFromStorage(name: Settings.pumpProfile)
  359. let carbs = self.loadFileFromStorage(name: Monitor.carbHistory)
  360. let autotunePreppedGlucose = self.autotunePrepare(
  361. pumphistory: pumpHistory,
  362. profile: profile,
  363. glucose: glucose,
  364. pumpprofile: pumpProfile,
  365. carbs: carbs,
  366. categorizeUamAsBasal: categorizeUamAsBasal,
  367. tuneInsulinCurve: tuneInsulinCurve
  368. )
  369. debug(.openAPS, "AUTOTUNE PREP: \(autotunePreppedGlucose)")
  370. let previousAutotune = self.storage.retrieve(Settings.autotune, as: RawJSON.self)
  371. let autotuneResult = self.autotuneRun(
  372. autotunePreparedData: autotunePreppedGlucose,
  373. previousAutotuneResult: previousAutotune ?? profile,
  374. pumpProfile: pumpProfile
  375. )
  376. debug(.openAPS, "AUTOTUNE RESULT: \(autotuneResult)")
  377. if let autotune = Autotune(from: autotuneResult) {
  378. self.storage.save(autotuneResult, as: Settings.autotune)
  379. promise(.success(autotune))
  380. } else {
  381. promise(.success(nil))
  382. }
  383. }
  384. }
  385. }
  386. func makeProfiles(useAutotune: Bool) -> Future<Autotune?, Never> {
  387. Future { promise in
  388. debug(.openAPS, "Start makeProfiles")
  389. self.processQueue.async {
  390. var preferences = self.loadFileFromStorage(name: Settings.preferences)
  391. if preferences.isEmpty {
  392. preferences = Preferences().rawJSON
  393. }
  394. let pumpSettings = self.loadFileFromStorage(name: Settings.settings)
  395. let bgTargets = self.loadFileFromStorage(name: Settings.bgTargets)
  396. let basalProfile = self.loadFileFromStorage(name: Settings.basalProfile)
  397. let isf = self.loadFileFromStorage(name: Settings.insulinSensitivities)
  398. let cr = self.loadFileFromStorage(name: Settings.carbRatios)
  399. let tempTargets = self.loadFileFromStorage(name: Settings.tempTargets)
  400. let model = self.loadFileFromStorage(name: Settings.model)
  401. let autotune = useAutotune ? self.loadFileFromStorage(name: Settings.autotune) : .empty
  402. let freeaps = self.loadFileFromStorage(name: FreeAPS.settings)
  403. let pumpProfile = self.makeProfile(
  404. preferences: preferences,
  405. pumpSettings: pumpSettings,
  406. bgTargets: bgTargets,
  407. basalProfile: basalProfile,
  408. isf: isf,
  409. carbRatio: cr,
  410. tempTargets: tempTargets,
  411. model: model,
  412. autotune: RawJSON.null,
  413. freeaps: freeaps
  414. )
  415. let profile = self.makeProfile(
  416. preferences: preferences,
  417. pumpSettings: pumpSettings,
  418. bgTargets: bgTargets,
  419. basalProfile: basalProfile,
  420. isf: isf,
  421. carbRatio: cr,
  422. tempTargets: tempTargets,
  423. model: model,
  424. autotune: autotune.isEmpty ? .null : autotune,
  425. freeaps: freeaps
  426. )
  427. self.storage.save(pumpProfile, as: Settings.pumpProfile)
  428. self.storage.save(profile, as: Settings.profile)
  429. if let tunedProfile = Autotune(from: profile) {
  430. promise(.success(tunedProfile))
  431. return
  432. }
  433. promise(.success(nil))
  434. }
  435. }
  436. }
  437. // MARK: - Private
  438. private func iob(pumphistory: JSON, profile: JSON, clock: JSON, autosens: JSON) -> RawJSON {
  439. dispatchPrecondition(condition: .onQueue(processQueue))
  440. return jsWorker.inCommonContext { worker in
  441. worker.evaluate(script: Script(name: Prepare.log))
  442. worker.evaluate(script: Script(name: Bundle.iob))
  443. worker.evaluate(script: Script(name: Prepare.iob))
  444. return worker.call(function: Function.generate, with: [
  445. pumphistory,
  446. profile,
  447. clock,
  448. autosens
  449. ])
  450. }
  451. }
  452. private func meal(pumphistory: JSON, profile: JSON, basalProfile: JSON, clock: JSON, carbs: JSON, glucose: JSON) -> RawJSON {
  453. dispatchPrecondition(condition: .onQueue(processQueue))
  454. return jsWorker.inCommonContext { worker in
  455. worker.evaluate(script: Script(name: Prepare.log))
  456. worker.evaluate(script: Script(name: Bundle.meal))
  457. worker.evaluate(script: Script(name: Prepare.meal))
  458. return worker.call(function: Function.generate, with: [
  459. pumphistory,
  460. profile,
  461. clock,
  462. glucose,
  463. basalProfile,
  464. carbs
  465. ])
  466. }
  467. }
  468. private func autotunePrepare(
  469. pumphistory: JSON,
  470. profile: JSON,
  471. glucose: JSON,
  472. pumpprofile: JSON,
  473. carbs: JSON,
  474. categorizeUamAsBasal: Bool,
  475. tuneInsulinCurve: Bool
  476. ) -> RawJSON {
  477. dispatchPrecondition(condition: .onQueue(processQueue))
  478. return jsWorker.inCommonContext { worker in
  479. worker.evaluate(script: Script(name: Prepare.log))
  480. worker.evaluate(script: Script(name: Bundle.autotunePrep))
  481. worker.evaluate(script: Script(name: Prepare.autotunePrep))
  482. return worker.call(function: Function.generate, with: [
  483. pumphistory,
  484. profile,
  485. glucose,
  486. pumpprofile,
  487. carbs,
  488. categorizeUamAsBasal,
  489. tuneInsulinCurve
  490. ])
  491. }
  492. }
  493. private func autotuneRun(
  494. autotunePreparedData: JSON,
  495. previousAutotuneResult: JSON,
  496. pumpProfile: JSON
  497. ) -> RawJSON {
  498. dispatchPrecondition(condition: .onQueue(processQueue))
  499. return jsWorker.inCommonContext { worker in
  500. worker.evaluate(script: Script(name: Prepare.log))
  501. worker.evaluate(script: Script(name: Bundle.autotuneCore))
  502. worker.evaluate(script: Script(name: Prepare.autotuneCore))
  503. return worker.call(function: Function.generate, with: [
  504. autotunePreparedData,
  505. previousAutotuneResult,
  506. pumpProfile
  507. ])
  508. }
  509. }
  510. private func determineBasal(
  511. glucose: JSON,
  512. currentTemp: JSON,
  513. iob: JSON,
  514. profile: JSON,
  515. autosens: JSON,
  516. meal: JSON,
  517. microBolusAllowed: Bool,
  518. reservoir: JSON,
  519. pumpHistory: JSON,
  520. preferences: JSON,
  521. basalProfile: JSON,
  522. oref2_variables: JSON
  523. ) -> RawJSON {
  524. dispatchPrecondition(condition: .onQueue(processQueue))
  525. return jsWorker.inCommonContext { worker in
  526. worker.evaluate(script: Script(name: Prepare.log))
  527. worker.evaluate(script: Script(name: Prepare.determineBasal))
  528. worker.evaluate(script: Script(name: Bundle.basalSetTemp))
  529. worker.evaluate(script: Script(name: Bundle.getLastGlucose))
  530. worker.evaluate(script: Script(name: Bundle.determineBasal))
  531. if let middleware = self.middlewareScript(name: OpenAPS.Middleware.determineBasal) {
  532. worker.evaluate(script: middleware)
  533. }
  534. return worker.call(
  535. function: Function.generate,
  536. with: [
  537. iob,
  538. currentTemp,
  539. glucose,
  540. profile,
  541. autosens,
  542. meal,
  543. microBolusAllowed,
  544. reservoir,
  545. Date(),
  546. pumpHistory,
  547. preferences,
  548. basalProfile,
  549. oref2_variables
  550. ]
  551. )
  552. }
  553. }
  554. private func autosense(
  555. glucose: JSON,
  556. pumpHistory: JSON,
  557. basalprofile: JSON,
  558. profile: JSON,
  559. carbs: JSON,
  560. temptargets: JSON
  561. ) -> RawJSON {
  562. dispatchPrecondition(condition: .onQueue(processQueue))
  563. return jsWorker.inCommonContext { worker in
  564. worker.evaluate(script: Script(name: Prepare.log))
  565. worker.evaluate(script: Script(name: Bundle.autosens))
  566. worker.evaluate(script: Script(name: Prepare.autosens))
  567. return worker.call(
  568. function: Function.generate,
  569. with: [
  570. glucose,
  571. pumpHistory,
  572. basalprofile,
  573. profile,
  574. carbs,
  575. temptargets
  576. ]
  577. )
  578. }
  579. }
  580. private func exportDefaultPreferences() -> RawJSON {
  581. dispatchPrecondition(condition: .onQueue(processQueue))
  582. return jsWorker.inCommonContext { worker in
  583. worker.evaluate(script: Script(name: Prepare.log))
  584. worker.evaluate(script: Script(name: Bundle.profile))
  585. worker.evaluate(script: Script(name: Prepare.profile))
  586. return worker.call(function: Function.exportDefaults, with: [])
  587. }
  588. }
  589. private func makeProfile(
  590. preferences: JSON,
  591. pumpSettings: JSON,
  592. bgTargets: JSON,
  593. basalProfile: JSON,
  594. isf: JSON,
  595. carbRatio: JSON,
  596. tempTargets: JSON,
  597. model: JSON,
  598. autotune: JSON,
  599. freeaps: JSON
  600. ) -> RawJSON {
  601. dispatchPrecondition(condition: .onQueue(processQueue))
  602. return jsWorker.inCommonContext { worker in
  603. worker.evaluate(script: Script(name: Prepare.log))
  604. worker.evaluate(script: Script(name: Bundle.profile))
  605. worker.evaluate(script: Script(name: Prepare.profile))
  606. return worker.call(
  607. function: Function.generate,
  608. with: [
  609. pumpSettings,
  610. bgTargets,
  611. isf,
  612. basalProfile,
  613. preferences,
  614. carbRatio,
  615. tempTargets,
  616. model,
  617. autotune,
  618. freeaps
  619. ]
  620. )
  621. }
  622. }
  623. private func loadJSON(name: String) -> String {
  624. try! String(contentsOf: Foundation.Bundle.main.url(forResource: "json/\(name)", withExtension: "json")!)
  625. }
  626. private func loadFileFromStorage(name: String) -> RawJSON {
  627. storage.retrieveRaw(name) ?? OpenAPS.defaults(for: name)
  628. }
  629. private func middlewareScript(name: String) -> Script? {
  630. if let body = storage.retrieveRaw(name) {
  631. return Script(name: "Middleware", body: body)
  632. }
  633. if let url = Foundation.Bundle.main.url(forResource: "javascript/\(name)", withExtension: "") {
  634. return Script(name: "Middleware", body: try! String(contentsOf: url))
  635. }
  636. return nil
  637. }
  638. static func defaults(for file: String) -> RawJSON {
  639. let prefix = file.hasSuffix(".json") ? "json/defaults" : "javascript"
  640. guard let url = Foundation.Bundle.main.url(forResource: "\(prefix)/\(file)", withExtension: "") else {
  641. return ""
  642. }
  643. return (try? String(contentsOf: url)) ?? ""
  644. }
  645. func processAndSave(forecastData: [String: [Int]]) {
  646. let context = viewContext
  647. let currentDate = Date()
  648. for (type, values) in forecastData {
  649. createForecast(type: type, values: values, date: currentDate, context: context)
  650. }
  651. }
  652. func createForecast(type: String, values: [Int], date: Date, context: NSManagedObjectContext) {
  653. let forecast = Forecast(context: context)
  654. forecast.id = UUID()
  655. forecast.date = date
  656. forecast.type = type
  657. for (index, value) in values.enumerated() {
  658. let forecastValue = ForecastValue(context: context)
  659. forecastValue.value = Int32(value)
  660. forecastValue.index = Int32(index)
  661. forecastValue.forecast = forecast
  662. }
  663. do {
  664. try context.save()
  665. } catch {
  666. print("Failed to save forecast: \(error)")
  667. }
  668. }
  669. }