AwsS3Adapter::isOnlyDir() - Code Metrics - Inspection of "Merge pull request #164 from ganeko/master" - thephpleague/flysystem-aws-s3-v3 - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( b35251...8c47cf )

by Frank

created 2019-06-05 17:13 UTC

AwsS3Adapter::isOnlyDir() A

↳ Parent: AwsS3Adapter

Complexity

Conditions	1
Paths	1

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	2
CRAP Score	1

Importance

Changes

Metric	Value
dl	0
loc	4
ccs	2
cts	2
cp	1
rs	10
c	0
b	0
f	0
cc	1
nc	1
nop	1
crap	1

<?php

namespace League\Flysystem\AwsS3v3;

use Aws\Result;
use Aws\S3\Exception\DeleteMultipleObjectsException;
use Aws\S3\Exception\S3Exception;
use Aws\S3\Exception\S3MultipartUploadException;
use Aws\S3\S3Client;
use League\Flysystem\Adapter\AbstractAdapter;
use League\Flysystem\Adapter\CanOverwriteFiles;
use League\Flysystem\AdapterInterface;
use League\Flysystem\Config;
use League\Flysystem\Util;

class AwsS3Adapter extends AbstractAdapter implements CanOverwriteFiles
{
    const PUBLIC_GRANT_URI = 'http://acs.amazonaws.com/groups/global/AllUsers';

    /**
     * @var array
     */
    protected static $resultMap = [
        'Body'          => 'contents',
        'ContentLength' => 'size',
        'ContentType'   => 'mimetype',
        'Size'          => 'size',
        'Metadata'      => 'metadata',
        'StorageClass'  => 'storageclass',
        'ETag'          => 'etag',
        'VersionId'     => 'versionid'
    ];

    /**
     * @var array
     */
    protected static $metaOptions = [
        'ACL',
        'CacheControl',
        'ContentDisposition',
        'ContentEncoding',
        'ContentLength',
        'ContentType',
        'Expires',
        'GrantFullControl',
        'GrantRead',
        'GrantReadACP',
        'GrantWriteACP',
        'Metadata',
        'RequestPayer',
        'SSECustomerAlgorithm',
        'SSECustomerKey',
        'SSECustomerKeyMD5',
        'SSEKMSKeyId',
        'ServerSideEncryption',
        'StorageClass',
        'Tagging',
        'WebsiteRedirectLocation',
    ];

    /**
     * @var S3Client
     */
    protected $s3Client;

    /**
     * @var string
     */
    protected $bucket;

    /**
     * @var array
     */
    protected $options = [];

    /**
     * Constructor.
     *
     * @param S3Client $client
     * @param string   $bucket
     * @param string   $prefix
     * @param array    $options
     */
    public function __construct(S3Client $client, $bucket, $prefix = '', array $options = [])
    {
        $this->s3Client = $client;
        $this->bucket = $bucket;
        $this->setPathPrefix($prefix);
        $this->options = $options;
    }

    /**
     * Get the S3Client bucket.
     *
     * @return string
     */
    public function getBucket()
    {
        return $this->bucket;
    }

    /**
     * Set the S3Client bucket.
     *
     * @return string
     */
    public function setBucket($bucket)
    {
        $this->bucket = $bucket;
    }

    /**
     * Get the S3Client instance.
     *
     * @return S3Client
     */
    public function getClient()
    {
        return $this->s3Client;
    }

    /**
     * Write a new file.
     *
     * @param string $path
     * @param string $contents
     * @param Config $config Config object
     *
     * @return false|array false on failure file meta data on success
     */
    public function write($path, $contents, Config $config)
    {
        return $this->upload($path, $contents, $config);
    }

    /**
     * Update a file.
     *
     * @param string $path
     * @param string $contents
     * @param Config $config Config object
     *
     * @return false|array false on failure file meta data on success
     */
    public function update($path, $contents, Config $config)
    {
        return $this->upload($path, $contents, $config);
    }

    /**
     * Rename a file.
     *
     * @param string $path
     * @param string $newpath
     *
     * @return bool
     */
    public function rename($path, $newpath)
    {
        if ( ! $this->copy($path, $newpath)) {
            return false;
        }

        return $this->delete($path);
    }

    /**
     * Delete a file.
     *
     * @param string $path
     *
     * @return bool
     */
    public function delete($path)
    {
        $location = $this->applyPathPrefix($path);

        $command = $this->s3Client->getCommand(
            'deleteObject',
            [
                'Bucket' => $this->bucket,
                'Key'    => $location,
            ]
        );

        $this->s3Client->execute($command);

        return ! $this->has($path);
    }

