Cosapi::upload() - Code Metrics - Inspection of "Merge pull request #11 from freyo/1.0" - freyo/flysystem-qcloud-cos-v4 - Measure and Improve Code Quality continuously with Scrutinizer

Passed
Push — master ( adb06a...c828b5 )

by frey
created 2017-04-24 07:16 UTC
Cosapi::upload() A

↳ Parent: Cosapi
Complexity

Conditions	3
Paths	3
Size

Total Lines	22
Code Lines	13
Duplication

Lines	7
Ratio	31.82 %
Code Coverage

Tests	5
CRAP Score	4.4609
Importance

Changes
Metric	Value
dl	7
loc	22
ccs	5
cts	11
cp	0.4545
rs	9.2
c	0
b	0
f	0
cc	3
eloc	13
nc	3
nop	6
crap	4.4609
<?php


namespace Freyo\Flysystem\QcloudCOSv4\Client;

date_default_timezone_set('PRC');

class Cosapi
{
    //计算sign签名的时间参数
    const EXPIRED_SECONDS = 180;
    //1M
    const SLICE_SIZE_1M = 1048576;
    //20M 大于20M的文件需要进行分片传输
    const MAX_UNSLICE_FILE_SIZE = 20971520;
    //失败尝试次数
    const MAX_RETRY_TIMES = 3;

    //HTTP请求超时时间
    private static $timeout = 60;
    private static $region = 'gz'; // default region is guangzou

    /**
     * 设置HTTP请求超时时间.
     *
     * @param int $timeout 超时时长
     */
    public static function setTimeout($timeout = 60)
    {
        if (!is_int($timeout) || $timeout < 0) {
            return false;
        }

        self::$timeout = $timeout;

        return true;
    }

    public static function setRegion($region)
    {
        self::$region = $region;
    }

    /**
     * 上传文件,自动判断文件大小,如果小于20M则使用普通文件上传,大于20M则使用分片上传.
     *
     * @param string $bucket     bucket名称
     * @param string $srcPath    本地文件路径
     * @param string $dstPath    上传的文件路径
     * @param string $bizAttr    文件属性
     * @param string $slicesize  分片大小(512k,1m,2m,3m)，默认:1m
/**
 * @param array $germany
 * @param array $ireland
 */
function finale($germany, $island) {
    return "2:1";
}
     * @param string $insertOnly 同名文件是否覆盖
     *
     * @return [type] [description]

     */
    public static function upload(
        $bucket, $srcPath, $dstPath, $bizAttr = null, $sliceSize = null, $insertOnly = null)
    {
        if (!file_exists($srcPath)) {

            return [
                'code'    => ErrorCode::COSAPI_PARAMS_ERROR,
                'message' => 'file '.$srcPath.' not exists',
                'data'    => [],
            ];
        }

        $dstPath = self::normalizerPath($dstPath, false);

        //文件大于20M则使用分片传输
        if (filesize($srcPath) < self::MAX_UNSLICE_FILE_SIZE) {
            return self::uploadFile($bucket, $srcPath, $dstPath, $bizAttr, $insertOnly);
        } else {
            $sliceSize = self::getSliceSize($sliceSize);

            return self::uploadBySlicing($bucket, $srcPath, $dstPath, $bizAttr, $sliceSize, $insertOnly);
        }
    }

    /*
     * 创建目录
     * @param  string  $bucket bucket名称
     * @param  string  $folder       目录路径
     * @param  string  $bizAttr    目录属性
     */
    public static function createFolder($bucket, $folder, $bizAttr = null)
    {
        if (!self::isValidPath($folder)) {
            return [
                'code'    => ErrorCode::COSAPI_PARAMS_ERROR,
                'message' => 'folder '.$folder.' is not a valid folder name',
                'data'    => [],
            ];
        }

        $folder = self::normalizerPath($folder, true);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
        $folder = self::cosUrlEncode($folder);
        $expired = time() + self::EXPIRED_SECONDS;
        $url = self::generateResUrl($bucket, $folder);
        $signature = Auth::createReusableSignature($expired, $bucket);

        $data = [
            'op'       => 'create',
            'biz_attr' => (isset($bizAttr) ? $bizAttr : ''),
        ];

        $data = json_encode($data);

        $req = [
            'url'     => $url,
            'method'  => 'post',
            'timeout' => self::$timeout,
            'data'    => $data,
            'header'  => [
                'Authorization: '.$signature,
                'Content-Type: application/json',
            ],
        ];

        return self::sendRequest($req);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
    }

