PHPSocialNetwork / phpfastcache

src/phpFastCache/Drivers/Cassandra/Driver.php

Indentation +32 added lines, -32 removed lines

@@ -73,16 +73,16 @@ 
         if ($item instanceof Item) {
             $cacheData = $this->encode($this->driverPreWrap($item));
             $options = new Cassandra\ExecutionOptions([
-              'arguments' => [
-                  'cache_uuid' => new Cassandra\Uuid(),
-                  'cache_id' => $item->getKey(),
-                  'cache_data' => $cacheData,
-                  'cache_creation_date' => new Cassandra\Timestamp((new \DateTime())->getTimestamp()),
-                  'cache_expiration_date' => new Cassandra\Timestamp($item->getExpirationDate()->getTimestamp()),
-                  'cache_length' => strlen($cacheData)
+                'arguments' => [
+                    'cache_uuid' => new Cassandra\Uuid(),
+                    'cache_id' => $item->getKey(),
+                    'cache_data' => $cacheData,
+                    'cache_creation_date' => new Cassandra\Timestamp((new \DateTime())->getTimestamp()),
+                    'cache_expiration_date' => new Cassandra\Timestamp($item->getExpirationDate()->getTimestamp()),
+                    'cache_length' => strlen($cacheData)
                 ],
-              'consistency' => Cassandra::CONSISTENCY_ALL,
-              'serial_consistency' => Cassandra::CONSISTENCY_SERIAL
+                'consistency' => Cassandra::CONSISTENCY_ALL,
+                'serial_consistency' => Cassandra::CONSISTENCY_SERIAL
             ]);
 
             $query = sprintf('INSERT INTO %s.%s
@@ -117,13 +117,13 @@ 
     {
         try {
             $options = new Cassandra\ExecutionOptions([
-              'arguments' => ['cache_id' => $item->getKey()],
-              'page_size' => 1
+                'arguments' => ['cache_id' => $item->getKey()],
+                'page_size' => 1
             ]);
             $query = sprintf(
-              'SELECT cache_data FROM %s.%s WHERE cache_id = :cache_id;',
-              self::CASSANDRA_KEY_SPACE,
-              self::CASSANDRA_TABLE
+                'SELECT cache_data FROM %s.%s WHERE cache_id = :cache_id;',
+                self::CASSANDRA_KEY_SPACE,
+                self::CASSANDRA_TABLE
             );
             $results = $this->instance->execute(new Cassandra\SimpleStatement($query), $options);
 
@@ -150,14 +150,14 @@ 
         if ($item instanceof Item) {
             try {
                 $options = new Cassandra\ExecutionOptions([
-                  'arguments' => [
+                    'arguments' => [
                     'cache_id' => $item->getKey(),
-                  ],
+                    ],
                 ]);
                 $result = $this->instance->execute(new Cassandra\SimpleStatement(sprintf(
-                  'DELETE FROM %s.%s WHERE cache_id = :cache_id;',
-                  self::CASSANDRA_KEY_SPACE,
-                  self::CASSANDRA_TABLE
+                    'DELETE FROM %s.%s WHERE cache_id = :cache_id;',
+                    self::CASSANDRA_KEY_SPACE,
+                    self::CASSANDRA_TABLE
                 )), $options);
 
                 /**
@@ -181,8 +181,8 @@ 
     {
         try {
             $result = $this->instance->execute(new Cassandra\SimpleStatement(sprintf(
-              'TRUNCATE %s.%s;',
-              self::CASSANDRA_KEY_SPACE, self::CASSANDRA_TABLE
+                'TRUNCATE %s.%s;',
+                self::CASSANDRA_KEY_SPACE, self::CASSANDRA_TABLE
             )));
             /**
              * There's no real way atm
@@ -210,8 +210,8 @@ 
             $username = isset($this->config[ 'username' ]) ? $this->config[ 'username' ] : '';
 
             $clusterBuilder = Cassandra::cluster()
-              ->withContactPoints($host)
-              ->withPort($port);
+                ->withContactPoints($host)
+                ->withPort($port);
 
             if(!empty($this->config['ssl']['enabled'])){
                 if(!empty($this->config['ssl']['verify'])){
@@ -239,8 +239,8 @@ 
              */
 
             $this->instance->execute(new Cassandra\SimpleStatement(sprintf(
-              "CREATE KEYSPACE IF NOT EXISTS %s WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor' : 1 };",
-              self::CASSANDRA_KEY_SPACE
+                "CREATE KEYSPACE IF NOT EXISTS %s WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor' : 1 };",
+                self::CASSANDRA_KEY_SPACE
             )));
             $this->instance->execute(new Cassandra\SimpleStatement(sprintf('USE %s;', self::CASSANDRA_KEY_SPACE)));
             $this->instance->execute(new Cassandra\SimpleStatement(sprintf('
@@ -286,15 +286,15 @@ 
     public function getStats()
     {
         $result = $this->instance->execute(new Cassandra\SimpleStatement(sprintf(
-          'SELECT SUM(cache_length) as cache_size FROM %s.%s',
-          self::CASSANDRA_KEY_SPACE,
-          self::CASSANDRA_TABLE
+            'SELECT SUM(cache_length) as cache_size FROM %s.%s',
+            self::CASSANDRA_KEY_SPACE,
+            self::CASSANDRA_TABLE
         )));
 
         return (new driverStatistic())
-          ->setSize($result->first()[ 'cache_size' ])
-          ->setRawData([])
-          ->setData(implode(', ', array_keys($this->itemInstances)))
-          ->setInfo('The cache size represents only the cache data itself without counting data structures associated to the cache entries.');
+            ->setSize($result->first()[ 'cache_size' ])
+            ->setRawData([])
+            ->setData(implode(', ', array_keys($this->itemInstances)))
+            ->setInfo('The cache size represents only the cache data itself without counting data structures associated to the cache entries.');
     }
 }
\ No newline at end of file