From 617adeea6f45d2f3ed5f8578f5af3e99ca4e8c84 Mon Sep 17 00:00:00 2001
From: TacticalFreak <RedKage@gmail.com>
Date: Sun, 2 May 2021 14:08:23 +0200
Subject: [PATCH] Support for mysql unix socket

This will add support for connecting with a unix socket path to the mysql database.
Users will need to set their `PSM_DB_HOST` the unix socket path starting with an ":" symbol, like so
`:/home/xxxxxx/var/run/mysql.sock`

I stole this way idea of using the database host to store the unix socket path from Nextcloud. They do the same.

Related: https://github.com/phpservermon/phpservermon/issues/1118
---
 src/psm/Service/Database.php | 29 +++++++++++++++++++++--------
 1 file changed, 21 insertions(+), 8 deletions(-)

diff --git a/src/psm/Service/Database.php b/src/psm/Service/Database.php
index 5d69dd55..c839c24e 100644
--- a/src/psm/Service/Database.php
+++ b/src/psm/Service/Database.php
@@ -533,16 +533,29 @@ class Database
      */
     protected function connect()
     {
+        $isHostUnixSocket = strpos($this->db_host, ':') === 0;
+
         // Initizale connection
         try {
-            $this->pdo = new \PDO(
-                'mysql:host=' . $this->db_host .
-                    ';port=' . $this->db_port .
-                    ';dbname=' . $this->db_name .
-                    ';charset=utf8',
-                $this->db_user,
-                $this->db_pass
-            );
+            if ($isHostUnixSocket) {
+                $this->pdo = new \PDO(
+                    'mysql:unix_socket=' . ltrim($this->db_host, ':') .
+                        ';dbname=' . $this->db_name .
+                        ';charset=utf8',
+                    $this->db_user,
+                    $this->db_pass
+                );
+            } else {
+                $this->pdo = new \PDO(
+                    'mysql:host=' . $this->db_host .
+                        ';port=' . $this->db_port .
+                        ';dbname=' . $this->db_name .
+                        ';charset=utf8',
+                    $this->db_user,
+                    $this->db_pass
+                );
+            }
+
             $this->pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
             $this->status = true;
         } catch (\PDOException $e) {