correctly identify/mock connections without session support

Author: jamis

lib/mongo/operation/shared/sessions_supported.rb

@@ -138,9 +138,11 @@ def command(connection)
 
         add_read_preference(sel, connection)
 
-        apply_cluster_time!(sel, connection)
-        if session && (acknowledged_write? || session.in_transaction?)
-          apply_session_options(sel, connection)
+        if connection.description.logical_session_timeout
+          apply_cluster_time!(sel, connection)
+          if session && (acknowledged_write? || session.in_transaction?)
+            apply_session_options(sel, connection)
+          end
         end
 
         sel

spec/mongo/operation/create/op_msg_spec.rb

@@ -148,6 +148,9 @@
 
         it 'creates the correct OP_MSG message' do
           RSpec::Mocks.with_temporary_scope do
+            # mimic lack of session support
+            allow(authorized_primary.description).to receive(:logical_session_timeout).and_return(nil)
+
             expect(expected_global_args[:session]).to be nil
             expect(Mongo::Protocol::Msg).to receive(:new).with([], {}, expected_global_args)
             op.send(:message, connection)

spec/mongo/operation/delete/op_msg_spec.rb

@@ -174,6 +174,9 @@
 
           it 'creates the correct OP_MSG message' do
             RSpec::Mocks.with_temporary_scope do
+              # mimic lack of session support
+              allow(authorized_primary.description).to receive(:logical_session_timeout).and_return(nil)
+
               expect(expected_global_args[:session]).to be nil
               expect(Mongo::Protocol::Msg).to receive(:new).with([], {}, expected_global_args, expected_payload_1)
               op.send(:message, connection)

spec/mongo/operation/insert/op_msg_spec.rb

@@ -185,6 +185,9 @@
 
         it 'creates the correct OP_MSG message' do
           RSpec::Mocks.with_temporary_scope do
+            # mimic lack of session support
+            allow(authorized_primary.description).to receive(:logical_session_timeout).and_return(nil)
+
             expect(expected_global_args).not_to have_key(:lsid)
             expect(Mongo::Protocol::Msg).to receive(:new).with([],
                                                                 {},

spec/mongo/operation/update/op_msg_spec.rb

@@ -175,6 +175,9 @@
 
           it 'creates the correct OP_MSG message' do
             RSpec::Mocks.with_temporary_scope do
+              # mimic lack of session support
+              allow(authorized_primary.description).to receive(:logical_session_timeout).and_return(nil)
+
               expect(Mongo::Protocol::Msg).to receive(:new).with([], {}, expected_global_args, expected_payload_1)
               op.send(:message, connection)
             end