Server Test

Server Test

rev. d838bf488731ae5e751cce0fe13f339a5b9be858 (ignoring whitespace)

Files changed:

tmp-codegen-diff/codegen-server-test/rest_json/rust-server-codegen/src/protocol_serde.rs

@@ -1,1 +95,107 @@
    8      8   
pub(crate) mod shape_content_type_parameters;
    9      9   
   10     10   
pub(crate) mod shape_datetime_offsets;
   11     11   
   12     12   
pub(crate) mod shape_document_type;
   13     13   
   14     14   
pub(crate) mod shape_document_type_as_map_value;
   15     15   
   16     16   
pub(crate) mod shape_document_type_as_payload;
   17     17   
          18  +
pub(crate) mod shape_duplex_stream;
          19  +
          20  +
pub(crate) mod shape_duplex_stream_with_distinct_streams;
          21  +
          22  +
pub(crate) mod shape_duplex_stream_with_initial_messages;
          23  +
   18     24   
pub(crate) mod shape_empty_input_and_empty_output;
   19     25   
   20     26   
pub(crate) mod shape_endpoint_operation;
   21     27   
   22     28   
pub(crate) mod shape_endpoint_with_host_label_operation;
   23     29   
   24     30   
pub(crate) mod shape_fractional_seconds;
   25     31   
   26     32   
pub(crate) mod shape_greeting_with_errors;
   27     33   
   28     34   
pub(crate) mod shape_host_with_path_operation;
   29     35   
   30     36   
pub(crate) mod shape_http_checksum_required;
   31     37   
   32     38   
pub(crate) mod shape_http_empty_prefix_headers;
   33     39   
   34     40   
pub(crate) mod shape_http_enum_payload;
   35     41   
   36     42   
pub(crate) mod shape_http_payload_traits;
   37     43   
   38     44   
pub(crate) mod shape_http_payload_traits_with_media_type;
   39     45   
   40     46   
pub(crate) mod shape_http_payload_with_structure;
   41     47   
   42     48   
pub(crate) mod shape_http_payload_with_union;
   43     49   
   44     50   
pub(crate) mod shape_http_prefix_headers;
   45     51   
   46     52   
pub(crate) mod shape_http_prefix_headers_in_response;
   47     53   
          54  +
pub(crate) mod shape_http_query_params_only_operation;
          55  +
   48     56   
pub(crate) mod shape_http_request_with_float_labels;
   49     57   
   50     58   
pub(crate) mod shape_http_request_with_greedy_label_in_path;
   51     59   
   52     60   
pub(crate) mod shape_http_request_with_labels;
   53     61   
   54     62   
pub(crate) mod shape_http_request_with_labels_and_timestamp_format;
   55     63   
   56     64   
pub(crate) mod shape_http_request_with_regex_literal;
   57     65   
   58     66   
pub(crate) mod shape_http_response_code;
   59     67   
   60     68   
pub(crate) mod shape_http_string_payload;
   61     69   
   62     70   
pub(crate) mod shape_ignore_query_params_in_response;
   63     71   
   64     72   
pub(crate) mod shape_input_and_output_with_headers;
   65     73   
          74  +
pub(crate) mod shape_input_stream;
          75  +
          76  +
pub(crate) mod shape_input_stream_with_initial_request;
          77  +
   66     78   
pub(crate) mod shape_json_blobs;
   67     79   
   68     80   
pub(crate) mod shape_json_enums;
   69     81   
   70     82   
pub(crate) mod shape_json_int_enums;
   71     83   
   72     84   
pub(crate) mod shape_json_lists;
   73     85   
   74     86   
pub(crate) mod shape_json_maps;
   75     87
@@ -134,146 +193,209 @@
  154    166   
pub(crate) mod shape_null_and_empty_headers_server;
  155    167   
  156    168   
pub(crate) mod shape_omits_null_serializes_empty_string;
  157    169   
  158    170   
pub(crate) mod shape_omits_serializing_empty_lists;
  159    171   
  160    172   
pub(crate) mod shape_operation_with_defaults;
  161    173   
  162    174   
pub(crate) mod shape_operation_with_nested_structure;
  163    175   
         176  +
pub(crate) mod shape_output_stream;
         177  +
         178  +
pub(crate) mod shape_output_stream_with_initial_response;
         179  +
  164    180   
pub(crate) mod shape_post_player_action;
  165    181   
  166    182   
pub(crate) mod shape_post_union_with_json_name;
  167    183   
  168    184   
pub(crate) mod shape_put_with_content_encoding;
  169    185   
  170    186   
pub(crate) mod shape_query_idempotency_token_auto_fill;
  171    187   
  172    188   
pub(crate) mod shape_query_params_as_string_list_map;
  173    189
@@ -218,234 +349,379 @@
  238    254   
pub fn serialize_document(input: &::aws_smithy_types::Document) -> ::std::vec::Vec<u8> {
  239    255   
    let mut out = String::new();
  240    256   
    ::aws_smithy_json::serialize::JsonValueWriter::new(&mut out).document(input);
  241    257   
    out.into_bytes()
  242    258   
}
  243    259   
  244    260   
pub(crate) mod shape_document_type_as_payload_output;
  245    261   
  246    262   
pub(crate) mod shape_document_type_output;
  247    263   
         264  +
pub(crate) mod shape_duplex_stream_input;
         265  +
         266  +
pub(crate) mod shape_duplex_stream_with_distinct_streams_input;
         267  +
         268  +
/* JsonSerializerGenerator.kt:274 */
         269  +
pub fn rest_json_unset_union_payload() -> ::std::vec::Vec<u8> {
         270  +
    ::std::vec::Vec::new()
         271  +
}
         272  +
         273  +
pub(crate) mod shape_duplex_stream_with_distinct_streams_output;
         274  +
         275  +
pub(crate) mod shape_duplex_stream_with_initial_messages_input;
         276  +
  248    277   
pub(crate) mod shape_empty_input_and_empty_output_output;
  249    278   
         279  +
pub(crate) mod shape_error_event;
         280  +
  250    281   
pub(crate) mod shape_foo_error;
  251    282   
  252    283   
pub(crate) mod shape_fractional_seconds_output;
  253    284   
  254    285   
pub(crate) mod shape_greeting_with_errors_output;
  255    286   
  256    287   
pub(crate) mod shape_http_checksum_required_output;
  257    288   
  258    289   
pub(crate) mod shape_http_empty_prefix_headers_input;
  259    290   
  260    291   
pub(crate) mod shape_http_empty_prefix_headers_output;
  261    292   
  262    293   
pub(crate) mod shape_http_enum_payload_input;
  263    294   
  264    295   
pub(crate) mod shape_http_enum_payload_output;
  265    296   
  266    297   
pub(crate) mod shape_http_payload_traits_input;
  267    298   
  268    299   
pub(crate) mod shape_http_payload_traits_output;
  269    300   
  270    301   
pub(crate) mod shape_http_payload_traits_with_media_type_input;
  271    302   
  272    303   
pub(crate) mod shape_http_payload_traits_with_media_type_output;
  273    304   
  274    305   
pub(crate) mod shape_http_payload_with_structure_input;
  275    306   
  276    307   
/* JsonSerializerGenerator.kt:262 */
  277    308   
pub fn rest_json_unset_struct_payload() -> ::std::vec::Vec<u8> {
  278    309   
    b"{}"[..].into()
  279    310   
}
  280    311   
  281    312   
pub(crate) mod shape_http_payload_with_structure_output;
  282    313   
  283    314   
pub(crate) mod shape_http_payload_with_union_input;
  284    315   
  285         -
/* JsonSerializerGenerator.kt:274 */
  286         -
pub fn rest_json_unset_union_payload() -> ::std::vec::Vec<u8> {
  287         -
    ::std::vec::Vec::new()
  288         -
}
  289         -
  290    316   
pub(crate) mod shape_http_payload_with_union_output;
  291    317   
  292    318   
pub(crate) mod shape_http_prefix_headers_in_response_output;
  293    319   
  294    320   
pub(crate) mod shape_http_prefix_headers_input;
  295    321   
  296    322   
pub(crate) mod shape_http_prefix_headers_output;
  297    323   
  298    324   
pub(crate) mod shape_http_request_with_float_labels_input;
  299    325   
  300    326   
pub(crate) mod shape_http_request_with_greedy_label_in_path_input;
  301    327   
  302    328   
pub(crate) mod shape_http_request_with_labels_and_timestamp_format_input;
  303    329   
  304    330   
pub(crate) mod shape_http_request_with_labels_input;
  305    331   
  306    332   
