base-station: Move radio code into module.

base-station/software/Cargo.lock

 # This file is automatically @generated by Cargo.
 # It is not intended for manual editing.
+[[package]]
+name = "aho-corasick"
+version = "0.7.10"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8716408b8bc624ed7f65d223ddb9ac2d044c0547b6fa4b0d554f3a9540496ada"
+dependencies = [
+ "memchr",
+]
+
+[[package]]
+name = "atty"
+version = "0.2.14"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d9b39be18770d11421cdb1b9947a45dd3f37e93092cbf377614828a319d5fee8"
+dependencies = [
+ "hermit-abi",
+ "libc",
+ "winapi",
+]
+
 [[package]]
 name = "base-station"
 version = "0.1.0"
 dependencies = [
  "embedded-hal",
  "embedded-nrf24l01",
+ "env_logger",
  "linux-embedded-hal",
+ "log",
+ "mqtt-protocol",
 ]
 
 [[package]]
  "embedded-hal",
 ]
 
+[[package]]
+name = "env_logger"
+version = "0.7.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "44533bbbb3bb3c1fa17d9f2e4e38bbbaf8396ba82193c4cb1b6445d711445d36"
+dependencies = [
+ "atty",
+ "humantime",
+ "log",
+ "regex",
+ "termcolor",
+]
+
+[[package]]
+name = "hermit-abi"
+version = "0.1.11"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8a0d737e0f947a1864e93d33fdef4af8445a00d1ed8dc0c8ddb73139ea6abf15"
+dependencies = [
+ "libc",
+]
+
+[[package]]
+name = "humantime"
+version = "1.3.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "df004cfca50ef23c36850aaaa59ad52cc70d0e90243c3c7737a4dd32dc7a3c4f"
+dependencies = [
+ "quick-error",
+]
+
 [[package]]
 name = "i2cdev"
 version = "0.4.4"
  "libc",
 ]
 
+[[package]]
+name = "lazy_static"
+version = "1.4.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e2abad23fbc42b3700f2f279844dc832adb2b2eb069b2df918f455c4e18cc646"
+
 [[package]]
 name = "libc"
 version = "0.2.68"
  "sysfs_gpio",
 ]
 
+[[package]]
+name = "log"
+version = "0.4.8"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "14b6052be84e6b71ab17edffc2eeabf5c2c3ae1fdb464aae35ac50c67a44e1f7"
+dependencies = [
+ "cfg-if",
+]
+
+[[package]]
+name = "memchr"
+version = "2.3.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "3728d817d99e5ac407411fa471ff9800a778d88a24685968b36824eaf4bee400"
+
+[[package]]
+name = "mqtt-protocol"
+version = "0.8.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0ad527bd1d7917664e1f35f30ac9d0a01fa1425c52c66494a5b875e8b8848058"
+dependencies = [
+ "byteorder",
+ "lazy_static",
+ "log",
+ "regex",
+]
+
 [[package]]
 name = "nb"
 version = "0.1.2"
  "void",
 ]
 
+[[package]]
+name = "quick-error"
+version = "1.2.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a1d01941d82fa2ab50be1e79e6714289dd7cde78eba4c074bc5a4374f650dfe0"
+
+[[package]]
+name = "regex"
+version = "1.3.7"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a6020f034922e3194c711b82a627453881bc4682166cabb07134a10c26ba7692"
+dependencies = [
+ "aho-corasick",
+ "memchr",
+ "regex-syntax",
+ "thread_local",
+]
+
+[[package]]
+name = "regex-syntax"
+version = "0.6.17"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "7fe5bd57d1d7414c6b5ed48563a2c855d995ff777729dcd91c369ec7fea395ae"
+
 [[package]]
 name = "rustc_version"
 version = "0.2.3"
  "nix",
 ]
 
+[[package]]
+name = "termcolor"
+version = "1.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "bb6bfa289a4d7c5766392812c0a1f4c1ba45afa1ad47803c11e1f407d846d75f"
+dependencies = [
+ "winapi-util",
+]
+
 [[package]]
 name = "termios"
 version = "0.2.2"
  "libc",
 ]
 
+[[package]]
+name = "thread_local"
+version = "1.0.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d40c6d1b69745a6ec6fb1ca717914848da4b44ae29d9b3080cbee91d72a69b14"
+dependencies = [
+ "lazy_static",
+]
+
 [[package]]
 name = "void"
 version = "1.0.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "6a02e4885ed3bc0f2de90ea6dd45ebcbb66dacffe03547fadbb0eeae2770887d"
