Initial integration tests (#16)

Co-authored-by: Martin Ruefenacht <martin.ruefenacht@lrz.de>

Author: martinruefenacht

src/pympistandard/__init__.py

@@ -13,7 +13,7 @@
 import importlib.resources
 import json
 from enum import Enum
-from typing import Union, Tuple
+from typing import Union, Tuple, Optional
 import logging
 import os
 
@@ -56,7 +56,9 @@ def unload() -> None:
 # TODO rename to load(api_version, mpi_version, path)
 @export
 def use_api_version(
-    version: Union[int, str] = "LATEST", given_path: Union[str, Path] = None
+    version: Union[int, str] = "LATEST",
+    given_path: Optional[Union[str, Path]] = None,
+    force_bundled: bool = False,
 ) -> None:
     """Sets the Python API interface which the user expects to use."""
 
@@ -66,7 +68,7 @@ def use_api_version(
     if version in (1, "LATEST"):
         _register_kinds_v1()
 
-        path = _resolve_path(given_path)
+        path = _resolve_path(given_path, force_bundled)
         _load_database_v1(path)
 
     else:
@@ -127,15 +129,21 @@ def _register_kinds_v1() -> None:
             KINDS[key.lower()] = item
 
 
-def _resolve_path(given_path: Union[str, Path] = None) -> Path:
+def _resolve_path(
+    given_path: Optional[Union[str, Path]] = None, force_bundled: bool = False
+) -> Path:
     """Find correct path to load apis.json from."""
 
+    if force_bundled:
+        with importlib.resources.path("pympistandard.data", "apis.json") as datapath:
+            path = datapath
+
     # convert str path to Path
-    if isinstance(given_path, str):
+    elif isinstance(given_path, str):
         given_path = Path(given_path)
 
     # use given path
-    if given_path is not None:
+    elif isinstance(given_path, Path):
         path = given_path / "apis.json"
 
     # use environment variable paths

tests/conftest.py

@@ -7,19 +7,19 @@
 
 
 # import pytest
-# 
-# 
+#
+#
 # from pympistandard.storage import KINDS, PROCEDURES
 # from pympistandard.procedure import Procedure
 # from pympistandard.kind import Kind
-# 
-# 
+#
+#
 # @pytest.fixture(scope="session", autouse=True)
 # def dataset() -> None:
 #     """Creates the test parsesets required for all tests."""
-# 
+#
 #     KINDS["return"] = Kind("RETURN", "LIS_RETURN", "ISO_C_RETURN", "F90_RETURN", "F08_RETURN")
-# 
+#
 #     PROCEDURES["mpi_procedure_name"] = Procedure(
 #         "MPI_Procedure_name",
 #         {
@@ -29,3 +29,16 @@
 #             "attributes": {"c_expressible": True},
 #         },
 #     )
+
+
+import pytest
+
+
+import pympistandard
+
+
+@pytest.fixture(scope="session")
+def bundled_dataset():
+    pympistandard.use_api_version(1, force_bundled=True)
+
+    return pympistandard

tests/test_integration.py

@@ -0,0 +1,44 @@
+"""
+This module contains tests which test the overall behaviour of pympistandard.
+"""
+
+
+def test_mpi_send_iso_c(bundled_dataset):
+    assert str(bundled_dataset.PROCEDURES.mpi_send.express.iso_c) == (
+        "int MPI_Send("
+        "const void* buf, "
+        "int count, "
+        "MPI_Datatype datatype, "
+        "int dest, "
+        "int tag, "
+        "MPI_Comm comm)"
+    )
+
+
+def test_mpi_comm_spawn_multiple(bundled_dataset):
+    assert str(bundled_dataset.PROCEDURES.mpi_comm_spawn_multiple.express.iso_c) == (
+        "int MPI_Comm_spawn_multiple("
+        "int count, char* array_of_commands[], "
+        "char** array_of_argv[], "
+        "const int array_of_maxprocs[], "
+        "const MPI_Info array_of_info[], "
+        "int root, "
+        "MPI_Comm comm, MPI_Comm* intercomm, "
+        "int array_of_errcodes[])"
+    )
+
+
+def test_mpi_allgatherv_init(bundled_dataset):
+    assert str(bundled_dataset.PROCEDURES.mpi_allgatherv_init.express.iso_c) == (
+        "int MPI_Allgatherv_init("
+        "const void* sendbuf, "
+        "int sendcount, "
+        "MPI_Datatype sendtype, "
+        "void* recvbuf, "
+        "const int recvcounts[], "
+        "const int displs[], "
+        "MPI_Datatype recvtype, "
+        "MPI_Comm comm, "
+        "MPI_Info info, "
+        "MPI_Request* request)"
+    )