firmware_wio_tracker_l1_console/

main.rs

// Seeed Wio Tracker L1 / L1 Pro bringup firmware with an interactive
// UMSH CLI on USB-CDC.
//
// Boot sequence:
//   1. Initialize the 8 KiB global heap (umsh-cli/umsh-node alloc usage).
//   2. Arm the watchdog (8 s timeout).
//   3. Read any panic message left by the previous boot.
//   4. Initialize the SH1106 OLED and spawn the display task.
//   5. Initialize the SX1262 LoRa radio and spawn the radio runner task.
//   6. Build Mac<WioTrackerPlatform>, park it in a 'static AsyncRefCell, and
//      spawn umsh_task which drives Host::run + CliSession::run concurrently
//      over the shared MacHandle.
//   7. Spawn output_task to own the USB Sender and drain OUTPUT_CH.
//   8. Join usb.run / heartbeat in main; the CLI runs in spawned tasks.
//
// Task layout (steady state):
//   - main():              joins usb.run / heartbeat
//   - display_task:        renders the OLED on boot and MAC count signals
//   - radio_runner_task:   owns lora_phy::LoRa, RX/TX state machine
//   - umsh_task:           host.run() + cli.run(), shares MAC via MacHandle
//   - output_task:         owns the USB Sender, drains OUTPUT_CH
//
// USB CDC flow control is preserved by the output_task / OUTPUT_CH split:
// nothing blocks CdcInput::read_packet on TX progress, so the host's bulk
// OUT NAK / retry mechanism handles backpressure correctly during pastes.
//
// Radio pin map (Wio Tracker L1):
//   SPI:  SCK=P0.30, MISO=P0.03, MOSI=P0.28  (TWISPI1)
//   CS=P1.14, RST=P1.07, BUSY=P1.10, DIO1=P0.07
//   RXEN=P1.08 → rf_switch_rx (lora-phy drives HIGH in RX, LOW in TX)
//   DIO2: internal RF switch (lora-phy SetDIO2AsRfSwitchCtrl)
//   DIO3: 1.8 V TCXO

#![cfg_attr(target_os = "none", no_std)]
#![cfg_attr(target_os = "none", no_main)]

#[cfg(not(target_os = "none"))]
fn main() {}

#[cfg(target_os = "none")]
mod panic;

#[cfg(target_os = "none")]
use umsh_bsp_wio_tracker_l1::display;

#[cfg(target_os = "none")]
mod cli_io;

#[cfg(target_os = "none")]
mod defmt_logger {
    #[defmt::global_logger]
    struct Logger;
    unsafe impl defmt::Logger for Logger {
        fn acquire() {}
        unsafe fn flush() {}
        unsafe fn release() {}
        unsafe fn write(_: &[u8]) {}
    }
    defmt::timestamp!("{=u32}", 0u32);
}

// Global heap allocator. umsh-mac → umsh-sync → alloc requires this even
// though runtime allocation is near-zero (we use Mac::run, not MacHandle).
#[cfg(target_os = "none")]
#[global_allocator]
static ALLOCATOR: embedded_alloc::Heap = embedded_alloc::Heap::empty();

#[cfg(target_os = "none")]
mod firmware {
    use core::sync::atomic::{AtomicU32, Ordering};

    use super::display;

