Removed workaround for blob storage enumeration missing metadata. (#2999)

Fixed issue #2934

Author: LarryOsterman

sdk/eventhubs/assets.json

@@ -2,5 +2,5 @@
   "AssetsRepo": "Azure/azure-sdk-assets",
   "AssetsRepoPrefixPath": "rust",
   "TagPrefix": "rust/eventhubs",
-  "Tag": "rust/eventhubs_e00fc5e364"
+  "Tag": "rust/eventhubs_12266aa668"
 }

sdk/eventhubs/azure_messaging_eventhubs_checkpointstore_blob/src/checkpoint_store.rs

@@ -17,9 +17,8 @@ use azure_messaging_eventhubs::{
 };
 use azure_storage_blob::{
     models::{
-        BlobClientGetPropertiesResultHeaders, BlobClientSetMetadataOptions,
-        BlobContainerClientListBlobFlatSegmentOptions, BlockBlobClientUploadOptions,
-        BlockBlobClientUploadResultHeaders, ListBlobsIncludeItem,
+        BlobClientSetMetadataOptions, BlobContainerClientListBlobFlatSegmentOptions,
+        BlockBlobClientUploadOptions, BlockBlobClientUploadResultHeaders, ListBlobsIncludeItem,
     },
     BlobContainerClient,
 };
@@ -250,18 +249,19 @@ impl CheckpointStore for BlobCheckpointStore {
                             .map(|pos| &name[pos + 1..])
                             .unwrap_or_default()
                             .to_string();
-                        // Since the current blob container client doesn't actually return the metadata, we
-                        // get it from the blob client instead.
-                        let blob = self
-                            .blob_container_client
-                            .blob_client(name.clone())
-                            .get_properties(None)
-                            .await?;
-                        if let Some(offset) = blob.metadata()?.get(OFFSET) {
-                            checkpoint.offset = Some(offset.clone());
-                        }
-                        if let Some(sequence_number) = blob.metadata()?.get(SEQUENCE_NUMBER) {
-                            checkpoint.sequence_number = Some(sequence_number.parse()?);
+                        if let Some(additional_properties) = blob
+                            .metadata
+                            .as_ref()
+                            .and_then(|m| m.additional_properties.as_ref())
+                        {
+                            if let Some(sequence_number) =
+                                additional_properties.get(SEQUENCE_NUMBER)
+                            {
+                                checkpoint.sequence_number = Some(sequence_number.parse()?);
+                            }
+                            if let Some(offset) = additional_properties.get(OFFSET) {
+                                checkpoint.offset = Some(offset.clone());
+                            }
                         }
                     }
                 }
@@ -318,17 +318,11 @@ impl CheckpointStore for BlobCheckpointStore {
                             .map(|pos| &name[pos + 1..])
                             .unwrap_or_default()
                             .to_string();
-                        // Since the current blob container client doesn't actually return the metadata, we
-                        // get it from the blob client instead.
-                        let blob = self
-                            .blob_container_client
-                            .blob_client(name.clone())
-                            .get_properties(None)
-                            .await?;
-                        let metadata = blob.metadata()?;
-                        if let Some(owner_id) = metadata.get(OWNER_ID) {
-                            ownership.owner_id = Some(owner_id.clone());
-                        }
+                        ownership.owner_id = blob
+                            .metadata
+                            .as_ref()
+                            .and_then(|m| m.additional_properties.as_ref())
+                            .and_then(|ap| ap.get(OWNER_ID).cloned());
                     }
                 }
                 if let Some(properties) = &blob.properties {