Qiniu\Cdn\CdnManager

Complexity

Total Complexity

29

Size/Duplication

Total Lines	493
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

7.25%

Importance

Changes

0

23 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	refreshUrls()	0	4	1
A	refreshDirs()	0	4	1
A	refreshUrlsAndDirs()	0	14	3
A	prefetchUrls()	0	10	1
A	getBandwidthData()	0	12	1
A	getFluxData()	0	12	1
A	getCdnLogList()	0	10	1
A	getCdnLoganalyzeTraffic()	0	14	1
A	getCdnLoganalyzeBandwidth()	0	14	1
A	getCdnLoganalyzeStatuscode()	0	12	1
A	getCdnLoganalyzeHitmiss()	0	12	1
A	getCdnLoganalyzeReqcount()	0	13	1
A	getCdnLoganalyzeIspreqcount()	0	13	1
A	getCdnLoganalyzeIsptraffic()	0	12	1
A	getCdnLoganalyzeTopcountip()	0	12	1
A	getCdnLoganalyzeToptrafficip()	0	12	1
A	getCdnLoganalyzeTopcounturl()	0	12	1
A	getCdnLoganalyzeToptrafficurl()	0	12	1
A	getCdnLoganalyzePageview()	0	12	1
A	getCdnLoganalyzeUniquevisitor()	0	12	1
A	post()	0	11	3
A	createTimestampAntiLeechUrl()	0	20	3

<?php

namespace Qiniu\Cdn;

use Qiniu\Auth;
use Qiniu\Http\Error;
use Qiniu\Http\Client;

final class CdnManager
{

    private $auth;
    private $server;

    public function __construct(Auth $auth)
    {
        $this->auth = $auth;
        $this->server = 'http://fusion.qiniuapi.com';
    }

    /**
     * @param array $urls 待刷新的文件链接数组
     * @return array
     */
    public function refreshUrls(array $urls)
    {
        return $this->refreshUrlsAndDirs($urls, array());
    }

    /**
     * @param array $dirs 待刷新的文件链接数组
     * @return array
     * 目前客户默认没有目录刷新权限，刷新会有400038报错，参考：https://developer.qiniu.com/fusion/api/1229/cache-refresh
     * 需要刷新目录请工单联系技术支持 https://support.qiniu.com/tickets/category
     */
    public function refreshDirs(array $dirs)
    {
        return $this->refreshUrlsAndDirs(array(), $dirs);
    }

    /**
     * @param array $urls 待刷新的文件链接数组
     * @param array $dirs 待刷新的目录链接数组
     *
     * @return array 刷新的请求回复和错误，参考 examples/cdn_manager.php 代码
     * @link http://developer.qiniu.com/article/fusion/api/refresh.html
     *
     * 目前客户默认没有目录刷新权限，刷新会有400038报错，参考：https://developer.qiniu.com/fusion/api/1229/cache-refresh
     * 需要刷新目录请工单联系技术支持 https://support.qiniu.com/tickets/category
     */
    public function refreshUrlsAndDirs(array $urls, array  $dirs)
    {
        $req = array();
        if (!empty($urls)) {
            $req['urls'] = $urls;
        }
        if (!empty($dirs)) {
            $req['dirs'] = $dirs;
        }

        $url = $this->server . '/v2/tune/refresh';
        $body = json_encode($req);
        return $this->post($url, $body);
    }

    /**
     * @param array $urls 待预取的文件链接数组
     *
     * @return array 预取的请求回复和错误，参考 examples/cdn_manager.php 代码
     *
     * @link http://developer.qiniu.com/article/fusion/api/refresh.html
     */
    public function prefetchUrls(array $urls)
    {
        $req = array(
            'urls' => $urls,
        );

        $url = $this->server . '/v2/tune/prefetch';
        $body = json_encode($req);
        return $this->post($url, $body);
    }

    /**
     * @param array $domains 待获取带宽数据的域名数组
     * @param string $startDate 开始的日期，格式类似 2017-01-01
     * @param string $endDate 结束的日期，格式类似 2017-01-01
     * @param string $granularity 获取数据的时间间隔，可以是 5min, hour 或者 day
     *
     * @return array 带宽数据和错误信息，参考 examples/cdn_manager.php 代码
     *
     * @link http://developer.qiniu.com/article/fusion/api/traffic-bandwidth.html
     */
    public function getBandwidthData(array $domains, $startDate, $endDate, $granularity)
    {
        $req = array();
        $req['domains'] = implode(';', $domains);
        $req['startDate'] = $startDate;
        $req['endDate'] = $endDate;
        $req['granularity'] = $granularity;

        $url = $this->server . '/v2/tune/bandwidth';
        $body = json_encode($req);
        return $this->post($url, $body);
    }

