Skip to content

Commit 3902588

Browse files
committed
fmt+fix feature flag
1 parent a5e76e6 commit 3902588

4 files changed

Lines changed: 21 additions & 39 deletions

File tree

lambda-events/examples/comprehensive-builders.rs

Lines changed: 7 additions & 28 deletions
Original file line numberDiff line numberDiff line change
@@ -1,46 +1,26 @@
11
// Example demonstrating builder pattern usage for AWS Lambda events
22
#[cfg(feature = "builders")]
33
use aws_lambda_events::event::{
4-
dynamodb::EventBuilder as DynamoDbEventBuilder,
5-
kinesis::KinesisEventBuilder,
6-
s3::S3EventBuilder,
7-
secretsmanager::SecretsManagerSecretRotationEventBuilder,
8-
sns::SnsEventBuilder,
9-
sqs::SqsEventBuilder,
4+
dynamodb::EventBuilder as DynamoDbEventBuilder, kinesis::KinesisEventBuilder, s3::S3EventBuilder,
5+
secretsmanager::SecretsManagerSecretRotationEventBuilder, sns::SnsEventBuilder, sqs::SqsEventBuilder,
106
};
117

128
#[cfg(feature = "builders")]
139
fn main() {
14-
1510
// S3 Event - Object storage notifications
16-
let s3_event = S3EventBuilder::default()
17-
.records(vec![])
18-
.build()
19-
.unwrap();
11+
let s3_event = S3EventBuilder::default().records(vec![]).build().unwrap();
2012

2113
// Kinesis Event - Stream processing
22-
let kinesis_event = KinesisEventBuilder::default()
23-
.records(vec![])
24-
.build()
25-
.unwrap();
14+
let kinesis_event = KinesisEventBuilder::default().records(vec![]).build().unwrap();
2615

2716
// DynamoDB Event - Database change streams
28-
let dynamodb_event = DynamoDbEventBuilder::default()
29-
.records(vec![])
30-
.build()
31-
.unwrap();
17+
let dynamodb_event = DynamoDbEventBuilder::default().records(vec![]).build().unwrap();
3218

3319
// SNS Event - Pub/sub messaging
34-
let sns_event = SnsEventBuilder::default()
35-
.records(vec![])
36-
.build()
37-
.unwrap();
20+
let sns_event = SnsEventBuilder::default().records(vec![]).build().unwrap();
3821

3922
// SQS Event - Queue messaging
40-
let sqs_event = SqsEventBuilder::default()
41-
.records(vec![])
42-
.build()
43-
.unwrap();
23+
let sqs_event = SqsEventBuilder::default().records(vec![]).build().unwrap();
4424

4525
// Secrets Manager Event - Secret rotation
4626
let secrets_event = SecretsManagerSecretRotationEventBuilder::default()
@@ -49,7 +29,6 @@ fn main() {
4929
.client_request_token("token-123")
5030
.build()
5131
.unwrap();
52-
5332
}
5433

5534
#[cfg(not(feature = "builders"))]

lambda-events/examples/lambda-runtime-authorizer-builder.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -33,8 +33,7 @@
3333

3434
#[cfg(feature = "builders")]
3535
use aws_lambda_events::event::apigw::{
36-
ApiGatewayV2CustomAuthorizerSimpleResponse,
37-
ApiGatewayV2CustomAuthorizerSimpleResponseBuilder,
36+
ApiGatewayV2CustomAuthorizerSimpleResponse, ApiGatewayV2CustomAuthorizerSimpleResponseBuilder,
3837
ApiGatewayV2CustomAuthorizerV2Request,
3938
};
4039
#[cfg(feature = "builders")]

lambda-events/examples/lambda-runtime-sqs-batch-builder.rs

Lines changed: 12 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -60,22 +60,22 @@ async fn process_record(record: &aws_lambda_events::event::sqs::SqsMessage) -> R
6060
#[allow(dead_code)]
6161
async fn function_handler_old_way(event: LambdaEvent<SqsEvent>) -> Result<SqsBatchResponse, Error> {
6262
let mut batch_item_failures = Vec::new();
63-
63+
6464
for record in event.payload.records {
6565
match process_record(&record).await {
6666
Ok(_) => (),
6767
Err(_) => {
6868
let mut item = BatchItemFailure::default();
6969
item.item_identifier = record.message_id.unwrap();
70-
70+
7171
batch_item_failures.push(item)
7272
}
7373
}
7474
}
75-
75+
7676
let mut response = SqsBatchResponse::default();
7777
response.batch_item_failures = batch_item_failures;
78-
78+
7979
Ok(response)
8080
}
8181

@@ -84,7 +84,7 @@ async fn function_handler_old_way(event: LambdaEvent<SqsEvent>) -> Result<SqsBat
8484
#[allow(dead_code)]
8585
async fn function_handler(event: LambdaEvent<SqsEvent>) -> Result<SqsBatchResponse, Error> {
8686
let mut batch_item_failures = Vec::new();
87-
87+
8888
for record in event.payload.records {
8989
match process_record(&record).await {
9090
Ok(_) => (),
@@ -94,18 +94,18 @@ async fn function_handler(event: LambdaEvent<SqsEvent>) -> Result<SqsBatchRespon
9494
.item_identifier(record.message_id.unwrap())
9595
.build()
9696
.unwrap();
97-
97+
9898
batch_item_failures.push(item)
9999
}
100100
}
101101
}
102-
102+
103103
// ✅ Clean response construction with builder
104104
let response = SqsBatchResponseBuilder::default()
105105
.batch_item_failures(batch_item_failures)
106106
.build()
107107
.map_err(|e| format!("Failed to build response: {}", e))?;
108-
108+
109109
Ok(response)
110110
}
111111

@@ -128,7 +128,10 @@ fn main() {
128128
.build()
129129
.unwrap();
130130

131-
println!("✅ Built SQS batch response with {} failed items", response.batch_item_failures.len());
131+
println!(
132+
"✅ Built SQS batch response with {} failed items",
133+
response.batch_item_failures.len()
134+
);
132135
for failure in &response.batch_item_failures {
133136
println!(" Failed message: {}", failure.item_identifier);
134137
}

lambda-events/src/event/cloudwatch_events/tag.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
1+
#[cfg(feature = "builders")]
12
use derive_builder::Builder;
23
#[cfg(feature = "catch-all-fields")]
34
use serde_json::Value;

0 commit comments

Comments
 (0)