Added initialize method

Author: dantleech

.travis.yml

@@ -0,0 +1,16 @@
+language: php
+
+php:
+  - 5.4
+  - 5.5
+  - 5.6
+
+before_script:
+  - composer install
+
+script: phpunit
+
+matrix:
+  allow_failures:
+    - env: SYMFONY_VERSION=dev-master
+

lib/Migrator.php

@@ -32,6 +32,23 @@ public function __construct(
         $this->versionStorage = $versionStorage;
     }
 
+    /**
+     * Add all the migrations without running them.
+     * This should be executed on new database installations.
+     */
+    public function initialize()
+    {
+        if ($this->versionStorage->hasVersioningNode()) {
+            throw MigratorException::cannotInitializeAlreadyHasVersions();
+        }
+
+        foreach (array_keys($this->versionCollection->getAllVersions()) as $timestamp) {
+            $this->versionStorage->add($timestamp);
+        }
+
+        $this->session->save();
+    }
+
     public function migrate($to = null, OutputInterface $output)
     {
         if ($to === null) {
@@ -60,8 +77,11 @@ public function migrate($to = null, OutputInterface $output)
         }
 
         $start = microtime(true);
+        $position = 0;
+        $output->writeln(sprintf('<comment>%s</comment> %d version(s):', ($direction == 'up' ? 'Upgrading' : 'Reverting'), count($versionsToExecute)));
         foreach ($versionsToExecute as $timestamp => $version) {
-            $output->writeln('<info>Executing migration version</info>: %s', $timestamp);
+            $position++;
+            $output->writeln(sprintf(' %s [<info>%d/%d</info>]: %s', $direction == 'up' ? '+' : '-', $position, count($versionsToExecute), $timestamp));
             $version->$direction($this->session);
 
             if ($direction === 'down') {
@@ -70,14 +90,10 @@ public function migrate($to = null, OutputInterface $output)
                 $this->versionStorage->add($timestamp);
             }
 
+            $this->session->save();
         }
 
-        $this->session->save();
 
-        $output->writeln(sprintf(
-            '<info>Done. Executed </info>%s<info> migration versions</info> %s', 
-            count($versionsToExecute), number_format(microtime(true) - $start, 4)
-        ));
 
         return $versionsToExecute;
     }

lib/MigratorException.php

@@ -31,4 +31,9 @@ public static function versionNotInstance($className)
     {
         return new self(sprintf('Version class "%s" is not an instance of DTL\PhpcrMigrations\VersionInterface', $className));
     }
+
+    public static function cannotInitializeAlreadyHasVersions()
+    {
+        return new self('Cannot initiaialize a content repository with previously existing migrations.');
+    }
 }

lib/MigratorFactory.php

@@ -0,0 +1,38 @@
+<?php
+/*
+ * This file is part of the <package> package.
+ *
+ * (c) 2011-2015 Daniel Leech 
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace DTL\PhpcrMigrations;
+
+use DTL\PhpcrMigrations\VersionStorage;
+use DTL\PhpcrMigrations\VersionFinder;
+use PHPCR\SessionInterface;
+
+class MigratorFactory
+{
+    private $storage;
+    private $finder;
+    private $session;
+
+    public function __construct(
+        VersionStorage $storage,
+        VersionFinder $finder,
+        SessionInterface $session
+    )
+    {
+        $this->storage = $storage;
+        $this->finder = $finder;
+        $this->session = $session;
+    }
+
+    public function getMigrator()
+    {
+        return new Migrator($this->session, $this->finder->getCollection(), $this->storage);
+    }
+}

lib/VersionCollection.php

@@ -25,7 +25,7 @@ public function has($versionTimestamp)
         return isset($this->versions[$versionTimestamp]);
     }
 
-    public function toArray()
+    public function getAllVersions()
     {
         return $this->versions;
     }

lib/VersionManager.php

@@ -0,0 +1,18 @@
+<?php
+/*
+ * This file is part of the <package> package.
+ *
+ * (c) Daniel Leech <daniel@dantleech.com>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace DTL\PhpcrMigrations;
+
+class VersionManager
+{
+    public function __construct(
+        VersionFinder $versionFinder,
+        VersionStorage
+}

lib/VersionStorage.php

@@ -36,7 +36,8 @@ public function init()
         if (!$nodeTypeManager->hasNodeType('phpcrMigration:version')) {
             $nodeTypeManager->registerNodeTypesCnd(<<<EOT
 <phpcrMigrations = 'http://www.danteech.com/phpcr-migrations'>
-[phpcrMigrations:version] > nt:base
+[phpcrMigrations:version] > nt:base, mix:created
+
 [phpcrMigrations:versions] > nt:base
 +* (phpcrMigrations:version)
 EOT
@@ -62,6 +63,11 @@ public function getPersistedVersions()
         return $versions;
     }
 
+    public function hasVersioningNode()
+    {
+        return $this->session->nodeExists('/' . $this->storageNodeName);
+    }
+
     public function getCurrentVersion()
     {
         $this->init();
@@ -88,6 +94,6 @@ public function add($timestamp)
     {
         $this->init();
 
-        $this->storageNode->addNode($timestamp, 'phpcrMigrations:version');
+        $node = $this->storageNode->addNode($timestamp, 'phpcrMigrations:version');
     }
 }

tests/Functional/MigrationTest.php

@@ -136,6 +136,20 @@ public function testMigrateToCurrentVersionFromCurrent()
         $this->assertCount(0, $migratedVersions);
     }
 
+    /**
+     * It should add all migrations
+     */
+    public function testInitialize()
+    {
+        $this->addVersion(self::VERSION1);
+        $this->addVersion(self::VERSION2);
+        $this->getMigrator()->initialize();
+
+        $nodes = $this->session->getNode('/phpcrMigrations:versions')->getNodes();
+
+        $this->assertCount(2, $nodes);
+    }
+
     private function addVersion($version)
     {
         $this->filesystem->copy(

tests/Unit/MigratorFactoryTest.php

@@ -0,0 +1,31 @@
+<?php
+
+namespace DTL\PhpcrMigrations\Tests\Unit;
+
+use DTL\PhpcrMigrations\VersionFinder;
+use DTL\PhpcrMigrations\VersionCollection;
+use DTL\PhpcrMigrations\VersionInterface;
+use DTL\PhpcrMigrations\VersionStorage;
+use DTL\PhpcrMigrations\Migrator;
+use DTL\PhpcrMigrations\MigratorFactory;
+use PHPCR\SessionInterface;
+
+class MigratorFactoryTest extends \PHPUnit_Framework_TestCase
+{
+    public function testFactory()
+    {
+        $storage = $this->prophesize(VersionStorage::class);
+        $finder = $this->prophesize(VersionFinder::class);
+        $session = $this->prophesize(SessionInterface::class);
+        $finder->getCollection()->willReturn($this->prophesize(VersionCollection::class)->reveal());
+
+        $factory = new MigratorFactory(
+            $storage->reveal(), 
+            $finder->reveal(),
+            $session->reveal()
+        );
+        $migrator = $factory->getMigrator();
+        $this->assertInstanceOf(Migrator::class, $migrator);
+    }
+}
+

tests/Unit/VersionFinderTest.php

@@ -21,7 +21,7 @@ public function testGetCollection()
     {
         $collection = $this->finder->getCollection();
         $this->assertInstanceOf(VersionCollection::class, $collection);
-        $versions = $collection->toArray();
+        $versions = $collection->getAllVersions();
         $this->assertCount(2, $versions);
     }