fix(transactions): only send recovery token on commitTransaction

daprahamian · mbroadst · commit 923a0891f620 · 2019-03-07T10:54:46.000-05:00
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;
   }
 

Original file line number	Diff line number	Diff line change
`@@ -469,7 +469,7 @@ function endTransaction(session, commandName, callback) {`
`469`	`469`	`return commandName === 'commitTransaction' ? err : null;`
`470`	`470`	`}`
`471`	`471`
`472`		`- if (session.transaction.recoveryToken) {`
	`472`	`+ if (commandName === 'commitTransaction' && session.transaction.recoveryToken) {`
`473`	`473`	`command.recoveryToken = session.transaction.recoveryToken;`
`474`	`474`	`}`
`475`	`475`