tarantool-php / mapper

src/Repository.php

Spacing +52 added lines, -52 removed lines

@@ -25,20 +25,20 @@ 
     {
         $data = (array) $data;
         $class = Entity::class;
-        foreach($this->space->getMapper()->getPlugins() as $plugin) {
+        foreach ($this->space->getMapper()->getPlugins() as $plugin) {
             $entityClass = $plugin->getEntityClass($this->space);
-            if($entityClass) {
-                if($class != Entity::class) {
+            if ($entityClass) {
+                if ($class != Entity::class) {
                     throw new Exception('Entity class override');
                 }
                 $class = $entityClass;
             }
         }
 
-        if(array_key_exists(0, $data)) {
+        if (array_key_exists(0, $data)) {
             $byType = [];
-            foreach($this->space->getFormat() as $row) {
-                if(!array_key_exists($row['type'], $byType)) {
+            foreach ($this->space->getFormat() as $row) {
+                if (!array_key_exists($row['type'], $byType)) {
                     $byType[$row['type']] = [$row['name']];
                 } else {
                     $byType[$row['type']][] = $row['name'];
@@ -49,10 +49,10 @@ 
                 'is_string' => 'str',
                 'is_array' => '*',
             ];
-            foreach($data as $k => $v) {
-                foreach($mapping as $function => $type) {
-                    if(call_user_func($function, $v)) {
-                        if(count($byType[$type]) == 1) {
+            foreach ($data as $k => $v) {
+                foreach ($mapping as $function => $type) {
+                    if (call_user_func($function, $v)) {
+                        if (count($byType[$type]) == 1) {
                             $data[$byType[$type][0]] = $v;
                             unset($data[$k]);
                         }
@@ -62,16 +62,16 @@ 
         }
 
         $instance = new $class($this);
-        foreach($this->space->getFormat() as $row) {
-            if(array_key_exists($row['name'], $data)) {
+        foreach ($this->space->getFormat() as $row) {
+            if (array_key_exists($row['name'], $data)) {
                 $instance->{$row['name']} = $data[$row['name']];
-                if($data[$row['name']] instanceof Entity) {
+                if ($data[$row['name']] instanceof Entity) {
                     $instance->{$row['name']} = $instance->{$row['name']}->id;
                 }
             }
         }
 
-        foreach($this->space->getMapper()->getPlugins() as $plugin) {
+        foreach ($this->space->getMapper()->getPlugins() as $plugin) {
             $plugin->generateKey($instance, $this->space);
         }
 
@@ -90,18 +90,18 @@ 
     public function find($params = [], $one = false)
     {
         $cacheIndex = array_search([$params, $one], $this->cache);
-        if($cacheIndex !== false) {
+        if ($cacheIndex !== false) {
             return $this->results[$cacheIndex];
         }
 
-        if(!is_array($params)) {
+        if (!is_array($params)) {
             $params = [$params];
         }
-        if(count($params) == 1 && array_key_exists(0, $params)) {
+        if (count($params) == 1 && array_key_exists(0, $params)) {
             $primary = $this->space->getPrimaryIndex();
-            if(count($primary->parts) == 1) {
+            if (count($primary->parts) == 1) {
                 $formatted = $this->space->getMapper()->getSchema()->formatValue($primary->parts[0][1], $params[0]);
-                if($params[0] == $formatted) {
+                if ($params[0] == $formatted) {
                     $params = [
                         $this->space->getFormat()[$primary->parts[0][0]]['name'] => $params[0]
                     ];
@@ -109,8 +109,8 @@ 
             }
         }
 
-        if(array_key_exists('id', $params)) {
-            if(array_key_exists($params['id'], $this->persisted)) {
+        if (array_key_exists('id', $params)) {
+            if (array_key_exists($params['id'], $this->persisted)) {
                 $instance = $this->persisted[$params['id']];
                 return $one ? $instance : [$instance];
             }
@@ -118,7 +118,7 @@ 
 
 
         $index = $this->space->castIndex($params);
-        if(is_null($index)) {
+        if (is_null($index)) {
             throw new Exception("No index for params ".json_encode($params));
         }
 
@@ -131,15 +131,15 @@ 
         $data = $client->getSpace($this->space->getId())->select($values, $index)->getData();
 
         $result = [];
-        foreach($data as $tuple) {
+        foreach ($data as $tuple) {
             $instance = $this->getInstance($tuple);
-            if($one) {
+            if ($one) {
                 return $this->results[$cacheIndex] = $instance;
             }
             $result[] = $instance;
         }
 
-        if($one) {
+        if ($one) {
             return $this->results[$cacheIndex] = null;
         }
 
@@ -150,15 +150,15 @@ 
     {
         $key = $this->space->getTupleKey($tuple);
 
-        if(array_key_exists($key, $this->persisted)) {
+        if (array_key_exists($key, $this->persisted)) {
             return $this->persisted[$key];
         }
 
         $class = Entity::class;
-        foreach($this->space->getMapper()->getPlugins() as $plugin) {
+        foreach ($this->space->getMapper()->getPlugins() as $plugin) {
             $entityClass = $plugin->getEntityClass($this->space);
-            if($entityClass) {
-                if($class != Entity::class) {
+            if ($entityClass) {
+                if ($class != Entity::class) {
                     throw new Exception('Entity class override');
                 }
                 $class = $entityClass;
@@ -168,7 +168,7 @@ 
 
         $this->original[$key] = $tuple;
 
-        foreach($this->space->getFormat() as $index => $info) {
+        foreach ($this->space->getFormat() as $index => $info) {
             $instance->{$info['name']} = array_key_exists($index, $tuple) ? $tuple[$index] : null;
         }
 
@@ -184,26 +184,26 @@ 
 
     public function update(Entity $instance, $operations)
     {
-        if(!count($operations)) {
+        if (!count($operations)) {
             return;
         }
 
         $tupleOperations = [];
-        foreach($operations as $operation) {
+        foreach ($operations as $operation) {
             $tupleIndex = $this->space->getPropertyIndex($operation[1]);
             $tupleOperations[] = [$operation[0], $tupleIndex, $operation[2]];
         }
 
         $pk = [];
-        foreach($this->space->getPrimaryIndex()->parts as $part) {
+        foreach ($this->space->getPrimaryIndex()->parts as $part) {
             $pk[] = $instance->{$this->space->getFormat()[$part[0]]['name']};
         }
 
         $client = $this->space->getMapper()->getClient();
         $result = $client->getSpace($this->space->getId())->update($pk, $tupleOperations);
-        foreach($result->getData() as $tuple) {
-            foreach($this->space->getFormat() as $index => $info) {
-                if(array_key_exists($index, $tuple)) {
+        foreach ($result->getData() as $tuple) {
+            foreach ($this->space->getFormat() as $index => $info) {
+                if (array_key_exists($index, $tuple)) {
                     $instance->{$info['name']} = $tuple[$index];
                 }
             }
@@ -220,15 +220,15 @@ 
 
     public function remove($params = [])
     {
-        if($params instanceof Entity) {
+        if ($params instanceof Entity) {
             return $this->removeEntity($params);
         }
 
-        if(!count($params)) {
+        if (!count($params)) {
             throw new Exception("Use truncate to flush space");
         }
 
-        foreach($this->find($params) as $entity) {
+        foreach ($this->find($params) as $entity) {
             $this->removeEntity($entity);
         }
     }
@@ -237,19 +237,19 @@ 
     {
         $key = $this->space->getInstanceKey($instance);
 
-        if(!array_key_exists($key, $this->original)) {
+        if (!array_key_exists($key, $this->original)) {
             return;
         }
 
-        if(array_key_exists($key, $this->persisted)) {
+        if (array_key_exists($key, $this->persisted)) {
 
             unset($this->persisted[$key]);
 
             $pk = [];
-            foreach($this->space->getPrimaryIndex()->parts as $part) {
+            foreach ($this->space->getPrimaryIndex()->parts as $part) {
                 $pk[] = $this->original[$key][$part[0]];
             }
-            foreach($this->space->getMapper()->getPlugins() as $plugin) {
+            foreach ($this->space->getMapper()->getPlugins() as $plugin) {
                 $plugin->beforeRemove($instance, $this->space);
             }
 
@@ -271,8 +271,8 @@ 
         $size = count(get_object_vars($instance));
         $skipped = 0;
 
-        foreach($this->space->getFormat() as $index => $info) {
-            if(!property_exists($instance, $info['name'])) {
+        foreach ($this->space->getFormat() as $index => $info) {
+            if (!property_exists($instance, $info['name'])) {
                 $skipped++;
                 $instance->{$info['name']} = null;
             }
@@ -281,7 +281,7 @@ 
                 ->formatValue($info['type'], $instance->{$info['name']});
             $tuple[$index] = $instance->{$info['name']};
 
-            if(count($tuple) == $size + $skipped) {
+            if (count($tuple) == $size + $skipped) {
                 break;
             }
         }
@@ -289,24 +289,24 @@ 
         $key = $this->space->getInstanceKey($instance);
         $client = $this->space->getMapper()->getClient();
 
-        if(array_key_exists($key, $this->persisted)) {
+        if (array_key_exists($key, $this->persisted)) {
             // update
             $update = array_diff_assoc($tuple, $this->original[$key]);
-            if(!count($update)) {
+            if (!count($update)) {
                 return $instance;
             }
 
             $operations = [];
-            foreach($update as $index => $value) {
+            foreach ($update as $index => $value) {
                 $operations[] = ['=', $index, $value];
             }
 
             $pk = [];
-            foreach($this->space->getPrimaryIndex()->parts as $part) {
+            foreach ($this->space->getPrimaryIndex()->parts as $part) {
                 $pk[] = $this->original[$key][$part[0]];
             }
 
-            foreach($this->space->getMapper()->getPlugins() as $plugin) {
+            foreach ($this->space->getMapper()->getPlugins() as $plugin) {
                 $plugin->beforeUpdate($instance, $this->space);
             }
 
@@ -315,7 +315,7 @@ 
 
         } else {
 
-            foreach($this->space->getMapper()->getPlugins() as $plugin) {
+            foreach ($this->space->getMapper()->getPlugins() as $plugin) {
                 $plugin->beforeCreate($instance, $this->space);
             }