Skip to content

Commit ab7e751

Browse files
Ulf LilleengenDirbaio
Ulf Lilleengen
authored and
Dirbaio
committed
Update to rust-lorawan with afit support
1 parent 5bda7eb commit ab7e751

File tree

8 files changed

+139
-179
lines changed

8 files changed

+139
-179
lines changed

‎embassy-lora/Cargo.toml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,5 +38,5 @@ futures = { version = "0.3.17", default-features = false, features = [ "async-aw
3838
embedded-hal = { version = "0.2", features = ["unproven"] }
3939
bit_field = { version = "0.10" }
4040

41-
lorawan-device = { version = "0.8.0", default-features = false, features = ["async"] }
41+
lorawan-device = { version = "0.8.0", git = "https://github.com/ivajloip/rust-lorawan.git", rev = "7d3eb40bc2412536c846cea40caff25198b6b068", default-features = false, features = ["async"] }
4242
lorawan = { version = "0.7.1", default-features = false }

‎embassy-lora/src/lib.rs‎

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
#![no_std]
2-
#![feature(type_alias_impl_trait)]
2+
#![feature(async_fn_in_trait, impl_trait_projections)]
3+
#![allow(incomplete_features)]
34
//! embassy-lora is a collection of async radio drivers that integrate with the lorawan-device
45
//! crate's async LoRaWAN MAC implementation.
56
@@ -34,13 +35,11 @@ impl lorawan_device::async_device::radio::Timer for LoraTimer {
3435
self.start = Instant::now();
3536
}
3637

37-
type AtFuture<'m> = impl core::future::Future<Output = ()> + 'm;
38-
fn at<'m>(&'m mut self, millis: u64) -> Self::AtFuture<'m> {
39-
Timer::at(self.start + Duration::from_millis(millis))
38+
async fn at(&mut self, millis: u64) {
39+
Timer::at(self.start + Duration::from_millis(millis)).await
4040
}
4141

42-
type DelayFuture<'m> = impl core::future::Future<Output = ()> + 'm;
43-
fn delay_ms<'m>(&'m mut self, millis: u64) -> Self::DelayFuture<'m> {
44-
Timer::after(Duration::from_millis(millis))
42+
async fn delay_ms(&mut self, millis: u64) {
43+
Timer::after(Duration::from_millis(millis)).await
4544
}
4645
}

‎embassy-lora/src/stm32wl/mod.rs‎

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
//! A radio driver integration for the radio found on STM32WL family devices.
2-
use core::future::{poll_fn, Future};
2+
use core::future::poll_fn;
33
use core::task::Poll;
44

