feat(services/opfs): add read, write, and stat support

core/edge/opfs_wasm32/Cargo.toml

@@ -0,0 +1,39 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License.  You may obtain a copy of the License at
+#
+#   http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations
+# under the License.
+
+[package]
+name = "edge_test_opfs_wasm32"
+
+edition.workspace = true
+license.workspace = true
+publish = false
+rust-version.workspace = true
+version.workspace = true
+
+[lib]
+crate-type = ["cdylib"]
+
+[dependencies]
+opendal = { path = "../..", default-features = false, features = [
+  "services-opfs",
+] }
+wasm-bindgen = "0.2.89"
+wasm-bindgen-futures = "0.4.39"
+web-sys = { version = "0.3.77", features = ["console"] }
+
+[dev-dependencies]
+wasm-bindgen-test = "0.3.41"

core/edge/opfs_wasm32/README.md

@@ -0,0 +1,27 @@
+# OPFS on WASM
+
+This test verifies the OpenDAL OPFS service works in a browser environment.
+
+## Install
+
+```shell
+cargo install wasm-pack
+```
+
+## Build
+
+```shell
+wasm-pack build
+```
+
+## Test
+
+NOTE:
+
+- You need to have Chrome installed.
+- OPFS requires a browser context (no Node.js support).
+- Headless Chrome may not work for OPFS tests.
+
+```shell
+wasm-pack test --chrome
+```

core/edge/opfs_wasm32/src/lib.rs

