Added tests to verify that the JsonIgnoreProperties annotation is being used. (#14)

Author: WadeWaldron

CHANGELOG.md

@@ -25,3 +25,7 @@
 * Implemented Exercise 16 - Merging Streams.
 * Implemented Exercise 18 - Aggregating Flink Data using Windowing.
 * Implemented Exercise 20 - Managing State in Flink.
+
+## Version 2.0.1
+
+* Added additional tests to verify the serialization/deserialization of the models, including one for testing the use of the JsonIgnoreProperties annotation.

staging/10-deserialization/src/test/java/models/SkyOneAirlinesFlightDataTest.java

@@ -1,12 +1,16 @@
 package models;
 
+import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper;
+import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
 import org.junit.jupiter.api.Test;
 
 import static org.apache.flink.types.PojoTestUtils.assertSerializedAsPojo;
 import static org.junit.jupiter.api.Assertions.*;
 
 class SkyOneAirlinesFlightDataTest {
 
+    ObjectMapper mapper = new ObjectMapper().registerModule(new JavaTimeModule());
+
     @Test
     void theClass_shouldBeSerializableAsAPOJO() {
         assertSerializedAsPojo(SkyOneAirlinesFlightData.class);
@@ -65,16 +69,36 @@ public void toString_shouldReturnTheExpectedResults() {
         SkyOneAirlinesFlightData flightData = new TestHelpers.SkyOneBuilder().build();
 
         String expected = "SkyOneAirlinesFlightData{" +
-                "emailAddress='" + flightData.getEmailAddress() + '\'' +
-                ", flightDepartureTime=" + flightData.getFlightDepartureTime() +
-                ", iataDepartureCode='" + flightData.getIataDepartureCode() + '\'' +
-                ", flightArrivalTime=" + flightData.getFlightArrivalTime() +
-                ", iataArrivalCode='" + flightData.getIataArrivalCode() + '\'' +
-                ", flightNumber='" + flightData.getFlightNumber() + '\'' +
-                ", confirmation='" + flightData.getConfirmation() + '\'' +
-                '}';
+            "emailAddress='" + flightData.getEmailAddress() + '\'' +
+            ", flightDepartureTime=" + flightData.getFlightDepartureTime() +
+            ", iataDepartureCode='" + flightData.getIataDepartureCode() + '\'' +
+            ", flightArrivalTime=" + flightData.getFlightArrivalTime() +
+            ", iataArrivalCode='" + flightData.getIataArrivalCode() + '\'' +
+            ", flightNumber='" + flightData.getFlightNumber() + '\'' +
+            ", confirmation='" + flightData.getConfirmation() + '\'' +
+            '}';
 
         assertEquals(expected, flightData.toString());
 
     }
+
+    @Test
+    public void serializer_shouldSerializeAndDeserializeTheCorrectObject() throws Exception {
+        SkyOneAirlinesFlightData original = new TestHelpers.SkyOneBuilder().build();
+
+        String serialized = mapper.writeValueAsString(original);
+        SkyOneAirlinesFlightData deserialized = mapper.readValue(serialized, SkyOneAirlinesFlightData.class);
+
+        assertSerializedAsPojo(SkyOneAirlinesFlightData.class);
+        assertEquals(original, deserialized);
+    }
+
+    @Test
+    public void serializer_shouldHandleUnknownFields() throws Exception {
+        String json = "{\"emailAddress\":\"[email protected]\",\"flightDepartureTime\":\"2023-10-16T22:25:00.000Z\",\"iataDepartureCode\":\"LAS\",\"flightArrivalTime\":\"2023-10-17T09:38:00.000Z\",\"iataArrivalCode\":\"BOS\",\"flightNumber\":\"SKY1522\",\"confirmation\":\"SKY1OUJUUK\",\"unknownField\":\"ignore\"}";
+
+        SkyOneAirlinesFlightData object = mapper.readValue(json, SkyOneAirlinesFlightData.class);
+
+        assertInstanceOf(SkyOneAirlinesFlightData.class, object);
+    }
 }

staging/16-merging-streams/src/test/java/models/SunsetAirFlightDataTest.java

@@ -1,12 +1,16 @@
 package models;
 
+import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper;
+import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
 import org.junit.jupiter.api.Test;
 
 import static org.apache.flink.types.PojoTestUtils.assertSerializedAsPojo;
 import static org.junit.jupiter.api.Assertions.*;
 
 class SunsetAirFlightDataTest {
 
+    ObjectMapper mapper = new ObjectMapper().registerModule(new JavaTimeModule());
+
     @Test
     void theClass_shouldBeSerializableAsAPOJO() {
         assertSerializedAsPojo(SunsetAirFlightData.class);
@@ -61,19 +65,38 @@ public void equals_shouldReturnFalse_forTwoDifferentFlights() {
 
     @Test
     public void toFlightData_shouldConvertToAFlightDataObject() {
-        SunsetAirFlightData skyOne = new TestHelpers.SunsetBuilder().build();
+        SunsetAirFlightData sunset = new TestHelpers.SunsetBuilder().build();
         FlightData expected = new FlightData();
-        expected.setEmailAddress(skyOne.getCustomerEmailAddress());
-        expected.setDepartureTime(skyOne.getDepartureTime());
-        expected.setDepartureAirportCode(skyOne.getDepartureAirport());
-        expected.setArrivalTime(skyOne.getArrivalTime());
-        expected.setArrivalAirportCode(skyOne.getArrivalAirport());
-        expected.setFlightNumber(skyOne.getFlightId());
-        expected.setConfirmationCode(skyOne.getReferenceNumber());
+        expected.setEmailAddress(sunset.getCustomerEmailAddress());
+        expected.setDepartureTime(sunset.getDepartureTime());
+        expected.setDepartureAirportCode(sunset.getDepartureAirport());
+        expected.setArrivalTime(sunset.getArrivalTime());
+        expected.setArrivalAirportCode(sunset.getArrivalAirport());
+        expected.setFlightNumber(sunset.getFlightId());
+        expected.setConfirmationCode(sunset.getReferenceNumber());
 
-        FlightData actual = skyOne.toFlightData();
+        FlightData actual = sunset.toFlightData();
 
         assertEquals(expected, actual);
     }
 
+    @Test
+    public void serializer_shouldSerializeAndDeserializeTheCorrectObject() throws Exception {
+        SunsetAirFlightData original = new TestHelpers.SunsetBuilder().build();
+
+        String serialized = mapper.writeValueAsString(original);
+        SunsetAirFlightData deserialized = mapper.readValue(serialized, SunsetAirFlightData.class);
+
+        assertSerializedAsPojo(SunsetAirFlightData.class);
+        assertEquals(original, deserialized);
+    }
+
+    @Test
+    public void serializer_shouldHandleUnknownFields() throws Exception {
+        String json = "{\"emailAddress\":\"[email protected]\",\"flightDepartureTime\":\"2023-10-16T22:25:00.000Z\",\"iataDepartureCode\":\"LAS\",\"flightArrivalTime\":\"2023-10-17T09:38:00.000Z\",\"iataArrivalCode\":\"BOS\",\"flightNumber\":\"SKY1522\",\"confirmation\":\"SKY1OUJUUK\",\"unknownField\":\"ignore\"}";
+
+        SunsetAirFlightData object = mapper.readValue(json, SunsetAirFlightData.class);
+
+        assertInstanceOf(SunsetAirFlightData.class, object);
+    }
 }