1 files changed, 88 insertions, 0 deletions
diff --git a/tests/functional/heketi/test_block_volumes_heketi.py b/tests/functional/heketi/test_block_volumes_heketi.py
new file mode 100644
index 00000000..b75f58ac
--- /dev/null
+++ b/tests/functional/heketi/test_block_volumes_heketi.py
@@ -0,0 +1,88 @@
+
+from cnslibs.common.heketi_ops import (heketi_blockvolume_create,
+                                       heketi_blockvolume_delete,
+                                       heketi_blockvolume_list,
+                                       heketi_volume_create,
+                                       heketi_volume_delete
+                                       )
+from cnslibs.common.baseclass import BaseClass
+
+
+class TestBlockVolumeOps(BaseClass):
+    """Class to test heketi block volume deletion with and without block
+       volumes existing, heketi block volume list, heketi block volume info
+       and heketi block volume creation with name and block volumes creation
+       after manually creating a Block Hosting volume.
+    """
+
+    def test_create_block_vol_after_host_vol_creation(self):
+        """Validate block-device after manual block hosting volume creation
+           using heketi
+        """
+        block_host_create_info = heketi_volume_create(
+            self.heketi_client_node, self.heketi_server_url, 5,
+            json=True, block=True)
+        self.addCleanup(
+            heketi_volume_delete, self.heketi_client_node,
+            self.heketi_server_url, block_host_create_info["id"])
+
+        block_vol = heketi_blockvolume_create(
+            self.heketi_client_node, self.heketi_server_url, 1, json=True)
+        self.addCleanup(
+            heketi_blockvolume_delete, self.heketi_client_node,
+            self.heketi_server_url, block_vol["id"])
+
+    def test_block_host_volume_delete_without_block_volumes(self):
+        """Validate deletion of empty block hosting volume"""
+        block_host_create_info = heketi_volume_create(
+            self.heketi_client_node, self.heketi_server_url, 1, json=True,
+            block=True)
+
+        block_hosting_vol_id = block_host_create_info["id"]
+        self.addCleanup(
+            heketi_volume_delete, self.heketi_client_node,
+            self.heketi_server_url, block_hosting_vol_id, raise_on_error=False)
+
+        heketi_volume_delete(
+            self.heketi_client_node, self.heketi_server_url,
+            block_hosting_vol_id, json=True)
+
+    def test_block_volume_delete(self):
+        """Validate deletion of gluster-block volume and capacity of used pool
+        """
+        block_vol = heketi_blockvolume_create(
+            self.heketi_client_node, self.heketi_server_url, 1, json=True)
+        self.addCleanup(
+            heketi_blockvolume_delete, self.heketi_client_node,
+            self.heketi_server_url, block_vol["id"], raise_on_error=False)
+
+        heketi_blockvolume_delete(
+            self.heketi_client_node, self.heketi_server_url,
+            block_vol["id"], json=True)
+
+        volume_list = heketi_blockvolume_list(
+            self.heketi_client_node, self.heketi_server_url, json=True)
+        self.assertNotIn(block_vol["id"], volume_list["blockvolumes"],
+                         "The block volume has not been successfully deleted,"
+                         " ID is %s" % block_vol["id"])
+
+    def test_block_volume_list(self):
+        """Validate heketi blockvolume list command works as expected"""
+        created_vol_ids = []
+        for count in range(3):
+            block_vol = heketi_blockvolume_create(
+                self.heketi_client_node, self.heketi_server_url, 1, json=True)
+            self.addCleanup(
+                heketi_blockvolume_delete, self.heketi_client_node,
+                self.heketi_server_url, block_vol["id"])
+
+            created_vol_ids.append(block_vol["id"])
+
+        volumes = heketi_blockvolume_list(
+            self.heketi_client_node, self.heketi_server_url, json=True)
+
+        existing_vol_ids = volumes.values()[0]
+        for vol_id in created_vol_ids:
+            self.assertIn(vol_id, existing_vol_ids,
+                          "Block vol with '%s' ID is absent in the "
+                          "list of block volumes." % vol_id)