ByJG\AnyDataset\Store\AwsS3Driver

Complexity

Total Complexity

8

Size/Duplication

Total Lines	107
Duplicated Lines	22.43 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

0%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	15	1
A	getIterator()	0	13	1
A	get()	12	12	1
A	put()	0	21	3
A	remove()	12	12	1
A	getDbConnection()	0	4	1

<?php
/**
 * User: jg
 * Date: 08/02/17
 * Time: 19:55
 */

namespace ByJG\AnyDataset\Store;

use Aws\S3\S3Client;
use ByJG\AnyDataset\Dataset\GenericIterator;
use ByJG\AnyDataset\KeyValueInterface;
use ByJG\AnyDataset\Dataset\ArrayDataset;
use ByJG\Util\Uri;

class AwsS3Driver implements KeyValueInterface
{

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

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

    /**
     * AwsS3Driver constructor.
     *
     *  s3://key:secret@region/bucket
     *
     * @param string $connectionString
     */
    public function __construct($connectionString)
    {
        $uri = new Uri($connectionString);

        $this->s3Client = new S3Client([
            'version'     => 'latest',
            'region'      => $uri->getHost(),
            'credentials' => [
                'key'    => $uri->getUsername(),
                'secret' => $uri->getPassword(),
            ],
        ]);

        $this->bucket = preg_replace('~^/~', '', $uri->getPath());
    }

    /**
     * @param array $options
     * @return GenericIterator
     */
    public function getIterator($options = [])
    {
        $data = array_merge(
            [
                'Bucket' => $this->bucket,
            ],
            $options
        );

        $result = $this->s3Client->listObjects($data);

        return (new ArrayDataset($result['Contents']))->getIterator();
    }

    public function get($key, $options = [])

This method seems to be duplicated in your project.

    {
        $data = array_merge(
            [
                'Bucket' => $this->bucket,
                'Key'    => $key
            ],
            $options
        );

        return $this->s3Client->getObject($data);
    }

    public function put($key, $value, $contentType = null, $options = [])
    {
        $data = array_merge(
            [
                'Bucket' => $this->bucket,
                'Key'    => $key,
                'Body'   => $value,
            ],
            $options
        );

        if (!empty($contentType)) {
            $data['ContentType'] = $contentType;
        }

        if (!isset($data['ACL'])) {
            $data['ACL'] = 'private';
        }

        return $this->s3Client->putObject($data);
    }

    public function remove($key, $options = [])

This method seems to be duplicated in your project.

    {
        $data = array_merge(
            [
                'Bucket' => $this->bucket,
                'Key'    => $key
            ],
            $options
        );

        $this->s3Client->deleteObject($data);
    }

    public function getDbConnection()
    {
        return $this->s3Client;
    }
}