fix: make Store::spawn async to ensure a runtime is set

src/handlers.rs

@@ -302,7 +302,7 @@ mod tests {
     #[tokio::test]
     async fn test_serve_stateless() {
         let temp_dir = TempDir::new().unwrap();
-        let mut store = Store::spawn(temp_dir.into_path());
+        let mut store = Store::spawn(temp_dir.into_path()).await;
         let pool = ThreadPool::new(4);
         let engine = nu::Engine::new(store.clone()).unwrap();
 
@@ -362,7 +362,7 @@ mod tests {
     #[tokio::test]
     async fn test_serve_stateful() {
         let temp_dir = TempDir::new().unwrap();
-        let mut store = Store::spawn(temp_dir.into_path());
+        let mut store = Store::spawn(temp_dir.into_path()).await;
         let pool = ThreadPool::new(4);
         let engine = nu::Engine::new(store.clone()).unwrap();
 
@@ -435,7 +435,7 @@ mod tests {
     #[tokio::test]
     async fn test_handler_update() {
         let temp_dir = TempDir::new().unwrap();
-        let mut store = Store::spawn(temp_dir.into_path());
+        let mut store = Store::spawn(temp_dir.into_path()).await;
         let pool = ThreadPool::new(4);
         let engine = nu::Engine::new(store.clone()).unwrap();
 

src/main.rs

@@ -27,7 +27,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
     xs::trace::init();
 
     let args = Args::parse();
-    let store = Store::spawn(args.path);
+    let store = Store::spawn(args.path).await;
     let pool = ThreadPool::new(10);
     let engine = nu::Engine::new(store.clone())?;
 

src/store.rs

@@ -162,7 +162,7 @@ enum Command {
 }
 
 impl Store {
-    pub fn spawn(path: PathBuf) -> Store {
+    pub async fn spawn(path: PathBuf) -> Store {
         let config = Config::new(path.join("fjall"));
         let keyspace = config.open().unwrap();
 
@@ -464,7 +464,7 @@ mod tests_store {
     #[tokio::test]
     async fn test_get() {
         let temp_dir = TempDir::new().unwrap();
-        let mut store = Store::spawn(temp_dir.into_path());
+        let mut store = Store::spawn(temp_dir.into_path()).await;
         let meta = serde_json::json!({"key": "value"});
         let frame = store.append("stream", None, Some(meta)).await;
         let got = store.get(&frame.id);
@@ -474,7 +474,7 @@ mod tests_store {
     #[tokio::test]
     async fn test_follow() {
         let temp_dir = TempDir::new().unwrap();
-        let mut store = Store::spawn(temp_dir.into_path());
+        let mut store = Store::spawn(temp_dir.into_path()).await;
 
         // Append two initial clips
         let f1 = store.append("stream", None, None).await;
@@ -523,7 +523,7 @@ mod tests_store {
     #[tokio::test]
     async fn test_stream_basics() {
         let temp_dir = TempDir::new().unwrap();
-        let mut store = Store::spawn(temp_dir.into_path());
+        let mut store = Store::spawn(temp_dir.into_path()).await;
 
         let f1 = store.append("/stream", None, None).await;
         let f2 = store.append("/stream", None, None).await;
@@ -552,7 +552,7 @@ mod tests_store {
     #[tokio::test]
     async fn test_read_limit_nofollow() {
         let temp_dir = tempfile::tempdir().unwrap();
-        let mut store = Store::spawn(temp_dir.path().to_path_buf());
+        let mut store = Store::spawn(temp_dir.path().to_path_buf()).await;
 
         // Add 3 items
         let frame1 = store.append("test", None, None).await;
@@ -574,7 +574,7 @@ mod tests_store {
     #[tokio::test]
     async fn test_read_limit_follow() {
         let temp_dir = tempfile::tempdir().unwrap();
-        let mut store = Store::spawn(temp_dir.path().to_path_buf());
+        let mut store = Store::spawn(temp_dir.path().to_path_buf()).await;
 
         // Add 1 item
         let frame1 = store.append("test", None, None).await;

src/tasks.rs

@@ -246,7 +246,7 @@ mod tests {
     #[tokio::test]
     async fn test_serve_basic() {
         let temp_dir = TempDir::new().unwrap();
-        let mut store = Store::spawn(temp_dir.into_path());
+        let mut store = Store::spawn(temp_dir.into_path()).await;
         let engine = nu::Engine::new(store.clone()).unwrap();
 
         {
@@ -296,7 +296,7 @@ mod tests {
     #[tokio::test]
     async fn test_serve_duplex() {
         let temp_dir = TempDir::new().unwrap();
-        let mut store = Store::spawn(temp_dir.into_path());
+        let mut store = Store::spawn(temp_dir.into_path()).await;
         let engine = nu::Engine::new(store.clone()).unwrap();
 
         {
@@ -352,7 +352,7 @@ mod tests {
     #[tokio::test]
     async fn test_serve_compact() {
         let temp_dir = TempDir::new().unwrap();
-        let mut store = Store::spawn(temp_dir.into_path());
+        let mut store = Store::spawn(temp_dir.into_path()).await;
         let engine = nu::Engine::new(store.clone()).unwrap();
 
         let _ = store