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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110

/*
 * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
 * SPDX-License-Identifier: Apache-2.0
 */

//! Serialization/deserialization for the orchestrator.

use crate::box_error::BoxError;
use crate::client::interceptors::context::{Error, Input, Output};
use crate::client::orchestrator::{HttpRequest, HttpResponse, OrchestratorError};
use crate::impl_shared_conversions;
use aws_smithy_types::config_bag::{ConfigBag, Storable, StoreReplace};
use std::fmt;
use std::sync::Arc;

/// Serialization implementation that converts an [`Input`] into an [`HttpRequest`].
pub trait SerializeRequest: Send + Sync + fmt::Debug {
    /// Serializes the input into an HTTP request.
    ///
    /// The type of the [`Input`] must be known ahead of time by the request serializer
    /// implementation, and must be downcasted to get access to the information necessary
    /// for serialization.
    ///
    /// The request serializer is generally added to the [`ConfigBag`] by the operation's
    /// code generated runtime plugin, which is aware of the correct input/output/error types.
    fn serialize_input(&self, input: Input, cfg: &mut ConfigBag) -> Result<HttpRequest, BoxError>;
}

/// A shared request serializer.
///
/// This is a simple shared ownership wrapper type for the [`SerializeRequest`] trait.
#[derive(Clone, Debug)]
pub struct SharedRequestSerializer(Arc<dyn SerializeRequest>);

impl SharedRequestSerializer {
    /// Creates a new shared request serializer.
    pub fn new(serializer: impl SerializeRequest + 'static) -> Self {
        Self(Arc::new(serializer))
    }
}

impl SerializeRequest for SharedRequestSerializer {
    fn serialize_input(&self, input: Input, cfg: &mut ConfigBag) -> Result<HttpRequest, BoxError> {
        self.0.serialize_input(input, cfg)
    }
}

impl Storable for SharedRequestSerializer {
    type Storer = StoreReplace<Self>;
}

impl_shared_conversions!(convert SharedRequestSerializer from SerializeRequest using SharedRequestSerializer::new);

/// Deserialization implementation that converts an [`HttpResponse`] into an [`Output`] or [`Error`].
pub trait DeserializeResponse: Send + Sync + fmt::Debug {
    /// For streaming requests, deserializes the response headers.
    ///
    /// The orchestrator will call `deserialize_streaming` first, and if it returns `None`,
    /// then it will continue onto `deserialize_nonstreaming`. This method should only be
    /// implemented for streaming requests where the streaming response body needs to be a part
    /// of the deserialized output.
    fn deserialize_streaming(
        &self,
        response: &mut HttpResponse,
    ) -> Option<Result<Output, OrchestratorError<Error>>> {
        let _ = response;
        None
    }

    /// Deserialize the entire response including its body into an output or error.
    fn deserialize_nonstreaming(
        &self,
        response: &HttpResponse,
    ) -> Result<Output, OrchestratorError<Error>>;
}

/// Shared response deserializer.
///
/// This is a simple shared ownership wrapper type for the [`DeserializeResponse`] trait.
#[derive(Debug)]
pub struct SharedResponseDeserializer(Arc<dyn DeserializeResponse>);

impl SharedResponseDeserializer {
    /// Creates a new [`SharedResponseDeserializer`].
    pub fn new(serializer: impl DeserializeResponse + 'static) -> Self {
        Self(Arc::new(serializer))
    }
}

impl DeserializeResponse for SharedResponseDeserializer {
    fn deserialize_nonstreaming(
        &self,
        response: &HttpResponse,
    ) -> Result<Output, OrchestratorError<Error>> {
        self.0.deserialize_nonstreaming(response)
    }

    fn deserialize_streaming(
        &self,
        response: &mut HttpResponse,
    ) -> Option<Result<Output, OrchestratorError<Error>>> {
        self.0.deserialize_streaming(response)
    }
}

impl Storable for SharedResponseDeserializer {
    type Storer = StoreReplace<Self>;
}

impl_shared_conversions!(convert SharedResponseDeserializer from DeserializeResponse using SharedResponseDeserializer::new);