ContentsFile\Aws\S3

Complexity

Total Complexity

26

Size/Duplication

Total Lines	190
Duplicated Lines	4.21 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
B	__construct()	8	29	7
A	getClient()	0	4	1
A	upload()	0	19	2
A	download()	0	11	2
A	copy()	0	14	2
A	delete()	0	13	2
A	deleteRecursive()	0	17	5
A	move()	0	9	3
A	fileExists()	0	4	1
A	getFileList()	0	7	1

<?php

namespace ContentsFile\Aws;

use Aws\Sdk;
use Cake\Core\Configure;
use Cake\Network\Exception\InternalErrorException;
use Cake\Network\Exception\NotFoundException;

/**
 * S3
 * AWS SDKのS3関係の処理
 * @author hagiwara
 */
class S3
{
    private $client;

    /**
     * __construct
     * @author hagiwara
     */
    public function __construct()
    {
        // S3に必要な設定がそろっているかチェックする
        $S3Setting = Configure::read('ContentsFile.Setting.S3');
        if (

This code seems to be duplicated across your project.

            !is_array($S3Setting) ||
            !array_key_exists('bucket', $S3Setting) ||
            !array_key_exists('tmpDir', $S3Setting) ||
            !array_key_exists('fileDir', $S3Setting)
        ) {
            throw new InternalErrorException('contentsFileS3Config paramater shortage');
        }
        // S3に接続するためのクライアントを用意します。
        $config = array(
            'version' => 'latest',
            'region'  => 'ap-northeast-1'
        );
        // key, secretが指定されている場合はcredentialsを設定する
        $key    = Configure::read('ContentsFile.Setting.S3.key');
        $secret = Configure::read('ContentsFile.Setting.S3.secret');
        if (!empty($key) && !empty($secret)) {
            $config['credentials'] = array(
                'key'=> $key,
                'secret' => $secret,
            );
        }
        $sdk = new Sdk($config);
        $this->client = $sdk->createS3();
    }

    /**
     * getClient
     * clientを取得
     * @author hagiwara
     */
    public function getClient()
    {
        return $this->client;
    }

    /**
     * upload
     * S3へのファイルアップロード
     * @author hagiwara
     */
    public function upload($filepath, $filename)
    {
        // アップロードするべきファイルがない場合
        if (!file_exists($filepath)) {
            throw new InternalErrorException('upload file not found');
        }
        $bucketName = Configure::read('ContentsFile.Setting.S3.bucket');
        $mimetype = mime_content_type($filepath);

        // ファイルのアップロード
        $data = file_get_contents($filepath);

        return $this->client->putObject([
            'Bucket' => $bucketName,
            'Key' => $filename,
            'Body' => $data,
            'ContentType' => $mimetype
        ]);
    }

    /**
     * upload
     * S3からのファイルダウンロード
     * @author hagiwara
     */
    public function download($filename)
    {
        // ファイルが存在しない場合は404
        if (!$this->fileExists($filename)) {
            throw new NotFoundException('404 error');
        }
        return $this->client->getObject([
            'Bucket' => Configure::read('ContentsFile.Setting.S3.bucket'),
            'Key' => $filename
        ]);
    }

    /**
     * copy
     * S3上でのファイルコピー
     * @author hagiwara
     */
    public function copy($oldFilename, $newFilename)
    {
        // ファイルが存在しない
        if (!$this->fileExists($oldFilename)) {
            return false;
        }
        // 権限不足のExceptionはそのまま出す
        $this->client->copyObject(array(
            'Bucket' => Configure::read('ContentsFile.Setting.S3.bucket'),
            'Key'        => $newFilename,
            'CopySource' => Configure::read('ContentsFile.Setting.S3.bucket') . '/' . $oldFilename,
        ));
        return true;
    }

    /**
     * delete
     * S3上でのファイル削除
     * @author hagiwara
     */
    public function delete($filename)
    {
        // 削除するファイルが存在しない
        if (!$this->fileExists($filename)) {
            return false;
        }
        // 権限不足のExceptionはそのまま出す
        $this->client->deleteObject(array(
            'Bucket' => Configure::read('ContentsFile.Setting.S3.bucket'),
            'Key' => $filename,
        ));
        return true;
    }

    /**
     * deleteRecursive
     * S3上でのファイル削除(再帰的)
     * @author hagiwara
     */
    public function deleteRecursive($dirname)
    {
        // $dirnameで消す単位は最低でもIDなので文字列内に数値のディレクトリがあることをチェックする
        if (!preg_match('#/[0-9]+/#', $dirname)) {
            return false;
        }
        $deleteFileLists = $this->getFileList($dirname);

        if (!empty($deleteFileLists)) {
            foreach ($deleteFileLists as $deleteDirInfo) {
                if (!$this->delete($deleteDirInfo['Key'])) {
                    return false;
                }
            }
        }
        return true;
    }

    /**
     * move
     * S3上でのファイル移動(コピー&削除)
     * @author hagiwara
     */
    public function move($oldFilename, $newFilename)
    {
        // 移動するファイルが存在しない
        if (!$this->fileExists($oldFilename)) {
            return false;
        }
        // 失敗時はException
        return $this->copy($oldFilename, $newFilename) && $this->delete($oldFilename);
    }

    /**
     * fileExists
     * S3上でのファイルの存在チェック(ディレクトリ存在チェックも兼)
     * @author hagiwara
     */
    public function fileExists($filename)
    {
        return !empty($this->getFileList($filename));
    }

    /**
     * getFileList
     * 特定ディレクトリ内のfileの一覧取得
     * @author hagiwara
     */
    public function getFileList($dirname)
    {
        return $this->client->listObjects(array(
            'Bucket' => Configure::read('ContentsFile.Setting.S3.bucket'),
            'Prefix' => $dirname
        ))->get('Contents');
    }
}