test: add disk-customization test

This commit adds a new integration test that checks for the disk
customizations. It exchanges some of the filesystem tests with
disk customization tests.

test/test_build.py

@@ -38,6 +38,7 @@ class ImageBuildResult(NamedTuple):
     img_arch: str
     container_ref: str
     rootfs: str
+    disk_config: str
     username: str
     password: str
     ssh_keyfile_private_path: str
@@ -327,7 +328,8 @@ def build_images(shared_tmpdir, build_container, request, force_aws_upload, gpg_
             bib_output = bib_output_path.read_text(encoding="utf8")
             results.append(ImageBuildResult(
                 image_type, generated_img, tc.target_arch,
-                container_ref, tc.rootfs, username, password,
+                container_ref, tc.rootfs, tc.disk_config,
+                username, password,
                 ssh_keyfile_private_path, kargs, bib_output, journal_output))
 
     # generate new keyfile
@@ -368,12 +370,13 @@ def build_images(shared_tmpdir, build_container, request, force_aws_upload, gpg_
                     "groups": ["wheel"],
                 },
             ],
-            "filesystem": testutil.create_filesystem_customizations(tc.rootfs),
             "kernel": {
                 "append": kargs,
             },
         },
     }
+    testutil.maybe_create_filesystem_customizations(cfg, tc)
+    testutil.maybe_create_disk_customizations(cfg, tc)
 
     config_json_path = output_path / "config.json"
     config_json_path.write_text(json.dumps(cfg), encoding="utf-8")
@@ -473,7 +476,8 @@ def del_ami():
     for image_type in image_types:
         results.append(ImageBuildResult(
             image_type, artifact[image_type], tc.target_arch,
-            container_ref, tc.rootfs, username, password,
+            container_ref, tc.rootfs, tc.disk_config,
+            username, password,
             ssh_keyfile_private_path, kargs, bib_output, journal_output, metadata))
     yield results
 
@@ -532,19 +536,10 @@ def test_image_boots(image_type):
         # XXX: read the fully yaml instead?
         assert f"image: {image_type.container_ref}" in output
 
-        # check the minsize specified in the build configuration for each mountpoint against the sizes in the image
-        # TODO: replace 'df' call with 'parted --json' and find the partition size for each mountpoint
-        exit_status, output = test_vm.run("df --output=target,size", user="root",
-                                          keyfile=image_type.ssh_keyfile_private_path)
-        assert exit_status == 0
-        # parse the output of 'df' to a mountpoint -> size dict for convenience
-        mountpoint_sizes = {}
-        for line in output.splitlines()[1:]:
-            fields = line.split()
-            # Note that df output is in 1k blocks, not bytes
-            mountpoint_sizes[fields[0]] = int(fields[1]) * 2 ** 10  # in bytes
-
-        assert_fs_customizations(image_type, mountpoint_sizes)
+        if image_type.disk_config:
+            assert_disk_customizations(image_type, test_vm)
+        else:
+            assert_fs_customizations(image_type, test_vm)
 
 
 @pytest.mark.parametrize("image_type", gen_testcases("ami-boot"), indirect=["image_type"])
@@ -663,17 +658,52 @@ def test_multi_build_request(images):
     assert artifacts == expected
 
 
-def assert_fs_customizations(image_type, mountpoint_sizes):
+def assert_fs_customizations(image_type, test_vm):
     """
     Asserts that each mountpoint that appears in the build configuration also appears in mountpoint_sizes.
 
     TODO: assert that the size of each filesystem (or partition) also matches the expected size based on the
     customization.
     """
-    fs_customizations = testutil.create_filesystem_customizations(image_type.rootfs)
-    for fs in fs_customizations:
+    # check the minsize specified in the build configuration for each mountpoint against the sizes in the image
+    # TODO: replace 'df' call with 'parted --json' and find the partition size for each mountpoint
+    exit_status, output = test_vm.run("df --output=target,size", user="root",
+                                      keyfile=image_type.ssh_keyfile_private_path)
+    assert exit_status == 0
+    # parse the output of 'df' to a mountpoint -> size dict for convenience
+    mountpoint_sizes = {}
+    for line in output.splitlines()[1:]:
+        fields = line.split()
+        # Note that df output is in 1k blocks, not bytes
+        mountpoint_sizes[fields[0]] = int(fields[1]) * 2 ** 10  # in bytes
+
+    cfg = {
+        "customizations": {},
+    }
+    testutil.maybe_create_filesystem_customizations(cfg, image_type)
+    for fs in cfg["customizations"]["filesystem"]:
         mountpoint = fs["mountpoint"]
         if mountpoint == "/":
             # / is actually /sysroot
             mountpoint = "/sysroot"
         assert mountpoint in mountpoint_sizes