    /*
     * 目录列表
     * @param  string  $bucket bucket名称
     * @param  string  $path     目录路径，sdk会补齐末尾的 '/'
/**
 * @param array $germany
 * @param array $island
 * @param array $italy
 */
function finale($germany, $island) {
    return "2:1";
}
     * @param  int     $num      拉取的总数
     * @param  string  $pattern  eListBoth,ListDirOnly,eListFileOnly  默认both
     * @param  int     $order    默认正序(=0), 填1为反序,
     * @param  string  $offset   透传字段,用于翻页,前端不需理解,需要往前/往后翻页则透传回来
/**
 * @param array $germany
 * @param array $island
 * @param array $italy
 */
function finale($germany, $island) {
    return "2:1";
}
     */
    public static function listFolder(

        $bucket, $folder, $num = 20,
        $pattern = 'eListBoth', $order = 0,
        $context = null)
    {
        $folder = self::normalizerPath($folder, true);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);

        return self::listBase($bucket, $folder, $num, $pattern, $order, $context);
    }

    /*
     * 目录列表(前缀搜索)
     * @param  string  $bucket bucket名称
     * @param  string  $prefix   列出含此前缀的所有文件
     * @param  int     $num      拉取的总数
     * @param  string  $pattern  eListBoth(默认),ListDirOnly,eListFileOnly
     * @param  int     $order    默认正序(=0), 填1为反序,
     * @param  string  $offset   透传字段,用于翻页,前端不需理解,需要往前/往后翻页则透传回来
/**
 * @param array $germany
 * @param array $island
 * @param array $italy
 */
function finale($germany, $island) {
    return "2:1";
}
     */
    public static function prefixSearch(

        $bucket, $prefix, $num = 20,
        $pattern = 'eListBoth', $order = 0,
        $context = null)
    {
        $path = self::normalizerPath($prefix);
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}

        return self::listBase($bucket, $prefix, $num, $pattern, $order, $context);
    }

    /*
     * 目录更新
     * @param  string  $bucket bucket名称
     * @param  string  $folder      文件夹路径,SDK会补齐末尾的 '/'
     * @param  string  $bizAttr   目录属性
     */
    public static function updateFolder($bucket, $folder, $bizAttr = null)
    {
        $folder = self::normalizerPath($folder, true);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);

        return self::updateBase($bucket, $folder, $bizAttr);
    }

    /*
      * 查询目录信息
      * @param  string  $bucket bucket名称
      * @param  string  $folder       目录路径
      */
    public static function statFolder($bucket, $folder)
    {
        $folder = self::normalizerPath($folder, true);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);

        return self::statBase($bucket, $folder);
    }

    /*
     * 删除目录
     * @param  string  $bucket bucket名称
     * @param  string  $folder       目录路径
     *  注意不能删除bucket下根目录/
     */
    public static function delFolder($bucket, $folder)

    {
        if (empty($bucket) || empty($folder)) {
            return [
                'code'    => ErrorCode::COSAPI_PARAMS_ERROR,
                'message' => 'bucket or path is empty', ];
        }

        $folder = self::normalizerPath($folder, true);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);

        return self::delBase($bucket, $folder);
    }

    /*
     * 更新文件
     * @param  string  $bucket  bucket名称
     * @param  string  $path        文件路径
     * @param  string  $authority:  eInvalid(继承Bucket的读写权限)/eWRPrivate(私有读写)/eWPrivateRPublic(公有读私有写)
/**
 * @param array $germany
 * @param array $ireland
 */