pub(crate) mod shape_http_request_with_regex_literal_input;
  307    333   
  308    334   
pub(crate) mod shape_http_response_code_output;
  309    335   
  310    336   
pub(crate) mod shape_http_string_payload_input;
  311    337   
  312    338   
pub(crate) mod shape_http_string_payload_output;
  313    339   
  314    340   
pub(crate) mod shape_ignore_query_params_in_response_output;
  315    341   
  316    342   
pub(crate) mod shape_input_and_output_with_headers_input;
  317    343   
  318    344   
pub(crate) mod shape_input_and_output_with_headers_output;
  319    345   
         346  +
pub(crate) mod shape_input_stream_input;
         347  +
         348  +
pub(crate) mod shape_input_stream_with_initial_request_input;
         349  +
  320    350   
pub(crate) mod shape_invalid_greeting;
  321    351   
  322    352   
pub(crate) mod shape_json_blobs_output;
  323    353   
  324    354   
pub(crate) mod shape_json_enums_output;
  325    355   
  326    356   
pub(crate) mod shape_json_int_enums_output;
  327    357   
  328    358   
pub(crate) mod shape_json_lists_output;
  329    359
@@ -390,420 +449,481 @@
  410    440   
pub(crate) mod shape_query_params_as_string_list_map_input;
  411    441   
  412    442   
pub(crate) mod shape_query_precedence_input;
  413    443   
  414    444   
pub(crate) mod shape_recursive_shapes_output;
  415    445   
  416    446   
pub(crate) mod shape_response_code_http_fallback_output;
  417    447   
  418    448   
pub(crate) mod shape_response_code_required_output;
  419    449   
         450  +
pub(crate) mod shape_service_unavailable_error;
         451  +
  420    452   
pub(crate) mod shape_simple_scalar_properties_input;
  421    453   
  422    454   
pub(crate) mod shape_simple_scalar_properties_output;
  423    455   
  424    456   
pub(crate) mod shape_sparse_json_lists_output;
  425    457   
  426    458   
pub(crate) mod shape_sparse_json_maps_output;
  427    459   
  428    460   
pub(crate) mod shape_streaming_traits_input;
  429    461
@@ -464,496 +0,622 @@
  484    516   
pub(crate) mod shape_document;
  485    517   
  486    518   
pub(crate) mod shape_document_valued_map;
  487    519   
  488    520   
pub(crate) mod shape_foo_enum_list;
  489    521   
  490    522   
pub(crate) mod shape_foo_enum_map;
  491    523   
  492    524   
pub(crate) mod shape_foo_enum_set;
  493    525   
         526  +
pub(crate) mod shape_headers_and_explicit_payload_event;
         527  +
  494    528   
pub(crate) mod shape_integer_enum_list;
  495    529   
  496    530   
pub(crate) mod shape_integer_enum_map;
  497    531   
  498    532   
pub(crate) mod shape_integer_enum_set;
  499    533   
  500    534   
pub(crate) mod shape_integer_list;
  501    535   
  502    536   
pub(crate) mod shape_my_union;
  503    537   
  504    538   
pub(crate) mod shape_nested_payload;
  505    539   
  506    540   
pub(crate) mod shape_nested_string_list;
  507    541   
  508    542   
pub(crate) mod shape_payload_config;
  509    543   
  510    544   
pub(crate) mod shape_player_action;
  511    545   
  512    546   
pub(crate) mod shape_recursive_shapes_input_output_nested1;
  513    547   
  514    548   
pub(crate) mod shape_simple_list;
  515    549   
  516    550   
pub(crate) mod shape_simple_map;
  517    551   
  518    552   
pub(crate) mod shape_simple_union;
  519    553   
  520    554   
pub(crate) mod shape_sparse_boolean_map;
  521    555   
  522    556   
pub(crate) mod shape_sparse_number_map;
  523    557   
  524    558   
pub(crate) mod shape_sparse_set_map;
  525    559   
  526    560   
pub(crate) mod shape_sparse_short_list;
  527    561   
  528    562   
pub(crate) mod shape_sparse_string_list;
  529    563   
  530    564   
pub(crate) mod shape_sparse_string_map;
  531    565   
  532    566   
pub(crate) mod shape_sparse_struct_map;
  533    567   
  534    568   
pub(crate) mod shape_string_list;
  535    569   
  536    570   
pub(crate) mod shape_string_set;
  537    571   
  538    572   
pub(crate) mod shape_structure_list;
  539    573   
         574  +
pub(crate) mod shape_structure_payload_event;
         575  +
  540    576   
pub(crate) mod shape_test_config;
  541    577   
  542    578   
pub(crate) mod shape_timestamp_list;
  543    579   
  544    580   
pub(crate) mod shape_top_level;
  545    581   
  546    582   
pub(crate) mod shape_union_payload;
  547    583   
         584  +
pub(crate) mod shape_union_payload_event;
         585  +
  548    586   
pub(crate) mod shape_union_with_json_name;
  549    587   
  550    588   
pub(crate) mod shape_complex_nested_error_data;
  551    589   
  552    590   
pub(crate) mod shape_dialog;
  553    591   
  554    592   
pub(crate) mod shape_dialog_list;
  555    593   
  556    594   
pub(crate) mod shape_dialog_map;
  557    595   
  558    596   
pub(crate) mod shape_greeting_struct;
  559    597   
         598  +
pub(crate) mod shape_headers_and_implicit_payload_event;
         599  +
         600  +
pub(crate) mod shape_payload_structure;
         601  +
         602  +
pub(crate) mod shape_payload_union;
         603  +
  560    604   
pub(crate) mod shape_recursive_shapes_input_output_nested2;
  561    605   
  562    606   
pub(crate) mod shape_renamed_greeting;
  563    607   
         608  +
pub(crate) mod shape_singleton_event_stream;
         609  +
  564    610   
pub(crate) mod shape_string_map;
  565    611   
  566    612   
pub(crate) mod shape_structure_list_member;
  567    613   
  568    614   
pub(crate) mod shape_test_string_list;
  569    615   
  570    616   
pub(crate) mod shape_test_string_map;
  571    617   
  572    618   
pub(crate) mod shape_validation_exception_field;
  573    619   
  574    620   
pub(crate) mod shape_farewell;
         621  +
         622  +
pub(crate) mod shape_singleton_event;

tmp-codegen-diff/codegen-server-test/rest_json/rust-server-codegen/src/protocol_serde/shape_duplex_stream.rs

@@ -0,1 +0,189 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* RustType.kt:534 */
           3  +
#[allow(clippy::unnecessary_wraps)]
           4  +
/* ServerHttpBoundProtocolGenerator.kt:412 */
           5  +
pub async fn de_duplex_stream_http_request<B>(
           6  +
    #[allow(unused_variables)] request: ::http_1x::Request<B>,
           7  +
) -> std::result::Result<
           8  +
    crate::input::DuplexStreamInput,
           9  +
    ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
          10  +
>
          11  +
where
          12  +
    B: ::aws_smithy_http_server::body::HttpBody + Send,
          13  +
    B: ::http_body_1x::Body<Data = ::bytes::Bytes>
          14  +
        + ::std::marker::Send
          15  +
        + ::std::marker::Sync
          16  +
        + 'static,
          17  +
    B::Error: Into<::aws_smithy_types::body::Error> + 'static,
          18  +
          19  +
    B::Data: Send,
          20  +
    ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
          21  +
        From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
          22  +
{
          23  +
    /* ServerHttpBoundProtocolGenerator.kt:428 */
          24  +
    Ok({
          25  +
        /* RustType.kt:534 */
          26  +
        #[allow(unused_mut)]
          27  +
        /* ServerHttpBoundProtocolGenerator.kt:773 */
          28  +
        let mut input = crate::input::duplex_stream_input::Builder::default();
          29  +
        /* RustType.kt:534 */
          30  +
        #[allow(unused_variables)]
          31  +
        /* ServerHttpBoundProtocolGenerator.kt:778 */
          32  +
        let ::aws_smithy_runtime_api::http::RequestParts {
          33  +
            uri, headers, body, ..
          34  +
        } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
          35  +
        /* ServerHttpBoundProtocolGenerator.kt:870 */
          36  +
        if let Some(value) = {
          37  +
            let mut receiver = crate::protocol_serde::shape_duplex_stream_input::de_stream_payload(
          38  +
                &mut ::aws_smithy_types::body::SdkBody::from_body_1_x(body),
          39  +
            )?;
          40  +
            if let Some(_initial_event) = receiver
          41  +
                                                .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
          42  +
                                                .await
          43  +
                                                .map_err(
          44  +
                                                    |ev_error| ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::ConstraintViolation(
          45  +
                                                        #[allow(clippy::useless_conversion)]
          46  +
                                                        format!("{ev_error}").into()
          47  +
                                                    )
          48  +
                                                )? {
          49  +
                                                
          50  +
                                            }
          51  +
            Some(receiver)
          52  +
        } {
          53  +
            input = input.set_stream(value)
          54  +
        }
          55  +
        /* ServerHttpBoundProtocolGenerator.kt:910 */
          56  +
        input.build()?
          57  +
        /* ServerHttpBoundProtocolGenerator.kt:428 */
          58  +
    })
          59  +
    /* ServerHttpBoundProtocolGenerator.kt:412 */
          60  +
}
          61  +
          62  +
