【2026 最新】Claude 找手機怎麼做？Bluetooth RSSI 從一句需求變成可用工具

import AudioToolbox
import CoreBluetooth
import Dispatch
import Foundation

struct Options {
    var survey = false
    var name: String?
    var id: UUID?
    var service: CBUUID?
    var sound = false
    var timeout: TimeInterval = 120

    static func parse(_ args: [String]) throws -> Options {
        enum ParseError: Error, CustomStringConvertible {
            case message(String)
            var description: String {
                switch self { case let .message(text): return text }
            }
        }
        var result = Options()
        var index = 0
        var timeoutWasSet = false
        func value(after flag: String) throws -> String {
            guard index + 1 < args.count, !args[index + 1].hasPrefix("-") else {
                throw ParseError.message("\(flag) 後面缺少值")
            }
            index += 1
            return args[index]
        }
        func isValidServiceUUID(_ text: String) -> Bool {
            let shortLengths = [4, 8]
            let hex = CharacterSet(charactersIn: "0123456789abcdefABCDEF")
            let isShort = shortLengths.contains(text.count)
                && text.unicodeScalars.allSatisfy { hex.contains($0) }
            return isShort || UUID(uuidString: text) != nil
        }
        while index < args.count {
            switch args[index] {
            case "--survey":
                guard !result.survey else { throw ParseError.message("--survey 不可重複") }
                result.survey = true
            case "--name":
                guard result.name == nil else { throw ParseError.message("--name 不可重複") }
                let text = try value(after: "--name")
                guard !text.trimmingCharacters(in: .whitespacesAndNewlines).isEmpty else {
                    throw ParseError.message("--name 不可為空")
                }
                result.name = text
            case "--id":
                guard result.id == nil else { throw ParseError.message("--id 不可重複") }
                let text = try value(after: "--id")
                guard let uuid = UUID(uuidString: text) else { throw ParseError.message("--id 不是有效 UUID") }
                result.id = uuid
            case "--service":
                guard result.service == nil else { throw ParseError.message("--service 不可重複") }
                let text = try value(after: "--service")
                guard isValidServiceUUID(text) else {
                    throw ParseError.message("--service 不是有效 UUID")
                }
                result.service = CBUUID(string: text)
            case "--sound":
                guard !result.sound else { throw ParseError.message("--sound 不可重複") }
                result.sound = true
            case "--timeout":
                guard !timeoutWasSet else { throw ParseError.message("--timeout 不可重複") }
                let text = try value(after: "--timeout")
                guard let seconds = TimeInterval(text), (3 ... 3600).contains(seconds) else {
                    throw ParseError.message("--timeout 必須是 3 到 3600 秒")
                }
                result.timeout = seconds
                timeoutWasSet = true
            case "-h", "--help":
                print(usage)
                exit(0)
            default: throw ParseError.message("不認得的參數：\(args[index])")
            }
            index += 1
        }
        let selectors = [result.name != nil, result.id != nil, result.service != nil].filter { $0 }.count
        if result.survey && (selectors > 0 || result.sound) {
            throw ParseError.message("--survey 不和目標條件或 --sound 混用")
        }
        if !result.survey && selectors != 1 {
            throw ParseError.message("追蹤模式請且只請提供 --name、--id 或 --service 其中一個")
        }
        return result
    }
}

let usage = """
用法：
  blefinder --survey [--timeout 15]
  blefinder --name "廣播名稱的一部分" [--sound] [--timeout 120]
  blefinder --id UUID [--sound] [--timeout 120]
  blefinder --service UUID [--sound] [--timeout 120]

先用 --survey 確認目標真的有在廣播；名稱與 UUID 都只是選擇線索，不是身分證明。
"""

final class Clicker: @unchecked Sendable {
    private var soundID: SystemSoundID = 0
    private var timer: Timer?
    private var rssi: Int?

    init?() {
        let path = "/System/Library/Sounds/Tink.aiff"
        guard FileManager.default.fileExists(atPath: path),
              AudioServicesCreateSystemSoundID(URL(fileURLWithPath: path) as CFURL, &soundID) == kAudioServicesNoError
        else { return nil }
    }

    func update(_ rssi: Int?) {
        self.rssi = rssi
        if timer == nil { schedule() }
    }

    func stop() {
        timer?.invalidate()
        timer = nil
        rssi = nil
        AudioServicesDisposeSystemSoundID(soundID)
    }

    private func schedule() {
        let interval: TimeInterval
        if let rssi {
            let fraction = min(1, max(0, (Double(rssi) + 95) / 45))
            interval = 1.0 - fraction * 0.88
        } else {
            interval = 1.0
        }
        timer = Timer.scheduledTimer(withTimeInterval: interval, repeats: false) { [weak self] _ in
            guard let self else { return }
            self.timer = nil
            if self.rssi != nil { AudioServicesPlaySystemSound(self.soundID) }
            self.schedule()
        }
    }
}