    use embassy_executor::Spawner;
    use embassy_futures::join::join;
    use embassy_nrf::bind_interrupts;
    use embassy_nrf::gpio::{Input, Level, Output, OutputDrive, Pull};
    use embassy_nrf::nvmc::Nvmc;
    use embassy_nrf::peripherals;
    use embassy_nrf::spim::{Config as SpimConfig, Frequency, Spim};
    use embassy_nrf::twim::{self, Config as TwimConfig, Twim};
    use embassy_nrf::usb::Driver;
    use embassy_nrf::usb::vbus_detect::HardwareVbusDetect;
    use embassy_nrf::wdt::{Config as WdtConfig, Watchdog, WatchdogHandle};
    use embassy_sync::blocking_mutex::raw::ThreadModeRawMutex;
    use embassy_sync::signal::Signal;
    use embassy_time::{Delay, Instant, Timer};
    use embassy_usb::class::cdc_acm::{CdcAcmClass, Sender, State};
    use embassy_usb::{Builder, Config};
    use embedded_hal_bus::spi::ExclusiveDevice;
    use lora_phy::LoRa;
    use lora_phy::iv::GenericSx126xInterfaceVariant;
    use lora_phy::mod_params::{Bandwidth, ModulationParams, PacketParams, SpreadingFactor};
    use lora_phy::sx126x::{Config as LoraConfig, Sx126x, Sx1262, TcxoCtrlVoltage};
    use static_cell::StaticCell;
    use umsh_bsp_nrf52840::cdc_rescue::CdcAcmRescue;
    use umsh_bsp_nrf52840::flash_store;
    use umsh_bsp_nrf52840::flash_store::{
        NvmcChannelStore, NvmcCounterStore, NvmcPeerStore, NvmcStorage,
    };
    use umsh_bsp_nrf52840::panic_persist::PanicSlot;
    use umsh_bsp_nrf52840::{EmbassyClock, Nrf52840Rng};
    use umsh_bsp_wio_tracker_l1::{PowerSignaler, WioMac, WioTrackerPlatform};
    use umsh_core::{ChannelKey, PayloadType, PublicKey};
    use umsh_crypto::{
        CryptoEngine, NodeIdentity,
        software::{SoftwareAes, SoftwareIdentity, SoftwareSha256},
    };
    use umsh_mac::{LocalIdentityId, MacHandle, OperatingPolicy, RepeaterConfig};
    use umsh_node::{Channel, Host, LocalNode};
    use umsh_sync::AsyncRefCell;

    use super::cli_io;
    use umsh_ux_tracker::led::{LedEngine, LedTimings};

    bind_interrupts!(struct Irqs {
        USBD        => embassy_nrf::usb::InterruptHandler<peripherals::USBD>;
        CLOCK_POWER => embassy_nrf::usb::vbus_detect::InterruptHandler;
        TWISPI0     => embassy_nrf::twim::InterruptHandler<peripherals::TWISPI0>;
        TWISPI1     => embassy_nrf::spim::InterruptHandler<peripherals::TWISPI1>;
    });

    // ─── Configuration ───────────────────────────────────────────────────────

    const TX_POWER_DBM: i32 = 14;

    // ─── Concrete types ───────────────────────────────────────────────────────

    type RadioSpiBus = ExclusiveDevice<Spim<'static>, Output<'static>, Delay>;
    type RadioIv = GenericSx126xInterfaceVariant<Output<'static>, Input<'static>>;
    type RadioKind = Sx126x<RadioSpiBus, RadioIv, Sx1262>;
    type LoraRadio = LoRa<RadioKind, Delay>;

    // Host/node aliases (need `umsh-node`, which the BSP doesn't pull in, so the
    // firmware owns them). Const params match `WioMac`'s capacities.
    /// Host bound to the `'static` mac_cell. Owned by `mac_task`.
    type WioHost = Host<MacHandle<'static, WioTrackerPlatform, 2, 8, 4, 4, 8, 255, 32>>;
    /// LocalNode handle. Cheap to clone — passed to `cli_task`.
    type WioNode = LocalNode<MacHandle<'static, WioTrackerPlatform, 2, 8, 4, 4, 8, 255, 32>>;

    // ─── Platform types ───────────────────────────────────────────────────────
    //
    // `WioTrackerPlatform`, `WioMac`, the embassy-backed clock, and the
    // hardware-TRNG RNG live in `umsh-bsp-wio-tracker-l1` (which composes
    // the chip-level pieces from `umsh-bsp-nrf52840`).

    // ─── Concrete USB driver type aliases ────────────────────────────────────
    // ('static lifetime, VbusDetect = HardwareVbusDetect.) Used by `umsh_task`
    // and `output_task`.
    type WioUsbDriver = Driver<'static, HardwareVbusDetect>;
    type WioSender = Sender<'static, WioUsbDriver>;
    type WioRescue = CdcAcmRescue<'static, WioUsbDriver>;

    // ─── Shared state ────────────────────────────────────────────────────────

    type RadioCh = umsh_radio_loraphy::Channels<ThreadModeRawMutex, 4, 2>;
    static RADIO_CH: RadioCh = RadioCh::new();

    static PACKET_COUNT: AtomicU32 = AtomicU32::new(0);
    static DISPLAY_SIGNAL: Signal<ThreadModeRawMutex, ()> = Signal::new();