    /**
     * @param array $domains 待获取流量数据的域名数组
     * @param string $startDate 开始的日期，格式类似 2017-01-01
     * @param string $endDate 结束的日期，格式类似 2017-01-01
     * @param string $granularity 获取数据的时间间隔，可以是 5min, hour 或者 day
     *
     * @return array 流量数据和错误信息，参考 examples/cdn_manager.php 代码
     *
     * @link http://developer.qiniu.com/article/fusion/api/traffic-bandwidth.html
     */
    public function getFluxData(array $domains, $startDate, $endDate, $granularity)
    {
        $req = array();
        $req['domains'] = implode(';', $domains);
        $req['startDate'] = $startDate;
        $req['endDate'] = $endDate;
        $req['granularity'] = $granularity;

        $url = $this->server . '/v2/tune/flux';
        $body = json_encode($req);
        return $this->post($url, $body);
    }

    /**
     * @param array $domains 待获取日志下载链接的域名数组
     * @param string $logDate 获取指定日期的日志下载链接，格式类似 2017-01-01
     *
     * @return array 日志下载链接数据和错误信息，参考 examples/cdn_manager.php 代码
     *
     * @link http://developer.qiniu.com/article/fusion/api/log.html
     */
    public function getCdnLogList(array $domains, $logDate)
    {
        $req = array();
        $req['domains'] = implode(';', $domains);
        $req['day'] = $logDate;

        $url = $this->server . '/v2/tune/log/list';
        $body = json_encode($req);
        return $this->post($url, $body);
    }

    /**
     * @param array $domains 待获取区域运营商流量的域名数组
     * @param string $freq 待获取区域运营商流量的粒度，可选项为 5min、1hour、1day
     * @param array $regions 待获取区域运营商流量的区域，例如global，具体看参考：https://developer.qiniu.com/fusion/api/4081/cdn-log-analysis#region
     * @param array $isp 待获取区域运营商流量的ISP运营商，例如比如all(所有 ISP)，telecom(电信)，unicom(联通)，mobile(中国移动)，drpeng(鹏博士)，tietong(铁通)，cernet(教育网)
     * @param string $startDate  待获取区域运营商流量的开始日期，格式类似 2017-01-01
     * @param string $endDate  待获取区域运营商流量的结束日期，格式类似 2017-01-01
     *
     * @return array 错误信息，参考 examples/cdn_manager.php 代码
     *
     * @link https://developer.qiniu.com/fusion/api/4081/cdn-log-analysis
     */
    public function getCdnLoganalyzeTraffic(array $domains, $freq, $regions, $isp, $startDate, $endDate)
    {
        $req = array();
        $req['domains'] = $domains;
        $req['freq'] = $freq;
        $req['regions'] = $regions;
        $req['isp'] = $isp;
        $req['startDate'] = $startDate;
        $req['endDate'] = $endDate;

        $url = $this->server . '/v2/tune/loganalyze/traffic';
        $body = json_encode($req);
        return $this->post($url, $body);
    }

    /**
     * @param array $domains 待获取区域运营商带宽的域名数组
     * @param string $freq 待获取区域运营商带宽的粒度，可选项为 5min、1hour、1day
     * @param array $regions 待获取区域运营商带宽的区域，例如global，具体看参考：https://developer.qiniu.com/fusion/api/4081/cdn-log-analysis#region
     * @param array $isp 待获取区域运营商带宽的ISP运营商，例如比如all(所有 ISP)，telecom(电信)，unicom(联通)，mobile(中国移动)，drpeng(鹏博士)，tietong(铁通)，cernet(教育网)
     * @param string $startDate  待获取区域运营商带宽的开始日期，格式类似 2017-01-01
     * @param string $endDate  待获取区域运营商带宽的结束日期，格式类似 2017-01-01
     *
     * @return array 错误信息，参考 examples/cdn_manager.php 代码
     *
     * @link https://developer.qiniu.com/fusion/api/4081/cdn-log-analysis
     */
    public function getCdnLoganalyzeBandwidth(array $domains, $freq, $regions, $isp, $startDate, $endDate)
    {
        $req = array();
        $req['domains'] = $domains;
        $req['freq'] = $freq;
        $req['regions'] = $regions;
        $req['isp'] = $isp;
        $req['startDate'] = $startDate;
        $req['endDate'] = $endDate;

        $url = $this->server . '/v2/tune/loganalyze/bandwidth';
        $body = json_encode($req);
        return $this->post($url, $body);
    }

