tarantool-php / mapper

src/Plugin/Temporal/Aggregator.php

Doc Comments +3 added lines

@@ -285,6 +285,9 @@
         return $slices;
     }
 
+    /**
+     * @param \Closure $callback
+     */
     private function generateStates($changes, $callback)
     {
         $slices = [];

Spacing +9 added lines, -9 removed lines

@@ -40,7 +40,7 @@ 
         ];
 
         $changes = $mapper->find('_temporal_reference', $params);
-        $states = $this->generateStates($changes, function ($state, $change) {
+        $states = $this->generateStates($changes, function($state, $change) {
             $state->data = $change->targetId;
         });
 
@@ -66,7 +66,7 @@ 
                 'targetId' => $entityId,
                 'entity' => $params['entity'],
             ]);
-            $aggregates = $this->generateStates($changes, function ($state, $change) {
+            $aggregates = $this->generateStates($changes, function($state, $change) {
                 if (!in_array($change->id, $state->data)) {
                     $state->data[] = $change->id;
                 }
@@ -214,11 +214,11 @@ 
             while (!$clean) {
                 $clean = true;
                 foreach ($states as $i => $state) {
-                    if (array_key_exists($i+1, $states)) {
-                        $next = $states[$i+1];
+                    if (array_key_exists($i + 1, $states)) {
+                        $next = $states[$i + 1];
                         if (json_encode($state->data) == json_encode($next->data)) {
                             $states[$i]->end = $next->end;
-                            unset($states[$i+1]);
+                            unset($states[$i + 1]);
                             $states = array_values($states);
                             $clean = false;
                             break;
@@ -242,7 +242,7 @@ 
         ];
 
         $changes = $mapper->find('_temporal_override', $params);
-        $states = $this->generateStates($changes, function ($state, $change) {
+        $states = $this->generateStates($changes, function($state, $change) {
             $state->data = array_merge($state->data, $change->data);
         });
         foreach ($mapper->find('_temporal_override_aggregate', $params) as $aggregate) {
@@ -340,11 +340,11 @@ 
         while (!$clean) {
             $clean = true;
             foreach ($states as $i => $state) {
-                if (array_key_exists($i+1, $states)) {
-                    $next = $states[$i+1];
+                if (array_key_exists($i + 1, $states)) {
+                    $next = $states[$i + 1];
                     if (json_encode($state->data) == json_encode($next->data)) {
                         $state->end = $next->end;
-                        unset($states[$i+1]);
+                        unset($states[$i + 1]);
                         $states = array_values($states);
                         $clean = false;
                         break;