Add custom connection checker

Author: abnegate

src/Database/Connection.php

@@ -0,0 +1,37 @@
+<?php
+
+namespace Utopia\Database;
+
+use Swoole\Database\DetectsLostConnections;
+
+class Connection
+{
+    /**
+     * @var array<string>
+     */
+    protected static array $errors = [
+        'Max connect timeout reached'
+    ];
+
+    /**
+     * Check if the given throwable was caused by a database connection error.
+     *
+     * @param \Throwable $e
+     * @return bool
+     */
+    public static function hasDatabaseError(\Throwable $e): bool
+    {
+        if (DetectsLostConnections::causedByLostConnection($e)) {
+            return true;
+        }
+
+        $message = $e->getMessage();
+        foreach (static::$errors as $needle) {
+            if (\mb_strpos($message, $needle) !== false) {
+                return true;
+            }
+        }
+
+        return false;
+    }
+}

src/Database/PDO.php

@@ -46,7 +46,7 @@ public function __call(string $method, array $args): mixed
             return $this->pdo->{$method}(...$args);
         } catch (\Throwable $e) {
             /** @phpstan-ignore-next-line can't find static method */
-            if (DetectsLostConnections::causedByLostConnection($e)) {
+            if (Connection::hasDatabaseError($e)) {
                 Console::warning('[Database] Lost connection detected. Reconnecting...');
                 $this->reconnect();
                 return $this->pdo->{$method}(...$args);