support flush db on clusters

Author: taylorotwell

src/Illuminate/Redis/Connections/PhpRedisConnection.php

@@ -4,6 +4,7 @@
 
 use Redis;
 use Closure;
+use RedisCluster;
 use Illuminate\Contracts\Redis\Connection as ConnectionContract;
 
 /**
@@ -388,6 +389,22 @@ public function createSubscription($channels, Closure $callback, $method = 'subs
         //
     }
 
+    /**
+     * Flush the selected Redis database.
+     *
+     * @return void
+     */
+    public function flushdb()
+    {
+        if (! $this->client instanceof RedisCluster) {
+            return $this->command('flushdb');
+        }
+
+        foreach ($this->client->_masters() as [$host, $port]) {
+            tap(new Redis)->connect($host, $port)->flushDb();
+        }
+    }
+
     /**
      * Execute a raw command.
      *

src/Illuminate/Redis/Connections/PredisConnection.php

@@ -3,6 +3,8 @@
 namespace Illuminate\Redis\Connections;
 
 use Closure;
+use Predis\Command\ServerFlushDatabase;
+use Predis\Connection\Aggregate\PredisCluster;
 use Illuminate\Contracts\Redis\Connection as ConnectionContract;
 
 /**
@@ -43,4 +45,20 @@ public function createSubscription($channels, Closure $callback, $method = 'subs
 
         unset($loop);
     }
+
+    /**
+     * Flush the selected Redis database.
+     *
+     * @return void
+     */
+    public function flushdb()
+    {
+        if (! $this->client->getConnection() instanceof PredisCluster) {
+            return $this->command('flushdb');
+        }
+
+        foreach ($this->getConnection() as $node) {
+            $node->executeCommand(new ServerFlushDatabase);
+        }
+    }
 }