/* RustType.kt:534 */
          63  +
#[allow(clippy::unnecessary_wraps)]
          64  +
/* ServerHttpBoundProtocolGenerator.kt:449 */
          65  +
pub fn ser_duplex_stream_http_response(
          66  +
    #[allow(unused_variables)] output: crate::output::DuplexStreamOutput,
          67  +
) -> std::result::Result<
          68  +
    ::aws_smithy_http_server::response::Response,
          69  +
    ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
          70  +
> {
          71  +
    /* ServerHttpBoundProtocolGenerator.kt:461 */
          72  +
    Ok({
          73  +
        /* RustType.kt:534 */
          74  +
        #[allow(unused_mut)]
          75  +
        /* ServerHttpBoundProtocolGenerator.kt:551 */
          76  +
        let mut builder = ::http_1x::Response::builder();
          77  +
        /* ServerHttpBoundProtocolGenerator.kt:647 */
          78  +
        builder = ::aws_smithy_http::header::set_response_header_if_absent(
          79  +
            builder,
          80  +
            ::http_1x::header::CONTENT_TYPE,
          81  +
            "application/vnd.amazon.eventstream",
          82  +
        );
          83  +
        /* ServerHttpBoundProtocolGenerator.kt:732 */
          84  +
        let http_status: u16 = 200;
          85  +
        builder = builder.status(http_status);
          86  +
        /* ServerHttpBoundProtocolGenerator.kt:589 */
          87  +
        let body = ::aws_smithy_http_server::body::boxed(::http_body_util::StreamBody::new(
          88  +
            /* ServerHttpBoundProtocolGenerator.kt:145 */
          89  +
            {
          90  +
                let error_marshaller = crate::event_stream_serde::EventStreamErrorMarshaller::new();
          91  +
                let marshaller = crate::event_stream_serde::EventStreamMarshaller::new();
          92  +
                let signer = ::aws_smithy_eventstream::frame::NoOpSigner {};
          93  +
                output
          94  +
                    .stream
          95  +
                    .into_body_stream(marshaller, error_marshaller, signer)
          96  +
            }, /* ServerHttpBoundProtocolGenerator.kt:589 */
          97  +
        ));
          98  +
        /* ServerHttpBoundProtocolGenerator.kt:625 */
          99  +
        builder.body(body)?
         100  +
        /* ServerHttpBoundProtocolGenerator.kt:461 */
         101  +
    })
         102  +
    /* ServerHttpBoundProtocolGenerator.kt:449 */
         103  +
}
         104  +
         105  +
/* RustType.kt:534 */
         106  +
#[allow(clippy::unnecessary_wraps)]
         107  +
/* ServerHttpBoundProtocolGenerator.kt:475 */
         108  +
pub fn ser_duplex_stream_http_error(
         109  +
    error: &crate::error::DuplexStreamError,
         110  +
) -> std::result::Result<
         111  +
    ::aws_smithy_http_server::response::Response,
         112  +
    ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
         113  +
> {
         114  +
    /* ServerHttpBoundProtocolGenerator.kt:480 */
         115  +
    Ok({
         116  +
        /* ServerHttpBoundProtocolGenerator.kt:496 */
         117  +
        match error {
         118  +
            /* ServerHttpBoundProtocolGenerator.kt:504 */
         119  +
            crate::error::DuplexStreamError::ValidationException(output) => {
         120  +
                /* ServerHttpBoundProtocolGenerator.kt:505 */
         121  +
                let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
         122  +
                /* RustType.kt:534 */
         123  +
                #[allow(unused_mut)]
         124  +
                /* ServerHttpBoundProtocolGenerator.kt:515 */
         125  +
                let mut builder = ::http_1x::Response::builder();
         126  +
                /* ServerHttpBoundProtocolGenerator.kt:647 */
         127  +
                builder = ::aws_smithy_http::header::set_response_header_if_absent(
         128  +
                    builder,
         129  +
                    ::http_1x::header::CONTENT_TYPE,
         130  +
                    "application/vnd.amazon.eventstream",
         131  +
                );
         132  +
                /* ServerHttpBoundProtocolGenerator.kt:647 */
         133  +
                builder = ::aws_smithy_http::header::set_response_header_if_absent(
         134  +
                    builder,
         135  +
                    ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
         136  +
                    "ValidationException",
         137  +
                );
         138  +
                /* ServerHttpBoundProtocolGenerator.kt:713 */
         139  +
                let content_length = payload.len();
         140  +
                builder = ::aws_smithy_http::header::set_response_header_if_absent(
         141  +
                    builder,
         142  +
                    ::http_1x::header::CONTENT_LENGTH,
         143  +
                    content_length,
         144  +
                );
         145  +
                /* ServerHttpBoundProtocolGenerator.kt:532 */
         146  +
                builder
         147  +
                    .status(400)
         148  +
                    .body(::aws_smithy_http_server::body::to_boxed(payload))?
         149  +
                /* ServerHttpBoundProtocolGenerator.kt:504 */
         150  +
            }
         151  +
            /* ServerHttpBoundProtocolGenerator.kt:504 */
         152  +
            crate::error::DuplexStreamError::ErrorEvent(output) => {
         153  +
                /* ServerHttpBoundProtocolGenerator.kt:505 */
         154  +
                let payload =
         155  +
                    crate::protocol_serde::shape_error_event::ser_error_event_error(output)?;
         156  +
                /* RustType.kt:534 */
         157  +
                #[allow(unused_mut)]
         158  +
                /* ServerHttpBoundProtocolGenerator.kt:515 */
         159  +
                let mut builder = ::http_1x::Response::builder();
         160  +
                /* ServerHttpBoundProtocolGenerator.kt:647 */
         161  +
                builder = ::aws_smithy_http::header::set_response_header_if_absent(
         162  +
                    builder,
         163  +
                    ::http_1x::header::CONTENT_TYPE,
         164  +
                    "application/vnd.amazon.eventstream",
         165  +
                );
         166  +
                /* ServerHttpBoundProtocolGenerator.kt:647 */
         167  +
                builder = ::aws_smithy_http::header::set_response_header_if_absent(
         168  +
                    builder,
         169  +
                    ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
         170  +
                    "ErrorEvent",
         171  +
                );
         172  +
                /* ServerHttpBoundProtocolGenerator.kt:713 */
         173  +
                let content_length = payload.len();
         174  +
                builder = ::aws_smithy_http::header::set_response_header_if_absent(
         175  +
                    builder,
         176  +
                    ::http_1x::header::CONTENT_LENGTH,
         177  +
                    content_length,
         178  +
                );
         179  +
                /* ServerHttpBoundProtocolGenerator.kt:532 */
         180  +
                builder
         181  +
                    .status(400)
         182  +
                    .body(::aws_smithy_http_server::body::to_boxed(payload))?
         183  +
                /* ServerHttpBoundProtocolGenerator.kt:504 */
         184  +
            } /* ServerHttpBoundProtocolGenerator.kt:496 */
         185  +
        }
         186  +
        /* ServerHttpBoundProtocolGenerator.kt:480 */
         187  +
    })
         188  +
    /* ServerHttpBoundProtocolGenerator.kt:475 */
         189  +
}

tmp-codegen-diff/codegen-server-test/rest_json/rust-server-codegen/src/protocol_serde/shape_duplex_stream_input.rs

@@ -0,1 +0,19 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* HttpBindingGenerator.kt:236 */
           3  +
pub fn de_stream_payload(
           4  +
    body: &mut ::aws_smithy_types::body::SdkBody,
           5  +
) -> std::result::Result<
           6  +
    crate::sigv4_event_stream::SigV4Receiver<
           7  +
        crate::model::EventStream,
           8  +
        crate::error::EventStreamError,
           9  +
    >,
          10  +
    ::aws_smithy_json::deserialize::error::DeserializeError,
          11  +