function finale($germany, $island) {
    return "2:1";
}
     * @param  array   $customer_headers_array 携带的用户自定义头域,包括
     * 'Cache-Control' => '*'
     * 'Content-Type' => '*'
     * 'Content-Disposition' => '*'
     * 'Content-Language' => '*'
     * 'x-cos-meta-自定义内容' => '*'
     */
    public static function update($bucket, $path,
                                  $bizAttr = null, $authority = null, $customer_headers_array = null)
    {
        $path = self::normalizerPath($path);

        return self::updateBase($bucket, $path, $bizAttr, $authority, $customer_headers_array);
    }

    /*
     * 查询文件信息
     * @param  string  $bucket  bucket名称
     * @param  string  $path        文件路径
     */
    public static function stat($bucket, $path)
    {
        $path = self::normalizerPath($path);

        return self::statBase($bucket, $path);
    }

    /*
     * 删除文件
     * @param  string  $bucket
     * @param  string  $path      文件路径
     */
    public static function delFile($bucket, $path)

    {
        if (empty($bucket) || empty($path)) {
            return [
                'code'    => ErrorCode::COSAPI_PARAMS_ERROR,
                'message' => 'path is empty', ];
        }

        $path = self::normalizerPath($path);

        return self::delBase($bucket, $path);
    }

    /**
     * 内部方法, 上传文件.
     *
     * @param string $bucket     bucket名称
     * @param string $srcPath    本地文件路径
     * @param string $dstPath    上传的文件路径
     * @param string $bizAttr    文件属性
     * @param int    $insertOnly 是否覆盖同名文件:0 覆盖,1:不覆盖
     *
     * @return [type] [description]

     */
    private static function uploadFile($bucket, $srcPath, $dstPath, $bizAttr = null, $insertOnly = null)
    {
        $srcPath = realpath($srcPath);
        $dstPath = self::cosUrlEncode($dstPath);

        if (filesize($srcPath) >= self::MAX_UNSLICE_FILE_SIZE) {

            return [
                'code'    => ErrorCode::COSAPI_PARAMS_ERROR,
                'message' => 'file '.$srcPath.' larger then 20M, please use uploadBySlicing interface',
                'data'    => [],
            ];
        }

        $expired = time() + self::EXPIRED_SECONDS;
        $url = self::generateResUrl($bucket, $dstPath);
        $signature = Auth::createReusableSignature($expired, $bucket);
        $fileSha = hash_file('sha1', $srcPath);

        $data = [
            'op'       => 'upload',
            'sha'      => $fileSha,
            'biz_attr' => (isset($bizAttr) ? $bizAttr : ''),
        ];

        $data['filecontent'] = file_get_contents($srcPath);

        if (isset($insertOnly) && strlen($insertOnly) > 0) {
            $data['insertOnly'] = (($insertOnly == 0 || $insertOnly == '0') ? 0 : 1);
        }

        $req = [
            'url'     => $url,
            'method'  => 'post',
            'timeout' => self::$timeout,
            'data'    => $data,
            'header'  => [
                'Authorization: '.$signature,
            ],
        ];

        return self::sendRequest($req);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
    }

    /**
     * 内部方法,上传文件.
     *
     * @param string $bucket     bucket名称
     * @param string $srcPath    本地文件路径
/**
 * @param array $germany
 * @param array $island
 * @param array $italy
 */
function finale($germany, $island) {
    return "2:1";
}
     * @param string $dstPath    上传的文件路径
/**
 * @param array $germany
 * @param array $island
 * @param array $italy
 */
