Extract DropIndexes operation class

Author: jmikola

src/Collection.php

@@ -19,6 +19,7 @@
 use MongoDB\Operation\Count;
 use MongoDB\Operation\Distinct;
 use MongoDB\Operation\DropCollection;
+use MongoDB\Operation\DropIndexes;
 use MongoDB\Operation\FindOneAndDelete;
 use MongoDB\Operation\FindOneAndReplace;
 use MongoDB\Operation\FindOneAndUpdate;
@@ -366,43 +367,35 @@ public function drop()
     /**
      * Drop a single index in the collection.
      *
-     * @see http://docs.mongodb.org/manual/reference/command/dropIndexes/
-     * @see http://docs.mongodb.org/manual/reference/method/db.collection.dropIndex/
-     * @param string $indexName
-     * @return Cursor
+     * @param string $indexName Index name
+     * @return object Command result document
      * @throws InvalidArgumentException if $indexName is an empty string or "*"
      */
     public function dropIndex($indexName)
     {
         $indexName = (string) $indexName;
 
-        if ($indexName === '') {
-            throw new InvalidArgumentException('Index name cannot be empty');
-        }
-
         if ($indexName === '*') {
             throw new InvalidArgumentException('dropIndexes() must be used to drop multiple indexes');
         }
 
-        $command = new Command(array('dropIndexes' => $this->collname, 'index' => $indexName));
-        $readPreference = new ReadPreference(ReadPreference::RP_PRIMARY);
+        $operation = new DropIndexes($this->dbname, $this->collname, $indexName);
+        $server = $this->manager->selectServer(new ReadPreference(ReadPreference::RP_PRIMARY));
 
-        return $this->manager->executeCommand($this->dbname, $command, $readPreference);
+        return $operation->execute($server);
     }
 
     /**
      * Drop all indexes in the collection.
      *
-     * @see http://docs.mongodb.org/manual/reference/command/dropIndexes/
-     * @see http://docs.mongodb.org/manual/reference/method/db.collection.dropIndexes/
-     * @return Cursor
+     * @return object Command result document
      */
     public function dropIndexes()
     {
-        $command = new Command(array('dropIndexes' => $this->collname, 'index' => '*'));
-        $readPreference = new ReadPreference(ReadPreference::RP_PRIMARY);
+        $operation = new DropIndexes($this->dbname, $this->collname, '*');
+        $server = $this->manager->selectServer(new ReadPreference(ReadPreference::RP_PRIMARY));
 
-        return $this->manager->executeCommand($this->dbname, $command, $readPreference);
+        return $operation->execute($server);
     }
 
     /**

src/Operation/DropIndexes.php

@@ -0,0 +1,67 @@
+<?php
+
+namespace MongoDB\Operation;
+
+use MongoDB\Driver\Command;
+use MongoDB\Driver\Server;
+use MongoDB\Exception\InvalidArgumentException;
+use MongoDB\Exception\RuntimeException;
+
+/**
+ * Operation for the dropIndexes command.
+ *
+ * @api
+ * @see MongoDB\Collection::dropIndexes()
+ * @see http://docs.mongodb.org/manual/reference/command/dropIndexes/
+ */
+class DropIndexes implements Executable
+{
+    private $databaseName;
+    private $collectionName;
+    private $indexName;
+
+    /**
+     * Constructs a dropIndexes command.
+     *
+     * @param string $databaseName   Database name
+     * @param string $collectionName Collection name
+     * @param string $indexName      Index name (use "*" to drop all indexes)
+     * @throws InvalidArgumentException
+     */
+    public function __construct($databaseName, $collectionName, $indexName)
+    {
+        $indexName = (string) $indexName;
+
+        if ($indexName === '') {
+            throw new InvalidArgumentException('$indexName cannot be empty');
+        }
+
+        $this->databaseName = (string) $databaseName;
+        $this->collectionName = (string) $collectionName;
+        $this->indexName = $indexName;
+    }
+
+    /**
+     * Execute the operation.
+     *
+     * @see Executable::execute()
+     * @param Server $server
+     * @return object Command result document
+     */
+    public function execute(Server $server)
+    {
+        $cmd = array(
+            'dropIndexes' => $this->collectionName,
+            'index' => $this->indexName,
+        );
+
+        $cursor = $server->executeCommand($this->databaseName, new Command($cmd));
+        $result = current($cursor->toArray());
+
+        if (empty($result['ok'])) {
+            throw new RuntimeException(isset($result['errmsg']) ? $result['errmsg'] : 'Unknown error');
+        }
+
+        return $result;
+    }
+}