26
26
27
27
import static org .assertj .core .api .Assertions .assertThat ;
28
28
import static org .assertj .core .api .Assertions .assertThatThrownBy ;
29
- import static software .amazon .lambda .powertools .utilities .EventDeserializer .from ;
29
+ import static software .amazon .lambda .powertools .utilities .EventDeserializer .extractDataFrom ;
30
30
31
31
public class EventDeserializerTest {
32
32
33
33
@ Test
34
34
public void testDeserializeStringAsString_shouldReturnString () {
35
35
String stringEvent = "Hello World" ;
36
- String result = from (stringEvent ).extractDataAs (String .class );
36
+ String result = extractDataFrom (stringEvent ).as (String .class );
37
37
assertThat (result ).isEqualTo (stringEvent );
38
38
}
39
39
40
40
@ Test
41
41
public void testDeserializeStringAsObject_shouldReturnObject () {
42
42
String productStr = "{\" id\" :1234, \" name\" :\" product\" , \" price\" :42}" ;
43
- Product product = from (productStr ).extractDataAs (Product .class );
43
+ Product product = extractDataFrom (productStr ).as (Product .class );
44
44
assertProduct (product );
45
45
}
46
46
@@ -50,68 +50,68 @@ public void testDeserializeMapAsObject_shouldReturnObject() {
50
50
map .put ("id" , 1234 );
51
51
map .put ("name" , "product" );
52
52
map .put ("price" , 42 );
53
- Product product = from (map ).extractDataAs (Product .class );
53
+ Product product = extractDataFrom (map ).as (Product .class );
54
54
assertProduct (product );
55
55
}
56
56
57
57
@ ParameterizedTest
58
58
@ Event (value = "apigw_event.json" , type = APIGatewayProxyRequestEvent .class )
59
59
public void testDeserializeAPIGWEventBodyAsObject_shouldReturnObject (APIGatewayProxyRequestEvent event ) {
60
- Product product = from (event ).extractDataAs (Product .class );
60
+ Product product = extractDataFrom (event ).as (Product .class );
61
61
assertProduct (product );
62
62
}
63
63
64
64
@ ParameterizedTest
65
65
@ Event (value = "apigw_event.json" , type = APIGatewayProxyRequestEvent .class )
66
66
public void testDeserializeAPIGWEventBodyAsWrongObjectType_shouldThrowException (APIGatewayProxyRequestEvent event ) {
67
- assertThatThrownBy (() -> from (event ).extractDataAs (Basket .class ))
67
+ assertThatThrownBy (() -> extractDataFrom (event ).as (Basket .class ))
68
68
.isInstanceOf (EventDeserializationException .class )
69
69
.hasMessage ("Cannot load the event as Basket" );
70
70
}
71
71
72
72
@ ParameterizedTest
73
73
@ Event (value = "sns_event.json" , type = SNSEvent .class )
74
74
public void testDeserializeSNSEventMessageAsObject_shouldReturnObject (SNSEvent event ) {
75
- Product product = from (event ).extractDataAs (Product .class );
75
+ Product product = extractDataFrom (event ).as (Product .class );
76
76
assertProduct (product );
77
77
}
78
78
79
79
@ ParameterizedTest
80
80
@ Event (value = "sqs_event.json" , type = SQSEvent .class )
81
81
public void testDeserializeSQSEventMessageAsList_shouldReturnList (SQSEvent event ) {
82
- List <Product > products = from (event ).extractDataAsListOf (Product .class );
82
+ List <Product > products = extractDataFrom (event ).asListOf (Product .class );
83
83
assertThat (products ).hasSize (2 );
84
84
assertProduct (products .get (0 ));
85
85
}
86
86
87
87
@ ParameterizedTest
88
88
@ Event (value = "kinesis_event.json" , type = KinesisEvent .class )
89
89
public void testDeserializeKinesisEventMessageAsList_shouldReturnList (KinesisEvent event ) {
90
- List <Product > products = from (event ).extractDataAsListOf (Product .class );
90
+ List <Product > products = extractDataFrom (event ).asListOf (Product .class );
91
91
assertThat (products ).hasSize (2 );
92
92
assertProduct (products .get (0 ));
93
93
}
94
94
95
95
@ ParameterizedTest
96
96
@ Event (value = "kafka_event.json" , type = KafkaEvent .class )
97
97
public void testDeserializeKafkaEventMessageAsList_shouldReturnList (KafkaEvent event ) {
98
- List <Product > products = from (event ).extractDataAsListOf (Product .class );
98
+ List <Product > products = extractDataFrom (event ).asListOf (Product .class );
99
99
assertThat (products ).hasSize (2 );
100
100
assertProduct (products .get (0 ));
101
101
}
102
102
103
103
@ ParameterizedTest
104
104
@ Event (value = "sqs_event.json" , type = SQSEvent .class )
105
105
public void testDeserializeSQSEventMessageAsObject_shouldThrowException (SQSEvent event ) {
106
- assertThatThrownBy (() -> from (event ).extractDataAs (Product .class ))
106
+ assertThatThrownBy (() -> extractDataFrom (event ).as (Product .class ))
107
107
.isInstanceOf (EventDeserializationException .class )
108
108
.hasMessageContaining ("consider using 'extractDataAsListOf' instead" );
109
109
}
110
110
111
111
@ Test
112
112
public void testDeserializeProductAsProduct_shouldReturnProduct () {
113
113
Product myProduct = new Product (1234 , "product" , 42 );
114
- Product product = from (myProduct ).extractDataAs (Product .class );
114
+ Product product = extractDataFrom (myProduct ).as (Product .class );
115
115
assertProduct (product );
116
116
}
117
117
0 commit comments