Adding a listener to support the notion of "reset" of the database.

Author: moufmouf

composer.json

@@ -30,7 +30,7 @@
             "install": [
                 {
                   "type": "class",
-                  "class": "Mouf\\Database\\Patcher\\DatabasePatchInstaller2",
+                  "class": "Mouf\\Database\\Patcher\\DatabasePatchInstaller3",
                   "description": "Create the 'patches' table in your database to track patches applied."
                 }
             ],

src/Mouf/Database/Patcher/DatabasePatchInstaller2.php renamed to src/Mouf/Database/Patcher/DatabasePatchInstaller3.php

@@ -35,7 +35,7 @@
  *
  * @author David Negrier <[email protected]>
  */
-class DatabasePatchInstaller2 implements PackageInstallerInterface
+class DatabasePatchInstaller3 implements PackageInstallerInterface
 {
     /**
      * (non-PHPdoc)
@@ -48,7 +48,7 @@ public static function install(MoufManager $moufManager) {
         $dbConnectionDescriptor = $moufManager->getInstanceDescriptor('dbalConnection');
 
         //Let's get the instance of PatchConnection or create it if not exist
-       if ($moufManager->has('patchConnection')) {
+        if ($moufManager->has('patchConnection')) {
             $patchConnection = $moufManager->get('patchConnection');
             $patchConnectionDescriptor = $moufManager->getInstanceDescriptor('patchConnection');
         } else {
@@ -60,11 +60,15 @@ public static function install(MoufManager $moufManager) {
             $patchConnection = $moufManager->get('patchConnection');
         }
 
-        // Let's create the table.
         $existingPatches = $moufManager->findInstances("Mouf\\Database\\Patcher\\DatabasePatch");
-        foreach($existingPatches as $existingPatche){
-            $patchIntance = $moufManager->getInstanceDescriptor($existingPatche);
-            $patchIntance->getProperty('patchConnection')->setValue($patchConnectionDescriptor);
+        foreach($existingPatches as $existingPatch) {
+            $patchInstance = $moufManager->getInstanceDescriptor($existingPatch);
+            $patchInstance->getProperty('patchConnection')->setValue($patchConnectionDescriptor);
+        }
+
+        $patchServiceDescriptor = $moufManager->getInstanceDescriptor('patchService');
+        if ($patchServiceDescriptor->getProperty('listeners')->getValue() === null) {
+            $patchServiceDescriptor->getProperty('listeners')->setValue([ $patchConnectionDescriptor ]);
         }
 
         // Finally, let's change the dbalConnection configuration to add an ignore rule on the "patches" table.

src/Mouf/Database/Patcher/PatchConnection.php

@@ -21,14 +21,15 @@
 namespace Mouf\Database\Patcher;
 
 use Doctrine\DBAL\Connection;
+use Mouf\Utils\Patcher\PatchListenerInterface;
 
 
 /**
  * Class representing the patches table in database
  *
  * @author Pierre Vaidie
  */
-class PatchConnection
+class PatchConnection implements PatchListenerInterface
 {
     /**
      * @var string
@@ -39,16 +40,22 @@ class PatchConnection
      * @var Connection
      */
     private $dbalConnection;
+    /**
+     * @var Connection
+     */
+    private $dbalRootConnection;
 
     /**
      * DatabasePatchTable constructor.
-     * @param  string      $tableName
-     * @param  Connection  $dbalConnection
+     * @param  string $tableName
+     * @param  Connection $dbalConnection
+     * @param Connection|null $dbalRootConnection The DBAL connection with "root" credentials to drop and create the database again.
      */
-    public function __construct($tableName, Connection $dbalConnection)
+    public function __construct($tableName, Connection $dbalConnection, Connection $dbalRootConnection = null)
     {
         $this->tableName = $tableName;
         $this->dbalConnection = $dbalConnection;
+        $this->dbalRootConnection = $dbalRootConnection ?: $dbalConnection;
     }
 
     /**
@@ -86,4 +93,14 @@ public function getConnection() {
     public function setConnnection(Connection $dbalConnection) {
         $this->dbalConnection = $dbalConnection;
     }
+
+    /**
+     * Triggered when the 'reset()' method is called on the PatchService
+     */
+    public function onReset(): void
+    {
+        // Let's drop and recreate the database from 0!
+        $dbName = $this->dbalConnection->getDatabase();
+        $this->dbalRootConnection->getSchemaManager()->dropAndCreateDatabase($dbName);
+    }
 }