@@ -183,6 +183,9 @@ |
||
| 183 | 183 | return $this->getData($entity, $id, $date, '_temporal_override_aggregate'); |
| 184 | 184 | } |
| 185 | 185 | |
| 186 | + /** |
|
| 187 | + * @param string $space |
|
| 188 | + */ |
|
| 186 | 189 | private function getData($entity, $id, $date, $space) |
| 187 | 190 | { |
| 188 | 191 | $entity = $this->entityNameToId($entity); |
@@ -324,7 +324,7 @@ discard block |
||
| 324 | 324 | 'entityId' => $id, |
| 325 | 325 | 'parent' => $node ? $node->id : 0, |
| 326 | 326 | ]; |
| 327 | - if (count($config) == $i+1) { |
|
| 327 | + if (count($config) == $i + 1) { |
|
| 328 | 328 | $params['begin'] = $link['begin']; |
| 329 | 329 | $params['timestamp'] = 0; |
| 330 | 330 | } |
@@ -399,7 +399,7 @@ discard block |
||
| 399 | 399 | $this->mapper->addPlugin(Sequence::class); |
| 400 | 400 | } |
| 401 | 401 | |
| 402 | - $this->mapper->getSchema()->once(__CLASS__.'@entity', function (Mapper $mapper) { |
|
| 402 | + $this->mapper->getSchema()->once(__CLASS__.'@entity', function(Mapper $mapper) { |
|
| 403 | 403 | $this->mapper->getSchema() |
| 404 | 404 | ->createSpace('_temporal_entity', [ |
| 405 | 405 | 'id' => 'unsigned', |
@@ -299,6 +299,9 @@ |
||
| 299 | 299 | $this->updateAggregation('override', $params, $changeaxis); |
| 300 | 300 | } |
| 301 | 301 | |
| 302 | + /** |
|
| 303 | + * @param string $type |
|
| 304 | + */ |
|
| 302 | 305 | public function updateAggregation($type, $params, $changeaxis) |
| 303 | 306 | { |
| 304 | 307 | $isLink = $type === 'link'; |
@@ -103,11 +103,11 @@ discard block |
||
| 103 | 103 | while (!$clean) { |
| 104 | 104 | $clean = true; |
| 105 | 105 | foreach ($states as $i => $state) { |
| 106 | - if (array_key_exists($i+1, $states)) { |
|
| 107 | - $next = $states[$i+1]; |
|
| 106 | + if (array_key_exists($i + 1, $states)) { |
|
| 107 | + $next = $states[$i + 1]; |
|
| 108 | 108 | if ($state['target'] == $next['target'] && $state['targetId'] == $next['targetId']) { |
| 109 | 109 | $states[$i]['end'] = $next['end']; |
| 110 | - unset($states[$i+1]); |
|
| 110 | + unset($states[$i + 1]); |
|
| 111 | 111 | $states = array_values($states); |
| 112 | 112 | $clean = false; |
| 113 | 113 | break; |
@@ -365,11 +365,11 @@ discard block |
||
| 365 | 365 | while (!$clean) { |
| 366 | 366 | $clean = true; |
| 367 | 367 | foreach ($states as $i => $state) { |
| 368 | - if (array_key_exists($i+1, $states)) { |
|
| 369 | - $next = $states[$i+1]; |
|
| 368 | + if (array_key_exists($i + 1, $states)) { |
|
| 369 | + $next = $states[$i + 1]; |
|
| 370 | 370 | if (json_encode($state['data']) == json_encode($next['data'])) { |
| 371 | 371 | $states[$i]['end'] = $next['end']; |
| 372 | - unset($states[$i+1]); |
|
| 372 | + unset($states[$i + 1]); |
|
| 373 | 373 | $states = array_values($states); |
| 374 | 374 | $clean = false; |
| 375 | 375 | break; |
@@ -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', |