rktk/config/storage/
read.rs

1use core::fmt::Debug;
2use postcard::experimental::max_size::MaxSize as _;
3use rktk_keymanager::interface::state::config::StateConfig;
4
5use crate::{config::keymap::Layer, drivers::interface::storage::StorageDriver};
6
7use super::{ConfigKey, StorageConfigManager};
8
9#[derive(Debug)]
10pub enum ConfigReadError<E: Debug> {
11    ReadError(E),
12    DecodeError(postcard::Error),
13}
14
15impl<E: Debug> From<E> for ConfigReadError<E> {
16    fn from(e: E) -> Self {
17        ConfigReadError::ReadError(e)
18    }
19}
20
21impl<S: StorageDriver> StorageConfigManager<S> {
22    pub async fn read_version(&self) -> Result<u16, ConfigReadError<S::Error>> {
23        let mut buf = [0; 2];
24        let key = u64::from_le_bytes([ConfigKey::Version as u8, 0, 0, 0, 0, 0, 0, 0]);
25        self.storage.read::<2>(key, &mut buf).await?;
26        Ok(u16::from_le_bytes(buf))
27    }
28
29    pub async fn read_state_config(&self) -> Result<StateConfig, ConfigReadError<S::Error>> {
30        let mut buf = [0; StateConfig::POSTCARD_MAX_SIZE];
31        let key = u64::from_le_bytes([ConfigKey::StateConfig as u8, 0, 0, 0, 0, 0, 0, 0]);
32        self.storage
33            .read::<{ StateConfig::POSTCARD_MAX_SIZE }>(key, &mut buf)
34            .await?;
35        let res = postcard::from_bytes(&buf).map_err(ConfigReadError::DecodeError)?;
36        Ok(res)
37    }
38
39    pub async fn read_keymap(&self, layer: u8) -> Result<Layer, ConfigReadError<S::Error>> {
40        let mut buf = [0; Layer::POSTCARD_MAX_SIZE];
41        let key = u64::from_le_bytes([ConfigKey::StateKeymap as u8, layer, 0, 0, 0, 0, 0, 0]);
42        self.storage
43            .read::<{ Layer::POSTCARD_MAX_SIZE }>(key, &mut buf)
44            .await?;
45        let res = postcard::from_bytes(&buf).map_err(ConfigReadError::DecodeError)?;
46        Ok(res)
47    }
48}
rktk/config/storage/read.rs

rktk/config/storage/
read.rs
