[Test] Add TC to validate dev path mapping for file&block vol delete

Change-Id: Id11489bb0cbf2f706e8ce756a1479276a76a3aa8
Signed-off-by: Sri Vignesh <sselvan@redhat.com>

1 files changed, 70 insertions, 0 deletions

diff --git a/tests/functional/provisioning/test_dev_path_mapping_file.py b/tests/functional/provisioning/test_dev_path_mapping_file.py
index bee37d62..a7f5a5fb 100644
--- a/tests/functional/provisioning/test_dev_path_mapping_file.py
+++ b/tests/functional/provisioning/test_dev_path_mapping_file.py
@@ -1,6 +1,7 @@
 import ddt
 import pytest
 from glusto.core import Glusto as g
+from glustolibs.gluster import volume_ops
 
 from openshiftstoragelibs import baseclass
 from openshiftstoragelibs import command
@@ -183,3 +184,72 @@ class TestDevPathMapping(baseclass.BaseClass):
             use_percent, use_percent_after,
             "Failed to execute IO's in the app pod {} after respin".format(
                 pod_name))
+
+    @pytest.mark.tier2
+    @podcmd.GlustoPod()
+    def test_dev_path_file_volume_delete(self):
+        """Validate device path name changes the deletion of
+           already existing file volumes
+        """
+
+        pvc_size, pvc_amount = 2, 5
+        vol_details, pvc_names = [], []
+
+        # Create PVC's
+        sc_name = self.create_storage_class()
+        for i in range(0, pvc_amount):
+            pvc_name = openshift_ops.oc_create_pvc(
+                self.node, sc_name, pvc_size=pvc_size)
+            pvc_names.append(pvc_name)
+            self.addCleanup(
+                openshift_ops.wait_for_resource_absence,
+                self.node, 'pvc', pvc_name)
+            self.addCleanup(
+                openshift_ops.oc_delete, self.node, 'pvc', pvc_name,
+                raise_on_absence=False)
+
+        # Wait for PVC's to be bound
+        openshift_ops.wait_for_pvcs_be_bound(self.node, pvc_names)
+
+        # Get Volumes name and validate volumes count
+        for pvc_name in pvc_names:
+            pv_name = openshift_ops.get_pv_name_from_pvc(self.node, pvc_name)
+            volume_name = openshift_ops.get_vol_names_from_pv(
+                self.node, pv_name)
+            vol_details.append(volume_name)
+
+        # Verify file volumes count
+        self.validate_file_volumes_count(
+            self.h_node, self.h_server, self.node_ip)
+
+        # Collect pvs info and detach disks and get pvs info
+        pvs_info_before = openshift_storage_libs.get_pvs_info(
+            self.node, self.node_ip, self.devices_list, raise_on_error=False)
+        self.detach_and_attach_vmdk(
+            self.vm_name, self.node_hostname, self.devices_list)
+        pvs_info_after = openshift_storage_libs.get_pvs_info(
+            self.node, self.node_ip, self.devices_list, raise_on_error=False)
+
+        # Compare pvs info before and after
+        for (path, uuid, vg_name), (_path, _uuid, _vg_name) in zip(
+                pvs_info_before[:-1], pvs_info_after[1:]):
+            self.assertEqual(
+                uuid, _uuid, "pv_uuid check failed. Expected:{},"
+                "Actual: {}".format(uuid, _uuid))
+            self.assertEqual(
+                vg_name, _vg_name, "vg_name check failed. Expected:"
+                "{}, Actual:{}".format(vg_name, _vg_name))
+
+        # Delete created PVC's
+        for pvc_name in pvc_names:
+            openshift_ops.oc_delete(self.node, 'pvc', pvc_name)
+
+        # Wait for resource absence and get volume list
+        openshift_ops.wait_for_resources_absence(self.node, 'pvc', pvc_names)
+        vol_list = volume_ops.get_volume_list(self.node_ip)
+        self.assertIsNotNone(vol_list, "Failed to get volumes list")
+
+        # Validate volumes created are not present
+        for vol in vol_details:
+            self.assertNotIn(
+                vol, vol_list, "Failed to delete volume {}".format(vol))