Adaptation of the connections method.

Author: walkor

src/RedisManager.php

@@ -6,6 +6,7 @@
 use Illuminate\Redis\Connections\Connection;
 use StdClass;
 use Throwable;
+use WeakMap;
 use Webman\Context;
 use Workerman\Coroutine\Pool;
 
@@ -16,6 +17,11 @@ class RedisManager extends \Illuminate\Redis\RedisManager
      */
     protected static array $pools = [];
 
+    /**
+     * @var WeakMap
+     */
+    protected WeakMap $allConnections;
+
     /**
      * Get connection.
      *
@@ -37,6 +43,8 @@ public function connection($name = null)
                     if (class_exists(Dispatcher::class)) {
                         $connection->setEventDispatcher(new Dispatcher());
                     }
+                    $this->allConnections ??= new WeakMap();
+                    $this->allConnections[$connection] = true;
                     return $connection;
                 });
                 $pool->setConnectionCloser(function ($connection) {
@@ -62,4 +70,21 @@ public function connection($name = null)
         }
         return $connection;
     }
+
+    /**
+     * Return all the created connections.
+     *
+     * @return array
+     */
+    public function connections()
+    {
+        if (empty($this->allConnections)) {
+            return [];
+        }
+        $connections = [];
+        foreach ($this->allConnections as $connection => $_) {
+            $connections[] = $connection;
+        }
+        return $connections;
+    }
 }