123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739 |
- <?php
- namespace OSS;
- use OSS\Core\MimeTypes;
- use OSS\Core\OssException;
- use OSS\Http\RequestCore;
- use OSS\Http\RequestCore_Exception;
- use OSS\Http\ResponseCore;
- use OSS\Model\CorsConfig;
- use OSS\Model\CnameConfig;
- use OSS\Model\LoggingConfig;
- use OSS\Model\LiveChannelConfig;
- use OSS\Model\LiveChannelInfo;
- use OSS\Model\LiveChannelListInfo;
- use OSS\Model\StorageCapacityConfig;
- use OSS\Result\AclResult;
- use OSS\Result\BodyResult;
- use OSS\Result\GetCorsResult;
- use OSS\Result\GetLifecycleResult;
- use OSS\Result\GetLoggingResult;
- use OSS\Result\GetRefererResult;
- use OSS\Result\GetWebsiteResult;
- use OSS\Result\GetCnameResult;
- use OSS\Result\GetLocationResult;
- use OSS\Result\HeaderResult;
- use OSS\Result\InitiateMultipartUploadResult;
- use OSS\Result\ListBucketsResult;
- use OSS\Result\ListMultipartUploadResult;
- use OSS\Model\ListMultipartUploadInfo;
- use OSS\Result\ListObjectsResult;
- use OSS\Result\ListPartsResult;
- use OSS\Result\PutSetDeleteResult;
- use OSS\Result\DeleteObjectsResult;
- use OSS\Result\CopyObjectResult;
- use OSS\Result\CallbackResult;
- use OSS\Result\ExistResult;
- use OSS\Result\PutLiveChannelResult;
- use OSS\Result\GetLiveChannelHistoryResult;
- use OSS\Result\GetLiveChannelInfoResult;
- use OSS\Result\GetLiveChannelStatusResult;
- use OSS\Result\ListLiveChannelResult;
- use OSS\Result\GetStorageCapacityResult;
- use OSS\Result\AppendResult;
- use OSS\Model\ObjectListInfo;
- use OSS\Result\UploadPartResult;
- use OSS\Model\BucketListInfo;
- use OSS\Model\LifecycleConfig;
- use OSS\Model\RefererConfig;
- use OSS\Model\WebsiteConfig;
- use OSS\Core\OssUtil;
- use OSS\Model\ListPartsInfo;
- use OSS\Result\SymlinkResult;
- class OssClient
- {
-
- public function __construct($accessKeyId, $accessKeySecret, $endpoint, $isCName = false, $securityToken = null, $requestProxy = null)
- {
- $accessKeyId = trim($accessKeyId);
- $accessKeySecret = trim($accessKeySecret);
- $endpoint = trim(trim($endpoint), "/");
- if (empty($accessKeyId)) {
- throw new OssException("access key id is empty");
- }
- if (empty($accessKeySecret)) {
- throw new OssException("access key secret is empty");
- }
- if (empty($endpoint)) {
- throw new OssException("endpoint is empty");
- }
- $this->hostname = $this->checkEndpoint($endpoint, $isCName);
- $this->accessKeyId = $accessKeyId;
- $this->accessKeySecret = $accessKeySecret;
- $this->securityToken = $securityToken;
- $this->requestProxy = $requestProxy;
- self::checkEnv();
- }
-
- public function listBuckets($options = null)
- {
- if ($this->hostType === self::OSS_HOST_TYPE_CNAME) {
- throw new OssException("operation is not permitted with CName host");
- }
- $this->precheckOptions($options);
- $options[self::OSS_BUCKET] = '';
- $options[self::OSS_METHOD] = self::OSS_HTTP_GET;
- $options[self::OSS_OBJECT] = '/';
- $response = $this->auth($options);
- $result = new ListBucketsResult($response);
- return $result->getData();
- }
-
- public function createBucket($bucket, $acl = self::OSS_ACL_TYPE_PRIVATE, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_PUT;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_HEADERS] = array(self::OSS_ACL => $acl);
- if (isset($options[self::OSS_STORAGE])) {
- $this->precheckStorage($options[self::OSS_STORAGE]);
- $options[self::OSS_CONTENT] = OssUtil::createBucketXmlBody($options[self::OSS_STORAGE]);
- unset($options[self::OSS_STORAGE]);
- }
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- public function deleteBucket($bucket, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_DELETE;
- $options[self::OSS_OBJECT] = '/';
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- public function doesBucketExist($bucket)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_GET;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'acl';
- $response = $this->auth($options);
- $result = new ExistResult($response);
- return $result->getData();
- }
-
- public function getBucketLocation($bucket, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_GET;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'location';
- $response = $this->auth($options);
- $result = new GetLocationResult($response);
- return $result->getData();
- }
-
- public function getBucketMeta($bucket, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_HEAD;
- $options[self::OSS_OBJECT] = '/';
- $response = $this->auth($options);
- $result = new HeaderResult($response);
- return $result->getData();
- }
-
- public function getBucketAcl($bucket, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_GET;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'acl';
- $response = $this->auth($options);
- $result = new AclResult($response);
- return $result->getData();
- }
-
- public function putBucketAcl($bucket, $acl, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_PUT;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_HEADERS] = array(self::OSS_ACL => $acl);
- $options[self::OSS_SUB_RESOURCE] = 'acl';
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- public function getObjectAcl($bucket, $object)
- {
- $options = array();
- $this->precheckCommon($bucket, $object, $options, true);
- $options[self::OSS_METHOD] = self::OSS_HTTP_GET;
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_OBJECT] = $object;
- $options[self::OSS_SUB_RESOURCE] = 'acl';
- $response = $this->auth($options);
- $result = new AclResult($response);
- return $result->getData();
- }
-
- public function putObjectAcl($bucket, $object, $acl)
- {
- $this->precheckCommon($bucket, $object, $options, true);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_PUT;
- $options[self::OSS_OBJECT] = $object;
- $options[self::OSS_HEADERS] = array(self::OSS_OBJECT_ACL => $acl);
- $options[self::OSS_SUB_RESOURCE] = 'acl';
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- public function getBucketLogging($bucket, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_GET;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'logging';
- $response = $this->auth($options);
- $result = new GetLoggingResult($response);
- return $result->getData();
- }
-
- public function putBucketLogging($bucket, $targetBucket, $targetPrefix, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $this->precheckBucket($targetBucket, 'targetbucket is not allowed empty');
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_PUT;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'logging';
- $options[self::OSS_CONTENT_TYPE] = 'application/xml';
- $loggingConfig = new LoggingConfig($targetBucket, $targetPrefix);
- $options[self::OSS_CONTENT] = $loggingConfig->serializeToXml();
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- public function deleteBucketLogging($bucket, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_DELETE;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'logging';
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- public function putBucketWebsite($bucket, $websiteConfig, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_PUT;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'website';
- $options[self::OSS_CONTENT_TYPE] = 'application/xml';
- $options[self::OSS_CONTENT] = $websiteConfig->serializeToXml();
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- public function getBucketWebsite($bucket, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_GET;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'website';
- $response = $this->auth($options);
- $result = new GetWebsiteResult($response);
- return $result->getData();
- }
-
- public function deleteBucketWebsite($bucket, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_DELETE;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'website';
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- public function putBucketCors($bucket, $corsConfig, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_PUT;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'cors';
- $options[self::OSS_CONTENT_TYPE] = 'application/xml';
- $options[self::OSS_CONTENT] = $corsConfig->serializeToXml();
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- public function getBucketCors($bucket, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_GET;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'cors';
- $response = $this->auth($options);
- $result = new GetCorsResult($response, __FUNCTION__);
- return $result->getData();
- }
-
- public function deleteBucketCors($bucket, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_DELETE;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'cors';
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- public function addBucketCname($bucket, $cname, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_POST;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'cname';
- $options[self::OSS_CONTENT_TYPE] = 'application/xml';
- $cnameConfig = new CnameConfig();
- $cnameConfig->addCname($cname);
- $options[self::OSS_CONTENT] = $cnameConfig->serializeToXml();
- $options[self::OSS_COMP] = 'add';
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- public function getBucketCname($bucket, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_GET;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'cname';
- $response = $this->auth($options);
- $result = new GetCnameResult($response);
- return $result->getData();
- }
-
- public function deleteBucketCname($bucket, $cname, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_POST;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'cname';
- $options[self::OSS_CONTENT_TYPE] = 'application/xml';
- $cnameConfig = new CnameConfig();
- $cnameConfig->addCname($cname);
- $options[self::OSS_CONTENT] = $cnameConfig->serializeToXml();
- $options[self::OSS_COMP] = 'delete';
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- public function putBucketLiveChannel($bucket, $channelName, $channelConfig, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_PUT;
- $options[self::OSS_OBJECT] = $channelName;
- $options[self::OSS_SUB_RESOURCE] = 'live';
- $options[self::OSS_CONTENT_TYPE] = 'application/xml';
- $options[self::OSS_CONTENT] = $channelConfig->serializeToXml();
- $response = $this->auth($options);
- $result = new PutLiveChannelResult($response);
- $info = $result->getData();
- $info->setName($channelName);
- $info->setDescription($channelConfig->getDescription());
- return $info;
- }
-
- public function putLiveChannelStatus($bucket, $channelName, $channelStatus, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_PUT;
- $options[self::OSS_OBJECT] = $channelName;
- $options[self::OSS_SUB_RESOURCE] = 'live';
- $options[self::OSS_LIVE_CHANNEL_STATUS] = $channelStatus;
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- public function getLiveChannelInfo($bucket, $channelName, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_GET;
- $options[self::OSS_OBJECT] = $channelName;
- $options[self::OSS_SUB_RESOURCE] = 'live';
- $response = $this->auth($options);
- $result = new GetLiveChannelInfoResult($response);
- return $result->getData();
- }
-
- public function getLiveChannelStatus($bucket, $channelName, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_GET;
- $options[self::OSS_OBJECT] = $channelName;
- $options[self::OSS_SUB_RESOURCE] = 'live';
- $options[self::OSS_COMP] = 'stat';
- $response = $this->auth($options);
- $result = new GetLiveChannelStatusResult($response);
- return $result->getData();
- }
-
- public function getLiveChannelHistory($bucket, $channelName, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_GET;
- $options[self::OSS_OBJECT] = $channelName;
- $options[self::OSS_SUB_RESOURCE] = 'live';
- $options[self::OSS_COMP] = 'history';
- $response = $this->auth($options);
- $result = new GetLiveChannelHistoryResult($response);
- return $result->getData();
- }
-
- public function listBucketLiveChannels($bucket, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_GET;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'live';
- $options[self::OSS_QUERY_STRING] = array(
- 'prefix' => isset($options['prefix']) ? $options['prefix'] : '',
- 'marker' => isset($options['marker']) ? $options['marker'] : '',
- 'max-keys' => isset($options['max-keys']) ? $options['max-keys'] : '',
- );
- $response = $this->auth($options);
- $result = new ListLiveChannelResult($response);
- $list = $result->getData();
- $list->setBucketName($bucket);
- return $list;
- }
-
- public function postVodPlaylist($bucket, $channelName, $playlistName, $setTime)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_POST;
- $options[self::OSS_OBJECT] = $channelName . '/' . $playlistName;
- $options[self::OSS_SUB_RESOURCE] = 'vod';
- $options[self::OSS_LIVE_CHANNEL_END_TIME] = $setTime['EndTime'];
- $options[self::OSS_LIVE_CHANNEL_START_TIME] = $setTime['StartTime'];
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- public function deleteBucketLiveChannel($bucket, $channelName, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_DELETE;
- $options[self::OSS_OBJECT] = $channelName;
- $options[self::OSS_SUB_RESOURCE] = 'live';
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- public function signRtmpUrl($bucket, $channelName, $timeout = 60, $options = null)
- {
- $this->precheckCommon($bucket, $channelName, $options, false);
- $expires = time() + $timeout;
- $proto = 'rtmp://';
- $hostname = $this->generateHostname($bucket);
- $cano_params = '';
- $query_items = array();
- $params = isset($options['params']) ? $options['params'] : array();
- uksort($params, 'strnatcasecmp');
- foreach ($params as $key => $value) {
- $cano_params = $cano_params . $key . ':' . $value . "\n";
- $query_items[] = rawurlencode($key) . '=' . rawurlencode($value);
- }
- $resource = '/' . $bucket . '/' . $channelName;
- $string_to_sign = $expires . "\n" . $cano_params . $resource;
- $signature = base64_encode(hash_hmac('sha1', $string_to_sign, $this->accessKeySecret, true));
- $query_items[] = 'OSSAccessKeyId=' . rawurlencode($this->accessKeyId);
- $query_items[] = 'Expires=' . rawurlencode($expires);
- $query_items[] = 'Signature=' . rawurlencode($signature);
- return $proto . $hostname . '/live/' . $channelName . '?' . implode('&', $query_items);
- }
-
- public function optionsObject($bucket, $object, $origin, $request_method, $request_headers, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_OPTIONS;
- $options[self::OSS_OBJECT] = $object;
- $options[self::OSS_HEADERS] = array(
- self::OSS_OPTIONS_ORIGIN => $origin,
- self::OSS_OPTIONS_REQUEST_HEADERS => $request_headers,
- self::OSS_OPTIONS_REQUEST_METHOD => $request_method
- );
- $response = $this->auth($options);
- $result = new HeaderResult($response);
- return $result->getData();
- }
-
- public function putBucketLifecycle($bucket, $lifecycleConfig, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_PUT;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'lifecycle';
- $options[self::OSS_CONTENT_TYPE] = 'application/xml';
- $options[self::OSS_CONTENT] = $lifecycleConfig->serializeToXml();
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- public function getBucketLifecycle($bucket, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_GET;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'lifecycle';
- $response = $this->auth($options);
- $result = new GetLifecycleResult($response);
- return $result->getData();
- }
-
- public function deleteBucketLifecycle($bucket, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_DELETE;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'lifecycle';
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- public function putBucketReferer($bucket, $refererConfig, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_PUT;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'referer';
- $options[self::OSS_CONTENT_TYPE] = 'application/xml';
- $options[self::OSS_CONTENT] = $refererConfig->serializeToXml();
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- public function getBucketReferer($bucket, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_GET;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'referer';
- $response = $this->auth($options);
- $result = new GetRefererResult($response);
- return $result->getData();
- }
-
- public function putBucketStorageCapacity($bucket, $storageCapacity, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_PUT;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'qos';
- $options[self::OSS_CONTENT_TYPE] = 'application/xml';
- $storageCapacityConfig = new StorageCapacityConfig($storageCapacity);
- $options[self::OSS_CONTENT] = $storageCapacityConfig->serializeToXml();
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- public function getBucketStorageCapacity($bucket, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_GET;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'qos';
- $response = $this->auth($options);
- $result = new GetStorageCapacityResult($response);
- return $result->getData();
- }
-
- public function listObjects($bucket, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_GET;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_HEADERS] = array(
- self::OSS_DELIMITER => isset($options[self::OSS_DELIMITER]) ? $options[self::OSS_DELIMITER] : '/',
- self::OSS_PREFIX => isset($options[self::OSS_PREFIX]) ? $options[self::OSS_PREFIX] : '',
- self::OSS_MAX_KEYS => isset($options[self::OSS_MAX_KEYS]) ? $options[self::OSS_MAX_KEYS] : self::OSS_MAX_KEYS_VALUE,
- self::OSS_MARKER => isset($options[self::OSS_MARKER]) ? $options[self::OSS_MARKER] : '',
- );
- $query = isset($options[self::OSS_QUERY_STRING]) ? $options[self::OSS_QUERY_STRING] : array();
- $options[self::OSS_QUERY_STRING] = array_merge(
- $query,
- array(self::OSS_ENCODING_TYPE => self::OSS_ENCODING_TYPE_URL)
- );
- $response = $this->auth($options);
- $result = new ListObjectsResult($response);
- return $result->getData();
- }
-
- public function createObjectDir($bucket, $object, $options = null)
- {
- $this->precheckCommon($bucket, $object, $options);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_PUT;
- $options[self::OSS_OBJECT] = $object . '/';
- $options[self::OSS_CONTENT_LENGTH] = array(self::OSS_CONTENT_LENGTH => 0);
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- public function putObject($bucket, $object, $content, $options = null)
- {
- $this->precheckCommon($bucket, $object, $options);
- $options[self::OSS_CONTENT] = $content;
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_PUT;
- $options[self::OSS_OBJECT] = $object;
- if (!isset($options[self::OSS_LENGTH])) {
- $options[self::OSS_CONTENT_LENGTH] = strlen($options[self::OSS_CONTENT]);
- } else {
- $options[self::OSS_CONTENT_LENGTH] = $options[self::OSS_LENGTH];
- }
- $is_check_md5 = $this->isCheckMD5($options);
- if ($is_check_md5) {
- $content_md5 = base64_encode(md5($content, true));
- $options[self::OSS_CONTENT_MD5] = $content_md5;
- }
- if (!isset($options[self::OSS_CONTENT_TYPE])) {
- $options[self::OSS_CONTENT_TYPE] = $this->getMimeType($object);
- }
- $response = $this->auth($options);
- if (isset($options[self::OSS_CALLBACK]) && !empty($options[self::OSS_CALLBACK])) {
- $result = new CallbackResult($response);
- } else {
- $result = new PutSetDeleteResult($response);
- }
- return $result->getData();
- }
-
- public function putSymlink($bucket, $symlink, $targetObject, $options = null)
- {
- $this->precheckCommon($bucket, $symlink, $options);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_PUT;
- $options[self::OSS_OBJECT] = $symlink;
- $options[self::OSS_SUB_RESOURCE] = self::OSS_SYMLINK;
- $options[self::OSS_HEADERS][self::OSS_SYMLINK_TARGET] = rawurlencode($targetObject);
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- public function getSymlink($bucket, $symlink)
- {
- $this->precheckCommon($bucket, $symlink, $options);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_GET;
- $options[self::OSS_OBJECT] = $symlink;
- $options[self::OSS_SUB_RESOURCE] = self::OSS_SYMLINK;
- $response = $this->auth($options);
- $result = new SymlinkResult($response);
- return $result->getData();
- }
-
- public function uploadFile($bucket, $object, $file, $options = null)
- {
- $this->precheckCommon($bucket, $object, $options);
- OssUtil::throwOssExceptionWithMessageIfEmpty($file, "file path is invalid");
- $file = OssUtil::encodePath($file);
- if (!file_exists($file)) {
- throw new OssException($file . " file does not exist");
- }
- $options[self::OSS_FILE_UPLOAD] = $file;
- $file_size = filesize($options[self::OSS_FILE_UPLOAD]);
- $is_check_md5 = $this->isCheckMD5($options);
- if ($is_check_md5) {
- $content_md5 = base64_encode(md5_file($options[self::OSS_FILE_UPLOAD], true));
- $options[self::OSS_CONTENT_MD5] = $content_md5;
- }
- if (!isset($options[self::OSS_CONTENT_TYPE])) {
- $options[self::OSS_CONTENT_TYPE] = $this->getMimeType($object, $file);
- }
- $options[self::OSS_METHOD] = self::OSS_HTTP_PUT;
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_OBJECT] = $object;
- $options[self::OSS_CONTENT_LENGTH] = $file_size;
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- public function appendObject($bucket, $object, $content, $position, $options = null)
- {
- $this->precheckCommon($bucket, $object, $options);
- $options[self::OSS_CONTENT] = $content;
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_POST;
- $options[self::OSS_OBJECT] = $object;
- $options[self::OSS_SUB_RESOURCE] = 'append';
- $options[self::OSS_POSITION] = strval($position);
- if (!isset($options[self::OSS_LENGTH])) {
- $options[self::OSS_CONTENT_LENGTH] = strlen($options[self::OSS_CONTENT]);
- } else {
- $options[self::OSS_CONTENT_LENGTH] = $options[self::OSS_LENGTH];
- }
- $is_check_md5 = $this->isCheckMD5($options);
- if ($is_check_md5) {
- $content_md5 = base64_encode(md5($content, true));
- $options[self::OSS_CONTENT_MD5] = $content_md5;
- }
- if (!isset($options[self::OSS_CONTENT_TYPE])) {
- $options[self::OSS_CONTENT_TYPE] = $this->getMimeType($object);
- }
- $response = $this->auth($options);
- $result = new AppendResult($response);
- return $result->getData();
- }
-
- public function appendFile($bucket, $object, $file, $position, $options = null)
- {
- $this->precheckCommon($bucket, $object, $options);
- OssUtil::throwOssExceptionWithMessageIfEmpty($file, "file path is invalid");
- $file = OssUtil::encodePath($file);
- if (!file_exists($file)) {
- throw new OssException($file . " file does not exist");
- }
- $options[self::OSS_FILE_UPLOAD] = $file;
- $file_size = filesize($options[self::OSS_FILE_UPLOAD]);
- $is_check_md5 = $this->isCheckMD5($options);
- if ($is_check_md5) {
- $content_md5 = base64_encode(md5_file($options[self::OSS_FILE_UPLOAD], true));
- $options[self::OSS_CONTENT_MD5] = $content_md5;
- }
- if (!isset($options[self::OSS_CONTENT_TYPE])) {
- $options[self::OSS_CONTENT_TYPE] = $this->getMimeType($object, $file);
- }
- $options[self::OSS_METHOD] = self::OSS_HTTP_POST;
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_OBJECT] = $object;
- $options[self::OSS_CONTENT_LENGTH] = $file_size;
- $options[self::OSS_SUB_RESOURCE] = 'append';
- $options[self::OSS_POSITION] = strval($position);
- $response = $this->auth($options);
- $result = new AppendResult($response);
- return $result->getData();
- }
-
- public function copyObject($fromBucket, $fromObject, $toBucket, $toObject, $options = null)
- {
- $this->precheckCommon($fromBucket, $fromObject, $options);
- $this->precheckCommon($toBucket, $toObject, $options);
- $options[self::OSS_BUCKET] = $toBucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_PUT;
- $options[self::OSS_OBJECT] = $toObject;
- if (isset($options[self::OSS_HEADERS])) {
- $options[self::OSS_HEADERS][self::OSS_OBJECT_COPY_SOURCE] = '/' . $fromBucket . '/' . $fromObject;
- } else {
- $options[self::OSS_HEADERS] = array(self::OSS_OBJECT_COPY_SOURCE => '/' . $fromBucket . '/' . $fromObject);
- }
- $response = $this->auth($options);
- $result = new CopyObjectResult($response);
- return $result->getData();
- }
-
- public function getObjectMeta($bucket, $object, $options = null)
- {
- $this->precheckCommon($bucket, $object, $options);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_HEAD;
- $options[self::OSS_OBJECT] = $object;
- $response = $this->auth($options);
- $result = new HeaderResult($response);
- return $result->getData();
- }
-
- public function deleteObject($bucket, $object, $options = null)
- {
- $this->precheckCommon($bucket, $object, $options);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_DELETE;
- $options[self::OSS_OBJECT] = $object;
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- public function deleteObjects($bucket, $objects, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- if (!is_array($objects) || !$objects) {
- throw new OssException('objects must be array');
- }
- $options[self::OSS_METHOD] = self::OSS_HTTP_POST;
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'delete';
- $options[self::OSS_CONTENT_TYPE] = 'application/xml';
- $quiet = 'false';
- if (isset($options['quiet'])) {
- if (is_bool($options['quiet'])) {
- $quiet = $options['quiet'] ? 'true' : 'false';
- } elseif (is_string($options['quiet'])) {
- $quiet = ($options['quiet'] === 'true') ? 'true' : 'false';
- }
- }
- $xmlBody = OssUtil::createDeleteObjectsXmlBody($objects, $quiet);
- $options[self::OSS_CONTENT] = $xmlBody;
- $response = $this->auth($options);
- $result = new DeleteObjectsResult($response);
- return $result->getData();
- }
-
- public function getObject($bucket, $object, $options = null)
- {
- $this->precheckCommon($bucket, $object, $options);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_GET;
- $options[self::OSS_OBJECT] = $object;
- if (isset($options[self::OSS_LAST_MODIFIED])) {
- $options[self::OSS_HEADERS][self::OSS_IF_MODIFIED_SINCE] = $options[self::OSS_LAST_MODIFIED];
- unset($options[self::OSS_LAST_MODIFIED]);
- }
- if (isset($options[self::OSS_ETAG])) {
- $options[self::OSS_HEADERS][self::OSS_IF_NONE_MATCH] = $options[self::OSS_ETAG];
- unset($options[self::OSS_ETAG]);
- }
- if (isset($options[self::OSS_RANGE])) {
- $range = $options[self::OSS_RANGE];
- $options[self::OSS_HEADERS][self::OSS_RANGE] = "bytes=$range";
- unset($options[self::OSS_RANGE]);
- }
- $response = $this->auth($options);
- $result = new BodyResult($response);
- return $result->getData();
- }
-
- public function doesObjectExist($bucket, $object, $options = null)
- {
- $this->precheckCommon($bucket, $object, $options);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_HEAD;
- $options[self::OSS_OBJECT] = $object;
- $response = $this->auth($options);
- $result = new ExistResult($response);
- return $result->getData();
- }
-
- public function restoreObject($bucket, $object, $options = null)
- {
- $this->precheckCommon($bucket, $object, $options);
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_METHOD] = self::OSS_HTTP_POST;
- $options[self::OSS_OBJECT] = $object;
- $options[self::OSS_SUB_RESOURCE] = self::OSS_RESTORE;
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- private function computePartSize($partSize)
- {
- $partSize = (integer)$partSize;
- if ($partSize <= self::OSS_MIN_PART_SIZE) {
- $partSize = self::OSS_MIN_PART_SIZE;
- } elseif ($partSize > self::OSS_MAX_PART_SIZE) {
- $partSize = self::OSS_MAX_PART_SIZE;
- }
- return $partSize;
- }
-
- public function generateMultiuploadParts($file_size, $partSize = 5242880)
- {
- $i = 0;
- $size_count = $file_size;
- $values = array();
- $partSize = $this->computePartSize($partSize);
- while ($size_count > 0) {
- $size_count -= $partSize;
- $values[] = array(
- self::OSS_SEEK_TO => ($partSize * $i),
- self::OSS_LENGTH => (($size_count > 0) ? $partSize : ($size_count + $partSize)),
- );
- $i++;
- }
- return $values;
- }
-
- public function initiateMultipartUpload($bucket, $object, $options = null)
- {
- $this->precheckCommon($bucket, $object, $options);
- $options[self::OSS_METHOD] = self::OSS_HTTP_POST;
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_OBJECT] = $object;
- $options[self::OSS_SUB_RESOURCE] = 'uploads';
- $options[self::OSS_CONTENT] = '';
- if (!isset($options[self::OSS_CONTENT_TYPE])) {
- $options[self::OSS_CONTENT_TYPE] = $this->getMimeType($object);
- }
- if (!isset($options[self::OSS_HEADERS])) {
- $options[self::OSS_HEADERS] = array();
- }
- $response = $this->auth($options);
- $result = new InitiateMultipartUploadResult($response);
- return $result->getData();
- }
-
- public function uploadPart($bucket, $object, $uploadId, $options = null)
- {
- $this->precheckCommon($bucket, $object, $options);
- $this->precheckParam($options, self::OSS_FILE_UPLOAD, __FUNCTION__);
- $this->precheckParam($options, self::OSS_PART_NUM, __FUNCTION__);
- $options[self::OSS_METHOD] = self::OSS_HTTP_PUT;
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_OBJECT] = $object;
- $options[self::OSS_UPLOAD_ID] = $uploadId;
- if (isset($options[self::OSS_LENGTH])) {
- $options[self::OSS_CONTENT_LENGTH] = $options[self::OSS_LENGTH];
- }
- $response = $this->auth($options);
- $result = new UploadPartResult($response);
- return $result->getData();
- }
-
- public function listParts($bucket, $object, $uploadId, $options = null)
- {
- $this->precheckCommon($bucket, $object, $options);
- $options[self::OSS_METHOD] = self::OSS_HTTP_GET;
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_OBJECT] = $object;
- $options[self::OSS_UPLOAD_ID] = $uploadId;
- $options[self::OSS_QUERY_STRING] = array();
- foreach (array('max-parts', 'part-number-marker') as $param) {
- if (isset($options[$param])) {
- $options[self::OSS_QUERY_STRING][$param] = $options[$param];
- unset($options[$param]);
- }
- }
- $response = $this->auth($options);
- $result = new ListPartsResult($response);
- return $result->getData();
- }
-
- public function abortMultipartUpload($bucket, $object, $uploadId, $options = null)
- {
- $this->precheckCommon($bucket, $object, $options);
- $options[self::OSS_METHOD] = self::OSS_HTTP_DELETE;
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_OBJECT] = $object;
- $options[self::OSS_UPLOAD_ID] = $uploadId;
- $response = $this->auth($options);
- $result = new PutSetDeleteResult($response);
- return $result->getData();
- }
-
- public function completeMultipartUpload($bucket, $object, $uploadId, $listParts, $options = null)
- {
- $this->precheckCommon($bucket, $object, $options);
- $options[self::OSS_METHOD] = self::OSS_HTTP_POST;
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_OBJECT] = $object;
- $options[self::OSS_UPLOAD_ID] = $uploadId;
- $options[self::OSS_CONTENT_TYPE] = 'application/xml';
- if (!is_array($listParts)) {
- throw new OssException("listParts must be array type");
- }
- $options[self::OSS_CONTENT] = OssUtil::createCompleteMultipartUploadXmlBody($listParts);
- $response = $this->auth($options);
- if (isset($options[self::OSS_CALLBACK]) && !empty($options[self::OSS_CALLBACK])) {
- $result = new CallbackResult($response);
- } else {
- $result = new PutSetDeleteResult($response);
- }
- return $result->getData();
- }
-
- public function listMultipartUploads($bucket, $options = null)
- {
- $this->precheckCommon($bucket, null, $options, false);
- $options[self::OSS_METHOD] = self::OSS_HTTP_GET;
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_OBJECT] = '/';
- $options[self::OSS_SUB_RESOURCE] = 'uploads';
- foreach (array('delimiter', 'key-marker', 'max-uploads', 'prefix', 'upload-id-marker') as $param) {
- if (isset($options[$param])) {
- $options[self::OSS_QUERY_STRING][$param] = $options[$param];
- unset($options[$param]);
- }
- }
- $query = isset($options[self::OSS_QUERY_STRING]) ? $options[self::OSS_QUERY_STRING] : array();
- $options[self::OSS_QUERY_STRING] = array_merge(
- $query,
- array(self::OSS_ENCODING_TYPE => self::OSS_ENCODING_TYPE_URL)
- );
- $response = $this->auth($options);
- $result = new ListMultipartUploadResult($response);
- return $result->getData();
- }
-
- public function uploadPartCopy($fromBucket, $fromObject, $toBucket, $toObject, $partNumber, $uploadId, $options = null)
- {
- $this->precheckCommon($fromBucket, $fromObject, $options);
- $this->precheckCommon($toBucket, $toObject, $options);
-
- $start_range = "0";
- if (isset($options['start'])) {
- $start_range = $options['start'];
- }
- $end_range = "";
- if (isset($options['end'])) {
- $end_range = $options['end'];
- }
- $options[self::OSS_METHOD] = self::OSS_HTTP_PUT;
- $options[self::OSS_BUCKET] = $toBucket;
- $options[self::OSS_OBJECT] = $toObject;
- $options[self::OSS_PART_NUM] = $partNumber;
- $options[self::OSS_UPLOAD_ID] = $uploadId;
- if (!isset($options[self::OSS_HEADERS])) {
- $options[self::OSS_HEADERS] = array();
- }
- $options[self::OSS_HEADERS][self::OSS_OBJECT_COPY_SOURCE] = '/' . $fromBucket . '/' . $fromObject;
- $options[self::OSS_HEADERS][self::OSS_OBJECT_COPY_SOURCE_RANGE] = "bytes=" . $start_range . "-" . $end_range;
- $response = $this->auth($options);
- $result = new UploadPartResult($response);
- return $result->getData();
- }
-
- public function multiuploadFile($bucket, $object, $file, $options = null)
- {
- $this->precheckCommon($bucket, $object, $options);
- if (isset($options[self::OSS_LENGTH])) {
- $options[self::OSS_CONTENT_LENGTH] = $options[self::OSS_LENGTH];
- unset($options[self::OSS_LENGTH]);
- }
- if (empty($file)) {
- throw new OssException("parameter invalid, file is empty");
- }
- $uploadFile = OssUtil::encodePath($file);
- if (!isset($options[self::OSS_CONTENT_TYPE])) {
- $options[self::OSS_CONTENT_TYPE] = $this->getMimeType($object, $uploadFile);
- }
- $upload_position = isset($options[self::OSS_SEEK_TO]) ? (integer)$options[self::OSS_SEEK_TO] : 0;
- if (isset($options[self::OSS_CONTENT_LENGTH])) {
- $upload_file_size = (integer)$options[self::OSS_CONTENT_LENGTH];
- } else {
- $upload_file_size = filesize($uploadFile);
- if ($upload_file_size !== false) {
- $upload_file_size -= $upload_position;
- }
- }
- if ($upload_position === false || !isset($upload_file_size) || $upload_file_size === false || $upload_file_size < 0) {
- throw new OssException('The size of `fileUpload` cannot be determined in ' . __FUNCTION__ . '().');
- }
-
- if (isset($options[self::OSS_PART_SIZE])) {
- $options[self::OSS_PART_SIZE] = $this->computePartSize($options[self::OSS_PART_SIZE]);
- } else {
- $options[self::OSS_PART_SIZE] = self::OSS_MID_PART_SIZE;
- }
- $is_check_md5 = $this->isCheckMD5($options);
-
- if ($upload_file_size < $options[self::OSS_PART_SIZE] && !isset($options[self::OSS_UPLOAD_ID])) {
- return $this->uploadFile($bucket, $object, $uploadFile, $options);
- }
-
- if (isset($options[self::OSS_UPLOAD_ID])) {
- $uploadId = $options[self::OSS_UPLOAD_ID];
- } else {
-
- $uploadId = $this->initiateMultipartUpload($bucket, $object, $options);
- }
-
- $pieces = $this->generateMultiuploadParts($upload_file_size, (integer)$options[self::OSS_PART_SIZE]);
- $response_upload_part = array();
- foreach ($pieces as $i => $piece) {
- $from_pos = $upload_position + (integer)$piece[self::OSS_SEEK_TO];
- $to_pos = (integer)$piece[self::OSS_LENGTH] + $from_pos - 1;
- $up_options = array(
- self::OSS_FILE_UPLOAD => $uploadFile,
- self::OSS_PART_NUM => ($i + 1),
- self::OSS_SEEK_TO => $from_pos,
- self::OSS_LENGTH => $to_pos - $from_pos + 1,
- self::OSS_CHECK_MD5 => $is_check_md5,
- );
- if ($is_check_md5) {
- $content_md5 = OssUtil::getMd5SumForFile($uploadFile, $from_pos, $to_pos);
- $up_options[self::OSS_CONTENT_MD5] = $content_md5;
- }
- $response_upload_part[] = $this->uploadPart($bucket, $object, $uploadId, $up_options);
- }
- $uploadParts = array();
- foreach ($response_upload_part as $i => $etag) {
- $uploadParts[] = array(
- 'PartNumber' => ($i + 1),
- 'ETag' => $etag,
- );
- }
- return $this->completeMultipartUpload($bucket, $object, $uploadId, $uploadParts);
- }
-
- public function uploadDir($bucket, $prefix, $localDirectory, $exclude = '.|..|.svn|.git', $recursive = false, $checkMd5 = true)
- {
- $retArray = array("succeededList" => array(), "failedList" => array());
- if (empty($bucket)) throw new OssException("parameter error, bucket is empty");
- if (!is_string($prefix)) throw new OssException("parameter error, prefix is not string");
- if (empty($localDirectory)) throw new OssException("parameter error, localDirectory is empty");
- $directory = $localDirectory;
- $directory = OssUtil::encodePath($directory);
-
- if (!is_dir($directory)) {
- throw new OssException('parameter error: ' . $directory . ' is not a directory, please check it');
- }
-
- $file_list_array = OssUtil::readDir($directory, $exclude, $recursive);
- if (!$file_list_array) {
- throw new OssException($directory . ' is empty...');
- }
- foreach ($file_list_array as $k => $item) {
- if (is_dir($item['path'])) {
- continue;
- }
- $options = array(
- self::OSS_PART_SIZE => self::OSS_MIN_PART_SIZE,
- self::OSS_CHECK_MD5 => $checkMd5,
- );
- $realObject = (!empty($prefix) ? $prefix . '/' : '') . $item['file'];
- try {
- $this->multiuploadFile($bucket, $realObject, $item['path'], $options);
- $retArray["succeededList"][] = $realObject;
- } catch (OssException $e) {
- $retArray["failedList"][$realObject] = $e->getMessage();
- }
- }
- return $retArray;
- }
-
- public function signUrl($bucket, $object, $timeout = 60, $method = self::OSS_HTTP_GET, $options = null)
- {
- $this->precheckCommon($bucket, $object, $options);
-
- if (self::OSS_HTTP_GET !== $method && self::OSS_HTTP_PUT !== $method) {
- throw new OssException("method is invalid");
- }
- $options[self::OSS_BUCKET] = $bucket;
- $options[self::OSS_OBJECT] = $object;
- $options[self::OSS_METHOD] = $method;
- if (!isset($options[self::OSS_CONTENT_TYPE])) {
- $options[self::OSS_CONTENT_TYPE] = '';
- }
- $timeout = time() + $timeout;
- $options[self::OSS_PREAUTH] = $timeout;
- $options[self::OSS_DATE] = $timeout;
- $this->setSignStsInUrl(true);
- return $this->auth($options);
- }
-
- private function precheckOptions(&$options)
- {
- OssUtil::validateOptions($options);
- if (!$options) {
- $options = array();
- }
- }
-
- private function precheckBucket($bucket, $errMsg = 'bucket is not allowed empty')
- {
- OssUtil::throwOssExceptionWithMessageIfEmpty($bucket, $errMsg);
- }
-
- private function precheckObject($object)
- {
- OssUtil::throwOssExceptionWithMessageIfEmpty($object, "object name is empty");
- }
-
- private function precheckStorage($storage)
- {
- if (is_string($storage)) {
- switch ($storage) {
- case self::OSS_STORAGE_ARCHIVE:
- return;
- case self::OSS_STORAGE_IA:
- return;
- case self::OSS_STORAGE_STANDARD:
- return;
- default:
- break;
- }
- }
- throw new OssException('storage name is invalid');
- }
-
- private function precheckCommon($bucket, $object, &$options, $isCheckObject = true)
- {
- if ($isCheckObject) {
- $this->precheckObject($object);
- }
- $this->precheckOptions($options);
- $this->precheckBucket($bucket);
- }
-
- private function precheckParam($options, $param, $funcName)
- {
- if (!isset($options[$param])) {
- throw new OssException('The `' . $param . '` options is required in ' . $funcName . '().');
- }
- }
-
- private function isCheckMD5($options)
- {
- return $this->getValue($options, self::OSS_CHECK_MD5, false, true, true);
- }
-
- private function getValue($options, $key, $default = null, $isCheckEmpty = false, $isCheckBool = false)
- {
- $value = $default;
- if (isset($options[$key])) {
- if ($isCheckEmpty) {
- if (!empty($options[$key])) {
- $value = $options[$key];
- }
- } else {
- $value = $options[$key];
- }
- unset($options[$key]);
- }
- if ($isCheckBool) {
- if ($value !== true && $value !== false) {
- $value = false;
- }
- }
- return $value;
- }
-
- private function getMimeType($object, $file = null)
- {
- if (!is_null($file)) {
- $type = MimeTypes::getMimetype($file);
- if (!is_null($type)) {
- return $type;
- }
- }
- $type = MimeTypes::getMimetype($object);
- if (!is_null($type)) {
- return $type;
- }
- return self::DEFAULT_CONTENT_TYPE;
- }
-
- public function auth($options)
- {
- OssUtil::validateOptions($options);
-
- $this->authPrecheckBucket($options);
-
- $this->authPrecheckObject($options);
-
- $this->authPrecheckObjectEncoding($options);
-
- $this->authPrecheckAcl($options);
-
- $scheme = $this->useSSL ? 'https://' : 'http://';
-
- $hostname = $this->generateHostname($options[self::OSS_BUCKET]);
- $string_to_sign = '';
- $headers = $this->generateHeaders($options, $hostname);
- $signable_query_string_params = $this->generateSignableQueryStringParam($options);
- $signable_query_string = OssUtil::toQueryString($signable_query_string_params);
- $resource_uri = $this->generateResourceUri($options);
-
- $conjunction = '?';
- $non_signable_resource = '';
- if (isset($options[self::OSS_SUB_RESOURCE])) {
- $conjunction = '&';
- }
- if ($signable_query_string !== '') {
- $signable_query_string = $conjunction . $signable_query_string;
- $conjunction = '&';
- }
- $query_string = $this->generateQueryString($options);
- if ($query_string !== '') {
- $non_signable_resource .= $conjunction . $query_string;
- $conjunction = '&';
- }
- $this->requestUrl = $scheme . $hostname . $resource_uri . $signable_query_string . $non_signable_resource;
-
- $request = new RequestCore($this->requestUrl, $this->requestProxy);
- $request->set_useragent($this->generateUserAgent());
-
- if (isset($options[self::OSS_FILE_UPLOAD])) {
- if (is_resource($options[self::OSS_FILE_UPLOAD])) {
- $length = null;
- if (isset($options[self::OSS_CONTENT_LENGTH])) {
- $length = $options[self::OSS_CONTENT_LENGTH];
- } elseif (isset($options[self::OSS_SEEK_TO])) {
- $stats = fstat($options[self::OSS_FILE_UPLOAD]);
- if ($stats && $stats[self::OSS_SIZE] >= 0) {
- $length = $stats[self::OSS_SIZE] - (integer)$options[self::OSS_SEEK_TO];
- }
- }
- $request->set_read_stream($options[self::OSS_FILE_UPLOAD], $length);
- } else {
- $request->set_read_file($options[self::OSS_FILE_UPLOAD]);
- $length = $request->read_stream_size;
- if (isset($options[self::OSS_CONTENT_LENGTH])) {
- $length = $options[self::OSS_CONTENT_LENGTH];
- } elseif (isset($options[self::OSS_SEEK_TO]) && isset($length)) {
- $length -= (integer)$options[self::OSS_SEEK_TO];
- }
- $request->set_read_stream_size($length);
- }
- }
- if (isset($options[self::OSS_SEEK_TO])) {
- $request->set_seek_position((integer)$options[self::OSS_SEEK_TO]);
- }
- if (isset($options[self::OSS_FILE_DOWNLOAD])) {
- if (is_resource($options[self::OSS_FILE_DOWNLOAD])) {
- $request->set_write_stream($options[self::OSS_FILE_DOWNLOAD]);
- } else {
- $request->set_write_file($options[self::OSS_FILE_DOWNLOAD]);
- }
- }
- if (isset($options[self::OSS_METHOD])) {
- $request->set_method($options[self::OSS_METHOD]);
- $string_to_sign .= $options[self::OSS_METHOD] . "\n";
- }
- if (isset($options[self::OSS_CONTENT])) {
- $request->set_body($options[self::OSS_CONTENT]);
- if ($headers[self::OSS_CONTENT_TYPE] === 'application/x-www-form-urlencoded') {
- $headers[self::OSS_CONTENT_TYPE] = 'application/octet-stream';
- }
- $headers[self::OSS_CONTENT_LENGTH] = strlen($options[self::OSS_CONTENT]);
- $headers[self::OSS_CONTENT_MD5] = base64_encode(md5($options[self::OSS_CONTENT], true));
- }
- if (isset($options[self::OSS_CALLBACK])) {
- $headers[self::OSS_CALLBACK] = base64_encode($options[self::OSS_CALLBACK]);
- }
- if (isset($options[self::OSS_CALLBACK_VAR])) {
- $headers[self::OSS_CALLBACK_VAR] = base64_encode($options[self::OSS_CALLBACK_VAR]);
- }
- if (!isset($headers[self::OSS_ACCEPT_ENCODING])) {
- $headers[self::OSS_ACCEPT_ENCODING] = '';
- }
- uksort($headers, 'strnatcasecmp');
- foreach ($headers as $header_key => $header_value) {
- $header_value = str_replace(array("\r", "\n"), '', $header_value);
- if ($header_value !== '' || $header_key === self::OSS_ACCEPT_ENCODING) {
- $request->add_header($header_key, $header_value);
- }
- if (
- strtolower($header_key) === 'content-md5' ||
- strtolower($header_key) === 'content-type' ||
- strtolower($header_key) === 'date' ||
- (isset($options['self::OSS_PREAUTH']) && (integer)$options['self::OSS_PREAUTH'] > 0)
- ) {
- $string_to_sign .= $header_value . "\n";
- } elseif (substr(strtolower($header_key), 0, 6) === self::OSS_DEFAULT_PREFIX) {
- $string_to_sign .= strtolower($header_key) . ':' . $header_value . "\n";
- }
- }
-
- $signable_resource = $this->generateSignableResource($options);
- $string_to_sign .= rawurldecode($signable_resource) . urldecode($signable_query_string);
-
- $string_to_sign_ordered = $this->stringToSignSorted($string_to_sign);
- $signature = base64_encode(hash_hmac('sha1', $string_to_sign_ordered, $this->accessKeySecret, true));
- $request->add_header('Authorization', 'OSS ' . $this->accessKeyId . ':' . $signature);
- if (isset($options[self::OSS_PREAUTH]) && (integer)$options[self::OSS_PREAUTH] > 0) {
- $signed_url = $this->requestUrl . $conjunction . self::OSS_URL_ACCESS_KEY_ID . '=' . rawurlencode($this->accessKeyId) . '&' . self::OSS_URL_EXPIRES . '=' . $options[self::OSS_PREAUTH] . '&' . self::OSS_URL_SIGNATURE . '=' . rawurlencode($signature);
- return $signed_url;
- } elseif (isset($options[self::OSS_PREAUTH])) {
- return $this->requestUrl;
- }
- if ($this->timeout !== 0) {
- $request->timeout = $this->timeout;
- }
- if ($this->connectTimeout !== 0) {
- $request->connect_timeout = $this->connectTimeout;
- }
- try {
- $request->send_request();
- } catch (RequestCore_Exception $e) {
- throw(new OssException('RequestCoreException: ' . $e->getMessage()));
- }
- $response_header = $request->get_response_header();
- $response_header['oss-request-url'] = $this->requestUrl;
- $response_header['oss-redirects'] = $this->redirects;
- $response_header['oss-stringtosign'] = $string_to_sign;
- $response_header['oss-requestheaders'] = $request->request_headers;
- $data = new ResponseCore($response_header, $request->get_response_body(), $request->get_response_code());
-
- if ((integer)$request->get_response_code() === 500) {
- if ($this->redirects <= $this->maxRetries) {
-
- $delay = (integer)(pow(4, $this->redirects) * 100000);
- usleep($delay);
- $this->redirects++;
- $data = $this->auth($options);
- }
- }
- $this->redirects = 0;
- return $data;
- }
-
- public function setMaxTries($maxRetries = 3)
- {
- $this->maxRetries = $maxRetries;
- }
-
- public function getMaxRetries()
- {
- return $this->maxRetries;
- }
-
- public function setSignStsInUrl($enable)
- {
- $this->enableStsInUrl = $enable;
- }
-
- public function isUseSSL()
- {
- return $this->useSSL;
- }
-
- public function setUseSSL($useSSL)
- {
- $this->useSSL = $useSSL;
- }
-
- private function authPrecheckBucket($options)
- {
- if (!(('/' == $options[self::OSS_OBJECT]) && ('' == $options[self::OSS_BUCKET]) && ('GET' == $options[self::OSS_METHOD])) && !OssUtil::validateBucket($options[self::OSS_BUCKET])) {
- throw new OssException('"' . $options[self::OSS_BUCKET] . '"' . 'bucket name is invalid');
- }
- }
-
- private function authPrecheckObject($options)
- {
- if (isset($options[self::OSS_OBJECT]) && $options[self::OSS_OBJECT] === '/') {
- return;
- }
- if (isset($options[self::OSS_OBJECT]) && !OssUtil::validateObject($options[self::OSS_OBJECT])) {
- throw new OssException('"' . $options[self::OSS_OBJECT] . '"' . ' object name is invalid');
- }
- }
-
- private function authPrecheckObjectEncoding(&$options)
- {
- $tmp_object = $options[self::OSS_OBJECT];
- try {
- if (OssUtil::isGb2312($options[self::OSS_OBJECT])) {
- $options[self::OSS_OBJECT] = iconv('GB2312', "UTF-8//IGNORE", $options[self::OSS_OBJECT]);
- } elseif (OssUtil::checkChar($options[self::OSS_OBJECT], true)) {
- $options[self::OSS_OBJECT] = iconv('GBK', "UTF-8//IGNORE", $options[self::OSS_OBJECT]);
- }
- } catch (\Exception $e) {
- try {
- $tmp_object = iconv(mb_detect_encoding($tmp_object), "UTF-8", $tmp_object);
- } catch (\Exception $e) {
- }
- }
- $options[self::OSS_OBJECT] = $tmp_object;
- }
-
- private function authPrecheckAcl($options)
- {
- if (isset($options[self::OSS_HEADERS][self::OSS_ACL]) && !empty($options[self::OSS_HEADERS][self::OSS_ACL])) {
- if (!in_array(strtolower($options[self::OSS_HEADERS][self::OSS_ACL]), self::$OSS_ACL_TYPES)) {
- throw new OssException($options[self::OSS_HEADERS][self::OSS_ACL] . ':' . 'acl is invalid(private,public-read,public-read-write)');
- }
- }
- }
-
- private function generateHostname($bucket)
- {
- if ($this->hostType === self::OSS_HOST_TYPE_IP) {
- $hostname = $this->hostname;
- } elseif ($this->hostType === self::OSS_HOST_TYPE_CNAME) {
- $hostname = $this->hostname;
- } else {
-
- $hostname = ($bucket == '') ? $this->hostname : ($bucket . '.') . $this->hostname;
- }
- return $hostname;
- }
-
- private function generateResourceUri($options)
- {
- $resource_uri = "";
-
- if (isset($options[self::OSS_BUCKET]) && '' !== $options[self::OSS_BUCKET]) {
- if ($this->hostType === self::OSS_HOST_TYPE_IP) {
- $resource_uri = '/' . $options[self::OSS_BUCKET];
- }
- }
-
- if (isset($options[self::OSS_OBJECT]) && '/' !== $options[self::OSS_OBJECT]) {
- $resource_uri .= '/' . str_replace(array('%2F', '%25'), array('/', '%'), rawurlencode($options[self::OSS_OBJECT]));
- }
-
- $conjunction = '?';
- if (isset($options[self::OSS_SUB_RESOURCE])) {
- $resource_uri .= $conjunction . $options[self::OSS_SUB_RESOURCE];
- }
- return $resource_uri;
- }
-
- private function generateSignableQueryStringParam($options)
- {
- $signableQueryStringParams = array();
- $signableList = array(
- self::OSS_PART_NUM,
- 'response-content-type',
- 'response-content-language',
- 'response-cache-control',
- 'response-content-encoding',
- 'response-expires',
- 'response-content-disposition',
- self::OSS_UPLOAD_ID,
- self::OSS_COMP,
- self::OSS_LIVE_CHANNEL_STATUS,
- self::OSS_LIVE_CHANNEL_START_TIME,
- self::OSS_LIVE_CHANNEL_END_TIME,
- self::OSS_PROCESS,
- self::OSS_POSITION,
- self::OSS_SYMLINK,
- self::OSS_RESTORE,
- );
- foreach ($signableList as $item) {
- if (isset($options[$item])) {
- $signableQueryStringParams[$item] = $options[$item];
- }
- }
- if ($this->enableStsInUrl && (!is_null($this->securityToken))) {
- $signableQueryStringParams["security-token"] = $this->securityToken;
- }
- return $signableQueryStringParams;
- }
-
- private function generateSignableResource($options)
- {
- $signableResource = "";
- $signableResource .= '/';
- if (isset($options[self::OSS_BUCKET]) && '' !== $options[self::OSS_BUCKET]) {
- $signableResource .= $options[self::OSS_BUCKET];
-
- if ($options[self::OSS_OBJECT] == '/') {
- if ($this->hostType !== self::OSS_HOST_TYPE_IP) {
- $signableResource .= "/";
- }
- }
- }
-
- if (isset($options[self::OSS_OBJECT]) && '/' !== $options[self::OSS_OBJECT]) {
- $signableResource .= '/' . str_replace(array('%2F', '%25'), array('/', '%'), rawurlencode($options[self::OSS_OBJECT]));
- }
- if (isset($options[self::OSS_SUB_RESOURCE])) {
- $signableResource .= '?' . $options[self::OSS_SUB_RESOURCE];
- }
- return $signableResource;
- }
-
- private function generateQueryString($options)
- {
-
- $queryStringParams = array();
- if (isset($options[self::OSS_QUERY_STRING])) {
- $queryStringParams = array_merge($queryStringParams, $options[self::OSS_QUERY_STRING]);
- }
- return OssUtil::toQueryString($queryStringParams);
- }
- private function stringToSignSorted($string_to_sign)
- {
- $queryStringSorted = '';
- $explodeResult = explode('?', $string_to_sign);
- $index = count($explodeResult);
- if ($index === 1)
- return $string_to_sign;
- $queryStringParams = explode('&', $explodeResult[$index - 1]);
- sort($queryStringParams);
- foreach ($queryStringParams as $params) {
- $queryStringSorted .= $params . '&';
- }
- $queryStringSorted = substr($queryStringSorted, 0, -1);
- return $explodeResult[0] . '?' . $queryStringSorted;
- }
-
- private function generateHeaders($options, $hostname)
- {
- $headers = array(
- self::OSS_CONTENT_MD5 => '',
- self::OSS_CONTENT_TYPE => isset($options[self::OSS_CONTENT_TYPE]) ? $options[self::OSS_CONTENT_TYPE] : self::DEFAULT_CONTENT_TYPE,
- self::OSS_DATE => isset($options[self::OSS_DATE]) ? $options[self::OSS_DATE] : gmdate('D, d M Y H:i:s \G\M\T'),
- self::OSS_HOST => $hostname,
- );
- if (isset($options[self::OSS_CONTENT_MD5])) {
- $headers[self::OSS_CONTENT_MD5] = $options[self::OSS_CONTENT_MD5];
- }
-
- if ((!is_null($this->securityToken)) && (!$this->enableStsInUrl)) {
- $headers[self::OSS_SECURITY_TOKEN] = $this->securityToken;
- }
-
- if (isset($options[self::OSS_HEADERS])) {
- $headers = array_merge($headers, $options[self::OSS_HEADERS]);
- }
- return $headers;
- }
-
- private function generateUserAgent()
- {
- return self::OSS_NAME . "/" . self::OSS_VERSION . " (" . php_uname('s') . "/" . php_uname('r') . "/" . php_uname('m') . ";" . PHP_VERSION . ")";
- }
-
- private function checkEndpoint($endpoint, $isCName)
- {
- $ret_endpoint = null;
- if (strpos($endpoint, 'http://') === 0) {
- $ret_endpoint = substr($endpoint, strlen('http://'));
- } elseif (strpos($endpoint, 'https://') === 0) {
- $ret_endpoint = substr($endpoint, strlen('https://'));
- $this->useSSL = true;
- } else {
- $ret_endpoint = $endpoint;
- }
- if ($isCName) {
- $this->hostType = self::OSS_HOST_TYPE_CNAME;
- } elseif (OssUtil::isIPFormat($ret_endpoint)) {
- $this->hostType = self::OSS_HOST_TYPE_IP;
- } else {
- $this->hostType = self::OSS_HOST_TYPE_NORMAL;
- }
- return $ret_endpoint;
- }
-
- public static function checkEnv()
- {
- if (function_exists('get_loaded_extensions')) {
-
- $enabled_extension = array("curl");
- $extensions = get_loaded_extensions();
- if ($extensions) {
- foreach ($enabled_extension as $item) {
- if (!in_array($item, $extensions)) {
- throw new OssException("Extension {" . $item . "} is not installed or not enabled, please check your php env.");
- }
- }
- } else {
- throw new OssException("function get_loaded_extensions not found.");
- }
- } else {
- throw new OssException('Function get_loaded_extensions has been disabled, please check php config.');
- }
- }
-
- public function setTimeout($timeout)
- {
- $this->timeout = $timeout;
- }
-
- public function setConnectTimeout($connectTimeout)
- {
- $this->connectTimeout = $connectTimeout;
- }
-
- const OSS_LIFECYCLE_EXPIRATION = "Expiration";
- const OSS_LIFECYCLE_TIMING_DAYS = "Days";
- const OSS_LIFECYCLE_TIMING_DATE = "Date";
-
- const OSS_BUCKET = 'bucket';
- const OSS_OBJECT = 'object';
- const OSS_HEADERS = OssUtil::OSS_HEADERS;
- const OSS_METHOD = 'method';
- const OSS_QUERY = 'query';
- const OSS_BASENAME = 'basename';
- const OSS_MAX_KEYS = 'max-keys';
- const OSS_UPLOAD_ID = 'uploadId';
- const OSS_PART_NUM = 'partNumber';
- const OSS_COMP = 'comp';
- const OSS_LIVE_CHANNEL_STATUS = 'status';
- const OSS_LIVE_CHANNEL_START_TIME = 'startTime';
- const OSS_LIVE_CHANNEL_END_TIME = 'endTime';
- const OSS_POSITION = 'position';
- const OSS_MAX_KEYS_VALUE = 100;
- const OSS_MAX_OBJECT_GROUP_VALUE = OssUtil::OSS_MAX_OBJECT_GROUP_VALUE;
- const OSS_MAX_PART_SIZE = OssUtil::OSS_MAX_PART_SIZE;
- const OSS_MID_PART_SIZE = OssUtil::OSS_MID_PART_SIZE;
- const OSS_MIN_PART_SIZE = OssUtil::OSS_MIN_PART_SIZE;
- const OSS_FILE_SLICE_SIZE = 8192;
- const OSS_PREFIX = 'prefix';
- const OSS_DELIMITER = 'delimiter';
- const OSS_MARKER = 'marker';
- const OSS_ACCEPT_ENCODING = 'Accept-Encoding';
- const OSS_CONTENT_MD5 = 'Content-Md5';
- const OSS_SELF_CONTENT_MD5 = 'x-oss-meta-md5';
- const OSS_CONTENT_TYPE = 'Content-Type';
- const OSS_CONTENT_LENGTH = 'Content-Length';
- const OSS_IF_MODIFIED_SINCE = 'If-Modified-Since';
- const OSS_IF_UNMODIFIED_SINCE = 'If-Unmodified-Since';
- const OSS_IF_MATCH = 'If-Match';
- const OSS_IF_NONE_MATCH = 'If-None-Match';
- const OSS_CACHE_CONTROL = 'Cache-Control';
- const OSS_EXPIRES = 'Expires';
- const OSS_PREAUTH = 'preauth';
- const OSS_CONTENT_COING = 'Content-Coding';
- const OSS_CONTENT_DISPOSTION = 'Content-Disposition';
- const OSS_RANGE = 'range';
- const OSS_ETAG = 'etag';
- const OSS_LAST_MODIFIED = 'lastmodified';
- const OS_CONTENT_RANGE = 'Content-Range';
- const OSS_CONTENT = OssUtil::OSS_CONTENT;
- const OSS_BODY = 'body';
- const OSS_LENGTH = OssUtil::OSS_LENGTH;
- const OSS_HOST = 'Host';
- const OSS_DATE = 'Date';
- const OSS_AUTHORIZATION = 'Authorization';
- const OSS_FILE_DOWNLOAD = 'fileDownload';
- const OSS_FILE_UPLOAD = 'fileUpload';
- const OSS_PART_SIZE = 'partSize';
- const OSS_SEEK_TO = 'seekTo';
- const OSS_SIZE = 'size';
- const OSS_QUERY_STRING = 'query_string';
- const OSS_SUB_RESOURCE = 'sub_resource';
- const OSS_DEFAULT_PREFIX = 'x-oss-';
- const OSS_CHECK_MD5 = 'checkmd5';
- const DEFAULT_CONTENT_TYPE = 'application/octet-stream';
- const OSS_SYMLINK_TARGET = 'x-oss-symlink-target';
- const OSS_SYMLINK = 'symlink';
- const OSS_HTTP_CODE = 'http_code';
- const OSS_REQUEST_ID = 'x-oss-request-id';
- const OSS_INFO = 'info';
- const OSS_STORAGE = 'storage';
- const OSS_RESTORE = 'restore';
- const OSS_STORAGE_STANDARD = 'Standard';
- const OSS_STORAGE_IA = 'IA';
- const OSS_STORAGE_ARCHIVE = 'Archive';
-
- const OSS_URL_ACCESS_KEY_ID = 'OSSAccessKeyId';
- const OSS_URL_EXPIRES = 'Expires';
- const OSS_URL_SIGNATURE = 'Signature';
-
- const OSS_HTTP_GET = 'GET';
- const OSS_HTTP_PUT = 'PUT';
- const OSS_HTTP_HEAD = 'HEAD';
- const OSS_HTTP_POST = 'POST';
- const OSS_HTTP_DELETE = 'DELETE';
- const OSS_HTTP_OPTIONS = 'OPTIONS';
-
- const OSS_ACL = 'x-oss-acl';
- const OSS_OBJECT_ACL = 'x-oss-object-acl';
- const OSS_OBJECT_GROUP = 'x-oss-file-group';
- const OSS_MULTI_PART = 'uploads';
- const OSS_MULTI_DELETE = 'delete';
- const OSS_OBJECT_COPY_SOURCE = 'x-oss-copy-source';
- const OSS_OBJECT_COPY_SOURCE_RANGE = "x-oss-copy-source-range";
- const OSS_PROCESS = "x-oss-process";
- const OSS_CALLBACK = "x-oss-callback";
- const OSS_CALLBACK_VAR = "x-oss-callback-var";
-
- const OSS_SECURITY_TOKEN = "x-oss-security-token";
- const OSS_ACL_TYPE_PRIVATE = 'private';
- const OSS_ACL_TYPE_PUBLIC_READ = 'public-read';
- const OSS_ACL_TYPE_PUBLIC_READ_WRITE = 'public-read-write';
- const OSS_ENCODING_TYPE = "encoding-type";
- const OSS_ENCODING_TYPE_URL = "url";
-
- const OSS_HOST_TYPE_NORMAL = "normal";
- const OSS_HOST_TYPE_IP = "ip";
- const OSS_HOST_TYPE_SPECIAL = 'special';
- const OSS_HOST_TYPE_CNAME = "cname";
-
- static $OSS_ACL_TYPES = array(
- self::OSS_ACL_TYPE_PRIVATE,
- self::OSS_ACL_TYPE_PUBLIC_READ,
- self::OSS_ACL_TYPE_PUBLIC_READ_WRITE
- );
-
- const OSS_NAME = "aliyun-sdk-php";
- const OSS_VERSION = "2.3.0";
- const OSS_BUILD = "20180105";
- const OSS_AUTHOR = "";
- const OSS_OPTIONS_ORIGIN = 'Origin';
- const OSS_OPTIONS_REQUEST_METHOD = 'Access-Control-Request-Method';
- const OSS_OPTIONS_REQUEST_HEADERS = 'Access-Control-Request-Headers';
-
- private $useSSL = false;
- private $maxRetries = 3;
- private $redirects = 0;
-
- private $hostType = self::OSS_HOST_TYPE_NORMAL;
- private $requestUrl;
- private $accessKeyId;
- private $accessKeySecret;
- private $hostname;
- private $securityToken;
- private $requestProxy = null;
- private $enableStsInUrl = false;
- private $timeout = 0;
- private $connectTimeout = 0;
- }
|