feat: Add config validation

linc · Dec 27, 2024 · c20d9e9 · c20d9e9
1 parent a780e90
commit c20d9e9
Show file tree

Hide file tree

Showing 2 changed files with 28 additions and 4 deletions.
diff --git a/src/Config.php b/src/Config.php
@@ -69,8 +69,36 @@ public function getConnectionAlias(string $alias): array
         foreach ($this->config['connections'] as $connection) {
             if ($alias === $connection['alias']) {
                 $result = $connection;
+                break;
             }
         }
+
+        $this->validateConnectionInfo($alias, $result);
+
         return $result;
     }
+
+    /**
+     * Validate config has required info.
+     *
+     * @param string $alias
+     * @param array $info
+     */
+    protected function validateConnectionInfo(string $alias, array $info): void
+    {
+        // Type is required.
+        if (empty($info['type'])) {
+            trigger_error('Config error: No connection `type` for alias "' . $alias . '"', E_USER_ERROR);
+        }
+
+        // Database required fields.
+        if ($info['type'] === 'database') {
+            foreach (['adapter', 'host','name','user'] as $required_field) {
+                if (!array_key_exists($required_field, $info)) {
+                    trigger_error('Config error: Database `' . $required_field .
+                        '` missing for alias "' . $alias . '"', E_USER_ERROR);
+                }
+            }
+        }
+    }
 }
diff --git a/src/ConnectionManager.php b/src/ConnectionManager.php
@@ -38,10 +38,6 @@ public function __construct(string $alias = '')
             $info = Config::getInstance()->getTestConnection();
         }
 
-        if (!isset($info['type'])) {
-            trigger_error('Config error: Connection `type` not found for  "' . $alias . '"', E_USER_ERROR);
-        }
-
         $this->setInfo($info);
         $this->setType($info['type']);