> {
          12  +
    /* HttpBindingGenerator.kt:278 */
          13  +
    let unmarshaller = crate::event_stream_serde::EventStreamUnmarshaller::new();
          14  +
    /* HttpBindingGenerator.kt:296 */
          15  +
    let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
          16  +
    let receiver = crate::sigv4_event_stream::SigV4Receiver::new(unmarshaller, body);
          17  +
    Ok(receiver)
          18  +
    /* HttpBindingGenerator.kt:236 */
          19  +
}

tmp-codegen-diff/codegen-server-test/rest_json/rust-server-codegen/src/protocol_serde/shape_duplex_stream_with_distinct_streams.rs

@@ -0,1 +0,188 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* RustType.kt:534 */
           3  +
#[allow(clippy::unnecessary_wraps)]
           4  +
/* ServerHttpBoundProtocolGenerator.kt:412 */
           5  +
pub async fn de_duplex_stream_with_distinct_streams_http_request<B>(
           6  +
    #[allow(unused_variables)] request: ::http_1x::Request<B>,
           7  +
) -> std::result::Result<
           8  +
    crate::input::DuplexStreamWithDistinctStreamsInput,
           9  +
    ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
          10  +
>
          11  +
where
          12  +
    B: ::aws_smithy_http_server::body::HttpBody + Send,
          13  +
    B: ::http_body_1x::Body<Data = ::bytes::Bytes>
          14  +
        + ::std::marker::Send
          15  +
        + ::std::marker::Sync
          16  +
        + 'static,
          17  +
    B::Error: Into<::aws_smithy_types::body::Error> + 'static,
          18  +
          19  +
    B::Data: Send,
          20  +
    ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
          21  +
        From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
          22  +
{
          23  +
    /* ServerHttpBoundProtocolGenerator.kt:428 */
          24  +
    Ok({
          25  +
        /* RustType.kt:534 */
          26  +
        #[allow(unused_mut)]
          27  +
        /* ServerHttpBoundProtocolGenerator.kt:773 */
          28  +
        let mut input = crate::input::duplex_stream_with_distinct_streams_input::Builder::default();
          29  +
        /* RustType.kt:534 */
          30  +
        #[allow(unused_variables)]
          31  +
        /* ServerHttpBoundProtocolGenerator.kt:778 */
          32  +
        let ::aws_smithy_runtime_api::http::RequestParts {
          33  +
            uri, headers, body, ..
          34  +
        } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
          35  +
        /* ServerHttpBoundProtocolGenerator.kt:870 */
          36  +
        if let Some(value) = {
          37  +
            let mut receiver = crate::protocol_serde::shape_duplex_stream_with_distinct_streams_input::de_stream_payload(&mut ::aws_smithy_types::body::SdkBody::from_body_1_x(body))?;
          38  +
            if let Some(_initial_event) = receiver
          39  +
                                                .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
          40  +
                                                .await
          41  +
                                                .map_err(
          42  +
                                                    |ev_error| ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::ConstraintViolation(
          43  +
                                                        #[allow(clippy::useless_conversion)]
          44  +
                                                        format!("{ev_error}").into()
          45  +
                                                    )
          46  +
                                                )? {
          47  +
                                                
          48  +
                                            }
          49  +
            Some(receiver)
          50  +
        } {
          51  +
            input = input.set_stream(value)
          52  +
        }
          53  +
        /* ServerHttpBoundProtocolGenerator.kt:910 */
          54  +
        input.build()?
          55  +
        /* ServerHttpBoundProtocolGenerator.kt:428 */
          56  +
    })
          57  +
    /* ServerHttpBoundProtocolGenerator.kt:412 */
          58  +
}
          59  +
          60  +
/* RustType.kt:534 */
          61  +
#[allow(clippy::unnecessary_wraps)]
          62  +
/* ServerHttpBoundProtocolGenerator.kt:449 */
          63  +
pub fn ser_duplex_stream_with_distinct_streams_http_response(
          64  +
    #[allow(unused_variables)] output: crate::output::DuplexStreamWithDistinctStreamsOutput,
          65  +
) -> std::result::Result<
          66  +
    ::aws_smithy_http_server::response::Response,
          67  +
    ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
          68  +
> {
          69  +
    /* ServerHttpBoundProtocolGenerator.kt:461 */
          70  +
    Ok({
          71  +
        /* RustType.kt:534 */
          72  +
        #[allow(unused_mut)]
          73  +
        /* ServerHttpBoundProtocolGenerator.kt:551 */
          74  +
        let mut builder = ::http_1x::Response::builder();
          75  +
        /* ServerHttpBoundProtocolGenerator.kt:647 */
          76  +
        builder = ::aws_smithy_http::header::set_response_header_if_absent(
          77  +
            builder,
          78  +
            ::http_1x::header::CONTENT_TYPE,
          79  +
            "application/json",
          80  +
        );
          81  +
        /* ServerHttpBoundProtocolGenerator.kt:732 */
          82  +
        let http_status: u16 = 200;
          83  +
        builder = builder.status(http_status);
          84  +
        /* ServerHttpBoundProtocolGenerator.kt:611 */
          85  +
        let payload =
          86  +
            /* HttpBoundProtocolPayloadGenerator.kt:353 */crate::protocol_serde::shape_duplex_stream_with_distinct_streams_output::ser_stream_http_payload(& output.stream)?
          87  +
        /* ServerHttpBoundProtocolGenerator.kt:611 */;
          88  +
        /* ServerHttpBoundProtocolGenerator.kt:713 */
          89  +
        let content_length = payload.len();
          90  +
        builder = ::aws_smithy_http::header::set_response_header_if_absent(
          91  +
            builder,
          92  +
            ::http_1x::header::CONTENT_LENGTH,
          93  +
            content_length,
          94  +
        );
          95  +
        /* ServerHttpBoundProtocolGenerator.kt:617 */
          96  +
        let body = ::aws_smithy_http_server::body::to_boxed(payload);
          97  +
        /* ServerHttpBoundProtocolGenerator.kt:625 */
          98  +
        builder.body(body)?
          99  +
        /* ServerHttpBoundProtocolGenerator.kt:461 */
         100  +
    })
         101  +
    /* ServerHttpBoundProtocolGenerator.kt:449 */
         102  +
}
         103  +
         104  +
/* RustType.kt:534 */
         105  +
#[allow(clippy::unnecessary_wraps)]
         106  +
/* ServerHttpBoundProtocolGenerator.kt:475 */
         107  +
pub fn ser_duplex_stream_with_distinct_streams_http_error(
         108  +
    error: &crate::error::DuplexStreamWithDistinctStreamsError,
         109  +
) -> std::result::Result<
         110  +
    ::aws_smithy_http_server::response::Response,
         111  +
    ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
         112  +
