Skip to content

fix(NODE-3521): update session support checks #3151

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 12 commits into from
Mar 3, 2022
Merged

fix(NODE-3521): update session support checks #3151

Changes from 5 commits
Commits
Show all changes
12 commits
Select commit Hold shift + click to select a range
a0dfc5b
fix(NODE-3521): remove session support checks
durran Feb 24, 2022
0f8cd6e
fix(NODE-3521): remove extra server selection
durran Feb 25, 2022
ef6894d
Revert "fix(NODE-3521): remove extra server selection"
durran Feb 28, 2022
b0ca0b6
Revert "fix(NODE-3521): remove session support checks"
durran Feb 28, 2022
d3e2109
fix(NODE-3521): properly check session check
durran Feb 28, 2022
ddc4d24
test(NODE-3521): add next tests for session
durran Mar 1, 2022
dc62173
chore(NODE-3521): find/agg cursor session always there
durran Mar 1, 2022
5839dae
test(NODE-3521): fix cursor server selection tests
durran Mar 2, 2022
68365bf
Update test/unit/cursor/aggregation_cursor.test.js
durran Mar 2, 2022
dd594f6
Update test/unit/cursor/aggregation_cursor.test.js
durran Mar 2, 2022
05ad2d2
Update test/unit/cursor/find_cursor.test.js
durran Mar 2, 2022
8ec9ca0
fix(NODE-3521): lint errors
durran Mar 3, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 9 additions & 2 deletions src/cursor/abstract_cursor.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -653,8 +653,15 @@ function next<T>(cursor: AbstractCursor, blocking: boolean, callback: Callback<T

if (cursorId == null) {
// All cursors must operate within a session, one must be made implicitly if not explicitly provided
if (cursor[kSession] == null && cursor[kTopology].hasSessionSupport()) {
cursor[kSession] = cursor[kTopology].startSession({ owner: cursor, explicit: false });
if (cursor[kSession] == null) {
if (cursor[kTopology].shouldCheckForSessionSupport()) {
return cursor[kTopology].selectServer(ReadPreference.primaryPreferred, err => {
if (err) return callback(err);
return next(cursor, blocking, callback);
});
} else if (cursor[kTopology].hasSessionSupport()) {
cursor[kSession] = cursor[kTopology].startSession({ owner: cursor, explicit: false });
}
}

cursor._initialize(cursor[kSession], (err, state) => {
Expand Down