Database Tables Check

src/Checks/BaseCheck.php

@@ -3,7 +3,7 @@
 
 use Health\Builder\HealthCheckResponseBuilder;
 
-abstract class BaseCheck implements HealthCheckInterface
+abstract class BaseCheck
 {
 
     /**

src/Checks/Servers/Database.php

@@ -20,10 +20,10 @@ public function call()
         try {
             DB::connection()->getPdo();
             if (! DB::connection()->getDatabaseName()) {
-                $builder->state(false)->withData("error", "Could not find the database.");
+                $builder->down()->withData("error", "Could not find the database.");
             }
         } catch (\Exception $e) {
-            $builder->state(false)->withData("error", "Could not open connection to database server.");
+            $builder->down()->withData("error", "Could not open connection to database server.");
         }
 
         return $builder->build();

src/Checks/Servers/DatabaseTables.php

@@ -0,0 +1,43 @@
+<?php
+namespace Health\Checks\Servers;
+
+use Health\Checks\HealthCheckInterface;
+use DB;
+use Health\HealthCheck;
+
+class DatabaseTables extends Database implements HealthCheckInterface
+{
+
+    /**
+     *
+     * {@inheritdoc}
+     * @see \Health\Checks\HealthCheckInterface::call()
+     */
+    public function call()
+    {
+        $health = parent::call();
+
+        if ($health->getState() == HealthCheck::STATE_UP) {
+
+            $builder = $this->getBuilder();
+
+            $tables = $this->params['tables'] ?? [];
+            $missing = [];
+            foreach ($tables as $table) {
+                if (! DB::getSchemaBuilder()->hasTable($table)) {
+                    $missing[] = $table;
+
+                    $builder->down();
+                }
+            }
+
+            if ($missing) {
+                $builder->withData('missing', $missing);
+            }
+
+            $health = $builder->build();
+        }
+
+        return $health;
+    }
+}

tests/Checks/CheckTestCase.php

@@ -8,7 +8,7 @@ class CheckTestCase extends \Orchestra\Testbench\TestCase
 
     protected function assertCheck($health, string $state = 'UP')
     {
-        // dd($health);
+        // dump($health);
         $this->assertInstanceOf(HealthCheck::class, $health);
         $this->assertNotEmpty($health->getName());
         $this->assertEquals($state, $health->getState());

tests/Checks/DatabaseTablesTest.php

@@ -0,0 +1,57 @@
+<?php
+namespace Tests\Checks;
+
+use Health\Checks\Servers\DatabaseTables;
+use Schema;
+
+class DatabaseTablesTest extends CheckTestCase
+{
+
+    /**
+     * Define environment setup.
+     *
+     * @param \Illuminate\Foundation\Application $app
+     * @return void
+     */
+    protected function getEnvironmentSetUp($app)
+    {
+        // Setup default database to use sqlite :memory:
+        $app['config']->set('database.default', 'testing');
+        $app['config']->set('database.connections.testing', [
+            'driver' => 'sqlite',
+            'database' => ':memory:',
+            'prefix' => ''
+        ]);
+    }
+
+    public function testCheckUpForEmptyTablesList()
+    {
+        $this->assertCheck($this->runCheck(DatabaseTables::class), 'UP');
+    }
+
+
+    public function testCheckUpForExistingNonExistingTable()
+    {
+        Schema::create('users', function ($table) {
+            $table->increments('id');
+        });
+
+        $check = $this->runCheck(DatabaseTables::class, [
+            'tables' => [
+                'users'
+            ]
+        ]);
+
+        $this->assertCheck($check, 'UP');
+
+        Schema::drop('users');
+
+        $check = $this->runCheck(DatabaseTables::class, [
+            'tables' => [
+                'users'
+            ]
+        ]);
+
+        $this->assertCheck($check, 'DOWN');
+    }
+}

tests/Checks/DatabaseTest.php

@@ -23,7 +23,7 @@ protected function getEnvironmentSetUp($app)
         ]);
     }
 
-    public function testCheckDown()
+    public function testCheckUp()
     {
         $this->assertCheck($this->runCheck(Database::class), 'UP');
     }