+
+[[package]]
+name = "winapi"
+version = "0.3.8"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8093091eeb260906a183e6ae1abdba2ef5ef2257a21801128899c3fc699229c6"
+dependencies = [
+ "winapi-i686-pc-windows-gnu",
+ "winapi-x86_64-pc-windows-gnu",
+]
+
+[[package]]
+name = "winapi-i686-pc-windows-gnu"
+version = "0.4.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ac3b87c63620426dd9b991e5ce0329eff545bccbbb34f3be09ff6fb6ab51b7b6"
+
+[[package]]
+name = "winapi-util"
+version = "0.1.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "fa515c5163a99cc82bab70fd3bfdd36d827be85de63737b40fcef2ce084a436e"
+dependencies = [
+ "winapi",
+]
+
+[[package]]
+name = "winapi-x86_64-pc-windows-gnu"
+version = "0.4.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "712e227841d057c1ee1cd2fb22fa7e5a5461ae8e48fa2ca79ec42cfc1931183f"

base-station/software/Cargo.toml

 linux-embedded-hal = "0.3"
 embedded-nrf24l01 = { git = "https://github.com/astro/embedded-nrf24l01.git" }
 embedded-hal = "0.2.3"
+mqtt-protocol = "0.8"
+env_logger = "0.7"
+log = "0.4"

base-station/software/src/main.rs

-use embedded_nrf24l01::{Configuration, CrcMode, DataRate, NRF24L01};
-use linux_embedded_hal::spidev::{SpiModeFlags, Spidev, SpidevOptions};
-use linux_embedded_hal::sysfs_gpio::Direction;
-use linux_embedded_hal::Pin;
-use std::convert::TryInto;
-use std::time::Instant;
-
-use spi::EmbeddedHalSpidev;
+use std::env;
+use std::thread;
+use std::time::Duration;
 
+mod radio;
 mod spi;
 
 fn main() {
-    // The NRF module is connected as follows:
-    // - CE: PA1
-    // - CS: PG8
-    // - IRQ: PG9
-    // - MOSI: PC0
-    // - MISO: PC1
-    // - SCK: PC2
-
-    // Configure SPI.
-    let mut spi = Spidev::open("/dev/spidev0.0").unwrap();
-    let options = SpidevOptions::new()
-        .bits_per_word(8)
-        .max_speed_hz(500_000)
-        .mode(SpiModeFlags::SPI_MODE_0)
-        .build();
-    spi.configure(&options).unwrap();
-    let spi = EmbeddedHalSpidev::from(spi);
-
-    // Configure the GPIOs.
-    let ce_nr = get_pin_number('A', 1);
-    let ce = Pin::new(ce_nr);
-    ce.export().unwrap();
-    ce.set_direction(Direction::Out).unwrap();
-    let cs_nr = get_pin_number('G', 8);
-    let cs = Pin::new(cs_nr);
-    cs.export().unwrap();
-    cs.set_direction(Direction::Out).unwrap();
-    let irq_nr = get_pin_number('G', 9);
-    let irq = Pin::new(irq_nr);
-    irq.export().unwrap();
-    irq.set_direction(Direction::In).unwrap();
-
-    // Initialize the radio module.
-    let mut nrf24 = NRF24L01::new(ce, cs, spi).unwrap();
-    nrf24.set_frequency(0x32).unwrap();
-    nrf24.set_rf(DataRate::R2Mbps, 3).unwrap();
-    nrf24.set_crc(Some(CrcMode::OneByte)).unwrap();
-    nrf24.set_auto_retransmit(250, 3).unwrap();
-    nrf24
-        .set_pipes_rx_enable(&[true, false, false, false, false, false])
-        .unwrap();
-    nrf24
-        .set_rx_addr(0, &[0x56, 0x34, 0x12, 0x00, 0x00])
-        .unwrap();
-    nrf24.flush_rx().unwrap();
-    nrf24.flush_tx().unwrap();
-    //nrf24.set_auto_ack(&[true; 6]).unwrap();
-    println!("auto ack: {:?}", nrf24.get_auto_ack().unwrap());
-    nrf24.set_pipes_rx_lengths(&[None; 6]).unwrap();
+    env::set_var(
+        "RUST_LOG",
+        env::var_os("RUST_LOG").unwrap_or_else(|| "info".into()),
+    );
+    env_logger::init();
 
-    println!("width: {}", nrf24.get_address_width().unwrap());
+    radio::start();
 
-    let mut start = Instant::now();
-
-    // Receive data.
-    let mut nrf24 = nrf24.rx().unwrap();
-    println!("Starting to receive:");
+    // TODO
     loop {
-        if let Some(pipe) = nrf24.can_read().unwrap() {
-            let payload = nrf24.read().unwrap();
-            println!("packet received on pipe {}: {:?}", pipe, payload.as_ref());
-            let pressure = u32::from_le_bytes(payload.as_ref()[0..4].try_into().unwrap());
-            let temperature = u32::from_le_bytes(payload.as_ref()[4..8].try_into().unwrap());
-            let humidity = u32::from_le_bytes(payload.as_ref()[8..12].try_into().unwrap());
-            println!("pressure: {}", pressure as f32 / 100.0);
-            println!("temperature: {}", temperature as f32 / 100.0);
-            println!("humidity: {}", humidity as f32 / 1024.0);
-            let end = Instant::now();
-            let elapsed = end.duration_since(start);
-            println!("Debug: {:?}", elapsed);
-            start = end;
-        }
+        thread::sleep(Duration::from_secs(10));
     }
 }
