fix(transactions): only send recovery token on commitTransaction

mongodb-js · Mar 7, 2019 · 923a089 · 923a089
1 parent aad05df
commit 923a089
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/sessions.js b/lib/sessions.js
@@ -469,7 +469,7 @@ function endTransaction(session, commandName, callback) {
     return commandName === 'commitTransaction' ? err : null;
   }
 
-  if (session.transaction.recoveryToken) {
+  if (commandName === 'commitTransaction' && session.transaction.recoveryToken) {
     command.recoveryToken = session.transaction.recoveryToken;
   }