Merge pull request #34083 from ruget/ChangeStreamOptionsWithfullDocum…

…entBeforeChange

Add fullDocumentBeforeChange to ChangeStreamOptions

extensions/mongodb-client/runtime/src/main/java/io/quarkus/mongodb/ChangeStreamOptions.java

@@ -7,6 +7,7 @@
 
 import com.mongodb.client.model.Collation;
 import com.mongodb.client.model.changestream.FullDocument;
+import com.mongodb.client.model.changestream.FullDocumentBeforeChange;
 import com.mongodb.reactivestreams.client.ChangeStreamPublisher;
 
 /**
@@ -15,6 +16,7 @@
 public class ChangeStreamOptions {
 
     private FullDocument fullDocument;
+    private FullDocumentBeforeChange fullDocumentBeforeChange;
     private BsonDocument resumeToken;
     private BsonDocument startAfterResumeToken;
     private BsonTimestamp startAtOperationTime;
@@ -33,6 +35,17 @@ public ChangeStreamOptions fullDocument(FullDocument fullDocument) {
         return this;
     }
 
+    /**
+     * Sets the fullDocumentBeforeChange value.
+     *
+     * @param fullDocumentBeforeChange the fullDocumentBeforeChange
+     * @return this
+     */
+    public ChangeStreamOptions fullDocumentBeforeChange(FullDocumentBeforeChange fullDocumentBeforeChange) {
+        this.fullDocumentBeforeChange = fullDocumentBeforeChange;
+        return this;
+    }
+
     /**
      * Sets the logical starting point for the new change stream.
      *
@@ -114,6 +127,9 @@ public <T> ChangeStreamPublisher<T> apply(ChangeStreamPublisher<T> stream) {
         if (fullDocument != null) {
             publisher = publisher.fullDocument(fullDocument);
         }
+        if (fullDocumentBeforeChange != null) {
+            publisher = publisher.fullDocumentBeforeChange(fullDocumentBeforeChange);
+        }
         if (resumeToken != null) {
             publisher = publisher.resumeAfter(resumeToken);
         }