azure_storage_blobs/blob/operations/
get_metadata.rs

1use crate::prelude::*;
2use azure_core::{headers::*, prelude::*, Method, RequestId};
3use time::OffsetDateTime;
4
5operation! {
6    GetMetadata,
7    client: BlobClient,
8    ?if_modified_since: IfModifiedSinceCondition,
9    ?if_match: IfMatchCondition,
10    ?if_tags: IfTags,
11    ?blob_versioning: BlobVersioning,
12    ?lease_id: LeaseId
13}
14
15impl GetMetadataBuilder {
16    pub fn into_future(mut self) -> GetMetadata {
17        Box::pin(async move {
18            let mut url = self.client.url()?;
19
20            url.query_pairs_mut().append_pair("comp", "metadata");
21            self.blob_versioning.append_to_url_query(&mut url);
22
23            let mut headers = Headers::new();
24            headers.add(self.lease_id);
25            headers.add(self.if_modified_since);
26            headers.add(self.if_match);
27            headers.add(self.if_tags);
28
29            let mut request = BlobClient::finalize_request(url, Method::Get, headers, None)?;
30
31            let response = self.client.send(&mut self.context, &mut request).await?;
32
33            response.headers().try_into()
34        })
35    }
36}
37
38#[derive(Debug, Clone)]
39pub struct GetMetadataResponse {
40    pub request_id: RequestId,
41    pub etag: String,
42    pub server: String,
43    pub date: OffsetDateTime,
44    pub metadata: Metadata,
45}
46
47impl TryFrom<&Headers> for GetMetadataResponse {
48    type Error = azure_core::Error;
49
50    fn try_from(headers: &Headers) -> Result<Self, Self::Error> {
51        Ok(GetMetadataResponse {
52            request_id: request_id_from_headers(headers)?,
53            etag: etag_from_headers(headers)?,
54            server: server_from_headers(headers)?,
55            date: date_from_headers(headers)?,
56            metadata: headers.into(),
57        })
58    }
59}