ArgentCrusade\Selectel\CloudStorage\CloudStorage

Complexity

Total Complexity

11

Size/Duplication

Total Lines	123
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	containers()	0	17	2
A	getContainer()	0	4	1
A	createContainer()	0	21	4
A	transformContainers()	0	15	3

<?php

namespace ArgentCrusade\Selectel\CloudStorage;

use InvalidArgumentException;
use ArgentCrusade\Selectel\CloudStorage\Collections\Collection;
use ArgentCrusade\Selectel\CloudStorage\Contracts\CloudStorageContract;
use ArgentCrusade\Selectel\CloudStorage\Contracts\Api\ApiClientContract;
use ArgentCrusade\Selectel\CloudStorage\Exceptions\ApiRequestFailedException;

class CloudStorage implements CloudStorageContract
{
    /**
     * API Client instance.
     *
     * @var \ArgentCrusade\Selectel\CloudStorage\Contracts\Api\ApiClientContract
     */
    protected $api;

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

    /**
     * Creates new instance.
     *
     * @param \ArgentCrusade\Selectel\CloudStorage\Contracts\Api\ApiClientContract $api
     */
    public function __construct(ApiClientContract $api)
    {
        $this->api = $api;
        $this->uploader = new FileUploader();
    }

    /**
     * Available containers.
     *
     * @param int    $limit  = 10000
     * @param string $marker = ''
     *
     * @throws \ArgentCrusade\Selectel\CloudStorage\Exceptions\ApiRequestFailedException
     *
     * @return \ArgentCrusade\Selectel\CloudStorage\Contracts\Collections\CollectionContract
     */
    public function containers($limit = 10000, $marker = '')
    {
        $response = $this->api->request('GET', '/', [
            'query' => [
                'limit' => intval($limit),
                'marker' => $marker,
            ],
        ]);

        if ($response->getStatusCode() !== 200) {
            throw new ApiRequestFailedException('Unable to list containers.', $response->getStatusCode());
        }

        $containers = json_decode($response->getBody(), true);

        return new Collection($this->transformContainers($containers));
    }

    /**
     * Retrieves single container from cloud storage.
     *
     * @param string $name
     *
     * @return \ArgentCrusade\Selectel\CloudStorage\Contracts\ContainerContract
     */
    public function getContainer($name)
    {
        return new Container($this->api, $this->uploader, $name);
    }

    /**
     * Creates new container.
     *
     * @param string $name
     * @param string $type
     *
     * @throws \InvalidArgumentException
     * @throws \ArgentCrusade\Selectel\CloudStorage\Exceptions\ApiRequestFailedException
     *
     * @return \ArgentCrusade\Selectel\CloudStorage\Contracts\ContainerContract
     */
    public function createContainer($name, $type = 'public')
    {
        if (!in_array($type, ['public', 'private', 'gallery'])) {
            throw new InvalidArgumentException('Unknown type "'.$type.'" provided.');
        }

        $response = $this->api->request('PUT', '/'.trim($name, '/'), [
            'headers' => [
                'X-Container-Meta-Type' => $type,
            ],
        ]);

        switch ($response->getStatusCode()) {
            case 201:
                return $this->getContainer(trim($name, '/'));
            case 202:
                throw new ApiRequestFailedException('Container "'.$name.'" already exists.');
            default:
                throw new ApiRequestFailedException('Unable to create container "'.$name.'".', $response->getStatusCode());
        }
    }

    /**
     * Transforms containers response to Container objects.
     *
     * @param array $items
     *
     * @return array
     */
    protected function transformContainers(array $items)
    {
        if (!count($items)) {
            return [];
        }

        $containers = [];

        foreach ($items as $item) {
            $container = new Container($this->api, $this->uploader, $item['name'], $item);
            $containers[$container->name()] = $container;
        }

        return $containers;
    }
}