feat: append to a file instead of overwriting while opening for disk …

…based file

fusio/src/impls/disk/monoio/fs.rs

@@ -21,16 +21,15 @@ impl Fs for MonoIoFs {
 
     async fn open_options(&self, path: &Path, options: OpenOptions) -> Result<Self::File, Error> {
         let local_path = path_to_local(path)?;
-
-        Ok(MonoioFile::from(
-            monoio::fs::OpenOptions::new()
-                .read(options.read)
-                .write(options.write)
-                .create(options.create)
-                .truncate(options.truncate)
-                .open(&local_path)
-                .await?,
-        ))
+        let file = monoio::fs::OpenOptions::new()
+            .read(options.read)
+            .write(options.write)
+            .create(options.create)
+            .truncate(options.truncate)
+            .open(&local_path)
+            .await?;
+        let metadata = file.metadata().await.expect("monoio: get metadat failed");
+        Ok(MonoioFile::new(file, metadata.len()))
     }
 
     async fn create_dir_all(path: &Path) -> Result<(), Error> {

fusio/src/impls/disk/monoio/mod.rs

@@ -52,6 +52,15 @@ impl From<File> for MonoioFile {
     }
 }
 
+impl MonoioFile {
+    pub(crate) fn new(file: File, pos: u64) -> Self {
+        Self {
+            file: Some(file),
+            pos,
+        }
+    }
+}
+
 impl Write for MonoioFile {
     async fn write_all<B: IoBuf>(&mut self, buf: B) -> (Result<(), Error>, B) {
         let (result, buf) = self

fusio/src/impls/disk/opfs/fs.rs

@@ -65,9 +65,9 @@ impl Fs for OPFS {
 
         cfg_if::cfg_if! {
             if #[cfg(feature = "sync")] {
-                Ok(Self::File::new(file_handle).await?)
+                Ok(Self::File::new(file_handle, options).await?)
             } else {
-                Ok(OPFSFile::new(file_handle))
+                Ok(OPFSFile::new(file_handle, options).await?)
             }
         }
     }