create home

crates/ascend/src/server.rs

@@ -103,8 +103,8 @@ pub async fn main() {
         }
         Command::ResetState => {
             let s = PersistentState::default();
-            let p = camino::Utf8Path::new(STATE_FILE);
-            tracing::info!("Resetting state to default: {p}");
+            let p = Path::new(STATE_FILE);
+            tracing::info!("Resetting state to default: {}", p.display());
             Persistent::persist(p, &s).await.unwrap_or_report();
         }
     }

crates/ascend/src/server/persistence.rs

@@ -1,19 +1,20 @@
-use camino::Utf8Path;
 use camino::Utf8PathBuf;
 use serde::Serialize;
 use serde::de::DeserializeOwned;
+use std::path::Path;
+use std::path::PathBuf;
 use std::sync::Arc;
 use tokio::sync::Mutex;
 
 #[derive(Debug, Clone)]
 pub struct Persistent<T> {
     state: Arc<Mutex<T>>,
-    file_path: Utf8PathBuf,
+    file_path: PathBuf,
 }
 
 impl<T> Persistent<T> {
     #[tracing::instrument(skip(state))]
-    pub fn new(state: T, file_path: Utf8PathBuf) -> Self {
+    pub fn new(state: T, file_path: PathBuf) -> Self {
         Self {
             state: Arc::new(Mutex::new(state)),
             file_path,
@@ -26,13 +27,18 @@ impl<T> Persistent<T> {
     where
         T: DeserializeOwned,
     {
+        let file_path = file_path.canonicalize().map_err(|source| Error::BadPath {
+            path: file_path.clone(),
+            source,
+        })?;
+
         let content = tokio::fs::read_to_string(&file_path).await.map_err(|source| Error::Read {
-            file_path: file_path.to_owned(),
+            file_path: file_path.clone(),
             source,
         })?;
 
         let t = ron::from_str(&content).map_err(|source| Error::Deserialize {
-            file_path: file_path.to_owned(),
+            file_path: file_path.clone(),
             source,
         })?;
 
@@ -93,7 +99,7 @@ impl<T> Persistent<T> {
     ///
     /// Implicitly called by `set` and `update`.
     #[tracing::instrument(skip_all, err)]
-    pub async fn persist(file_path: &Utf8Path, state: &T) -> Result<(), Error>
+    pub async fn persist(file_path: &Path, state: &T) -> Result<(), Error>
     where
         T: Serialize,
     {
@@ -110,18 +116,18 @@ impl<T> Persistent<T> {
 #[derive(Debug, derive_more::Error, derive_more::Display)]
 #[display("Persistent state error: {_variant}")]
 pub enum Error {
-    #[display("Failed to read file: {file_path}")]
-    Read { file_path: Utf8PathBuf, source: std::io::Error },
+    #[display("Failed to operate on path: {path}")]
+    BadPath { path: Utf8PathBuf, source: std::io::Error },
 
-    #[display("Failed to deserialize state from file: {file_path}")]
-    Deserialize {
-        file_path: Utf8PathBuf,
-        source: ron::error::SpannedError,
-    },
+    #[display("Failed to read file: {}", file_path.display())]
+    Read { file_path: PathBuf, source: std::io::Error },
+
+    #[display("Failed to deserialize state from file: {}", file_path.display())]
+    Deserialize { file_path: PathBuf, source: ron::error::SpannedError },
 
     #[display("Failed to serialize state")]
     Serialize { source: ron::Error },
 
-    #[display("Failed to write file: {file_path}")]
-    Write { file_path: Utf8PathBuf, source: std::io::Error },
+    #[display("Failed to write file: {}", file_path.display())]
+    Write { file_path: PathBuf, source: std::io::Error },
 }

flake.nix

@@ -96,6 +96,7 @@
               home = "/home/ascend";
               group = "ascend";
               description = "Ascend service user";
+              createHome = true;
             };
             users.groups.ascend = { };
             systemd.services.ascend = {