final class Finder: NSObject, CBCentralManagerDelegate, @unchecked Sendable {
    private let options: Options
    private var central: CBCentralManager!
    private var timeoutTimer: Timer?
    private var statusTimer: Timer?
    private var filter = SignalFilter()
    private var foundTarget = false
    private var selectedID: UUID?
    private var lastTrend = Trend.learning
    private var clicker: Clicker?
    private var seen: Set<UUID> = []
    private var stopped = false

    init(options: Options) {
        self.options = options
        if options.sound { clicker = Clicker() }
        super.init()
        if options.sound && clicker == nil {
            FileHandle.standardError.write(Data("警告：無法建立提示音，仍會繼續顯示文字。\n".utf8))
        }
    }

    func start() {
        print(options.survey ? "掃描附近 BLE 廣播…" : "等待目標廣播…")
        central = CBCentralManager(delegate: self, queue: .main)
        timeoutTimer = Timer.scheduledTimer(withTimeInterval: options.timeout, repeats: false) { [weak self] _ in
            guard let self else { return }
            if self.options.survey {
                self.finish(code: 0, message: "盤點時間結束，共看見 \(self.seen.count) 個廣播來源。")
            } else {
                self.finish(code: self.foundTarget ? 0 : 5,
                            message: self.foundTarget ? "已到達安全時限，停止掃描。" : "時限內沒有看見目標。")
            }
        }
        statusTimer = Timer.scheduledTimer(withTimeInterval: 1, repeats: true) { [weak self] _ in
            self?.reportStatus()
        }
    }

    func stopForSignal(_ label: String) {
        finish(code: 0, message: "收到 \(label)，已停止掃描。")
    }

    func centralManagerDidUpdateState(_ central: CBCentralManager) {
        switch central.state {
        case .poweredOn:
            let services = options.service.map { [$0] }
            central.scanForPeripherals(
                withServices: services,
                options: [CBCentralManagerScanOptionAllowDuplicatesKey: true])
        case .unauthorized:
            finish(code: 3, message: "藍牙權限遭拒。請到「系統設定 → 隱私權與安全性 → 藍牙」允許目前的終端程式。")
        case .poweredOff:
            finish(code: 3, message: "藍牙目前關閉。")
        case .unsupported:
            finish(code: 4, message: "這台 Mac 不支援 CoreBluetooth。")
        case .resetting:
            print("藍牙正在重設，等待系統恢復…")
        case .unknown:
            break
        @unknown default:
            finish(code: 4, message: "遇到未知的藍牙狀態。")
        }
    }

    func centralManager(_ central: CBCentralManager,
                        didDiscover peripheral: CBPeripheral,
                        advertisementData: [String: Any],
                        rssi RSSI: NSNumber) {
        let raw = RSSI.intValue
        guard (-127 ... 20).contains(raw) else { return }
        let localName = advertisementData[CBAdvertisementDataLocalNameKey] as? String
        let displayName = localName ?? peripheral.name

        if options.survey {
            if seen.insert(peripheral.identifier).inserted {
                let name = displayName ?? "（未提供名稱）"
                print("\(peripheral.identifier.uuidString)  RSSI \(raw) dBm  \(name)")
            }
            return
        }

        let matches: Bool
        if let id = options.id {
            matches = peripheral.identifier == id
        } else if let query = options.name {
            matches = displayName?.localizedCaseInsensitiveContains(query) == true
        } else {
            matches = true // scan itself is filtered by the requested service UUID
        }
        guard matches else { return }

        if let selectedID {
            guard peripheral.identifier == selectedID else { return }
        } else {
            selectedID = peripheral.identifier
            let name = displayName ?? "（未提供名稱）"
            print("已鎖定本次掃描的第一個相符來源：\(name)")
        }

        foundTarget = true
        filter.add(rssi: raw, at: Date().timeIntervalSinceReferenceDate)
    }

    private func reportStatus() {
        guard !options.survey else { return }
        let now = Date().timeIntervalSinceReferenceDate
        guard filter.isFresh(now: now), let smooth = filter.latestSmoothed() else {
            clicker?.update(nil)
            if foundTarget { print("訊號逾時：先停下來，等待新封包。") }
            return
        }
        let trend = filter.trend(now: now)
        let changed = trend != lastTrend
        lastTrend = trend
        print("平滑 RSSI \(smooth) dBm｜\(trend.rawValue)\(changed ? "" : "（持續）")")
        clicker?.update(smooth)
    }