> {
         113  +
    /* ServerHttpBoundProtocolGenerator.kt:480 */
         114  +
    Ok({
         115  +
        /* ServerHttpBoundProtocolGenerator.kt:496 */
         116  +
        match error {
         117  +
            /* ServerHttpBoundProtocolGenerator.kt:504 */
         118  +
            crate::error::DuplexStreamWithDistinctStreamsError::ValidationException(output) => {
         119  +
                /* ServerHttpBoundProtocolGenerator.kt:505 */
         120  +
                let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
         121  +
                /* RustType.kt:534 */
         122  +
                #[allow(unused_mut)]
         123  +
                /* ServerHttpBoundProtocolGenerator.kt:515 */
         124  +
                let mut builder = ::http_1x::Response::builder();
         125  +
                /* ServerHttpBoundProtocolGenerator.kt:647 */
         126  +
                builder = ::aws_smithy_http::header::set_response_header_if_absent(
         127  +
                    builder,
         128  +
                    ::http_1x::header::CONTENT_TYPE,
         129  +
                    "application/json",
         130  +
                );
         131  +
                /* ServerHttpBoundProtocolGenerator.kt:647 */
         132  +
                builder = ::aws_smithy_http::header::set_response_header_if_absent(
         133  +
                    builder,
         134  +
                    ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
         135  +
                    "ValidationException",
         136  +
                );
         137  +
                /* ServerHttpBoundProtocolGenerator.kt:713 */
         138  +
                let content_length = payload.len();
         139  +
                builder = ::aws_smithy_http::header::set_response_header_if_absent(
         140  +
                    builder,
         141  +
                    ::http_1x::header::CONTENT_LENGTH,
         142  +
                    content_length,
         143  +
                );
         144  +
                /* ServerHttpBoundProtocolGenerator.kt:532 */
         145  +
                builder
         146  +
                    .status(400)
         147  +
                    .body(::aws_smithy_http_server::body::to_boxed(payload))?
         148  +
                /* ServerHttpBoundProtocolGenerator.kt:504 */
         149  +
            }
         150  +
            /* ServerHttpBoundProtocolGenerator.kt:504 */
         151  +
            crate::error::DuplexStreamWithDistinctStreamsError::ErrorEvent(output) => {
         152  +
                /* ServerHttpBoundProtocolGenerator.kt:505 */
         153  +
                let payload =
         154  +
                    crate::protocol_serde::shape_error_event::ser_error_event_error(output)?;
         155  +
                /* RustType.kt:534 */
         156  +
                #[allow(unused_mut)]
         157  +
                /* ServerHttpBoundProtocolGenerator.kt:515 */
         158  +
                let mut builder = ::http_1x::Response::builder();
         159  +
                /* ServerHttpBoundProtocolGenerator.kt:647 */
         160  +
                builder = ::aws_smithy_http::header::set_response_header_if_absent(
         161  +
                    builder,
         162  +
                    ::http_1x::header::CONTENT_TYPE,
         163  +
                    "application/json",
         164  +
                );
         165  +
                /* ServerHttpBoundProtocolGenerator.kt:647 */
         166  +
                builder = ::aws_smithy_http::header::set_response_header_if_absent(
         167  +
                    builder,
         168  +
                    ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
         169  +
                    "ErrorEvent",
         170  +
                );
         171  +
                /* ServerHttpBoundProtocolGenerator.kt:713 */
         172  +
                let content_length = payload.len();
         173  +
                builder = ::aws_smithy_http::header::set_response_header_if_absent(
         174  +
                    builder,
         175  +
                    ::http_1x::header::CONTENT_LENGTH,
         176  +
                    content_length,
         177  +
                );
         178  +
                /* ServerHttpBoundProtocolGenerator.kt:532 */
         179  +
                builder
         180  +
                    .status(400)
         181  +
                    .body(::aws_smithy_http_server::body::to_boxed(payload))?
         182  +
                /* ServerHttpBoundProtocolGenerator.kt:504 */
         183  +
            } /* ServerHttpBoundProtocolGenerator.kt:496 */
         184  +
        }
         185  +
        /* ServerHttpBoundProtocolGenerator.kt:480 */
         186  +
    })
         187  +
    /* ServerHttpBoundProtocolGenerator.kt:475 */
         188  +
}

tmp-codegen-diff/codegen-server-test/rest_json/rust-server-codegen/src/protocol_serde/shape_duplex_stream_with_distinct_streams_input.rs

@@ -0,1 +0,19 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* HttpBindingGenerator.kt:236 */
           3  +
pub fn de_stream_payload(
           4  +
    body: &mut ::aws_smithy_types::body::SdkBody,
           5  +
) -> std::result::Result<
           6  +
    crate::sigv4_event_stream::SigV4Receiver<
           7  +
        crate::model::EventStream,
           8  +
        crate::error::EventStreamError,
           9  +
    >,
          10  +
    ::aws_smithy_json::deserialize::error::DeserializeError,
          11  +
> {
          12  +
    /* HttpBindingGenerator.kt:278 */
          13  +
    let unmarshaller = crate::event_stream_serde::EventStreamUnmarshaller::new();
          14  +
    /* HttpBindingGenerator.kt:296 */
          15  +
    let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
          16  +
    let receiver = crate::sigv4_event_stream::SigV4Receiver::new(unmarshaller, body);
          17  +
    Ok(receiver)
          18  +
    /* HttpBindingGenerator.kt:236 */
          19  +
}

tmp-codegen-diff/codegen-server-test/rest_json/rust-server-codegen/src/protocol_serde/shape_duplex_stream_with_distinct_streams_output.rs

@@ -0,1 +0,44 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* HttpBoundProtocolPayloadGenerator.kt:314 */
           3  +
pub fn ser_stream_http_payload(
           4  +
    payload: &::std::option::Option<crate::model::SingletonEventStream>,
           5  +
) -> ::std::result::Result<::std::vec::Vec<u8>, ::aws_smithy_types::error::operation::BuildError> {
           6  +
    /* HttpBoundProtocolPayloadGenerator.kt:323 */
           7  +
    let payload = match payload.as_ref() {
           8  +
        Some(t) => t,
           9  +
        None => {
          10  +
            return Ok(
          11  +
                /* HttpBoundProtocolPayloadGenerator.kt:342 */
          12  +
                crate::protocol_serde::rest_json_unset_union_payload(), /* HttpBoundProtocolPayloadGenerator.kt:323 */
          13  +
            )
          14  +
        }
          15  +
    };
          16  +
    /* HttpBoundProtocolPayloadGenerator.kt:348 */
          17  +
    Ok(
          18  +
        /* HttpBoundProtocolPayloadGenerator.kt:389 */crate::protocol_serde::shape_duplex_stream_with_distinct_streams_output::ser_stream_payload(payload)?
          19  +
    /* HttpBoundProtocolPayloadGenerator.kt:348 */)
          20  +
    /* HttpBoundProtocolPayloadGenerator.kt:314 */
          21  +
}
          22  +
          23  +
/* JsonSerializerGenerator.kt:242 */
          24  +
pub fn ser_stream_payload(
          25  +
    input: &crate::model::SingletonEventStream,
          26  +
) -> std::result::Result<
          27  +
    ::std::vec::Vec<u8>,
          28  +
    ::aws_smithy_types::error::operation::SerializationError,
          29  +
> {
          30  +
    /* JsonSerializerGenerator.kt:247 */
          31  +
    let mut out = String::new();
          32  +
    /* JsonSerializerGenerator.kt:248 */
          33  +
    let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
          34  +
    /* JsonSerializerGenerator.kt:591 */
          35  +
    crate::protocol_serde::shape_singleton_event_stream::ser_singleton_event_stream(
          36  +
        &mut object,
          37  +
        input,
          38  +
    )?;
          39  +
    /* JsonSerializerGenerator.kt:254 */
          40  +
    object.finish();
          41  +
    /* JsonSerializerGenerator.kt:255 */
          42  +
    Ok(out.into_bytes())
          43  +
    /* JsonSerializerGenerator.kt:242 */
          44  +
}

tmp-codegen-diff/codegen-server-test/rest_json/rust-server-codegen/src/protocol_serde/shape_duplex_stream_with_initial_messages.rs

@@ -0,1 +0,261 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* RustType.kt:534 */
           3  +
#[allow(clippy::unnecessary_wraps)]
           4  +
/* ServerHttpBoundProtocolGenerator.kt:412 */
           5  +
pub async fn de_duplex_stream_with_initial_messages_http_request<B>(
           6  +
    #[allow(unused_variables)] request: ::http_1x::Request<B>,
           7  +
) -> std::result::Result<
           8  +
    crate::input::DuplexStreamWithInitialMessagesInput,
           9  +
    ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection,
          10  +
>
          11  +
where
          12  +
    B: ::aws_smithy_http_server::body::HttpBody + Send,
          13  +
    B: ::http_body_1x::Body<Data = ::bytes::Bytes>
          14  +
        + ::std::marker::Send
          15  +
        + ::std::marker::Sync
          16  +
        + 'static,
          17  +
    B::Error: Into<::aws_smithy_types::body::Error> + 'static,
          18  +
          19  +
    B::Data: Send,
          20  +
    ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection:
          21  +
        From<<B as ::aws_smithy_http_server::body::HttpBody>::Error>,
          22  +
{
          23  +
    /* ServerHttpBoundProtocolGenerator.kt:428 */
          24  +
    Ok({
          25  +
        /* RustType.kt:534 */
          26  +
        #[allow(unused_mut)]
          27  +
        /* ServerHttpBoundProtocolGenerator.kt:773 */
          28  +
        let mut input = crate::input::duplex_stream_with_initial_messages_input::Builder::default();
          29  +
        /* RustType.kt:534 */
          30  +
        #[allow(unused_variables)]
          31  +
        /* ServerHttpBoundProtocolGenerator.kt:778 */
          32  +
        let ::aws_smithy_runtime_api::http::RequestParts {
          33  +
            uri, headers, body, ..
          34  +
        } = ::aws_smithy_runtime_api::http::Request::try_from(request)?.into_parts();
          35  +
        /* ServerHttpBoundProtocolGenerator.kt:870 */
          36  +
        if let Some(value) = crate::protocol_serde::shape_duplex_stream_with_initial_messages_input::de_initial_request_member_header(&headers)? {
          37  +
                                input = input.set_initial_request_member(value)
          38  +
                            }
          39  +
        /* ServerHttpBoundProtocolGenerator.kt:870 */
          40  +
        if let Some(value) = {
          41  +
            let mut receiver = crate::protocol_serde::shape_duplex_stream_with_initial_messages_input::de_stream_payload(&mut ::aws_smithy_types::body::SdkBody::from_body_1_x(body))?;
          42  +
            if let Some(_initial_event) = receiver
          43  +
                                                .try_recv_initial(::aws_smithy_http::event_stream::InitialMessageType::Request)
          44  +
                                                .await
          45  +
                                                .map_err(
          46  +
                                                    |ev_error| ::aws_smithy_http_server::protocol::rest_json_1::rejection::RequestRejection::ConstraintViolation(
          47  +
                                                        #[allow(clippy::useless_conversion)]
          48  +
                                                        format!("{ev_error}").into()
          49  +
                                                    )
          50  +
                                                )? {
          51  +
                                                
          52  +
                                            }
          53  +
            Some(receiver)
          54  +
        } {
          55  +
            input = input.set_stream(value)
          56  +
        }
          57  +
        /* ServerHttpBoundProtocolGenerator.kt:910 */
          58  +
        input.build()?
          59  +
        /* ServerHttpBoundProtocolGenerator.kt:428 */
          60  +
    })
          61  +
    /* ServerHttpBoundProtocolGenerator.kt:412 */
          62  +
}
          63  +
          64  +
