@@ -77,7 +77,7 @@ |
||
77 | 77 | * @return string |
78 | 78 | */ |
79 | 79 | public function getDirection() { |
80 | - return $this->direction; |
|
80 | + return $this->direction; |
|
81 | 81 | } |
82 | 82 | |
83 | 83 | /** |
@@ -20,8 +20,6 @@ |
||
20 | 20 | namespace Baleen\Migrations\Service\Runner; |
21 | 21 | |
22 | 22 | use Baleen\Migrations\Exception\Service\Runner\RunnerException; |
23 | -use Baleen\Migrations\Service\MigrationBus\MigrationBus; |
|
24 | -use Baleen\Migrations\Service\MigrationBus\MigrationBusInterface; |
|
25 | 23 | use Baleen\Migrations\Migration\OptionsInterface; |
26 | 24 | use Baleen\Migrations\Service\Runner\Event\Migration\MigrateAfterEvent; |
27 | 25 | use Baleen\Migrations\Service\Runner\Event\Migration\MigrateBeforeEvent; |
@@ -47,7 +47,7 @@ |
||
47 | 47 | $filter = function (VersionInterface $v) use ($target, $comparator, $direction) { |
48 | 48 | return ($direction->isUp() ^ $v->isMigrated()) // direction must be opposite to migration status |
49 | 49 | && $comparator->compare($v, $target) <= 0; // version must be before or be equal to target (not |
50 | - // affected by direction because comparator is reversed) |
|
50 | + // affected by direction because comparator is reversed) |
|
51 | 51 | }; |
52 | 52 | $collection = $collection->filter($filter)->sort($comparator); |
53 | 53 |
@@ -83,7 +83,7 @@ discard block |
||
83 | 83 | * |
84 | 84 | * @param string|integer $key The kex/index of the element to remove. |
85 | 85 | * |
86 | - * @return mixed The removed element or NULL, if the collection did not contain the element. |
|
86 | + * @return null|DeltaInterface The removed element or NULL, if the collection did not contain the element. |
|
87 | 87 | */ |
88 | 88 | public function remove($key); |
89 | 89 | |
@@ -99,7 +99,7 @@ discard block |
||
99 | 99 | /** |
100 | 100 | * Gets all keys/indices of the collection. |
101 | 101 | * |
102 | - * @return array The keys/indices of the collection, in the order of the corresponding |
|
102 | + * @return integer[] The keys/indices of the collection, in the order of the corresponding |
|
103 | 103 | * elements in the collection. |
104 | 104 | */ |
105 | 105 | public function getKeys(); |
@@ -188,7 +188,7 @@ discard block |
||
188 | 188 | * |
189 | 189 | * @param Closure $func |
190 | 190 | * |
191 | - * @return array |
|
191 | + * @return \Baleen\Migrations\Delta\DeltaId[] |
|
192 | 192 | */ |
193 | 193 | public function map(Closure $func); |
194 | 194 | |
@@ -214,7 +214,7 @@ discard block |
||
214 | 214 | * @param int $offset The offset to start from. |
215 | 215 | * @param int|null $length The maximum number of elements to return, or null for no limit. |
216 | 216 | * |
217 | - * @return array |
|
217 | + * @return DeltaInterface[] |
|
218 | 218 | */ |
219 | 219 | public function slice($offset, $length = null); |
220 | 220 |
@@ -70,7 +70,7 @@ |
||
70 | 70 | /** |
71 | 71 | * Update the current progress |
72 | 72 | * |
73 | - * @param $newProgress |
|
73 | + * @param integer $newProgress |
|
74 | 74 | * |
75 | 75 | * @return void |
76 | 76 | * |
@@ -141,7 +141,7 @@ |
||
141 | 141 | /** |
142 | 142 | * Add a version to the collection |
143 | 143 | * |
144 | - * @param mixed $version |
|
144 | + * @param DeltaInterface $version |
|
145 | 145 | * |
146 | 146 | * @return bool |
147 | 147 | * |
@@ -21,14 +21,12 @@ |
||
21 | 21 | |
22 | 22 | use Baleen\Migrations\Exception\InvalidArgumentException; |
23 | 23 | use Baleen\Migrations\Exception\Version\Collection\CollectionException; |
24 | -use Baleen\Migrations\Migration\Options\Direction; |
|
25 | 24 | use Baleen\Migrations\Shared\Collection\AbstractCollection; |
26 | 25 | use Baleen\Migrations\Version\Collection\Resolver\DefaultResolverStackFactory; |
27 | 26 | use Baleen\Migrations\Version\Collection\Resolver\ResolverInterface; |
28 | 27 | use Baleen\Migrations\Version\Comparator\ComparatorInterface; |
29 | 28 | use Baleen\Migrations\Version\Comparator\MigrationComparator; |
30 | 29 | use Baleen\Migrations\Version\VersionInterface; |
31 | -use Zend\Stdlib\ArrayUtils; |
|
32 | 30 | |
33 | 31 | /** |
34 | 32 | * Class CollectionAbstract. |
@@ -49,7 +49,7 @@ |
||
49 | 49 | * |
50 | 50 | * @param SingleCommand $command |
51 | 51 | * |
52 | - * @return DeltaInterface |
|
52 | + * @return boolean |
|
53 | 53 | */ |
54 | 54 | public function handle(SingleCommand $command) |
55 | 55 | { |
@@ -25,7 +25,6 @@ |
||
25 | 25 | use Baleen\Migrations\Service\Runner\Event\Collection\CollectionBeforeEvent; |
26 | 26 | use Baleen\Migrations\Common\Collection\CollectionInterface; |
27 | 27 | use Baleen\Migrations\Common\Event\Context\CollectionContext; |
28 | -use Baleen\Migrations\Common\Event\MutePublisher; |
|
29 | 28 | use Baleen\Migrations\Common\Event\Publisher\HasInternalPublisherTrait; |
30 | 29 | use Baleen\Migrations\Common\Event\PublisherInterface; |
31 | 30 | use Baleen\Migrations\Delta\Collection\Collection; |
@@ -81,12 +81,12 @@ |
||
81 | 81 | return true; // nothing to do - exit early |
82 | 82 | } |
83 | 83 | |
84 | - $mapToIds = function(DeltaInterface $v) { |
|
84 | + $mapToIds = function (DeltaInterface $v) { |
|
85 | 85 | return $v->getId(); |
86 | 86 | }; |
87 | 87 | /** @var CollectionInterface $migrated */ |
88 | 88 | /** @var CollectionInterface $notMigrated */ |
89 | - list($migrated, $notMigrated) = $versions->partition(function($i, DeltaInterface $v) { |
|
89 | + list($migrated, $notMigrated) = $versions->partition(function ($i, DeltaInterface $v) { |
|
90 | 90 | return $v->isMigrated(); |
91 | 91 | }); |
92 | 92 | $migratedIds = $migrated->map($mapToIds); |