uqbar-dao/nectar
1
1
Fork 0
mirror of https://github.com/uqbar-dao/nectar.git synced 2025-01-02 13:36:47 +03:00
Code Issues Packages Projects Releases Wiki Activity

vfs: hotfix cursor position addzip

Browse Source
This commit is contained in:
bitful-pannul 2024-01-09 23:37:00 -03:00
parent 87bb23e146
commit cda752f43c
1 changed files with 8 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
src/vfs.rs
View File

@ -193,10 +193,7 @@ async fn handle_request(
error: "blob needs to exist for Write".into(),
});
};
open_files.remove(&path);
let file = open_file(open_files.clone(), path, true, true).await?;
let mut file = file.lock().await;
file.write_all(&blob.bytes).await?;
fs::write(path, &blob.bytes).await?;
(serde_json::to_vec(&VfsResponse::Ok).unwrap(), None)
}
VfsAction::Append => {
@ -219,12 +216,7 @@ async fn handle_request(
(serde_json::to_vec(&VfsResponse::Ok).unwrap(), None)
}
VfsAction::Read => {
let file = open_file(open_files.clone(), path.clone(), false, false).await?;
let mut file = file.lock().await;
let mut contents = Vec::new();
file.seek(SeekFrom::Start(0)).await?;
file.read_to_end(&mut contents).await?;
let contents = fs::read(&path).await?;
(
serde_json::to_vec(&VfsResponse::Read).unwrap(),
Some(contents),
@ -403,15 +395,8 @@ async fn handle_request(
(is_file, is_dir, local_path, file_contents)
};
if is_file {
open_files.remove(&local_path);
let file = open_file(open_files.clone(), local_path, true, true).await?;
let mut file = file.lock().await;
file.seek(SeekFrom::Start(0)).await?;
file.write_all(&file_contents).await?;
file.set_len(file_contents.len() as u64).await?;
fs::write(&local_path, &file_contents).await?;
} else if is_dir {
// If it's a directory, create it
fs::create_dir_all(local_path).await?;
} else {
println!("vfs: zip with non-file non-dir");
@ -509,7 +494,11 @@ async fn open_file<P: AsRef<Path>>(
) -> Result<Arc<Mutex<fs::File>>, VfsError> {
let path = path.as_ref().to_path_buf();
Ok(match open_files.get(&path) {
Some(file) => Arc::clone(file.value()),
Some(file) => {
let mut file_lock = file.lock().await;
file_lock.seek(SeekFrom::Start(0)).await?;
Arc::clone(file.value())
}
None => {
let file = Arc::new(Mutex::new(
OpenOptions::new()