Unit and Integration test for Find volume added

cloudbridge/cloud/providers/azure/services.py

@@ -107,7 +107,7 @@ class AzureObjectStoreService(BaseObjectStoreService):
             else:
                 return None
         except AzureMissingResourceHttpError as error:
-            log.exception(error.message)
+            log.exception(error)
             return None
 
     def find(self, name, limit=None, marker=None):

integration_test/test_integration_azure_volume_service.py

@@ -32,13 +32,18 @@ class AzureIntegrationVolumeServiceTestCase(helpers.ProviderTestBase):
         self.assertTrue(
             volume.name == volume_name, "Volume name should be MyVolume")
 
+        volume_find = self.provider.block_store.volumes.find(volume_name)
+        print("Find Volume  - " + str(volume))
+        self.assertEqual(
+            len(volume_find), 1)
         # volume.attach('/subscriptions/7904d702-e01c-4826-8519-f5a25c866a96/resourceGroups/CloudBridge-Azure/providers/Microsoft.Compute/virtualMachines/ubuntu-intro2')
         #TODO: Add logic to verify that disk is attached to instance
 
         # volume.detach()
         #TODO: Add logic to verify that disk is not in use
 
-        # snapshot = volume.create_snapshot(snapshot_name)
+        with self.assertRaises(NotImplementedError):
+            snapshot = volume.create_snapshot(snapshot_name)
         # self.assertTrue(snapshot is not None, 'Snapshot {0} not created'.format(snapshot_name))
 
         volume.refresh()

test/test_azure_volume_service.py

@@ -79,6 +79,12 @@ class AzureVolumeServiceTestCase(ProviderTestBase):
         self.assertTrue(
             len(volumes) == 2, "Volume should not be available")
 
+    @helpers.skipIfNoService(['block_store.volumes'])
+    def test_azure_volume_find_ifNotExist(self):
+        volumes = self.provider.block_store.volumes.find("Volume123")
+        self.assertTrue(
+            len(volumes) == 0, "Volume should not be available")
+
 
 
     @helpers.skipIfNoService(['block_store.volumes'])