Debugging engine issues

pyproject.toml

@@ -4,10 +4,10 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "xpublish_opendap"
-description = ""
+description = "OpenDAP plugin for Xpublish"
 readme = "README.md"
 requires-python = ">=3.9"
-keywords = []
+keywords = ["xarray", "xpublish", "wms"]
 license = { file = "LICENSE.txt" }
 
 classifiers = [

requirements-dev.txt

@@ -1,17 +1,21 @@
 black
 check-manifest
 doctr
+h5netcdf
+h5pyd
 httpx
 nbsphinx
 netCDF4
 pooch
 pre-commit
+pydap
 pylint
 pytest
 pytest-cov
 pytest-flake8
 pytest-github-actions-annotate-failures
 pytest-xdist
+pytest-xprocess
 recommonmark
 ruff
 setuptools_scm

tests/conftest.py

@@ -0,0 +1,45 @@
+"""Py.test configuration and shared fixtures."""
+from pathlib import Path
+
+import pytest
+from xprocess import ProcessStarter
+
+server_path = Path(__file__).parent / "server.py"
+
+
+@pytest.fixture
+def xpublish_server(xprocess):
+    """Launch an Xpublish server in the background.
+
+    Server has the air_temperature tutorial dataset
+    at `air` and has the OpenDAP plugin running with
+    defaults.
+    """
+
+    class Starter(ProcessStarter):
+        # Wait till the pattern is printed before
+        # considering things started
+        pattern = "Uvicorn running on"
+
+        # server startup args
+        args = ["python", str(server_path)]
+
+        # seconds before timing out on server startup
+        timeout = 30
+
+        # Try to cleanup if inturrupted
+        terminate_on_interrupt = True
+
+    xprocess.ensure("xpublish", Starter)
+    yield "http://0.0.0.0:9000"
+    xprocess.getinfo("xpublish").terminate()
+
+
+@pytest.fixture(scope="session")
+def dataset():
+    """Xarray air temperature tutorial dataset."""
+    from xarray.tutorial import open_dataset
+
+    ds = open_dataset("air_temperature")
+
+    return ds

tests/server.py

@@ -0,0 +1,11 @@
+"""Test OpenDAP server with air temperature dataset."""
+import xarray.tutorial
+import xpublish
+
+from xpublish_opendap import OpenDapPlugin
+
+ds = xarray.tutorial.open_dataset("air_temperature")
+
+rest = xpublish.Rest({"air": ds}, plugins={"opendap": OpenDapPlugin()})
+
+rest.serve()

tests/test_server.py

@@ -0,0 +1,25 @@
+"""Test OpenDAP clients against Xpublish OpenDAP plugin."""
+import netCDF4
+import pytest
+import xarray as xr
+
+
+def test_netcdf4(xpublish_server):
+    """Test opening OpenDAP dataset directly with NetCDF4 library."""
+    url = f"{xpublish_server}/datasets/air/opendap"
+    netCDF4.Dataset(url)
+
+
+def test_default_xarray_engine(xpublish_server, dataset):
+    """Test opening OpenDAP dataset with default Xarray engine."""
+    url = f"{xpublish_server}/datasets/air/opendap"
+    ds = xr.open_dataset(url)
+    assert ds == dataset
+
+
+@pytest.mark.parametrize("engine", ["netcdf4", "h5netcdf", "pydap"])
+def test_xarray_engines(xpublish_server, engine, dataset):
+    """Test opening OpenDAP dataset with specified engines."""
+    url = f"{xpublish_server}/datasets/air/opendap"
+    ds = xr.open_dataset(url, engine=engine)
+    assert ds == dataset