test: cover UPath and DVC integrations (#68)

Author: PsiACE

.gitignore

@@ -5,6 +5,7 @@ venv/
 *.pyc
 .pdm-python
 .idea
+.downstreams/
 
 opendalfs.egg-info/
 dist/

pyproject.toml

@@ -30,12 +30,14 @@ bench = [
 test = [
     "boto3>=1.37.3",
     "dask[dataframe]==2026.8.0",
+    "dvc-objects==5.2.0",
     "pandas==3.0.5",
     "pyarrow>=22.0.0",
     "pytest>=8.4.0",
     "pytest-asyncio>=1.0.0",
     "pytest-cov>=6.1.1",
     "s3fs>=2025.5.1",
+    "universal-pathlib==0.3.10",
 ]
 dev = [
     { include-group = "bench" },

tests/integration/dvc_objects/test_filesystem.py

@@ -0,0 +1,44 @@
+"""dvc-objects compatibility cases migrated for issue #51.
+
+Source: dvc-objects 5.2.0,
+``tests/fs/test_generic.py::test_copy`` and
+``tests/fs/test_localfs.py::test_walk``. The operations pass an opendalfs
+instance through dvc-objects' existing ``MemoryFileSystem(fs=...)`` entry point.
+"""
+
+from dvc_objects.fs.memory import MemoryFileSystem
+
+from opendalfs import OpendalFileSystem
+
+
+def test_dvc_objects_find_walk_put_and_get(tmp_path):
+    fs = MemoryFileSystem(
+        fs=OpendalFileSystem(
+            scheme="memory",
+            asynchronous=False,
+            skip_instance_cache=True,
+        )
+    )
+    sources = {
+        tmp_path / "sources" / "one.txt": b"one",
+        tmp_path / "sources" / "nested" / "two.txt": b"two",
+    }
+    for path, content in sources.items():
+        path.parent.mkdir(parents=True, exist_ok=True)
+        path.write_bytes(content)
+
+    remote_paths = ["dataset/one.txt", "dataset/nested/two.txt"]
+    fs.put([str(path) for path in sources], remote_paths)
+
+    assert set(fs.find("dataset")) == set(remote_paths)
+    assert [
+        (root, set(dirs), set(files)) for root, dirs, files in fs.walk("dataset")
+    ] == [
+        ("dataset", {"nested"}, {"one.txt"}),
+        ("dataset/nested", set(), {"two.txt"}),
+    ]
+
+    downloads = [tmp_path / "downloads" / path for path in ("one.txt", "two.txt")]
+    fs.get(remote_paths, [str(path) for path in downloads])
+
+    assert [path.read_bytes() for path in downloads] == [b"one", b"two"]

tests/integration/universal_pathlib/test_upath.py

@@ -0,0 +1,28 @@
+"""universal_pathlib compatibility cases migrated for issue #51.
+
+Source: universal-pathlib 0.3.10,
+``docs/usage.md`` (the public ``protocol=`` constructor) and
+``upath/tests/cases.py`` (``make_test_files``, ``test_iterdir``,
+``test_write_text`` and ``test_write_bytes``).
+"""
+
+from upath import UPath
+
+from opendalfs import register_opendal_service
+
+
+def test_upath_protocol_read_write_and_listing():
+    protocol = register_opendal_service("memory")
+    root = UPath("universal-pathlib", protocol=protocol)
+
+    folder = root / "folder1"
+    folder.mkdir(parents=True)
+    (folder / "file1.txt").write_text("hello world")
+    (folder / "file2.txt").write_bytes(b"hello bytes")
+
+    assert (folder / "file1.txt").read_text() == "hello world"
+    assert (folder / "file2.txt").read_bytes() == b"hello bytes"
+    assert {path.name for path in folder.iterdir()} == {
+        "file1.txt",
+        "file2.txt",
+    }