+
+
+def assert_disk_customizations(image_type, test_vm):
+    exit_status, output = test_vm.run("findmnt --json", user="root",
+                                      keyfile=image_type.ssh_keyfile_private_path)
+    assert exit_status == 0
+    findmnt = json.loads(output)
+    if dc := image_type.disk_config:
+        if dc == "lvm":
+            mnts = [mnt for mnt in findmnt["filesystems"][0]["children"]
+                    if mnt["target"] == "/sysroot"]
+            assert len(mnts) == 1
+            assert "/dev/mapper/vg00-rootlv" == mnts[0]["source"]
+        elif dc == "btrfs":
+            mnts = [mnt for mnt in findmnt["filesystems"][0]["children"]
+                    if mnt["target"] == "/sysroot"]
+            assert len(mnts) == 1
+            assert "btrfs" == mnts[0]["fstype"]
+            # ensure sysroot comes from the "root" subvolume
+            assert mnts[0]["source"].endswith("[/root]")

test/testcases.py

@@ -25,8 +25,8 @@ class TestCase:
     rootfs: str = ""
     # Sign the container_ref and use the new signed image instead of the original one
     sign: bool = False
-    # use special partition_mode like "lvm"
-    partition_mode: str = ""
+    # use special disk_config like "lvm"
+    disk_config: str = ""
 
     def bib_rootfs_args(self):
         if self.rootfs:
@@ -92,9 +92,10 @@ def gen_testcases(what):  # pylint: disable=too-many-return-statements
         # and custom with raw (this is arbitrary, we could do it the
         # other way around too
         test_cases.append(
-            TestCaseCentos(image="raw", partition_mode="lvm"))
+            TestCaseCentos(image="raw", disk_config="lvm"))
         test_cases.append(
-            TestCaseFedora(image="raw", partition_mode="btrfs"))
+            # drop roofs from Fedora here as we add it via disk_config
+            TestCaseFedora(image="raw", disk_config="btrfs", rootfs=""))
         # do a cross arch test too
         if platform.machine() == "x86_64":
             # TODO: re-enable once

test/testutil.py

@@ -109,18 +109,21 @@ def deregister_ami(ami_id):
         print(f"Error {err_code}: {err_msg}")
 
 
-def create_filesystem_customizations(rootfs: str):
-    if rootfs == "btrfs":
+def maybe_create_filesystem_customizations(cfg, tc):
+    # disk_config and filesystem_customization are mutually exclusive
+    if tc.disk_config:
+        return
+    if tc.rootfs == "btrfs":
         # only minimal customizations are supported for btrfs currently
-        return [
+        cfg["customizations"]["filesystem"] = [
             {
                 "mountpoint": "/",
                 "minsize": "12 GiB"
             },
         ]
-
+        return
     # add some custom mountpoints
-    return [
+    cfg["customizations"]["filesystem"] = [
         {
             "mountpoint": "/",
             "minsize": "12 GiB"
@@ -140,6 +143,49 @@ def create_filesystem_customizations(rootfs: str):
     ]
 
 
+def maybe_create_disk_customizations(cfg, tc):
+    if not tc.disk_config:
+        return
+    if tc.disk_config == "lvm":
+        cfg["customizations"]["disk"] = {
+            # XXX: needed because we have no defaults in images currently
+            "minsize": "10 GiB",
+            "partitions": [
+                {
+                    "type": "lvm",
+                    "logical_volumes": [
+                        {
+                            # XXX: without this we get
+                            # .pipelines[1].stages[2].options.volumes[0].size:
+                            #    '0B' does not match '[1-9][0-9]*[bBsSkKmMgGtTpPeE]?'
+                            "minsize": 10000000000,
+                            "fs_type": "xfs",
+                            "mountpoint": "/",
+                        }
+                    ]
+                }
+            ]
+        }
+    elif tc.disk_config == "btrfs":
+        cfg["customizations"]["disk"] = {
+            # XXX: needed because we have no defaults in images currently
+            "minsize": "10 GiB",
+            "partitions": [
+                {
+                    "type": "btrfs",
+                    "subvolumes": [
+                        {
+                            "name": "varlog",
+                            "mountpoint": "/var/log",
+                        }
+                    ]
+                }
+            ]
+        }
+    else:
+        raise ValueError(f"unsupported disk_config {tc.disk_config}")
+
+
 # podman_run_common has the common prefix for the podman run invocations
 podman_run_common = [
     "podman", "run", "--rm",