Files
warewulf/overlays/mkfs/internal/mkfs_test.go
kosmolito 378abfc373 fix(mkfs): correctly handle already-formatted disks and conditional overwrite
- Updated `already_formatted()` to use `blkid` plus safe read-only mount for accurate filesystem detection.
- Added conditional `-f` flag to `mkfs` only when `overwrite: true` is set.
- Removed `continue` statements from the shell script to prevent runtime errors.
- Updated Go overlay snapshot tests to reflect new template rendering.
- Ensures disks with leftover signatures but no valid filesystem are properly reformatted during node provisioning.
2025-12-17 14:37:35 -07:00

240 lines
6.3 KiB
Go

package mkfs
import (
"bytes"
"testing"
"github.com/stretchr/testify/assert"
"github.com/warewulf/warewulf/internal/app/wwctl/overlay/show"
"github.com/warewulf/warewulf/internal/pkg/testenv"
"github.com/warewulf/warewulf/internal/pkg/wwlog"
)
func Test_mkfsOverlay(t *testing.T) {
tests := map[string]struct {
args []string
nodesConf string
output string
}{
"mkfs:20-mkfs.sh.ww (empty)": {
args: []string{"--quiet=true", "--render=node1", "mkfs", "warewulf/wwinit.d/20-mkfs.sh.ww"},
nodesConf: `
nodes:
node1: {}`,
output: `#!/bin/sh
PATH=$PATH:/sbin:/usr/sbin:/bin:/usr/bin
if ! command -v info >/dev/null; then
info() {
printf '%s\n' "$*"
}
fi
if ! command -v die >/dev/null; then
die() {
printf '%s\n' "$*" >&2
exit 1
}
fi
already_formatted() {
dev="$1"
# Step 1: check if blkid recognizes a filesystem
fs_type=$(blkid -o value -s TYPE "$dev" 2>/dev/null)
if [ -z "$fs_type" ]; then
# No recognized filesystem
return 1
fi
# Step 2: try mounting read-only to a temp dir
tmpdir=$(mktemp -d)
if mount -o ro,norecovery -t "$fs_type" "$dev" "$tmpdir" >/dev/null 2>&1; then
umount "$tmpdir"
rmdir "$tmpdir"
return 0 # usable filesystem
else
rmdir "$tmpdir"
return 1 # filesystem exists but not mountable → treat as unformatted
fi
}
if command -v mkfs >/dev/null ; then :
else
info "warewulf: mkfs not found"
fi
`,
},
"mkfs:20-mkfs.sh.ww (resource)": {
args: []string{"--quiet=true", "--render=node1", "mkfs", "warewulf/wwinit.d/20-mkfs.sh.ww"},
nodesConf: `
nodes:
node1:
resources:
mkfs:
- device: /dev/disk/by-partlabel/rootfs
type: ext4
- device: /dev/disk/by-partlabel/scratch
type: ext4
overwrite: true`,
output: `#!/bin/sh
PATH=$PATH:/sbin:/usr/sbin:/bin:/usr/bin
if ! command -v info >/dev/null; then
info() {
printf '%s\n' "$*"
}
fi
if ! command -v die >/dev/null; then
die() {
printf '%s\n' "$*" >&2
exit 1
}
fi
already_formatted() {
dev="$1"
# Step 1: check if blkid recognizes a filesystem
fs_type=$(blkid -o value -s TYPE "$dev" 2>/dev/null)
if [ -z "$fs_type" ]; then
# No recognized filesystem
return 1
fi
# Step 2: try mounting read-only to a temp dir
tmpdir=$(mktemp -d)
if mount -o ro,norecovery -t "$fs_type" "$dev" "$tmpdir" >/dev/null 2>&1; then
umount "$tmpdir"
rmdir "$tmpdir"
return 0 # usable filesystem
else
rmdir "$tmpdir"
return 1 # filesystem exists but not mountable → treat as unformatted
fi
}
if command -v mkfs >/dev/null ; then :
if false || ! already_formatted /dev/disk/by-partlabel/rootfs; then
info "warewulf: mkfs: formatting /dev/disk/by-partlabel/rootfs"
mkfs --type=ext4 /dev/disk/by-partlabel/rootfs || die "warewulf: mkfs: failed to format /dev/disk/by-partlabel/rootfs"
else
info "warewulf: mkfs: skipping /dev/disk/by-partlabel/rootfs"
fi
if true || ! already_formatted /dev/disk/by-partlabel/scratch; then
info "warewulf: mkfs: formatting /dev/disk/by-partlabel/scratch"
mkfs --type=ext4 -f /dev/disk/by-partlabel/scratch || die "warewulf: mkfs: failed to format /dev/disk/by-partlabel/scratch"
else
info "warewulf: mkfs: skipping /dev/disk/by-partlabel/scratch"
fi
else
info "warewulf: mkfs not found"
fi
`,
},
"mkfs:20-mkfs.sh.ww (native)": {
args: []string{"--quiet=true", "--render=node1", "mkfs", "warewulf/wwinit.d/20-mkfs.sh.ww"},
nodesConf: `
nodes:
node1:
filesystems:
/dev/disk/by-partlabel/rootfs:
format: ext4
path: /
/dev/disk/by-partlabel/scratch:
format: ext4
path: /scratch
wipe_filesystem: true
/dev/disk/by-partlabel/swap:
format: swap
path: swap`,
output: `#!/bin/sh
PATH=$PATH:/sbin:/usr/sbin:/bin:/usr/bin
if ! command -v info >/dev/null; then
info() {
printf '%s\n' "$*"
}
fi
if ! command -v die >/dev/null; then
die() {
printf '%s\n' "$*" >&2
exit 1
}
fi
already_formatted() {
dev="$1"
# Step 1: check if blkid recognizes a filesystem
fs_type=$(blkid -o value -s TYPE "$dev" 2>/dev/null)
if [ -z "$fs_type" ]; then
# No recognized filesystem
return 1
fi
# Step 2: try mounting read-only to a temp dir
tmpdir=$(mktemp -d)
if mount -o ro,norecovery -t "$fs_type" "$dev" "$tmpdir" >/dev/null 2>&1; then
umount "$tmpdir"
rmdir "$tmpdir"
return 0 # usable filesystem
else
rmdir "$tmpdir"
return 1 # filesystem exists but not mountable → treat as unformatted
fi
}
if command -v mkfs >/dev/null ; then :
if false || ! already_formatted /dev/disk/by-partlabel/rootfs; then
info "warewulf: mkfs: formatting /dev/disk/by-partlabel/rootfs"
mkfs --type=ext4 /dev/disk/by-partlabel/rootfs || die "warewulf: mkfs: failed to format /dev/disk/by-partlabel/rootfs"
else
info "warewulf: mkfs: skipping /dev/disk/by-partlabel/rootfs"
fi
if true || ! already_formatted /dev/disk/by-partlabel/scratch; then
info "warewulf: mkfs: formatting /dev/disk/by-partlabel/scratch"
mkfs --type=ext4 -f /dev/disk/by-partlabel/scratch || die "warewulf: mkfs: failed to format /dev/disk/by-partlabel/scratch"
else
info "warewulf: mkfs: skipping /dev/disk/by-partlabel/scratch"
fi
else
info "warewulf: mkfs not found"
fi
`,
},
}
for name, tt := range tests {
t.Run(name, func(t *testing.T) {
env := testenv.New(t)
defer env.RemoveAll()
env.ImportFile("var/lib/warewulf/overlays/mkfs/rootfs/warewulf/wwinit.d/20-mkfs.sh.ww", "../rootfs/warewulf/wwinit.d/20-mkfs.sh.ww")
env.WriteFile("etc/warewulf/nodes.conf", tt.nodesConf)
cmd := show.GetCommand()
cmd.SetArgs(tt.args)
stdout := bytes.NewBufferString("")
stderr := bytes.NewBufferString("")
logbuf := bytes.NewBufferString("")
cmd.SetOut(stdout)
cmd.SetErr(stderr)
wwlog.SetLogWriter(logbuf)
err := cmd.Execute()
assert.NoError(t, err)
assert.Empty(t, stdout.String())
assert.Empty(t, stderr.String())
assert.Equal(t, tt.output, logbuf.String())
})
}
}