@@ -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', |
@@ -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', |
@@ -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; |
@@ -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() |