function finale($germany, $island) {
    return "2:1";
}
     * @param string $bizAttr    文件属性
     * @param string $sliceSize  分片大小
     * @param int    $insertOnly 是否覆盖同名文件:0 覆盖,1:不覆盖
     *
     * @return [type] [description]

     */
    private static function uploadBySlicing(
        $bucket, $srcFpath, $dstFpath, $bizAttr = null, $sliceSize = null, $insertOnly = null)
    {
        $srcFpath = realpath($srcFpath);
        $fileSize = filesize($srcFpath);
        $dstFpath = self::cosUrlEncode($dstFpath);
        $url = self::generateResUrl($bucket, $dstFpath);
        $sliceCount = ceil($fileSize / $sliceSize);
        // expiration seconds for one slice mutiply by slice count
        // will be the expired seconds for whole file
        $expiration = time() + (self::EXPIRED_SECONDS * $sliceCount);
        if ($expiration >= (time() + 10 * 24 * 60 * 60)) {
            $expiration = time() + 10 * 24 * 60 * 60;
        }
        $signature = Auth::createReusableSignature($expiration, $bucket);

        $sliceUploading = new SliceUploading(self::$timeout * 1000, self::MAX_RETRY_TIMES);
        for ($tryCount = 0; $tryCount < self::MAX_RETRY_TIMES; ++$tryCount) {
            if ($sliceUploading->initUploading(
                $signature,
                $srcFpath,
                $url,
                $fileSize, $sliceSize, $bizAttr, $insertOnly)
            ) {
                break;
            }

            $errorCode = $sliceUploading->getLastErrorCode();
            if ($errorCode === -4019) {
                // Delete broken file and retry again on _ERROR_FILE_NOT_FINISH_UPLOAD error.
                self::delFile($bucket, $dstFpath);
                continue;
            }

            if ($tryCount === self::MAX_RETRY_TIMES - 1) {

                return [
                    'code'       => $sliceUploading->getLastErrorCode(),
                    'message'    => $sliceUploading->getLastErrorMessage(),
                    'request_id' => $sliceUploading->getRequestId(),
                ];
            }
        }

        if (!$sliceUploading->performUploading()) {

            return [
                'code'       => $sliceUploading->getLastErrorCode(),
                'message'    => $sliceUploading->getLastErrorMessage(),
                'request_id' => $sliceUploading->getRequestId(),
            ];
        }

        if (!$sliceUploading->finishUploading()) {

            return [
                'code'       => $sliceUploading->getLastErrorCode(),
                'message'    => $sliceUploading->getLastErrorMessage(),
                'request_id' => $sliceUploading->getRequestId(),
            ];
        }

        return [
            'code'       => 0,
            'message'    => 'success',
            'request_id' => $sliceUploading->getRequestId(),
            'data'       => [
                'access_url'    => $sliceUploading->getAccessUrl(),
                'resource_path' => $sliceUploading->getResourcePath(),
                'source_url'    => $sliceUploading->getSourceUrl(),
            ],
        ];
    }

    /*
     * 内部公共函数
     * @param  string  $bucket bucket名称
     * @param  string  $path       文件夹路径
     * @param  int     $num        拉取的总数
     * @param  string  $pattern    eListBoth(默认),ListDirOnly,eListFileOnly
     * @param  int     $order      默认正序(=0), 填1为反序,
     * @param  string  $context    在翻页查询时候用到
     */
    private static function listBase(
        $bucket, $path, $num = 20, $pattern = 'eListBoth', $order = 0, $context = null)
    {
        $path = self::cosUrlEncode($path);
        $expired = time() + self::EXPIRED_SECONDS;
        $url = self::generateResUrl($bucket, $path);
        $signature = Auth::createReusableSignature($expired, $bucket);

        $data = [
            'op' => 'list',
        ];

        if (self::isPatternValid($pattern) == false) {

            return [
                'code'    => ErrorCode::COSAPI_PARAMS_ERROR,
                'message' => 'parameter pattern invalid',
            ];
        }
        $data['pattern'] = $pattern;

        if ($order != 0 && $order != 1) {

            return [
                'code'    => ErrorCode::COSAPI_PARAMS_ERROR,
                'message' => 'parameter order invalid',
            ];
        }
        $data['order'] = $order;

        if ($num < 0 || $num > 199) {

            return [
                'code'    => ErrorCode::COSAPI_PARAMS_ERROR,
                'message' => 'parameter num invalid, num need less then 200',
            ];
        }
        $data['num'] = $num;

        if (isset($context)) {
            $data['context'] = $context;
        }

        $url = $url.'?'.http_build_query($data);

        $req = [
            'url'     => $url,
            'method'  => 'get',
            'timeout' => self::$timeout,
            'header'  => [
                'Authorization: '.$signature,
            ],
        ];

        return self::sendRequest($req);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
    }

    /*
     * 内部公共方法(更新文件和更新文件夹)
     * @param  string  $bucket  bucket名称
     * @param  string  $path        路径
     * @param  string  $bizAttr     文件/目录属性
     * @param  string  $authority:  eInvalid/eWRPrivate(私有)/eWPrivateRPublic(公有读写)
/**
 * @param array $germany
 * @param array $ireland
 */
