Container::uploadFromStream() - Code Metrics - ArgentCrusade/selectel-cloud-storage - Measure and Improve Code Quality continuously with Scrutinizer

Container::uploadFromStream() A
last analyzed 2017-07-28 17:30 UTC

↳ Parent: Container

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	4
rs	10
c	0
b	0
f	0
cc	1
eloc	2
nc	1
nop	3

<?php

namespace ArgentCrusade\Selectel\CloudStorage;

use Countable;
use JsonSerializable;
use ArgentCrusade\Selectel\CloudStorage\Traits\MetaData;
use ArgentCrusade\Selectel\CloudStorage\Contracts\HasMetaData;
use ArgentCrusade\Selectel\CloudStorage\Traits\FilesTransformer;
use ArgentCrusade\Selectel\CloudStorage\Contracts\ContainerContract;
use ArgentCrusade\Selectel\CloudStorage\Contracts\Api\ApiClientContract;
use ArgentCrusade\Selectel\CloudStorage\Contracts\FilesTransformerContract;
use ArgentCrusade\Selectel\CloudStorage\Exceptions\ApiRequestFailedException;

class Container implements ContainerContract, FilesTransformerContract, Countable, JsonSerializable, HasMetaData
{
    use FilesTransformer, MetaData;

    /**
     * @var \ArgentCrusade\Selectel\CloudStorage\Contracts\Api\ApiClientContract $api
     */
    protected $api;

    /**
     * File uploader.
     *
     * @var \ArgentCrusade\Selectel\CloudStorage\Contracts\FileUploaderContract
     */
    protected $uploader;

    /**
     * Container name.
     *
     * @var string
     */
    protected $containerName;

    /**
     * Container data.
     *
     * @var array
     */
    protected $data = [];

    /**
     * Determines if container data was already loaded.
     *
     * @var bool
     */
    protected $dataLoaded = false;

    /**
     * Container URL. Uses "X-Storage-Url/container-name" by default.
     *
     * @var string
     */
    protected $url;

    /**
     * @param \ArgentCrusade\Selectel\CloudStorage\Contracts\Api\ApiClientContract $api
     * @param \ArgentCrusade\Selectel\CloudStorage\FileUploader                    $uploader
     * @param string                                                               $name
     * @param array                                                                $data
     */
    public function __construct(ApiClientContract $api, FileUploader $uploader, $name, array $data = [])
    {
        $this->api = $api;
        $this->uploader = $uploader;
        $this->containerName = $name;
        $this->data = $data;
        $this->dataLoaded = !empty($data);
        $this->url = rtrim($api->storageUrl(), '/').'/'.$name;
    }

    /**
     * Returns specific container data.
     *
     * @param string $key
     * @param mixed  $default = null
     *
     * @return mixed
     */
    protected function objectData($key, $default = null)
    {
        if (!$this->dataLoaded) {
            $this->loadContainerData();
        }

        return isset($this->data[$key]) ? $this->data[$key] : $default;
    }

    /**
     * Container data lazy loader.
     *
     * @throws \ArgentCrusade\Selectel\CloudStorage\Exceptions\ApiRequestFailedException
     */
    protected function loadContainerData()
    {
        // CloudStorage::containers and CloudStorage::getContainer methods did not
        // produce any requests to Selectel API, since it may be unnecessary if
        // user only wants to upload/manage files or delete container via API.

        // If user really wants some container info, we will load
        // it here on demand. This speeds up application a bit.

        $response = $this->api->request('HEAD', $this->absolutePath());

        if ($response->getStatusCode() !== 204) {
            throw new ApiRequestFailedException('Container "'.$this->name().'" was not found.');
        }

        $this->dataLoaded = true;

        // We will extract some headers from response
        // and assign them as container data. Also
        // we'll try to find any container Meta.

        $this->data = [
            'type' => $response->getHeaderLine('X-Container-Meta-Type'),
            'count' => intval($response->getHeaderLine('X-Container-Object-Count')),
            'bytes' => intval($response->getHeaderLine('X-Container-Bytes-Used')),
            'rx_bytes' => intval($response->getHeaderLine('X-Received-Bytes')),
            'tx_bytes' => intval($response->getHeaderLine('X-Transfered-Bytes')),
            'meta' => $this->extractMetaData($response),
        ];
    }

    /**
     * Returns object meta type.
     *
     * @return string
     */
    protected function objectMetaType()
    {
        return 'Container';
    }

