GODRIVER-2587 Implement modifyCollection for the unified test runner (#1796)

Author: joyjwang

internal/integration/unified/database_operation_execution.go

@@ -223,6 +223,37 @@ func executeListCollectionNames(ctx context.Context, operation *operation) (*ope
 	return newValueResult(bson.TypeArray, data, nil), nil
 }
 
+func executeModifyCollection(ctx context.Context, operation *operation) (*operationResult, error) {
+	db, err := entities(ctx).database(operation.Object)
+	if err != nil {
+		return nil, err
+	}
+
+	collModCmd := bson.D{}
+
+	elems, _ := operation.Arguments.Elements()
+	for _, elem := range elems {
+		key := elem.Key()
+		val := elem.Value()
+
+		switch key {
+		case "collection":
+			collModCmd = append(collModCmd, bson.E{"collMod", val.StringValue()})
+		case "changeStreamPreAndPostImages":
+			collModCmd = append(collModCmd, bson.E{"changeStreamPreAndPostImages", val.Document()})
+		case "validator":
+			collModCmd = append(collModCmd, bson.E{"validator", val.Document()})
+		case "index":
+			collModCmd = append(collModCmd, bson.E{"index", val.Document()})
+		default:
+			return nil, fmt.Errorf("unrecognized modifyCollection option %q", key)
+		}
+	}
+
+	res, err := db.RunCommand(ctx, collModCmd).Raw()
+	return newDocumentResult(res, err), nil
+}
+
 func executeRunCommand(ctx context.Context, operation *operation) (*operationResult, error) {
 	db, err := entities(ctx).database(operation.Object)
 	if err != nil {

internal/integration/unified/operation.go

@@ -145,6 +145,8 @@ func (op *operation) run(ctx context.Context, loopDone <-chan struct{}) (*operat
 		return executeListCollections(ctx, op)
 	case "listCollectionNames":
 		return executeListCollectionNames(ctx, op)
+	case "modifyCollection":
+		return executeModifyCollection(ctx, op)
 	case "runCommand":
 		return executeRunCommand(ctx, op)
 	case "runCursorCommand":
@@ -268,7 +270,7 @@ func (op *operation) run(ctx context.Context, loopDone <-chan struct{}) (*operat
 		return executeAddKeyAltName(ctx, op)
 
 	// Unsupported operations
-	case "count", "listIndexNames", "modifyCollection":
+	case "count", "listIndexNames":
 		return nil, newSkipTestError(fmt.Sprintf("the %q operation is not supported", op.Name))
 	default:
 		return nil, fmt.Errorf("unrecognized entity operation %q", op.Name)

testdata/collection-management/modifyCollection-errorResponse.json

@@ -0,0 +1,118 @@
+{
+    "description": "modifyCollection-errorResponse",
+    "schemaVersion": "1.12",
+    "createEntities": [
+      {
+        "client": {
+          "id": "client0",
+          "observeEvents": [
+            "commandStartedEvent"
+          ]
+        }
+      },
+      {
+        "database": {
+          "id": "database0",
+          "client": "client0",
+          "databaseName": "collMod-tests"
+        }
+      },
+      {
+        "collection": {
+          "id": "collection0",
+          "database": "database0",
+          "collectionName": "test"
+        }
+      }
+    ],
+    "initialData": [
+      {
+        "collectionName": "test",
+        "databaseName": "collMod-tests",
+        "documents": [
+          {
+            "_id": 1,
+            "x": 1
+          },
+          {
+            "_id": 2,
+            "x": 1
+          }
+        ]
+      }
+    ],
+    "tests": [
+      {
+        "description": "modifyCollection prepareUnique violations are accessible",
+        "runOnRequirements": [
+          {
+            "minServerVersion": "5.2"
+          }
+        ],
+        "operations": [
+          {
+            "name": "createIndex",
+            "object": "collection0",
+            "arguments": {
+              "keys": {
+                "x": 1
+              }
+            }
+          },
+          {
+            "name": "modifyCollection",
+            "object": "database0",
+            "arguments": {
+              "collection": "test",
+              "index": {
+                "keyPattern": {
+                  "x": 1
+                },
+                "prepareUnique": true
+              }
+            }
+          },
+          {
+            "name": "insertOne",
+            "object": "collection0",
+            "arguments": {
+              "document": {
+                "_id": 3,
+                "x": 1
+              }
+            },
+            "expectError": {
+              "errorCode": 11000
+            }
+          },
+          {
+            "name": "modifyCollection",
+            "object": "database0",
+            "arguments": {
+              "collection": "test",
+              "index": {
+                "keyPattern": {
+                  "x": 1
+                },
+                "unique": true
+              }
+            },
+            "expectError": {
+              "isClientError": false,
+              "errorCode": 359,
+              "errorResponse": {
+                "violations": [
+                  {
+                    "ids": [
+                      1,
+                      2
+                    ]
+                  }
+                ]
+              }
+            }
+          }
+        ]
+      }
+    ]
+  }

testdata/collection-management/modifyCollection-errorResponse.yml

@@ -0,0 +1,59 @@
+description: "modifyCollection-errorResponse"
+
+schemaVersion: "1.12"
+
+createEntities:
+  - client:
+      id: &client0 client0
+      observeEvents: [ commandStartedEvent ]
+  - database:
+      id: &database0 database0
+      client: *client0
+      databaseName: &database0Name collMod-tests
+  - collection:
+      id: &collection0 collection0
+      database: *database0
+      collectionName: &collection0Name test
+
+initialData: &initialData
+  - collectionName: *collection0Name
+    databaseName: *database0Name
+    documents:
+      - { _id: 1, x: 1 }
+      - { _id: 2, x: 1 }
+
+tests:
+  - description: "modifyCollection prepareUnique violations are accessible"
+    runOnRequirements:
+      - minServerVersion: "5.2" # SERVER-61158
+    operations:
+      - name: createIndex
+        object: *collection0
+        arguments:
+          keys: { x: 1 }
+      - name: modifyCollection
+        object: *database0
+        arguments:
+          collection: *collection0Name
+          index:
+            keyPattern: { x: 1 }
+            prepareUnique: true
+      - name: insertOne
+        object: *collection0
+        arguments:
+          document: { _id: 3, x: 1 }
+        expectError:
+          errorCode: 11000 # DuplicateKey
+      - name: modifyCollection
+        object: *database0
+        arguments:
+          collection: *collection0Name
+          index:
+            keyPattern: { x: 1 }
+            unique: true
+        expectError:
+          isClientError: false
+          errorCode: 359 # CannotConvertIndexToUnique
+          errorResponse:
+            violations:
+               - { ids: [ 1, 2 ] }