    /**
     * Delete a directory.
     *
     * @param string $dirname
     *
     * @return bool
     */
    public function deleteDir($dirname)
    {
        try {
            $prefix = $this->applyPathPrefix($dirname) . '/';
            $this->s3Client->deleteMatchingObjects($this->bucket, $prefix);
        } catch (DeleteMultipleObjectsException $exception) {
            return false;
        }

        return true;
    }

    /**
     * Create a directory.
     *
     * @param string $dirname directory name
     * @param Config $config
     *
     * @return bool|array
     */
    public function createDir($dirname, Config $config)
    {
        return $this->upload($dirname . '/', '', $config);
    }

    /**
     * Check whether a file exists.
     *
     * @param string $path
     *
     * @return bool
     */
    public function has($path)
    {
        $location = $this->applyPathPrefix($path);

        if ($this->s3Client->doesObjectExist($this->bucket, $location, $this->options)) {
            return true;
        }

        return $this->doesDirectoryExist($location);
    }

    /**
     * Read a file.
     *
     * @param string $path
     *
     * @return false|array
     */
    public function read($path)
    {
        $response = $this->readObject($path);

        if ($response !== false) {
            $response['contents'] = $response['contents']->getContents();
        }

        return $response;
    }

    /**
     * List contents of a directory.
     *
     * @param string $directory
     * @param bool   $recursive
     *
     * @return array
     */
    public function listContents($directory = '', $recursive = false)
    {
        $prefix = $this->applyPathPrefix(rtrim($directory, '/') . '/');
        $options = ['Bucket' => $this->bucket, 'Prefix' => ltrim($prefix, '/')];

        if ($recursive === false) {
            $options['Delimiter'] = '/';
        }

        $listing = $this->retrievePaginatedListing($options);
        $normalizer = [$this, 'normalizeResponse'];
        $normalized = array_map($normalizer, $listing);

        return Util::emulateDirectories($normalized);
    }

    /**
     * @param array $options
     *
     * @return array
     */
    protected function retrievePaginatedListing(array $options)
    {
        $resultPaginator = $this->s3Client->getPaginator('ListObjects', $options);
        $listing = [];

        foreach ($resultPaginator as $result) {
            $listing = array_merge($listing, $result->get('Contents') ?: [], $result->get('CommonPrefixes') ?: []);
        }

        return $listing;
    }

    /**
     * Get all the meta data of a file or directory.
     *
     * @param string $path
     *
     * @return false|array
     */
    public function getMetadata($path)
    {
        $command = $this->s3Client->getCommand(
            'headObject',
            [
                'Bucket' => $this->bucket,
                'Key'    => $this->applyPathPrefix($path),
            ] + $this->options
        );

        /* @var Result $result */
        try {
            $result = $this->s3Client->execute($command);
        } catch (S3Exception $exception) {
            if ($this->is404Exception($exception)) {
                return false;
            }

            throw $exception;
        }

        return $this->normalizeResponse($result->toArray(), $path);
    }

    /**
     * @return bool
     */
    private function is404Exception(S3Exception $exception)
    {
        $response = $exception->getResponse();

        if ($response !== null && $response->getStatusCode() === 404) {
            return true;
        }

        return false;
    }

    /**
     * Get all the meta data of a file or directory.
     *
     * @param string $path
     *
     * @return false|array
     */
    public function getSize($path)
    {
        return $this->getMetadata($path);
    }

    /**
     * Get the mimetype of a file.
     *
     * @param string $path
     *
     * @return false|array
     */
    public function getMimetype($path)
    {
        return $this->getMetadata($path);
    }

    /**
     * Get the timestamp of a file.
     *
     * @param string $path
     *
     * @return false|array
     */
    public function getTimestamp($path)
    {
        return $this->getMetadata($path);
    }

    /**
     * Write a new file using a stream.
     *
     * @param string   $path
     * @param resource $resource
     * @param Config   $config Config object
     *
     * @return array|false false on failure file meta data on success
     */
    public function writeStream($path, $resource, Config $config)
    {
        return $this->upload($path, $resource, $config);
    }

    /**
     * Update a file using a stream.
     *
     * @param string   $path
     * @param resource $resource
     * @param Config   $config Config object
     *
     * @return array|false false on failure file meta data on success
     */
    public function updateStream($path, $resource, Config $config)
    {
        return $this->upload($path, $resource, $config);
    }

