GODRIVER-1788 correctly replace errors in IndexView CreateMany (#543)

Author: iwysiu

mongo/index_view.go

@@ -249,7 +249,7 @@ func (iv IndexView) CreateMany(ctx context.Context, models []IndexModel, opts ..
 
 	err = op.Execute(ctx)
 	if err != nil {
-		return nil, err
+		return nil, replaceErrors(err)
 	}
 
 	return names, nil

mongo/integration/index_view_test.go

@@ -218,6 +218,24 @@ func TestIndexView(t *testing.T) {
 				})
 			}
 		})
+		// Needs to run on these versions for failpoints
+		mt.RunOpts("replace error", mtest.NewOptions().Topologies(mtest.ReplicaSet).MinServerVersion("4.0"), func(mt *mtest.T) {
+			mt.SetFailPoint(mtest.FailPoint{
+				ConfigureFailPoint: "failCommand",
+				Mode:               "alwaysOn",
+				Data: mtest.FailPointData{
+					FailCommands: []string{"createIndexes"},
+					ErrorCode:    100,
+				},
+			})
+
+			_, err := mt.Coll.Indexes().CreateOne(mtest.Background, mongo.IndexModel{Keys: bson.D{{"x", 1}}})
+			assert.NotNil(mt, err, "expected CreateOne error, got nil")
+			cmdErr, ok := err.(mongo.CommandError)
+			assert.True(mt, ok, "expected mongo.CommandError, got %T", err)
+			assert.Equal(mt, int32(100), cmdErr.Code, "expected error code 100, got %v", cmdErr.Code)
+
+		})
 	})
 	mt.Run("create many", func(mt *mtest.T) {
 		mt.Run("success", func(mt *mtest.T) {
@@ -277,9 +295,12 @@ func TestIndexView(t *testing.T) {
 			majority := options.CreateIndexes().SetCommitQuorumMajority()
 			votingMembers := options.CreateIndexes().SetCommitQuorumVotingMembers()
 
-			indexModel := mongo.IndexModel{
+			indexModel1 := mongo.IndexModel{
 				Keys: bson.D{{"x", 1}},
 			}
+			indexModel2 := mongo.IndexModel{
+				Keys: bson.D{{"y", 1}},
+			}
 
 			testCases := []struct {
 				name             string
@@ -299,13 +320,13 @@ func TestIndexView(t *testing.T) {
 				mtOpts := mtest.NewOptions().MinServerVersion(tc.minServerVersion).MaxServerVersion(tc.maxServerVersion)
 				mt.RunOpts(tc.name, mtOpts, func(mt *mtest.T) {
 					mt.ClearEvents()
-					_, err := mt.Coll.Indexes().CreateOne(mtest.Background, indexModel, tc.opts)
+					_, err := mt.Coll.Indexes().CreateMany(mtest.Background, []mongo.IndexModel{indexModel1, indexModel2}, tc.opts)
 					if tc.expectError {
-						assert.NotNil(mt, err, "expected CreateOne error, got nil")
+						assert.NotNil(mt, err, "expected CreateMany error, got nil")
 						return
 					}
 
-					assert.Nil(mt, err, "CreateOne error: %v", err)
+					assert.Nil(mt, err, "CreateMany error: %v", err)
 					cmd := mt.GetStartedEvent().Command
 					sentBSONValue, err := cmd.LookupErr("commitQuorum")
 					assert.Nil(mt, err, "expected commitQuorum in command %s", cmd)
@@ -319,6 +340,31 @@ func TestIndexView(t *testing.T) {
 				})
 			}
 		})
+		// Needs to run on these versions for failpoints
+		mt.RunOpts("replace error", mtest.NewOptions().Topologies(mtest.ReplicaSet).MinServerVersion("4.0"), func(mt *mtest.T) {
+			mt.SetFailPoint(mtest.FailPoint{
+				ConfigureFailPoint: "failCommand",
+				Mode:               "alwaysOn",
+				Data: mtest.FailPointData{
+					FailCommands: []string{"createIndexes"},
+					ErrorCode:    100,
+				},
+			})
+
+			_, err := mt.Coll.Indexes().CreateMany(mtest.Background, []mongo.IndexModel{
+				{
+					Keys: bson.D{{"foo", int32(-1)}},
+				},
+				{
+					Keys: bson.D{{"bar", int32(1)}, {"baz", int32(-1)}},
+				},
+			})
+			assert.NotNil(mt, err, "expected CreateMany error, got nil")
+			cmdErr, ok := err.(mongo.CommandError)
+			assert.True(mt, ok, "expected mongo.CommandError, got %T", err)
+			assert.Equal(mt, int32(100), cmdErr.Code, "expected error code 100, got %v", cmdErr.Code)
+
+		})
 	})
 	mt.Run("drop one", func(mt *mtest.T) {
 		iv := mt.Coll.Indexes()