    /**
     * Absolute path to file from storage root.
     *
     * @param string $path = '' Relative file path.
     *
     * @return string
     */
    protected function absolutePath($path = '')
    {
        return '/'.$this->name().($path ? '/'.ltrim($path, '/') : '');
    }

    /**
     * API Client.
     *
     * @return \ArgentCrusade\Selectel\CloudStorage\Contracts\Api\ApiClientContract
     */
    public function apiClient()
    {
        return $this->api;
    }

    /**
     * JSON representation of container.
     *
     * @return array
     */
    public function jsonSerialize()
    {
        return [
            'name' => $this->name(),
            'type' => $this->type(),
            'files_count' => $this->filesCount(),
            'size' => $this->size(),
            'uploaded_bytes' => $this->uploadedBytes(),
            'downloaded_bytes' => $this->downloadedBytes(),
        ];
    }

    /**
     * Container name.
     *
     * @return string
     */
    public function name()
    {
        return $this->containerName();
    }

    /**
     * Container name.
     *
     * @return string
     */
    public function containerName()
    {
        return $this->containerName;
    }

    /**
     * Get container's root URL.
     *
     * @param string $path = ''
     *
     * @return string
     */
    public function url($path = '')
    {
        return $this->url.($path ? '/'.ltrim($path, '/') : '');
    }

    /**
     * Container type.
     *
     * @return string
     */
    public function type()
    {
        return $this->objectData('type', 'public');
    }

    /**
     * Container files count.
     *
     * @return int
     */
    public function filesCount()
    {
        return intval($this->objectData('count', 0));
    }

    /**
     * Container files count.
     *
     * @return int
     */
    public function count()
    {
        return $this->filesCount();
    }

    /**
     * Container size in bytes.
     *
     * @return int
     */
    public function size()
    {
        return intval($this->objectData('bytes', 0));
    }

    /**
     * Total uploaded (received) bytes.
     *
     * @return int
     */
    public function uploadedBytes()
    {
        return intval($this->objectData('rx_bytes', 0));
    }

    /**
     * Total downloaded (transmitted) bytes.
     *
     * @return int
     */
    public function downloadedBytes()
    {
        return intval($this->objectData('tx_bytes', 0));
    }

    /**
     * Updates container type.
     *
     * @param string $type Container type: 'public', 'private' or 'gallery'.
     *
     * @throws \ArgentCrusade\Selectel\CloudStorage\Exceptions\ApiRequestFailedException
     *
     * @return string
     */
    public function setType($type)
    {
        if ($this->type() === $type) {
            return $type;
        }

        // Catch any API Request Exceptions here
        // so we can replace exception message
        // with more informative one.

        try {
            $this->setMeta(['Type' => $type]);
        } catch (ApiRequestFailedException $e) {
            throw new ApiRequestFailedException('Unable to set container type to "'.$type.'".', $e->getCode());
        }

        return $this->data['type'] = $type;
    }

    /**
     * Set container's root URL.
     *
     * @param string $url
     *
     * @return static
     */
    public function setUrl($url)
    {
        $this->url = $url;

        return $this;
    }

    /**
     * Creates new Fluent files loader instance.
     *
     * @return \ArgentCrusade\Selectel\CloudStorage\Contracts\FluentFilesLoaderContract
     */
    public function files()
    {
        return new FluentFilesLoader($this->api, $this->name(), $this->absolutePath());
    }

    /**
     * Creates new directory.
     *
     * @param string $name Directory name.
     *
     * @throws \ArgentCrusade\Selectel\CloudStorage\Exceptions\ApiRequestFailedException
     *
     * @return string
     */
    public function createDir($name)
    {
        $response = $this->api->request('PUT', $this->absolutePath($name), [
            'headers' => [
                'Content-Type' => 'application/directory',
            ],
        ]);

        if ($response->getStatusCode() !== 201) {
            throw new ApiRequestFailedException('Unable to create directory "'.$name.'".', $response->getStatusCode());
        }

        return $response->getHeaderLine('ETag');
    }

    /**
     * Deletes directory.
     *
     * @param string $name Directory name.
     *
     * @throws \ArgentCrusade\Selectel\CloudStorage\Exceptions\ApiRequestFailedException
     *
     * @return bool
     */
    public function deleteDir($name)
    {
        $response = $this->api->request('DELETE', $this->absolutePath($name));

        if ($response->getStatusCode() !== 204) {
            throw new ApiRequestFailedException('Unable to delete directory "'.$name.'".', $response->getStatusCode());
        }

        return true;
    }