/* RustType.kt:534 */
          65  +
#[allow(clippy::unnecessary_wraps)]
          66  +
/* ServerHttpBoundProtocolGenerator.kt:449 */
          67  +
pub fn ser_duplex_stream_with_initial_messages_http_response(
          68  +
    #[allow(unused_variables)] output: crate::output::DuplexStreamWithInitialMessagesOutput,
          69  +
) -> std::result::Result<
          70  +
    ::aws_smithy_http_server::response::Response,
          71  +
    ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
          72  +
> {
          73  +
    /* ServerHttpBoundProtocolGenerator.kt:461 */
          74  +
    Ok({
          75  +
        /* RustType.kt:534 */
          76  +
        #[allow(unused_mut)]
          77  +
        /* ServerHttpBoundProtocolGenerator.kt:551 */
          78  +
        let mut builder = ::http_1x::Response::builder();
          79  +
        /* ServerHttpBoundProtocolGenerator.kt:679 */
          80  +
        builder = crate::protocol_serde::shape_duplex_stream_with_initial_messages::ser_duplex_stream_with_initial_messages_headers(&output, builder)?;
          81  +
        /* ServerHttpBoundProtocolGenerator.kt:647 */
          82  +
        builder = ::aws_smithy_http::header::set_response_header_if_absent(
          83  +
            builder,
          84  +
            ::http_1x::header::CONTENT_TYPE,
          85  +
            "application/vnd.amazon.eventstream",
          86  +
        );
          87  +
        /* ServerHttpBoundProtocolGenerator.kt:732 */
          88  +
        let http_status: u16 = 200;
          89  +
        builder = builder.status(http_status);
          90  +
        /* ServerHttpBoundProtocolGenerator.kt:589 */
          91  +
        let body = ::aws_smithy_http_server::body::boxed(::http_body_util::StreamBody::new(
          92  +
            /* ServerHttpBoundProtocolGenerator.kt:145 */
          93  +
            {
          94  +
                let error_marshaller = crate::event_stream_serde::EventStreamErrorMarshaller::new();
          95  +
                let marshaller = crate::event_stream_serde::EventStreamMarshaller::new();
          96  +
                let signer = ::aws_smithy_eventstream::frame::NoOpSigner {};
          97  +
                output
          98  +
                    .stream
          99  +
                    .into_body_stream(marshaller, error_marshaller, signer)
         100  +
            }, /* ServerHttpBoundProtocolGenerator.kt:589 */
         101  +
        ));
         102  +
        /* ServerHttpBoundProtocolGenerator.kt:625 */
         103  +
        builder.body(body)?
         104  +
        /* ServerHttpBoundProtocolGenerator.kt:461 */
         105  +
    })
         106  +
    /* ServerHttpBoundProtocolGenerator.kt:449 */
         107  +
}
         108  +
         109  +
/* RustType.kt:534 */
         110  +
#[allow(clippy::unnecessary_wraps)]
         111  +
/* ServerHttpBoundProtocolGenerator.kt:475 */
         112  +
pub fn ser_duplex_stream_with_initial_messages_http_error(
         113  +
    error: &crate::error::DuplexStreamWithInitialMessagesError,
         114  +
) -> std::result::Result<
         115  +
    ::aws_smithy_http_server::response::Response,
         116  +
    ::aws_smithy_http_server::protocol::rest_json_1::rejection::ResponseRejection,
         117  +
> {
         118  +
    /* ServerHttpBoundProtocolGenerator.kt:480 */
         119  +
    Ok({
         120  +
        /* ServerHttpBoundProtocolGenerator.kt:496 */
         121  +
        match error {
         122  +
            /* ServerHttpBoundProtocolGenerator.kt:504 */
         123  +
            crate::error::DuplexStreamWithInitialMessagesError::ServiceUnavailableError(output) => {
         124  +
                /* ServerHttpBoundProtocolGenerator.kt:505 */
         125  +
                let payload = crate::protocol_serde::shape_service_unavailable_error::ser_service_unavailable_error_error(output)?;
         126  +
                /* RustType.kt:534 */
         127  +
                #[allow(unused_mut)]
         128  +
                /* ServerHttpBoundProtocolGenerator.kt:515 */
         129  +
                let mut builder = ::http_1x::Response::builder();
         130  +
                /* ServerHttpBoundProtocolGenerator.kt:647 */
         131  +
                builder = ::aws_smithy_http::header::set_response_header_if_absent(
         132  +
                    builder,
         133  +
                    ::http_1x::header::CONTENT_TYPE,
         134  +
                    "application/vnd.amazon.eventstream",
         135  +
                );
         136  +
                /* ServerHttpBoundProtocolGenerator.kt:647 */
         137  +
                builder = ::aws_smithy_http::header::set_response_header_if_absent(
         138  +
                    builder,
         139  +
                    ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
         140  +
                    "ServiceUnavailableError",
         141  +
                );
         142  +
                /* ServerHttpBoundProtocolGenerator.kt:713 */
         143  +
                let content_length = payload.len();
         144  +
                builder = ::aws_smithy_http::header::set_response_header_if_absent(
         145  +
                    builder,
         146  +
                    ::http_1x::header::CONTENT_LENGTH,
         147  +
                    content_length,
         148  +
                );
         149  +
                /* ServerHttpBoundProtocolGenerator.kt:532 */
         150  +
                builder
         151  +
                    .status(500)
         152  +
                    .body(::aws_smithy_http_server::body::to_boxed(payload))?
         153  +
                /* ServerHttpBoundProtocolGenerator.kt:504 */
         154  +
            }
         155  +
            /* ServerHttpBoundProtocolGenerator.kt:504 */
         156  +
            crate::error::DuplexStreamWithInitialMessagesError::ValidationException(output) => {
         157  +
                /* ServerHttpBoundProtocolGenerator.kt:505 */
         158  +
                let payload = crate::protocol_serde::shape_validation_exception::ser_validation_exception_error(output)?;
         159  +
                /* RustType.kt:534 */
         160  +
                #[allow(unused_mut)]
         161  +
                /* ServerHttpBoundProtocolGenerator.kt:515 */
         162  +
                let mut builder = ::http_1x::Response::builder();
         163  +
                /* ServerHttpBoundProtocolGenerator.kt:647 */
         164  +
                builder = ::aws_smithy_http::header::set_response_header_if_absent(
         165  +
                    builder,
         166  +
                    ::http_1x::header::CONTENT_TYPE,
         167  +
                    "application/vnd.amazon.eventstream",
         168  +
                );
         169  +
                /* ServerHttpBoundProtocolGenerator.kt:647 */
         170  +
                builder = ::aws_smithy_http::header::set_response_header_if_absent(
         171  +
                    builder,
         172  +
                    ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
         173  +
                    "ValidationException",
         174  +
                );
         175  +
                /* ServerHttpBoundProtocolGenerator.kt:713 */
         176  +
                let content_length = payload.len();
         177  +
                builder = ::aws_smithy_http::header::set_response_header_if_absent(
         178  +
                    builder,
         179  +
                    ::http_1x::header::CONTENT_LENGTH,
         180  +
                    content_length,
         181  +
                );
         182  +
                /* ServerHttpBoundProtocolGenerator.kt:532 */
         183  +
                builder
         184  +
                    .status(400)
         185  +
                    .body(::aws_smithy_http_server::body::to_boxed(payload))?
         186  +
                /* ServerHttpBoundProtocolGenerator.kt:504 */
         187  +
            }
         188  +
            /* ServerHttpBoundProtocolGenerator.kt:504 */
         189  +
            crate::error::DuplexStreamWithInitialMessagesError::ErrorEvent(output) => {
         190  +
                /* ServerHttpBoundProtocolGenerator.kt:505 */
         191  +
                let payload =
         192  +
                    crate::protocol_serde::shape_error_event::ser_error_event_error(output)?;
         193  +
                /* RustType.kt:534 */
         194  +
                #[allow(unused_mut)]
         195  +
                /* ServerHttpBoundProtocolGenerator.kt:515 */
         196  +
                let mut builder = ::http_1x::Response::builder();
         197  +
                /* ServerHttpBoundProtocolGenerator.kt:647 */
         198  +
                builder = ::aws_smithy_http::header::set_response_header_if_absent(
         199  +
                    builder,
         200  +
                    ::http_1x::header::CONTENT_TYPE,
         201  +
                    "application/vnd.amazon.eventstream",
         202  +
                );
         203  +
                /* ServerHttpBoundProtocolGenerator.kt:647 */
         204  +
                builder = ::aws_smithy_http::header::set_response_header_if_absent(
         205  +
                    builder,
         206  +
                    ::http_1x::header::HeaderName::from_static("x-amzn-errortype"),
         207  +
                    "ErrorEvent",
         208  +
                );
         209  +
                /* ServerHttpBoundProtocolGenerator.kt:713 */
         210  +
                let content_length = payload.len();
         211  +
                builder = ::aws_smithy_http::header::set_response_header_if_absent(
         212  +
                    builder,
         213  +
                    ::http_1x::header::CONTENT_LENGTH,
         214  +
                    content_length,
         215  +
                );
         216  +
                /* ServerHttpBoundProtocolGenerator.kt:532 */
         217  +
                builder
         218  +
                    .status(400)
         219  +
                    .body(::aws_smithy_http_server::body::to_boxed(payload))?
         220  +
                /* ServerHttpBoundProtocolGenerator.kt:504 */
         221  +
            } /* ServerHttpBoundProtocolGenerator.kt:496 */
         222  +
        }
         223  +
        /* ServerHttpBoundProtocolGenerator.kt:480 */
         224  +
    })
         225  +
    /* ServerHttpBoundProtocolGenerator.kt:475 */
         226  +
}
         227  +
         228  +