    private func finish(code: Int32, message: String) {
        guard !stopped else { return }
        stopped = true
        central?.stopScan()
        timeoutTimer?.invalidate()
        statusTimer?.invalidate()
        clicker?.stop()
        print(message)
        fflush(stdout)
        exit(code)
    }
}

do {
    let options = try Options.parse(Array(CommandLine.arguments.dropFirst()))
    let finder = Finder(options: options)

    signal(SIGINT, SIG_IGN)
    signal(SIGTERM, SIG_IGN)
    let sigint = DispatchSource.makeSignalSource(signal: SIGINT, queue: .main)
    sigint.setEventHandler { finder.stopForSignal("Ctrl-C") }
    sigint.resume()
    let sigterm = DispatchSource.makeSignalSource(signal: SIGTERM, queue: .main)
    sigterm.setEventHandler { finder.stopForSignal("SIGTERM") }
    sigterm.resume()

    finder.start()
    RunLoop.main.run()
} catch {
    FileHandle.standardError.write(Data("參數錯誤：\(error)\n\n\(usage)\n".utf8))
    exit(2)
}

import XCTest
@testable import blefinder

final class SignalFilterTests: XCTestCase {
    func testRejectsInvalidRSSIAndSmoothsSpikeWithMedian() {
        var filter = SignalFilter()
        for (time, value) in [(-4.0, -70), (-3.0, -69), (-2.0, -25), (-1.0, -71), (0.0, -70)] {
            filter.add(rssi: value, at: time)
        }
        filter.add(rssi: 127, at: 0)
        filter.add(rssi: -128, at: 0)
        filter.add(rssi: 21, at: 0)
        XCTAssertEqual(filter.smoothed(now: 0), -70)
        XCTAssertEqual(filter.samples.count, 5)
    }

    func testAcceptsFullBluetoothRSSIRange() {
        var filter = SignalFilter()
        filter.add(rssi: -127, at: 0)
        filter.add(rssi: 0, at: 1)
        filter.add(rssi: 20, at: 2)
        XCTAssertEqual(filter.samples.map(\.rssi), [-127, 0, 20])
        XCTAssertEqual(filter.smoothed(now: 2), 0)
    }

    func testWarmerAndColderUseTwoWindows() {
        var warmer = SignalFilter()
        for t in 0 ..< 6 { warmer.add(rssi: -78 + (t % 2), at: Double(t)) }
        for t in 7 ..< 12 { warmer.add(rssi: -62 + (t % 2), at: Double(t)) }
        XCTAssertEqual(warmer.trend(now: 11), .warmer)

        var colder = SignalFilter()
        for t in 0 ..< 6 { colder.add(rssi: -55 + (t % 2), at: Double(t)) }
        for t in 7 ..< 12 { colder.add(rssi: -75 + (t % 2), at: Double(t)) }
        XCTAssertEqual(colder.trend(now: 11), .colder)
    }

    func testSteadyLearningAndStale() {
        var filter = SignalFilter()
        filter.add(rssi: -65, at: 0)
        XCTAssertEqual(filter.trend(now: 0), .learning)
        XCTAssertTrue(filter.isFresh(now: 8))
        XCTAssertFalse(filter.isFresh(now: 8.01))

        for t in 1 ..< 12 { filter.add(rssi: -65 + (t % 2), at: Double(t)) }
        XCTAssertEqual(filter.trend(now: 11), .steady)
    }

    func testLatestMedianPersistsUntilEightSecondStaleBoundary() {
        var filter = SignalFilter()
        filter.add(rssi: -65, at: 0)
        XCTAssertNil(filter.smoothed(now: 4.1))
        XCTAssertEqual(filter.latestSmoothed(), -65)
        XCTAssertTrue(filter.isFresh(now: 7.9))
        XCTAssertFalse(filter.isFresh(now: 8.01))
    }

    func testParserRejectsCrashingAndAmbiguousInputs() {
        XCTAssertThrowsError(try Options.parse(["--service", "not-a-uuid"]))
        XCTAssertThrowsError(try Options.parse(["--service", ""]))
        XCTAssertThrowsError(try Options.parse(["--name", "--sound", "--timeout", "3"]))
        XCTAssertThrowsError(try Options.parse(["--name", ""]))
        XCTAssertThrowsError(try Options.parse(["--name", "phone", "--name", "watch"]))
        XCTAssertThrowsError(try Options.parse(["--survey", "--sound"]))
        XCTAssertNoThrow(try Options.parse(["--service", "180D"]))
        XCTAssertNoThrow(try Options.parse(["--service", "12345678-1234-1234-1234-1234567890AB"]))
    }
}