nitroglycerin 0.4.5

High level dynamodb crate
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
50
51
52
53
54

use std::convert::TryFrom;

use rusoto_dynamodb::{GetItemError, GetItemInput};

use crate::{AttributeError, Attributes, DynamoError, Table, client::DynamoDb, key};

/// Trait that declares a type can be built into a get item request
pub trait Get<'d, D: ?Sized>: Table {
    /// The builder type that performs the get item request
    type Builder;

    /// Create the get builder
    fn get(client: &'d D) -> Self::Builder;
}

impl<'d, D: 'd + ?Sized, K: key::Builder<'d, D, GetItemInput>> Get<'d, D> for K {
    type Builder = K::Builder;
    fn get(client: &'d D) -> Self::Builder {
        K::key(client)
    }
}

impl From<key::Key> for GetItemInput {
    fn from(k: key::Key) -> Self {
        let key::Key { table_name, key } = k;
        Self { key, table_name, ..Self::default() }
    }
}

impl<'d, D: 'd + ?Sized, T> key::Expr<'d, D, GetItemInput, T> {
    /// Enable consistent read for the get item request
    #[must_use]
    pub const fn consistent_read(mut self) -> Self {
        self.input.consistent_read = Some(true);
        self
    }
}

impl<'d, D: 'd + ?Sized, T> key::Expr<'d, D, GetItemInput, T>
where
    D: DynamoDb,
    &'d D: Send,
    T: TryFrom<Attributes, Error = AttributeError> + Send,
{
    /// Execute the get item request
    ///
    /// # Errors
    /// Will error if the dynamodb request fails or if the result could not be parsed
    pub async fn execute(self) -> Result<Option<T>, DynamoError<GetItemError>> {
        let Self { client, input, _phantom } = self;
        let output = client.get_item(input).await?;
        Ok(output.item.map(T::try_from).transpose()?)
    }
}