Change Streams fullDocumentBeforeChange support

Closes spring-projects#4187
kufd · Oct 6, 2022 · 7722b66 · 7722b66
1 parent 5fb2b68
commit 7722b66
Showing 1 changed file with 4 additions and 16 deletions.
diff --git a/...g-data-mongodb/src/main/java/org/springframework/data/mongodb/core/ChangeStreamEvent.java b/...g-data-mongodb/src/main/java/org/springframework/data/mongodb/core/ChangeStreamEvent.java
@@ -155,33 +155,21 @@ public String getCollectionName() {
 	@Nullable
 	public T getBody() {
 
-		if (raw == null) {
+		if (raw == null || raw.getFullDocument() == null) {
 			return null;
 		}
 
-		Document fullDocument = raw.getFullDocument();
-
-		if (fullDocument == null) {
-			return targetType.cast(fullDocument);
-		}
-
-		return getConvertedFullDocument(fullDocument);
+		return getConvertedFullDocument(raw.getFullDocument());
 	}
 
 	@Nullable
 	public T getBodyBeforeChange() {
 
-		if (raw == null) {
+		if (raw == null || raw.getFullDocumentBeforeChange() == null) {
 			return null;
 		}
 
-		Document fullDocumentBeforeChange = raw.getFullDocumentBeforeChange();
-
-		if (fullDocumentBeforeChange == null) {
-			return targetType.cast(fullDocumentBeforeChange);
-		}
-
-		return getConvertedFullDocumentBeforeChange(fullDocumentBeforeChange);
+		return getConvertedFullDocumentBeforeChange(raw.getFullDocumentBeforeChange());
 	}
 
 	@SuppressWarnings("unchecked")