Merge pull request #1282 from mariansollmann/issue-1282

Add delete command to index cli
cargomedia · Jun 12, 2014 · 59d8369 · 59d8369
2 parents e68727d + bed4a5d
commit 59d8369
Showing 1 changed file with 18 additions and 4 deletions.
diff --git a/library/CM/Elasticsearch/Index/Cli.php b/library/CM/Elasticsearch/Index/Cli.php
@@ -6,7 +6,7 @@ class CM_Elasticsearch_Index_Cli extends CM_Cli_Runnable_Abstract {
      * @param string|null $indexName
      */
     public function create($indexName = null) {
-        if ($indexName) {
+        if (null !== $indexName) {
             $indexes = array($this->_getIndex($indexName));
         } else {
             $indexes = $this->_getIndexes();
@@ -20,14 +20,14 @@ public function create($indexName = null) {
 
     /**
      * @param string|CM_Elasticsearch_Type_Abstract|null $indexName
-     * @param string|null                           $host Elasticsearch host
-     * @param int|null                              $port Elasticsearch port
+     * @param string|null                                $host Elasticsearch host
+     * @param int|null                                   $port Elasticsearch port
      * @throws CM_Exception_Invalid
      */
     public function update($indexName = null, $host = null, $port = null) {
         if ($indexName instanceof CM_Elasticsearch_Type_Abstract) {
             $indexes = array($indexName);
-        } elseif ($indexName) {
+        } elseif (null !== $indexName) {
             $indexes = array($this->_getIndex($indexName, $host, $port));
         } else {
             $indexes = $this->_getIndexes($host, $port);
@@ -55,6 +55,20 @@ public function update($indexName = null, $host = null, $port = null) {
         }
     }
 
+    /**
+     * @param string|null $indexName
+     */
+    public function delete($indexName = null) {
+        if (null !== $indexName) {
+            $indexes = array($this->_getIndex($indexName));
+        } else {
+            $indexes = $this->_getIndexes();
+        }
+        foreach ($indexes as $index) {
+            $index->getIndex()->delete();
+        }
+    }
+
     public function optimize() {
         $servers = CM_Config::get()->CM_Elasticsearch_Client->servers;
         foreach ($servers as $server) {