    /// Shared MAC coordinator cell. Stored in a `StaticCell` so a `'static`
    /// reference can be handed to the spawned `umsh_task` (which builds
    /// `MacHandle` / `Host` / `CliSession` off of it). The cell itself is
    /// `Send` (since `WioMac: Send`); `MacHandle` and `CliSession` are `!Send`
    /// but that's fine — Embassy's local `Spawner::spawn` accepts `!Send`
    /// tasks (only `SendSpawner` requires `Send`).
    static MAC_CELL: StaticCell<AsyncRefCell<WioMac>> = StaticCell::new();
    static STORAGE: StaticCell<NvmcStorage> = StaticCell::new();

    /// Relay from the sync `on_receive` callback to the async
    /// `identity_persist_task`. Carries (pk, payload_body, len).
    static IDENTITY_SIGNAL: Signal<ThreadModeRawMutex, ([u8; 32], [u8; 256], usize)> =
        Signal::new();

    // ─── Tasks ───────────────────────────────────────────────────────────────

    #[embassy_executor::task]
    async fn display_task(i2c: Twim<'static>) {
        use embedded_graphics::Drawable;
        use embedded_graphics::geometry::Point;
        use embedded_graphics::mono_font::MonoTextStyle;
        use embedded_graphics::mono_font::ascii::FONT_6X10;
        use embedded_graphics::pixelcolor::BinaryColor;
        use embedded_graphics::text::{Baseline, Text};
        use heapless::String;

        let mut oled = display::Sh1106::new(i2c);
        oled.init().await;

        let sha = env!("GIT_SHORT_SHA");
        let style = MonoTextStyle::new(&FONT_6X10, BinaryColor::On);

        let render = |fb: &mut display::Sh1106Fb, count: u32| {
            fb.clear();
            let _ = Text::with_baseline("UMSH bringup", Point::new(0, 0), style, Baseline::Top)
                .draw(fb);
            let _ = Text::with_baseline(sha, Point::new(0, 16), style, Baseline::Top).draw(fb);
            let mut s: String<16> = String::new();
            let _ = core::fmt::write(&mut s, format_args!("MAC: {}", count));
            let _ = Text::with_baseline(&s, Point::new(0, 32), style, Baseline::Top).draw(fb);
        };

        let mut fb = display::Sh1106Fb::new();
        render(&mut fb, 0);
        oled.flush(&fb).await;

        loop {
            DISPLAY_SIGNAL.wait().await;
            let count = PACKET_COUNT.load(Ordering::Relaxed);
            render(&mut fb, count);
            oled.flush(&fb).await;
        }
    }

    #[embassy_executor::task]
    async fn radio_runner_task(
        lora: LoraRadio,
        mdltn: ModulationParams,
        rx_pkt: PacketParams,
        tx_pkt: PacketParams,
    ) {
        umsh_radio_loraphy::runner(lora, &RADIO_CH, mdltn, rx_pkt, tx_pkt, TX_POWER_DBM, None)
            .await;
    }

    // `PowerSignaler` lives in `umsh-bsp-wio-tracker-l1::power`. The L1's
    // `request_power_off` is currently a no-op (mechanical power switch);
    // see the BSP module's TODO if/when soft poweroff is needed.

    // ─── umsh_task (CliSession-backed CLI + MAC driver) ─────────────────────

    /// Drains `IDENTITY_SIGNAL` and persists received `NodeIdentityPayload`
    /// bytes for known peers.
    #[embassy_executor::task]
    async fn identity_persist_task(storage: &'static NvmcStorage) {
        loop {
            let (pk, payload, len) = IDENTITY_SIGNAL.wait().await;
            if storage.peer_exists(&pk).await.unwrap_or(false) {
                let _ = storage.update_peer_identity(&pk, &payload[..len]).await;
            }
        }
    }

    /// Owns the USB `Sender` and serves the static `OUTPUT_CH`. Decoupling
    /// the sender from `umsh_task` lets RX keep flowing while TX awaits host
    /// IN polls, so USB OUT NAKs handle backpressure from the host correctly
    /// during long pastes.
    #[embassy_executor::task]
    async fn output_task(mut tx: WioSender) {
        cli_io::drain_to_sender(&mut tx).await;
    }

