simple plan impl

src/Bridges/SymfonyConsole/CreateCommand.php

@@ -11,6 +11,7 @@
 
 use Nette\Utils\Strings;
 use Nextras;
+use Nextras\Migrations\Engine\Plan;
 use Nextras\Migrations\Entities\Group;
 use Symfony\Component\Console\Input\InputArgument;
 use Symfony\Component\Console\Input\InputInterface;
@@ -68,6 +69,10 @@ protected function execute(InputInterface $input, OutputInterface $output)
 		$path = $this->getPath($group, $input->getArgument('label'));
 		$content = $this->getFileContent($group, $this->getFileContentSource($input));
 
+		$planFile = $this->config->getPlanFile();
+		$plan = new Plan($planFile);
+		$plan->append($group, basename($path));
+
 		$this->createFile($path, $content, $output);
 		$output->writeln($path);
 

src/Configurations/DefaultConfiguration.php

@@ -131,4 +131,13 @@ public function setDummyDataDiffGenerator(IDiffGenerator $generator = NULL)
 		$this->dummyDataDiffGenerator = $generator;
 	}
 
+
+	/**
+	 * @return string
+	 */
+	public function getPlanFile()
+	{
+		return $this->dir . '/plan.tsv';
+	}
+
 }

src/Engine/Plan.php

@@ -0,0 +1,65 @@
+<?php declare(strict_types=1);
+
+namespace Nextras\Migrations\Engine;
+
+use Nextras\Migrations\Entities\Group;
+use Nextras\Migrations\PlanException;
+
+
+class Plan
+{
+
+	/** @var NULL|string */
+	private $planFile;
+
+
+	/**
+	 * @param NULL|string $planFile
+	 */
+	public function __construct($planFile)
+	{
+		$this->planFile = $planFile;
+	}
+
+
+	private function getEntries(): array
+	{
+		if ($this->planFile === NULL || !file_exists($this->planFile)) {
+			return [];
+		}
+
+		$raw = file_get_contents($this->planFile);
+		$lines = preg_split("~\r?\n\r?~", $raw, -1, PREG_SPLIT_NO_EMPTY);
+		return array_map(function(string $line) {
+			return explode("\t", $line);
+		}, $lines);
+	}
+
+
+	public function append(Group $group, string $name): void
+	{
+		$entries = $this->getEntries();
+		$lastEntry = array_shift($entries);
+
+		$ord = 0;
+		if ($lastEntry !== NULL) {
+			$ord = 1 + (int) $lastEntry[0];
+		}
+
+		file_put_contents($this->planFile, "$ord\t{$group->name}\t$name\n", FILE_APPEND);
+	}
+
+
+	public function validate(): void
+	{
+		$expectedOrd = 0;
+		foreach ($this->getEntries() as $entry) {
+			if ($expectedOrd !== (int) $entry[0]) {
+				$fmtEntry = $entry[1] . ': ' . $entry[2];
+				throw new PlanException("Execution plan violation: expected ord $expectedOrd, got $entry[0] ($fmtEntry).");
+			}
+			$expectedOrd++;
+		}
+	}
+
+}

src/Engine/Runner.php

@@ -97,6 +97,9 @@ public function run($mode = self::MODE_CONTINUE, IConfiguration $config = NULL)
 			}
 		}
 
+		$plan = new Plan($config->getPlanFile());
+		$plan->validate();
+
 		if ($mode === self::MODE_INIT) {
 			$this->printer->printSource($this->driver->getInitTableSource() . "\n");
 			$files = $this->finder->find($this->groups, array_keys($this->extensionsHandlers));

src/IConfiguration.php

@@ -28,4 +28,10 @@ public function getGroups();
 	 */
 	public function getExtensionHandlers();
 
+
+	/**
+	 * @return NULL|string
+	 */
+	public function getPlanFile();
+
 }

src/exceptions.php

@@ -26,6 +26,14 @@ class LogicException extends \LogicException implements Exception
 }
 
 
+/**
+ * Execution plan violation.
+ */
+class PlanException extends LogicException
+{
+}
+
+
 /**
  * Error during runtime.
  */