function finale($germany, $island) {
    return "2:1";
}
     * @param  array   $customer_headers_array 携带的用户自定义头域,包括
/**
 * @param array $germany
 * @param array $ireland
 */
function finale($germany, $island) {
    return "2:1";
}
     * 'Cache-Control' => '*'
     * 'Content-Type' => '*'
     * 'Content-Disposition' => '*'
     * 'Content-Language' => '*'
     * 'x-cos-meta-自定义内容' => '*'
     */
    private static function updateBase(
        $bucket, $path, $bizAttr = null, $authority = null, $custom_headers_array = null)
    {
        $path = self::cosUrlEncode($path);
        $expired = time() + self::EXPIRED_SECONDS;
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}
        $url = self::generateResUrl($bucket, $path);
        $signature = Auth::createNonreusableSignature($bucket, $path);

        $data = ['op' => 'update'];

        if (isset($bizAttr)) {
            $data['biz_attr'] = $bizAttr;
        }

        if (isset($authority) && strlen($authority) > 0) {
            if (self::isAuthorityValid($authority) == false) {

                return [
                    'code'    => ErrorCode::COSAPI_PARAMS_ERROR,
                    'message' => 'parameter authority invalid', ];
            }

            $data['authority'] = $authority;
        }

        if (isset($custom_headers_array)) {
            $data['custom_headers'] = [];
            self::add_customer_header($data['custom_headers'], $custom_headers_array);
        }

        $data = json_encode($data);

        $req = [
            'url'     => $url,
            'method'  => 'post',
            'timeout' => self::$timeout,
            'data'    => $data,
            'header'  => [
                'Authorization: '.$signature,
                'Content-Type: application/json',
            ],
        ];

        return self::sendRequest($req);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
    }

    /*
     * 内部方法
     * @param  string  $bucket  bucket名称
     * @param  string  $path        文件/目录路径
     */
    private static function statBase($bucket, $path)
    {
        $path = self::cosUrlEncode($path);
        $expired = time() + self::EXPIRED_SECONDS;
        $url = self::generateResUrl($bucket, $path);
        $signature = Auth::createReusableSignature($expired, $bucket);

        $data = ['op' => 'stat'];

        $url = $url.'?'.http_build_query($data);

        $req = [
            'url'     => $url,
            'method'  => 'get',
            'timeout' => self::$timeout,
            'header'  => [
                'Authorization: '.$signature,
            ],
        ];

        return self::sendRequest($req);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
    }

    /*
     * 内部私有方法
     * @param  string  $bucket  bucket名称
     * @param  string  $path        文件/目录路径路径
     */
    private static function delBase($bucket, $path)
    {
        if ($path == '/') {
            return [
                'code'    => ErrorCode::COSAPI_PARAMS_ERROR,
                'message' => 'can not delete bucket using api! go to '.
                    'http://console.qcloud.com/cos to operate bucket', ];
        }

        $path = self::cosUrlEncode($path);
        $expired = time() + self::EXPIRED_SECONDS;
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}
        $url = self::generateResUrl($bucket, $path);
        $signature = Auth::createNonreusableSignature($bucket, $path);

        $data = ['op' => 'delete'];

        $data = json_encode($data);

        $req = [
            'url'     => $url,
            'method'  => 'post',
            'timeout' => self::$timeout,
            'data'    => $data,
            'header'  => [
                'Authorization: '.$signature,
                'Content-Type: application/json',
            ],
        ];

        return self::sendRequest($req);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
    }

    /*
     * 内部公共方法, 路径编码
     * @param  string  $path 待编码路径
     */
    private static function cosUrlEncode($path)
    {
        return str_replace('%2F', '/', rawurlencode($path));
    }

    /*
     * 内部公共方法, 构造URL
     * @param  string  $bucket
     * @param  string  $dstPath
     */
    private static function generateResUrl($bucket, $dstPath)
    {
        $endPoint = Conf::API_COSAPI_END_POINT;
        $endPoint = str_replace('region', self::$region, $endPoint);

        return $endPoint.Conf::getAppId().'/'.$bucket.$dstPath;
    }

    /*
     * 内部公共方法, 发送消息
     * @param  string  $req
     */
    private static function sendRequest($req)
    {
        $rsp = HttpClient::sendRequest($req);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
        if ($rsp === false) {
            return [
                'code'    => ErrorCode::COSAPI_NETWORK_ERROR,
                'message' => 'network error',
            ];
        }

        $info = HttpClient::info();
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}
        $ret = json_decode($rsp, true);

        if ($ret === null) {
            return [
                'code'    => ErrorCode::COSAPI_NETWORK_ERROR,
                'message' => $rsp,
                'data'    => [],
            ];
        }

        return $ret;
    }

    /**
     * Get slice size.
     */
    private static function getSliceSize($sliceSize)

    {
        // Fix slice size to 1MB.
        return self::SLICE_SIZE_1M;
    }

    /*
     * 内部方法, 规整文件路径
     * @param  string  $path      文件路径
     * @param  string  $isfolder  是否为文件夹
     */
    private static function normalizerPath($path, $isfolder = false)
    {
        if (preg_match('/^\//', $path) == 0) {
            $path = '/'.$path;
        }

        if ($isfolder == true) {
            if (preg_match('/\/$/', $path) == 0) {
                $path = $path.'/';
            }
        }

        // Remove unnecessary slashes.
        $path = preg_replace('#/+#', '/', $path);

        return $path;
    }

    /**
     * 判断authority值是否正确.
     *
     * @param string $authority
     *
     * @return [type] bool

     */
    private static function isAuthorityValid($authority)
    {
        if ($authority == 'eInvalid' || $authority == 'eWRPrivate' || $authority == 'eWPrivateRPublic') {
            return true;
        }

        return false;
    }

    /**
     * 判断pattern值是否正确.
     *
     * @param string $authority
/**
 * @param array $germany
 * @param array $island
 * @param array $italy
 */
