Function updateSessionFromResponse

src/sessions.ts:1253–1287

(session: ClientSession, document: MongoDBResponse)

}

export function updateSessionFromResponse(session: ClientSession, document: MongoDBResponse): void {
  if (document.$clusterTime) {
    _advanceClusterTime(session, document.$clusterTime);
  }

  if (document.operationTime && session && session.supports.causalConsistency) {
    session.advanceOperationTime(document.operationTime);
  }

  if (document.recoveryToken && session && session.inTransaction()) {
    session.transaction._recoveryToken = document.recoveryToken;
  }

  if (session?.snapshotEnabled && session.snapshotTime == null) {
    // find and aggregate commands return atClusterTime on the cursor
    // distinct includes it in the response body
    const atClusterTime = document.atClusterTime;
    if (atClusterTime) {
      session.snapshotTime = atClusterTime;
    }
  }

  if (session.transaction.state === TxnState.STARTING_TRANSACTION) {
    if (document.ok === 1) {
      session.transaction.transition(TxnState.TRANSACTION_IN_PROGRESS);
    } else {
      const error = new MongoServerError(document.toObject());
      const isRetryableError = error.hasErrorLabel(MongoErrorLabel.RetryableError);

      if (!isRetryableError) {
        session.transaction.transition(TxnState.TRANSACTION_IN_PROGRESS);
      }
    }
  }
}