    /**
     * @param array $domains 待获取状态码数据的域名数组
     * @param string $freq 待获取状态码数据的粒度，可选项为 5min、1hour、1day
     * @param string $startDate  待获取状态码数据的开始日期，格式类似 2017-01-01
     * @param string $endDate  待获取状态码数据的结束日期，格式类似 2017-01-01
     *
     * @return array 错误信息，参考 examples/cdn_manager.php 代码
     *
     * @link https://developer.qiniu.com/fusion/api/4081/cdn-log-analysis
     */
    public function getCdnLoganalyzeStatuscode(array $domains, $freq, $startDate, $endDate)
    {
        $req = array();
        $req['domains'] = $domains;
        $req['freq'] = $freq;
        $req['startDate'] = $startDate;
        $req['endDate'] = $endDate;

        $url = $this->server . '/v2/tune/loganalyze/statuscode';
        $body = json_encode($req);
        return $this->post($url, $body);
    }

    /**
     * @param array $domains 待获取命中率数据的域名数组
     * @param string $freq 待获取命中率数据的粒度，可选项为 5min、1hour、1day
     * @param string $startDate  待获取命中率数据的开始日期，格式类似 2017-01-01
     * @param string $endDate  待获取命中率数据的结束日期，格式类似 2017-01-01
     *
     * @return array 错误信息，参考 examples/cdn_manager.php 代码
     *
     * @link https://developer.qiniu.com/fusion/api/4081/cdn-log-analysis
     */
    public function getCdnLoganalyzeHitmiss(array $domains, $freq, $startDate, $endDate)
    {
        $req = array();
        $req['domains'] = $domains;
        $req['freq'] = $freq;
        $req['startDate'] = $startDate;
        $req['endDate'] = $endDate;

        $url = $this->server . '/v2/tune/loganalyze/hitmiss';
        $body = json_encode($req);
        return $this->post($url, $body);
    }

    /**
     * @param array $domains 待获取请求次数数据的域名数组
     * @param string $freq 待获取请求次数数据的粒度，可选项为 5min、1hour、1day
     * @param string $region 待获取请求次数数据的区域，例如global，具体看参考：https://developer.qiniu.com/fusion/api/4081/cdn-log-analysis#region
     * @param string $startDate  待获取请求次数数据的开始日期，格式类似 2017-01-01
     * @param string $endDate  待获取请求次数数据的结束日期，格式类似 2017-01-01
     *
     * @return array 错误信息，参考 examples/cdn_manager.php 代码
     *
     * @link https://developer.qiniu.com/fusion/api/4081/cdn-log-analysis
     */
    public function getCdnLoganalyzeReqcount(array $domains, $freq, $region, $startDate, $endDate)
    {
        $req = array();
        $req['domains'] = $domains;
        $req['freq'] = $freq;
        $req['region'] = $region;
        $req['startDate'] = $startDate;
        $req['endDate'] = $endDate;

        $url = $this->server . '/v2/tune/loganalyze/reqcount';
        $body = json_encode($req);
        return $this->post($url, $body);
    }

    /**
     * @param array $domains 待获取 ISP 请求次数数据的域名数组
     * @param string $freq 待获取 ISP 请求次数数据的粒度，可选项为 5min、1hour、1day
     * @param string $region 待获取 ISP 请求次数数据的区域，例如global，具体看参考：https://developer.qiniu.com/fusion/api/4081/cdn-log-analysis#region
     * @param string $startDate  待获取 ISP 请求次数数据的开始日期，格式类似 2017-01-01
     * @param string $endDate  待获取 ISP 请求次数数据的结束日期，格式类似 2017-01-01
     *
     * @return array 错误信息，参考 examples/cdn_manager.php 代码
     *
     * @link https://developer.qiniu.com/fusion/api/4081/cdn-log-analysis
     */
    public function getCdnLoganalyzeIspreqcount(array $domains, $freq, $region, $startDate, $endDate)
    {
        $req = array();
        $req['domains'] = $domains;
        $req['freq'] = $freq;
        $req['region'] = $region;
        $req['startDate'] = $startDate;
        $req['endDate'] = $endDate;

        $url = $this->server . '/v2/tune/loganalyze/ispreqcount';
        $body = json_encode($req);
        return $this->post($url, $body);
    }

