style(application): apply rustfmt formatting

Run cargo fmt to fix formatting across the application crate.
No logic changes.

Co-authored-by: Claude <noreply@anthropic.com>
Signed-off-by: Marvin Drees <marvin.drees@9elements.com>

Author: MDr164

application/src/auth.rs

@@ -95,9 +95,7 @@ impl<'r> FromRequestParts<'r, ()> for AuthUser {
             core::str::from_utf8(&decoded[..n]).map_err(|_| AuthError::InvalidEncoding)?;
 
         // 4. Split "username:password"
-        let colon = decoded_str
-            .find(':')
-            .ok_or(AuthError::InvalidEncoding)?;
+        let colon = decoded_str.find(':').ok_or(AuthError::InvalidEncoding)?;
         let username = &decoded_str[..colon];
         let password = &decoded_str[colon + 1..];
 

application/src/main.rs

@@ -16,6 +16,7 @@ mod storage;
 mod web;
 
 use defmt::*;
+use defmt_rtt as _;
 use embassy_executor::Spawner;
 use embassy_net::StackResources;
 use embassy_net_wiznet::chip::W5500;
@@ -31,13 +32,12 @@ use embassy_rp::spi::{Async, Config as SpiConfig, Spi};
 use embassy_rp::watchdog::Watchdog;
 use embassy_time::{Duration, Timer};
 use embedded_hal_bus::spi::ExclusiveDevice;
-use picoserve::AppWithStateBuilder;
-use static_cell::StaticCell;
-use defmt_rtt as _;
-#[cfg(feature = "panic-reset")]
-use panic_reset as _;
 #[cfg(feature = "panic-probe")]
 use panic_probe as _;
+#[cfg(feature = "panic-reset")]
+use panic_reset as _;
+use picoserve::AppWithStateBuilder;
+use static_cell::StaticCell;
 
 use config::{FLASH_SIZE, SPI_FREQ_HZ};
 use gpio::gpio_task;
@@ -98,8 +98,7 @@ async fn main(spawner: Spawner) {
     drop(factory_reset_pin);
 
     // 3. Init flash → ekv database (async flash using DMA_CH2)
-    let flash: Flash<'static, _, FlashAsync, FLASH_SIZE> =
-        Flash::new(p.FLASH, p.DMA_CH2, Irqs);
+    let flash: Flash<'static, _, FlashAsync, FLASH_SIZE> = Flash::new(p.FLASH, p.DMA_CH2, Irqs);
     let random_seed_u32 = rng.next_u32();
     let db = init_database(flash, random_seed_u32).await;
 
@@ -129,14 +128,10 @@ async fn main(spawner: Spawner) {
     let mut spi_cfg = SpiConfig::default();
     spi_cfg.frequency = SPI_FREQ_HZ;
     let spi = Spi::new(
-        p.SPI0,
-        p.PIN_18, // CLK
+        p.SPI0, p.PIN_18, // CLK
         p.PIN_19, // MOSI
         p.PIN_16, // MISO
-        p.DMA_CH0,
-        p.DMA_CH1,
-        Irqs,
-        spi_cfg,
+        p.DMA_CH0, p.DMA_CH1, Irqs, spi_cfg,
     );
     let cs = Output::new(p.PIN_17, Level::High);
     let w5500_int = Input::new(p.PIN_21, Pull::Up);

application/src/storage.rs

@@ -7,10 +7,10 @@
 //! from the embassy-sync 0.7.x used elsewhere. We alias embassy-sync 0.6.x as
 //! `embassy_sync_ekv` in Cargo.toml and use its RawMutex for the Database type.
 
-use embassy_rp::flash::{Async as FlashAsync, Flash};
-use embassy_sync_ekv::blocking_mutex::raw::CriticalSectionRawMutex;
 use ekv::flash::PageID;
 use ekv::{Config, Database};
+use embassy_rp::flash::{Async as FlashAsync, Flash};
+use embassy_sync_ekv::blocking_mutex::raw::CriticalSectionRawMutex;
 use embedded_storage_async::nor_flash::NorFlash;
 use static_cell::StaticCell;
 
@@ -57,12 +57,8 @@ impl<'d> ekv::flash::Flash for PduFlash<'d> {
         data: &mut [u8],
     ) -> Result<(), Self::Error> {
         let flash_offset = Self::page_offset(page_id) + offset as u32;
-        embedded_storage_async::nor_flash::ReadNorFlash::read(
-            &mut self.flash,
-            flash_offset,
-            data,
-        )
-        .await
+        embedded_storage_async::nor_flash::ReadNorFlash::read(&mut self.flash, flash_offset, data)
+            .await
     }
 
     async fn write(

application/src/web/admin.rs

@@ -175,10 +175,7 @@ pub async fn handle_set_user_ports(
 
 // ── Delete user ────────────────────────────────────────────────────────────────
 
-pub async fn handle_delete_user(
-    username: heapless::String<32>,
-    _admin: AdminUser,
-) -> ApiResult {
+pub async fn handle_delete_user(username: heapless::String<32>, _admin: AdminUser) -> ApiResult {
     let pw_key = user_pw_key(username.as_str());
     let ports_key = user_ports_key(username.as_str());
     let admin_key = user_admin_key(username.as_str());

application/src/web/gpio.rs

@@ -75,16 +75,29 @@ pub async fn handle_gpio_toggle(pin: u8, user: AuthUser) -> Json<GpioToggleRespo
     if pin >= 8 || (user.allowed_ports & (1 << pin) == 0) {
         let state_val = {
             let states = GPIO_STATES.lock().await;
-            if (pin as usize) < 8 { states[pin as usize] } else { false }
+            if (pin as usize) < 8 {
+                states[pin as usize]
+            } else {
+                false
+            }
         };
-        return Json(GpioToggleResponse { pin, state: state_val });
+        return Json(GpioToggleResponse {
+            pin,
+            state: state_val,
+        });
     }
 
     GPIO_SIGNAL.signal(GpioCommand::Toggle(pin));
     embassy_time::Timer::after_millis(1).await;
-    let state_val = { let states = GPIO_STATES.lock().await; states[pin as usize] };
+    let state_val = {
+        let states = GPIO_STATES.lock().await;
+        states[pin as usize]
+    };
 
-    Json(GpioToggleResponse { pin, state: state_val })
+    Json(GpioToggleResponse {
+        pin,
+        state: state_val,
+    })
 }
 
 // ── POST /api/gpio/:pin/set ────────────────────────────────────────────────────
@@ -97,14 +110,27 @@ pub async fn handle_gpio_set(
     if pin >= 8 || (user.allowed_ports & (1 << pin) == 0) {
         let state_val = {
             let states = GPIO_STATES.lock().await;
-            if (pin as usize) < 8 { states[pin as usize] } else { false }
+            if (pin as usize) < 8 {
+                states[pin as usize]
+            } else {
+                false
+            }
         };
-        return Json(GpioToggleResponse { pin, state: state_val });
+        return Json(GpioToggleResponse {
+            pin,
+            state: state_val,
+        });
     }
 
     GPIO_SIGNAL.signal(GpioCommand::Set(pin, body.state));
     embassy_time::Timer::after_millis(1).await;
-    let state_val = { let states = GPIO_STATES.lock().await; states[pin as usize] };
+    let state_val = {
+        let states = GPIO_STATES.lock().await;
+        states[pin as usize]
+    };
 
-    Json(GpioToggleResponse { pin, state: state_val })
+    Json(GpioToggleResponse {
+        pin,
+        state: state_val,
+    })
 }

application/src/web/mod.rs

@@ -7,8 +7,8 @@ pub mod status;
 pub mod update;
 
 use picoserve::routing::{delete, get, parse_path_segment, post};
-use update::FirmwareUpdateService;
 use picoserve::{AppWithStateBuilder, Router};
+use update::FirmwareUpdateService;
 
 use crate::storage::PduDatabase;
 
@@ -21,8 +21,7 @@ use crate::storage::PduDatabase;
 ///
 /// Stored as `usize` (pointer-as-integer) in a `portable_atomic::AtomicUsize`
 /// so the static is `Sync` without needing unsafe.
-static DB_PTR: portable_atomic::AtomicUsize =
-    portable_atomic::AtomicUsize::new(0);
+static DB_PTR: portable_atomic::AtomicUsize = portable_atomic::AtomicUsize::new(0);
 
 /// Initialise the module-level DB handle. Call exactly once before spawning web tasks.
 pub fn init_db(db: &'static PduDatabase) {

application/src/web/update.rs

@@ -62,10 +62,16 @@ impl MethodHandlerService<(), ()> for FirmwareUpdateService {
         let conn = body_connection.finalize().await?;
 
         match result {
-            Ok(()) => (StatusCode::OK, "{\"ok\":true}").write_to(conn, response_writer).await,
-            Err(msg) => (StatusCode::INTERNAL_SERVER_ERROR, msg)
-                .write_to(conn, response_writer)
-                .await,
+            Ok(()) => {
+                (StatusCode::OK, "{\"ok\":true}")
+                    .write_to(conn, response_writer)
+                    .await
+            }
+            Err(msg) => {
+                (StatusCode::INTERNAL_SERVER_ERROR, msg)
+                    .write_to(conn, response_writer)
+                    .await
+            }
         }
     }
 }
@@ -117,7 +123,10 @@ async fn write_firmware_streaming<'r, R: Read>(
         remaining -= chunk_size;
     }
 
-    updater.mark_updated().await.map_err(|_| "Mark update error")?;
+    updater
+        .mark_updated()
+        .await
+        .map_err(|_| "Mark update error")?;
 
     embassy_time::Timer::after_millis(100).await;
     cortex_m::peripheral::SCB::sys_reset();