    /**
     * Copy a file.
     *
     * @param string $path
     * @param string $newpath
     *
     * @return bool
     */
    public function copy($path, $newpath)
    {
        $command = $this->s3Client->getCommand(
            'copyObject',
            [
                'Bucket'     => $this->bucket,
                'Key'        => $this->applyPathPrefix($newpath),
                'CopySource' => urlencode($this->bucket . '/' . $this->applyPathPrefix($path)),
                'ACL'        => $this->getRawVisibility($path) === AdapterInterface::VISIBILITY_PUBLIC
                    ? 'public-read' : 'private',
            ] + $this->options
        );

        try {
            $this->s3Client->execute($command);
        } catch (S3Exception $e) {
            return false;
        }

        return true;
    }

    /**
     * Read a file as a stream.
     *
     * @param string $path
     *
     * @return array|false
     */
    public function readStream($path)
    {
        $response = $this->readObject($path);

        if ($response !== false) {
            $response['stream'] = $response['contents']->detach();
            unset($response['contents']);
        }

        return $response;
    }

    /**
     * Read an object and normalize the response.
     *
     * @param $path
     *
     * @return array|bool
     */
    protected function readObject($path)
    {
        $options = [
            'Bucket' => $this->bucket,
            'Key'    => $this->applyPathPrefix($path),
        ];

        if (isset($this->options['@http'])) {
            $options['@http'] = $this->options['@http'];
        }

        $command = $this->s3Client->getCommand('getObject', $options + $this->options);

        try {
            /** @var Result $response */
            $response = $this->s3Client->execute($command);
        } catch (S3Exception $e) {
            return false;
        }

        return $this->normalizeResponse($response->toArray(), $path);
    }

    /**
     * Set the visibility for a file.
     *
     * @param string $path
     * @param string $visibility
     *
     * @return array|false file meta data
     */
    public function setVisibility($path, $visibility)
    {
        $command = $this->s3Client->getCommand(
            'putObjectAcl',
            [
                'Bucket' => $this->bucket,
                'Key'    => $this->applyPathPrefix($path),
                'ACL'    => $visibility === AdapterInterface::VISIBILITY_PUBLIC ? 'public-read' : 'private',
            ]
        );

        try {
            $this->s3Client->execute($command);
        } catch (S3Exception $exception) {
            return false;
        }

        return compact('path', 'visibility');
    }

    /**
     * Get the visibility of a file.
     *
     * @param string $path
     *
     * @return array|false
     */
    public function getVisibility($path)
    {
        return ['visibility' => $this->getRawVisibility($path)];
    }

    /**
     * {@inheritdoc}
     */
    public function applyPathPrefix($path)
    {
        return ltrim(parent::applyPathPrefix($path), '/');
    }

    /**
     * {@inheritdoc}
     */
    public function setPathPrefix($prefix)
    {
        $prefix = ltrim($prefix, '/');

        return parent::setPathPrefix($prefix);
    }

    /**
     * Get the object acl presented as a visibility.
     *
     * @param string $path
     *
     * @return string
     */
    protected function getRawVisibility($path)
    {
        $command = $this->s3Client->getCommand(
            'getObjectAcl',
            [
                'Bucket' => $this->bucket,
                'Key'    => $this->applyPathPrefix($path),
            ]
        );

        $result = $this->s3Client->execute($command);
        $visibility = AdapterInterface::VISIBILITY_PRIVATE;

        foreach ($result->get('Grants') as $grant) {
            if (
                isset($grant['Grantee']['URI'])
                && $grant['Grantee']['URI'] === self::PUBLIC_GRANT_URI
                && $grant['Permission'] === 'READ'
            ) {
                $visibility = AdapterInterface::VISIBILITY_PUBLIC;
                break;
            }
        }

        return $visibility;
    }

