objectstore-client 0.2.9

Client SDK for Objectstore, the Sentry object storage platform
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49

use objectstore_types::metadata::Metadata;
use reqwest::StatusCode;

use crate::response::ResponseExt as _;
use crate::{ObjectKey, Session};

/// The result from a successful [`head()`](Session::head) call.
///
/// Returns `Some(metadata)` if the object exists, `None` otherwise.
pub type HeadResponse = Option<Metadata>;

impl Session {
    /// Checks whether an object exists and retrieves its metadata.
    ///
    /// If the object exists and has a TTI expiration policy, this is considered an access, and
    /// therefore bumps its expiration.
    pub fn head(&self, key: &str) -> HeadBuilder {
        HeadBuilder {
            session: self.clone(),
            key: key.to_owned(),
        }
    }
}

/// A [`head`](Session::head) request builder.
#[derive(Debug)]
pub struct HeadBuilder {
    pub(crate) session: Session,
    pub(crate) key: ObjectKey,
}

impl HeadBuilder {
    /// Sends the head request.
    pub async fn send(self) -> crate::Result<HeadResponse> {
        let response = self
            .session
            .request(reqwest::Method::HEAD, &self.key)?
            .send()
            .await?;
        if response.status() == StatusCode::NOT_FOUND {
            response.drain_body().await;
            return Ok(None);
        }
        let response = response.error_for_status_and_drain().await?;
        let metadata = Metadata::from_headers(response.headers(), "");
        response.drain_body().await;
        Ok(Some(metadata?))
    }
}