Camper-Monitor/CamperMonitorWatch/WatchLevelRadio.swift

import CoreBluetooth
import Foundation
import Observation

/// Die eigene Funkverbindung der Uhr zum Neigungsmesser.
///
/// Für dieses eine Gerät geht die Uhr direkt hin, statt über das iPhone. Das
/// ist genau dort möglich, wo es beim Rest nicht geht:
///
/// * Der Neigungsmesser **bewirbt seinen Dienst**. Die Uhr findet ihn also von
///   selbst und muss nichts eingerichtet bekommen – anders als BMS und
///   Kühlbox, die über die Kennung des Peripheriegeräts gesucht werden.
/// * Er ist **unverschlüsselt**. Es braucht keinen Victron-Schlüssel, der auf
///   der Uhr ein zweites Mal lagern müsste.
///
/// Damit ist die Nivellierung auf der Uhr eigenständig: kein geöffnetes iPhone,
/// keine Reichweite zum Telefon. Für alles andere bleibt der Weg über das
/// iPhone, siehe `PhoneLink`.
///
/// Gefunkt wird nur im Vordergrund. watchOS lässt eine App im Hintergrund
/// ohnehin kaum scannen, und beim Ausrichten schaut man auf die Uhr.
@Observable
final class WatchLevelRadio: NSObject {

    private(set) var state = LevelState()
    private(set) var link: DeviceLinkState = .idle
    /// Wann zuletzt ein Wert vom Sensor kam.
    private(set) var updatedAt: Date?
    private(set) var statusText = "Bluetooth wird gestartet…"

    /// Die Einbaulage des Sensors. Kommt vom iPhone und wird hier behalten,
    /// damit die Uhr auch ohne Telefon richtig rechnet – ohne sie stünden
    /// längs und quer je nach Einbau vertauscht oder mit falschem Vorzeichen.
    var orientation = SensorOrientation.identity {
        didSet {
            guard orientation != oldValue else { return }
            Self.store(orientation)
            let value = orientation
            queue.async { self.session?.orientation = value }
        }
    }

    private let queue = DispatchQueue(label: "de.fritob.CamperMonitor.watch.ble")
    private var central: CBCentralManager?
    private var peripheral: CBPeripheral?
    private var session: LevelSession?
    private var isRunning = false

    /// Kennung für die Momentaufnahmen dieser Sitzung. Auf der Uhr gibt es
    /// keine Geräteliste, in der sie nachgeschlagen würde – sie muss nur
    /// innerhalb eines Laufs gleich bleiben.
    private let deviceID = UUID()

    override init() {
        super.init()
        orientation = Self.storedOrientation()
    }

    // MARK: - Steuerung

    func start() {
        isRunning = true
        if central == nil {
            central = CBCentralManager(delegate: self, queue: queue)
        } else {
            queue.async { self.scanIfPossible() }
        }
    }

    func stop() {
        isRunning = false
        queue.async {
            self.central?.stopScan()
            self.session?.stop()
            if let peripheral = self.peripheral, peripheral.state != .disconnected {
                self.central?.cancelPeripheralConnection(peripheral)
            }
        }
        publish { self.link = .idle }
    }

    private func scanIfPossible() {
        guard isRunning, let central, central.state == .poweredOn else { return }
        if let peripheral, peripheral.state == .connected { return }
        central.scanForPeripherals(withServices: [LevelSession.serviceUUID])
        publish {
            self.link = .searching
            self.statusText = "Suche Neigungsmesser…"
        }
    }

    private func publish(_ work: @escaping () -> Void) {
        if Thread.isMainThread { work() } else { DispatchQueue.main.async(execute: work) }
    }

    // MARK: - Einbaulage merken

    private static let orientationKey = "sensorOrientation"

    private static func storedOrientation() -> SensorOrientation {
        guard let data = UserDefaults.standard.data(forKey: orientationKey),
              let value = try? JSONDecoder().decode(SensorOrientation.self, from: data)
        else { return .identity }
        return value
    }

    private static func store(_ orientation: SensorOrientation) {
        guard let data = try? JSONEncoder().encode(orientation) else { return }
        UserDefaults.standard.set(data, forKey: orientationKey)
    }
}

// MARK: - CBCentralManagerDelegate

extension WatchLevelRadio: CBCentralManagerDelegate {

    func centralManagerDidUpdateState(_ central: CBCentralManager) {
        switch central.state {
        case .poweredOn:
            scanIfPossible()
        case .unauthorized:
            publish {
                self.link = .failed("Bluetooth nicht erlaubt")
                self.statusText = "Bluetooth für die App erlauben"
            }
        case .poweredOff:
            publish {
                self.link = .failed("Bluetooth aus")
                self.statusText = "Bluetooth ist ausgeschaltet"
            }
        default:
            publish { self.statusText = "Bluetooth nicht verfügbar" }
        }
    }

    func centralManager(_ central: CBCentralManager,
                        didDiscover peripheral: CBPeripheral,
                        advertisementData: [String: Any],
                        rssi RSSI: NSNumber) {
        // Gesucht wird nach dem Dienst, nicht nach dem Namen: der lässt sich in
        // der Firmware ändern, die Dienstkennung nicht.
        central.stopScan()
        self.peripheral = peripheral
        central.connect(peripheral)
        publish {
            self.link = .connecting
            self.statusText = "Verbinde…"
        }
    }

    func centralManager(_ central: CBCentralManager, didConnect peripheral: CBPeripheral) {
        let session = LevelSession(
            deviceID: deviceID,
            peripheral: peripheral,
            queue: queue,
            onUpdate: { _ in },
            onStateChange: { [weak self] state in
                self?.publish { self?.link = state }
            },
            onLevelState: { [weak self] state in
                self?.publish {
                    self?.state = state
                    self?.updatedAt = Date()
                    self?.statusText = "Direkt am Sensor"
                }
            })
        session.orientation = orientation
        self.session = session
        session.start()
    }

    func centralManager(_ central: CBCentralManager,
                        didFailToConnect peripheral: CBPeripheral,
                        error: Error?) {
        publish { self.link = .failed(error?.localizedDescription ?? "Verbindung gescheitert") }
        scanIfPossible()
    }

    func centralManager(_ central: CBCentralManager,
                        didDisconnectPeripheral peripheral: CBPeripheral,
                        error: Error?) {
        session?.handleDisconnect()
        session = nil
        publish {
            // Die zuletzt gemessene Lage bleibt stehen; wie alt sie ist, steht
            // daneben. Sie wegzuwerfen hiesse, beim Rangieren mitten in der
            // Bewegung einen leeren Bildschirm zu zeigen.
            self.link = .searching
            self.statusText = "Verbindung verloren – suche erneut"
        }
        scanIfPossible()
    }
}