    /**
     * @param array $domains 待获取 ISP 流量占比数据的域名数组
     * @param array $regions 待获取 ISP 流量占比数据的区域，例如global，具体看参考：https://developer.qiniu.com/fusion/api/4081/cdn-log-analysis#region
     * @param string $startDate  待获取 ISP 流量占比数据的开始日期，格式类似 2017-01-01
     * @param string $endDate  待获取 ISP 流量占比数据的结束日期，格式类似 2017-01-01
     *
     * @return array 错误信息，参考 examples/cdn_manager.php 代码
     *
     * @link https://developer.qiniu.com/fusion/api/4081/cdn-log-analysis
     */
    public function getCdnLoganalyzeIsptraffic(array $domains, $regions, $startDate, $endDate)
    {
        $req = array();
        $req['domains'] = $domains;
        $req['regions'] = $regions;
        $req['startDate'] = $startDate;
        $req['endDate'] = $endDate;

        $url = $this->server . '/v2/tune/loganalyze/isptraffic';
        $body = json_encode($req);
        return $this->post($url, $body);
    }

    /**
     * @param array $domains 待获取访问量数据的域名数组
     * @param string $region 待获取访问量数据的区域，例如global，具体看参考：https://developer.qiniu.com/fusion/api/4081/cdn-log-analysis#region
     * @param string $startDate  待获取访问量数据的开始日期，格式类似 2017-01-01
     * @param string $endDate  待获取访问量数据的结束日期，格式类似 2017-01-01
     *
     * @return array 错误信息，参考 examples/cdn_manager.php 代码
     *
     * @link https://developer.qiniu.com/fusion/api/4081/cdn-log-analysis
     */
    public function getCdnLoganalyzeTopcountip(array $domains, $region, $startDate, $endDate)
    {
        $req = array();
        $req['domains'] = $domains;
        $req['region'] = $region;
        $req['startDate'] = $startDate;
        $req['endDate'] = $endDate;

        $url = $this->server . '/v2/tune/loganalyze/topcountip';
        $body = json_encode($req);
        return $this->post($url, $body);
    }

    /**
     * @param array $domains 待获取访问量数据的域名数组
     * @param string $region 待获取访问量数据的区域，例如global，具体看参考：https://developer.qiniu.com/fusion/api/4081/cdn-log-analysis#region
     * @param string $startDate  待获取访问量数据的开始日期，格式类似 2017-01-01
     * @param string $endDate  待获取访问量数据的结束日期，格式类似 2017-01-01
     *
     * @return array 错误信息，参考 examples/cdn_manager.php 代码
     *
     * @link https://developer.qiniu.com/fusion/api/4081/cdn-log-analysis
     */
    public function getCdnLoganalyzeToptrafficip(array $domains, $region, $startDate, $endDate)
    {
        $req = array();
        $req['domains'] = $domains;
        $req['region'] = $region;
        $req['startDate'] = $startDate;
        $req['endDate'] = $endDate;

        $url = $this->server . '/v2/tune/loganalyze/toptrafficip';
        $body = json_encode($req);
        return $this->post($url, $body);
    }

    /**
     * @param array $domains 待获取访问量数据的域名数组
     * @param string $region 待获取访问量数据的区域，例如global，具体看参考：https://developer.qiniu.com/fusion/api/4081/cdn-log-analysis#region
     * @param string $startDate  待获取访问量数据的开始日期，格式类似 2017-01-01
     * @param string $endDate  待获取访问量数据的结束日期，格式类似 2017-01-01
     *
     * @return array 错误信息，参考 examples/cdn_manager.php 代码
     *
     * @link https://developer.qiniu.com/fusion/api/4081/cdn-log-analysis
     */
    public function getCdnLoganalyzeTopcounturl(array $domains, $region, $startDate, $endDate)
    {
        $req = array();
        $req['domains'] = $domains;
        $req['region'] = $region;
        $req['startDate'] = $startDate;
        $req['endDate'] = $endDate;

        $url = $this->server . '/v2/tune/loganalyze/topcounturl';
        $body = json_encode($req);
        return $this->post($url, $body);
    }

