@@ -24,7 +24,7 @@ |
||
| 24 | 24 | if (!is_object($migration)) { |
| 25 | 25 | $migration = new $migration; |
| 26 | 26 | } |
| 27 | - $schema->once(get_class($migration), function () use ($migration) { |
|
| 27 | + $schema->once(get_class($migration), function() use ($migration) { |
|
| 28 | 28 | $migration->migrate($this->mapper); |
| 29 | 29 | }); |
| 30 | 30 | } |
@@ -31,7 +31,7 @@ discard block |
||
| 31 | 31 | |
| 32 | 32 | private function initLink() |
| 33 | 33 | { |
| 34 | - $this->mapper->getSchema()->once(__CLASS__.'@link', function (Mapper $mapper) { |
|
| 34 | + $this->mapper->getSchema()->once(__CLASS__.'@link', function(Mapper $mapper) { |
|
| 35 | 35 | $mapper->getSchema() |
| 36 | 36 | ->createSpace('_temporal_link', [ |
| 37 | 37 | 'id' => 'unsigned', |
@@ -62,14 +62,14 @@ discard block |
||
| 62 | 62 | ->addIndex(['entity', 'id', 'begin']); |
| 63 | 63 | }); |
| 64 | 64 | |
| 65 | - $this->mapper->getSchema()->once(__CLASS__.'@link-idle', function (Mapper $mapper) { |
|
| 65 | + $this->mapper->getSchema()->once(__CLASS__.'@link-idle', function(Mapper $mapper) { |
|
| 66 | 66 | $mapper->getSchema()->getSpace('_temporal_link')->addProperty('idle', 'unsigned'); |
| 67 | 67 | }); |
| 68 | 68 | } |
| 69 | 69 | |
| 70 | 70 | private function initOverride() |
| 71 | 71 | { |
| 72 | - $this->mapper->getSchema()->once(__CLASS__.'@states', function (Mapper $mapper) { |
|
| 72 | + $this->mapper->getSchema()->once(__CLASS__.'@states', function(Mapper $mapper) { |
|
| 73 | 73 | $mapper->getSchema() |
| 74 | 74 | ->createSpace('_temporal_override', [ |
| 75 | 75 | 'entity' => 'unsigned', |
@@ -93,14 +93,14 @@ discard block |
||
| 93 | 93 | ->addIndex(['entity', 'id', 'begin']); |
| 94 | 94 | }); |
| 95 | 95 | |
| 96 | - $this->mapper->getSchema()->once(__CLASS__.'@override-idle', function (Mapper $mapper) { |
|
| 96 | + $this->mapper->getSchema()->once(__CLASS__.'@override-idle', function(Mapper $mapper) { |
|
| 97 | 97 | $mapper->getSchema()->getSpace('_temporal_override')->addProperty('idle', 'unsigned'); |
| 98 | 98 | }); |
| 99 | 99 | } |
| 100 | 100 | |
| 101 | 101 | private function initReference() |
| 102 | 102 | { |
| 103 | - $this->mapper->getSchema()->once(__CLASS__.'@reference', function (Mapper $mapper) { |
|
| 103 | + $this->mapper->getSchema()->once(__CLASS__.'@reference', function(Mapper $mapper) { |
|
| 104 | 104 | $mapper->getSchema() |
| 105 | 105 | ->createSpace('_temporal_reference', [ |
| 106 | 106 | 'idle' => 'unsigned', |
@@ -258,6 +258,9 @@ |
||
| 258 | 258 | } |
| 259 | 259 | } |
| 260 | 260 | |
| 261 | + /** |
|
| 262 | + * @param \Closure $callback |
|
| 263 | + */ |
|
| 261 | 264 | private function generateStates($changes, $callback) |
| 262 | 265 | { |
| 263 | 266 | $slices = []; |
@@ -46,7 +46,7 @@ discard block |
||
| 46 | 46 | ]; |
| 47 | 47 | |
| 48 | 48 | $changes = $mapper->find('_temporal_reference', $params); |
| 49 | - $states = $this->generateStates($changes, function ($state, $change) { |
|
| 49 | + $states = $this->generateStates($changes, function($state, $change) { |
|
| 50 | 50 | $state->data = $change->targetId; |
| 51 | 51 | }); |
| 52 | 52 | |
@@ -77,7 +77,7 @@ discard block |
||
| 77 | 77 | 'targetId' => $entityId, |
| 78 | 78 | 'entity' => $params['entity'], |
| 79 | 79 | ]); |
| 80 | - $aggregates = $this->generateStates($changes, function ($state, $change) { |
|
| 80 | + $aggregates = $this->generateStates($changes, function($state, $change) { |
|
| 81 | 81 | if (!in_array($change->id, $state->data)) { |
| 82 | 82 | $state->data[] = $change->id; |
| 83 | 83 | } |
@@ -232,11 +232,11 @@ discard block |
||
| 232 | 232 | while (!$clean) { |
| 233 | 233 | $clean = true; |
| 234 | 234 | foreach ($states as $i => $state) { |
| 235 | - if (array_key_exists($i+1, $states)) { |
|
| 236 | - $next = $states[$i+1]; |
|
| 235 | + if (array_key_exists($i + 1, $states)) { |
|
| 236 | + $next = $states[$i + 1]; |
|
| 237 | 237 | if (json_encode($state->data) == json_encode($next->data)) { |
| 238 | 238 | $states[$i]->end = $next->end; |
| 239 | - unset($states[$i+1]); |
|
| 239 | + unset($states[$i + 1]); |
|
| 240 | 240 | $states = array_values($states); |
| 241 | 241 | $clean = false; |
| 242 | 242 | break; |
@@ -264,7 +264,7 @@ discard block |
||
| 264 | 264 | ]; |
| 265 | 265 | |
| 266 | 266 | $changes = $mapper->find('_temporal_override', $params); |
| 267 | - $states = $this->generateStates($changes, function ($state, $change) { |
|
| 267 | + $states = $this->generateStates($changes, function($state, $change) { |
|
| 268 | 268 | $state->data = array_merge($state->data, $change->data); |
| 269 | 269 | $state->exists = false; |
| 270 | 270 | }); |
@@ -344,15 +344,15 @@ discard block |
||
| 344 | 344 | while (!$clean) { |
| 345 | 345 | $clean = true; |
| 346 | 346 | foreach ($states as $i => $state) { |
| 347 | - if (array_key_exists($i+1, $states)) { |
|
| 348 | - $next = $states[$i+1]; |
|
| 347 | + if (array_key_exists($i + 1, $states)) { |
|
| 348 | + $next = $states[$i + 1]; |
|
| 349 | 349 | if ($state->end && $state->end < $next->begin) { |
| 350 | 350 | // unmergable |
| 351 | 351 | continue; |
| 352 | 352 | } |
| 353 | 353 | if (json_encode($state->data) == json_encode($next->data)) { |
| 354 | 354 | $state->end = $next->end; |
| 355 | - unset($states[$i+1]); |
|
| 355 | + unset($states[$i + 1]); |
|
| 356 | 356 | $states = array_values($states); |
| 357 | 357 | $clean = false; |
| 358 | 358 | break; |
@@ -54,7 +54,7 @@ |
||
| 54 | 54 | |
| 55 | 55 | private function initSchema() |
| 56 | 56 | { |
| 57 | - $this->mapper->getSchema()->once(__CLASS__, function ($mapper) { |
|
| 57 | + $this->mapper->getSchema()->once(__CLASS__, function($mapper) { |
|
| 58 | 58 | $mapper->getSchema() |
| 59 | 59 | ->createSpace('_procedure') |
| 60 | 60 | ->addProperties([ |
@@ -382,7 +382,7 @@ discard block |
||
| 382 | 382 | 'entityId' => $id, |
| 383 | 383 | 'parent' => $node ? $node->id : 0, |
| 384 | 384 | ]; |
| 385 | - if (count($config) == $i+1) { |
|
| 385 | + if (count($config) == $i + 1) { |
|
| 386 | 386 | $params['begin'] = $link['begin']; |
| 387 | 387 | $params['timestamp'] = 0; |
| 388 | 388 | } |
@@ -461,7 +461,7 @@ discard block |
||
| 461 | 461 | $this->mapper->getPlugin(Sequence::class); |
| 462 | 462 | } |
| 463 | 463 | |
| 464 | - $this->mapper->getSchema()->once(__CLASS__.'@entity', function (Mapper $mapper) { |
|
| 464 | + $this->mapper->getSchema()->once(__CLASS__.'@entity', function(Mapper $mapper) { |
|
| 465 | 465 | $this->mapper->getSchema() |
| 466 | 466 | ->createSpace('_temporal_entity', [ |
| 467 | 467 | 'id' => 'unsigned', |
@@ -250,6 +250,9 @@ discard block |
||
| 250 | 250 | return $this->getData($entity, $id, $date, '_temporal_override_aggregate'); |
| 251 | 251 | } |
| 252 | 252 | |
| 253 | + /** |
|
| 254 | + * @param string $space |
|
| 255 | + */ |
|
| 253 | 256 | private function getData($entity, $id, $date, $space) |
| 254 | 257 | { |
| 255 | 258 | $entity = $this->entityNameToId($entity); |
@@ -468,6 +471,9 @@ discard block |
||
| 468 | 471 | return $this; |
| 469 | 472 | } |
| 470 | 473 | |
| 474 | + /** |
|
| 475 | + * @return string |
|
| 476 | + */ |
|
| 471 | 477 | private function getTimestamp($string) |
| 472 | 478 | { |
| 473 | 479 | if (Carbon::hasTestNow() || !array_key_exists($string, $this->timestamps)) { |
@@ -33,6 +33,9 @@ |
||
| 33 | 33 | return null; |
| 34 | 34 | } |
| 35 | 35 | |
| 36 | + /** |
|
| 37 | + * @param string $space |
|
| 38 | + */ |
|
| 36 | 39 | public function mapEntity($space, $class) : self |
| 37 | 40 | { |
| 38 | 41 | $this->validateSpace($space); |
@@ -325,6 +325,9 @@ |
||
| 325 | 325 | return $this->formatNamesHash[$name]; |
| 326 | 326 | } |
| 327 | 327 | |
| 328 | + /** |
|
| 329 | + * @return string |
|
| 330 | + */ |
|
| 328 | 331 | public function getReference(string $name) : ?string |
| 329 | 332 | { |
| 330 | 333 | return $this->isReference($name) ? $this->formatReferences[$name] : null; |
@@ -166,7 +166,7 @@ discard block |
||
| 166 | 166 | if (!$this->getPropertyType($property)) { |
| 167 | 167 | throw new Exception("Unknown property $property", 1); |
| 168 | 168 | } |
| 169 | - $options['parts'][] = $this->getPropertyIndex($property)+1; |
|
| 169 | + $options['parts'][] = $this->getPropertyIndex($property) + 1; |
|
| 170 | 170 | $options['parts'][] = $this->getPropertyType($property); |
| 171 | 171 | $this->setPropertyNullable($property, false); |
| 172 | 172 | } |
@@ -199,7 +199,7 @@ discard block |
||
| 199 | 199 | |
| 200 | 200 | public function isSpecial() : bool |
| 201 | 201 | { |
| 202 | - return in_array($this->id, [ ClientSpace::VSPACE_ID, ClientSpace::VINDEX_ID ]); |
|
| 202 | + return in_array($this->id, [ClientSpace::VSPACE_ID, ClientSpace::VINDEX_ID]); |
|
| 203 | 203 | } |
| 204 | 204 | |
| 205 | 205 | public function isSystem() : bool |
@@ -46,7 +46,7 @@ |
||
| 46 | 46 | $this->mapper |
| 47 | 47 | ->getPlugin(Procedure::class) |
| 48 | 48 | ->get(CreateSequence::class) |
| 49 | - ->execute($name, $primaryIndex['name'], $primaryIndex['parts'][0][0]+1); |
|
| 49 | + ->execute($name, $primaryIndex['name'], $primaryIndex['parts'][0][0] + 1); |
|
| 50 | 50 | |
| 51 | 51 | $this->mapper->getRepository('_vsequence')->flushCache(); |
| 52 | 52 | |
@@ -44,7 +44,7 @@ |
||
| 44 | 44 | $pkIndex = null; |
| 45 | 45 | if ($key) { |
| 46 | 46 | // convert php to lua index |
| 47 | - $pkIndex = $space->getPrimaryField()+1; |
|
| 47 | + $pkIndex = $space->getPrimaryField() + 1; |
|
| 48 | 48 | if (!array_key_exists($key, $params) || !$params[$key]) { |
| 49 | 49 | $sequence = 1; |
| 50 | 50 | $space->getMapper() |