    /**
     * Upload an object.
     *
     * @param        $path
     * @param        $body
     * @param Config $config
     *
     * @return array|bool
     */
    protected function upload($path, $body, Config $config)
    {
        $key = $this->applyPathPrefix($path);
        $options = $this->getOptionsFromConfig($config);
        $acl = array_key_exists('ACL', $options) ? $options['ACL'] : 'private';

        if (!$this->isOnlyDir($path)) {
            if ( ! isset($options['ContentType'])) {
                $options['ContentType'] = Util::guessMimeType($path, $body);
            }

            if ( ! isset($options['ContentLength'])) {
                $options['ContentLength'] = is_resource($body) ? Util::getStreamSize($body) : Util::contentSize($body);
            }

            if ($options['ContentLength'] === null) {
                unset($options['ContentLength']);
            }
        }

        try {
            $this->s3Client->upload($this->bucket, $key, $body, $acl, ['params' => $options]);
        } catch (S3MultipartUploadException $multipartUploadException) {
            return false;
        }

        return $this->normalizeResponse($options, $path);
    }

    /**
     * Check if the path contains only directories
     *
     * @param string $path
     * @return bool
     */
    private function isOnlyDir($path)
    {
        return substr($path, -1) === '/';
    }

    /**
     * Get options from the config.
     *
     * @param Config $config
     *
     * @return array
     */
    protected function getOptionsFromConfig(Config $config)
    {
        $options = $this->options;

        if ($visibility = $config->get('visibility')) {
            // For local reference
            $options['visibility'] = $visibility;
            // For external reference
            $options['ACL'] = $visibility === AdapterInterface::VISIBILITY_PUBLIC ? 'public-read' : 'private';
        }

        if ($mimetype = $config->get('mimetype')) {
            // For local reference
            $options['mimetype'] = $mimetype;
            // For external reference
            $options['ContentType'] = $mimetype;
        }

        foreach (static::$metaOptions as $option) {
            if ( ! $config->has($option)) {
                continue;
            }
            $options[$option] = $config->get($option);
        }

        return $options;
    }

    /**
     * Normalize the object result array.
     *
     * @param array  $response
     * @param string $path
     *
     * @return array
     */
    protected function normalizeResponse(array $response, $path = null)
    {
        $result = [
            'path' => $path ?: $this->removePathPrefix(
                isset($response['Key']) ? $response['Key'] : $response['Prefix']
            ),
        ];
        $result = array_merge($result, Util::pathinfo($result['path']));

        if (isset($response['LastModified'])) {
            $result['timestamp'] = strtotime($response['LastModified']);
        }

        if ($this->isOnlyDir($result['path'])) {
            $result['type'] = 'dir';
            $result['path'] = rtrim($result['path'], '/');

            return $result;
        }

        return array_merge($result, Util::map($response, static::$resultMap), ['type' => 'file']);
    }

    /**
     * @param $location
     *
     * @return bool
     */
    protected function doesDirectoryExist($location)
    {
        // Maybe this isn't an actual key, but a prefix.
        // Do a prefix listing of objects to determine.
        $command = $this->s3Client->getCommand(
            'listObjects',
            [
                'Bucket'  => $this->bucket,
                'Prefix'  => rtrim($location, '/') . '/',
                'MaxKeys' => 1,
            ]
        );

        try {
            $result = $this->s3Client->execute($command);

            return $result['Contents'] || $result['CommonPrefixes'];
        } catch (S3Exception $e) {
            if ($e->getStatusCode() === 403) {
                return false;
            }

            throw $e;
        }
    }
}