    /**
     * @param array $domains 待获取访问量数据的域名数组
     * @param string $region 待获取访问量数据的区域，例如global，具体看参考：https://developer.qiniu.com/fusion/api/4081/cdn-log-analysis#region
     * @param string $startDate  待获取访问量数据的开始日期，格式类似 2017-01-01
     * @param string $endDate  待获取访问量数据的结束日期，格式类似 2017-01-01
     *
     * @return array 错误信息，参考 examples/cdn_manager.php 代码
     *
     * @link https://developer.qiniu.com/fusion/api/4081/cdn-log-analysis
     */
    public function getCdnLoganalyzeToptrafficurl(array $domains, $region, $startDate, $endDate)
    {
        $req = array();
        $req['domains'] = $domains;
        $req['region'] = $region;
        $req['startDate'] = $startDate;
        $req['endDate'] = $endDate;

        $url = $this->server . '/v2/tune/loganalyze/toptrafficurl';
        $body = json_encode($req);
        return $this->post($url, $body);
    }

    /**
     * @param array $domains 待获取PageView数据的域名数组
     * @param string $freq 待获取PageView数据的粒度，可选项为 1hour、1day
     * @param string $startDate  待获取PageView数据的开始日期，格式类似 2017-01-01
     * @param string $endDate  待获取PageView数据的结束日期，格式类似 2017-01-01
     *
     * @return array 获取PageView数据时的错误信息，参考 examples/cdn_manager.php 代码
     *
     * @link https://developer.qiniu.com/fusion/api/4081/cdn-log-analysis
     */
    public function getCdnLoganalyzePageview(array $domains, $freq, $startDate, $endDate)
    {
        $req = array();
        $req['domains'] = $domains;
        $req['freq'] = $freq;
        $req['startDate'] = $startDate;
        $req['endDate'] = $endDate;

        $url = $this->server . '/v2/tune/loganalyze/pageview';
        $body = json_encode($req);
        return $this->post($url, $body);
    }

    /**
     * @param array $domains 待获取UniqueVisitor数据的域名数组
     * @param string $freq 待获取UniqueVisitor数据的粒度，可选项为 1hour、1day
     * @param string $startDate  待获取UniqueVisitor数据的开始日期，格式类似 2017-01-01
     * @param string $endDate  待获取UniqueVisitor数据的结束日期，格式类似 2017-01-01
     *
     * @return array 获取UniqueVisitor数据时的错误信息，参考 examples/cdn_manager.php 代码
     *
     * @link https://developer.qiniu.com/fusion/api/4081/cdn-log-analysis
     */
    public function getCdnLoganalyzeUniquevisitor(array $domains, $freq, $startDate, $endDate)
    {
        $req = array();
        $req['domains'] = $domains;
        $req['freq'] = $freq;
        $req['startDate'] = $startDate;
        $req['endDate'] = $endDate;

        $url = $this->server . '/v2/tune/loganalyze/uniquevisitor';
        $body = json_encode($req);
        return $this->post($url, $body);
    }

    private function post($url, $body)
    {
        $headers = $this->auth->authorization($url, $body, 'application/json');
        $headers['Content-Type'] = 'application/json';
        $ret = Client::post($url, $body, $headers);
        if (!$ret->ok()) {
            return array(null, new Error($url, $ret));
        }
        $r = ($ret->body === null) ? array() : $ret->json();
        return array($r, null);
    }

    /**
     * 构建时间戳防盗链鉴权的访问外链
     *
     * @param string $rawUrl 需要签名的资源url
     * @param string $encryptKey 时间戳防盗链密钥
     * @param string $durationInSeconds 链接的有效期（以秒为单位）
     *
     * @return string 带鉴权信息的资源外链，参考 examples/cdn_timestamp_antileech.php 代码
     */
    public static function createTimestampAntiLeechUrl($rawUrl, $encryptKey, $durationInSeconds)
    {

        $parsedUrl = parse_url($rawUrl);

        $deadline = time() + $durationInSeconds;
        $expireHex = dechex($deadline);
        $path = isset($parsedUrl['path']) ? $parsedUrl['path'] : '';

        $strToSign = $encryptKey . $path . $expireHex;
        $signStr = md5($strToSign);

        if (isset($parsedUrl['query'])) {
            $signedUrl = $rawUrl . '&sign=' . $signStr . '&t=' . $expireHex;
        } else {
            $signedUrl = $rawUrl . '?sign=' . $signStr . '&t=' . $expireHex;
        }

        return $signedUrl;
    }
}