@@ -0,0 +1,146 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership.  The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License.  You may obtain a copy of the License at
+//
+//   http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+#![cfg(target_arch = "wasm32")]
+#[cfg(test)]
+mod tests {
+    use opendal::EntryMode;
+    use opendal::ErrorKind;
+    use opendal::Operator;
+    use opendal::services::Opfs;
+    use opendal::services::OpfsConfig;
+    use wasm_bindgen_test::wasm_bindgen_test;
+    use wasm_bindgen_test::wasm_bindgen_test_configure;
+
+    macro_rules! console_log {
+        ($($arg:tt)*) => {
+            web_sys::console::log_1(&format!($($arg)*).into())
+        };
+    }
+
+    wasm_bindgen_test_configure!(run_in_browser);
+
+    fn new_operator() -> Operator {
+        Operator::from_config(OpfsConfig::default())
+            .expect("failed to create opfs operator")
+            .finish()
+    }
+
+    #[wasm_bindgen_test]
+    async fn test_create_directory_handle() {
+        let op = new_operator();
+        op.create_dir("/dir/").await.expect("directory");
+        op.create_dir("/dir///").await.expect("directory");
+        op.create_dir("/dir:/").await.expect("directory");
+        op.create_dir("/dir<>/").await.expect("directory");
+        assert_eq!(
+            op.create_dir("/a/b/../x/y/z/").await.unwrap_err().kind(),
+            ErrorKind::Unexpected
+        );
+    }
+
+    #[wasm_bindgen_test]
+    async fn test_write() {
+        let op = new_operator();
+
+        assert_eq!(
+            op.write("/", "should_not_work").await.unwrap_err().kind(),
+            ErrorKind::IsADirectory
+        );
+    }
+
+    #[wasm_bindgen_test]
+    async fn test_write_read_simple() {
+        let path = "/test_wr_simple";
+        let content = "Content of the file to write";
+        let op = new_operator();
+
+        let meta = op.write(path, content).await.expect("write");
+        console_log!("{:?}", meta);
+        assert_eq!(meta.content_length(), content.len() as u64);
+        assert!(meta.last_modified().is_none());
+
+        let stat = op.stat(path).await.expect("stat");
+        console_log!("stat = {:?}", stat);
+        assert_eq!(stat.mode(), EntryMode::FILE);
+        assert_eq!(stat.content_length(), content.len() as u64);
+        assert!(stat.last_modified().is_some());
+
+        let buffer = op.read(path).await.expect("read");
+        console_log!("read = {:?}", buffer);
+        assert_eq!(buffer.to_bytes(), content.as_bytes());
+    }
+
+    #[wasm_bindgen_test]
+    async fn test_write_twice_same_file() {
+        let op = new_operator();
+        let content = "Content of the file to write";
+        let path = "/test_wr_twice";
+        let _meta = op.write(path, content).await.expect("write");
+        let meta = op.write(path, content).await.expect("write");
+        assert_eq!(meta.content_length(), content.len() as u64);
+        assert!(meta.last_modified().is_none());
+    }
+
+    #[wasm_bindgen_test]
+    async fn test_write_multi_chunks() {
+        let op = new_operator();
+        let content = "Content of the file to write";
+        let path = "/test_wr_multi";
+        let mut w = op.writer(path).await.expect("writer");
+        w.write(content).await.expect("write");
+        w.write(content).await.expect("write");
+        w.write(content).await.expect("write");
+        let meta = w.close().await.expect("close");
+        let expected_file_size = (content.len() as u64) * 3;
+        assert_eq!(meta.content_length(), expected_file_size);
+        assert!(meta.last_modified().is_none());
+        let stat = op.stat(path).await.expect("stat");
+        assert_eq!(stat.content_length(), expected_file_size);
+    }
+
+    #[wasm_bindgen_test]
+    async fn test_write_with_root() {
+        let op_rooted = Operator::new(Opfs::default().root("/myapp/subdir1/subdir2/"))
+            .expect("config")
+            .finish();
+        op_rooted
+            .write("subdir3/somefile", "content")
+            .await
+            .expect("write under root");
+
+        let stat_rooted = op_rooted.stat("subdir3/somefile").await.expect("stat");
+        console_log!("stat_rooted = {:?}", stat_rooted);
+
+        let op = new_operator();
+        let stat = op
+            .stat("/myapp/subdir1/subdir2/subdir3/somefile")
+            .await
+            .expect("stat");
+        assert_eq!(stat.content_length(), stat_rooted.content_length());
+    }
+
+    #[wasm_bindgen_test]
+    async fn test_read_with_range() {
+        let op = new_operator();
+        let path = "/test_wr_range";
+        let content = "0123456789";
+        let _meta = op.write(path, content).await.expect("write");
+        let buffer = op.read_with(path).range(3..5).await.expect("read");
+        assert_eq!(buffer.to_bytes(), "34".as_bytes());
+    }
+}

core/edge/opfs_wasm32/webdriver.json

@@ -0,0 +1,15 @@
+{
+  "moz:firefoxOptions": {
+    "prefs": {
+      "media.navigator.streams.fake": true,
+      "media.navigator.permission.disabled": true
+    },
+    "args": []
+  },
+  "goog:chromeOptions": {
+    "args": [
+      "--use-fake-device-for-media-stream",
+      "--use-fake-ui-for-media-stream"
+    ]
+  }
+}

core/services/opfs/Cargo.toml

@@ -33,17 +33,23 @@ all-features = true
 [target.'cfg(target_arch = "wasm32")'.dependencies]
 js-sys = "0.3.77"
 opendal-core = { path = "../../core", version = "0.55.0", default-features = false }
+send_wrapper = "0.6"
 serde = { workspace = true, features = ["derive"] }
 wasm-bindgen = "0.2.100"
 wasm-bindgen-futures = "0.4.50"
 web-sys = { version = "0.3.77", features = [
-  "Window",
+  "Blob",
+  "console",
+  "DomException",
   "File",
   "FileSystemDirectoryHandle",
   "FileSystemFileHandle",
   "FileSystemGetDirectoryOptions",
   "FileSystemGetFileOptions",
   "FileSystemWritableFileStream",
   "Navigator",
+  "WriteCommandType",
+  "WriteParams",
   "StorageManager",
+  "Window",
 ] }