Skip to content

Commit bbd6773

Browse files
committed
fix: update examples to work with bon builders
- Remove unused Builder imports - Remove .unwrap() and .map_err() calls (bon doesn't return Results) - Handle catch-all-fields feature in comprehensive example - Prefix unused variables with underscore
1 parent 610b520 commit bbd6773

3 files changed

Lines changed: 23 additions & 23 deletions

File tree

lambda-events/examples/comprehensive-builders.rs

Lines changed: 13 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -8,22 +8,29 @@ use aws_lambda_events::event::{
88
#[cfg(feature = "builders")]
99
fn main() {
1010
// S3 Event - Object storage notifications
11-
let s3_event = S3Event::builder().records(vec![]).build();
11+
let _s3_event = S3Event::builder().records(vec![]).build();
1212

1313
// Kinesis Event - Stream processing
14-
let kinesis_event = KinesisEvent::builder().records(vec![]).build();
14+
let _kinesis_event = KinesisEvent::builder().records(vec![]).build();
1515

1616
// DynamoDB Event - Database change streams
17-
let dynamodb_event = DynamoDbEvent::builder().records(vec![]).build();
17+
let _dynamodb_event = DynamoDbEvent::builder().records(vec![]).build();
1818

1919
// SNS Event - Pub/sub messaging
20-
let sns_event = SnsEvent::builder().records(vec![]).build();
20+
let _sns_event = SnsEvent::builder().records(vec![]).build();
2121

2222
// SQS Event - Queue messaging
23-
let sqs_event = SqsEvent::builder().records(vec![]).build();
23+
#[cfg(feature = "catch-all-fields")]
24+
let _sqs_event = SqsEvent::builder()
25+
.records(vec![])
26+
.other(serde_json::Map::new())
27+
.build();
28+
29+
#[cfg(not(feature = "catch-all-fields"))]
30+
let _sqs_event = SqsEvent::builder().records(vec![]).build();
2431

2532
// Secrets Manager Event - Secret rotation
26-
let secrets_event = SecretsManagerSecretRotationEvent::builder()
33+
let _secrets_event = SecretsManagerSecretRotationEvent::builder()
2734
.step("createSecret".to_string())
2835
.secret_id("test-secret".to_string())
2936
.client_request_token("token-123".to_string())

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

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@
3333

3434
#[cfg(feature = "builders")]
3535
use aws_lambda_events::event::apigw::{
36-
ApiGatewayV2CustomAuthorizerSimpleResponse, ApiGatewayV2CustomAuthorizerSimpleResponseBuilder,
36+
ApiGatewayV2CustomAuthorizerSimpleResponse,
3737
ApiGatewayV2CustomAuthorizerV2Request,
3838
};
3939
#[cfg(feature = "builders")]
@@ -108,8 +108,7 @@ pub async fn function_handler(
108108
let output = ApiGatewayV2CustomAuthorizerSimpleResponse::builder()
109109
.is_authorized(true)
110110
.context(context)
111-
.build()
112-
.map_err(|e| format!("Failed to build response: {}", e))?;
111+
.build();
113112

114113
Ok(output)
115114
}
@@ -126,11 +125,10 @@ fn main() {
126125
permissions: vec!["read".to_string(), "write".to_string()],
127126
};
128127

129-
let response = ApiGatewayV2CustomAuthorizerSimpleResponseBuilder::<MyContext>::default()
128+
let response = ApiGatewayV2CustomAuthorizerSimpleResponse::<MyContext>::builder()
130129
.is_authorized(true)
131130
.context(context)
132-
.build()
133-
.unwrap();
131+
.build();
134132

135133
println!("✅ Built authorizer response for user: {}", response.context.user_id);
136134
println!(" Authorized: {}", response.is_authorized);

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

Lines changed: 6 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@
3737

3838
#[cfg(feature = "builders")]
3939
use aws_lambda_events::event::sqs::{
40-
BatchItemFailure, BatchItemFailureBuilder, SqsBatchResponse, SqsBatchResponseBuilder, SqsEvent,
40+
BatchItemFailure, SqsBatchResponse, SqsEvent,
4141
};
4242
#[cfg(feature = "builders")]
4343
use lambda_runtime::{Error, LambdaEvent};
@@ -92,8 +92,7 @@ async fn function_handler(event: LambdaEvent<SqsEvent>) -> Result<SqsBatchRespon
9292
// ✅ Clean builder construction
9393
let item = BatchItemFailure::builder()
9494
.item_identifier(record.message_id.unwrap())
95-
.build()
96-
.unwrap();
95+
.build();
9796

9897
batch_item_failures.push(item)
9998
}
@@ -103,8 +102,7 @@ async fn function_handler(event: LambdaEvent<SqsEvent>) -> Result<SqsBatchRespon
103102
// ✅ Clean response construction with builder
104103
let response = SqsBatchResponse::builder()
105104
.batch_item_failures(batch_item_failures)
106-
.build()
107-
.map_err(|e| format!("Failed to build response: {}", e))?;
105+
.build();
108106

109107
Ok(response)
110108
}
@@ -115,18 +113,15 @@ fn main() {
115113
let failures = vec![
116114
BatchItemFailure::builder()
117115
.item_identifier("msg-123".to_string())
118-
.build()
119-
.unwrap(),
116+
.build(),
120117
BatchItemFailure::builder()
121118
.item_identifier("msg-456".to_string())
122-
.build()
123-
.unwrap(),
119+
.build(),
124120
];
125121

126122
let response = SqsBatchResponse::builder()
127123
.batch_item_failures(failures)
128-
.build()
129-
.unwrap();
124+
.build();
130125

131126
println!(
132127
"✅ Built SQS batch response with {} failed items",

0 commit comments

Comments
 (0)