lxd/storage/drivers/powerflex: Add volume restore support

Signed-off-by: Julian Pelizäus <[email protected]>

lxd/storage/drivers/driver_powerflex_utils.go

@@ -379,6 +379,23 @@ func (p *powerFlexClient) setVolumeSize(volumeID string, sizeGiB int64) error {
 	return nil
 }
 
+// overwriteVolume overwrites the volumes contents behind volumeID with the given snapshot.
+func (p *powerFlexClient) overwriteVolume(volumeID string, snapshotID string) error {
+	body, err := p.createBodyReader(map[string]any{
+		"srcVolumeId": snapshotID,
+	})
+	if err != nil {
+		return err
+	}
+
+	err = p.requestAuthenticated(http.MethodPost, fmt.Sprintf("/api/instances/Volume::%s/action/overwriteVolumeContent", volumeID), body, nil)
+	if err != nil {
+		return fmt.Errorf("Failed to overwrite volume: %q: %w", volumeID, err)
+	}
+
+	return nil
+}
+
 // createVolumeSnapshot creates a new volume snapshot under the given systemID for the volume behind volumeID.
 // The accessMode can be either ReadWrite or ReadOnly.
 // The returned string represents the ID of the snapshot.

lxd/storage/drivers/driver_powerflex_volumes.go

@@ -872,7 +872,28 @@ func (d *powerflex) VolumeSnapshots(vol Volume, op *operations.Operation) ([]str
 
 // RestoreVolume restores a volume from a snapshot.
 func (d *powerflex) RestoreVolume(vol Volume, snapshotName string, op *operations.Operation) error {
-	return ErrNotSupported
+	ourUnmount, err := d.UnmountVolume(vol, false, op)
+	if err != nil {
+		return err
+	}
+
+	if ourUnmount {
+		defer func() { _ = d.MountVolume(vol, op) }()
+	}
+
+	client := d.client()
+	volumeID, err := client.getVolumeID(d.getVolumeName(vol, ""))
+	if err != nil {
+		return err
+	}
+
+	snapVol := NewVolume(d, d.name, vol.volType, vol.contentType, fmt.Sprintf("%s/%s", vol.Name(), snapshotName), nil, nil)
+	snapshotID, err := client.getVolumeID(d.getVolumeName(snapVol, ""))
+	if err != nil {
+		return err
+	}
+
+	return client.overwriteVolume(volumeID, snapshotID)
 }
 
 // RenameVolumeSnapshot renames a volume snapshot.