USB-Meter / USB Meter / Model / BluetoothManager.swift
Newer Older
204 lines | 8.173kb
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
        }
Bogdan Timofte authored 2 weeks ago
58

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

            
Bogdan Timofte authored 2 weeks ago
63
        let macAddress = MACAddress(from: manufacturerData.suffix(from: 2))
Bogdan Timofte authored 2 weeks ago
64
        appData.registerMeterDiscovery(
65
            macAddress: macAddress.description,
66
            modelType: "\(model)",
67
            peripheralName: peripheralName
68
        )
69

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

            
85
    private func resolvedPeripheralName(for peripheral: CBPeripheral, advertising advertismentData: [String : Any]) -> String? {
86
        let candidates = [
87
            (advertismentData[CBAdvertisementDataLocalNameKey] as? String),
88
            peripheral.name
89
        ]
90

            
91
        for candidate in candidates {
92
            if let trimmed = candidate?.trimmingCharacters(in: .whitespacesAndNewlines), !trimmed.isEmpty {
93
                return trimmed
Bogdan Timofte authored 2 weeks ago
94
            }
95
        }
Bogdan Timofte authored 2 weeks ago
96

            
97
        return nil
98
    }
99

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

            
111
extension BluetoothManager : CBCentralManagerDelegate {
112
    // MARK:  CBCentralManager state Changed
113
    func centralManagerDidUpdateState(_ central: CBCentralManager) {
114
        managerState = central.state;
115
        track("\(central.state)")
116

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

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

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

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

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

            
185
private class AdvertisementDataCache {
186

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

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

            
201
    func clear() {
202
        map.removeAll()
203
    }
204
}