add tests for config-management sessionevents

src-tauri/src/worker/tests/mutations.rs

@@ -324,4 +324,6 @@ fn move_source() -> Result<()> {
     Ok(())
 }
 
-// XXX need tests for branch/ref mutations
+// XXX missing tests for:
+// - branch/ref mutations
+// - git interop

src-tauri/src/worker/tests/session.rs

@@ -4,6 +4,7 @@ use crate::{
     worker::{Session, SessionEvent, WorkerSession},
 };
 use anyhow::Result;
+use jj_cli::config::ConfigSource;
 use std::{path::PathBuf, sync::mpsc::channel};
 
 #[test]
@@ -329,3 +330,64 @@ fn query_rev_not_found() -> Result<()> {
 
     Ok(())
 }
+
+#[test]
+fn config_read() -> Result<()> {
+    let repo = mkrepo();
+
+    let (tx, rx) = channel::<SessionEvent>();
+    let (tx_load, rx_load) = channel::<Result<RepoConfig>>();
+    let (tx_read, rx_read) = channel::<Result<Vec<String>>>();
+
+    tx.send(SessionEvent::OpenWorkspace {
+        tx: tx_load,
+        wd: Some(repo.path().to_owned()),
+    })?;
+    tx.send(SessionEvent::ReadConfigArray {
+        tx: tx_read,
+        key: vec!["gg".into(), "ui".into(), "recent-workspaces".into()],
+    })?;
+    tx.send(SessionEvent::EndSession)?;
+
+    WorkerSession::default().handle_events(&rx)?;
+
+    _ = rx_load.recv()??;
+    let result = rx_read.recv()??;
+
+    assert!(!result.is_empty()); // it will contain the test-repo, at least
+
+    Ok(())
+}
+
+#[test]
+fn config_write() -> Result<()> {
+    let repo = mkrepo();
+
+    let (tx, rx) = channel::<SessionEvent>();
+    let (tx_load, rx_load) = channel::<Result<RepoConfig>>();
+    let (tx_read, rx_read) = channel::<Result<Vec<String>>>();
+
+    tx.send(SessionEvent::OpenWorkspace {
+        tx: tx_load,
+        wd: Some(repo.path().to_owned()),
+    })?;
+    tx.send(SessionEvent::WriteConfigArray {
+        scope: ConfigSource::Repo,
+        key: vec!["gg".into(), "test".into()],
+        values: vec!["a".into(), "b".into()]
+    })?;
+    tx.send(SessionEvent::ReadConfigArray {
+        tx: tx_read,
+        key: vec!["gg".into(), "test".into()],
+    })?;
+    tx.send(SessionEvent::EndSession)?;
+
+    WorkerSession::default().handle_events(&rx)?;
+
+    _ = rx_load.recv()??;
+    let result = rx_read.recv()??;
+
+    assert_eq!(vec!["a".to_string(), "b".to_string()], result);
+
+    Ok(())
+}