pub(crate) fn de_history_event<'a, I>(
tokens: &mut ::std::iter::Peekable<I>,
_value: &'a [u8],
) -> ::std::result::Result<Option<crate::types::HistoryEvent>, ::aws_smithy_json::deserialize::error::DeserializeError>
where
I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
{
match tokens.next().transpose()? {
Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::types::builders::HistoryEventBuilder::default();
loop {
match tokens.next().transpose()? {
Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"eventTimestamp" => {
builder = builder.set_event_timestamp(::aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
::aws_smithy_types::date_time::Format::EpochSeconds,
)?);
}
"eventType" => {
builder = builder.set_event_type(
::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
.map(|s| s.to_unescaped().map(|u| crate::types::EventType::from(u.as_ref())))
.transpose()?,
);
}
"eventId" => {
builder = builder.set_event_id(
::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
.map(i64::try_from)
.transpose()?,
);
}
"workflowExecutionStartedEventAttributes" => {
builder = builder.set_workflow_execution_started_event_attributes(
crate::protocol_serde::shape_workflow_execution_started_event_attributes::de_workflow_execution_started_event_attributes(tokens, _value)?
);
}
"workflowExecutionCompletedEventAttributes" => {
builder = builder.set_workflow_execution_completed_event_attributes(
crate::protocol_serde::shape_workflow_execution_completed_event_attributes::de_workflow_execution_completed_event_attributes(tokens, _value)?
);
}
"completeWorkflowExecutionFailedEventAttributes" => {
builder = builder.set_complete_workflow_execution_failed_event_attributes(
crate::protocol_serde::shape_complete_workflow_execution_failed_event_attributes::de_complete_workflow_execution_failed_event_attributes(tokens, _value)?
);
}
"workflowExecutionFailedEventAttributes" => {
builder = builder.set_workflow_execution_failed_event_attributes(
crate::protocol_serde::shape_workflow_execution_failed_event_attributes::de_workflow_execution_failed_event_attributes(tokens, _value)?
);
}
"failWorkflowExecutionFailedEventAttributes" => {
builder = builder.set_fail_workflow_execution_failed_event_attributes(
crate::protocol_serde::shape_fail_workflow_execution_failed_event_attributes::de_fail_workflow_execution_failed_event_attributes(tokens, _value)?
);
}
"workflowExecutionTimedOutEventAttributes" => {
builder = builder.set_workflow_execution_timed_out_event_attributes(
crate::protocol_serde::shape_workflow_execution_timed_out_event_attributes::de_workflow_execution_timed_out_event_attributes(tokens, _value)?
);
}
"workflowExecutionCanceledEventAttributes" => {
builder = builder.set_workflow_execution_canceled_event_attributes(
crate::protocol_serde::shape_workflow_execution_canceled_event_attributes::de_workflow_execution_canceled_event_attributes(tokens, _value)?
);
}
"cancelWorkflowExecutionFailedEventAttributes" => {
builder = builder.set_cancel_workflow_execution_failed_event_attributes(
crate::protocol_serde::shape_cancel_workflow_execution_failed_event_attributes::de_cancel_workflow_execution_failed_event_attributes(tokens, _value)?
);
}
"workflowExecutionContinuedAsNewEventAttributes" => {
builder = builder.set_workflow_execution_continued_as_new_event_attributes(
crate::protocol_serde::shape_workflow_execution_continued_as_new_event_attributes::de_workflow_execution_continued_as_new_event_attributes(tokens, _value)?
);
}
"continueAsNewWorkflowExecutionFailedEventAttributes" => {
builder = builder.set_continue_as_new_workflow_execution_failed_event_attributes(
crate::protocol_serde::shape_continue_as_new_workflow_execution_failed_event_attributes::de_continue_as_new_workflow_execution_failed_event_attributes(tokens, _value)?
);
}
"workflowExecutionTerminatedEventAttributes" => {
builder = builder.set_workflow_execution_terminated_event_attributes(
crate::protocol_serde::shape_workflow_execution_terminated_event_attributes::de_workflow_execution_terminated_event_attributes(tokens, _value)?
);
}
"workflowExecutionCancelRequestedEventAttributes" => {
builder = builder.set_workflow_execution_cancel_requested_event_attributes(
crate::protocol_serde::shape_workflow_execution_cancel_requested_event_attributes::de_workflow_execution_cancel_requested_event_attributes(tokens, _value)?
);
}
"decisionTaskScheduledEventAttributes" => {
builder = builder.set_decision_task_scheduled_event_attributes(
crate::protocol_serde::shape_decision_task_scheduled_event_attributes::de_decision_task_scheduled_event_attributes(tokens, _value)?
);
}
"decisionTaskStartedEventAttributes" => {
builder = builder.set_decision_task_started_event_attributes(
crate::protocol_serde::shape_decision_task_started_event_attributes::de_decision_task_started_event_attributes(
tokens, _value,
)?,
);
}
"decisionTaskCompletedEventAttributes" => {
builder = builder.set_decision_task_completed_event_attributes(
crate::protocol_serde::shape_decision_task_completed_event_attributes::de_decision_task_completed_event_attributes(tokens, _value)?
);
}
"decisionTaskTimedOutEventAttributes" => {
builder = builder.set_decision_task_timed_out_event_attributes(
crate::protocol_serde::shape_decision_task_timed_out_event_attributes::de_decision_task_timed_out_event_attributes(tokens, _value)?
);
}
"activityTaskScheduledEventAttributes" => {
builder = builder.set_activity_task_scheduled_event_attributes(
crate::protocol_serde::shape_activity_task_scheduled_event_attributes::de_activity_task_scheduled_event_attributes(tokens, _value)?
);
}
"activityTaskStartedEventAttributes" => {
builder = builder.set_activity_task_started_event_attributes(
crate::protocol_serde::shape_activity_task_started_event_attributes::de_activity_task_started_event_attributes(
tokens, _value,
)?,
);
}
"activityTaskCompletedEventAttributes" => {
builder = builder.set_activity_task_completed_event_attributes(
crate::protocol_serde::shape_activity_task_completed_event_attributes::de_activity_task_completed_event_attributes(tokens, _value)?
);
}
"activityTaskFailedEventAttributes" => {
builder = builder.set_activity_task_failed_event_attributes(
crate::protocol_serde::shape_activity_task_failed_event_attributes::de_activity_task_failed_event_attributes(
tokens, _value,
)?,
);
}
"activityTaskTimedOutEventAttributes" => {
builder = builder.set_activity_task_timed_out_event_attributes(
crate::protocol_serde::shape_activity_task_timed_out_event_attributes::de_activity_task_timed_out_event_attributes(tokens, _value)?
);
}
"activityTaskCanceledEventAttributes" => {
builder = builder.set_activity_task_canceled_event_attributes(
crate::protocol_serde::shape_activity_task_canceled_event_attributes::de_activity_task_canceled_event_attributes(
tokens, _value,
)?,
);
}
"activityTaskCancelRequestedEventAttributes" => {
builder = builder.set_activity_task_cancel_requested_event_attributes(
crate::protocol_serde::shape_activity_task_cancel_requested_event_attributes::de_activity_task_cancel_requested_event_attributes(tokens, _value)?
);
}
"workflowExecutionSignaledEventAttributes" => {
builder = builder.set_workflow_execution_signaled_event_attributes(
crate::protocol_serde::shape_workflow_execution_signaled_event_attributes::de_workflow_execution_signaled_event_attributes(tokens, _value)?
);
}
"markerRecordedEventAttributes" => {
builder = builder.set_marker_recorded_event_attributes(
crate::protocol_serde::shape_marker_recorded_event_attributes::de_marker_recorded_event_attributes(
tokens, _value,
)?,
);
}
"recordMarkerFailedEventAttributes" => {
builder = builder.set_record_marker_failed_event_attributes(
crate::protocol_serde::shape_record_marker_failed_event_attributes::de_record_marker_failed_event_attributes(
tokens, _value,
)?,
);
}
"timerStartedEventAttributes" => {
builder = builder.set_timer_started_event_attributes(
crate::protocol_serde::shape_timer_started_event_attributes::de_timer_started_event_attributes(tokens, _value)?,
);
}
"timerFiredEventAttributes" => {
builder = builder.set_timer_fired_event_attributes(
crate::protocol_serde::shape_timer_fired_event_attributes::de_timer_fired_event_attributes(tokens, _value)?,
);
}
"timerCanceledEventAttributes" => {
builder = builder.set_timer_canceled_event_attributes(
crate::protocol_serde::shape_timer_canceled_event_attributes::de_timer_canceled_event_attributes(tokens, _value)?,
);
}
"startChildWorkflowExecutionInitiatedEventAttributes" => {
builder = builder.set_start_child_workflow_execution_initiated_event_attributes(
crate::protocol_serde::shape_start_child_workflow_execution_initiated_event_attributes::de_start_child_workflow_execution_initiated_event_attributes(tokens, _value)?
);
}
"childWorkflowExecutionStartedEventAttributes" => {
builder = builder.set_child_workflow_execution_started_event_attributes(
crate::protocol_serde::shape_child_workflow_execution_started_event_attributes::de_child_workflow_execution_started_event_attributes(tokens, _value)?
);
}
"childWorkflowExecutionCompletedEventAttributes" => {
builder = builder.set_child_workflow_execution_completed_event_attributes(
crate::protocol_serde::shape_child_workflow_execution_completed_event_attributes::de_child_workflow_execution_completed_event_attributes(tokens, _value)?
);
}
"childWorkflowExecutionFailedEventAttributes" => {
builder = builder.set_child_workflow_execution_failed_event_attributes(
crate::protocol_serde::shape_child_workflow_execution_failed_event_attributes::de_child_workflow_execution_failed_event_attributes(tokens, _value)?
);
}
"childWorkflowExecutionTimedOutEventAttributes" => {
builder = builder.set_child_workflow_execution_timed_out_event_attributes(
crate::protocol_serde::shape_child_workflow_execution_timed_out_event_attributes::de_child_workflow_execution_timed_out_event_attributes(tokens, _value)?
);
}
"childWorkflowExecutionCanceledEventAttributes" => {
builder = builder.set_child_workflow_execution_canceled_event_attributes(
crate::protocol_serde::shape_child_workflow_execution_canceled_event_attributes::de_child_workflow_execution_canceled_event_attributes(tokens, _value)?
);
}
"childWorkflowExecutionTerminatedEventAttributes" => {
builder = builder.set_child_workflow_execution_terminated_event_attributes(
crate::protocol_serde::shape_child_workflow_execution_terminated_event_attributes::de_child_workflow_execution_terminated_event_attributes(tokens, _value)?
);
}
"signalExternalWorkflowExecutionInitiatedEventAttributes" => {
builder = builder.set_signal_external_workflow_execution_initiated_event_attributes(
crate::protocol_serde::shape_signal_external_workflow_execution_initiated_event_attributes::de_signal_external_workflow_execution_initiated_event_attributes(tokens, _value)?
);
}
"externalWorkflowExecutionSignaledEventAttributes" => {
builder = builder.set_external_workflow_execution_signaled_event_attributes(
crate::protocol_serde::shape_external_workflow_execution_signaled_event_attributes::de_external_workflow_execution_signaled_event_attributes(tokens, _value)?
);
}
"signalExternalWorkflowExecutionFailedEventAttributes" => {
builder = builder.set_signal_external_workflow_execution_failed_event_attributes(
crate::protocol_serde::shape_signal_external_workflow_execution_failed_event_attributes::de_signal_external_workflow_execution_failed_event_attributes(tokens, _value)?
);
}
"externalWorkflowExecutionCancelRequestedEventAttributes" => {
builder = builder.set_external_workflow_execution_cancel_requested_event_attributes(
crate::protocol_serde::shape_external_workflow_execution_cancel_requested_event_attributes::de_external_workflow_execution_cancel_requested_event_attributes(tokens, _value)?
);
}
"requestCancelExternalWorkflowExecutionInitiatedEventAttributes" => {
builder = builder.set_request_cancel_external_workflow_execution_initiated_event_attributes(
crate::protocol_serde::shape_request_cancel_external_workflow_execution_initiated_event_attributes::de_request_cancel_external_workflow_execution_initiated_event_attributes(tokens, _value)?
);
}
"requestCancelExternalWorkflowExecutionFailedEventAttributes" => {
builder = builder.set_request_cancel_external_workflow_execution_failed_event_attributes(
crate::protocol_serde::shape_request_cancel_external_workflow_execution_failed_event_attributes::de_request_cancel_external_workflow_execution_failed_event_attributes(tokens, _value)?
);
}
"scheduleActivityTaskFailedEventAttributes" => {
builder = builder.set_schedule_activity_task_failed_event_attributes(
crate::protocol_serde::shape_schedule_activity_task_failed_event_attributes::de_schedule_activity_task_failed_event_attributes(tokens, _value)?
);
}
"requestCancelActivityTaskFailedEventAttributes" => {
builder = builder.set_request_cancel_activity_task_failed_event_attributes(
crate::protocol_serde::shape_request_cancel_activity_task_failed_event_attributes::de_request_cancel_activity_task_failed_event_attributes(tokens, _value)?
);
}
"startTimerFailedEventAttributes" => {
builder = builder.set_start_timer_failed_event_attributes(
crate::protocol_serde::shape_start_timer_failed_event_attributes::de_start_timer_failed_event_attributes(
tokens, _value,
)?,
);
}
"cancelTimerFailedEventAttributes" => {
builder = builder.set_cancel_timer_failed_event_attributes(
crate::protocol_serde::shape_cancel_timer_failed_event_attributes::de_cancel_timer_failed_event_attributes(
tokens, _value,
)?,
);
}
"startChildWorkflowExecutionFailedEventAttributes" => {
builder = builder.set_start_child_workflow_execution_failed_event_attributes(
crate::protocol_serde::shape_start_child_workflow_execution_failed_event_attributes::de_start_child_workflow_execution_failed_event_attributes(tokens, _value)?
);
}
"lambdaFunctionScheduledEventAttributes" => {
builder = builder.set_lambda_function_scheduled_event_attributes(
crate::protocol_serde::shape_lambda_function_scheduled_event_attributes::de_lambda_function_scheduled_event_attributes(tokens, _value)?
);
}
"lambdaFunctionStartedEventAttributes" => {
builder = builder.set_lambda_function_started_event_attributes(
crate::protocol_serde::shape_lambda_function_started_event_attributes::de_lambda_function_started_event_attributes(tokens, _value)?
);
}
"lambdaFunctionCompletedEventAttributes" => {
builder = builder.set_lambda_function_completed_event_attributes(
crate::protocol_serde::shape_lambda_function_completed_event_attributes::de_lambda_function_completed_event_attributes(tokens, _value)?
);
}
"lambdaFunctionFailedEventAttributes" => {
builder = builder.set_lambda_function_failed_event_attributes(
crate::protocol_serde::shape_lambda_function_failed_event_attributes::de_lambda_function_failed_event_attributes(
tokens, _value,
)?,
);
}
"lambdaFunctionTimedOutEventAttributes" => {
builder = builder.set_lambda_function_timed_out_event_attributes(
crate::protocol_serde::shape_lambda_function_timed_out_event_attributes::de_lambda_function_timed_out_event_attributes(tokens, _value)?
);
}
"scheduleLambdaFunctionFailedEventAttributes" => {
builder = builder.set_schedule_lambda_function_failed_event_attributes(
crate::protocol_serde::shape_schedule_lambda_function_failed_event_attributes::de_schedule_lambda_function_failed_event_attributes(tokens, _value)?
);
}
"startLambdaFunctionFailedEventAttributes" => {
builder = builder.set_start_lambda_function_failed_event_attributes(
crate::protocol_serde::shape_start_lambda_function_failed_event_attributes::de_start_lambda_function_failed_event_attributes(tokens, _value)?
);
}
_ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {other:?}"
)))
}
}
}
Ok(Some(crate::serde_util::history_event_correct_errors(builder).build().map_err(|err| {
::aws_smithy_json::deserialize::error::DeserializeError::custom_source("Response was invalid", err)
})?))
}
_ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
)),
}
}