protoflight 0.1.4

Protoflight flight controller.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91

/// Macro to generate boilerplate non-volatile storage loader routines.
#[allow(unused)]
#[rustfmt::skip]
macro_rules! generate_config_handlers {
    ($location:expr, $prefix:ident, $key:expr, $buf_size:expr) => {
        paste::paste! {

// 1. Configure the PostcardValue macro for the Option wrap variant
//impl<'a> PostcardValue<'a> for Option<[<$prefix Config>]> {}

use $location::[<$prefix Config>];

/// Generate the `load` function.
#[allow(unused)]
#[cfg(feature = "storage")]
pub async fn [<load_ $prefix:lower _config>]<F, C>(
    config: &mut [<$prefix Config>],
    storage: &mut MapStorage<u16, F, C>,
) -> Result<(), sequential_storage::Error<F::Error>>
where
    F: NorFlash,
    C: CacheImpl<u16>,
{
    let mut buffer = [0u8; $buf_size];
    let stored = storage.fetch_item::<Option<[<$prefix Config>]>>(&mut buffer, &$key).await?;
    match stored {
        Some(Some(loaded_data)) => {
            *config = loaded_data;
        }
        None | Some(None) => {
            *config = [<$prefix Config>]::default();
        }
    }
    Ok(())
}

/// Generate the `store` function.
#[allow(unused)]
#[cfg(feature = "storage")]
pub async fn [<save_ $prefix:lower _config>]<F, C>(
    config: &[<$prefix Config>],
    storage: &mut MapStorage<u16, F, C>
) -> Result<(), sequential_storage::Error<F::Error>>
where
    F: NorFlash,
    C: CacheImpl<u16>,
    [<$prefix Config>]: PartialEq // Enforces that the struct derives PartialEq
{
    let mut buffer = [0u8; $buf_size];
    // READ BEFORE SAVE: Check what is currently stored under this key
    let stored = storage.fetch_item::<Option<[<$prefix Config>]>>(&mut buffer, &$key).await?;
    if *config == [<$prefix Config>]::default() {
        // Default configuration means "no stored configuration".
        // If there is an existing configuration, append a None marker to mark it deleted.
        // If there is no record, do nothing.
        if matches!(stored, Some(Some(_))) {
            let delete_marker: Option<ArmingConfig> = None;
            storage.store_item(&mut buffer, &$key, &delete_marker).await?;
        }
    } else {
        // Non-default configuration:
        // only write it if it differs from the currently stored value.
        if !matches!(stored, Some(Some(stored_config)) if stored_config == *config) {
            storage.store_item(&mut buffer, &$key, &Some(*config)).await?;
        }
    }
    Ok(())
}

/// Generate the `delete` function.
#[allow(unused)]
#[cfg(feature = "storage")]
pub async fn [<delete_ $prefix:lower _config>]<F, C>(
    storage: &mut MapStorage<u16, F, C>
) -> Result<(), sequential_storage::Error<F::Error>>
where
    F: NorFlash,
    C: CacheImpl<u16>
{
    let mut buffer = [0u8; $buf_size];
    // READ BEFORE DELETE: Check what is currently stored under this key
    let stored =storage.fetch_item::<Option<[<$prefix Config>]>>(&mut buffer, &$key).await?;
    // WRITE ONLY IF NOT ALREADY DELETED
    if matches!(stored, Some(Some(_))) {
        let delete_marker: Option<[<$prefix Config>]> = None;
        storage.store_item(&mut buffer, &$key, &delete_marker).await?;
    }
    Ok(())
}

}};}