tests/unit: Add unit tests for create_host_path implementation

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

Author: mokibit

tests/unit/test_container_to_args.py

@@ -679,6 +679,69 @@ async def test_volumes_bind_mount_source(
             ],
         )
 
+    @parameterized.expand([
+        (
+            "create_host_path_set_to_true",
+            {"bind": {"create_host_path": True}},
+        ),
+        (
+            "create_host_path_default_true",
+            {},
+        ),
+    ])
+    # creates a missing source dir
+    async def test_volumes_bind_mount_create_source_dir(self, test_name: str, bind: dict) -> None:
+        c = create_compose_mock()
+        c.prefer_volume_over_mount = True
+        cnt = get_minimal_container()
+
+        cnt["_service"] = cnt["service_name"]
+
+        volume_info = {
+            "type": "bind",
+            "source": "./not_exists/foo",
+            "target": "/mnt",
+        }
+        volume_info.update(bind)
+        cnt["volumes"] = [
+            volume_info,
+        ]
+
+        args = await container_to_args(c, cnt)
+
+        self.assertEqual(
+            args,
+            [
+                "--name=project_name_service_name1",
+                "-d",
+                "-v",
+                f"{get_test_file_path('./test_dirname/not_exists/foo')}:/mnt",
+                "--network=bridge:alias=service_name",
+                "busybox",
+            ],
+        )
+
+    # throws an error as the source path does not exist and its creation was suppressed with the
+    # create_host_path = False option
+    async def test_volumes_bind_mount_source_does_not_exist(self) -> None:
+        c = create_compose_mock()
+        c.prefer_volume_over_mount = True
+        cnt = get_minimal_container()
+
+        cnt["_service"] = cnt["service_name"]
+
+        cnt["volumes"] = [
+            {
+                "type": "bind",
+                "source": './not_exists/foo',
+                "target": "/mnt",
+                "bind": {"create_host_path": False},
+            }
+        ]
+
+        with self.assertRaises(ValueError):
+            await container_to_args(c, cnt)
+
     @parameterized.expand([
         ("not_compat", False, "test_project_name", "test_project_name_network1"),
         ("compat_no_dash", True, "test_project_name", "test_project_name_network1"),