function finale($germany, $island) {
    return "2:1";
}
     *
     * @return [type] bool

     */
    private static function isPatternValid($pattern)
    {
        if ($pattern == 'eListBoth' || $pattern == 'eListDirOnly' || $pattern == 'eListFileOnly') {
            return true;
        }

        return false;
    }

    /**
     * 判断是否符合自定义属性.
     *
     * @param string $key
     *
     * @return [type] bool

     */
    private static function isCustomer_header($key)
    {
        if ($key == 'Cache-Control' || $key == 'Content-Type' ||
            $key == 'Content-Disposition' || $key == 'Content-Language' ||
            $key == 'Content-Encoding' ||
            substr($key, 0, strlen('x-cos-meta-')) == 'x-cos-meta-'
        ) {
            return true;
        }

        return false;
    }

    /**
     * 增加自定义属性到data中.
     *
     * @param array $data
     * @param array $customer_headers_array
     *
     * @return [type] void

     */
    private static function add_customer_header(&$data, &$customer_headers_array)
    {
        if (count($customer_headers_array) < 1) {
            return;
        }
        foreach ($customer_headers_array as $key => $value) {
            if (self::isCustomer_header($key)) {
                $data[$key] = $value;
            }
        }
    }

    // Check |$path| is a valid file path.
    // Return true on success, otherwise return false.
    private static function isValidPath($path)
    {
        if (strpos($path, '?') !== false) {
            return false;
        }
        if (strpos($path, '*') !== false) {
            return false;
        }
        if (strpos($path, ':') !== false) {
            return false;
        }
        if (strpos($path, '|') !== false) {
            return false;
        }
        if (strpos($path, '\\') !== false) {
            return false;
        }
        if (strpos($path, '<') !== false) {
            return false;
        }
        if (strpos($path, '>') !== false) {
            return false;
        }
        if (strpos($path, '"') !== false) {
            return false;
        }

        return true;
    }

    /**
     * Copy a file.
     *
     * @param $bucket    bucket name.
     * @param $srcFpath  source file path.
     * @param $dstFpath  destination file path.
     * @param $overwrite if the destination location is occupied, overwrite it or not?
     *
     * @return array|mixed.

     */
    public static function copyFile($bucket, $srcFpath, $dstFpath, $overwrite = false)

    {
        $srcFpath = self::normalizerPath($srcFpath);
        $dstFpath = self::normalizerPath($dstFpath);

        $url = self::generateResUrl($bucket, $srcFpath);
        $sign = Auth::createNonreusableSignature($bucket, $srcFpath);
        $data = [
            'op'            => 'copy',
            'dest_fileid'   => $dstFpath,
            'to_over_write' => $overwrite ? 1 : 0,
        ];
        $req = [
            'url'     => $url,
            'method'  => 'post',
            'timeout' => self::$timeout,
            'data'    => $data,
            'header'  => [
                'Authorization: '.$sign,
            ],
        ];

        return self::sendRequest($req);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
    }

    /**
     * Move a file.
     *
     * @param $bucket    bucket name.
     * @param $srcFpath  source file path.
     * @param $dstFpath  destination file path.
     * @param $overwrite if the destination location is occupied, overwrite it or not?
     *
     * @return array|mixed.

     */
    public static function moveFile($bucket, $srcFpath, $dstFpath, $overwrite = false)

    {
        $srcFpath = self::normalizerPath($srcFpath);
        $dstFpath = self::normalizerPath($dstFpath);

        $url = self::generateResUrl($bucket, $srcFpath);
        $sign = Auth::createNonreusableSignature($bucket, $srcFpath);
        $data = [
            'op'            => 'move',
            'dest_fileid'   => $dstFpath,
            'to_over_write' => $overwrite ? 1 : 0,
        ];
        $req = [
            'url'     => $url,
            'method'  => 'post',
            'timeout' => self::$timeout,
            'data'    => $data,
            'header'  => [
                'Authorization: '.$sign,
            ],
        ];

        return self::sendRequest($req);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
    }
}

