Merge pull request #91 from kinode-dao/develop

develop v0.9.1

Cargo.toml

@@ -1,7 +1,7 @@
 [package]
 name = "kinode_process_lib"
 description = "A library for writing Kinode processes in Rust."
-version = "0.9.0"
+version = "0.9.1"
 edition = "2021"
 license-file = "LICENSE"
 homepage = "https://kinode.org"

src/vfs/directory.rs

@@ -1,4 +1,4 @@
-use super::{parse_response, vfs_request, DirEntry, VfsAction, VfsError, VfsResponse};
+use super::{parse_response, vfs_request, DirEntry, FileType, VfsAction, VfsError, VfsResponse};
 
 /// Vfs helper struct for a directory.
 /// Opening or creating a directory will give you a Result<Directory>.
@@ -36,13 +36,38 @@ impl Directory {
 pub fn open_dir(path: &str, create: bool, timeout: Option<u64>) -> Result<Directory, VfsError> {
     let timeout = timeout.unwrap_or(5);
     if !create {
+        let message = vfs_request(path, VfsAction::Metadata)
+            .send_and_await_response(timeout)
+            .unwrap()
+            .map_err(|e| VfsError::IOError {
+                error: e.to_string(),
+                path: path.to_string(),
+            })?;
+        match parse_response(message.body())? {
+            VfsResponse::Metadata(m) => {
+                if m.file_type != FileType::Directory {
+                    return Err(VfsError::IOError {
+                        error: "Entry at path not a directory".to_string(),
+                        path: path.to_string(),
+                    });
+                }
+            }
+            VfsResponse::Err(e) => return Err(e),
+            _ => {
+                return Err(VfsError::ParseError {
+                    error: "unexpected response".to_string(),
+                    path: path.to_string(),
+                })
+            }
+        }
+
         return Ok(Directory {
             path: path.to_string(),
             timeout,
         });
     }
 
-    let message = vfs_request(path, VfsAction::CreateDir)
+    let message = vfs_request(path, VfsAction::CreateDirAll)
         .send_and_await_response(timeout)
         .unwrap()
         .map_err(|e| VfsError::IOError {