/* HttpBindingGenerator.kt:565 */
         229  +
pub fn ser_duplex_stream_with_initial_messages_headers(
         230  +
    input: &crate::output::DuplexStreamWithInitialMessagesOutput,
         231  +
    mut builder: ::http_1x::response::Builder,
         232  +
) -> std::result::Result<
         233  +
    ::http_1x::response::Builder,
         234  +
    ::aws_smithy_types::error::operation::BuildError,
         235  +
> {
         236  +
    /* SerializerUtil.kt:42 */
         237  +
    {
         238  +
        /* HttpBindingGenerator.kt:727 */
         239  +
        let formatted_1 = &input.initial_response_member.as_str();
         240  +
        /* HttpBindingGenerator.kt:728 */
         241  +
        if !formatted_1.is_empty() {
         242  +
            /* HttpBindingGenerator.kt:729 */
         243  +
            let header_value = formatted_1;
         244  +
            let header_value: ::http_1x::HeaderValue = header_value.parse().map_err(|err| {
         245  +
                ::aws_smithy_types::error::operation::BuildError::invalid_field(
         246  +
                    "initial_response_member",
         247  +
                    format!(
         248  +
                        "`{}` cannot be used as a header value: {}",
         249  +
                        &header_value, err
         250  +
                    ),
         251  +
                )
         252  +
            })?;
         253  +
            builder = builder.header("initial-response-member", header_value);
         254  +
            /* HttpBindingGenerator.kt:728 */
         255  +
        }
         256  +
        /* SerializerUtil.kt:42 */
         257  +
    }
         258  +
    /* HttpBindingGenerator.kt:578 */
         259  +
    Ok(builder)
         260  +
    /* HttpBindingGenerator.kt:565 */
         261  +
}

tmp-codegen-diff/codegen-server-test/rest_json/rust-server-codegen/src/protocol_serde/shape_duplex_stream_with_initial_messages_input.rs

@@ -0,1 +0,33 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* HttpBindingGenerator.kt:159 */
           3  +
pub(crate) fn de_initial_request_member_header(
           4  +
    header_map: &::aws_smithy_runtime_api::http::Headers,
           5  +
) -> ::std::result::Result<
           6  +
    ::std::option::Option<::std::string::String>,
           7  +
    ::aws_smithy_http::header::ParseError,
           8  +
> {
           9  +
    /* HttpBindingGenerator.kt:166 */
          10  +
    let headers = header_map.get_all("initial-request-member");
          11  +
    /* HttpBindingGenerator.kt:398 */
          12  +
    ::aws_smithy_http::header::one_or_none(headers)
          13  +
    /* HttpBindingGenerator.kt:159 */
          14  +
}
          15  +
          16  +
/* HttpBindingGenerator.kt:236 */
          17  +
pub fn de_stream_payload(
          18  +
    body: &mut ::aws_smithy_types::body::SdkBody,
          19  +
) -> std::result::Result<
          20  +
    crate::sigv4_event_stream::SigV4Receiver<
          21  +
        crate::model::EventStream,
          22  +
        crate::error::EventStreamError,
          23  +
    >,
          24  +
    ::aws_smithy_json::deserialize::error::DeserializeError,
          25  +
> {
          26  +
    /* HttpBindingGenerator.kt:278 */
          27  +
    let unmarshaller = crate::event_stream_serde::EventStreamUnmarshaller::new();
          28  +
    /* HttpBindingGenerator.kt:296 */
          29  +
    let body = std::mem::replace(body, ::aws_smithy_types::body::SdkBody::taken());
          30  +
    let receiver = crate::sigv4_event_stream::SigV4Receiver::new(unmarshaller, body);
          31  +
    Ok(receiver)
          32  +
    /* HttpBindingGenerator.kt:236 */
          33  +
}

tmp-codegen-diff/codegen-server-test/rest_json/rust-server-codegen/src/protocol_serde/shape_error_event.rs

@@ -0,1 +0,102 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* JsonSerializerGenerator.kt:215 */
           3  +
pub fn ser_error_event_error(
           4  +
    value: &crate::error::ErrorEvent,
           5  +
) -> ::std::result::Result<String, ::aws_smithy_types::error::operation::SerializationError> {
           6  +
    /* JsonSerializerGenerator.kt:220 */
           7  +
    let mut out = ::std::string::String::new();
           8  +
    let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
           9  +
    /* JsonSerializerGenerator.kt:377 */
          10  +
    crate::protocol_serde::shape_error_event::ser_error_event(&mut object, value)?;
          11  +
    /* JsonSerializerGenerator.kt:229 */
          12  +
    object.finish();
          13  +
    Ok(out)
          14  +
    /* JsonSerializerGenerator.kt:215 */
          15  +
}
          16  +
          17  +
/* JsonSerializerGenerator.kt:360 */
          18  +
pub fn ser_error_event(
          19  +
    object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
          20  +
    input: &crate::error::ErrorEvent,
          21  +
) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
          22  +
    /* JsonSerializerGenerator.kt:384 */
          23  +
    if let Some(var_1) = &input.message {
          24  +
        /* JsonSerializerGenerator.kt:425 */
          25  +
        object.key("message").string(var_1.as_str());
          26  +
        /* JsonSerializerGenerator.kt:384 */
          27  +
    }
          28  +
    /* JsonSerializerGenerator.kt:374 */
          29  +
    Ok(())
          30  +
    /* JsonSerializerGenerator.kt:360 */
          31  +
}
          32  +
          33  +
/* JsonParserGenerator.kt:151 */
          34  +
pub(crate) fn de_error_event_json_err(
          35  +
    _value: &[u8],
          36  +
    mut builder: crate::error::error_event::Builder,
          37  +
) -> ::std::result::Result<
          38  +
    crate::error::error_event::Builder,
          39  +
    ::aws_smithy_json::deserialize::error::DeserializeError,
          40  +