1		<?php
2
3		namespace League\Flysystem\AwsS3v3;
4
5		use Aws\Result;
6		use Aws\S3\Exception\DeleteMultipleObjectsException;
7		use Aws\S3\Exception\S3Exception;
8		use Aws\S3\Exception\S3MultipartUploadException;
9		use Aws\S3\S3Client;
10		use League\Flysystem\Adapter\AbstractAdapter;
11		use League\Flysystem\Adapter\CanOverwriteFiles;
12		use League\Flysystem\AdapterInterface;
13		use League\Flysystem\Config;
14		use League\Flysystem\Util;
15
16		class AwsS3Adapter extends AbstractAdapter implements CanOverwriteFiles
17		{
18		const PUBLIC_GRANT_URI = 'http://acs.amazonaws.com/groups/global/AllUsers';
19
20		/**
21		* @var array
22		*/
23		protected static $resultMap = [
24		'Body' => 'contents',
25		'ContentLength' => 'size',
26		'ContentType' => 'mimetype',
27		'Size' => 'size',
28		'Metadata' => 'metadata',
29		'StorageClass' => 'storageclass',
30		'ETag' => 'etag',
31		'VersionId' => 'versionid'
32		];
33
34		/**
35		* @var array
36		*/
37		protected static $metaOptions = [
38		'ACL',
39		'CacheControl',
40		'ContentDisposition',
41		'ContentEncoding',
42		'ContentLength',
43		'ContentType',
44		'Expires',
45		'GrantFullControl',
46		'GrantRead',
47		'GrantReadACP',
48		'GrantWriteACP',
49		'Metadata',
50		'RequestPayer',
51		'SSECustomerAlgorithm',
52		'SSECustomerKey',
53		'SSECustomerKeyMD5',
54		'SSEKMSKeyId',
55		'ServerSideEncryption',
56		'StorageClass',
57		'Tagging',
58		'WebsiteRedirectLocation',
59		];
60
61		/**
62		* @var S3Client
63		*/
64		protected $s3Client;
65
66		/**
67		* @var string
68		*/
69		protected $bucket;
70
71		/**
72		* @var array
73		*/
74		protected $options = [];
75
76		/**
77		* Constructor.
78		*
79		* @param S3Client $client
80		* @param string $bucket
81		* @param string $prefix
82		* @param array $options
83		*/
84	76	public function __construct(S3Client $client, $bucket, $prefix = '', array $options = [])
85		{
86	76	$this->s3Client = $client;
87	76	$this->bucket = $bucket;
88	76	$this->setPathPrefix($prefix);
89	76	$this->options = $options;
90	76	}
91
92		/**
93		* Get the S3Client bucket.
94		*
95		* @return string
96		*/
97	4	public function getBucket()
98		{
99	4	return $this->bucket;
100		}
101
102		/**
103		* Set the S3Client bucket.
104		*
105		* @return string
106		*/
107	2	public function setBucket($bucket)
108		{
109	2	$this->bucket = $bucket;
110	2	}
111
112		/**
113		* Get the S3Client instance.
114		*
115		* @return S3Client
116		*/
117	2	public function getClient()
118		{
119	2	return $this->s3Client;
120		}
121
122		/**
123		* Write a new file.
124		*
125		* @param string $path
126		* @param string $contents
127		* @param Config $config Config object
128		*
129		* @return false\|array false on failure file meta data on success
130		*/
131	6	public function write($path, $contents, Config $config)
132		{
133	6	return $this->upload($path, $contents, $config);
134		}
135
136		/**
137		* Update a file.
138		*
139		* @param string $path
140		* @param string $contents
141		* @param Config $config Config object
142		*
143		* @return false\|array false on failure file meta data on success
144		*/
145	4	public function update($path, $contents, Config $config)
146		{
147	4	return $this->upload($path, $contents, $config);
148		}
149
150		/**
151		* Rename a file.
152		*
153		* @param string $path
154		* @param string $newpath
155		*
156		* @return bool
157		*/
158	4	public function rename($path, $newpath)
159		{
160	4	if ( ! $this->copy($path, $newpath)) {
161	2	return false;
162		}
163
164	2	return $this->delete($path);
165		}
166
167		/**
168		* Delete a file.
169		*
170		* @param string $path
171		*
172		* @return bool
173		*/
174	4	public function delete($path)
175		{
176	4	$location = $this->applyPathPrefix($path);
177
178	4	$command = $this->s3Client->getCommand(
179	4	'deleteObject',
180		[
181	4	'Bucket' => $this->bucket,
182	4	'Key' => $location,
183		]
184	2	);
185
186	4	$this->s3Client->execute($command);
187
188	4	return ! $this->has($path);
189		}
190
191		/**
192		* Delete a directory.
193		*
194		* @param string $dirname
195		*
196		* @return bool
197		*/
198	4	public function deleteDir($dirname)
199		{
200		try {
201	4	$prefix = $this->applyPathPrefix($dirname) . '/';
202	4	$this->s3Client->deleteMatchingObjects($this->bucket, $prefix);
203	3	} catch (DeleteMultipleObjectsException $exception) {
204	2	return false;
205		}
206
207	2	return true;
208		}
209
210		/**
211		* Create a directory.
212		*
213		* @param string $dirname directory name
214		* @param Config $config
215		*
216		* @return bool\|array
217		*/
218	4	public function createDir($dirname, Config $config)
219		{
220	4	return $this->upload($dirname . '/', '', $config);
221		}
222
223		/**
224		* Check whether a file exists.
225		*
226		* @param string $path
227		*
228		* @return bool
229		*/
230	12	public function has($path)
231		{
232	12	$location = $this->applyPathPrefix($path);
233
234	12	if ($this->s3Client->doesObjectExist($this->bucket, $location, $this->options)) {
235	2	return true;
236		}
237
238	10	return $this->doesDirectoryExist($location);
239		}
240
241		/**
242		* Read a file.
243		*
244		* @param string $path
245		*
246		* @return false\|array
247		*/
248	6	public function read($path)
249		{
250	6	$response = $this->readObject($path);
251
252	6	if ($response !== false) {
253	4	$response['contents'] = $response['contents']->getContents();
254	2	}
255
256	6	return $response;
257		}
258
259		/**
260		* List contents of a directory.
261		*
262		* @param string $directory
263		* @param bool $recursive
264		*
265		* @return array
266		*/
267	4	public function listContents($directory = '', $recursive = false)
268		{
269	4	$prefix = $this->applyPathPrefix(rtrim($directory, '/') . '/');
270	4	$options = ['Bucket' => $this->bucket, 'Prefix' => ltrim($prefix, '/')];
271
272	4	if ($recursive === false) {
273	4	$options['Delimiter'] = '/';
274	2	}
275
276	4	$listing = $this->retrievePaginatedListing($options);
277	4	$normalizer = [$this, 'normalizeResponse'];
278	4	$normalized = array_map($normalizer, $listing);
279
280	4	return Util::emulateDirectories($normalized);
281		}
282
283		/**
284		* @param array $options
285		*
286		* @return array
287		*/
288	4	protected function retrievePaginatedListing(array $options)
289		{
290	4	$resultPaginator = $this->s3Client->getPaginator('ListObjects', $options);
291	4	$listing = [];
292
293	4	foreach ($resultPaginator as $result) {
294	4	$listing = array_merge($listing, $result->get('Contents') ?: [], $result->get('CommonPrefixes') ?: []);
295	2	}
296
297	4	return $listing;
298		}
299
300		/**
301		* Get all the meta data of a file or directory.
302		*
303		* @param string $path
304		*
305		* @return false\|array
306		*/
307	14	public function getMetadata($path)
308		{
309	14	$command = $this->s3Client->getCommand(
310	14	'headObject',
311		[
312	14	'Bucket' => $this->bucket,
313	14	'Key' => $this->applyPathPrefix($path),
314	14	] + $this->options
315	7	);
316
317		/* @var Result $result */
318		try {
319	14	$result = $this->s3Client->execute($command);
320	9	} catch (S3Exception $exception) {
321	4	if ($this->is404Exception($exception)) {
322	2	return false;
323		}
324
325	2	throw $exception;
326		}
327
328	10	return $this->normalizeResponse($result->toArray(), $path);
329		}
330
331		/**
332		* @return bool
333		*/
334	4	private function is404Exception(S3Exception $exception)
335		{
336	4	$response = $exception->getResponse();
337
338	4	if ($response !== null && $response->getStatusCode() === 404) {
339	2	return true;
340		}
341
342	2	return false;
343		}
344
345		/**
346		* Get all the meta data of a file or directory.
347		*
348		* @param string $path
349		*
350		* @return false\|array
351		*/
352	2	public function getSize($path)
353		{
354	2	return $this->getMetadata($path);
355		}
356
357		/**
358		* Get the mimetype of a file.
359		*
360		* @param string $path
361		*
362		* @return false\|array
363		*/
364	2	public function getMimetype($path)
365		{
366	2	return $this->getMetadata($path);
367		}
368
369		/**
370		* Get the timestamp of a file.
371		*
372		* @param string $path
373		*
374		* @return false\|array
375		*/
376	2	public function getTimestamp($path)
377		{
378	2	return $this->getMetadata($path);
379		}
380
381		/**
382		* Write a new file using a stream.
383		*
384		* @param string $path
385		* @param resource $resource
386		* @param Config $config Config object
387		*
388		* @return array\|false false on failure file meta data on success
389		*/
390	4	public function writeStream($path, $resource, Config $config)
391		{
392	4	return $this->upload($path, $resource, $config);
393		}
394
395		/**
396		* Update a file using a stream.
397		*
398		* @param string $path
399		* @param resource $resource
400		* @param Config $config Config object
401		*
402		* @return array\|false false on failure file meta data on success
403		*/
404	4	public function updateStream($path, $resource, Config $config)
405		{
406	4	return $this->upload($path, $resource, $config);
407		}
408
409		/**
410		* Copy a file.
411		*
412		* @param string $path
413		* @param string $newpath
414		*
415		* @return bool
416		*/
417	8	public function copy($path, $newpath)
418		{
419	8	$command = $this->s3Client->getCommand(
420	8	'copyObject',
421		[
422	8	'Bucket' => $this->bucket,
423	8	'Key' => $this->applyPathPrefix($newpath),
424	8	'CopySource' => urlencode($this->bucket . '/' . $this->applyPathPrefix($path)),
425	8	'ACL' => $this->getRawVisibility($path) === AdapterInterface::VISIBILITY_PUBLIC
426	8	? 'public-read' : 'private',
427	8	] + $this->options
428	4	);
429
430		try {
431	8	$this->s3Client->execute($command);
432	6	} catch (S3Exception $e) {
433	4	return false;
434		}
435
436	4	return true;
437		}
438
439		/**
440		* Read a file as a stream.
441		*
442		* @param string $path
443		*
444		* @return array\|false
445		*/
446	6	public function readStream($path)
447		{
448	6	$response = $this->readObject($path);
449
450	6	if ($response !== false) {
451	6	$response['stream'] = $response['contents']->detach();
452	6	unset($response['contents']);
453	3	}
454
455	6	return $response;
456		}
457
458		/**
459		* Read an object and normalize the response.
460		*
461		* @param $path
462		*
463		* @return array\|bool
464		*/
465	10	protected function readObject($path)
466		{
467		$options = [
468	10	'Bucket' => $this->bucket,
469	10	'Key' => $this->applyPathPrefix($path),
470	5	];
471
472	10	if (isset($this->options['@http'])) {
473	2	$options['@http'] = $this->options['@http'];
474	1	}
475
476	10	$command = $this->s3Client->getCommand('getObject', $options + $this->options);
477
478		try {
479		/** @var Result $response */
480	10	$response = $this->s3Client->execute($command);
481	6	} catch (S3Exception $e) {
482	2	return false;
483		}
484
485	8	return $this->normalizeResponse($response->toArray(), $path);
486		}
487
488		/**
489		* Set the visibility for a file.
490		*
491		* @param string $path
492		* @param string $visibility
493		*
494		* @return array\|false file meta data
495		*/
496	6	public function setVisibility($path, $visibility)
497		{
498	6	$command = $this->s3Client->getCommand(
499	6	'putObjectAcl',
500		[
501	6	'Bucket' => $this->bucket,
502	6	'Key' => $this->applyPathPrefix($path),
503	6	'ACL' => $visibility === AdapterInterface::VISIBILITY_PUBLIC ? 'public-read' : 'private',
504		]
505	3	);
506
507		try {
508	6	$this->s3Client->execute($command);
509	4	} catch (S3Exception $exception) {
510	2	return false;
511		}
512
513	4	return compact('path', 'visibility');
514		}
515
516		/**
517		* Get the visibility of a file.
518		*
519		* @param string $path
520		*
521		* @return array\|false
522		*/
523	4	public function getVisibility($path)
524		{
525	4	return ['visibility' => $this->getRawVisibility($path)];
526		}
527
528		/**
529		* {@inheritdoc}
530		*/
531	68	public function applyPathPrefix($path)
532		{
533	68	return ltrim(parent::applyPathPrefix($path), '/');
534		}
535
536		/**
537		* {@inheritdoc}
538		*/
539	76	public function setPathPrefix($prefix)
540		{
541	76	$prefix = ltrim($prefix, '/');
542
543	76	return parent::setPathPrefix($prefix);
544		}
545
546		/**
547		* Get the object acl presented as a visibility.
548		*
549		* @param string $path
550		*
551		* @return string
552		*/
553	12	protected function getRawVisibility($path)
554		{
555	12	$command = $this->s3Client->getCommand(
556	12	'getObjectAcl',
557		[
558	12	'Bucket' => $this->bucket,
559	12	'Key' => $this->applyPathPrefix($path),
560		]
561	6	);
562
563	12	$result = $this->s3Client->execute($command);
564	12	$visibility = AdapterInterface::VISIBILITY_PRIVATE;
565
566	12	foreach ($result->get('Grants') as $grant) {
567		if (
568	2	isset($grant['Grantee']['URI'])
569	2	&& $grant['Grantee']['URI'] === self::PUBLIC_GRANT_URI
570	2	&& $grant['Permission'] === 'READ'
571	1	) {
572	2	$visibility = AdapterInterface::VISIBILITY_PUBLIC;
573	2	break;
574		}
575	6	}
576
577	12	return $visibility;
578		}
579
580		/**
581		* Upload an object.
582		*
583		* @param $path
584		* @param $body
585		* @param Config $config
586		*
587		* @return array\|bool
588		*/
589	14	protected function upload($path, $body, Config $config)
590		{
591	14	$key = $this->applyPathPrefix($path);
592	14	$options = $this->getOptionsFromConfig($config);
593	14	$acl = array_key_exists('ACL', $options) ? $options['ACL'] : 'private';
594
595	14	if (!$this->isOnlyDir($path)) {
596	12	if ( ! isset($options['ContentType'])) {
597	2	$options['ContentType'] = Util::guessMimeType($path, $body);
598	1	}
599
600	12	if ( ! isset($options['ContentLength'])) {
601	12	$options['ContentLength'] = is_resource($body) ? Util::getStreamSize($body) : Util::contentSize($body);
602	6	}
603
604	12	if ($options['ContentLength'] === null) {
605		unset($options['ContentLength']);
606		}
607	6	}
608
609		try {
610	14	$this->s3Client->upload($this->bucket, $key, $body, $acl, ['params' => $options]);
611	8	} catch (S3MultipartUploadException $multipartUploadException) {
612	2	return false;
613		}
614
615	12	return $this->normalizeResponse($options, $path);
616		}
617
618		/**
619		* Check if the path contains only directories
620		*
621		* @param string $path
622		* @return bool
623		*/
624	30	private function isOnlyDir($path)
625		{
626	30	return substr($path, -1) === '/';
627		}
628
629		/**
630		* Get options from the config.
631		*
632		* @param Config $config
633		*
634		* @return array
635		*/
636	14	protected function getOptionsFromConfig(Config $config)
637		{
638	14	$options = $this->options;
639
640	14	if ($visibility = $config->get('visibility')) {
641		// For local reference
642	10	$options['visibility'] = $visibility;
643		// For external reference
644	10	$options['ACL'] = $visibility === AdapterInterface::VISIBILITY_PUBLIC ? 'public-read' : 'private';
645	5	}
646
647	14	if ($mimetype = $config->get('mimetype')) {
648		// For local reference
649	10	$options['mimetype'] = $mimetype;
650		// For external reference
651	10	$options['ContentType'] = $mimetype;
652	5	}
653
654	14	foreach (static::$metaOptions as $option) {
655	14	if ( ! $config->has($option)) {
656	14	continue;
657		}
658	10	$options[$option] = $config->get($option);
659	7	}
660
661	14	return $options;
662		}
663
664		/**
665		* Normalize the object result array.
666		*
667		* @param array $response
668		* @param string $path
669		*
670		* @return array
671		*/
672	28	protected function normalizeResponse(array $response, $path = null)
673		{
674		$result = [
675	28	'path' => $path ?: $this->removePathPrefix(
676	16	isset($response['Key']) ? $response['Key'] : $response['Prefix']
677	14	),
678	14	];
679	28	$result = array_merge($result, Util::pathinfo($result['path']));
680
681	28	if (isset($response['LastModified'])) {
682	16	$result['timestamp'] = strtotime($response['LastModified']);
683	8	}
684
685	28	if ($this->isOnlyDir($result['path'])) {
686	6	$result['type'] = 'dir';
687	6	$result['path'] = rtrim($result['path'], '/');
688
689	6	return $result;
690		}
691
692	26	return array_merge($result, Util::map($response, static::$resultMap), ['type' => 'file']);
693		}
694
695		/**
696		* @param $location
697		*
698		* @return bool
699		*/
700	10	protected function doesDirectoryExist($location)
701		{
702		// Maybe this isn't an actual key, but a prefix.
703		// Do a prefix listing of objects to determine.
704	10	$command = $this->s3Client->getCommand(
705	10	'listObjects',
706		[
707	10	'Bucket' => $this->bucket,
708	10	'Prefix' => rtrim($location, '/') . '/',
709	10	'MaxKeys' => 1,
710		]
711	5	);
712
713		try {
714	10	$result = $this->s3Client->execute($command);
715
716	6	return $result['Contents'] \|\| $result['CommonPrefixes'];
717	4	} catch (S3Exception $e) {
718	4	if ($e->getStatusCode() === 403) {
719	2	return false;
720		}
721
722	2	throw $e;
723		}
724		}
725		}
726

thephpleague / flysystem-aws-s3-v3

Push — master ( b35251...8c47cf )

AwsS3Adapter::isOnlyDir() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like