spec/mongo/operation/write/bulk/insert_spec.rb in mongo-2.2.7 vs spec/mongo/operation/write/bulk/insert_spec.rb in mongo-2.3.0

@@ -1,18 +1,21 @@
 require 'spec_helper'
 
 describe Mongo::Operation::Write::Bulk::Insert do
-  include_context 'operation'
 
   let(:documents) do
     [{ :name => 'test' }]
   end
 
+  let(:write_concern) do
+    Mongo::WriteConcern.get(WRITE_CONCERN)
+  end
+
   let(:spec) do
     { documents: documents,
-      db_name: db_name,
-      coll_name: coll_name,
+      db_name: authorized_collection.database.name,
+      coll_name: authorized_collection.name,
       write_concern: write_concern
     }
   end
 
   let(:op) do
@@ -82,11 +85,11 @@
         [{ 'field' => 'test' },
          { 'field' => 'test' }]
       end
 
       let(:inserted_ids) do
-        op.execute(authorized_primary.context).inserted_ids
+        op.execute(authorized_primary).inserted_ids
       end
 
       let(:collection_ids) do
         authorized_collection.find(field: 'test').collect { |d| d['_id'] }
       end
@@ -111,11 +114,11 @@
     context 'when inserting a single document' do
 
       context 'when the insert succeeds' do
 
         let(:response) do
-          op.execute(authorized_primary.context)
+          op.execute(authorized_primary)
         end
 
         it 'inserts the documents into the database', if: write_command_enabled? do
           expect(response.written_count).to eq(1)
         end
@@ -133,11 +136,11 @@
         let(:documents) do
           [{ name: 'test1' }, { name: 'test2' }]
         end
 
         let(:response) do
-          op.execute(authorized_primary.context)
+          op.execute(authorized_primary)
         end
 
         it 'inserts the documents into the database', if: write_command_enabled? do
           expect(response.written_count).to eq(2)
         end
@@ -154,12 +157,12 @@
         [{ name: 'test' }, { name: 'test' }, { name: 'test1' }]
       end
 
       let(:spec) do
         { documents: documents,
-          db_name: db_name,
-          coll_name: coll_name,
+          db_name: authorized_collection.database.name,
+          coll_name: authorized_collection.name,
           write_concern: write_concern,
           ordered: true
         }
       end
 
@@ -174,11 +177,11 @@
         end
 
         context 'when the insert fails' do
     
           it 'aborts after first error' do
-            failing_insert.execute(authorized_primary.context)
+            failing_insert.execute(authorized_primary)
             expect(authorized_collection.find.count).to eq(1)
           end
         end
       end
 
@@ -189,11 +192,11 @@
         end
 
         context 'when the insert fails' do
 
           it 'aborts after first error' do
-            failing_insert.execute(authorized_primary.context)
+            failing_insert.execute(authorized_primary)
             expect(authorized_collection.find.count).to eq(1)
           end
         end
       end
     end
@@ -204,12 +207,12 @@
         [{ name: 'test' }, { name: 'test' }, { name: 'test1' }]
       end
 
       let(:spec) do
         { documents: documents,
-          db_name: db_name,
-          coll_name: coll_name,
+          db_name: authorized_collection.database.name,
+          coll_name: authorized_collection.name,
           write_concern: write_concern,
           ordered: false
         }
       end
 
@@ -217,18 +220,14 @@
         described_class.new(spec)
       end
 
       context 'when write concern is acknowledged' do
 
-        let(:write_concern) do
-          Mongo::WriteConcern.get(w: 1)
-        end
-
         context 'when the insert fails' do
     
           it 'does not abort after first error' do
-            failing_insert.execute(authorized_primary.context)
+            failing_insert.execute(authorized_primary)
             expect(authorized_collection.find.count).to eq(2)
           end
         end
       end
 
@@ -239,10 +238,10 @@
         end
 
         context 'when the insert fails' do
 
           it 'does not after first error' do
-            failing_insert.execute(authorized_primary.context)
+            failing_insert.execute(authorized_primary)
             expect(authorized_collection.find.count).to eq(2)
           end
         end
       end
     end