meshtastic/Meshtastic-Apple
1
0
Fork 0
mirror of https://github.com/meshtastic/Meshtastic-Apple.git synced 2026-04-20 22:13:56 +00:00
Code Issues Projects Releases Packages Wiki Activity

Queue for peripherals

Browse source
This commit is contained in:
Garth Vander Houwen 2025-11-05 16:21:10 -08:00
parent 872c1ef7ee
commit 0f90d8497a
1 changed files with 31 additions and 19 deletions
Download patch file Download diff file Expand all files Collapse all files

50
Meshtastic/Accessory/Transports/Bluetooth Low Energy/BLETransport.swift
View file

@ -164,27 +164,39 @@ class BLETransport: Transport {
}
}
private let peripheralsQueue = DispatchQueue(label: "com.meshtastic.peripheralAccess", qos: .default)
func didDiscover(peripheral: CBPeripheral, rssi: NSNumber) {
guard !restoreInProgress else { return }
let id = peripheral.identifier
let isNew = discoveredPeripherals[id] == nil
if isNew {
discoveredPeripherals[id] = (peripheral, Date())
}
let device = Device(id: id,
name: peripheral.name ?? "Unknown",
transportType: .ble,
identifier: id.uuidString,
rssi: rssi.intValue)
if isNew {
Logger.transport.debug("🛜 [BLE] Did Discover new device: \(peripheral.name ?? "Unknown", privacy: .public) (\(peripheral.identifier, privacy: .public))")
discoveredDeviceContinuation?.yield(.deviceFound(device))
} else {
let rssiVal = rssi.intValue
let deviceId = id
discoveredPeripherals[id]?.lastSeen = Date()
discoveredDeviceContinuation?.yield(.deviceReportedRssi(deviceId, rssiVal))
// Use the queue to ensure thread-safe access to the dictionary
peripheralsQueue.async {
let id = peripheral.identifier
let isNew = self.discoveredPeripherals[id] == nil
// Update the dictionary
if isNew {
self.discoveredPeripherals[id] = (peripheral, Date())
} else {
self.discoveredPeripherals[id]?.lastSeen = Date()
}
let device = Device(id: id,
name: peripheral.name ?? "Unknown",
transportType: .ble,
identifier: id.uuidString,
rssi: rssi.intValue)
// Safely yield results
if isNew {
Logger.transport.debug("🛜 [BLE] Did Discover new device: \(peripheral.name ?? "Unknown", privacy: .public) (\(peripheral.identifier, privacy: .public))")
self.discoveredDeviceContinuation?.yield(.deviceFound(device))
} else {
let rssiVal = rssi.intValue
let deviceId = id
self.discoveredDeviceContinuation?.yield(.deviceReportedRssi(deviceId, rssiVal))
}
}
}