matecat / simple-s3

benchmark/test.php

Spacing +10 added lines, -10 removed lines

@@ -1,10 +1,10 @@ 
 <?php
 
-require __DIR__.'/../vendor/autoload.php';
+require __DIR__ . '/../vendor/autoload.php';
 
 use Matecat\SimpleS3\Components\Cache\RedisCache;
 
-$config = parse_ini_file(__DIR__.'/../config/credentials.ini');
+$config = parse_ini_file(__DIR__ . '/../config/credentials.ini');
 $s3Client = new Matecat\SimpleS3\Client(
     [
         'version' => $config['VERSION'],
@@ -30,24 +30,24 @@ 
 echo 'ELAPSED TIME:' . (microtime(true) - $x) . PHP_EOL . PHP_EOL;
 
 $x = microtime(true);
-echo 'UPLOAD '. $n . ' ITEMS IN THE BUCKET' . PHP_EOL;
+echo 'UPLOAD ' . $n . ' ITEMS IN THE BUCKET' . PHP_EOL;
 echo '----------------------------------------' . PHP_EOL;
 
-for ($i=0;$i<$n;$i++) {
+for ($i = 0; $i < $n; $i++) {
     $rand = rand(11111111, 99999999);
     $body = 'lorem ipsum';
 
     $s3Client->uploadItemFromBody([
         'bucket' => 'mauretto78-benchmark-test-bucket',
-        'key' => 'folder/'.$rand . '.txt',
+        'key' => 'folder/' . $rand . '.txt',
         'body' => $body
     ]);
 }
 
-echo 'ELAPSED TIME:' . (microtime(true) - $x) . PHP_EOL. PHP_EOL;
+echo 'ELAPSED TIME:' . (microtime(true) - $x) . PHP_EOL . PHP_EOL;
 
 $x = microtime(true);
-echo 'GET '. $n . ' ITEMS IN THE BUCKET' . PHP_EOL;
+echo 'GET ' . $n . ' ITEMS IN THE BUCKET' . PHP_EOL;
 echo '----------------------------------------' . PHP_EOL;
 
 $s3Client->getItemsInABucket([
@@ -55,7 +55,7 @@ 
     'prefix' => 'folder/',
 ]);
 
-echo 'ELAPSED TIME:' . (microtime(true) - $x) . PHP_EOL. PHP_EOL;
+echo 'ELAPSED TIME:' . (microtime(true) - $x) . PHP_EOL . PHP_EOL;
 
 $x = microtime(true);
 echo 'DELETE FOLDER IN THE BUCKET' . PHP_EOL;
@@ -66,7 +66,7 @@ 
     'prefix' => 'folder/',
 ]);
 
-echo 'ELAPSED TIME:' . (microtime(true) - $x) . PHP_EOL. PHP_EOL;
+echo 'ELAPSED TIME:' . (microtime(true) - $x) . PHP_EOL . PHP_EOL;
 
 $x = microtime(true);
 echo 'DELETE BUCKET' . PHP_EOL;
@@ -76,4 +76,4 @@ 
     'bucket' => 'mauretto78-benchmark-test-bucket',
 ]);
 
-echo 'ELAPSED TIME:' . (microtime(true) - $x) . PHP_EOL. PHP_EOL;
+echo 'ELAPSED TIME:' . (microtime(true) - $x) . PHP_EOL . PHP_EOL;

src/Components/Cache/RedisCache.php

Spacing +1 added lines, -1 removed lines

@@ -172,6 +172,6 @@
 
         $fileInfo = File::getPathInfo($item);
 
-        return $fileInfo[ 'dirname' ] . $this->prefixSeparator;
+        return $fileInfo['dirname'] . $this->prefixSeparator;
     }
 }

src/Commands/Handlers/GetBucketLifeCycleConfiguration.php

Spacing +2 added lines, -2 removed lines

