fn unmarshall()

in crates/amzn-codewhisperer-streaming-client/src/event_stream_serde.rs [15:100]
86 lines of code
2 McCabe index (conditional complexity)

    fn unmarshall(
        &self,
        message: &::aws_smithy_types::event_stream::Message,
    ) -> std::result::Result<
        ::aws_smithy_eventstream::frame::UnmarshalledMessage<Self::Output, Self::Error>,
        ::aws_smithy_eventstream::error::Error,
    > {
        let response_headers = ::aws_smithy_eventstream::smithy::parse_response_headers(message)?;
        match response_headers.message_type.as_str() {
            "event" => match response_headers.smithy_type.as_str() {
                "binaryMetadataEvent" => {
                    let parsed = crate::protocol_serde::shape_binary_metadata_event::de_binary_metadata_event_payload(
                        &message.payload()[..],
                    )
                    .map_err(|err| {
                        ::aws_smithy_eventstream::error::Error::unmarshalling(format!(
                            "failed to unmarshall BinaryMetadataEvent: {}",
                            err
                        ))
                    })?;
                    Ok(::aws_smithy_eventstream::frame::UnmarshalledMessage::Event(
                        crate::types::ResultArchiveStream::BinaryMetadataEvent(parsed),
                    ))
                },
                "binaryPayloadEvent" => {
                    let parsed = crate::protocol_serde::shape_binary_payload_event::de_binary_payload_event_payload(
                        &message.payload()[..],
                    )
                    .map_err(|err| {
                        ::aws_smithy_eventstream::error::Error::unmarshalling(format!(
                            "failed to unmarshall BinaryPayloadEvent: {}",
                            err
                        ))
                    })?;
                    Ok(::aws_smithy_eventstream::frame::UnmarshalledMessage::Event(
                        crate::types::ResultArchiveStream::BinaryPayloadEvent(parsed),
                    ))
                },
                _unknown_variant => Ok(::aws_smithy_eventstream::frame::UnmarshalledMessage::Event(
                    crate::types::ResultArchiveStream::Unknown,
                )),
            },
            "exception" => {
                let generic = match crate::protocol_serde::parse_event_stream_error_metadata(message.payload()) {
                    Ok(builder) => builder.build(),
                    Err(err) => {
                        return Ok(::aws_smithy_eventstream::frame::UnmarshalledMessage::Error(
                            crate::types::error::ResultArchiveStreamError::unhandled(err),
                        ));
                    },
                };
                if response_headers.smithy_type.as_str() == "internalServerException" {
                    let mut builder = crate::types::error::builders::InternalServerErrorBuilder::default();
                    builder = crate::protocol_serde::shape_internal_server_error::de_internal_server_error_json_err(
                        &message.payload()[..],
                        builder,
                    )
                    .map_err(|err| {
                        ::aws_smithy_eventstream::error::Error::unmarshalling(format!(
                            "failed to unmarshall internalServerException: {}",
                            err
                        ))
                    })?;
                    builder.set_meta(Some(generic));
                    return Ok(::aws_smithy_eventstream::frame::UnmarshalledMessage::Error(
                        crate::types::error::ResultArchiveStreamError::InternalServerError(
                            crate::serde_util::internal_server_error_correct_errors(builder)
                                .build()
                                .map_err(|err| {
                                    ::aws_smithy_eventstream::error::Error::unmarshalling(format!("{}", err))
                                })?,
                        ),
                    ));
                }
                Ok(::aws_smithy_eventstream::frame::UnmarshalledMessage::Error(
                    crate::types::error::ResultArchiveStreamError::generic(generic),
                ))
            },
            value => {
                return Err(::aws_smithy_eventstream::error::Error::unmarshalling(format!(
                    "unrecognized :message-type: {}",
                    value
                )));
            },
        }
    }