fix tests and introduce WarmUpService

Author: apacheborys

composer.json

@@ -32,7 +32,8 @@
     "autoload": {
         "psr-4": {
             "ApacheBorys\\Retry\\BasicTransport\\": "src/BasicTransport",
-            "ApacheBorys\\Retry\\BasicExecutor\\": "src/BasicExecutor"
+            "ApacheBorys\\Retry\\BasicExecutor\\": "src/BasicExecutor",
+            "ApacheBorys\\Retry\\Common\\": "src/Common"
         }
     },
     "autoload-dev": {

src/BasicTransport/Migration/DbPdoTransportMigration.php

@@ -115,7 +115,7 @@ public function version(): int
         return 1;
     }
 
-    public function support(): array
+    public static function support(): array
     {
         return [DbPdoTransport::class];
     }
@@ -127,9 +127,14 @@ public function wasExecuted(): bool
             $this->compileDbAndTableName($this->migrationTableName),
             $this->version()
         );
-        $res = $this->pdo->query($sql);
 
-        return $res->fetchColumn() != 0;
+        try {
+            $res = $this->pdo->query($sql);
+
+            return $res->fetchColumn() != 0;
+        } catch (\PDOException $e) {
+            return false;
+        }
     }
 
     private function compileDbAndTableName(string $tableName): string

src/BasicTransport/Migration/MigrationInterface.php

@@ -12,7 +12,7 @@ public function rollback(): bool;
     public function version(): int;
 
     /** @return string[] Transport classes what support current migration */
-    public function support(): array;
+    public static function support(): array;
 
     public function wasExecuted(): bool;
 }

src/BasicTransport/Migration/Migrator.php

@@ -24,7 +24,10 @@ private function getAllMigrationsForTransport(array $context, string $transportC
         $migrations = [];
 
         foreach (get_declared_classes() as $className) {
-            if (in_array(MigrationInterface::class, class_implements($className))) {
+            if (
+                in_array(MigrationInterface::class, class_implements($className), true) &&
+                in_array($transportClass, $className::support(), true)
+            ) {
                 $migrations[] = $className;
             }
         }
@@ -37,13 +40,6 @@ static function (string $migration) use ($context) {
             $migrations
         );
 
-        $migrations = array_filter(
-            $migrations,
-            static function (MigrationInterface $migration) use ($transportClass) {
-                return in_array($transportClass, $migration->support());
-            }
-        );
-
         $result = [];
         foreach ($migrations as $migration) {
             $result[$migration->version()] = $migration;

src/BasicTransport/Migration/MongoDbTransportMigration.php

@@ -67,7 +67,7 @@ public function version(): int
         return 1;
     }
 
-    public function support(): array
+    public static function support(): array
     {
         return [MongoDbTransport::class];
     }

src/Common/WarmUpService.php

@@ -0,0 +1,48 @@
+<?php
+declare(strict_types=1);
+
+namespace ApacheBorys\Retry\Common;
+
+class WarmUpService
+{
+    public const FILES_FOR_IGNORE = [
+        __DIR__ . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . 'tests' . DIRECTORY_SEPARATOR . 'BasicExecutor' . DIRECTORY_SEPARATOR . 'test.php',
+    ];
+
+    public function registerAllClasses(): void
+    {
+        $srcLocation = __DIR__ . DIRECTORY_SEPARATOR . '..';
+        $testsLocation = __DIR__ . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . 'tests';
+
+        $filesForIgnore = array_map(static function (string $path) { return realpath($path); }, self::FILES_FOR_IGNORE);
+
+        $this->loadDir($srcLocation, $filesForIgnore);
+        $this->loadDir($testsLocation, $filesForIgnore);
+    }
+
+    /**
+     * @param string[] $filesForIgnore
+     */
+    private function loadDir(string $loc, array $filesForIgnore): void
+    {
+        foreach (scandir($loc) as $item) {
+            if ($item === '..' || $item === '.') {
+                continue;
+            }
+
+            $fullPath = $loc . DIRECTORY_SEPARATOR . $item;
+
+            if (is_dir($fullPath)) {
+                $this->loadDir($fullPath, $filesForIgnore);
+            }
+
+            if (in_array(realpath($fullPath), $filesForIgnore,true)) {
+                continue;
+            }
+
+            if (pathinfo($fullPath)['extension'] ?? '' === 'php') {
+                require_once $fullPath;
+            }
+        }
+    }
+}

tests/BasicTransport/TransportTest.php

@@ -3,7 +3,7 @@
 
 namespace ApacheBorys\Retry\BasicTransport\Tests;
 
-use ApacheBorys\Retry\BasicTransport\Migration\MigrationInterface;
+use ApacheBorys\Retry\Common\WarmUpService;
 use ApacheBorys\Retry\Entity\Config;
 use ApacheBorys\Retry\Entity\Message;
 use ApacheBorys\Retry\Interfaces\Transport;
@@ -31,6 +31,9 @@ public static function setUpBeforeClass(): void
     {
         parent::setUpBeforeClass();
 
+        $warmUp = new WarmUpService();
+        $warmUp->registerAllClasses();
+
         foreach (self::getTestsForTransports() as $transport) {
             $transport->setUpBeforeClass();
         }