    /**
     * Uploads file contents from string. Returns ETag header value if upload was successful.
     *
     * @param string $path           Remote path.
     * @param string $contents       File contents.
     * @param array  $params         = [] Upload params.
     * @param bool   $verifyChecksum = true
     *
     * @throws \ArgentCrusade\Selectel\CloudStorage\Exceptions\UploadFailedException
     *
     * @return string
     */
    public function uploadFromString($path, $contents, array $params = [], $verifyChecksum = true)
    {
        return $this->uploader->upload($this->api, $this->absolutePath($path), $contents, $params, $verifyChecksum);
    }

    /**
     * Uploads file from stream. Returns ETag header value if upload was successful.
     *
     * @param string   $path     Remote path.
     * @param resource $resource Stream resource.
     * @param array    $params   = [] Upload params.
     *
     * @throws \ArgentCrusade\Selectel\CloudStorage\Exceptions\UploadFailedException
     *
     * @return string
     */
    public function uploadFromStream($path, $resource, array $params = [])
    {
        return $this->uploader->upload($this->api, $this->absolutePath($path), $resource, $params, false);
    }

    /**
     * Deletes container. Container must be empty in order to perform this operation.
     *
     * @throws \ArgentCrusade\Selectel\CloudStorage\Exceptions\ApiRequestFailedException
     */
    public function delete()
    {
        $response = $this->api->request('DELETE', $this->absolutePath());

        switch ($response->getStatusCode()) {
            case 204:
                // Container removed.
                return;
            case 404:
                throw new ApiRequestFailedException('Container "'.$this->name().'" was not found.');
            case 409:
                throw new ApiRequestFailedException('Container must be empty.');
        }
    }
}


