tarantool-php / mapper

src/Repository.php

Doc Comments +3 added lines

@@ -236,6 +236,9 @@
         $this->cache = [];
     }
 
+    /**
+     * @param Entity $instance
+     */
     public function save($instance)
     {
         $tuple = [];

Spacing +45 added lines, -45 removed lines

@@ -24,26 +24,26 @@ 
     public function create($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;
             }
         }
         $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);
         }
 
@@ -62,18 +62,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]
                     ];
@@ -81,8 +81,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];
             }
@@ -90,7 +90,7 @@ 
 
 
         $index = $this->space->castIndex($params);
-        if(is_null($index)) {
+        if (is_null($index)) {
             throw new Exception("No index for params ".json_encode($params));
         }
 
@@ -103,15 +103,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;
         }
 
@@ -122,15 +122,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;
@@ -140,7 +140,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;
         }
 
@@ -156,26 +156,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];
                 }
             }
@@ -192,15 +192,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);
         }
     }
@@ -209,19 +209,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);
             }
 
@@ -243,8 +243,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;
             }
@@ -253,7 +253,7 @@ 
                 ->formatValue($info['type'], $instance->{$info['name']});
             $tuple[$index] = $instance->{$info['name']};
 
-            if(count($tuple) == $size + $skipped) {
+            if (count($tuple) == $size + $skipped) {
                 break;
             }
         }
@@ -261,24 +261,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);
             }
 
@@ -287,7 +287,7 @@ 
 
         } else {
 
-            foreach($this->space->getMapper()->getPlugins() as $plugin) {
+            foreach ($this->space->getMapper()->getPlugins() as $plugin) {
                 $plugin->beforeCreate($instance, $this->space);
             }