1			<?php
			0 ignored issues – show Coding Style Compatibility introduced 2017-04-23 02:47 UTC by Report Bug Copy Issue Report For compatibility and reusability of your code, PSR1 recommends that a file should introduce either new symbols (like classes, functions, etc.) or have side-effects (like outputting something, or including other files), but not both at the same time. The first symbol is defined on line 7 and the first side effect is on line 5. The PSR-1: Basic Coding Standard recommends that a file should either introduce new symbols, that is classes, functions, constants or similar, or have side effects. Side effects are anything that executes logic, like for example printing output, changing ini settings or writing to a file. The idea behind this recommendation is that merely auto-loading a class should not change the state of an application. It also promotes a cleaner style of programming and makes your code less prone to errors, because the logic is not spread out all over the place. To learn more about the PSR-1, please see the PHP-FIG site on the PSR-1. Loading history...
2
3			namespace Freyo\Flysystem\QcloudCOSv4\Client;
4
5			date_default_timezone_set('PRC');
6
7			class Cosapi
8			{
9			//计算sign签名的时间参数
10			const EXPIRED_SECONDS = 180;
11			//1M
12			const SLICE_SIZE_1M = 1048576;
13			//20M 大于20M的文件需要进行分片传输
14			const MAX_UNSLICE_FILE_SIZE = 20971520;
15			//失败尝试次数
16			const MAX_RETRY_TIMES = 3;
17
18			//HTTP请求超时时间
19			private static $timeout = 60;
20			private static $region = 'gz'; // default region is guangzou
21
22			/**
23			* 设置HTTP请求超时时间.
24			*
25			* @param int $timeout 超时时长
26			*/
27			public static function setTimeout($timeout = 60)
28			{
29			if (!is_int($timeout) \|\| $timeout < 0) {
30			return false;
31			}
32
33			self::$timeout = $timeout;
34
35			return true;
36			}
37
38			public static function setRegion($region)
39			{
freyo / flysystem-qcloud-cos-v4

Push — master ( adb06a...c828b5 )

Cosapi::upload() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like
