tarantool-php / mapper

src/Mapper.php

Spacing +10 added lines, -10 removed lines

@@ -19,8 +19,8 @@ 
 
     public function addPlugin($class)
     {
-        if(!is_subclass_of($class, Plugin::class)) {
-            throw new Exception("Plugin should extend " . Plugin::class . " class");
+        if (!is_subclass_of($class, Plugin::class)) {
+            throw new Exception("Plugin should extend ".Plugin::class." class");
         }
 
         $plugin = is_object($class) ? $class : new $class($this);
@@ -48,8 +48,8 @@ 
 
     public function findRepository(Entity $instance)
     {
-        foreach($this->getSchema()->getSpaces() as $space) {
-            if($space->getRepository()->knows($instance)) {
+        foreach ($this->getSchema()->getSpaces() as $space) {
+            if ($space->getRepository()->knows($instance)) {
                 return $space->getRepository();
             }
         }
@@ -59,7 +59,7 @@ 
 
     public function getBootstrap()
     {
-        if(!$this->bootstrap) {
+        if (!$this->bootstrap) {
             $this->bootstrap = new Bootstrap($this);
         }
 
@@ -73,8 +73,8 @@ 
 
     public function getPlugin($class)
     {
-        foreach($this->getPlugins() as $plugin) {
-            if(is_a($plugin, $class)) {
+        foreach ($this->getPlugins() as $plugin) {
+            if (is_a($plugin, $class)) {
                 return $plugin;
             }
         }
@@ -93,8 +93,8 @@ 
     public function getRepositories()
     {
         $repositories = [];
-        foreach($this->getSchema()->getSpaces() as $space) {
-            if($space->repositoryExists()) {
+        foreach ($this->getSchema()->getSpaces() as $space) {
+            if ($space->repositoryExists()) {
                 $repositories[] = $space->getRepository();
             }
         }
@@ -108,7 +108,7 @@ 
 
     public function remove($space, $params = [])
     {
-        if($space instanceof Entity) {
+        if ($space instanceof Entity) {
             $this->findRepository($space)->removeEntity($space);
 
         } else {

src/Repository.php

Spacing +44 added lines, -44 removed lines

@@ -24,23 +24,23 @@ 
     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();
-        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']];
             }
         }
 
-        foreach($this->space->getMapper()->getPlugins() as $plugin) {
+        foreach ($this->space->getMapper()->getPlugins() as $plugin) {
             $plugin->generateKey($instance, $this->space);
         }
 
@@ -59,18 +59,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]
                     ];
@@ -78,8 +78,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];
             }
@@ -87,7 +87,7 @@ 
 
 
         $index = $this->space->castIndex($params);
-        if(is_null($index)) {
+        if (is_null($index)) {
             throw new Exception("No index for params ".json_encode($params));
         }
 
@@ -100,15 +100,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;
         }
 
@@ -119,15 +119,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;
@@ -137,7 +137,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;
         }
 
@@ -153,26 +153,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];
                 }
             }
@@ -189,15 +189,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);
         }
     }
@@ -206,19 +206,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);
             }
 
@@ -240,8 +240,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;
             }
@@ -250,7 +250,7 @@ 
                 ->formatValue($info['type'], $instance->{$info['name']});
             $tuple[$index] = $instance->{$info['name']};
 
-            if(count($tuple) == $size + $skipped) {
+            if (count($tuple) == $size + $skipped) {
                 break;
             }
         }
@@ -258,24 +258,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);
             }
 
@@ -284,7 +284,7 @@ 
 
         } else {
 
-            foreach($this->space->getMapper()->getPlugins() as $plugin) {
+            foreach ($this->space->getMapper()->getPlugins() as $plugin) {
                 $plugin->beforeCreate($instance, $this->space);
             }