[8.x] Fix flushdb for predis cluster (#40446)

* Fix flushdb for predis cluster

* move flushdb to PredisClusterConnection

* add back flushdb

* use `Predis\Client` iterator to get all nodes

* return void

otherwise it would return `Predis\Response\Status`

* skip method all togehter

* support `ASYNC` argument

* Update PredisClusterConnection.php

* fix typo

* Update PredisClusterConnection.php

Co-authored-by: Bernard Wiesner <[email protected]>
Co-authored-by: Till Krüss <[email protected]>
Co-authored-by: Taylor Otwell <[email protected]>

Author: 4 people

src/Illuminate/Redis/Connections/PredisClusterConnection.php

@@ -2,7 +2,19 @@
 
 namespace Illuminate\Redis\Connections;
 
+use Predis\Command\ServerFlushDatabase;
+
 class PredisClusterConnection extends PredisConnection
 {
-    //
+    /**
+     * Flush the selected Redis database on all cluster nodes.
+     *
+     * @return void
+     */
+    public function flushdb()
+    {
+        $this->client->executeCommandOnNodes(
+            tap(new ServerFlushDatabase)->setArguments(func_get_args())
+        );
+    }
 }

src/Illuminate/Redis/Connections/PredisConnection.php

@@ -4,8 +4,6 @@
 
 use Closure;
 use Illuminate\Contracts\Redis\Connection as ConnectionContract;
-use Predis\Command\ServerFlushDatabase;
-use Predis\Connection\Aggregate\ClusterInterface;
 
 /**
  * @mixin \Predis\Client
@@ -52,20 +50,4 @@ 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 ClusterInterface) {
-            return $this->command('flushdb');
-        }
-
-        foreach ($this->getConnection() as $node) {
-            $node->executeCommand(new ServerFlushDatabase);
-        }
-    }
 }