55
use embassy_hal_common::{into_ref, Peripheral, PeripheralRef};
@@ -241,14 +241,12 @@ fn configure_radio(radio: &mut SubGhz<'_, NoDma, NoDma>, config: SubGhzRadioConf
241241
impl<'d, RS: RadioSwitch> PhyRxTx for SubGhzRadio<'d, RS> {
242242
type PhyError = RadioError;
243243

244-
type TxFuture<'m> = impl Future<Output = Result<u32, Self::PhyError>> + 'm where Self: 'm;
245-
fn tx<'m>(&'m mut self, config: TxConfig, buf: &'m [u8]) -> Self::TxFuture<'m> {
246-
async move { self.do_tx(config, buf).await }
244+
async fn tx(&mut self, config: TxConfig, buf: &[u8]) -> Result<u32, Self::PhyError> {
245+
self.do_tx(config, buf).await
247246
}
248247

249-
type RxFuture<'m> = impl Future<Output = Result<(usize, RxQuality), Self::PhyError>> + 'm where Self: 'm;
250-
fn rx<'m>(&'m mut self, config: RfConfig, buf: &'m mut [u8]) -> Self::RxFuture<'m> {
251-
async move { self.do_rx(config, buf).await }
248+
async fn rx(&mut self, config: RfConfig, buf: &mut [u8]) -> Result<(usize, RxQuality), Self::PhyError> {
249+
self.do_rx(config, buf).await
252250
}
253251
}
254252

‎embassy-lora/src/sx126x/mod.rs‎

Lines changed: 58 additions & 72 deletions
Original file line numberDiff line numberDiff line change
@@ -71,83 +71,69 @@ where
7171
{
7272
type PhyError = RadioError<BUS>;
7373

74-
type TxFuture<'m> = impl Future<Output = Result<u32, Self::PhyError>> + 'm
75-
where
76-
SPI: 'm,
77-
CTRL: 'm,
78-
WAIT: 'm,
79-
BUS: 'm;
80-
81-
fn tx<'m>(&'m mut self, config: TxConfig, buffer: &'m [u8]) -> Self::TxFuture<'m> {
74+
async fn tx(&mut self, config: TxConfig, buffer: &[u8]) -> Result<u32, Self::PhyError> {
8275
trace!("TX START");
83-
async move {
84-
self.lora
85-
.set_tx_config(
86-
config.pw,
87-
config.rf.spreading_factor.into(),
88-
config.rf.bandwidth.into(),
89-
config.rf.coding_rate.into(),
90-
8,
91-
false,
92-
true,
93-
false,
94-
0,
95-
false,
96-
)
97-
.await?;
98-
self.lora.set_max_payload_length(buffer.len() as u8).await?;
99-
self.lora.set_channel(config.rf.frequency).await?;
100-
self.lora.send(buffer, 0xffffff).await?;
101-
self.lora.process_irq(None, None, None).await?;
102-
trace!("TX DONE");
103-
return Ok(0);
104-
}
76+
self.lora
77+
.set_tx_config(
78+
config.pw,
79+
config.rf.spreading_factor.into(),
80+
config.rf.bandwidth.into(),
81+
config.rf.coding_rate.into(),
82+
8,
83+
false,
84+
true,
85+
false,
86+
0,
87+
false,
88+
)
89+
.await?;
90+
self.lora.set_max_payload_length(buffer.len() as u8).await?;
91+
self.lora.set_channel(config.rf.frequency).await?;
92+
self.lora.send(buffer, 0xffffff).await?;
93+
self.lora.process_irq(None, None, None).await?;
94+
trace!("TX DONE");
95+
return Ok(0);
10596
}
10697

107-
type RxFuture<'m> = impl Future<Output = Result<(usize, RxQuality), Self::PhyError>> + 'm
108-
where
109-
SPI: 'm,
110-
CTRL: 'm,
111-
WAIT: 'm,
112-
BUS: 'm;
113-
114-
fn rx<'m>(&'m mut self, config: RfConfig, receiving_buffer: &'m mut [u8]) -> Self::RxFuture<'m> {
98+
async fn rx(
99+
&mut self,
100+
config: RfConfig,
101+
receiving_buffer: &mut [u8],
102+
) -> Result<(usize, RxQuality), Self::PhyError> {
115103
trace!("RX START");
116-
async move {
117-
self.lora
118-
.set_rx_config(
119-
config.spreading_factor.into(),
120-
config.bandwidth.into(),
121-
config.coding_rate.into(),
122-
8,
123-
4,
124-
false,
125-
0u8,
126-
true,
127-
false,
128-
0,
129-
true,
130-
true,
131-
)
132-
.await?;
133-
self.lora.set_max_payload_length(receiving_buffer.len() as u8).await?;
134-
self.lora.set_channel(config.frequency).await?;
135-
self.lora.rx(90 * 1000).await?;
136-
let mut received_len = 0u8;
137-
self.lora
138-
.process_irq(Some(receiving_buffer), Some(&mut received_len), None)
139-
.await?;
140-
trace!("RX DONE");
104+
self.lora
105+
.set_rx_config(
106+
config.spreading_factor.into(),
107+
config.bandwidth.into(),
108+
config.coding_rate.into(),
109+
8,
110+
4,
111+
false,
112+
0u8,
113+
true,
114+
false,
115+
0,
116+
true,
117+
true,
118+
)
119+
.await?;
120+
self.lora.set_max_payload_length(receiving_buffer.len() as u8).await?;
121+
self.lora.set_channel(config.frequency).await?;
122+
self.lora.rx(90 * 1000).await?;
123+
let mut received_len = 0u8;
124+
self.lora
125+
.process_irq(Some(receiving_buffer), Some(&mut received_len), None)
126+
.await?;
127+
trace!("RX DONE");
141128

142-
let packet_status = self.lora.get_latest_packet_status();
143-
let mut rssi = 0i16;
144-
let mut snr = 0i8;
145-
if packet_status.is_some() {
146-
rssi = packet_status.unwrap().rssi as i16;
147-
snr = packet_status.unwrap().snr;
148-
}
149-
150-
Ok((received_len as usize, RxQuality::new(rssi, snr)))
129+
let packet_status = self.lora.get_latest_packet_status();
130+
let mut rssi = 0i16;
131+
let mut snr = 0i8;
132+
if packet_status.is_some() {
133+
rssi = packet_status.unwrap().rssi as i16;
134+
snr = packet_status.unwrap().snr;
151135
}
136+
137+
Ok((received_len as usize, RxQuality::new(rssi, snr)))
152138
}
153139
}

‎embassy-lora/src/sx127x/mod.rs‎

Lines changed: 66 additions & 89 deletions
Original file line numberDiff line numberDiff line change
@@ -88,101 +88,78 @@ where
8888
{
8989
type PhyError = Sx127xError;
9090

91-
type TxFuture<'m> = impl Future<Output = Result<u32, Self::PhyError>> + 'm
92-
where
93-
SPI: 'm,
94-
CS: 'm,
95-
RESET: 'm,
96-
E: 'm,
97-
I: 'm,
98-
RFS: 'm;
99-
100-
fn tx<'m>(&'m mut self, config: TxConfig, buf: &'m [u8]) -> Self::TxFuture<'m> {
91+
async fn tx(&mut self, config: TxConfig, buf: &[u8]) -> Result<u32, Self::PhyError> {
10192
trace!("TX START");
102-
async move {
93+
self.radio.set_mode(RadioMode::Stdby).await.ok().unwrap();
94+
self.rfs.set_tx();
95+
self.radio.set_tx_power(14, 0).await?;
96+
self.radio.set_frequency(config.rf.frequency).await?;
97+
// TODO: Modify radio to support other coding rates
98+
self.radio.set_coding_rate_4(5).await?;
99+
self.radio
100+
.set_signal_bandwidth(bandwidth_to_i64(config.rf.bandwidth))
101+
.await?;
102+
self.radio
103+
.set_spreading_factor(spreading_factor_to_u8(config.rf.spreading_factor))
104+
.await?;
105+
106+
self.radio.set_preamble_length(8).await?;
107+
self.radio.set_lora_pa_ramp().await?;
108+
self.radio.set_lora_sync_word().await?;
109+
self.radio.set_invert_iq(false).await?;
110+
self.radio.set_crc(true).await?;
111+
112+
self.radio.set_dio0_tx_done().await?;
113+
114+
self.radio.transmit_start(buf).await?;
115+
116+
loop {
117+
self.irq.wait_for_rising_edge().await.unwrap();
103118
self.radio.set_mode(RadioMode::Stdby).await.ok().unwrap();
104-
self.rfs.set_tx();
105-
self.radio.set_tx_power(14, 0).await?;
106-
self.radio.set_frequency(config.rf.frequency).await?;
107-
// TODO: Modify radio to support other coding rates
108-
self.radio.set_coding_rate_4(5).await?;
109-
self.radio
110-
.set_signal_bandwidth(bandwidth_to_i64(config.rf.bandwidth))
111-
.await?;
112-
self.radio
113-
.set_spreading_factor(spreading_factor_to_u8(config.rf.spreading_factor))
114-
.await?;
115-
116-
self.radio.set_preamble_length(8).await?;
117-
self.radio.set_lora_pa_ramp().await?;
118-
self.radio.set_lora_sync_word().await?;
119-
self.radio.set_invert_iq(false).await?;
120-
self.radio.set_crc(true).await?;
121-
122-
self.radio.set_dio0_tx_done().await?;
123-
124-
self.radio.transmit_start(buf).await?;
125-
126-
loop {
127-
self.irq.wait_for_rising_edge().await.unwrap();
128-
self.radio.set_mode(RadioMode::Stdby).await.ok().unwrap();
129-
let irq = self.radio.clear_irq().await.ok().unwrap();
130-
if (irq & IRQ::IrqTxDoneMask.addr()) != 0 {
131-
trace!("TX DONE");
132-
return Ok(0);
133-
}
119+
let irq = self.radio.clear_irq().await.ok().unwrap();
120+
if (irq & IRQ::IrqTxDoneMask.addr()) != 0 {
121+
trace!("TX DONE");
122+
return Ok(0);
134123
}
135124
}
136125
}
137126

138-
type RxFuture<'m> = impl Future<Output = Result<(usize, RxQuality), Self::PhyError>> + 'm
139-
where
140-
SPI: 'm,
141-
CS: 'm,
142-
RESET: 'm,
143-
E: 'm,
144-
I: 'm,
145-
RFS: 'm;
146-
147-
fn rx<'m>(&'m mut self, config: RfConfig, buf: &'m mut [u8]) -> Self::RxFuture<'m> {
148-
trace!("RX START");
149-
async move {
150-
self.rfs.set_rx();
151-
self.radio.reset_payload_length().await?;
152-
self.radio.set_frequency(config.frequency).await?;
153-
// TODO: Modify radio to support other coding rates
154-
self.radio.set_coding_rate_4(5).await?;
155-
self.radio
156-
.set_signal_bandwidth(bandwidth_to_i64(config.bandwidth))
157-
.await?;
158-
self.radio
159-
.set_spreading_factor(spreading_factor_to_u8(config.spreading_factor))
160-
.await?;
161-
162-
self.radio.set_preamble_length(8).await?;
163-
self.radio.set_lora_sync_word().await?;
164-
self.radio.set_invert_iq(true).await?;
165-
self.radio.set_crc(true).await?;
166-
167-
self.radio.set_dio0_rx_done().await?;
168-
self.radio.set_mode(RadioMode::RxContinuous).await?;
169-
170-
loop {
171-
self.irq.wait_for_rising_edge().await.unwrap();
172-
self.radio.set_mode(RadioMode::Stdby).await.ok().unwrap();
173-
let irq = self.radio.clear_irq().await.ok().unwrap();
174-
if (irq & IRQ::IrqRxDoneMask.addr()) != 0 {
175-
let rssi = self.radio.get_packet_rssi().await.unwrap_or(0) as i16;
176-
let snr = self.radio.get_packet_snr().await.unwrap_or(0.0) as i8;
177-
let response = if let Ok(size) = self.radio.read_packet_size().await {
178-
self.radio.read_packet(buf).await?;
179-
Ok((size, RxQuality::new(rssi, snr)))
180-
} else {
181-
Ok((0, RxQuality::new(rssi, snr)))
182-
};
183-
trace!("RX DONE");
184-
return response;
185-
}
127+
async fn rx(&mut self, config: RfConfig, buf: &mut [u8]) -> Result<(usize, RxQuality), Self::PhyError> {
128+
self.rfs.set_rx();
129+
self.radio.reset_payload_length().await?;
130+
self.radio.set_frequency(config.frequency).await?;
131+
// TODO: Modify radio to support other coding rates
132+
self.radio.set_coding_rate_4(5).await?;
133+
self.radio
134+
.set_signal_bandwidth(bandwidth_to_i64(config.bandwidth))
135+
.await?;
136+
self.radio
137+
.set_spreading_factor(spreading_factor_to_u8(config.spreading_factor))
138+
.await?;
139+
140+
self.radio.set_preamble_length(8).await?;
141+
self.radio.set_lora_sync_word().await?;
142+
self.radio.set_invert_iq(true).await?;
143+
self.radio.set_crc(true).await?;
144+
145+
self.radio.set_dio0_rx_done().await?;
146+
self.radio.set_mode(RadioMode::RxContinuous).await?;
147+
148+
loop {
149+
self.irq.wait_for_rising_edge().await.unwrap();
150+
self.radio.set_mode(RadioMode::Stdby).await.ok().unwrap();
151+
let irq = self.radio.clear_irq().await.ok().unwrap();
152+
if (irq & IRQ::IrqRxDoneMask.addr()) != 0 {
153+
let rssi = self.radio.get_packet_rssi().await.unwrap_or(0) as i16;
154+
let snr = self.radio.get_packet_snr().await.unwrap_or(0.0) as i8;
155+
let response = if let Ok(size) = self.radio.read_packet_size().await {
156+
self.radio.read_packet(buf).await?;
157+
Ok((size, RxQuality::new(rssi, snr)))
158+
} else {
159+
Ok((0, RxQuality::new(rssi, snr)))
160+
};
161+
trace!("RX DONE");
162+
return response;
186163
}
187164
}
188165
}

‎examples/nrf52840/Cargo.toml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ embassy-usb = { version = "0.1.0", path = "../../embassy-usb", features = ["defm
2020
embedded-io = "0.4.0"
2121
embassy-lora = { version = "0.1.0", path = "../../embassy-lora", features = ["sx126x", "time", "defmt"], optional = true }
2222

23-
lorawan-device = { version = "0.8.0", default-features = false, features = ["async"], optional = true }
23+
lorawan-device = { version = "0.8.0", git = "https://github.com/ivajloip/rust-lorawan.git", rev = "7d3eb40bc2412536c846cea40caff25198b6b068", default-features = false, features = ["async"], optional = true }
2424
lorawan = { version = "0.7.1", default-features = false, features = ["default-crypto"], optional = true }
2525

2626
defmt = "0.3"

‎examples/stm32l0/Cargo.toml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ embassy-time = { version = "0.1.0", path = "../../embassy-time", features = ["de
1515
embassy-stm32 = { version = "0.1.0", path = "../../embassy-stm32", features = ["defmt", "stm32l072cz", "time-driver-any", "exti", "unstable-traits", "memory-x"] }
1616
embassy-lora = { version = "0.1.0", path = "../../embassy-lora", features = ["sx127x", "time", "defmt"], optional = true}
1717

18-
lorawan-device = { version = "0.8.0", default-features = false, features = ["async"], optional = true }
18+
lorawan-device = { version = "0.8.0", git = "https://github.com/ivajloip/rust-lorawan.git", rev = "7d3eb40bc2412536c846cea40caff25198b6b068", default-features = false, features = ["async"], optional = true }
1919
lorawan = { version = "0.7.1", default-features = false, features = ["default-crypto"], optional = true }
2020

2121
defmt = "0.3"

‎examples/stm32wl/Cargo.toml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ embassy-time = { version = "0.1.0", path = "../../embassy-time", features = ["de
1111
embassy-stm32 = { version = "0.1.0", path = "../../embassy-stm32", features = ["nightly", "defmt", "stm32wl55jc-cm4", "time-driver-any", "memory-x", "unstable-pac", "exti"] }
1212
embassy-lora = { version = "0.1.0", path = "../../embassy-lora", features = ["stm32wl", "time", "defmt"] }
1313

14-
lorawan-device = { version = "0.8.0", default-features = false, features = ["async"] }
14+
lorawan-device = { version = "0.8.0", git = "https://github.com/ivajloip/rust-lorawan.git", rev = "7d3eb40bc2412536c846cea40caff25198b6b068", default-features = false, features = ["async"] }
1515
lorawan = { version = "0.7.1", default-features = false, features = ["default-crypto"] }
1616

1717
defmt = "0.3"

0 commit comments

Comments
 (0)