force make filesystem on a device (#935)

* force make filesystem on a device

pkg/storage/filesystem/btrfs.go

@@ -54,6 +54,14 @@ func NewBtrfs(manager DeviceManager) Filesystem {
 }
 
 func (b *btrfs) Create(ctx context.Context, name string, policy pkg.RaidProfile, devices ...*Device) (Pool, error) {
+	return b.create(ctx, name, policy, false, devices)
+}
+
+func (b *btrfs) CreateForce(ctx context.Context, name string, policy pkg.RaidProfile, devices ...*Device) (Pool, error) {
+	return b.create(ctx, name, policy, true, devices)
+}
+
+func (b *btrfs) create(ctx context.Context, name string, policy pkg.RaidProfile, force bool, devices []*Device) (Pool, error) {
 	name = strings.TrimSpace(name)
 	if len(name) == 0 {
 		return nil, fmt.Errorf("invalid name")
@@ -83,6 +91,10 @@ func (b *btrfs) Create(ctx context.Context, name string, policy pkg.RaidProfile,
 		"-m", string(policy),
 	}
 
+	if force {
+		args = append(args, "-f")
+	}
+
 	args = append(args, paths...)
 	if _, err := b.utils.run(ctx, "mkfs.btrfs", args...); err != nil {
 		return nil, err

pkg/storage/filesystem/filesystem.go

@@ -79,6 +79,10 @@ type Filesystem interface {
 	// devices: list of devices to use in the filesystem
 	// profile: Raid profile of the filesystem
 	Create(ctx context.Context, name string, profile pkg.RaidProfile, devices ...*Device) (Pool, error)
+
+	// CreateForce creates a new filesystem with force
+	// It will delete existing data and partition tables
+	CreateForce(ctx context.Context, name string, profile pkg.RaidProfile, devices ...*Device) (Pool, error)
 	// List all existing filesystems on the node
 	List(ctx context.Context, filter Filter) ([]Pool, error)
 }

pkg/storage/storage.go

@@ -256,7 +256,7 @@ func (s *storageModule) initialize(policy pkg.StoragePolicy) error {
 				poolDevices = append(poolDevices, &fdisks[idx][i*int(policy.Disks)+j])
 			}
 
-			pool, err := fs.Create(ctx, uuid.New().String(), policy.Raid, poolDevices...)
+			pool, err := fs.CreateForce(ctx, uuid.New().String(), policy.Raid, poolDevices...)
 			if err != nil {
 				log.Info().Err(err).Msg("create filesystem")