1			<?php
2
3			namespace ArgentCrusade\Selectel\CloudStorage;
4
5			use Countable;
6			use JsonSerializable;
7			use ArgentCrusade\Selectel\CloudStorage\Traits\MetaData;
8			use ArgentCrusade\Selectel\CloudStorage\Contracts\HasMetaData;
9			use ArgentCrusade\Selectel\CloudStorage\Traits\FilesTransformer;
10			use ArgentCrusade\Selectel\CloudStorage\Contracts\ContainerContract;
11			use ArgentCrusade\Selectel\CloudStorage\Contracts\Api\ApiClientContract;
12			use ArgentCrusade\Selectel\CloudStorage\Contracts\FilesTransformerContract;
13			use ArgentCrusade\Selectel\CloudStorage\Exceptions\ApiRequestFailedException;
14
15			class Container implements ContainerContract, FilesTransformerContract, Countable, JsonSerializable, HasMetaData
16			{
17			use FilesTransformer, MetaData;
18
19			/**
20			* @var \ArgentCrusade\Selectel\CloudStorage\Contracts\Api\ApiClientContract $api
21			*/
22			protected $api;
23
24			/**
25			* File uploader.
26			*
27			* @var \ArgentCrusade\Selectel\CloudStorage\Contracts\FileUploaderContract
28			*/
29			protected $uploader;
30
31			/**
32			* Container name.
33			*
34			* @var string
35			*/
36			protected $containerName;
37
38			/**
39			* Container data.
40			*
41			* @var array
42			*/
43			protected $data = [];
44
45			/**
46			* Determines if container data was already loaded.
47			*
48			* @var bool
49			*/
50			protected $dataLoaded = false;
51
52			/**
53			* Container URL. Uses "X-Storage-Url/container-name" by default.
54			*
55			* @var string
56			*/
57			protected $url;
58
59			/**
60			* @param \ArgentCrusade\Selectel\CloudStorage\Contracts\Api\ApiClientContract $api
61			* @param \ArgentCrusade\Selectel\CloudStorage\FileUploader $uploader
62			* @param string $name
63			* @param array $data
64			*/
65			public function __construct(ApiClientContract $api, FileUploader $uploader, $name, array $data = [])
66			{
67			$this->api = $api;
68			$this->uploader = $uploader;
69			$this->containerName = $name;
70			$this->data = $data;
71			$this->dataLoaded = !empty($data);
72			$this->url = rtrim($api->storageUrl(), '/').'/'.$name;
73			}
74
75			/**
76			* Returns specific container data.
77			*
78			* @param string $key
79			* @param mixed $default = null
80			*
81			* @return mixed
82			*/
83			protected function objectData($key, $default = null)
84			{
85			if (!$this->dataLoaded) {
86			$this->loadContainerData();
87			}
88
89			return isset($this->data[$key]) ? $this->data[$key] : $default;
90			}
91
92			/**
93			* Container data lazy loader.
94			*
95			* @throws \ArgentCrusade\Selectel\CloudStorage\Exceptions\ApiRequestFailedException
96			*/
97			protected function loadContainerData()
98			{
99			// CloudStorage::containers and CloudStorage::getContainer methods did not
100			// produce any requests to Selectel API, since it may be unnecessary if
101			// user only wants to upload/manage files or delete container via API.
102
103			// If user really wants some container info, we will load
104			// it here on demand. This speeds up application a bit.
105
106			$response = $this->api->request('HEAD', $this->absolutePath());
107
108			if ($response->getStatusCode() !== 204) {
109			throw new ApiRequestFailedException('Container "'.$this->name().'" was not found.');
110			}
111
112			$this->dataLoaded = true;
113
114			// We will extract some headers from response
115			// and assign them as container data. Also
116			// we'll try to find any container Meta.
117
118			$this->data = [
119			'type' => $response->getHeaderLine('X-Container-Meta-Type'),
120			'count' => intval($response->getHeaderLine('X-Container-Object-Count')),
121			'bytes' => intval($response->getHeaderLine('X-Container-Bytes-Used')),
122			'rx_bytes' => intval($response->getHeaderLine('X-Received-Bytes')),
123			'tx_bytes' => intval($response->getHeaderLine('X-Transfered-Bytes')),
124			'meta' => $this->extractMetaData($response),
125			];
126			}
127
128			/**
129			* Returns object meta type.
130			*
131			* @return string
132			*/
133			protected function objectMetaType()
134			{
135			return 'Container';
136			}
137
138			/**
139			* Absolute path to file from storage root.
140			*
141			* @param string $path = '' Relative file path.
142			*
143			* @return string
144			*/
145			protected function absolutePath($path = '')
146			{
147			return '/'.$this->name().($path ? '/'.ltrim($path, '/') : '');
148			}
149
150			/**
151			* API Client.
152			*
153			* @return \ArgentCrusade\Selectel\CloudStorage\Contracts\Api\ApiClientContract
154			*/
155			public function apiClient()
156			{
157			return $this->api;
158			}
159
160			/**
161			* JSON representation of container.
162			*
163			* @return array
164			*/
165			public function jsonSerialize()
166			{
167			return [
168			'name' => $this->name(),
169			'type' => $this->type(),
170			'files_count' => $this->filesCount(),
171			'size' => $this->size(),
172			'uploaded_bytes' => $this->uploadedBytes(),
173			'downloaded_bytes' => $this->downloadedBytes(),
174			];
175			}
176
177			/**
178			* Container name.
179			*
180			* @return string
181			*/
182			public function name()
183			{
184			return $this->containerName();
185			}
186
187			/**
188			* Container name.
189			*
190			* @return string
191			*/
192			public function containerName()
193			{
194			return $this->containerName;
195			}
196
197			/**
198			* Get container's root URL.
199			*
200			* @param string $path = ''
201			*
202			* @return string
203			*/
204			public function url($path = '')
205			{
206			return $this->url.($path ? '/'.ltrim($path, '/') : '');
207			}
208
209			/**
210			* Container type.
211			*
212			* @return string
213			*/
214			public function type()
215			{
216			return $this->objectData('type', 'public');
217			}
218
219			/**
220			* Container files count.
221			*
222			* @return int
223			*/
224			public function filesCount()
225			{
226			return intval($this->objectData('count', 0));
227			}
228
229			/**
230			* Container files count.
231			*
232			* @return int
233			*/
234			public function count()
235			{
236			return $this->filesCount();
237			}
238
239			/**
240			* Container size in bytes.
241			*
242			* @return int
243			*/
244			public function size()
245			{
246			return intval($this->objectData('bytes', 0));
247			}
248
249			/**
250			* Total uploaded (received) bytes.
251			*
252			* @return int
253			*/
254			public function uploadedBytes()
255			{
256			return intval($this->objectData('rx_bytes', 0));
257			}
258
259			/**
260			* Total downloaded (transmitted) bytes.
261			*
262			* @return int
263			*/
264			public function downloadedBytes()
265			{
266			return intval($this->objectData('tx_bytes', 0));
267			}
268
269			/**
270			* Updates container type.
271			*
272			* @param string $type Container type: 'public', 'private' or 'gallery'.
273			*
274			* @throws \ArgentCrusade\Selectel\CloudStorage\Exceptions\ApiRequestFailedException
275			*
276			* @return string
277			*/
278			public function setType($type)
279			{
280			if ($this->type() === $type) {
281			return $type;
282			}
283
284			// Catch any API Request Exceptions here
285			// so we can replace exception message
286			// with more informative one.
287
288			try {
289			$this->setMeta(['Type' => $type]);
290			} catch (ApiRequestFailedException $e) {
291			throw new ApiRequestFailedException('Unable to set container type to "'.$type.'".', $e->getCode());
292			}
293
294			return $this->data['type'] = $type;
295			}
296
297			/**
298			* Set container's root URL.
299			*
300			* @param string $url
301			*
302			* @return static
303			*/
304			public function setUrl($url)
305			{
306			$this->url = $url;
307
308			return $this;
309			}
310
311			/**
312			* Creates new Fluent files loader instance.
313			*
314			* @return \ArgentCrusade\Selectel\CloudStorage\Contracts\FluentFilesLoaderContract
315			*/
316			public function files()
317			{
318			return new FluentFilesLoader($this->api, $this->name(), $this->absolutePath());
319			}
320
321			/**
322			* Creates new directory.
323			*
324			* @param string $name Directory name.
325			*
326			* @throws \ArgentCrusade\Selectel\CloudStorage\Exceptions\ApiRequestFailedException
327			*
328			* @return string
329			*/
330			public function createDir($name)
331			{
332			$response = $this->api->request('PUT', $this->absolutePath($name), [
333			'headers' => [
334			'Content-Type' => 'application/directory',
335			],
336			]);
337
338			if ($response->getStatusCode() !== 201) {
339			throw new ApiRequestFailedException('Unable to create directory "'.$name.'".', $response->getStatusCode());
340			}
341
342			return $response->getHeaderLine('ETag');
343			}
344
345			/**
346			* Deletes directory.
347			*
348			* @param string $name Directory name.
349			*
350			* @throws \ArgentCrusade\Selectel\CloudStorage\Exceptions\ApiRequestFailedException
351			*
352			* @return bool
353			*/
354			public function deleteDir($name)
355			{
356			$response = $this->api->request('DELETE', $this->absolutePath($name));
357
358			if ($response->getStatusCode() !== 204) {
359			throw new ApiRequestFailedException('Unable to delete directory "'.$name.'".', $response->getStatusCode());
360			}
361
362			return true;
363			}
364
365			/**
366			* Uploads file contents from string. Returns ETag header value if upload was successful.
367			*
368			* @param string $path Remote path.
369			* @param string $contents File contents.
370			* @param array $params = [] Upload params.
371			* @param bool $verifyChecksum = true
372			*
373			* @throws \ArgentCrusade\Selectel\CloudStorage\Exceptions\UploadFailedException
374			*
375			* @return string
376			*/
377			public function uploadFromString($path, $contents, array $params = [], $verifyChecksum = true)
378			{
379			return $this->uploader->upload($this->api, $this->absolutePath($path), $contents, $params, $verifyChecksum);
380			}
381
382			/**
383			* Uploads file from stream. Returns ETag header value if upload was successful.
384			*
385			* @param string $path Remote path.
386			* @param resource $resource Stream resource.
387			* @param array $params = [] Upload params.
388			*
389			* @throws \ArgentCrusade\Selectel\CloudStorage\Exceptions\UploadFailedException
390			*
391			* @return string
392			*/
393			public function uploadFromStream($path, $resource, array $params = [])
394			{
395			return $this->uploader->upload($this->api, $this->absolutePath($path), $resource, $params, false);
396			}
397
398			/**
399			* Deletes container. Container must be empty in order to perform this operation.
400			*
401			* @throws \ArgentCrusade\Selectel\CloudStorage\Exceptions\ApiRequestFailedException
402			*/
403			public function delete()
404			{
405			$response = $this->api->request('DELETE', $this->absolutePath());
406
407			switch ($response->getStatusCode()) {
408			case 204:
409			// Container removed.
410			return;
411			case 404:
412			throw new ApiRequestFailedException('Container "'.$this->name().'" was not found.');
413			case 409:
414			throw new ApiRequestFailedException('Container must be empty.');
415			}
416			}
417			}
418

ArgentCrusade / selectel-cloud-storage

Container::uploadFromStream() A last analyzed 2017-07-28 17:30 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

Container::uploadFromStream() A
last analyzed 2017-07-28 17:30 UTC