journal: Store encryptionType in Config struct

Add encryptionType next to kmsID to support both block and file
encryption.

Signed-off-by: Marcel Lauhoff <marcel.lauhoff@suse.com>

internal/journal/voljournal.go

@@ -149,6 +149,9 @@ type Config struct {
 	// encryptKMS in which encryption passphrase was saved, default is no encryption
 	encryptKMSKey string
 
+	// encryptKMS in which encryption passphrase was saved, default is no encryption
+	encryptionType string
+
 	// ownerKey is used to identify the owner of the volume, can be used with some KMS configurations
 	ownerKey string
 
@@ -172,6 +175,7 @@ func NewCSIVolumeJournal(suffix string) *Config {
 		namespace:               "",
 		csiImageIDKey:           "csi.imageid",
 		encryptKMSKey:           "csi.volume.encryptKMS",
+		encryptionType:          "csi.volume.encryptionType",
 		ownerKey:                "csi.volume.owner",
 		backingSnapshotIDKey:    "csi.volume.backingsnapshotid",
 		commonPrefix:            "csi.",
@@ -191,6 +195,7 @@ func NewCSISnapshotJournal(suffix string) *Config {
 		namespace:               "",
 		csiImageIDKey:           "csi.imageid",
 		encryptKMSKey:           "csi.volume.encryptKMS",
+		encryptionType:          "csi.volume.encryptionType",
 		ownerKey:                "csi.volume.owner",
 		commonPrefix:            "csi.",
 	}
@@ -280,6 +285,7 @@ Return values:
 */
 func (conn *Connection) CheckReservation(ctx context.Context,
 	journalPool, reqName, namePrefix, snapParentName, kmsConfig string,
+	encryptionType util.EncryptionType,
 ) (*ImageData, error) {
 	var (
 		snapSource       bool
@@ -377,6 +383,14 @@ func (conn *Connection) CheckReservation(ctx context.Context,
 		}
 	}
 
+	if encryptionType != util.EncryptionTypeInvalid {
+		if savedImageAttributes.EncryptionType != encryptionType {
+			return nil, fmt.Errorf("internal state inconsistent, omap encryption type"+
+				" mismatch, request KMS (%s) volume UUID (%s) volume omap KMS (%d)",
+				kmsConfig, objUUID, savedImageAttributes.EncryptionType)
+		}
+	}
+
 	// TODO: skipping due to excessive poolID to poolname call, also this should never happen!
 	// check if journal pool points back to the passed in journal pool
 	// if savedJournalPoolID != journalPoolID {
@@ -530,6 +544,7 @@ Input arguments:
 	- namePrefix: Prefix to use when generating the image/subvolume name (suffix is an auto-generated UUID)
 	- parentName: Name of the parent image/subvolume if reservation is for a snapshot (optional)
 	- kmsConf: Name of the key management service used to encrypt the image (optional)
+	- encryptionType: Type of encryption used when kmsConf is set (optional)
 	- volUUID: UUID need to be reserved instead of auto-generating one (this is useful for mirroring and metro-DR)
 	- owner: the owner of the volume (optional)
 	- backingSnapshotID: ID of the snapshot on which the CephFS snapshot-backed volume is based (optional)
@@ -544,6 +559,7 @@ func (conn *Connection) ReserveName(ctx context.Context,
 	imagePool string, imagePoolID int64,
 	reqName, namePrefix, parentName, kmsConf, volUUID, owner,
 	backingSnapshotID string,
+	encryptionType util.EncryptionType,
 ) (string, string, error) {
 	// TODO: Take in-arg as ImageAttributes?
 	var (
@@ -624,6 +640,7 @@ func (conn *Connection) ReserveName(ctx context.Context,
 	// Update UUID directory to store encryption values
 	if kmsConf != "" {
 		omapValues[cj.encryptKMSKey] = kmsConf
+		omapValues[cj.encryptionType] = util.EncryptionTypeString(encryptionType)
 	}
 
 	// if owner is passed, set it in the UUID directory too
@@ -664,6 +681,7 @@ type ImageAttributes struct {
 	SourceName        string              // Contains the parent image name for the passed in UUID, if it is a snapshot
 	ImageName         string              // Contains the image or subvolume name for the passed in UUID
 	KmsID             string              // Contains encryption KMS, if it is an encrypted image
+	EncryptionType    util.EncryptionType // Type of encryption used, if image encrypted
 	Owner             string              // Contains the owner to be used in combination with KmsID (for some KMS)
 	ImageID           string              // Contains the image id
 	JournalPoolID     int64               // Pool ID of the CSI journal pool, stored in big endian format (on-disk data)
@@ -692,6 +710,7 @@ func (conn *Connection) GetImageAttributes(
 		cj.csiNameKey,
 		cj.csiImageKey,
 		cj.encryptKMSKey,
+		cj.encryptionType,
 		cj.csiJournalPool,
 		cj.cephSnapSourceKey,
 		cj.csiImageIDKey,
@@ -711,6 +730,7 @@ func (conn *Connection) GetImageAttributes(
 	var found bool
 	imageAttributes.RequestName = values[cj.csiNameKey]
 	imageAttributes.KmsID = values[cj.encryptKMSKey]
+	imageAttributes.EncryptionType = util.ParseEncryptionType(values[cj.encryptionType])
 	imageAttributes.Owner = values[cj.ownerKey]
 	imageAttributes.ImageID = values[cj.csiImageIDKey]
 	imageAttributes.BackingSnapshotID = values[cj.backingSnapshotIDKey]