    /// Drives the MAC coordinator and owns the identity-relay subscription.
    /// Independent of USB so radio RX/TX and the MAC pump (including ping
    /// auto-replies) keep running whether or not a host terminal is attached.
    #[embassy_executor::task]
    async fn mac_task(mut host: WioHost, identity_id: LocalIdentityId) {
        // Subscribe to raw packets so NodeIdentity payloads from known peers
        // can be relayed to identity_persist_task for durable storage.
        let sub_node = host.node(identity_id).expect("node just added");
        let _identity_sub = sub_node.on_receive(|pkt| {
            if pkt.payload_type() != PayloadType::NodeIdentity {
                return false;
            }
            let Some(from) = pkt.from_key() else {
                return false;
            };
            let raw = pkt.payload();
            let len = raw.len().min(256);
            let mut buf = [0u8; 256];
            buf[..len].copy_from_slice(&raw[..len]);
            IDENTITY_SIGNAL.signal((from.0, buf, len));
            false
        });

        let _ = host.run().await;
        panic!("host exited");
    }

    /// Runs the `CliSession` over USB-CDC. The only task that blocks on a host
    /// terminal connection — the radio, MAC pump, and identity relay all run
    /// without it.
    #[embassy_executor::task]
    async fn cli_task(
        node: WioNode,
        local_key: PublicKey,
        storage: &'static NvmcStorage,
        rx: WioRescue,
        prev_panic_buf: &'static [u8; 256],
        prev_panic_len: usize,
    ) {
        use umsh_cli::CliSession;
        use umsh_cli::io::CliOutput;
        use umsh_cli::logger::NullLogger;

        let mut input = cli_io::CdcInput::new(rx);
        let mut out = cli_io::CdcOutput::new();

        // Wait for the host to open the CDC port before writing the banner —
        // otherwise the writes silently disappear into a closed IN endpoint.
        input.wait_connection().await;

        let _ = out.write_line("").await;
        let _ = out.write_line("UMSH CLI (Wio Tracker L1)").await;
        let _ = out.write_line("type /help for commands").await;
        if prev_panic_len > 0 {
            let _ = out.write_line("[PREV PANIC]:").await;
            if let Ok(s) = core::str::from_utf8(&prev_panic_buf[..prev_panic_len]) {
                let _ = out.write_line(s).await;
            }
        }

        let peer_store = NvmcPeerStore::new(storage);
        let channel_store = NvmcChannelStore::new(storage);
        let mut cli: CliSession<_, _, _, _, _, _, 4, 4, 2, 8, 128> = CliSession::new(
            node,
            local_key,
            out,
            NullLogger::new(),
            peer_store,
            channel_store,
            PowerSignaler,
        );

        // `run` loads peers/channels from storage and registers them with the
        // MAC (idempotent) and the CLI display tables before entering the loop.
        let _ = cli.run(&mut input).await;
        panic!("cli exited");
    }

    // ─── Main ────────────────────────────────────────────────────────────────

