Function test_configurable_notification_payload

tests/common/test_cases.rs:474–522

()

}

pub async fn test_configurable_notification_payload() {
    use futures::StreamExt;
    use std::time::Duration;
    use tokio::time;

    let peripheral = peripheral_finder::find_and_connect().await;
    peripheral_finder::reset_peripheral(&peripheral).await;
    let config_char =
        peripheral_finder::find_characteristic(&peripheral, gatt_uuids::CONFIGURABLE_NOTIFY);
    let control_point =
        peripheral_finder::find_characteristic(&peripheral, gatt_uuids::CONTROL_POINT);

    let mut cmd = vec![gatt_uuids::CMD_SET_NOTIFICATION_PAYLOAD];
    cmd.extend_from_slice(&[0xCA, 0xFE, 0xBA, 0xBE]);
    peripheral
        .write(&control_point, &cmd, btleplug::api::WriteType::WithResponse)
        .await
        .unwrap();

    let mut stream = peripheral.notifications().await.unwrap();
    peripheral.subscribe(&config_char).await.unwrap();
    peripheral_finder::send_control_command(&peripheral, gatt_uuids::CMD_START_NOTIFICATIONS).await;

    let timeout = time::sleep(Duration::from_secs(5));
    tokio::pin!(timeout);
    let mut matching = false;

    loop {
        tokio::select! {
            Some(n) = stream.next() => {
                if n.uuid == gatt_uuids::CONFIGURABLE_NOTIFY
                    && n.value == vec![0xCA, 0xFE, 0xBA, 0xBE]
                {
                    matching = true;
                    break;
                }
            }
            _ = &mut timeout => break,
        }
    }

    peripheral_finder::send_control_command(&peripheral, gatt_uuids::CMD_STOP_NOTIFICATIONS).await;
    peripheral.unsubscribe(&config_char).await.unwrap();
    assert!(
        matching,
        "Should receive notification with custom payload [0xCA, 0xFE, 0xBA, 0xBE]"
    );
    peripheral.disconnect().await.unwrap();
}

// ── Descriptors ─────────────────────────────────────────────────────