|
|
@@ -8,9 +8,83 @@ final class BaseAPSManager: APSManager, Injectable {
|
|
|
private var openAPS: OpenAPS!
|
|
|
@Injected() var deviceDataManager: DeviceDataManager!
|
|
|
|
|
|
+ private(set) var devices: [RileyLinkDevice] = [] {
|
|
|
+ didSet {
|
|
|
+ print("Devices: \(devices)")
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ private var deviceRSSI: [UUID: Int] = [:] {
|
|
|
+ didSet {
|
|
|
+ print("RSSI: \(deviceRSSI)")
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ private(set) var rileyLinkPumpManager: RileyLinkPumpManager!
|
|
|
+
|
|
|
+ private var rssiFetchTimer: Timer? {
|
|
|
+ willSet {
|
|
|
+ rssiFetchTimer?.invalidate()
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
init(resolver: Resolver) {
|
|
|
injectServices(resolver)
|
|
|
openAPS = OpenAPS(storage: resolver.resolve(FileStorage.self)!)
|
|
|
+ rileyLinkPumpManager = RileyLinkPumpManager(
|
|
|
+ rileyLinkDeviceProvider: deviceDataManager.rileyLinkConnectionManager.deviceProvider,
|
|
|
+ rileyLinkConnectionManager: deviceDataManager.rileyLinkConnectionManager
|
|
|
+ )
|
|
|
+ registerNotifications()
|
|
|
+ reloadDevices()
|
|
|
+ rssiFetchTimer = Timer.scheduledTimer(
|
|
|
+ timeInterval: 3,
|
|
|
+ target: self,
|
|
|
+ selector: #selector(updateRSSI),
|
|
|
+ userInfo: nil,
|
|
|
+ repeats: true
|
|
|
+ )
|
|
|
+ updateRSSI()
|
|
|
+ }
|
|
|
+
|
|
|
+ private func registerNotifications() {
|
|
|
+ // Register for manager notifications
|
|
|
+ NotificationCenter.default.addObserver(
|
|
|
+ self,
|
|
|
+ selector: #selector(reloadDevices),
|
|
|
+ name: .ManagerDevicesDidChange,
|
|
|
+ object: rileyLinkPumpManager.rileyLinkDeviceProvider
|
|
|
+ )
|
|
|
+
|
|
|
+ // Register for device notifications
|
|
|
+ for name in [.DeviceConnectionStateDidChange, .DeviceRSSIDidChange, .DeviceNameDidChange] as [Notification.Name] {
|
|
|
+ NotificationCenter.default.addObserver(self, selector: #selector(deviceDidUpdate(_:)), name: name, object: nil)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @objc private func reloadDevices() {
|
|
|
+ rileyLinkPumpManager.rileyLinkDeviceProvider.getDevices { devices in
|
|
|
+ DispatchQueue.main.async { [weak self] in
|
|
|
+ self?.devices = devices
|
|
|
+ devices.forEach { self?.rileyLinkPumpManager.connectToRileyLink($0) }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @objc private func deviceDidUpdate(_ note: Notification) {
|
|
|
+ DispatchQueue.main.async {
|
|
|
+ if let device = note.object as? RileyLinkDevice {
|
|
|
+ if let rssi = note.userInfo?[RileyLinkDevice.notificationRSSIKey] as? Int {
|
|
|
+ self.deviceRSSI[device.peripheralIdentifier] = rssi
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @objc public func updateRSSI() {
|
|
|
+ for device in devices {
|
|
|
+ device.readRSSI()
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
func runTest() {
|
Ivan Valkou