USB-Meter / USB Meter / Model / BluetoothManager.swift
Newer Older
199 lines | 8.021kb
Bogdan Timofte authored 2 weeks ago
1
//
2
//  BTManager.swift
3
//  USB Meter
4
//
5
//  Created by Bogdan Timofte on 01/03/2020.
6
//  Copyright © 2020 Bogdan Timofte. All rights reserved.
7
//
8

            
9
import CoreBluetooth
10

            
11
class BluetoothManager : NSObject, ObservableObject {
Bogdan Timofte authored 2 weeks ago
12
    private var manager: CBCentralManager?
Bogdan Timofte authored 2 weeks ago
13
    private var isStarting = false
Bogdan Timofte authored 2 weeks ago
14
    private var advertisementDataCache = AdvertisementDataCache()
15
    @Published var managerState = CBManagerState.unknown
Bogdan Timofte authored 2 weeks ago
16
    @Published private(set) var scanStartedAt: Date?
Bogdan Timofte authored 2 weeks ago
17

            
18
    override init () {
19
        super.init()
20
    }
21

            
Bogdan Timofte authored 2 weeks ago
22
    func start() {
Bogdan Timofte authored 2 weeks ago
23
        guard manager == nil, !isStarting else {
Bogdan Timofte authored 2 weeks ago
24
            return
25
        }
Bogdan Timofte authored 2 weeks ago
26
        isStarting = true
Bogdan Timofte authored 2 weeks ago
27
        track("Starting Bluetooth manager and requesting authorization if needed")
Bogdan Timofte authored 2 weeks ago
28
        DispatchQueue.main.async { [weak self] in
29
            guard let self else { return }
30
            defer { self.isStarting = false }
31
            guard self.manager == nil else {
32
                return
33
            }
34
            self.manager = CBCentralManager(delegate: self, queue: nil)
35
        }
Bogdan Timofte authored 2 weeks ago
36
    }
Bogdan Timofte authored 2 weeks ago
37

            
38
    private func scanForMeters() {
Bogdan Timofte authored 2 weeks ago
39
        guard let manager else {
40
            track("Scan requested before Bluetooth manager was started")
41
            return
42
        }
Bogdan Timofte authored 2 weeks ago
43
        guard manager.state == .poweredOn else {
44
            track( "Scan requested but Bluetooth state is \(manager.state)")
45
            return
46
        }
47
        //manager.scanForPeripherals(withServices: allBluetoothRadioServices(), options: [ CBCentralManagerScanOptionAllowDuplicatesKey: true ])
48
        manager.scanForPeripherals(withServices: allBluetoothRadioServices(), options: [ CBCentralManagerScanOptionAllowDuplicatesKey: true ])
49
    }
50

            
51
    func discoveredMeter(peripheral: CBPeripheral, advertising advertismentData: [String : Any], rssi RSSI: NSNumber) {
Bogdan Timofte authored 2 weeks ago
52
        guard let peripheralName = resolvedPeripheralName(for: peripheral, advertising: advertismentData) else {
53
            return
54
        }
55
        guard let manufacturerData = resolvedManufacturerData(from: advertismentData), manufacturerData.count > 2 else {
56
            return
57
        }
58

            
Bogdan Timofte authored 2 weeks ago
59
        guard let model = Model.byPeripheralName[peripheralName] else {
Bogdan Timofte authored 2 weeks ago
60
            return
61
        }
62

            
63
        let macAddress = MACAddress(from: manufacturerData.suffix(from: 2))
64

            
65
        if appData.meters[peripheral.identifier] == nil {
66
            track("adding new USB Meter named '\(peripheralName)' with MAC Address: '\(macAddress)'")
Bogdan Timofte authored 2 weeks ago
67
            let btSerial = BluetoothSerial(peripheral: peripheral, radio: model.radio, with: macAddress, managedBy: manager!, RSSI: RSSI.intValue)
Bogdan Timofte authored 2 weeks ago
68
            var m = appData.meters
69
            m[peripheral.identifier] = Meter(model: model, with: btSerial)
70
            appData.meters = m
71
        } else if let meter = appData.meters[peripheral.identifier] {
72
            meter.lastSeen = Date()
Bogdan Timofte authored 2 weeks ago
73
            meter.btSerial.updateRSSI(RSSI.intValue)
Bogdan Timofte authored 2 weeks ago
74
            if peripheral.delegate == nil {
75
                peripheral.delegate = meter.btSerial
76
            }
77
        }
78
    }
79

            
80
    private func resolvedPeripheralName(for peripheral: CBPeripheral, advertising advertismentData: [String : Any]) -> String? {
81
        let candidates = [
82
            (advertismentData[CBAdvertisementDataLocalNameKey] as? String),
83
            peripheral.name
84
        ]
85

            
86
        for candidate in candidates {
87
            if let trimmed = candidate?.trimmingCharacters(in: .whitespacesAndNewlines), !trimmed.isEmpty {
88
                return trimmed
Bogdan Timofte authored 2 weeks ago
89
            }
90
        }
Bogdan Timofte authored 2 weeks ago
91

            
92
        return nil
93
    }
94

            
95
    private func resolvedManufacturerData(from advertismentData: [String : Any]) -> Data? {
96
        if let data = advertismentData[CBAdvertisementDataManufacturerDataKey] as? Data {
97
            return data
Bogdan Timofte authored 2 weeks ago
98
        }
Bogdan Timofte authored 2 weeks ago
99
        if let data = advertismentData["kCBAdvDataManufacturerData"] as? Data {
100
            return data
101
        }
102
        return nil
Bogdan Timofte authored 2 weeks ago
103
    }
104
}
105

            
106
extension BluetoothManager : CBCentralManagerDelegate {
107
    // MARK:  CBCentralManager state Changed
108
    func centralManagerDidUpdateState(_ central: CBCentralManager) {
109
        managerState = central.state;
110
        track("\(central.state)")
111

            
112
        switch central.state {
113
        case .poweredOff:
Bogdan Timofte authored 2 weeks ago
114
            scanStartedAt = nil
Bogdan Timofte authored 2 weeks ago
115
            track("Bluetooth is Off. How should I behave?")
116
        case .poweredOn:
Bogdan Timofte authored 2 weeks ago
117
            scanStartedAt = Date()
Bogdan Timofte authored 2 weeks ago
118
            track("Bluetooth is On... Start scanning...")
119
            // note that "didDisconnectPeripheral" won't be called if BLE is turned off while connected
120
            // connectedPeripheral = nil
121
            // pendingPeripheral = nil
Bogdan Timofte authored 2 weeks ago
122
            scanForMeters()
Bogdan Timofte authored 2 weeks ago
123
        case .resetting:
Bogdan Timofte authored 2 weeks ago
124
            scanStartedAt = nil
Bogdan Timofte authored 2 weeks ago
125
            track("Bluetooth is reseting... . Whatever that means.")
126
        case .unauthorized:
Bogdan Timofte authored 2 weeks ago
127
            scanStartedAt = nil
Bogdan Timofte authored 2 weeks ago
128
            track("Bluetooth is not authorized.")
129
        case .unknown:
Bogdan Timofte authored 2 weeks ago
130
            scanStartedAt = nil
Bogdan Timofte authored 2 weeks ago
131
            track("Bluetooth is in an unknown state.")
132
        case .unsupported:
Bogdan Timofte authored 2 weeks ago
133
            scanStartedAt = nil
Bogdan Timofte authored 2 weeks ago
134
            track("Bluetooth not supported by device")
135
        default:
Bogdan Timofte authored 2 weeks ago
136
            scanStartedAt = nil
Bogdan Timofte authored 2 weeks ago
137
            track("Bluetooth is in a state never seen before!")
138
        }
139
    }
140

            
141
    // MARK:  CBCentralManager didDiscover peripheral
142
    func centralManager(_ central: CBCentralManager, didDiscover peripheral: CBPeripheral, advertisementData: [String : Any], rssi RSSI: NSNumber) {
143
        let completeAdvertisementData = self.advertisementDataCache.append(peripheral: peripheral, advertisementData: advertisementData)
144
        //track("Device discoverded UUID: '\(peripheral.identifier)' named '\(peripheral.name ?? "Unknown")'); RSSI: \(RSSI) dBm; Advertisment data: \(advertisementData)")
145
        discoveredMeter(peripheral: peripheral, advertising: completeAdvertisementData, rssi: RSSI )
146
    }
147

            
148
    // MARK:  CBCentralManager didConnect peripheral
149
    internal func centralManager(_ central: CBCentralManager, didConnect peripheral: CBPeripheral) {
150
        //track("Connected to peripheral: '\(peripheral.identifier)'")
151
        if let usbMeter = appData.meters[peripheral.identifier] {
152
            usbMeter.btSerial.connectionEstablished()
153
        }
154
        else {
155
            track("Connected to unknown meter with UUID: '\(peripheral.identifier)'")
156
        }
157
    }
158

            
159
    // MARK:  CBCentralManager didDisconnectPeripheral peripheral
160
    internal func centralManager(_ central: CBCentralManager, didDisconnectPeripheral peripheral: CBPeripheral, error: Error?) {
161
        track("Disconnected from peripheral: '\(peripheral.identifier)' with error: \(error.debugDescription)")
162
        if let usbMeter = appData.meters[peripheral.identifier] {
163
            usbMeter.btSerial.connectionClosed()
164
        }
165
        else {
166
            track("Disconnected from unknown meter with UUID: '\(peripheral.identifier)'")
167
        }
168
    }
Bogdan Timofte authored 2 weeks ago
169

            
170
    internal func centralManager(_ central: CBCentralManager, didFailToConnect peripheral: CBPeripheral, error: Error?) {
171
        track("Failed to connect to peripheral: '\(peripheral.identifier)' with error: \(error.debugDescription)")
172
        if let usbMeter = appData.meters[peripheral.identifier] {
173
            usbMeter.btSerial.connectionClosed()
174
        } else {
175
            track("Failed to connect to unknown meter with UUID: '\(peripheral.identifier)'")
176
        }
177
    }
Bogdan Timofte authored 2 weeks ago
178
}
179

            
180
private class AdvertisementDataCache {
181

            
Bogdan Timofte authored 2 weeks ago
182
    private var map = [UUID: [String: Any]]()
Bogdan Timofte authored 2 weeks ago
183

            
184
    func append(peripheral: CBPeripheral, advertisementData: [String: Any]) -> [String: Any] {
185
        var ad = (map[peripheral.identifier]) ?? [String: Any]()
Bogdan Timofte authored 2 weeks ago
186
        if let localName = peripheral.name?.trimmingCharacters(in: .whitespacesAndNewlines), !localName.isEmpty {
187
            ad[CBAdvertisementDataLocalNameKey] = localName
188
        }
Bogdan Timofte authored 2 weeks ago
189
        for (key, value) in advertisementData {
190
            ad[key] = value
191
        }
192
        map[peripheral.identifier] = ad
193
        return ad
194
    }
195

            
196
    func clear() {
197
        map.removeAll()
198
    }
199
}