> {
          41  +
    /* JsonParserGenerator.kt:158 */
          42  +
    let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(
          43  +
        crate::protocol_serde::or_empty_doc(_value),
          44  +
    )
          45  +
    .peekable();
          46  +
    let tokens = &mut tokens_owned;
          47  +
    ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
          48  +
    /* JsonParserGenerator.kt:721 */
          49  +
    loop {
          50  +
        /* JsonParserGenerator.kt:722 */
          51  +
        match tokens.next().transpose()? {
          52  +
            /* JsonParserGenerator.kt:723 */
          53  +
            Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
          54  +
            Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
          55  +
                /* JsonParserGenerator.kt:265 */
          56  +
                match key.to_unescaped()?.as_ref() {
          57  +
                    /* JsonParserGenerator.kt:267 */
          58  +
                    "message" => {
          59  +
                        /* JsonParserGenerator.kt:277 */
          60  +
                        builder = builder.set_message(
          61  +
                            /* JsonParserGenerator.kt:361 */
          62  +
                            ::aws_smithy_json::deserialize::token::expect_string_or_null(
          63  +
                                tokens.next(),
          64  +
                            )?
          65  +
                            .map(|s|
          66  +
                                /* JsonParserGenerator.kt:346 */s.to_unescaped().map(|u|
          67  +
                                    /* JsonParserGenerator.kt:355 */u.into_owned()
          68  +
                                /* JsonParserGenerator.kt:346 */) /* JsonParserGenerator.kt:361 */)
          69  +
                            .transpose()?, /* JsonParserGenerator.kt:277 */
          70  +
                        );
          71  +
                        /* JsonParserGenerator.kt:267 */
          72  +
                    }
          73  +
                    /* JsonParserGenerator.kt:295 */
          74  +
                    _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?, /* JsonParserGenerator.kt:265 */
          75  +
                }
          76  +
                /* JsonParserGenerator.kt:723 */
          77  +
            }
          78  +
            /* JsonParserGenerator.kt:732 */
          79  +
            other => {
          80  +
                return Err(
          81  +
                    ::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
          82  +
                        "expected object key or end object, found: {other:?}"
          83  +
                    )),
          84  +
                )
          85  +
            } /* JsonParserGenerator.kt:722 */
          86  +
        }
          87  +
        /* JsonParserGenerator.kt:721 */
          88  +
    }
          89  +
    /* JsonParserGenerator.kt:255 */
          90  +
    if tokens.next().is_some() {
          91  +
        /* JsonParserGenerator.kt:256 */
          92  +
        return Err(
          93  +
            ::aws_smithy_json::deserialize::error::DeserializeError::custom(
          94  +
                "found more JSON tokens after completing parsing",
          95  +
            ),
          96  +
        );
          97  +
        /* JsonParserGenerator.kt:255 */
          98  +
    }
          99  +
    /* JsonParserGenerator.kt:168 */
         100  +
    Ok(builder)
         101  +
    /* JsonParserGenerator.kt:151 */
         102  +
}

tmp-codegen-diff/codegen-server-test/rest_json/rust-server-codegen/src/protocol_serde/shape_headers_and_explicit_payload_event.rs

@@ -0,1 +0,20 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* JsonSerializerGenerator.kt:242 */
           3  +
pub fn ser_payload_payload(
           4  +
    input: &crate::model::PayloadStructure,
           5  +
) -> std::result::Result<
           6  +
    ::std::vec::Vec<u8>,
           7  +
    ::aws_smithy_types::error::operation::SerializationError,
           8  +
> {
           9  +
    /* JsonSerializerGenerator.kt:247 */
          10  +
    let mut out = String::new();
          11  +
    /* JsonSerializerGenerator.kt:248 */
          12  +
    let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
          13  +
    /* JsonSerializerGenerator.kt:377 */
          14  +
    crate::protocol_serde::shape_payload_structure::ser_payload_structure(&mut object, input)?;
          15  +
    /* JsonSerializerGenerator.kt:254 */
          16  +
    object.finish();
          17  +
    /* JsonSerializerGenerator.kt:255 */
          18  +
    Ok(out.into_bytes())
          19  +
    /* JsonSerializerGenerator.kt:242 */
          20  +
}

tmp-codegen-diff/codegen-server-test/rest_json/rust-server-codegen/src/protocol_serde/shape_headers_and_implicit_payload_event.rs

@@ -0,1 +0,87 @@
           1  +
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* JsonParserGenerator.kt:151 */
           3  +
pub(crate) fn de_headers_and_implicit_payload_event_json_err(
           4  +
    _value: &[u8],
           5  +
    mut builder: crate::model::headers_and_implicit_payload_event::Builder,
           6  +
) -> ::std::result::Result<
           7  +
    crate::model::headers_and_implicit_payload_event::Builder,
           8  +
    ::aws_smithy_json::deserialize::error::DeserializeError,
           9  +
> {
          10  +
    /* JsonParserGenerator.kt:158 */
          11  +
    let mut tokens_owned = ::aws_smithy_json::deserialize::json_token_iter(
          12  +
        crate::protocol_serde::or_empty_doc(_value),
          13  +
    )
          14  +
    .peekable();
          15  +
    let tokens = &mut tokens_owned;
          16  +
    ::aws_smithy_json::deserialize::token::expect_start_object(tokens.next())?;
          17  +
    /* JsonParserGenerator.kt:721 */
          18  +
    loop {
          19  +
        /* JsonParserGenerator.kt:722 */
          20  +
        match tokens.next().transpose()? {
          21  +
            /* JsonParserGenerator.kt:723 */
          22  +
            Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
          23  +
            Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
          24  +
                /* JsonParserGenerator.kt:265 */
          25  +
                match key.to_unescaped()?.as_ref() {
          26  +
                    /* JsonParserGenerator.kt:267 */
          27  +
                    "header" => {
          28  +
                        /* JsonParserGenerator.kt:277 */
          29  +
                        builder = builder.set_header(
          30  +
                            /* JsonParserGenerator.kt:361 */
          31  +
                            ::aws_smithy_json::deserialize::token::expect_string_or_null(
          32  +
                                tokens.next(),
          33  +
                            )?
          34  +
                            .map(|s|
          35  +
                                /* JsonParserGenerator.kt:346 */s.to_unescaped().map(|u|
          36  +
                                    /* JsonParserGenerator.kt:355 */u.into_owned()
          37  +
                                /* JsonParserGenerator.kt:346 */) /* JsonParserGenerator.kt:361 */)
          38  +
                            .transpose()?, /* JsonParserGenerator.kt:277 */
          39  +
                        );
          40  +
                        /* JsonParserGenerator.kt:267 */
          41  +
                    }
          42  +
                    /* JsonParserGenerator.kt:267 */
          43  +
                    "payload" => {
          44  +
                        /* JsonParserGenerator.kt:277 */
          45  +
                        builder = builder.set_payload(
          46  +
                            /* JsonParserGenerator.kt:361 */
          47  +
                            ::aws_smithy_json::deserialize::token::expect_string_or_null(
          48  +
                                tokens.next(),
          49  +
                            )?
          50  +
                            .map(|s|
          51  +
                                /* JsonParserGenerator.kt:346 */s.to_unescaped().map(|u|
          52  +
                                    /* JsonParserGenerator.kt:355 */u.into_owned()
          53  +
                                /* JsonParserGenerator.kt:346 */) /* JsonParserGenerator.kt:361 */)
          54  +
                            .transpose()?, /* JsonParserGenerator.kt:277 */
          55  +
                        );
          56  +
                        /* JsonParserGenerator.kt:267 */
          57  +
                    }
          58  +
                    /* JsonParserGenerator.kt:295 */
          59  +
                    _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?, /* JsonParserGenerator.kt:265 */
          60  +
                }
          61  +
                /* JsonParserGenerator.kt:723 */
          62  +
            }
          63  +
            /* JsonParserGenerator.kt:732 */
          64  +
            other => {
          65  +
                return Err(
          66  +
                    ::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
          67  +
                        "expected object key or end object, found: {other:?}"
          68  +
                    )),
          69  +
                )
          70  +
            } /* JsonParserGenerator.kt:722 */
          71  +
        }
          72  +
        /* JsonParserGenerator.kt:721 */
          73  +
    }
          74  +
    /* JsonParserGenerator.kt:255 */
          75  +
    if tokens.next().is_some() {
          76  +
        /* JsonParserGenerator.kt:256 */
          77  +
        return Err(
          78  +
            ::aws_smithy_json::deserialize::error::DeserializeError::custom(
          79  +
                "found more JSON tokens after completing parsing",
          80  +
            ),
          81  +
        );
          82  +
        /* JsonParserGenerator.kt:255 */
          83  +
    }
          84  +
    /* JsonParserGenerator.kt:168 */
          85  +
    Ok(builder)
          86  +
    /* JsonParserGenerator.kt:151 */
          87  +
}