adding filesystem type validation

ecs-agent/acs/session/attach_resource_responder.go

@@ -202,6 +202,10 @@ func validateAttachmentAndReturnProperties(message *ecsacs.ConfirmAttachmentMess
 		if err != nil {
 			return nil, errors.Wrap(err, "resource attachment validation by attachment type failed")
 		}
+		err = resource.ValidateFileSystemType(attachmentProperties[resource.FileSystemKey])
+		if err != nil {
+			return nil, errors.Wrap(err, "resource attachment validation by attachment type failed")
+		}
 		return attachmentProperties, nil
 	}
 

ecs-agent/acs/session/attach_resource_responder_test.go

@@ -59,6 +59,10 @@ var (
 			Name:  aws.String(resource.DeviceNameKey),
 			Value: aws.String("device1"),
 		},
+		{
+			Name:  aws.String(resource.FileSystemKey),
+			Value: aws.String(""),
+		},
 	}
 
 	testAttachmentProperties = []*ecsacs.AttachmentProperty{
@@ -202,12 +206,6 @@ func testValidateAttachmentAndReturnPropertiesWithAttachmentType(t *testing.T) {
 			_, err := validateAttachmentAndReturnProperties(&confirmAttachmentMessageCopy)
 			require.Error(t, err)
 			property.Name = originalPropertyName
-
-			originalPropertyValue := property.Value
-			property.Value = aws.String("")
-			_, err = validateAttachmentAndReturnProperties(&confirmAttachmentMessageCopy)
-			require.Error(t, err)
-			property.Value = originalPropertyValue
 		})
 	}
 
@@ -244,6 +242,23 @@ func testValidateAttachmentAndReturnPropertiesWithAttachmentType(t *testing.T) {
 		}
 		require.True(t, verified, "Missing required property: %s", requiredProperty)
 	}
+
+	for _, property := range confirmAttachmentMessageCopy.Attachment.AttachmentProperties {
+		if aws.StringValue(property.Name) == resource.FileSystemKey {
+			originalPropertyValue := property.Value
+			property.Value = aws.String("SomeFilesystemType")
+			_, err = validateAttachmentAndReturnProperties(&confirmAttachmentMessageCopy)
+			require.Error(t, err)
+			property.Value = originalPropertyValue
+
+			originalPropertyValue = property.Value
+			property.Value = aws.String("")
+			_, err = validateAttachmentAndReturnProperties(&confirmAttachmentMessageCopy)
+			require.Error(t, err)
+			property.Value = originalPropertyValue
+		}
+	}
+
 }
 
 // TestResourceAckHappyPath tests the happy path for a typical ConfirmAttachmentMessage and confirms expected

ecs-agent/api/resource/ebs_discovery_linux.go

@@ -52,7 +52,7 @@ func (api *EBSDiscoveryClient) ConfirmEBSVolumeIsAttached(deviceName, volumeID s
 		err = fmt.Errorf("%w; failed to run lsblk %v", err, string(output))
 		return "", err
 	}
-	logger.Debug(fmt.Sprintf("lsblk output: %s", string(output)))
+	// logger.Debug(fmt.Sprintf("lsblk output: %s", string(output)))
 	err = json.Unmarshal(output, &lsblkOut)
 	if err != nil {
 		err = fmt.Errorf("%w; failed to unmarshal string: %v", err, string(output))

ecs-agent/api/resource/resource_attachment.go

@@ -74,6 +74,16 @@ const (
 	FileSystemKey           = "fileSystem"
 )
 
+var (
+	AllowedFSTypes = map[string]bool{
+		"xfs":  true,
+		"ext2": true,
+		"ext3": true,
+		"ext4": true,
+		"ntfs": true,
+	}
+)
+
 // getCommonProperties returns the common properties as used for validating a resource.
 func getCommonProperties() (commonProperties []string) {
 	commonProperties = []string{

ecs-agent/api/resource/resource_validation.go

@@ -71,3 +71,10 @@ func ValidateRequiredProperties(actualProperties map[string]string, requiredProp
 	}
 	return nil
 }
+
+func ValidateFileSystemType(filesystemType string) error {
+	if !AllowedFSTypes[filesystemType] {
+		return errors.Errorf("invalid file system type: %s", filesystemType)
+	}
+	return nil
+}