    #[embassy_executor::main]
    async fn main(spawner: Spawner) {
        // Heap must be initialized before any alloc-using code runs.
        // Bumped from 4 KiB to 8 KiB to accommodate umsh-cli alloc (command parse errors,
        // subscription vecs, etc.) without embedded-alloc OOM.
        {
            use core::mem::MaybeUninit;
            const HEAP_SIZE: usize = 8192;
            static mut HEAP: [MaybeUninit<u8>; HEAP_SIZE] = [MaybeUninit::uninit(); HEAP_SIZE];
            unsafe { crate::ALLOCATOR.init(core::ptr::addr_of!(HEAP) as usize, HEAP_SIZE) }
        }

        let p = embassy_nrf::init(umsh_bsp_nrf52840::clocks::default_config());

        let mut wdt_config = WdtConfig::default();
        wdt_config.timeout_ticks = 32768 * 8;
        let (_wdt, [wdt_handle]) =
            Watchdog::try_new::<_, 1>(p.WDT, wdt_config).unwrap_or_else(|_| panic!("wdt"));

        // Panic message from previous boot — stored in a StaticCell so cli_task
        // can hold a 'static reference to it without lifetime issues.
        static PREV_PANIC_BUF: StaticCell<[u8; 256]> = StaticCell::new();
        let mut prev_panic_tmp = [0u8; 256];
        let prev_panic_len = {
            let mut slot = PanicSlot::new(super::panic::panic_region());
            if let Some(msg) = slot.read() {
                let n = msg.len().min(prev_panic_tmp.len());
                prev_panic_tmp[..n].copy_from_slice(&msg[..n]);
                slot.clear();
                n
            } else {
                0
            }
        };
        let prev_panic_buf: &'static [u8; 256] = PREV_PANIC_BUF.init(prev_panic_tmp);

        // ── SH1106 OLED (TWIM0, SDA=P0.06, SCL=P0.05) ───────────────────────
        {
            static TWIM0_BUF: StaticCell<[u8; 256]> = StaticCell::new();
            let mut twim_cfg = TwimConfig::default();
            twim_cfg.frequency = twim::Frequency::K400;
            let i2c = Twim::new(
                p.TWISPI0,
                Irqs,
                p.P0_06,
                p.P0_05,
                twim_cfg,
                TWIM0_BUF.init([0; 256]),
            );
            spawner.spawn(display_task(i2c).unwrap());
        }

        // ── SX1262 LoRa radio (TWISPI1) ──────────────────────────────────────
        let t_frame_ms = umsh_radio_loraphy::airtime_ms(
            SpreadingFactor::_7,
            Bandwidth::_62KHz,
            umsh_radio_loraphy::MAX_PAYLOAD,
        );
        {
            let mut spi_cfg = SpimConfig::default();
            spi_cfg.frequency = Frequency::M16;
            let radio_bus = Spim::new(
                p.TWISPI1, Irqs, p.P0_30, // SCK
                p.P0_03, // MISO
                p.P0_28, // MOSI
                spi_cfg,
            );
            let radio_cs = Output::new(p.P1_14, Level::High, OutputDrive::Standard);
            let radio_spi = ExclusiveDevice::new(radio_bus, radio_cs, Delay).unwrap();

            let radio_rst = Output::new(p.P1_07, Level::High, OutputDrive::Standard);
            let radio_dio1 = Input::new(p.P0_07, Pull::None);
            let radio_busy = Input::new(p.P1_10, Pull::None);
            let radio_rxen = Output::new(p.P1_08, Level::Low, OutputDrive::Standard);

            let iv = GenericSx126xInterfaceVariant::new(
                radio_rst,
                radio_dio1,
                radio_busy,
                Some(radio_rxen), // rf_switch_rx: lora-phy drives HIGH in RX, LOW in TX
                None,             // rf_switch_tx: no separate TX enable
            )
            .unwrap();

            let lora_config = LoraConfig {
                chip: Sx1262,
                tcxo_ctrl: Some(TcxoCtrlVoltage::Ctrl1V8),
                use_dcdc: true,
                rx_boost: true,
            };

            let mut lora = LoRa::new(Sx126x::new(radio_spi, iv, lora_config), false, Delay)
                .await
                .unwrap_or_else(|_| panic!("radio init"));

            let (mdltn, rx_pkt, tx_pkt) = umsh_radio_loraphy::profile_params(
                &mut lora,
                umsh_radio_loraphy::profiles::DEFAULT,
                8,
            )
            .unwrap_or_else(|_| panic!("radio params"));

            spawner.spawn(radio_runner_task(lora, mdltn, rx_pkt, tx_pkt).unwrap());
        }

        // ── NV storage ────────────────────────────────────────────────────────
        let storage: &'static NvmcStorage =
            STORAGE.init(flash_store::new_storage(Nvmc::new(p.NVMC)));

        // ── MAC coordinator ───────────────────────────────────────────────────
        // The hardware-TRNG RNG built here is the single RNG path for this
        // firmware — used for first-boot identity generation AND passed
        // ownership-by-value into `Mac::new` below as `Platform::Rng`.
        //
        // Load identity from flash on subsequent boots; TRNG-generate on
        // first boot. We do NOT fall back to any PRNG on failure — a
        // predictable long-term key is worse than refusing to start.
        let mut rng = Nrf52840Rng::new(p.RNG);
        let sk_bytes: [u8; 32] = match storage.load_sk().await {
            Ok(Some(sk)) => sk,
            Ok(None) => {
                let mut sk = [0u8; 32];
                rng.fill_bytes(&mut sk);
                storage
                    .store_sk(&sk)
                    .await
                    .unwrap_or_else(|_| panic!("identity persist"));
                sk
            }
            Err(_) => panic!("storage init failed"),
        };
        let identity = SoftwareIdentity::from_secret_bytes(&sk_bytes);
        let local_key = *identity.public_key();

        let radio_handle = umsh_radio_loraphy::LoraphyRadio::new(&RADIO_CH, t_frame_ms);
        let crypto = CryptoEngine::new(SoftwareAes, SoftwareSha256);
        let mut mac = WioMac::new(
            radio_handle,
            crypto,
            EmbassyClock,
            rng,
            NvmcCounterStore::new(storage),
            RepeaterConfig::default(),
            OperatingPolicy::default(),
        );
        let identity_id = mac
            .add_identity(identity)
            .unwrap_or_else(|_| panic!("identity"));
        mac.load_persisted_counter(identity_id)
            .await
            .unwrap_or_else(|_| panic!("tx counter load"));

        // Hand ownership of the MAC to a 'static AsyncRefCell so `umsh_task`
        // can build MacHandle/Host/CliSession off of it.
        let mac_cell: &'static AsyncRefCell<WioMac> = MAC_CELL.init(AsyncRefCell::new(mac));

        // ── Host + node + boot-time peer/channel registration ─────────────────
        // Build the Host/node here so the MAC pump (`mac_task`) is independent
        // of USB, and register persisted peer/channel keys into the MAC now —
        // not from the CLI task, which only runs after a host opens the CDC
        // port. Without this the coordinator had no keys until a serial client
        // attached, so it couldn't authenticate inbound secure frames and
        // silently dropped every ping.
        let handle = MacHandle::new(mac_cell);
        let mut host: WioHost = Host::new(handle);
        let node = host.add_node(identity_id);

        {
            let mut peer_buf: heapless::Vec<([u8; 32], Option<heapless::String<16>>), 8> =
                heapless::Vec::new();
            let _ = storage.load_all_peers(&mut peer_buf).await;
            let mut ch_buf: heapless::Vec<(heapless::String<16>, [u8; 32]), 2> =
                heapless::Vec::new();
            let _ = storage.load_all_channels(&mut ch_buf).await;
            for (pk, _alias) in peer_buf.iter() {
                let _ = node.peer(PublicKey(*pk)).await;
            }
            for (name, key_bytes) in ch_buf.iter() {
                let channel = Channel::private(ChannelKey(*key_bytes), name.as_str());
                let _ = node.join(&channel).await;
            }
        }
        // Restore RX counter boundaries after peer registration so the persisted
        // boundaries land on registered peers.
        MacHandle::new(mac_cell)
            .load_all_persisted_rx_counters()
            .await
            .ok();

        // ── USB stack + steady-state services ────────────────────────────────
        let led = Output::new(p.P1_01, Level::Low, OutputDrive::Standard);
        let driver = Driver::new(p.USBD, Irqs, HardwareVbusDetect::new(Irqs));

        let mut config = Config::new(0x2886, 0x1667);
        config.manufacturer = Some("UMSH");
        config.product = Some("Seeed Wio Tracker L1 Bringup");
        config.serial_number = Some("wio-tracker-l1-console");
        config.max_power = 100;
        config.max_packet_size_0 = 64;

        static CONFIG_DESC: StaticCell<[u8; 256]> = StaticCell::new();
        static BOS_DESC: StaticCell<[u8; 256]> = StaticCell::new();
        static MSOS_DESC: StaticCell<[u8; 0]> = StaticCell::new();
        static CONTROL_BUF: StaticCell<[u8; 64]> = StaticCell::new();
        static STATE: StaticCell<State> = StaticCell::new();

        let mut builder = Builder::new(
            driver,
            config,
            CONFIG_DESC.init([0; 256]),
            BOS_DESC.init([0; 256]),
            MSOS_DESC.init([0; 0]),
            CONTROL_BUF.init([0; 64]),
        );

        let class = CdcAcmClass::new(&mut builder, STATE.init(State::new()), 64);
        let mut usb = builder.build();

        let (tx, raw_rx, ctrl) = class.split_with_control();
        let rx = CdcAcmRescue::new(raw_rx, ctrl);

        spawner.spawn(output_task(tx).unwrap());
        spawner.spawn(identity_persist_task(storage).unwrap());
        spawner.spawn(mac_task(host, identity_id).unwrap());
        spawner
            .spawn(cli_task(node, local_key, storage, rx, prev_panic_buf, prev_panic_len).unwrap());

        join(usb.run(), heartbeat(led, wdt_handle)).await;
    }

    // ─── Heartbeat ────────────────────────────────────────────────────────────

    async fn heartbeat(mut led: Output<'static>, mut wdt: WatchdogHandle) -> ! {
        let mut engine = LedEngine::new(LedTimings::default(), Instant::now().as_millis());
        loop {
            wdt.pet();
            let decision = engine.tick(Instant::now().as_millis());
            if decision.on {
                led.set_high()
            } else {
                led.set_low()
            }
            Timer::at(Instant::from_millis(decision.next_deadline_ms)).await;
        }
    }
}