Contents

# frozen_string_literal: true
# encoding: utf-8

require 'spec_helper'

describe 'Map-reduce operations' do
  let(:client) { authorized_client }
  let(:collection) { client['mr_integration'] }

  let(:subscriber) { Mrss::EventSubscriber.new }

  let(:find_options) { {} }

  let(:operation) do
    collection.find({}, find_options).map_reduce('function(){}', 'function(){}')
  end

  before do
    collection.insert_one(test: 1)
    client.subscribe(Mongo::Monitoring::COMMAND, subscriber)
  end

  let(:event) { subscriber.single_command_started_event('mapReduce') }

  context 'read preference' do
    require_topology :sharded

    context 'specified on client' do
      let(:client) { authorized_client.with(read: {mode: :secondary_preferred }) }

      # RUBY-2706: read preference is not sent on pre-3.6 servers
      min_server_fcv '3.6'

      it 'is sent' do
        operation.to_a

        event.command['$readPreference'].should == {'mode' => 'secondaryPreferred'}
      end
    end

    context 'specified on collection' do
      let(:collection) { client['mr_integration', read: {mode: :secondary_preferred }] }

      # RUBY-2706: read preference is not sent on pre-3.6 servers
      min_server_fcv '3.6'

      it 'is sent' do
        operation.to_a

        event.command['$readPreference'].should == {'mode' => 'secondaryPreferred'}
      end
    end

    context 'specified on operation' do
      let(:find_options) { {read: {mode: :secondary_preferred }} }

      # RUBY-2706: read preference is not sent on pre-3.6 servers
      min_server_fcv '3.6'

      it 'is sent' do
        operation.to_a

        event.command['$readPreference'].should == {'mode' => 'secondaryPreferred'}
      end
    end
  end

  context 'session' do
    min_server_fcv '3.6'

    it 'is sent' do
      operation.to_a

      event.command['lsid'].should_not be nil
    end
  end
end

Version data entries

16 entries across 16 versions & 1 rubygems

Version	Path
mongo-2.16.4	spec/integration/map_reduce_spec.rb
mongo-2.17.4	spec/integration/map_reduce_spec.rb
mongo-2.18.3	spec/integration/map_reduce_spec.rb
mongo-2.18.2	spec/integration/map_reduce_spec.rb
mongo-2.17.3	spec/integration/map_reduce_spec.rb
mongo-2.18.1	spec/integration/map_reduce_spec.rb
mongo-2.18.0	spec/integration/map_reduce_spec.rb
mongo-2.17.2	spec/integration/map_reduce_spec.rb
mongo-2.16.3	spec/integration/map_reduce_spec.rb
mongo-2.18.0.beta1	spec/integration/map_reduce_spec.rb
mongo-2.16.2	spec/integration/map_reduce_spec.rb
mongo-2.17.1	spec/integration/map_reduce_spec.rb
mongo-2.16.1	spec/integration/map_reduce_spec.rb
mongo-2.17.0	spec/integration/map_reduce_spec.rb
mongo-2.16.0	spec/integration/map_reduce_spec.rb
mongo-2.16.0.alpha1	spec/integration/map_reduce_spec.rb