AlphaSnow\AliyunOssThink\AliyunOssAdapter

Complexity

Total Complexity

8

Size/Duplication

Total Lines	74
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	3

Test Coverage

Coverage

33.33%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	getOptionsFromConfig()	0	11	3
A	getUrl()	0	19	3
A	getTemporaryUrl()	0	8	1

<?php

namespace AlphaSnow\AliyunOssThink;

use Aliyun\Flysystem\AliyunOss\AliyunOssAdapter as BaseAdapter;
use League\Flysystem\Adapter\CanOverwriteFiles;
use League\Flysystem\AdapterInterface;
use League\Flysystem\Config;
use OSS\OssClient;

/**
 * Class AliyunOssAdapter
 * @package AlphaSnow\AliyunOssThink
 */
class AliyunOssAdapter extends BaseAdapter implements CanOverwriteFiles
{
    /**
     * @var array
     */
    protected $config;

    public function __construct(OssClient $client, array $config)
    {
        $this->config = $config;
        parent::__construct($client, $config['bucket'], $config['prefix'], $config['options']);
    }

    /**
     * {@inheritdoc}
     */
    protected function getOptionsFromConfig(Config $config)
    {
        $options = parent::getOptionsFromConfig($config);

        if ($visibility = $config->get('visibility')) {
            // Object ACL > Bucket ACL
            $options[OssClient::OSS_OBJECT_ACL] = $visibility === AdapterInterface::VISIBILITY_PUBLIC ? OssClient::OSS_ACL_TYPE_PUBLIC_READ : OssClient::OSS_ACL_TYPE_PRIVATE;
        }

        return $options;
    }

    /**
     * Used by \Illuminate\Filesystem\FilesystemAdapter::url
     *
     * @param string $path
     * @return string
     */
    public function getUrl($path)
    {
        $url = '';

        if ($this->config['is_ssl']) {
            $url .= 'https://';
        } else {
            $url .= 'http://';
        }

        if ($this->config['is_cname']) {
            $url .= $this->config['cdn_domain'];
        } else {
            $url .= $this->config['bucket'] . '.' . $this->config['endpoint'];
        }

        $url .= '/' . ltrim($path, '/');
        return $url;
    }

    /**
     * Used by \Illuminate\Filesystem\FilesystemAdapter::temporaryUrl
     * Get a temporary URL for the file at the given path.
     *
     * @param string $path
     * @param \DateTimeInterface $expiration
     * @param array $options
     * @return string
     *
     * @throws \RuntimeException
     */
    public function getTemporaryUrl($path, $expiration, array $options = [])
    {
        $object = $this->applyPathPrefix($path);
        $clientOptions = $this->getOptionsFromConfig(new Config($options));
        $timeout = $expiration->getTimestamp() - time();

        return $this->client->signUrl($this->bucket, $object, $timeout, OssClient::OSS_HTTP_GET, $clientOptions);
    }
}