-
-fn get_pin_number(c: char, n: u64) -> u64 {
-    (c as u64 - 'A' as u64) * 32 + n
-}

base-station/software/src/radio.rs

+use std::convert::TryInto;
+use std::io;
+use std::thread;
+use std::time::{Duration, Instant};
+
+use embedded_nrf24l01::{Configuration, CrcMode, DataRate, NRF24L01};
+use linux_embedded_hal::spidev::{SpiModeFlags, Spidev, SpidevOptions};
+use linux_embedded_hal::sysfs_gpio::Direction;
+use linux_embedded_hal::Pin;
+use log::{error, info};
+
+use crate::spi::EmbeddedHalSpidev;
+
+pub fn start() {
+    // TODO: Channels for sensor readings.
+    thread::spawn(move || {
+        // Whenever a error occurs, reinitialize the radio module shortly later.
+        loop {
+            match radio_thread() {
+                Ok(()) => {}
+                Err(e) => {
+                    error!("Radio error: {:?}", e);
+                }
+            }
+            thread::sleep(Duration::from_secs(3));
+        }
+    });
+}
+
+fn radio_thread() -> Result<(), io::Error> {
+    info!("Initializing radio...");
+
+    // The NRF module is connected as follows:
+    // - CE: PA1
+    // - CS: PG8
+    // - IRQ: PG9
+    // - MOSI: PC0
+    // - MISO: PC1
+    // - SCK: PC2
+
+    // Configure SPI.
+    let mut spi = Spidev::open("/dev/spidev0.0").unwrap();
+    let options = SpidevOptions::new()
+        .bits_per_word(8)
+        .max_speed_hz(500_000)
+        .mode(SpiModeFlags::SPI_MODE_0)
+        .build();
+    spi.configure(&options).unwrap();
+    let spi = EmbeddedHalSpidev::from(spi);
+
+    // Configure the GPIOs.
+    let ce_nr = get_pin_number('A', 1);
+    let ce = Pin::new(ce_nr);
+    ce.export().unwrap();
+    ce.set_direction(Direction::Out).unwrap();
+    let cs_nr = get_pin_number('G', 8);
+    let cs = Pin::new(cs_nr);
+    cs.export().unwrap();
+    cs.set_direction(Direction::Out).unwrap();
+    let irq_nr = get_pin_number('G', 9);
+    let irq = Pin::new(irq_nr);
+    irq.export().unwrap();
+    irq.set_direction(Direction::In).unwrap();
+
+    // Initialize the radio module.
+    let mut nrf24 = NRF24L01::new(ce, cs, spi).unwrap();
+    nrf24.set_frequency(0x32).unwrap();
+    nrf24.set_rf(DataRate::R2Mbps, 3).unwrap();
+    nrf24.set_crc(Some(CrcMode::OneByte)).unwrap();
+    nrf24.set_auto_retransmit(250, 3).unwrap();
+    nrf24
+        .set_pipes_rx_enable(&[true, false, false, false, false, false])
+        .unwrap();
+    nrf24
+        .set_rx_addr(0, &[0x56, 0x34, 0x12, 0x00, 0x00])
+        .unwrap();
+    nrf24.flush_rx().unwrap();
+    nrf24.flush_tx().unwrap();
+    //nrf24.set_auto_ack(&[true; 6]).unwrap();
+    info!("auto ack: {:?}", nrf24.get_auto_ack().unwrap());
+    nrf24.set_pipes_rx_lengths(&[None; 6]).unwrap();
+
+    info!("width: {}", nrf24.get_address_width().unwrap());
+
+    let mut start = Instant::now();
+
+    // Receive data.
+    let mut nrf24 = nrf24.rx().unwrap();
+    info!("Starting to receive:");
+    loop {
+        if let Some(pipe) = nrf24.can_read().unwrap() {
+            let payload = nrf24.read().unwrap();
+            info!("packet received on pipe {}: {:?}", pipe, payload.as_ref());
+            let pressure = u32::from_le_bytes(payload.as_ref()[0..4].try_into().unwrap());
+            let temperature = u32::from_le_bytes(payload.as_ref()[4..8].try_into().unwrap());
+            let humidity = u32::from_le_bytes(payload.as_ref()[8..12].try_into().unwrap());
+            info!("pressure: {}", pressure as f32 / 100.0);
+            info!("temperature: {}", temperature as f32 / 100.0);
+            info!("humidity: {}", humidity as f32 / 1024.0);
+            let end = Instant::now();
+            let elapsed = end.duration_since(start);
+            info!("Debug: {:?}", elapsed);
+            start = end;
+        }
+    }
+}
+
+fn get_pin_number(c: char, n: u64) -> u64 {
+    (c as u64 - 'A' as u64) * 32 + n
+}