@@ -63,7 +63,7 @@ discard block |
||
| 63 | 63 | $targetBucket = (isset($params['target_bucket'])) ? $params['target_bucket'] : $params['source_bucket']; |
| 64 | 64 | |
| 65 | 65 | foreach ($params['files']['source'] as $key => $file) { |
| 66 | - $targetKey = (isset($params['files']['target'][$key])) ? $params['files']['target'][$key] : $file; |
|
| 66 | + $targetKey = (isset($params['files']['target'][$key])) ? $params['files']['target'][$key] : $file; |
|
| 67 | 67 | $sourceBucket = $params['source_bucket']; |
| 68 | 68 | |
| 69 | 69 | if ($this->client->hasEncoder()) { |
@@ -82,7 +82,7 @@ discard block |
||
| 82 | 82 | |
| 83 | 83 | if ($this->client->isBucketVersioned(['bucket' => $sourceBucket])) { |
| 84 | 84 | $version = $this->client->getCurrentItemVersion(['bucket' => $sourceBucket, 'key' => $params['source']]); |
| 85 | - $config['CopySource'] = $copySource . '?versionId='.$version; |
|
| 85 | + $config['CopySource'] = $copySource . '?versionId=' . $version; |
|
| 86 | 86 | } |
| 87 | 87 | |
| 88 | 88 | $commands[] = $this->client->getConn()->getCommand('CopyObject', $config); |
@@ -92,13 +92,13 @@ discard block |
||
| 92 | 92 | // Create a pool and provide an optional array of configuration |
| 93 | 93 | $pool = new CommandPool($this->client->getConn(), $commands, [ |
| 94 | 94 | 'concurrency' => (isset($params['concurrency'])) ? $params['concurrency'] : 25, |
| 95 | - 'before' => function (CommandInterface $cmd, $iterKey) { |
|
| 95 | + 'before' => function(CommandInterface $cmd, $iterKey) { |
|
| 96 | 96 | if (null !== $this->commandHandlerLogger) { |
| 97 | 97 | $this->commandHandlerLogger->log($this, sprintf('About to send \'%s\'', $iterKey)); |
| 98 | 98 | } |
| 99 | 99 | }, |
| 100 | 100 | // Invoke this function for each successful transfer |
| 101 | - 'fulfilled' => function ( |
|
| 101 | + 'fulfilled' => function( |
|
| 102 | 102 | ResultInterface $result, |
| 103 | 103 | $iterKey |
| 104 | 104 | ) use ($targetBucket, $targetKeys) { |
@@ -111,7 +111,7 @@ discard block |
||
| 111 | 111 | } |
| 112 | 112 | }, |
| 113 | 113 | // Invoke this function for each failed transfer |
| 114 | - 'rejected' => function ( |
|
| 114 | + 'rejected' => function( |
|
| 115 | 115 | AwsException $reason |
| 116 | 116 | ) use (&$errors) { |
| 117 | 117 | $errors[] = $reason; |