OpenAPS.swift 30 KB

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