mauretto78 / in-memory-list

examples/apcu/benchmark.php

Spacing +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
 
 $client = new Client('apcu');
 
-if(!$client->getRepository()->existsListInIndex('range-list')){
+if (!$client->getRepository()->existsListInIndex('range-list')) {
     $client->create($array, [
         'uuid' => 'range-list',
         'element-uuid' => 'id']);

examples/simple-array-with-headers.php

Spacing +1 added lines, -1 removed lines

@@ -35,7 +35,7 @@
 $client->getRepository()->flush();
 
 
-if(!$client->getRepository()->existsListInIndex('simple-list-with-h')){
+if (!$client->getRepository()->existsListInIndex('simple-list-with-h')) {
     $client->create($simpleArray, [
         'uuid' => 'simple-list-with-h',
         'element-uuid' => 'id',

examples/memcached/benchmark.php

Spacing +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
 
 $client = new Client('memcached', $config['memcached_parameters']);
 
-if(!$client->getRepository()->existsListInIndex('range-list')){
+if (!$client->getRepository()->existsListInIndex('range-list')) {
     $client->create($array, [
         'uuid' => 'range-list',
         'element-uuid' => 'id'

examples/redis/benchmark.php

Spacing +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
 
 $client = new Client('redis', $config['redis_parameters']);
 
-if(!$client->getRepository()->existsListInIndex('range-list')){
+if (!$client->getRepository()->existsListInIndex('range-list')) {
     $client->create($array, [
         'uuid' => 'range-list',
         'element-uuid' => 'id']);

examples/simple-array.php

Spacing +1 added lines, -1 removed lines

@@ -29,7 +29,7 @@
 $client = new Client('memcached', $config['memcached_parameters']);
 $client->getRepository()->flush();
 
-if(!$client->getRepository()->existsListInIndex('simple-list')){
+if (!$client->getRepository()->existsListInIndex('simple-list')) {
     $client->create($simpleArray, [
         'uuid' => 'simple-list',
         'element-uuid' => 'id',

src/Command/IndexCommand.php

Spacing +2 added lines, -2 removed lines

@@ -54,7 +54,7 @@ 
         if ($index && count($index)) {
             ksort($index);
             $table = new Table($output);
-            $table->setHeaders(['#', 'List', 'Created on', 'Chunks', 'Chunk size', 'Headers', 'Ttl','Expires on', 'Items']);
+            $table->setHeaders(['#', 'List', 'Created on', 'Chunks', 'Chunk size', 'Headers', 'Ttl', 'Expires on', 'Items']);
 
             $counter = 0;
             foreach ($index as $item) {
@@ -98,7 +98,7 @@ 
     protected function implodeArrayToAString(array $input)
     {
         $output = implode(', ', array_map(
-            function ($v, $k) {
+            function($v, $k) {
                 if (is_array($v)) {
                     return $k.'[]='.implode('&'.$k.'[]=', $v);
                 } else {

src/InMemoryList/Infrastructure/Persistance/MemcachedRepository.php

Spacing +1 added lines, -1 removed lines

@@ -150,7 +150,7 @@
     {
         $listFirstChunk = $this->memcached->get($listUuid.self::SEPARATOR.self::CHUNK.'-1');
 
-        if(false === $listFirstChunk){
+        if (false === $listFirstChunk) {
             return false;
         }
 

src/InMemoryList/Infrastructure/Persistance/RedisRepository.php

Spacing +6 added lines, -6 removed lines

@@ -70,7 +70,7 @@ 
         ];
 
         // persist all in a transaction
-        $this->client->transaction($options, function ($tx) use ($arrayChunks, $list, $ttl, $listUuid, $items, $chunkSize) {
+        $this->client->transaction($options, function($tx) use ($arrayChunks, $list, $ttl, $listUuid, $items, $chunkSize) {
             foreach ($arrayChunks as $chunkNumber => $item) {
                 foreach ($item as $key => $element) {
                     $listChunkUuid = $listUuid.self::SEPARATOR.self::CHUNK.'-'.($chunkNumber + 1);
@@ -127,7 +127,7 @@ 
     private function getArrayChunksKeys($listUuid, $numberOfChunks)
     {
         $arrayChunksKeys = [];
-        for($i=0;$i<$numberOfChunks;$i++){
+        for ($i = 0; $i < $numberOfChunks; $i++) {
             $arrayChunksKeys[] = $listUuid.self::SEPARATOR.self::CHUNK.'-'.($i + 1);
         }
 
@@ -152,7 +152,7 @@ 
         ];
 
         // delete in a transaction
-        $this->client->transaction($options, function ($tx) use ($listUuid, $numberOfChunks, $chunkSize, $elementUuid) {
+        $this->client->transaction($options, function($tx) use ($listUuid, $numberOfChunks, $chunkSize, $elementUuid) {
             for ($i = 1; $i <= $numberOfChunks; ++$i) {
                 $chunkNumber = $listUuid.self::SEPARATOR.self::CHUNK.'-'.$i;
                 $chunk = $this->client->hgetall($chunkNumber);
@@ -313,7 +313,7 @@ 
         ];
 
         // persist in a transaction
-        $this->client->transaction($options, function ($tx) use ($chunkNumber, $numberOfChunks, $chunkSize, $listUuid, $elementUuid, $body) {
+        $this->client->transaction($options, function($tx) use ($chunkNumber, $numberOfChunks, $chunkSize, $listUuid, $elementUuid, $body) {
             if (($chunkSize - count($tx->hgetall($chunkNumber))) === 0) {
                 ++$numberOfChunks;
                 $chunkNumber = $listUuid.self::SEPARATOR.self::CHUNK.'-'.$numberOfChunks;
@@ -370,7 +370,7 @@ 
         ];
 
         // persist in a transaction
-        $this->client->transaction($options, function ($tx) use ($numberOfChunks, $listUuid, $elementUuid, $data) {
+        $this->client->transaction($options, function($tx) use ($numberOfChunks, $listUuid, $elementUuid, $data) {
             for ($i = 1; $i <= $numberOfChunks; ++$i) {
                 $chunkNumber = $listUuid.self::SEPARATOR.self::CHUNK.'-'.$i;
                 $chunk = $this->client->hgetall($chunkNumber);
@@ -428,7 +428,7 @@ 
         ];
 
         // persist in a transaction
-        $this->client->transaction($options, function ($tx) use ($numberOfChunks, $listUuid, $ttl) {
+        $this->client->transaction($options, function($tx) use ($numberOfChunks, $listUuid, $ttl) {
             for ($i = 1; $i <= $numberOfChunks; ++$i) {
                 $tx->expire(
                     (string) $listUuid.self::SEPARATOR.self::CHUNK.'-'.$i,

src/InMemoryList/Infrastructure/Persistance/PdoRepository.php

Spacing +15 added lines, -15 removed lines

@@ -41,7 +41,7 @@ 
     {
         $this->pdo = $pdo;
 
-        if($createSchema){
+        if ($createSchema) {
             $this->createListCollectionSchema();
             $this->createListElementSchema();
         }
@@ -107,7 +107,7 @@ 
             'data' => $data,
         ];
 
-        foreach ($list->getElements() as $uuid => $element){
+        foreach ($list->getElements() as $uuid => $element) {
             /** @var ListElement $element */
 
             $sql = 'INSERT INTO `'.self::LIST_ELEMENT_TABLE_NAME.'` (
@@ -141,21 +141,21 @@ 
     private function executeQueriesInATransaction(array $statements)
     {
         try {
-            $this->pdo->setAttribute(\PDO::ATTR_ERRMODE,\PDO::ERRMODE_EXCEPTION);
+            $this->pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
 
             // beginTransaction
             $this->pdo->beginTransaction();
 
-            foreach ($statements as $statement){
-                if(isset($statement['sql'])){
+            foreach ($statements as $statement) {
+                if (isset($statement['sql'])) {
 
                     $sql = $statement['sql'];
                     $data = isset($statement['data']) ? $statement['data'] : [];
 
                     $stmt = $this->pdo->prepare($sql);
                     if (!empty($data)) {
-                        foreach ($data as $key => &$value){
-                            if(is_array($value)){
+                        foreach ($data as $key => &$value) {
+                            if (is_array($value)) {
                                 $value = serialize($value);
                             }
 
@@ -168,7 +168,7 @@ 
 
             // commit
             $this->pdo->commit();
-        } catch(\PDOException $e){
+        } catch (\PDOException $e) {
             $this->pdo->rollBack();
             throw $e;
         }
@@ -220,11 +220,11 @@ 
             \PDO::FETCH_ASSOC
         );
 
-        if(count($list) === 0){
+        if (count($list) === 0) {
             return [];
         }
 
-        foreach ($list as $item){
+        foreach ($list as $item) {
             $items[$item['uuid']] = unserialize($item['body']);
         }
 
@@ -261,7 +261,7 @@ 
         $stmt->bindParam(':uuid', $listUuid);
         $stmt->execute();
 
-        if($list = $stmt->fetchAll(\PDO::FETCH_ASSOC)){
+        if ($list = $stmt->fetchAll(\PDO::FETCH_ASSOC)) {
             $headers = $list[0]['headers'];
 
             if (SerializeChecker::isSerialized($headers)) {
@@ -292,19 +292,19 @@ 
                 JOIN `'.$lc.'` 
                 ON `'.$lt.'`.`list` = `'.$lc.'`.`uuid`';
 
-        if($listUuid){
+        if ($listUuid) {
             $sql .= 'WHERE `'.$lc.'`.`uuid` = :list';
         }
 
         $stmt = $this->pdo->prepare($sql);
-        if($listUuid){
+        if ($listUuid) {
             $stmt->bindParam(':list', $listUuid);
         }
         $stmt->execute();
 
         $list = $stmt->fetchAll(\PDO::FETCH_ASSOC);
 
-        foreach ($list as $item){
+        foreach ($list as $item) {
             $index[$item['uuid']] = [
                 'uuid' => $item['uuid'],
                 'created_on' => \DateTime::createFromFormat('Y-m-d H:i:s.u', $item['created_at']),
@@ -393,7 +393,7 @@ 
             throw new ListElementNotConsistentException('Element '.(string) $elementUuid.' is not consistent with list data.');
         }
 
-        if(is_array($updatedElementBody) || is_object($updatedElementBody)){
+        if (is_array($updatedElementBody) || is_object($updatedElementBody)) {
             $updatedElementBody = serialize($updatedElementBody);
         }