@@ -30,7 +30,7 @@ 
      */
     public function handle(array $params = []): Result
     {
-        $bucketName = $params[ 'bucket' ];
+        $bucketName = $params['bucket'];
 
         try {
             $result = $this->client->getConn()->getBucketLifecycle([
@@ -54,6 +54,6 @@ 
      */
     public function validateParams(array $params = []): bool
     {
-        return isset($params[ 'bucket' ]);
+        return isset($params['bucket']);
     }
 }

src/Commands/Handlers/CopyInBatch.php

Spacing +19 added lines, -19 removed lines

@@ -48,22 +48,22 @@ 
      */
     public function handle(array $params = []): bool
     {
-        if (isset($params[ 'target_bucket' ])) {
-            $this->client->createBucketIfItDoesNotExist(['bucket' => $params[ 'target_bucket' ]]);
+        if (isset($params['target_bucket'])) {
+            $this->client->createBucketIfItDoesNotExist(['bucket' => $params['target_bucket']]);
         }
 
-        if (empty($params[ 'files' ][ 'source' ])) {
+        if (empty($params['files']['source'])) {
             throw new InvalidArgumentException('source files array cannot be empty.');
         }
 
         $commands     = [];
         $errors       = [];
         $targetKeys   = [];
-        $targetBucket = (isset($params[ 'target_bucket' ])) ? $params[ 'target_bucket' ] : $params[ 'source_bucket' ];
+        $targetBucket = (isset($params['target_bucket'])) ? $params['target_bucket'] : $params['source_bucket'];
 
-        foreach ($params[ 'files' ][ 'source' ] as $key => $file) {
-            $targetKey    = (isset($params[ 'files' ][ 'target' ][ $key ])) ? $params[ 'files' ][ 'target' ][ $key ] : $file;
-            $sourceBucket = $params[ 'source_bucket' ];
+        foreach ($params['files']['source'] as $key => $file) {
+            $targetKey    = (isset($params['files']['target'][$key])) ? $params['files']['target'][$key] : $file;
+            $sourceBucket = $params['source_bucket'];
 
             if ($this->client->hasEncoder()) {
                 $targetKey = $this->client->getEncoder()->encode($targetKey);
@@ -80,8 +80,8 @@ 
             ];
 
             if ($this->client->isBucketVersioned(['bucket' => $sourceBucket])) {
-                $version                = $this->client->getCurrentItemVersion(['bucket' => $sourceBucket, 'key' => $params[ 'source' ]]);
-                $config[ 'CopySource' ] = $copySource . '?versionId=' . $version;
+                $version                = $this->client->getCurrentItemVersion(['bucket' => $sourceBucket, 'key' => $params['source']]);
+                $config['CopySource'] = $copySource . '?versionId=' . $version;
             }
 
             $commands[] = $this->client->getConn()->getCommand('CopyObject', $config);
@@ -90,23 +90,23 @@ 
         try {
             // Create a pool and provide an optional array of configuration
             $pool = new CommandPool($this->client->getConn(), $commands, [
-                    'concurrency' => (isset($params[ 'concurrency' ])) ? $params[ 'concurrency' ] : 25,
-                    'before'      => function (CommandInterface $cmd, $iterKey) {
+                    'concurrency' => (isset($params['concurrency'])) ? $params['concurrency'] : 25,
+                    'before'      => function(CommandInterface $cmd, $iterKey) {
                         $this->commandHandlerLogger?->log($this, sprintf('About to send \'%s\'', $iterKey));
                     },
                 // Invoke this function for each successful transfer
-                    'fulfilled'   => function (
+                    'fulfilled'   => function(
                             ResultInterface $result,
                             $iterKey
                     ) use ($targetBucket, $targetKeys) {
-                        $this->commandHandlerLogger?->log($this, sprintf('Completed copy of \'%s\'', $targetKeys[ $iterKey ]));
+                        $this->commandHandlerLogger?->log($this, sprintf('Completed copy of \'%s\'', $targetKeys[$iterKey]));
 
                         if ($this->client->hasCache()) {
-                            $this->client->getCache()->set($targetBucket, $targetKeys[ $iterKey ], '');
+                            $this->client->getCache()->set($targetBucket, $targetKeys[$iterKey], '');
                         }
                     },
                 // Invoke this function for each failed transfer
-                    'rejected'    => function (
+                    'rejected'    => function(
                             AwsException $reason
                     ) use (&$errors) {
                         $errors[] = $reason;
@@ -121,12 +121,12 @@ 
             $pool->promise()->wait();
 
             if (count($errors) === 0) {
-                $this->commandHandlerLogger?->log($this, sprintf('Copy in batch from \'%s\' to \'%s\' was succeded without errors', $params[ 'source_bucket' ], $targetBucket));
+                $this->commandHandlerLogger?->log($this, sprintf('Copy in batch from \'%s\' to \'%s\' was succeded without errors', $params['source_bucket'], $targetBucket));
 
                 return true;
             }
 
-            $this->commandHandlerLogger?->log($this, sprintf('Something went wrong during copying in batch from \'%s\' to \'%s\'', $params[ 'source_bucket' ], (isset($params[ 'target_bucket' ])) ? $params[ 'target_bucket' ] : $params[ 'source_bucket' ]), 'warning');
+            $this->commandHandlerLogger?->log($this, sprintf('Something went wrong during copying in batch from \'%s\' to \'%s\'', $params['source_bucket'], (isset($params['target_bucket'])) ? $params['target_bucket'] : $params['source_bucket']), 'warning');
 
             return false;
         } catch (Exception $e) {
@@ -144,8 +144,8 @@ 
     public function validateParams(array $params = []): bool
     {
         return (
-                isset($params[ 'source_bucket' ]) and
-                isset($params[ 'files' ][ 'source' ])
+                isset($params['source_bucket']) and
+                isset($params['files']['source'])
         );
     }
 }

src/Commands/Handlers/SetBucketVersioning.php

Spacing +11 added lines, -11 removed lines

@@ -29,7 +29,7 @@ 
      */
     public function handle(array $params = []): bool
     {
-        $bucketName = $params[ 'bucket' ];
+        $bucketName = $params['bucket'];
         $config     = [
                 'Bucket'                  => $bucketName,
                 'VersioningConfiguration' => [
@@ -38,26 +38,26 @@ 
                 ],
         ];
 
-        if (isset($params[ 'md5' ])) {
-            $config[ 'ContentMD5' ] = $params[ 'md5' ];
+        if (isset($params['md5'])) {
+            $config['ContentMD5'] = $params['md5'];
         }
 
-        if (isset($params[ 'mfa' ])) {
-            $config[ 'MFA' ] = $params[ 'mfa' ];
+        if (isset($params['mfa'])) {
+            $config['MFA'] = $params['mfa'];
         }
 
-        if (isset($params[ 'mfa_delete' ])) {
-            $config[ 'VersioningConfiguration' ][ 'MFADelete' ] = $params[ 'mfa_delete' ];
+        if (isset($params['mfa_delete'])) {
+            $config['VersioningConfiguration']['MFADelete'] = $params['mfa_delete'];
         }
 
-        if (isset($params[ 'status' ])) {
-            $config[ 'VersioningConfiguration' ][ 'Status' ] = $params[ 'status' ];
+        if (isset($params['status'])) {
+            $config['VersioningConfiguration']['Status'] = $params['status'];
         }
 
         try {
             $versioning = $this->client->getConn()->putBucketVersioning($config);
 
-            if (($versioning instanceof ResultInterface) and $versioning[ '@metadata' ][ 'statusCode' ] === 200) {
+            if (($versioning instanceof ResultInterface) and $versioning['@metadata']['statusCode'] === 200) {
                 $this->commandHandlerLogger?->log($this, sprintf('Versioning was successfully enabled for \'%s\' bucket', $bucketName));
 
                 return true;
@@ -80,6 +80,6 @@ 
      */
     public function validateParams(array $params = []): bool
     {
-        return isset($params[ 'bucket' ]);
+        return isset($params['bucket']);
     }
 }

src/Commands/Handlers/UploadItem.php

Spacing +22 added lines, -22 removed lines

@@ -40,11 +40,11 @@ 
      */
     public function handle(array $params = []): bool
     {
-        $bucketName = $params[ 'bucket' ];
-        $keyName    = $params[ 'key' ];
-        $source     = $params[ 'source' ];
+        $bucketName = $params['bucket'];
+        $keyName    = $params['key'];
+        $source     = $params['source'];
 
-        if (isset($params[ 'bucket_check' ]) and true === $params[ 'bucket_check' ]) {
+        if (isset($params['bucket_check']) and true === $params['bucket_check']) {
             $this->client->createBucketIfItDoesNotExist(['bucket' => $bucketName]);
         }
 
@@ -52,8 +52,8 @@ 
             throw new InvalidS3NameException(sprintf('%s is not a valid S3 object name. [' . implode(', ', S3ObjectSafeNameValidator::validate($keyName)) . ']', $keyName));
         }
 
-        if ((isset($params[ 'storage' ]) and false === S3StorageClassNameValidator::isValid($params[ 'storage' ]))) {
-            throw new InvalidArgumentException(S3StorageClassNameValidator::validate($params[ 'storage' ])[ 0 ]);
+        if ((isset($params['storage']) and false === S3StorageClassNameValidator::isValid($params['storage']))) {
+            throw new InvalidArgumentException(S3StorageClassNameValidator::validate($params['storage'])[0]);
         }
 
         if (File::getSize($source) > self::MAX_FILESIZE) {
@@ -64,7 +64,7 @@ 
                 'bucket'  => $bucketName,
                 'key'     => $keyName,
                 'body'    => File::open($source),
-                'storage' => (isset($params[ 'storage' ])) ? $params[ 'storage' ] : null
+                'storage' => (isset($params['storage'])) ? $params['storage'] : null
         ]);
     }
 
@@ -76,9 +76,9 @@ 
     public function validateParams(array $params = []): bool
     {
         return (
-                isset($params[ 'bucket' ]) and
-                isset($params[ 'key' ]) and
-                isset($params[ 'source' ])
+                isset($params['bucket']) and
+                isset($params['key']) and
+                isset($params['source'])
         );
     }
 
@@ -99,19 +99,19 @@ 
                 [
                         'bucket'          => $bucketName,
                         'key'             => $keyName,
-                        'before_initiate' => function (CommandInterface $command) use ($source, $params, $keyName) {
-                            $command[ 'ContentType' ] = File::getMimeType($source);
+                        'before_initiate' => function(CommandInterface $command) use ($source, $params, $keyName) {
+                            $command['ContentType'] = File::getMimeType($source);
 
-                            if ((isset($params[ 'storage' ]))) {
-                                $command[ 'StorageClass' ] = $params[ 'storage' ];
+                            if ((isset($params['storage']))) {
+                                $command['StorageClass'] = $params['storage'];
                             }
 
-                            if ((isset($params[ 'Metadata' ]))) {
-                                $command[ 'Metadata' ] = $params[ 'meta' ];
+                            if ((isset($params['Metadata']))) {
+                                $command['Metadata'] = $params['meta'];
                             }
 
-                            $command[ 'Metadata' ][ 'original_name' ] = File::getBaseName($keyName);
-                            $command[ 'MetadataDirective' ]           = 'REPLACE';
+                            $command['Metadata']['original_name'] = File::getBaseName($keyName);
+                            $command['MetadataDirective']           = 'REPLACE';
                         }
                 ]
         );
@@ -119,7 +119,7 @@ 
         try {
             $upload = $uploader->upload();
 
-            if (($upload instanceof ResultInterface) and $upload[ '@metadata' ][ 'statusCode' ] === 200) {
+            if (($upload instanceof ResultInterface) and $upload['@metadata']['statusCode'] === 200) {
                 $this->commandHandlerLogger?->log($this, sprintf('File \'%s\' was successfully uploaded in \'%s\' bucket', $keyName, $bucketName));
 
                 return true;
@@ -128,10 +128,10 @@ 
             $this->commandHandlerLogger?->log($this, sprintf('Something went wrong during upload of file \'%s\' in \'%s\' bucket', $keyName, $bucketName), 'warning');
 
             // update cache
-            if ((!isset($params[ 'storage' ])) and $this->client->hasCache()) {
+            if ((!isset($params['storage'])) and $this->client->hasCache()) {
                 $version = null;
-                if (isset($upload[ '@metadata' ][ 'headers' ][ 'x-amz-version-id' ])) {
-                    $version = $upload[ '@metadata' ][ 'headers' ][ 'x-amz-version-id' ];
+                if (isset($upload['@metadata']['headers']['x-amz-version-id'])) {
+                    $version = $upload['@metadata']['headers']['x-amz-version-id'];
                 }
 
                 $this->client->getCache()->set($bucketName, $keyName, '', $version);

src/Commands/Handlers/CopyFolder.php

Spacing +8 added lines, -8 removed lines

@@ -31,10 +31,10 @@ 
      */
     public function handle(array $params = ['source_bucket' => '', 'source_folder' => '', 'target_bucket' => null, 'target_folder' => '', 'delete_source' => false]): bool
     {
-        $targetBucketName = (isset($params[ 'target_bucket' ])) ? $params[ 'target_bucket' ] : $params[ 'source_bucket' ];
-        $targetFolder     = $params[ 'target_folder' ];
-        $sourceBucketName = $params[ 'source_bucket' ];
-        $sourceFolder     = $params[ 'source_folder' ];
+        $targetBucketName = (isset($params['target_bucket'])) ? $params['target_bucket'] : $params['source_bucket'];
+        $targetFolder     = $params['target_folder'];
+        $sourceBucketName = $params['source_bucket'];
+        $sourceFolder     = $params['source_folder'];
 
         try {
             $sourceItems = $this->client->getItemsInABucket([
@@ -63,7 +63,7 @@ 
                 }
             }
 
-            if (isset($params[ 'delete_source' ]) and true === $params[ 'delete_source' ]) {
+            if (isset($params['delete_source']) and true === $params['delete_source']) {
                 $deleteSource = $this->client->deleteFolder([
                         'bucket' => $sourceBucketName,
                         'prefix' => $sourceFolder,
@@ -90,9 +90,9 @@ 
     public function validateParams(array $params = []): bool
     {
         return (
-                isset($params[ 'target_folder' ]) and
-                isset($params[ 'source_bucket' ]) and
-                isset($params[ 'source_folder' ])
+                isset($params['target_folder']) and
+                isset($params['source_bucket']) and
+                isset($params['source_folder'])
         );
     }
 }

src/Commands/Handlers/DeleteFolder.php

Spacing +4 added lines, -4 removed lines

@@ -29,8 +29,8 @@ 
      */
     public function handle(array $params = []): true
     {
-        $bucketName = $params[ 'bucket' ];
-        $prefix     = $params[ 'prefix' ];
+        $bucketName = $params['bucket'];
+        $prefix     = $params['prefix'];
 
         if (false === File::endsWith($prefix, $this->client->getPrefixSeparator())) {
             $prefix .= $this->client->getPrefixSeparator();
@@ -67,8 +67,8 @@ 
     public function validateParams(array $params = []): bool
     {
         return (
-                isset($params[ 'bucket' ]) and
-                isset($params[ 'prefix' ])
+                isset($params['bucket']) and
+                isset($params['prefix'])
         );
     }
 }

src/Commands/Handlers/DeleteBucketPolicy.php

Spacing +3 added lines, -3 removed lines

@@ -30,7 +30,7 @@ 
      */
     public function handle(array $params = []): bool
     {
-        $bucketName = $params[ 'bucket' ];
+        $bucketName = $params['bucket'];
 
         if (false === $this->client->hasBucket(['bucket' => $bucketName])) {
             $this->commandHandlerLogger?->log($this, sprintf('Bucket \'%s\' does not exists', $bucketName), 'warning');
@@ -41,7 +41,7 @@ 
         try {
             $delete = $this->client->getConn()->deleteBucketPolicy(['Bucket' => $bucketName]);
 
-            if (($delete instanceof ResultInterface) and $delete[ '@metadata' ][ 'statusCode' ] === 204) {
+            if (($delete instanceof ResultInterface) and $delete['@metadata']['statusCode'] === 204) {
                 $this->commandHandlerLogger?->log($this, sprintf('Policy was successfully deleted for bucket \'%s\'', $bucketName));
 
                 return true;
@@ -64,6 +64,6 @@ 
      */
     public function validateParams(array $params = []): bool
     {
-        return (isset($params[ 'bucket' ]));
+        return (isset($params['bucket']));
     }
 }