mirror of
https://gitee.com/niucloud-team/niucloud-admin.git
synced 2026-01-19 01:38:10 +00:00
643 lines
25 KiB
PHP
643 lines
25 KiB
PHP
<?php
|
|
|
|
/**
|
|
* Copyright 2019 Huawei Technologies Co.,Ltd.
|
|
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use
|
|
* this file except in compliance with the License. You may obtain a copy of the
|
|
* License at
|
|
*
|
|
* http://www.apache.org/licenses/LICENSE-2.0
|
|
*
|
|
* Unless required by applicable law or agreed to in writing, software distributed
|
|
* under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
|
|
* CONDITIONS OF ANY KIND, either express or implied. See the License for the
|
|
* specific language governing permissions and limitations under the License.
|
|
*
|
|
*/
|
|
|
|
namespace Obs;
|
|
|
|
use Obs\Internal\Signature\DefaultSignature;
|
|
use Obs\Log\ObsLog;
|
|
use Obs\Internal\Common\SdkCurlFactory;
|
|
use Obs\Internal\Common\SdkStreamHandler;
|
|
use Obs\Internal\Common\Model;
|
|
use Monolog\Logger;
|
|
use GuzzleHttp\Client;
|
|
use GuzzleHttp\HandlerStack;
|
|
use GuzzleHttp\Handler\CurlHandler;
|
|
use GuzzleHttp\Handler\CurlMultiHandler;
|
|
use GuzzleHttp\Handler\Proxy;
|
|
use GuzzleHttp\Promise\Promise;
|
|
use Obs\Internal\Resource\Constants;
|
|
|
|
|
|
define('DEBUG', Logger::DEBUG);
|
|
define('INFO', Logger::INFO);
|
|
define('NOTICE', Logger::NOTICE);
|
|
define('WARNING', Logger::WARNING);
|
|
define('WARN', Logger::WARNING);
|
|
define('ERROR', Logger::ERROR);
|
|
define('CRITICAL', Logger::CRITICAL);
|
|
define('ALERT', Logger::ALERT);
|
|
define('EMERGENCY', Logger::EMERGENCY);
|
|
|
|
/**
|
|
* @method Model createPostSignature(array $args = []);
|
|
// * @method Model createSignedUrl(array $args = []);
|
|
* @method Model createBucket(array $args = []);
|
|
* @method Model listBuckets();
|
|
* @method Model deleteBucket(array $args = []);
|
|
* @method Model listObjects(array $args = []);
|
|
* @method Model listVersions(array $args = []);
|
|
* @method Model headBucket(array $args = []);
|
|
* @method Model getBucketMetadata(array $args = []);
|
|
* @method Model getBucketLocation(array $args = []);
|
|
* @method Model getBucketStorageInfo(array $args = []);
|
|
* @method Model setBucketQuota(array $args = []);
|
|
* @method Model getBucketQuota(array $args = []);
|
|
* @method Model setBucketStoragePolicy(array $args = []);
|
|
* @method Model getBucketStoragePolicy(array $args = []);
|
|
* @method Model setBucketAcl(array $args = []);
|
|
* @method Model getBucketAcl(array $args = []);
|
|
* @method Model setBucketLogging(array $args = []);
|
|
* @method Model getBucketLogging(array $args = []);
|
|
* @method Model setBucketPolicy(array $args = []);
|
|
* @method Model getBucketPolicy(array $args = []);
|
|
* @method Model deleteBucketPolicy(array $args = []);
|
|
* @method Model setBucketLifecycle(array $args = []);
|
|
* @method Model getBucketLifecycle(array $args = []);
|
|
* @method Model deleteBucketLifecycle(array $args = []);
|
|
* @method Model setBucketWebsite(array $args = []);
|
|
* @method Model getBucketWebsite(array $args = []);
|
|
* @method Model deleteBucketWebsite(array $args = []);
|
|
* @method Model setBucketVersioning(array $args = []);
|
|
* @method Model getBucketVersioning(array $args = []);
|
|
* @method Model setBucketCors(array $args = []);
|
|
* @method Model getBucketCors(array $args = []);
|
|
* @method Model deleteBucketCors(array $args = []);
|
|
* @method Model setBucketNotification(array $args = []);
|
|
* @method Model getBucketNotification(array $args = []);
|
|
* @method Model setBucketTagging(array $args = []);
|
|
* @method Model getBucketTagging(array $args = []);
|
|
* @method Model deleteBucketTagging(array $args = []);
|
|
* @method Model optionsBucket(array $args = []);
|
|
*
|
|
* @method Model putObject(array $args = []);
|
|
* @method Model getObject(array $args = []);
|
|
* @method Model copyObject(array $args = []);
|
|
* @method Model deleteObject(array $args = []);
|
|
* @method Model deleteObjects(array $args = []);
|
|
* @method Model getObjectMetadata(array $args = []);
|
|
* @method Model setObjectAcl(array $args = []);
|
|
* @method Model getObjectAcl(array $args = []);
|
|
* @method Model initiateMultipartUpload(array $args = []);
|
|
* @method Model uploadPart(array $args = []);
|
|
* @method Model copyPart(array $args = []);
|
|
* @method Model listParts(array $args = []);
|
|
* @method Model completeMultipartUpload(array $args = []);
|
|
* @method Model abortMultipartUpload(array $args = []);
|
|
* @method Model listMultipartUploads(array $args = []);
|
|
* @method Model optionsObject(array $args = []);
|
|
* @method Model restoreObject(array $args = []);
|
|
*
|
|
* @method Promise createBucketAsync(array $args = [], callable $callback);
|
|
* @method Promise listBucketsAsync(callable $callback);
|
|
* @method Promise deleteBucketAsync(array $args = [], callable $callback);
|
|
* @method Promise listObjectsAsync(array $args = [], callable $callback);
|
|
* @method Promise listVersionsAsync(array $args = [], callable $callback);
|
|
* @method Promise headBucketAsync(array $args = [], callable $callback);
|
|
* @method Promise getBucketMetadataAsync(array $args = [], callable $callback);
|
|
* @method Promise getBucketLocationAsync(array $args = [], callable $callback);
|
|
* @method Promise getBucketStorageInfoAsync(array $args = [], callable $callback);
|
|
* @method Promise setBucketQuotaAsync(array $args = [], callable $callback);
|
|
* @method Promise getBucketQuotaAsync(array $args = [], callable $callback);
|
|
* @method Promise setBucketStoragePolicyAsync(array $args = [], callable $callback);
|
|
* @method Promise getBucketStoragePolicyAsync(array $args = [], callable $callback);
|
|
* @method Promise setBucketAclAsync(array $args = [], callable $callback);
|
|
* @method Promise getBucketAclAsync(array $args = [], callable $callback);
|
|
* @method Promise setBucketLoggingAsync(array $args = [], callable $callback);
|
|
* @method Promise getBucketLoggingAsync(array $args = [], callable $callback);
|
|
* @method Promise setBucketPolicyAsync(array $args = [], callable $callback);
|
|
* @method Promise getBucketPolicyAsync(array $args = [], callable $callback);
|
|
* @method Promise deleteBucketPolicyAsync(array $args = [], callable $callback);
|
|
* @method Promise setBucketLifecycleAsync(array $args = [], callable $callback);
|
|
* @method Promise getBucketLifecycleAsync(array $args = [], callable $callback);
|
|
* @method Promise deleteBucketLifecycleAsync(array $args = [], callable $callback);
|
|
* @method Promise setBucketWebsiteAsync(array $args = [], callable $callback);
|
|
* @method Promise getBucketWebsiteAsync(array $args = [], callable $callback);
|
|
* @method Promise deleteBucketWebsiteAsync(array $args = [], callable $callback);
|
|
* @method Promise setBucketVersioningAsync(array $args = [], callable $callback);
|
|
* @method Promise getBucketVersioningAsync(array $args = [], callable $callback);
|
|
* @method Promise setBucketCorsAsync(array $args = [], callable $callback);
|
|
* @method Promise getBucketCorsAsync(array $args = [], callable $callback);
|
|
* @method Promise deleteBucketCorsAsync(array $args = [], callable $callback);
|
|
* @method Promise setBucketNotificationAsync(array $args = [], callable $callback);
|
|
* @method Promise getBucketNotificationAsync(array $args = [], callable $callback);
|
|
* @method Promise setBucketTaggingAsync(array $args = [], callable $callback);
|
|
* @method Promise getBucketTaggingAsync(array $args = [], callable $callback);
|
|
* @method Promise deleteBucketTaggingAsync(array $args = [], callable $callback);
|
|
* @method Promise optionsBucketAsync(array $args = [], callable $callback);
|
|
*
|
|
* @method Promise putObjectAsync(array $args = [], callable $callback);
|
|
* @method Promise getObjectAsync(array $args = [], callable $callback);
|
|
* @method Promise copyObjectAsync(array $args = [], callable $callback);
|
|
* @method Promise deleteObjectAsync(array $args = [], callable $callback);
|
|
* @method Promise deleteObjectsAsync(array $args = [], callable $callback);
|
|
* @method Promise getObjectMetadataAsync(array $args = [], callable $callback);
|
|
* @method Promise setObjectAclAsync(array $args = [], callable $callback);
|
|
* @method Promise getObjectAclAsync(array $args = [], callable $callback);
|
|
* @method Promise initiateMultipartUploadAsync(array $args = [], callable $callback);
|
|
* @method Promise uploadPartAsync(array $args = [], callable $callback);
|
|
* @method Promise copyPartAsync(array $args = [], callable $callback);
|
|
* @method Promise listPartsAsync(array $args = [], callable $callback);
|
|
* @method Promise completeMultipartUploadAsync(array $args = [], callable $callback);
|
|
* @method Promise abortMultipartUploadAsync(array $args = [], callable $callback);
|
|
* @method Promise listMultipartUploadsAsync(array $args = [], callable $callback);
|
|
* @method Promise optionsObjectAsync(array $args = [], callable $callback);
|
|
* @method Promise restoreObjectAsync(array $args = [], callable $callback);
|
|
*
|
|
*/
|
|
class ObsImageClient
|
|
{
|
|
|
|
const SDK_VERSION = '3.20.5';
|
|
|
|
const AclPrivate = 'private';
|
|
const AclPublicRead = 'public-read';
|
|
const AclPublicReadWrite = 'public-read-write';
|
|
const AclPublicReadDelivered = 'public-read-delivered';
|
|
const AclPublicReadWriteDelivered = 'public-read-write-delivered';
|
|
|
|
const AclAuthenticatedRead = 'authenticated-read';
|
|
const AclBucketOwnerRead = 'bucket-owner-read';
|
|
const AclBucketOwnerFullControl = 'bucket-owner-full-control';
|
|
const AclLogDeliveryWrite = 'log-delivery-write';
|
|
|
|
const StorageClassStandard = 'STANDARD';
|
|
const StorageClassWarm = 'WARM';
|
|
const StorageClassCold = 'COLD';
|
|
|
|
const PermissionRead = 'READ';
|
|
const PermissionWrite = 'WRITE';
|
|
const PermissionReadAcp = 'READ_ACP';
|
|
const PermissionWriteAcp = 'WRITE_ACP';
|
|
const PermissionFullControl = 'FULL_CONTROL';
|
|
|
|
const AllUsers = 'Everyone';
|
|
|
|
const GroupAllUsers = 'AllUsers';
|
|
const GroupAuthenticatedUsers = 'AuthenticatedUsers';
|
|
const GroupLogDelivery = 'LogDelivery';
|
|
|
|
const RestoreTierExpedited = 'Expedited';
|
|
const RestoreTierStandard = 'Standard';
|
|
const RestoreTierBulk = 'Bulk';
|
|
|
|
const GranteeGroup = 'Group';
|
|
const GranteeUser = 'CanonicalUser';
|
|
|
|
const CopyMetadata = 'COPY';
|
|
const ReplaceMetadata = 'REPLACE';
|
|
|
|
const SignatureV2 = 'v2';
|
|
const SignatureV4 = 'v4';
|
|
const SigantureObs = 'obs';
|
|
|
|
const ObjectCreatedAll = 'ObjectCreated:*';
|
|
const ObjectCreatedPut = 'ObjectCreated:Put';
|
|
const ObjectCreatedPost = 'ObjectCreated:Post';
|
|
const ObjectCreatedCopy = 'ObjectCreated:Copy';
|
|
const ObjectCreatedCompleteMultipartUpload = 'ObjectCreated:CompleteMultipartUpload';
|
|
const ObjectRemovedAll = 'ObjectRemoved:*';
|
|
const ObjectRemovedDelete = 'ObjectRemoved:Delete';
|
|
const ObjectRemovedDeleteMarkerCreated = 'ObjectRemoved:DeleteMarkerCreated';
|
|
|
|
use Internal\SendRequestTrait;
|
|
use Internal\GetResponseTrait;
|
|
|
|
private $factorys;
|
|
private $project_name;//项目名称
|
|
private $project_sub_name;//项目二级路径
|
|
private $custom_domain;//指定域名替换默认域名
|
|
|
|
public function __construct(array $config = [])
|
|
{
|
|
$this->factorys = [];
|
|
|
|
$this->ak = strval($config['key']);
|
|
$this->sk = strval($config['secret']);
|
|
|
|
if (isset($config['project_name'])) {
|
|
$this->project_name = strval($config['project_name']);
|
|
}
|
|
|
|
if (isset($config['project_sub_name'])) {
|
|
$this->project_sub_name = strval($config['project_sub_name']);
|
|
}
|
|
|
|
if (isset($config['custom_domain'])) {
|
|
$this->custom_domain = strval($config['custom_domain']);
|
|
}
|
|
|
|
if (isset($config['security_token'])) {
|
|
$this->securityToken = strval($config['security_token']);
|
|
}
|
|
|
|
if (isset($config['endpoint'])) {
|
|
$this->endpoint = trim(strval($config['endpoint']));
|
|
}
|
|
|
|
if ($this->endpoint === '') {
|
|
throw new \RuntimeException('endpoint is not set');
|
|
}
|
|
|
|
while ($this->endpoint[strlen($this->endpoint) - 1] === '/') {
|
|
$this->endpoint = substr($this->endpoint, 0, strlen($this->endpoint) - 1);
|
|
}
|
|
|
|
if (strpos($this->endpoint, 'http') !== 0) {
|
|
$this->endpoint = 'https://' . $this->endpoint;
|
|
}
|
|
|
|
if (isset($config['signature'])) {
|
|
$this->signature = strval($config['signature']);
|
|
}
|
|
|
|
if (isset($config['path_style'])) {
|
|
$this->pathStyle = $config['path_style'];
|
|
}
|
|
|
|
if (isset($config['region'])) {
|
|
$this->region = strval($config['region']);
|
|
}
|
|
|
|
if (isset($config['ssl_verify'])) {
|
|
$this->sslVerify = $config['ssl_verify'];
|
|
} else if (isset($config['ssl.certificate_authority'])) {
|
|
$this->sslVerify = $config['ssl.certificate_authority'];
|
|
}
|
|
|
|
if (isset($config['max_retry_count'])) {
|
|
$this->maxRetryCount = intval($config['max_retry_count']);
|
|
}
|
|
|
|
if (isset($config['timeout'])) {
|
|
$this->timeout = intval($config['timeout']);
|
|
}
|
|
|
|
if (isset($config['socket_timeout'])) {
|
|
$this->socketTimeout = intval($config['socket_timeout']);
|
|
}
|
|
|
|
if (isset($config['connect_timeout'])) {
|
|
$this->connectTimeout = intval($config['connect_timeout']);
|
|
}
|
|
|
|
if (isset($config['chunk_size'])) {
|
|
$this->chunkSize = intval($config['chunk_size']);
|
|
}
|
|
|
|
if (isset($config['exception_response_mode'])) {
|
|
$this->exceptionResponseMode = $config['exception_response_mode'];
|
|
}
|
|
|
|
if (isset($config['is_cname'])) {
|
|
$this->isCname = $config['is_cname'];
|
|
}
|
|
|
|
$host = parse_url($this->endpoint)['host'];
|
|
if (filter_var($host, FILTER_VALIDATE_IP) !== false) {
|
|
$this->pathStyle = true;
|
|
}
|
|
|
|
$handler = self::choose_handler($this);
|
|
|
|
$this->httpClient = new Client(
|
|
[
|
|
'timeout' => 0,
|
|
'read_timeout' => $this->socketTimeout,
|
|
'connect_timeout' => $this->connectTimeout,
|
|
'allow_redirects' => false,
|
|
'verify' => $this->sslVerify,
|
|
'expect' => false,
|
|
'handler' => HandlerStack::create($handler),
|
|
'curl' => [
|
|
CURLOPT_BUFFERSIZE => $this->chunkSize
|
|
]
|
|
]
|
|
);
|
|
|
|
}
|
|
|
|
public function __destruct()
|
|
{
|
|
$this->close();
|
|
}
|
|
|
|
public function refresh($key, $secret, $security_token = false)
|
|
{
|
|
$this->ak = strval($key);
|
|
$this->sk = strval($secret);
|
|
if ($security_token) {
|
|
$this->securityToken = strval($security_token);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Get the default User-Agent string to use with Guzzle
|
|
*
|
|
* @return string
|
|
*/
|
|
private static function default_user_agent()
|
|
{
|
|
static $defaultAgent = '';
|
|
if (!$defaultAgent) {
|
|
$defaultAgent = 'obs-sdk-php/' . self::SDK_VERSION;
|
|
}
|
|
|
|
return $defaultAgent;
|
|
}
|
|
|
|
/**
|
|
* Factory method to create a new Obs client using an array of configuration options.
|
|
*
|
|
* @param array $config Client configuration data
|
|
*
|
|
* @return ObsClient
|
|
*/
|
|
public static function factory(array $config = [])
|
|
{
|
|
return new ObsClient($config);
|
|
}
|
|
|
|
public function close()
|
|
{
|
|
if ($this->factorys) {
|
|
foreach ($this->factorys as $factory) {
|
|
$factory->close();
|
|
}
|
|
}
|
|
}
|
|
|
|
public function initLog(array $logConfig = [])
|
|
{
|
|
ObsLog::initLog($logConfig);
|
|
|
|
$msg = [];
|
|
$msg[] = '[OBS SDK Version=' . self::SDK_VERSION;
|
|
$msg[] = 'Endpoint=' . $this->endpoint;
|
|
$msg[] = 'Access Mode=' . ($this->pathStyle ? 'Path' : 'Virtual Hosting') . ']';
|
|
|
|
ObsLog::commonLog(WARNING, implode("];[", $msg));
|
|
}
|
|
|
|
private static function choose_handler($obsclient)
|
|
{
|
|
$handler = null;
|
|
if (function_exists('curl_multi_exec') && function_exists('curl_exec')) {
|
|
$f1 = new SdkCurlFactory(50);
|
|
$f2 = new SdkCurlFactory(3);
|
|
$obsclient->factorys[] = $f1;
|
|
$obsclient->factorys[] = $f2;
|
|
$handler = Proxy::wrapSync(new CurlMultiHandler(['handle_factory' => $f1]), new CurlHandler(['handle_factory' => $f2]));
|
|
} elseif (function_exists('curl_exec')) {
|
|
$f = new SdkCurlFactory(3);
|
|
$obsclient->factorys[] = $f;
|
|
$handler = new CurlHandler(['handle_factory' => $f]);
|
|
} elseif (function_exists('curl_multi_exec')) {
|
|
$f = new SdkCurlFactory(50);
|
|
$obsclient->factorys[] = $f;
|
|
$handler = new CurlMultiHandler(['handle_factory' => $f]);
|
|
}
|
|
|
|
if (ini_get('allow_url_fopen')) {
|
|
$handler = $handler
|
|
? Proxy::wrapStreaming($handler, new SdkStreamHandler())
|
|
: new SdkStreamHandler();
|
|
} elseif (!$handler) {
|
|
throw new \RuntimeException('GuzzleHttp requires cURL, the '
|
|
. 'allow_url_fopen ini setting, or a custom HTTP handler.');
|
|
}
|
|
|
|
return $handler;
|
|
}
|
|
|
|
public function createSignedUrl(array $args=[])
|
|
{
|
|
if (strcasecmp($this -> signature, 'v4') === 0) {
|
|
return $this -> createV4SignedUrl($args);
|
|
}
|
|
return $this->createCommonSignedUrl($this->signature,$args);
|
|
}
|
|
|
|
private function createCommonSignedUrl(string $signature,array $args=[]) {
|
|
if(!isset($args['Method'])){
|
|
$obsException = new ObsException('Method param must be specified, allowed values: GET | PUT | HEAD | POST | DELETE | OPTIONS');
|
|
$obsException-> setExceptionType('client');
|
|
throw $obsException;
|
|
}
|
|
$method = strval($args['Method']);
|
|
$bucketName = isset($args['Bucket'])? strval($args['Bucket']): null;
|
|
$objectKey = isset($args['Key'])? strval($args['Key']): null;
|
|
$specialParam = isset($args['SpecialParam'])? strval($args['SpecialParam']): null;
|
|
$expires = isset($args['Expires']) && is_numeric($args['Expires']) ? intval($args['Expires']): 300;
|
|
$objectKey = $this->genKey($objectKey);
|
|
|
|
$headers = [];
|
|
if(isset($args['Headers']) && is_array($args['Headers']) ){
|
|
foreach ($args['Headers'] as $key => $val){
|
|
if(is_string($key) && $key !== ''){
|
|
$headers[$key] = $val;
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
|
|
$queryParams = [];
|
|
if(isset($args['QueryParams']) && is_array($args['QueryParams']) ){
|
|
foreach ($args['QueryParams'] as $key => $val){
|
|
if(is_string($key) && $key !== ''){
|
|
$queryParams[$key] = $val;
|
|
}
|
|
}
|
|
}
|
|
|
|
$constants = Constants::selectConstants($signature);
|
|
if($this->securityToken && !isset($queryParams[$constants::SECURITY_TOKEN_HEAD])){
|
|
$queryParams[$constants::SECURITY_TOKEN_HEAD] = $this->securityToken;
|
|
}
|
|
|
|
$sign = new DefaultSignature($this->ak, $this->sk, $this->pathStyle, $this->endpoint, $method, $this->signature, $this->securityToken, $this->isCname);
|
|
|
|
$url = parse_url($this->endpoint);
|
|
$host = $url['host'];
|
|
|
|
$result = '';
|
|
|
|
if($bucketName){
|
|
if($this-> pathStyle){
|
|
$result = '/' . $bucketName;
|
|
}else{
|
|
$host = $this->isCname ? $host : $bucketName . '.' . $host;
|
|
}
|
|
}
|
|
|
|
$headers['Host'] = $this->custom_domain ?? $host;
|
|
|
|
if($objectKey){
|
|
$objectKey = $sign ->urlencodeWithSafe($objectKey);
|
|
$result .= '/' . $objectKey;
|
|
}
|
|
|
|
$result .= '?';
|
|
|
|
if($specialParam){
|
|
$queryParams[$specialParam] = '';
|
|
}
|
|
|
|
$queryParams[$constants::TEMPURL_AK_HEAD] = $this->ak;
|
|
|
|
|
|
if(!is_numeric($expires) || $expires < 0){
|
|
$expires = 300;
|
|
}
|
|
$expires = intval($expires) + intval(microtime(true));
|
|
|
|
$queryParams['Expires'] = strval($expires);
|
|
|
|
$_queryParams = [];
|
|
|
|
foreach ($queryParams as $key => $val){
|
|
$key = $sign -> urlencodeWithSafe($key);
|
|
$val = $sign -> urlencodeWithSafe($val);
|
|
$_queryParams[$key] = $val;
|
|
$result .= $key;
|
|
if($val){
|
|
$result .= '=' . $val;
|
|
}
|
|
$result .= '&';
|
|
}
|
|
|
|
$canonicalstring = $sign ->makeCanonicalstring($method, $headers, $_queryParams, $bucketName, $objectKey, $expires);
|
|
$signatureContent = base64_encode(hash_hmac('sha1', $canonicalstring, $this->sk, true));
|
|
|
|
$result .= 'Signature=' . $sign->urlencodeWithSafe($signatureContent);
|
|
|
|
$model = new Model();
|
|
$model['ActualSignedRequestHeaders'] = $headers;
|
|
$model['SignedUrl'] = $url['scheme'] . '://' . ($this->custom_domain ?? $host) . ':' . (isset($url['port']) ? $url['port'] : (strtolower($url['scheme']) === 'https' ? '443' : '80')) . $result;
|
|
return $model;
|
|
}
|
|
|
|
public function genKey(&$key)
|
|
{
|
|
if (empty($this->project_name)) {
|
|
throw new \RuntimeException('project_name 参数有误');
|
|
}
|
|
$extension = explode('.', $key);
|
|
$ext = end($extension);
|
|
$date_ym = date('Y-m');
|
|
$date_ymd = date('Ymd');
|
|
$filePath = empty($this->project_sub_name) ? $this->project_name : $this->project_name . '/' . $this->project_sub_name;
|
|
$filePath .= "/{$date_ym}/{$date_ymd}_";
|
|
$hash_data = $this->project_name . $key . time() . mt_rand(111111, 999999);
|
|
$filePath .= hash('sha256', $hash_data) . '.' . $ext;
|
|
return $filePath;
|
|
}
|
|
|
|
/************************************************ 改造内容 *******************************************************/
|
|
public function __call($originMethod, $args)
|
|
{
|
|
$method = $originMethod;
|
|
|
|
$contents = Constants::selectRequestResource($this->signature);
|
|
$resource = &$contents::$RESOURCE_ARRAY;
|
|
$async = false;
|
|
if (strpos($method, 'Async') === (strlen($method) - 5)) {
|
|
$method = substr($method, 0, strlen($method) - 5);
|
|
$async = true;
|
|
}
|
|
|
|
if (isset($resource['aliases'][$method])) {
|
|
$method = $resource['aliases'][$method];
|
|
}
|
|
|
|
$method = lcfirst($method);
|
|
|
|
|
|
$operation = isset($resource['operations'][$method]) ?
|
|
$resource['operations'][$method] : null;
|
|
|
|
if (!$operation) {
|
|
ObsLog::commonLog(WARNING, 'unknow method ' . $originMethod);
|
|
$obsException = new ObsException('unknow method ' . $originMethod);
|
|
$obsException->setExceptionType('client');
|
|
throw $obsException;
|
|
}
|
|
|
|
$start = microtime(true);
|
|
if (!$async) {
|
|
ObsLog::commonLog(INFO, 'enter method ' . $originMethod . '...');
|
|
$model = new Model();
|
|
$model['method'] = $method;
|
|
$params = empty($args) ? [] : $args[0];
|
|
$this->_checkParams($params);//house365::校验参数，自动生成文件路径名
|
|
$this->checkMimeType($method, $params);
|
|
$this->doRequest($model, $operation, $params);
|
|
ObsLog::commonLog(INFO, 'obsclient cost ' . round(microtime(true) - $start, 3) * 1000 . ' ms to execute ' . $originMethod);
|
|
unset($model['method']);
|
|
$this->_replaceDomain($model);//house365::替换域名
|
|
return $model;
|
|
} else {
|
|
if (empty($args) || !(is_callable($callback = $args[count($args) - 1]))) {
|
|
ObsLog::commonLog(WARNING, 'async method ' . $originMethod . ' must pass a CallbackInterface as param');
|
|
$obsException = new ObsException('async method ' . $originMethod . ' must pass a CallbackInterface as param');
|
|
$obsException->setExceptionType('client');
|
|
throw $obsException;
|
|
}
|
|
ObsLog::commonLog(INFO, 'enter method ' . $originMethod . '...');
|
|
$params = count($args) === 1 ? [] : $args[0];
|
|
$this->checkMimeType($method, $params);
|
|
$model = new Model();
|
|
$model['method'] = $method;
|
|
return $this->doRequestAsync($model, $operation, $params, $callback, $start, $originMethod);
|
|
}
|
|
}
|
|
|
|
//house365::校验参数，自动生成文件路径名
|
|
private function _checkParams(&$params)
|
|
{
|
|
if (!isset($params['Key'])) {
|
|
throw new \RuntimeException('Key 参数有误');
|
|
}
|
|
if (empty($this->project_name)) {
|
|
throw new \RuntimeException('project_name 参数有误');
|
|
}
|
|
$extension = explode('.', $params['Key']);
|
|
$ext = end($extension);
|
|
$date_ym = date('Y-m');
|
|
$date_ymd = date('Ymd');
|
|
$filePath = empty($this->project_sub_name) ? $this->project_name : $this->project_name . '/' . $this->project_sub_name;
|
|
$filePath .= "/{$date_ym}/{$date_ymd}_";
|
|
$hash_data = $this->project_name . $params['Key'] . time() . mt_rand(111111, 999999);
|
|
$filePath .= hash('sha256', $hash_data) . '.' . $ext;
|
|
$params['Key'] = $filePath;
|
|
}
|
|
|
|
//house365::替换域名
|
|
private function _replaceDomain(&$model)
|
|
{
|
|
if ($this->custom_domain && $model['ObjectURL']) {
|
|
$origin_url = $model['ObjectURL'];
|
|
$url_arr = parse_url($origin_url);
|
|
if (!empty($url_arr['host'])) {
|
|
$url_ = $url_arr['scheme'] . '://' . $this->custom_domain . $url_arr['path'];
|
|
$url_ .= isset($url_arr['query']) ? '?' . $url_arr['query'] : '';
|
|
$model['ObjectURL'] = $url_;
|
|
}
|
|
}
|
|
}
|
|
}
|