tests/integration: Add integration tests for create_host_path implementation

Signed-off-by: Monika Kairaityte <[email protected]>

Author: mokibit

tests/integration/vol/long_syntax/__init__.py

@@ -0,0 +1,29 @@
+version: "3"
+services:
+  create_host_path_default_true: # default is to always create
+    image: docker.io/library/debian
+    command: "echo test1"
+    volumes:
+      - type: bind
+        source: ./test_dir
+        target: /data
+  create_host_path_true:
+    image: docker.io/library/debian
+    command: "echo test2"
+    volumes:
+      - type: bind
+        source: ./test_dir
+        target: /data
+        bind:
+          create_host_path: true
+  create_host_path_false:
+    image: docker.io/library/debian
+    command: "echo test3"
+    volumes:
+      - type: bind
+        source: ./test_dir
+        target: /data
+        bind:
+          create_host_path: false
+
+

tests/integration/vol/long_syntax/docker-compose.yml

@@ -0,0 +1,105 @@
+# SPDX-License-Identifier: GPL-2.0
+
+import os
+import shutil
+import unittest
+
+from parameterized import parameterized
+
+from tests.integration.test_utils import RunSubprocessMixin
+from tests.integration.test_utils import podman_compose_path
+from tests.integration.test_utils import test_path
+
+
+def compose_yaml_path(test_ref_folder: str) -> str:
+    return os.path.join(test_path(), "vol", test_ref_folder, "docker-compose.yml")
+
+
+class TestComposeVolLongSyntax(unittest.TestCase, RunSubprocessMixin):
+    @parameterized.expand([
+        (True, "create_host_path_default_true", "test1\n"),
+        (True, "create_host_path_true", "test2\n"),
+        (True, "create_host_path_false", "test3\n"),
+        (False, "create_host_path_default_true", "test1\n"),
+        (False, "create_host_path_true", "test2\n"),
+    ])
+    def test_source_host_dir(
+        self, source_dir_exists: bool, service_name: str, log_output: str
+    ) -> None:
+        project_dir = os.path.join(test_path(), "vol", "long_syntax")
+        if source_dir_exists:
+            # create host source directory for volume
+            os.mkdir(os.path.join(project_dir, "test_dir"))
+
+        initial_dirs = set(os.listdir(project_dir))
+        try:
+            output, _, return_code = self.run_subprocess([
+                podman_compose_path(),
+                "-f",
+                compose_yaml_path("long_syntax"),
+                "up",
+                "-d",
+                f"{service_name}",
+            ])
+            self.assertEqual(return_code, 0)
+
+            output, _, return_code = self.run_subprocess([
+                podman_compose_path(),
+                "-f",
+                compose_yaml_path("long_syntax"),
+                "logs",
+                f"{service_name}",
+            ])
+            self.assertEqual(return_code, 0)
+            self.assertEqual(f"{log_output}", output.decode('utf-8'))
+
+            if source_dir_exists:
+                # new directories were not created as source host directory already exists
+                final_dirs = set(os.listdir(project_dir))
+                self.assertEqual(initial_dirs, final_dirs)
+            else:
+                # new directory was created as source host directory did not exist
+                final_dirs = set(os.listdir(project_dir))
+                new_dir = final_dirs - initial_dirs
+                self.assertIn("test_dir", new_dir)
+        finally:
+            self.run_subprocess_assert_returncode([
+                podman_compose_path(),
+                "-f",
+                compose_yaml_path("long_syntax"),
+                "down",
+                "-t",
+                "0",
+            ])
+            shutil.rmtree(os.path.join(project_dir, "test_dir"))
+
+    def test_no_source_host_dir_create_host_path_false(self) -> None:
+        project_dir = os.path.join(test_path(), "vol", "long_syntax")
+        initial_dirs = set(os.listdir(project_dir))
+        try:
+            _, error, return_code = self.run_subprocess([
+                podman_compose_path(),
+                "-f",
+                compose_yaml_path("long_syntax"),
+                "up",
+                "-d",
+                "create_host_path_false",
+            ])
+            self.assertEqual(return_code, 1)
+            self.assertIn(
+                b"invalid mount config for type 'bind': bind source path does not exist:", error
+            )
+
+            # new directories were not created
+            final_dirs = set(os.listdir(project_dir))
+            self.assertEqual(initial_dirs, final_dirs)
+
+        finally:
+            self.run_subprocess_assert_returncode([
+                podman_compose_path(),
+                "-f",
+                compose_yaml_path("long_syntax"),
+                "down",
+                "-t",
+                "0",
+            ])

tests/integration/vol/long_syntax/test_podman_compose_vol_long_syntax.py

@@ -0,0 +1,12 @@
+version: "3"
+services:
+  test1:
+    image: docker.io/library/debian
+    command: "echo test1"
+    volumes:
+      - ./test_dir:/cont/data
+  test2:
+    image: docker.io/library/debian
+    command: "echo test2"
+    volumes:
+      - ./not_exists:/cont/data

tests/integration/vol/short_syntax/__init__.py

@@ -0,0 +1,79 @@
+# SPDX-License-Identifier: GPL-2.0
+
+import os
+import shutil
+import unittest
+
+from tests.integration.test_utils import RunSubprocessMixin
+from tests.integration.test_utils import podman_compose_path
+from tests.integration.test_utils import test_path
+
+
+def compose_yaml_path(test_ref_folder: str) -> str:
+    return os.path.join(test_path(), "vol", test_ref_folder, "docker-compose.yml")
+
+
+class TestComposeVolShortSyntax(unittest.TestCase, RunSubprocessMixin):
+    def test_source_host_dir(self) -> None:
+        project_dir = os.path.join(test_path(), "vol", "short_syntax")
+        initial_dirs = set(os.listdir(project_dir))
+        try:
+            output, _, return_code = self.run_subprocess([
+                podman_compose_path(),
+                "-f",
+                compose_yaml_path("short_syntax"),
+                "up",
+                "-d",
+                "test1",
+            ])
+            self.assertEqual(return_code, 0)
+
+            output, _, return_code = self.run_subprocess([
+                podman_compose_path(),
+                "-f",
+                compose_yaml_path("short_syntax"),
+                "logs",
+                "test1",
+            ])
+            self.assertEqual(return_code, 0)
+            self.assertEqual(output, b'test1\n')
+
+            final_dirs = set(os.listdir(project_dir))
+            # new directories were not created as source host directory already exists
+            self.assertEqual(initial_dirs, final_dirs)
+
+            output, _, return_code = self.run_subprocess([
+                podman_compose_path(),
+                "-f",
+                compose_yaml_path("short_syntax"),
+                "up",
+                "-d",
+                "test2",
+            ])
+            self.assertEqual(return_code, 0)
+
+            output, _, return_code = self.run_subprocess([
+                podman_compose_path(),
+                "-f",
+                compose_yaml_path("short_syntax"),
+                "logs",
+                "test2",
+            ])
+            self.assertEqual(return_code, 0)
+            self.assertEqual(output, b'test2\n')
+
+            # new directory was created as source host directory did not exist
+            final_dirs = set(os.listdir(project_dir))
+            new_dir = final_dirs - initial_dirs
+            self.assertIn("not_exists", new_dir)
+        finally:
+            self.run_subprocess_assert_returncode([
+                podman_compose_path(),
+                "-f",
+                compose_yaml_path("short_syntax"),
+                "down",
+                "-t",
+                "0",
+            ])
+            dir_path = os.path.join(project_dir, "not_exists")
+            shutil.rmtree(dir_path)