Skip to content

Commit c2df718

Browse files
committed
Fix NPE when UserIdentity is null
1 parent 109a240 commit c2df718

File tree

2 files changed

+13
-1
lines changed

2 files changed

+13
-1
lines changed

aws-lambda-java-events-sdk-transformer/src/main/java/com/amazonaws/services/lambda/runtime/events/transformers/dynamodb/DynamodbRecordTransformer.java

+3-1
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,9 @@ public static Record toRecordV2(final DynamodbEvent.DynamodbStreamRecord record)
1616
.eventSource(record.getEventSource())
1717
.eventVersion(record.getEventVersion())
1818
.userIdentity(
19-
DynamodbIdentityTransformer.toIdentityV2(record.getUserIdentity())
19+
record.getUserIdentity() != null
20+
? DynamodbIdentityTransformer.toIdentityV2(record.getUserIdentity())
21+
: null
2022
)
2123
.build();
2224
}

aws-lambda-java-events-sdk-transformer/src/test/java/com/amazonaws/services/lambda/runtime/events/transformers/dynamodb/DynamodbRecordTransformerTest.java

+10
Original file line numberDiff line numberDiff line change
@@ -50,4 +50,14 @@ public void testToRecordV2() {
5050
Assertions.assertEquals(record_v2, convertedRecord);
5151
}
5252

53+
@Test
54+
public void testToRecordV2WhenUserIdentityIsNull() {
55+
DynamodbEvent.DynamodbStreamRecord record = record_event.clone();
56+
record.setUserIdentity(null);
57+
58+
Assertions.assertDoesNotThrow(() -> {
59+
DynamodbRecordTransformer.toRecordV2(record);
60+
});
61+
}
62+
5363
}

0 commit comments

Comments
 (0)