Add support for unix sockets

Author: RobiNN1

README.md

@@ -80,16 +80,18 @@ services:
 Redis:
 
 - `PCA_REDIS_0_NAME` The server name for an info panel. Optional, default: Localhost.
-- `PCA_REDIS_0_HOST` Redis server host.
-- `PCA_REDIS_0_PORT` Redis server port. Optional, default: 6379.
+- `PCA_REDIS_0_HOST` Redis host. Optional, when a path is specified.
+- `PCA_REDIS_0_PORT` Redis port. Optional, default: 6379.
 - `PCA_REDIS_0_DATABASE` Redis database. Optional, default: 0.
 - `PCA_REDIS_0_PASSWORD` Redis password. Optional, default: empty.
+- `PCA_REDIS_0_PATH` Redis unix path. Optional, default: /var/run/redis/redis-server.sock.
 
 Memcached:
 
 - `PCA_MEMCACHED_0_NAME` The server name for an info panel. Optional, default: Localhost.
-- `PCA_MEMCACHED_0_HOST` Memcached server host.
-- `PCA_MEMCACHED_0_PORT` Memcached server port. Optional, default: 11211.
+- `PCA_MEMCACHED_0_HOST` Memcached host. Optional, when a path is specified.
+- `PCA_MEMCACHED_0_PORT` Memcached port. Optional, default: 11211.
+- `PCA_MEMCACHED_0_PATH` Memcached unix path. Optional, default: /var/run/memcached/memcached.sock.
 
 To add another server, add the same environment variables, but change 0 to 1 (2 for third server and so on).
 

config.dist.php

@@ -23,17 +23,19 @@
     'redis'      => [
         [
             'name' => 'Localhost', // Optional
-            'host' => '127.0.0.1',
+            'host' => '127.0.0.1', // Optional, when a path is specified
             'port' => 6379, // Optional
             //'database' => 0, // Optional
             //'password' => '', // Optional
+            //'path'     => '/var/run/redis/redis-server.sock', // Optional
         ],
     ],
     'memcached'  => [
         [
             'name' => 'Localhost', // Optional
-            'host' => '127.0.0.1',
+            'host' => '127.0.0.1', // Optional, when a path is specified
             'port' => 11211, // Optional
+            //'path' => '/var/run/memcached/memcached.sock', // Optional
         ],
     ],
     'timeformat' => 'd. m. Y H:i:s',

src/Dashboards/Memcached/MemcacheCompatibility/RunCommandTrait.php

@@ -25,9 +25,13 @@ trait RunCommandTrait {
     public function runCommand(string $command): ?array {
         $data = [];
 
-        $this->server['port'] ??= 11211;
+        if (isset($this->server['path'])) {
+            $fp = stream_socket_client('unix://'.$this->server['path']);
+        } else {
+            $this->server['port'] ??= 11211;
 
-        $fp = @fsockopen($this->server['host'], (int) $this->server['port'], $error_code, $error_message, 3);
+            $fp = fsockopen($this->server['host'], (int) $this->server['port'], $error_code, $error_message, 3);
+        }
 
         if ($fp === false) {
             return null;

src/Dashboards/Memcached/MemcachedDashboard.php

@@ -72,14 +72,20 @@ private function connect(array $server) {
             throw new DashboardException('Memcache(d) extension is not installed.');
         }
 
-        $server['port'] ??= 11211;
+        if (isset($server['path'])) {
+            $memcached_server = $server['path'];
 
-        $memcache->addServer($server['host'], (int) $server['port']);
+            $memcache->addServer($server['path'], 0);
+        } else {
+            $server['port'] ??= 11211;
+
+            $memcached_server = $server['host'].':'.$server['port'];
+
+            $memcache->addServer($server['host'], (int) $server['port']);
+        }
 
         if (!$memcache->isConnected()) {
-            throw new DashboardException(
-                sprintf('Failed to connect to Memcache(d) server (%s:%s).', $server['host'], $server['port'])
-            );
+            throw new DashboardException(sprintf('Failed to connect to Memcache(d) server (%s).', $memcached_server));
         }
 
         return $memcache;

src/Dashboards/Redis/RedisDashboard.php

@@ -75,13 +75,23 @@ private function connect(array $server): Redis {
             throw new DashboardException('Redis extension is not installed.');
         }
 
-        $server['port'] ??= 6379;
+        if (isset($server['path'])) {
+            $redis_server = $server['path'];
+        } else {
+            $server['port'] ??= 6379;
+
+            $redis_server = $server['host'].':'.$server['port'];
+        }
 
         try {
-            $redis->connect($server['host'], (int) $server['port'], 3);
+            if (isset($server['path'])) {
+                $redis->connect($server['path']);
+            } else {
+                $redis->connect($server['host'], (int) $server['port'], 3);
+            }
         } catch (Exception $e) {
             throw new DashboardException(
-                sprintf('Failed to connect to Redis server (%s:%s). Error: %s', $server['host'], $server['port'], $e->getMessage())
+                sprintf('Failed to connect to Redis server (%s). Error: %s', $redis_server, $e->getMessage())
             );
         }
 
@@ -91,15 +101,15 @@ private function connect(array $server): Redis {
             }
         } catch (Exception $e) {
             throw new DashboardException(
-                sprintf('Could not authenticate with Redis server (%s:%s). Error: %s', $server['host'], $server['port'], $e->getMessage())
+                sprintf('Could not authenticate with Redis server (%s). Error: %s', $redis_server, $e->getMessage())
             );
         }
 
         try {
             $redis->select(Http::get('db', 'int', $server['database'] ?? 0));
         } catch (Exception $e) {
             throw new DashboardException(
-                sprintf('Could not select Redis database (%s:%s). Error: %s', $server['host'], $server['port'], $e->getMessage())
+                sprintf('Could not select Redis database (%s). Error: %s', $redis_server, $e->getMessage())
             );
         }