test.js 134 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412341334143415341634173418341934203421342234233424342534263427342834293430343134323433343434353436343734383439344034413442344334443445344634473448344934503451345234533454345534563457345834593460346134623463346434653466346734683469347034713472347334743475347634773478347934803481348234833484348534863487348834893490349134923493349434953496349734983499350035013502350335043505350635073508350935103511351235133514351535163517351835193520352135223523352435253526352735283529353035313532353335343535353635373538353935403541354235433544354535463547354835493550355135523553355435553556355735583559356035613562356335643565356635673568356935703571357235733574357535763577357835793580358135823583358435853586358735883589359035913592359335943595359635973598359936003601360236033604360536063607360836093610361136123613361436153616361736183619362036213622362336243625362636273628362936303631363236333634363536363637363836393640364136423643364436453646364736483649365036513652365336543655365636573658365936603661366236633664366536663667366836693670367136723673367436753676367736783679368036813682368336843685368636873688368936903691369236933694369536963697369836993700370137023703370437053706370737083709371037113712371337143715371637173718371937203721372237233724372537263727372837293730373137323733373437353736373737383739374037413742374337443745374637473748374937503751375237533754375537563757375837593760376137623763376437653766376737683769377037713772377337743775377637773778377937803781378237833784378537863787378837893790379137923793379437953796379737983799380038013802380338043805380638073808380938103811381238133814381538163817381838193820382138223823382438253826382738283829383038313832383338343835383638373838383938403841384238433844
  1. // config 替换成自己的桶信息
  2. var config = {
  3. Bucket: 'test-1250000000',
  4. Region: 'ap-guangzhou',
  5. };
  6. config.Uin = '10001';
  7. QUnit.log(function(details) {
  8. console.log("[test-log]" + JSON.stringify(details));
  9. });
  10. QUnit.done(function(details) {
  11. console.log("[test-result]" + JSON.stringify(details));
  12. });
  13. var util = {
  14. createFile: function (options) {
  15. var buffer = new ArrayBuffer(options.size || 0);
  16. var arr = new Uint8Array(buffer);
  17. for (var i = 0; i < arr.length; i++) {
  18. arr[i] = 0;
  19. }
  20. var opt = {};
  21. options.type && (opt.type = options.type);
  22. var blob = new Blob([buffer], options);
  23. return blob;
  24. },
  25. str2blob: function (str) {
  26. var size = str.length;
  27. var buffer = new ArrayBuffer(size || 0);
  28. var arr = new Uint8Array(buffer);
  29. for (var i = 0; i < arr.length; i++) {
  30. arr[i] = str[i];
  31. }
  32. var blob = new Blob([buffer]);
  33. return blob;
  34. }
  35. };
  36. function camSafeUrlEncode(str) {
  37. return encodeURIComponent(str)
  38. .replace(/!/g, '%21')
  39. .replace(/'/g, '%27')
  40. .replace(/\(/g, '%28')
  41. .replace(/\)/g, '%29')
  42. .replace(/\*/g, '%2A');
  43. }
  44. var getAuthorization = function (options, callback) {
  45. // 格式一、(推荐)后端通过获取临时密钥给到前端,前端计算签名
  46. // 服务端 JS 和 PHP 例子:https://github.com/tencentyun/cos-js-sdk-v5/blob/master/server/
  47. // 服务端其他语言参考 COS STS SDK :https://github.com/tencentyun/qcloud-cos-sts-sdk
  48. // var url = '../server/sts.php';
  49. var url = '/sts';
  50. var xhr = new XMLHttpRequest();
  51. xhr.open('GET', url, true);
  52. xhr.onload = function (e) {
  53. try {
  54. var data = JSON.parse(e.target.responseText);
  55. var credentials = data.credentials;
  56. } catch (e) {
  57. }
  58. callback({
  59. TmpSecretId: credentials.tmpSecretId,
  60. TmpSecretKey: credentials.tmpSecretKey,
  61. SecurityToken: credentials.sessionToken,
  62. ExpiredTime: data.expiredTime, // SDK 在 ExpiredTime 时间前,不会再次调用 getAuthorization
  63. });
  64. };
  65. xhr.send();
  66. // // 格式二、(推荐)【细粒度控制权限】后端通过获取临时密钥给到前端,前端只有相同请求才重用临时密钥,后端可以通过 Scope 细粒度控制权限
  67. // // 服务端例子:https://github.com/tencentyun/qcloud-cos-sts-sdk/edit/master/scope.md
  68. // // var url = '../server/sts.php';
  69. // var url = '/sts-scope';
  70. // var xhr = new XMLHttpRequest();
  71. // xhr.open('POST', url, true);
  72. // xhr.setRequestHeader('Content-Type', 'application/json');
  73. // xhr.onload = function (e) {
  74. // try {
  75. // var data = JSON.parse(e.target.responseText);
  76. // var credentials = data.credentials;
  77. // } catch (e) {
  78. // }
  79. // callback({
  80. // TmpSecretId: credentials.tmpSecretId,
  81. // TmpSecretKey: credentials.tmpSecretKey,
  82. // SecurityToken: credentials.sessionToken,
  83. // ExpiredTime: data.expiredTime,
  84. // ScopeLimit: true, // 设为 true 可限制密钥只在相同请求可重用,默认不限制一直可重用,细粒度控制权限需要设为 true
  85. // });
  86. // };
  87. // xhr.send(JSON.stringify(options.Scope));
  88. // // 格式三、(不推荐,分片上传权限不好控制)前端每次请求前都需要通过 getAuthorization 获取签名,后端使用固定密钥或临时密钥计算签名返回给前端
  89. // // 服务端获取签名,请参考对应语言的 COS SDK:https://cloud.tencent.com/document/product/436/6474
  90. // // 注意:这种有安全风险,后端需要通过 method、pathname 严格控制好权限,比如不允许 put / 等
  91. // var method = (options.Method || 'get').toLowerCase();
  92. // var query = options.Query || {};
  93. // var headers = options.Headers || {};
  94. // var pathname = options.Pathname || '/';
  95. // // var url = 'http://127.0.0.1:3000/auth';
  96. // var url = '../server/auth.php';
  97. // var xhr = new XMLHttpRequest();
  98. // var data = {
  99. // method: method,
  100. // pathname: pathname,
  101. // query: query,
  102. // headers: headers,
  103. // };
  104. // xhr.open('POST', url, true);
  105. // xhr.setRequestHeader('content-type', 'application/json');
  106. // xhr.onload = function (e) {
  107. // try {
  108. // var data = JSON.parse(e.target.responseText);
  109. // } catch (e) {
  110. // }
  111. // callback({
  112. // Authorization: data.authorization,
  113. // // SecurityToken: data.sessionToken, // 如果使用临时密钥,需要把 sessionToken 传给 SecurityToken
  114. // });
  115. // };
  116. // xhr.send(JSON.stringify(data));
  117. // // 格式四、(不推荐,适用于前端调试,避免泄露密钥)前端使用固定密钥计算签名,通过 COS.getAuthorization 静态方法计算
  118. // var authorization = COS.getAuthorization({
  119. // SecretId: 'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx', // 可传固定密钥或者临时密钥
  120. // SecretKey: 'xxx', // 可传固定密钥或者临时密钥
  121. // Method: options.Method,
  122. // Pathname: options.Pathname,
  123. // Query: options.Query,
  124. // Headers: options.Headers,
  125. // Expires: 900,
  126. // });
  127. // callback({
  128. // Authorization: authorization,
  129. // // SecurityToken: credentials.sessionToken, // 如果使用临时密钥,需要传 SecurityToken
  130. // });
  131. // // 格式五、(不推荐,适用于前端调试,避免泄露密钥)前端使用固定密钥计算签名,通过 cos-auth.js 计算
  132. // var auth = CosAuth({
  133. // Version: '4.0',
  134. // SecretId: 'xxx',
  135. // SecretKey: 'xxx',
  136. // Bucket: config.Bucket,
  137. // Expires: 900,
  138. // Pathname: '/' + (options.Headers && options.Headers['x-cos-copy-source'] ? '' : options.Key),
  139. // });
  140. // callback({Authorization: auth});
  141. };
  142. var dataURItoUploadBody = function (dataURI) {
  143. var byteString = atob(dataURI.split(',')[1]);
  144. var mimeString = dataURI.split(',')[0].split(':')[1].split(';')[0];
  145. var ab = new ArrayBuffer(byteString.length);
  146. var ia = new Uint8Array(ab);
  147. for (var i = 0; i < byteString.length; i++) {
  148. ia[i] = byteString.charCodeAt(i);
  149. }
  150. return new Blob([ab], {type: mimeString});
  151. };
  152. var createFileSync = function (size) {
  153. return util.createFile({size: size});
  154. };
  155. var group = function (name, fn) {
  156. return fn();
  157. };
  158. var test = function (name, fn) {
  159. QUnit.test(name, function (assert) {
  160. return new Promise(function (done) {
  161. fn(done, assert);
  162. });
  163. });
  164. };
  165. var request = function (opt, callback) {
  166. var i;
  167. var xhr = new XMLHttpRequest();
  168. xhr.open('GET', opt.url, true);
  169. if (opt.headers) {
  170. for (i in opt.headers) {
  171. if (opt.headers.hasOwnProperty(i)) {
  172. xhr.setRequestHeader(i, opt.headers[i]);
  173. }
  174. }
  175. }
  176. xhr.onload = function (e) {
  177. callback(null, {statusCode: xhr.status}, xhr.responseText);
  178. };
  179. xhr.onerror = function (e) {
  180. callback('error', {statusCode: xhr.status});
  181. };
  182. xhr.send();
  183. };
  184. var cos = new COS({
  185. // 必选参数
  186. getAuthorization: getAuthorization,
  187. // 可选参数
  188. FileParallelLimit: 3, // 控制文件上传并发数
  189. ChunkParallelLimit: 3, // 控制单个文件下分片上传并发数
  190. ChunkSize: 1024 * 1024, // 控制分片大小,单位 B
  191. ProgressInterval: 1, // 控制 onProgress 回调的间隔
  192. ChunkRetryTimes: 3, // 控制文件切片后单片上传失败后重试次数
  193. UploadCheckContentMd5: true, // 上传过程计算 Content-MD5
  194. });
  195. var AppId = config.AppId;
  196. var Bucket = config.Bucket;
  197. var BucketShortName = Bucket;
  198. var BucketLongName = Bucket + '-' + AppId;
  199. var TaskId;
  200. var match = config.Bucket.match(/^(.+)-(\d+)$/);
  201. if (match) {
  202. BucketLongName = config.Bucket;
  203. BucketShortName = match[1];
  204. AppId = match[2];
  205. }
  206. function comparePlainObject(a, b) {
  207. if (Object.keys(a).length !== Object.keys(b).length) {
  208. return false;
  209. }
  210. for (var key in a) {
  211. if (typeof a[key] === 'object' && typeof b[key] === 'object') {
  212. if (!comparePlainObject(a[key], b[key])) {
  213. return false;
  214. }
  215. } else if (a[key] != b[key]) {
  216. return false;
  217. }
  218. }
  219. return true;
  220. }
  221. function prepareBigObject(needHeaders) {
  222. return new Promise(function (resolve, reject) {
  223. // 创建测试文件
  224. var filename = name || 'bigger.zip';
  225. var content = util.createFile({size: 1024 * 1024 * 10});
  226. var put = function () {
  227. // 调用方法
  228. var params = {
  229. Bucket: config.Bucket,
  230. Region: config.Region,
  231. Key: filename,
  232. Body: content,
  233. ContentLength: content.length,
  234. };
  235. if (needHeaders) {
  236. params.ContentType = 'text/html';
  237. params.CacheControl = 'max-age=7200';
  238. params.ContentDisposition = 'inline;filename=hello.jpg';
  239. params.Expires = (new Date()).toGMTString();
  240. params.Headers = {
  241. 'x-cos-meta-test': 'xxx'
  242. };
  243. }
  244. cos.putObject(params, function (err, data) {
  245. err ? reject(err) : resolve()
  246. });
  247. };
  248. put();
  249. });
  250. }
  251. function prepareBucket() {
  252. return new Promise(function (resolve, reject) {
  253. resolve();
  254. });
  255. }
  256. group('mock readAsBinaryString', function () {
  257. test('mock readAsBinaryString', function (done, assert) {
  258. FileReader.prototype._readAsBinaryString = FileReader.prototype.readAsBinaryString;
  259. FileReader.prototype.readAsBinaryString = false;
  260. var filename = '10m.zip';
  261. var blob = util.createFile({size: 1024 * 1024 * 10});
  262. var paused = false;
  263. cos.sliceUploadFile({
  264. Bucket: config.Bucket,
  265. Region: config.Region,
  266. Key: filename,
  267. Body: blob,
  268. onTaskReady: function (taskId) {
  269. TaskId = taskId;
  270. },
  271. onProgress: function (info) {
  272. if (!paused && info.percent > 0.6) {
  273. cos.cancelTask(TaskId);
  274. var hasProgress = false;
  275. cos.sliceUploadFile({
  276. Bucket: config.Bucket,
  277. Region: config.Region,
  278. Key: filename,
  279. Body: blob,
  280. onTaskReady: function (taskId) {
  281. TaskId = taskId;
  282. },
  283. onProgress: function (info) {
  284. if (info.percent === 0) return;
  285. assert.ok(info.percent > 0.3, '分片续传成功');
  286. cos.cancelTask(TaskId);
  287. FileReader.prototype.readAsBinaryString = FileReader.prototype._readAsBinaryString;
  288. delete FileReader.prototype._readAsBinaryString;
  289. done();
  290. }
  291. }, function (err) {
  292. if (hasProgress) {
  293. assert.ok(false, '分片续传');
  294. done();
  295. }
  296. });
  297. }
  298. }
  299. });
  300. });
  301. });
  302. group('getAuth()', function () {
  303. test('getAuth()', function (done, assert) {
  304. var content = Date.now().toString();
  305. var key = '1.txt';
  306. cos.putObject({
  307. Bucket: config.Bucket,
  308. Region: config.Region,
  309. Key: key,
  310. Body: content,
  311. }, function (err, data) {
  312. cos.options.getAuthorization({
  313. Method: 'get',
  314. Key: key,
  315. Scope: [{
  316. action: 'GetObject',
  317. bucket: config.Bucket,
  318. region: config.Region,
  319. prefix: key,
  320. }],
  321. }, function (AuthData) {
  322. if (typeof AuthData === 'string') {
  323. AuthData = {Authorization: AuthData};
  324. }
  325. if (!AuthData.Authorization) {
  326. AuthData.Authorization = COS.getAuthorization({
  327. SecretId: AuthData.TmpSecretId,
  328. SecretKey: AuthData.TmpSecretKey,
  329. Method: 'get',
  330. Key: key,
  331. SystemClockOffset: cos.options.SystemClockOffset,
  332. });
  333. }
  334. var link = 'http://' + config.Bucket + '.cos.' + config.Region + '.myqcloud.com' + '/' +
  335. camSafeUrlEncode(key).replace(/%2F/g, '/') + '?' + AuthData.Authorization +
  336. (AuthData.SecurityToken ? '&x-cos-security-token=' + AuthData.SecurityToken : '');
  337. request({
  338. url: link,
  339. }, function (err, response, body) {
  340. assert.ok(response.statusCode === 200);
  341. assert.ok(body === content);
  342. done();
  343. });
  344. });
  345. });
  346. });
  347. });
  348. group('getObjectUrl()', function () {
  349. test('getObjectUrl()', function (done, assert) {
  350. var content = Date.now().toString();
  351. var key = '1.txt';
  352. cos.putObject({
  353. Bucket: config.Bucket,
  354. Region: config.Region,
  355. Key: key,
  356. Body: content,
  357. }, function (err, data) {
  358. cos.getObjectUrl({
  359. Bucket: config.Bucket,
  360. Region: config.Region,
  361. Key: key,
  362. }, function (err, data) {
  363. request({
  364. url: data.Url,
  365. }, function (err, response, body) {
  366. assert.ok(!err, '文件获取出错');
  367. assert.ok(response.statusCode === 200, '获取文件 200');
  368. assert.ok(body.toString() === content, '通过获取签名能正常获取文件');
  369. done();
  370. });
  371. });
  372. });
  373. });
  374. });
  375. group('auth check', function () {
  376. test('auth check', function (done, assert) {
  377. cos.getBucket({
  378. Bucket: config.Bucket,
  379. Region: config.Region,
  380. Prefix: 'aksjhdlash sajlhj!@#$%^&*()_+=-[]{}\';:"/.<>?.,??sadasd#/.,/~`',
  381. Headers: {
  382. 'x-cos-test': 'aksjhdlash sajlhj!@#$%^&*()_+=-[]{}\';:\"/.<>?.,??sadasd#/.,/~`',
  383. },
  384. }, function (err, data) {
  385. assert.ok(!err);
  386. done();
  387. });
  388. });
  389. });
  390. group('getBucket(),listObjectVersions', function () {
  391. test('正常获取 bucket 里的文件列表', function (done, assert) {
  392. prepareBucket().then(function () {
  393. cos.getBucket({
  394. Bucket: config.Bucket,
  395. Region: config.Region
  396. }, function (err, data) {
  397. assert.ok(data.Name === BucketLongName);
  398. assert.ok(data.Contents.constructor, Array);
  399. done();
  400. });
  401. }).catch(function () {
  402. assert.ok(false);
  403. done();
  404. });
  405. });
  406. test('正常获取 bucket 里的文件版本列表', function (done, assert) {
  407. prepareBucket().then(function () {
  408. cos.listObjectVersions({
  409. Bucket: config.Bucket,
  410. Region: config.Region
  411. }, function (err, data) {
  412. assert.ok(data.Name === BucketLongName);
  413. assert.ok(data.Versions.constructor === Array);
  414. done();
  415. });
  416. }).catch(function () {
  417. assert.ok(false);
  418. done();
  419. });
  420. });
  421. });
  422. group('putObject(),cancelTask()', function () {
  423. test('putObject(),cancelTask()', function (done, assert) {
  424. var filename = '10m.zip';
  425. var alive = false;
  426. var canceled = false;
  427. cos.putObject({
  428. Bucket: config.Bucket,
  429. Region: config.Region,
  430. Key: filename,
  431. Body: util.createFile({size: 1024 * 1024 * 10}),
  432. onTaskReady: function (taskId) {
  433. TaskId = taskId;
  434. },
  435. onProgress: function (info) {
  436. alive = true;
  437. if (!canceled) {
  438. cos.cancelTask(TaskId);
  439. alive = false;
  440. canceled = true;
  441. setTimeout(function () {
  442. assert.ok(!alive, '取消上传已经生效');
  443. done();
  444. }, 1200);
  445. }
  446. }
  447. }, function (err, data) {
  448. alive = true;
  449. });
  450. });
  451. });
  452. group('sliceUploadFile() 完整上传文件', function () {
  453. test('sliceUploadFile() 完整上传文件', function (done, assert) {
  454. var lastPercent;
  455. var filename = '3m.zip';
  456. var fileSize = 1024 * 1024 * 3;
  457. var blob = createFileSync(fileSize)
  458. cos.abortUploadTask({
  459. Bucket: config.Bucket,
  460. Region: config.Region,
  461. Key: filename,
  462. Level: 'file',
  463. }, function (err, data) {
  464. cos.sliceUploadFile({
  465. Bucket: config.Bucket,
  466. Region: config.Region,
  467. Key: filename,
  468. Body: blob,
  469. onTaskReady: function (taskId) {
  470. TaskId = taskId;
  471. },
  472. onProgress: function (info) {
  473. lastPercent = info.percent;
  474. }
  475. }, function (err, data) {
  476. assert.ok(data.ETag.length > 0);
  477. cos.headObject({
  478. Bucket: config.Bucket,
  479. Region: config.Region,
  480. Key: filename,
  481. }, function (err, data) {
  482. assert.ok(data && data.headers && data.headers.etag && data.headers.etag.length > 0, '文件已上传成功');
  483. assert.ok(data && data.headers && parseInt(data.headers['content-length'] || 0) === fileSize, '文件大小一致');
  484. done();
  485. });
  486. });
  487. });
  488. });
  489. test('sliceUploadFile(),pauseTask(),restartTask()', function (done, assert) {
  490. var filename = '10m.zip';
  491. var blob = util.createFile({size: 1024 * 1024 * 10});
  492. var paused = false;
  493. var restarted = false;
  494. cos.abortUploadTask({
  495. Bucket: config.Bucket,
  496. Region: config.Region,
  497. Key: filename,
  498. Level: 'file',
  499. }, function (err, data) {
  500. var TaskId;
  501. cos.sliceUploadFile({
  502. Bucket: config.Bucket,
  503. Region: config.Region,
  504. Key: filename,
  505. Body: blob,
  506. onTaskReady: function (taskId) {
  507. TaskId = taskId;
  508. },
  509. onProgress: function (info) {
  510. if (!paused && info.percent > 0.6) {
  511. cos.pauseTask(TaskId);
  512. paused = true;
  513. setTimeout(function () {
  514. restarted = true;
  515. cos.restartTask(TaskId);
  516. }, 1000);
  517. }
  518. if (paused && restarted) {
  519. if (info.percent === 0) return;
  520. assert.ok(info.percent > 0.3, '暂停和重试成功');
  521. cos.cancelTask(TaskId);
  522. done();
  523. }
  524. }
  525. }, function (err, data) {
  526. paused = true;
  527. });
  528. });
  529. });
  530. test('sliceUploadFile(),cancelTask(),restartTask()', function (done, assert) {
  531. var filename = '10m.zip';
  532. var blob = util.createFile({size: 1024 * 1024 * 3});
  533. var paused = false;
  534. cos.abortUploadTask({
  535. Bucket: config.Bucket,
  536. Region: config.Region,
  537. Key: filename,
  538. Level: 'file',
  539. }, function (err, data) {
  540. var TaskId;
  541. cos.sliceUploadFile({
  542. Bucket: config.Bucket,
  543. Region: config.Region,
  544. Key: filename,
  545. Body: blob,
  546. onTaskReady: function (taskId) {
  547. TaskId = taskId;
  548. },
  549. onProgress: function (info) {
  550. if (!paused && info.percent > 0.6) {
  551. cos.cancelTask(TaskId);
  552. setTimeout(function () {
  553. cos.sliceUploadFile({
  554. Bucket: config.Bucket,
  555. Region: config.Region,
  556. Key: filename,
  557. Body: blob,
  558. }, function (err, data) {
  559. assert.ok(!err);
  560. done();
  561. });
  562. }, 10);
  563. }
  564. }
  565. }, function (err, data) {
  566. });
  567. });
  568. });
  569. test('sliceUploadFile(),cancelTask()', function (done, assert) {
  570. var filename = '3m.zip';
  571. var alive = false;
  572. var canceled = false;
  573. cos.sliceUploadFile({
  574. Bucket: config.Bucket,
  575. Region: config.Region,
  576. Key: filename,
  577. Body: util.createFile({size: 1024 * 1024 * 3}),
  578. onTaskReady: function (taskId) {
  579. TaskId = taskId;
  580. },
  581. onProgress: function (info) {
  582. alive = true;
  583. if (!canceled) {
  584. cos.cancelTask(TaskId);
  585. alive = false;
  586. canceled = true;
  587. setTimeout(function () {
  588. assert.ok(!alive, '取消上传已经生效');
  589. done();
  590. }, 1200);
  591. }
  592. }
  593. }, function (err, data) {
  594. alive = true;
  595. });
  596. });
  597. });
  598. group('abortUploadTask()', function () {
  599. test('abortUploadTask(),Level=task', function (done, assert) {
  600. var filename = '1m.zip';
  601. cos.multipartInit({
  602. Bucket: config.Bucket,
  603. Region: config.Region,
  604. Key: filename,
  605. }, function (err, data) {
  606. cos.abortUploadTask({
  607. Bucket: config.Bucket,
  608. Region: config.Region,
  609. Key: filename,
  610. Level: 'task',
  611. UploadId: data.UploadId,
  612. }, function (err, data) {
  613. var nameExist = false;
  614. data.successList.forEach(function (item) {
  615. if (filename === item.Key) {
  616. nameExist = true;
  617. }
  618. });
  619. assert.ok(data.successList.length >= 1, '成功取消单个分片任务');
  620. assert.ok(nameExist, '成功取消单个分片任务');
  621. done();
  622. });
  623. });
  624. });
  625. test('abortUploadTask(),Level=file', function (done, assert) {
  626. var filename = '1m.zip';
  627. var blob = util.createFile({size: 1024 * 1024});
  628. cos.sliceUploadFile({
  629. Bucket: config.Bucket,
  630. Region: config.Region,
  631. Key: filename,
  632. Body: blob,
  633. onTaskReady: function (taskId) {
  634. TaskId = taskId;
  635. },
  636. onProgress: function (info) {
  637. cos.cancelTask(TaskId);
  638. cos.abortUploadTask({
  639. Bucket: config.Bucket,
  640. Region: config.Region,
  641. Level: 'file',
  642. Key: filename,
  643. }, function (err, data) {
  644. assert.ok(data.successList.length >= 1, '成功舍弃单个文件下的所有分片任务');
  645. assert.ok(data.successList[0] && data.successList[0].Key === filename, '成功舍弃单个文件的所有分片任务');
  646. done();
  647. });
  648. }
  649. });
  650. });
  651. test('abortUploadTask(),Level=bucket', function (done, assert) {
  652. var filename = '1m.zip';
  653. var blob = util.createFile({size: 1024 * 1024 * 10});
  654. cos.sliceUploadFile({
  655. Bucket: config.Bucket,
  656. Region: config.Region,
  657. Key: filename,
  658. Body: blob,
  659. onTaskReady: function (taskId) {
  660. TaskId = taskId;
  661. },
  662. onProgress: function (info) {
  663. cos.cancelTask(TaskId);
  664. cos.abortUploadTask({
  665. Bucket: config.Bucket,
  666. Region: config.Region,
  667. Level: 'bucket',
  668. }, function (err, data) {
  669. var nameExist = false;
  670. data.successList.forEach(function (item) {
  671. if (filename === item.Key) {
  672. nameExist = true;
  673. }
  674. });
  675. assert.ok(data.successList.length >= 1, '成功舍弃Bucket下所有分片任务');
  676. assert.ok(nameExist, '成功舍弃Bucket下所有分片任务');
  677. done();
  678. });
  679. }
  680. });
  681. });
  682. });
  683. group('headBucket()', function () {
  684. test('headBucket()', function (done, assert) {
  685. cos.headBucket({
  686. Bucket: config.Bucket,
  687. Region: config.Region
  688. }, function (err, data) {
  689. assert.ok(data, '正常获取 head bucket');
  690. done();
  691. });
  692. });
  693. test('headBucket() not exist', function (done, assert) {
  694. cos.headBucket({
  695. Bucket: config.Bucket + Date.now().toString(36),
  696. Region: config.Region
  697. }, function (err, data) {
  698. assert.ok(err, 'bucket 不存在');
  699. done();
  700. });
  701. });
  702. test('deleteBucket()', function (done, assert) {
  703. cos.deleteBucket({
  704. Bucket: config.Bucket + Date.now().toString(36),
  705. Region: config.Region
  706. }, function (err, data) {
  707. assert.ok(err, '正常获取 head bucket');
  708. done();
  709. });
  710. });
  711. test('getBucket()', function (done, assert) {
  712. cos.getBucket({
  713. Bucket: config.Bucket,
  714. Region: config.Region
  715. }, function (err, data) {
  716. assert.ok(data.Name === BucketLongName, '能列出 bucket');
  717. assert.ok(data.Contents.constructor === Array, '正常获取 bucket 里的文件列表');
  718. done();
  719. });
  720. });
  721. });
  722. group('putObject()', function () {
  723. var buf = new ArrayBuffer(8);
  724. var arr = new Uint8Array(buf);
  725. [0x89, 0xe8,0xaf,0xb4,0x2e,0x70,0x72,0x70,0x72].forEach(function (v, i) {
  726. arr[i] = v;
  727. });
  728. test('putObject()', function (done, assert) {
  729. var filename = '1.txt';
  730. var getObjectETag = function (callback) {
  731. setTimeout(function () {
  732. cos.headObject({
  733. Bucket: config.Bucket,
  734. Region: config.Region,
  735. Key: filename,
  736. }, function (err, data) {
  737. callback(data && data.headers && data.headers.etag);
  738. });
  739. }, 2000);
  740. };
  741. var content = Date.now().toString();
  742. var lastPercent = 0;
  743. cos.putObject({
  744. Bucket: config.Bucket,
  745. Region: config.Region,
  746. Key: filename,
  747. Body: util.str2blob(content),
  748. onProgress: function (info) {
  749. lastPercent = info.percent;
  750. },
  751. }, function (err, data) {
  752. if (err) throw err;
  753. assert.ok(data && data.ETag, 'putObject 有返回 ETag');
  754. getObjectETag(function (ETag) {
  755. assert.ok(data.ETag === ETag, 'Blob 创建 object');
  756. done();
  757. });
  758. });
  759. });
  760. test('putObject(),string', function (done, assert) {
  761. var filename = '1.txt';
  762. var content = '中文_' + Date.now().toString(36);
  763. var lastPercent = 0;
  764. cos.putObject({
  765. Bucket: config.Bucket,
  766. Region: config.Region,
  767. Key: filename,
  768. Body: content,
  769. onProgress: function (info) {
  770. lastPercent = info.percent;
  771. },
  772. }, function (err, data) {
  773. if (err) throw err;
  774. var ETag = data && data.ETag;
  775. assert.ok(ETag, 'putObject 有返回 ETag');
  776. cos.getObject({
  777. Bucket: config.Bucket,
  778. Region: config.Region,
  779. Key: filename,
  780. }, function (err, data) {
  781. assert.ok(data.Body && data.Body === content && (data.headers && data.headers.etag) === ETag);
  782. done();
  783. });
  784. });
  785. });
  786. test('putObject(),string,empty', function (done, assert) {
  787. var content = '';
  788. var lastPercent = 0;
  789. var Key = '1.txt';
  790. cos.putObject({
  791. Bucket: config.Bucket,
  792. Region: config.Region,
  793. Key: Key,
  794. Body: content,
  795. onProgress: function (info) {
  796. lastPercent = info.percent;
  797. },
  798. }, function (err, data) {
  799. if (err) throw err;
  800. var ETag = data && data.ETag;
  801. assert.ok(ETag, 'putObject 有返回 ETag');
  802. cos.getObject({
  803. Bucket: config.Bucket,
  804. Region: config.Region,
  805. Key: Key,
  806. }, function (err, data) {
  807. assert.ok(data.Body === content && (data.headers && data.headers.etag) === ETag);
  808. done();
  809. });
  810. });
  811. });
  812. test('putObject(),特殊二进制字符 ArrayBuffer md5', function (done, assert) {
  813. var content = '';
  814. var lastPercent = 0;
  815. var Key = '1.mp4';
  816. var blob = new Blob([buf]);
  817. cos.putObject({
  818. Bucket: config.Bucket,
  819. Region: config.Region,
  820. Key: Key,
  821. Body: blob,
  822. onProgress: function (info) {
  823. lastPercent = info.percent;
  824. },
  825. }, function (err, data) {
  826. if (err) throw err;
  827. var ETag = data && data.ETag;
  828. assert.ok(ETag, 'putObject 有返回 ETag');
  829. cos.getObject({
  830. Bucket: config.Bucket,
  831. Region: config.Region,
  832. Key: Key,
  833. BodyType: 'arraybuffer',
  834. }, function (err, data) {
  835. var arr = new Uint8Array(data.Body);
  836. var isSame = arr.every(function (v, i) {
  837. return v === arr[i];
  838. });
  839. assert.ok(isSame && (data.headers && data.headers.etag) === ETag);
  840. done();
  841. });
  842. });
  843. });
  844. test('putObject(),特殊二进制字符 Blob md5', function (done, assert) {
  845. var content = '';
  846. var lastPercent = 0;
  847. var Key = '1.mp4';
  848. cos.putObject({
  849. Bucket: config.Bucket,
  850. Region: config.Region,
  851. Key: Key,
  852. Body: buf,
  853. onProgress: function (info) {
  854. lastPercent = info.percent;
  855. },
  856. }, function (err, data) {
  857. if (err) throw err;
  858. var ETag = data && data.ETag;
  859. assert.ok(ETag, 'putObject 有返回 ETag');
  860. cos.getObject({
  861. Bucket: config.Bucket,
  862. Region: config.Region,
  863. Key: Key,
  864. BodyType: 'arraybuffer',
  865. }, function (err, data) {
  866. var arr = new Uint8Array(data.Body);
  867. var isSame = arr.every(function (v, i) {
  868. return v === arr[i];
  869. });
  870. assert.ok(isSame && (data.headers && data.headers.etag) === ETag);
  871. done();
  872. });
  873. });
  874. });
  875. test('putObject(),特殊二进制字符 中文 string md5', function (done, assert) {
  876. var Key = '1.txt';
  877. var content = '中文';
  878. cos.putObject({
  879. Bucket: config.Bucket,
  880. Region: config.Region,
  881. Key: Key,
  882. Body: content,
  883. }, function (err, data) {
  884. if (err) throw err;
  885. var ETag = data && data.ETag;
  886. assert.ok(ETag, 'putObject 有返回 ETag');
  887. cos.getObject({
  888. Bucket: config.Bucket,
  889. Region: config.Region,
  890. Key: Key,
  891. }, function (err, data) {
  892. var isSame = content === data.Body;
  893. assert.ok(isSame && (data.headers && data.headers.etag) === ETag);
  894. done();
  895. });
  896. });
  897. });
  898. test('putObject(),特殊二进制字符 unescape string md5', function (done, assert) {
  899. var Key = '1.txt';
  900. var content = unescape(encodeURIComponent('中文'));
  901. cos.putObject({
  902. Bucket: config.Bucket,
  903. Region: config.Region,
  904. Key: Key,
  905. Body: content,
  906. }, function (err, data) {
  907. if (err) throw err;
  908. var ETag = data && data.ETag;
  909. assert.ok(ETag, 'putObject 有返回 ETag');
  910. cos.getObject({
  911. Bucket: config.Bucket,
  912. Region: config.Region,
  913. Key: Key,
  914. }, function (err, data) {
  915. var isSame = content === data.Body;
  916. assert.ok(isSame && (data.headers && data.headers.etag) === ETag);
  917. done();
  918. });
  919. });
  920. });
  921. });
  922. group('getObject()', function () {
  923. test('getObject() body', function (done, assert) {
  924. var key = '1.txt';
  925. var content = Date.now().toString();
  926. cos.putObject({
  927. Bucket: config.Bucket,
  928. Region: config.Region,
  929. Key: key,
  930. Body: content,
  931. }, function (err, data) {
  932. cos.getObject({
  933. Bucket: config.Bucket,
  934. Region: config.Region,
  935. Key: key
  936. }, function (err, data) {
  937. if (err) throw err;
  938. var objectContent = data.Body.toString();
  939. assert.ok(data.headers['content-length'] === '' + content.length);
  940. assert.ok(objectContent === content);
  941. done();
  942. });
  943. });
  944. });
  945. test('getObject() DataType blob', function (done, assert) {
  946. var key = '1.txt';
  947. var content = Date.now().toString();
  948. cos.putObject({
  949. Bucket: config.Bucket,
  950. Region: config.Region,
  951. Key: key,
  952. Body: content,
  953. }, function (err, data) {
  954. cos.getObject({
  955. Bucket: config.Bucket,
  956. Region: config.Region,
  957. Key: key,
  958. DataType: 'blob',
  959. }, function (err, data) {
  960. if (err) throw err;
  961. assert.ok(data.Body instanceof Blob);
  962. assert.ok(data.headers['content-length'] === '' + content.length);
  963. done();
  964. });
  965. });
  966. });
  967. test('getObject() DataType arraybuffer', function (done, assert) {
  968. var key = '1.txt';
  969. var content = Date.now().toString();
  970. cos.putObject({
  971. Bucket: config.Bucket,
  972. Region: config.Region,
  973. Key: key,
  974. Body: content,
  975. }, function (err, data) {
  976. cos.getObject({
  977. Bucket: config.Bucket,
  978. Region: config.Region,
  979. Key: key,
  980. DataType: 'arraybuffer',
  981. }, function (err, data) {
  982. if (err) throw err;
  983. assert.ok(data.Body instanceof ArrayBuffer);
  984. assert.ok(data.headers['content-length'] === '' + content.length);
  985. done();
  986. });
  987. });
  988. });
  989. });
  990. group('Key 特殊字符', function () {
  991. test('Key 特殊字符', function (done, assert) {
  992. cos.putObject({
  993. Bucket: config.Bucket,
  994. Region: config.Region,
  995. Key: '(!\'*) "#$%&+,-./0123456789:;<=>@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\\]^_`abcdefghijklmnopqrstuvwxyz{|}~',
  996. Body: Date.now().toString()
  997. }, function (err, data) {
  998. if (err) throw err;
  999. assert.ok(data, 'putObject 特殊字符的 Key 能通过');
  1000. done();
  1001. });
  1002. });
  1003. });
  1004. group('putObjectCopy() 1', function () {
  1005. test('putObjectCopy() 1', function (done, assert) {
  1006. var content = Date.now().toString(36);
  1007. cos.putObject({
  1008. Bucket: config.Bucket,
  1009. Region: config.Region,
  1010. Key: '1.txt',
  1011. Body: content,
  1012. }, function (err, data) {
  1013. var ETag = data.ETag;
  1014. cos.deleteObject({
  1015. Bucket: config.Bucket,
  1016. Region: config.Region,
  1017. Key: '1.copy.txt',
  1018. }, function (err, data) {
  1019. cos.putObjectCopy({
  1020. Bucket: config.Bucket,
  1021. Region: config.Region,
  1022. Key: '1.copy.txt',
  1023. CopySource: BucketLongName + '.cos.' + config.Region + '.myqcloud.com/1.txt',
  1024. }, function (err, data) {
  1025. cos.headObject({
  1026. Bucket: config.Bucket,
  1027. Region: config.Region,
  1028. Key: '1.copy.txt',
  1029. }, function (err, data) {
  1030. assert.ok(data.headers && data.headers.etag === ETag, '成功复制文件');
  1031. done();
  1032. });
  1033. });
  1034. });
  1035. });
  1036. });
  1037. });
  1038. group('putObjectCopy()', function () {
  1039. var filename = '1.txt';
  1040. test('正常复制 object', function (done, assert) {
  1041. cos.putObjectCopy({
  1042. Bucket: config.Bucket,
  1043. Region: config.Region,
  1044. Key: '1.copy.txt',
  1045. CopySource: config.Bucket + '.cos.' + config.Region + '.myqcloud.com/' + filename,
  1046. }, function (err, data) {
  1047. assert.ok(!err);
  1048. assert.ok(data.ETag.length > 0);
  1049. done();
  1050. });
  1051. });
  1052. test('捕获 object 异常', function (done, assert) {
  1053. var errFileName = '12345.txt';
  1054. cos.putObjectCopy({
  1055. Bucket: config.Bucket,
  1056. Region: config.Region,
  1057. Key: '1.copy.txt',
  1058. CopySource: config.Bucket + '.cos.' + config.Region + '.myqcloud.com/' + errFileName,
  1059. }, function (err, data) {
  1060. assert.equal(true, err.statusCode === 404);
  1061. assert.equal(true, err.error.Code === 'NoSuchKey')
  1062. done();
  1063. });
  1064. });
  1065. });
  1066. group('sliceCopyFile()', function () {
  1067. var filename = 'bigger.zip';
  1068. var Key = 'bigger.copy.zip';
  1069. test('正常分片复制 object', function (done, assert) {
  1070. prepareBigObject(true).then(function () {
  1071. cos.headObject({
  1072. Bucket: config.Bucket,
  1073. Region: config.Region,
  1074. Key: filename,
  1075. }, function (err, data1) {
  1076. if (err) throw err;
  1077. cos.sliceCopyFile({
  1078. Bucket: config.Bucket,
  1079. Region: config.Region,
  1080. Key: Key,
  1081. CopySource: config.Bucket + '.cos.' + config.Region + '.myqcloud.com/'+ filename,
  1082. CopySliceSize: 5 * 1024 * 1024,
  1083. },function (err, data) {
  1084. if (err) throw err;
  1085. assert.ok(data.ETag.length > 0);
  1086. cos.headObject({
  1087. Bucket: config.Bucket,
  1088. Region: config.Region,
  1089. Key: Key,
  1090. }, function (err, data2) {
  1091. if (err) throw err;
  1092. delete data1.VersionId;
  1093. delete data2.VersionId;
  1094. delete data1.headers['x-cos-request-id'];
  1095. delete data2.headers['x-cos-request-id'];
  1096. delete data1.headers['x-cos-version-id'];
  1097. delete data2.headers['x-cos-version-id'];
  1098. delete data1.headers['x-cos-replication-status'];
  1099. delete data2.headers['x-cos-replication-status'];
  1100. delete data1.headers['last-modified'];
  1101. delete data2.headers['last-modified'];
  1102. delete data1.headers['date'];
  1103. delete data2.headers['date'];
  1104. delete data1.headers['etag'];
  1105. delete data2.headers['etag'];
  1106. delete data1.ETag;
  1107. delete data2.ETag;
  1108. delete data1.RequestId;
  1109. delete data2.RequestId;
  1110. assert.ok(comparePlainObject(data1, data2));
  1111. done();
  1112. });
  1113. });
  1114. });
  1115. }).catch(function () {
  1116. assert.ok(false);
  1117. done();
  1118. });
  1119. });
  1120. test('单片复制 object', function (done, assert) {
  1121. setTimeout(function () {
  1122. prepareBigObject(true).then(function () {
  1123. cos.headObject({
  1124. Bucket: config.Bucket,
  1125. Region: config.Region,
  1126. Key: filename,
  1127. }, function (err, data1) {
  1128. if (err) throw err;
  1129. cos.sliceCopyFile({
  1130. Bucket: config.Bucket,
  1131. Region: config.Region,
  1132. Key: Key,
  1133. CopySource: config.Bucket + '.cos.' + config.Region + '.myqcloud.com/' + filename,
  1134. SliceSize: 10 * 1024 * 1024,
  1135. }, function (err, data) {
  1136. if (err) throw err;
  1137. assert.ok(data.ETag.length > 0);
  1138. setTimeout(function () {
  1139. cos.headObject({
  1140. Bucket: config.Bucket,
  1141. Region: config.Region,
  1142. Key: Key,
  1143. }, function (err, data2) {
  1144. if (err) throw err;
  1145. delete data1.VersionId;
  1146. delete data2.VersionId;
  1147. delete data1.headers['x-cos-request-id'];
  1148. delete data2.headers['x-cos-request-id'];
  1149. delete data1.headers['x-cos-version-id'];
  1150. delete data2.headers['x-cos-version-id'];
  1151. delete data1.headers['x-cos-replication-status'];
  1152. delete data2.headers['x-cos-replication-status'];
  1153. delete data1.headers['last-modified'];
  1154. delete data2.headers['last-modified'];
  1155. delete data1.headers['date'];
  1156. delete data2.headers['date'];
  1157. delete data1.ETag;
  1158. delete data2.ETag;
  1159. delete data1.RequestId;
  1160. delete data2.RequestId;
  1161. assert.ok(comparePlainObject(data1, data2));
  1162. done();
  1163. });
  1164. }, 2000);
  1165. });
  1166. });
  1167. }).catch(function () {
  1168. assert.ok(false);
  1169. done();
  1170. });
  1171. }, 2000);
  1172. });
  1173. test('CopySource nor found', function (done, assert) {
  1174. cos.sliceCopyFile({
  1175. Bucket: config.Bucket,
  1176. Region: config.Region,
  1177. Key: Key,
  1178. CopySource: config.Bucket + '.cos.' + config.Region + '.myqcloud.com/' + Date.now(),
  1179. }, function (err, data) {
  1180. assert.ok(err);
  1181. done();
  1182. });
  1183. });
  1184. test('复制归档文件', function (done, assert) {
  1185. var sourceKey = Date.now().toString(36);
  1186. cos.putObject({
  1187. Bucket: config.Bucket,
  1188. Region: config.Region,
  1189. Key: sourceKey,
  1190. StorageClass: 'ARCHIVE',
  1191. }, function () {
  1192. cos.sliceCopyFile({
  1193. Bucket: config.Bucket,
  1194. Region: config.Region,
  1195. Key: Key,
  1196. CopySource: config.Bucket + '.cos.' + config.Region + '.myqcloud.com/' + sourceKey,
  1197. }, function (err, data) {
  1198. assert.ok(err);
  1199. done();
  1200. });
  1201. });
  1202. });
  1203. });
  1204. group('deleteMultipleObject', function () {
  1205. test('deleteMultipleObject()', function (done, assert) {
  1206. var content = Date.now().toString(36);
  1207. cos.putObject({
  1208. Bucket: config.Bucket,
  1209. Region: config.Region,
  1210. Key: '1.txt',
  1211. Body: content,
  1212. }, function (err, data) {
  1213. cos.putObject({
  1214. Bucket: config.Bucket,
  1215. Region: config.Region,
  1216. Key: '2.txt',
  1217. Body: content,
  1218. }, function (err, data) {
  1219. cos.deleteMultipleObject({
  1220. Bucket: config.Bucket,
  1221. Region: config.Region,
  1222. Objects: [
  1223. {Key: '1.txt'},
  1224. {Key: '2.txt'},
  1225. ],
  1226. }, function (err, data) {
  1227. assert.ok(data.Deleted.length === 2);
  1228. cos.headObject({
  1229. Bucket: config.Bucket,
  1230. Region: config.Region,
  1231. Key: '1.txt',
  1232. }, function (err, data) {
  1233. assert.ok(err.statusCode === 404, '1.txt 删除成功');
  1234. cos.headObject({
  1235. Bucket: config.Bucket,
  1236. Region: config.Region,
  1237. Key: '2.txt',
  1238. }, function (err, data) {
  1239. assert.ok(err.statusCode === 404, '2.txt 删除成功');
  1240. done();
  1241. });
  1242. });
  1243. });
  1244. });
  1245. });
  1246. });
  1247. });
  1248. group('BucketAcl', function () {
  1249. var AccessControlPolicy = {
  1250. "Owner": {
  1251. "ID": 'qcs::cam::uin/10001:uin/10001' // 10001 是 QQ 号
  1252. },
  1253. "Grants": [{
  1254. "Grantee": {
  1255. "ID": "qcs::cam::uin/10002:uin/10002", // 10002 是 QQ 号
  1256. },
  1257. "Permission": "READ"
  1258. }]
  1259. };
  1260. var AccessControlPolicy2 = {
  1261. "Owner": {
  1262. "ID": 'qcs::cam::uin/10001:uin/10001' // 10001 是 QQ 号
  1263. },
  1264. "Grant": {
  1265. "Grantee": {
  1266. "ID": "qcs::cam::uin/10002:uin/10002", // 10002 是 QQ 号
  1267. },
  1268. "Permission": "READ"
  1269. }
  1270. };
  1271. test('putBucketAcl() header ACL:private', function (done, assert) {
  1272. cos.putBucketAcl({
  1273. Bucket: config.Bucket,
  1274. Region: config.Region,
  1275. ACL: 'private'
  1276. }, function (err, data) {
  1277. assert.ok(!err, 'putBucketAcl 成功');
  1278. cos.getBucketAcl({
  1279. Bucket: config.Bucket,
  1280. Region: config.Region
  1281. }, function (err, data) {
  1282. AccessControlPolicy.Owner.ID = data.Owner.ID;
  1283. AccessControlPolicy2.Owner.ID = data.Owner.ID;
  1284. assert.ok(data.ACL === 'private' || data.ACL === 'default');
  1285. done();
  1286. });
  1287. });
  1288. });
  1289. test('putBucketAcl() header ACL:public-read', function (done, assert) {
  1290. cos.putBucketAcl({
  1291. Bucket: config.Bucket,
  1292. Region: config.Region,
  1293. ACL: 'public-read',
  1294. }, function (err, data) {
  1295. assert.ok(!err, 'putBucketAcl 成功');
  1296. cos.getBucketAcl({Bucket: config.Bucket, Region: config.Region}, function (err, data) {
  1297. assert.ok(data.ACL === 'public-read');
  1298. done();
  1299. });
  1300. });
  1301. });
  1302. test('putBucketAcl() header ACL:public-read-write', function (done, assert) {
  1303. cos.putBucketAcl({
  1304. Bucket: config.Bucket,
  1305. Region: config.Region,
  1306. ACL: 'public-read-write',
  1307. }, function (err, data) {
  1308. assert.ok(!err, 'putBucketAcl 成功');
  1309. cos.getBucketAcl({Bucket: config.Bucket, Region: config.Region}, function (err, data) {
  1310. assert.ok(data.ACL === 'public-read-write');
  1311. done();
  1312. });
  1313. });
  1314. });
  1315. test('putBucketAcl() header GrantRead:1001,1002', function (done, assert) {
  1316. var GrantRead = 'id="qcs::cam::uin/1001:uin/1001", id="qcs::cam::uin/1002:uin/1002"';
  1317. cos.putBucketAcl({
  1318. Bucket: config.Bucket,
  1319. Region: config.Region,
  1320. GrantRead: GrantRead,
  1321. }, function (err, data) {
  1322. assert.ok(!err, 'putBucketAcl 成功');
  1323. cos.getBucketAcl({Bucket: config.Bucket, Region: config.Region}, function (err, data) {
  1324. assert.ok(data.GrantRead = GrantRead);
  1325. done();
  1326. });
  1327. });
  1328. });
  1329. test('putBucketAcl() header GrantWrite:1001,1002', function (done, assert) {
  1330. var GrantWrite = 'id="qcs::cam::uin/1001:uin/1001", id="qcs::cam::uin/1002:uin/1002"';
  1331. cos.putBucketAcl({
  1332. Bucket: config.Bucket,
  1333. Region: config.Region,
  1334. GrantWrite: GrantWrite,
  1335. }, function (err, data) {
  1336. assert.ok(!err, 'putBucketAcl 成功');
  1337. cos.getBucketAcl({Bucket: config.Bucket, Region: config.Region}, function (err, data) {
  1338. assert.ok(data.GrantWrite = GrantWrite);
  1339. done();
  1340. });
  1341. });
  1342. });
  1343. test('putBucketAcl() header GrantFullControl:1001,1002', function (done, assert) {
  1344. var GrantFullControl = 'id="qcs::cam::uin/1001:uin/1001", id="qcs::cam::uin/1002:uin/1002"';
  1345. cos.putBucketAcl({
  1346. Bucket: config.Bucket,
  1347. Region: config.Region,
  1348. GrantFullControl: GrantFullControl,
  1349. }, function (err, data) {
  1350. assert.ok(!err, 'putBucketAcl 成功');
  1351. cos.getBucketAcl({Bucket: config.Bucket, Region: config.Region}, function (err, data) {
  1352. assert.ok(data.GrantFullControl = GrantFullControl);
  1353. done();
  1354. });
  1355. });
  1356. });
  1357. test('putBucketAcl() header ACL:public-read, GrantFullControl:1001,1002', function (done, assert) {
  1358. var GrantFullControl = 'id="qcs::cam::uin/1001:uin/1001", id="qcs::cam::uin/1002:uin/1002"';
  1359. cos.putBucketAcl({
  1360. Bucket: config.Bucket,
  1361. Region: config.Region,
  1362. GrantFullControl: GrantFullControl,
  1363. ACL: 'public-read',
  1364. }, function (err, data) {
  1365. assert.ok(!err, 'putBucketAcl 成功');
  1366. cos.getBucketAcl({Bucket: config.Bucket, Region: config.Region}, function (err, data) {
  1367. assert.ok(data.GrantFullControl = GrantFullControl);
  1368. assert.ok(data.ACL === 'public-read');
  1369. done();
  1370. });
  1371. });
  1372. });
  1373. test('putBucketAcl() xml', function (done, assert) {
  1374. cos.putBucketAcl({
  1375. Bucket: config.Bucket,
  1376. Region: config.Region,
  1377. AccessControlPolicy: AccessControlPolicy
  1378. }, function (err, data) {
  1379. assert.ok(!err, 'putBucketAcl 成功');
  1380. cos.getBucketAcl({Bucket: config.Bucket, Region: config.Region}, function (err, data) {
  1381. assert.ok(data.Grants.length === 1);
  1382. assert.ok(data.Grants[0] && data.Grants[0].Grantee.ID === 'qcs::cam::uin/10002:uin/10002', '设置 AccessControlPolicy ID 正确');
  1383. assert.ok(data.Grants[0] && data.Grants[0].Permission === 'READ', '设置 AccessControlPolicy Permission 正确');
  1384. done();
  1385. });
  1386. });
  1387. });
  1388. test('putBucketAcl() xml2', function (done, assert) {
  1389. cos.putBucketAcl({
  1390. Bucket: config.Bucket,
  1391. Region: config.Region,
  1392. AccessControlPolicy: AccessControlPolicy2,
  1393. }, function (err, data) {
  1394. assert.ok(!err, 'putBucketAcl 成功');
  1395. cos.getBucketAcl({Bucket: config.Bucket, Region: config.Region}, function (err, data) {
  1396. assert.ok(data.Grants.length === 1);
  1397. assert.ok(data.Grants[0] && data.Grants[0].Grantee.ID === 'qcs::cam::uin/10002:uin/10002');
  1398. assert.ok(data.Grants[0] && data.Grants[0].Permission === 'READ');
  1399. done();
  1400. });
  1401. });
  1402. });
  1403. test('putBucketAcl() decodeAcl', function (done, assert) {
  1404. cos.getBucketAcl({
  1405. Bucket: config.Bucket,
  1406. Region: config.Region
  1407. }, function (err, data) {
  1408. cos.putBucketAcl({
  1409. Bucket: config.Bucket,
  1410. Region: config.Region,
  1411. GrantFullControl: data.GrantFullControl,
  1412. GrantWrite: data.GrantWrite,
  1413. GrantRead: data.GrantRead,
  1414. ACL: data.ACL,
  1415. }, function (err, data) {
  1416. assert.ok(data);
  1417. done();
  1418. });
  1419. });
  1420. });
  1421. });
  1422. group('ObjectAcl', function () {
  1423. var AccessControlPolicy = {
  1424. "Owner": {
  1425. "ID": 'qcs::cam::uin/10001:uin/10001' // 10001 是 QQ 号
  1426. },
  1427. "Grants": [{
  1428. "Grantee": {
  1429. "ID": "qcs::cam::uin/10002:uin/10002", // 10002 是 QQ 号
  1430. },
  1431. "Permission": "READ"
  1432. }]
  1433. };
  1434. var AccessControlPolicy2 = {
  1435. "Owner": {
  1436. "ID": 'qcs::cam::uin/10001:uin/10001' // 10001 是 QQ 号
  1437. },
  1438. "Grant": {
  1439. "Grantee": {
  1440. "ID": "qcs::cam::uin/10002:uin/10002", // 10002 是 QQ 号
  1441. },
  1442. "Permission": "READ"
  1443. }
  1444. };
  1445. test('putObjectAcl() header ACL:private', function (done, assert) {
  1446. cos.putObject({
  1447. Bucket: config.Bucket,
  1448. Region: config.Region,
  1449. Key: '1.txt',
  1450. Body: 'hello!',
  1451. }, function (err, data) {
  1452. assert.ok(!err);
  1453. cos.putObjectAcl({
  1454. Bucket: config.Bucket,
  1455. Region: config.Region,
  1456. ACL: 'private',
  1457. Key: '1.txt',
  1458. }, function (err, data) {
  1459. assert.ok(!err, 'putObjectAcl 成功');
  1460. cos.getObjectAcl({
  1461. Bucket: config.Bucket,
  1462. Region: config.Region,
  1463. Key: '1.txt'
  1464. }, function (err, data) {
  1465. assert.ok(data.ACL = 'private');
  1466. AccessControlPolicy.Owner.ID = data.Owner.ID;
  1467. AccessControlPolicy2.Owner.ID = data.Owner.ID;
  1468. assert.ok(data.Grants.length === 1);
  1469. done();
  1470. });
  1471. });
  1472. });
  1473. });
  1474. test('putObjectAcl() header ACL:default', function (done, assert) {
  1475. cos.putObjectAcl({
  1476. Bucket: config.Bucket,
  1477. Region: config.Region,
  1478. ACL: 'default',
  1479. Key: '1.txt',
  1480. }, function (err, data) {
  1481. assert.ok(!err, 'putObjectAcl 成功');
  1482. cos.getObjectAcl({
  1483. Bucket: config.Bucket,
  1484. Region: config.Region,
  1485. Key: '1.txt'
  1486. }, function (err, data) {
  1487. assert.ok(data.ACL = 'default');
  1488. done();
  1489. });
  1490. });
  1491. });
  1492. test('putObjectAcl() header ACL:public-read', function (done, assert) {
  1493. cos.putObjectAcl({
  1494. Bucket: config.Bucket,
  1495. Region: config.Region,
  1496. ACL: 'public-read',
  1497. Key: '1.txt',
  1498. }, function (err, data) {
  1499. assert.ok(!err, 'putObjectAcl 成功');
  1500. cos.getObjectAcl({Bucket: config.Bucket, Region: config.Region, Key: '1.txt'}, function (err, data) {
  1501. assert.ok(data.ACL = 'public-read');
  1502. done();
  1503. });
  1504. });
  1505. });
  1506. // Object 不再支持修改写权限
  1507. // test('putObjectAcl() header ACL:public-read-write', function (done, assert) {
  1508. // cos.putObjectAcl({
  1509. // Bucket: config.Bucket,
  1510. // Region: config.Region,
  1511. // ACL: 'public-read-write',
  1512. // Key: '1.txt',
  1513. // }, function (err, data) {
  1514. // assert.ok(!err, 'putObjectAcl 成功');
  1515. // cos.getObjectAcl({Bucket: config.Bucket, Region: config.Region, Key: '1.txt'}, function (err, data) {
  1516. // assert.ok(data.ACL = 'public-read-write');
  1517. // done();
  1518. // });
  1519. // });
  1520. // });
  1521. test('putObjectAcl() header GrantRead:1001,1002', function (done, assert) {
  1522. var GrantRead = 'id="qcs::cam::uin/1001:uin/1001",id="qcs::cam::uin/1002:uin/1002"';
  1523. cos.putObjectAcl({
  1524. Bucket: config.Bucket,
  1525. Region: config.Region,
  1526. GrantRead: GrantRead,
  1527. Key: '1.txt',
  1528. }, function (err, data) {
  1529. assert.ok(!err, 'putObjectAcl 成功');
  1530. cos.getObjectAcl({Bucket: config.Bucket, Region: config.Region, Key: '1.txt'}, function (err, data) {
  1531. assert.ok(data.GrantRead = GrantRead);
  1532. done();
  1533. });
  1534. });
  1535. });
  1536. // Object 不再支持修改写权限
  1537. // test('putObjectAcl() header GrantWrite:1001,1002', function (done, assert) {
  1538. // var GrantWrite = 'id="qcs::cam::uin/1001:uin/1001", id="qcs::cam::uin/1002:uin/1002"';
  1539. // cos.putObjectAcl({
  1540. // Bucket: config.Bucket,
  1541. // Region: config.Region,
  1542. // GrantWrite: GrantWrite,
  1543. // Key: '1.txt',
  1544. // }, function (err, data) {
  1545. // assert.ok(!err, 'putObjectAcl 成功');
  1546. // cos.getObjectAcl({Bucket: config.Bucket, Region: config.Region, Key: '1.txt'}, function (err, data) {
  1547. // assert.ok(data.GrantWrite = GrantWrite);
  1548. // done();
  1549. // });
  1550. // });
  1551. // });
  1552. test('putObjectAcl() header GrantFullControl:1001,1002', function (done, assert) {
  1553. var GrantFullControl = 'id="qcs::cam::uin/1001:uin/1001", id="qcs::cam::uin/1002:uin/1002"';
  1554. cos.putObjectAcl({
  1555. Bucket: config.Bucket,
  1556. Region: config.Region,
  1557. GrantFullControl: GrantFullControl,
  1558. Key: '1.txt',
  1559. }, function (err, data) {
  1560. assert.ok(!err, 'putObjectAcl 成功');
  1561. cos.getObjectAcl({Bucket: config.Bucket, Region: config.Region, Key: '1.txt'}, function (err, data) {
  1562. assert.ok(data.GrantFullControl = GrantFullControl);
  1563. done();
  1564. });
  1565. });
  1566. });
  1567. test('putObjectAcl() header ACL:public-read, GrantRead:1001,1002', function (done, assert) {
  1568. var GrantFullControl = 'id="qcs::cam::uin/1001:uin/1001", id="qcs::cam::uin/1002:uin/1002"';
  1569. cos.putObjectAcl({
  1570. Bucket: config.Bucket,
  1571. Region: config.Region,
  1572. GrantFullControl: GrantFullControl,
  1573. ACL: 'public-read',
  1574. Key: '1.txt',
  1575. }, function (err, data) {
  1576. assert.ok(!err, 'putObjectAcl 成功');
  1577. cos.getObjectAcl({Bucket: config.Bucket, Region: config.Region, Key: '1.txt'}, function (err, data) {
  1578. assert.ok(data.GrantFullControl = GrantFullControl);
  1579. assert.ok(data.ACL = 'public-read');
  1580. done();
  1581. });
  1582. });
  1583. });
  1584. test('putObjectAcl() xml', function (done, assert) {
  1585. cos.putObjectAcl({
  1586. Bucket: config.Bucket,
  1587. Region: config.Region,
  1588. AccessControlPolicy: AccessControlPolicy,
  1589. Key: '1.txt',
  1590. }, function (err, data) {
  1591. assert.ok(!err, 'putObjectAcl 成功');
  1592. cos.getBucketAcl({Bucket: config.Bucket, Region: config.Region, Key: '1.txt'}, function (err, data) {
  1593. assert.ok(data.Grants.length === 1);
  1594. assert.ok(data.Grants[0] && data.Grants[0].Grantee.ID === 'qcs::cam::uin/10002:uin/10002', '设置 AccessControlPolicy ID 正确');
  1595. assert.ok(data.Grants[0] && data.Grants[0].Permission === 'READ', '设置 AccessControlPolicy Permission 正确');
  1596. done();
  1597. });
  1598. });
  1599. });
  1600. test('putObjectAcl() xml2', function (done, assert) {
  1601. cos.putObjectAcl({
  1602. Bucket: config.Bucket,
  1603. Region: config.Region,
  1604. AccessControlPolicy: AccessControlPolicy2,
  1605. Key: '1.txt',
  1606. }, function (err, data) {
  1607. assert.ok(!err, 'putObjectAcl 成功');
  1608. cos.getObjectAcl({
  1609. Bucket: config.Bucket,
  1610. Region: config.Region,
  1611. Key: '1.txt'
  1612. }, function (err, data) {
  1613. assert.ok(data.Grants.length === 1);
  1614. assert.ok(data.Grants[0] && data.Grants[0].Grantee.ID === 'qcs::cam::uin/10002:uin/10002', 'ID 正确');
  1615. assert.ok(data.Grants[0] && data.Grants[0].Permission === 'READ', 'Permission 正确');
  1616. done();
  1617. });
  1618. });
  1619. });
  1620. test('putObjectAcl() decodeAcl', function (done, assert) {
  1621. cos.getObjectAcl({
  1622. Bucket: config.Bucket,
  1623. Region: config.Region,
  1624. Key: '1.txt'
  1625. }, function (err, data) {
  1626. cos.putObjectAcl({
  1627. Bucket: config.Bucket,
  1628. Region: config.Region,
  1629. Key: '1.txt',
  1630. GrantFullControl: data.GrantFullControl,
  1631. GrantWrite: data.GrantWrite,
  1632. GrantRead: data.GrantRead,
  1633. ACL: data.ACL,
  1634. }, function (err, data) {
  1635. assert.ok(data);
  1636. done();
  1637. });
  1638. });
  1639. });
  1640. });
  1641. group('BucketCors', function () {
  1642. var CORSRules = [{
  1643. "AllowedOrigins": ["*"],
  1644. "AllowedMethods": ["GET", "POST", "PUT", "DELETE", "HEAD"],
  1645. "AllowedHeaders": ["*", 'test-' + Date.now().toString(36)],
  1646. "ExposeHeaders": [
  1647. 'etag',
  1648. 'date',
  1649. 'content-length',
  1650. 'expires',
  1651. 'cache-control',
  1652. 'content-disposition',
  1653. 'content-encoding',
  1654. 'x-cos-acl',
  1655. 'x-cos-version-id',
  1656. 'x-cos-request-id',
  1657. 'x-cos-delete-marker',
  1658. 'x-cos-server-side-encryption',
  1659. 'x-cos-storage-class',
  1660. 'x-cos-acl',
  1661. 'x-cos-meta-test',
  1662. 'x-cos-tagging-count',
  1663. ],
  1664. "MaxAgeSeconds": "5"
  1665. }];
  1666. var CORSRulesMulti = [{
  1667. "AllowedOrigins": ["*"],
  1668. "AllowedMethods": ["GET", "POST", "PUT", "DELETE", "HEAD"],
  1669. "AllowedHeaders": ["*"],
  1670. "ExposeHeaders": ["ETag", "Date", "Content-Length", "x-cos-acl", "x-cos-version-id", "x-cos-request-id", "x-cos-delete-marker", "x-cos-server-side-encryption"],
  1671. "MaxAgeSeconds": "5"
  1672. }, {
  1673. "AllowedOrigins": ["http://qq.com", "http://qcloud.com"],
  1674. "AllowedMethods": ["GET", "POST", "PUT", "DELETE", "HEAD"],
  1675. "AllowedHeaders": ["*"],
  1676. "ExposeHeaders": ["ETag", "Date", "Content-Length", "x-cos-acl", "x-cos-version-id", "x-cos-request-id", "x-cos-delete-marker", "x-cos-server-side-encryption"],
  1677. "MaxAgeSeconds": "5"
  1678. }];
  1679. test('putBucketCors() old CORSConfiguration', function (done, assert) {
  1680. CORSRules[0].AllowedHeaders[1] = 'test-' + Date.now().toString(36);
  1681. cos.putBucketCors({
  1682. Bucket: config.Bucket,
  1683. Region: config.Region,
  1684. CORSConfiguration: {
  1685. CORSRules: CORSRules
  1686. }
  1687. }, function (err, data) {
  1688. assert.ok(!err);
  1689. setTimeout(function () {
  1690. cos.getBucketCors({
  1691. Bucket: config.Bucket,
  1692. Region: config.Region
  1693. }, function (err, data) {
  1694. assert.ok(comparePlainObject(CORSRules, data.CORSRules));
  1695. done();
  1696. });
  1697. }, 2000);
  1698. });
  1699. });
  1700. test('putBucketCors() multi', function (done, assert) {
  1701. cos.putBucketCors({
  1702. Bucket: config.Bucket,
  1703. Region: config.Region,
  1704. CORSConfiguration: {
  1705. CORSRules: CORSRulesMulti
  1706. }
  1707. }, function (err, data) {
  1708. assert.ok(!err);
  1709. setTimeout(function () {
  1710. cos.getBucketCors({
  1711. Bucket: config.Bucket,
  1712. Region: config.Region
  1713. }, function (err, data) {
  1714. assert.ok(comparePlainObject(CORSRulesMulti, data.CORSRules));
  1715. done();
  1716. });
  1717. }, 2000);
  1718. });
  1719. });
  1720. test('putBucketCors() old CORSRules', function (done, assert) {
  1721. CORSRules[0].AllowedHeaders[1] = 'test-' + Date.now().toString(36);
  1722. cos.putBucketCors({
  1723. Bucket: config.Bucket,
  1724. Region: config.Region,
  1725. CORSRules: CORSRules
  1726. }, function (err, data) {
  1727. assert.ok(!err);
  1728. setTimeout(function () {
  1729. cos.getBucketCors({
  1730. Bucket: config.Bucket,
  1731. Region: config.Region
  1732. }, function (err, data) {
  1733. assert.ok(comparePlainObject(CORSRules, data.CORSRules));
  1734. done();
  1735. });
  1736. }, 2000);
  1737. });
  1738. });
  1739. test('putBucketCors(),getBucketCors()', function (done, assert) {
  1740. CORSRules[0].AllowedHeaders = ['*'];
  1741. cos.putBucketCors({
  1742. Bucket: config.Bucket,
  1743. Region: config.Region,
  1744. CORSConfiguration: {
  1745. CORSRules: CORSRules
  1746. }
  1747. }, function (err, data) {
  1748. assert.ok(!err);
  1749. setTimeout(function () {
  1750. cos.getBucketCors({
  1751. Bucket: config.Bucket,
  1752. Region: config.Region
  1753. }, function (err, data) {
  1754. assert.ok(comparePlainObject(CORSRules, data.CORSRules));
  1755. done();
  1756. });
  1757. }, 2000);
  1758. });
  1759. });
  1760. });
  1761. group('BucketTagging', function () {
  1762. var Tags = [
  1763. {Key: "k1", Value: "v1"}
  1764. ];
  1765. var TagsMulti = [
  1766. {Key: "k1", Value: "v1"},
  1767. {Key: "k2", Value: "v2"},
  1768. ];
  1769. test('putBucketTagging(),getBucketTagging()', function (done, assert) {
  1770. Tags[0].Value = Date.now().toString(36);
  1771. cos.putBucketTagging({
  1772. Bucket: config.Bucket,
  1773. Region: config.Region,
  1774. Tagging: {
  1775. Tags: Tags
  1776. }
  1777. }, function (err, data) {
  1778. assert.ok(!err);
  1779. setTimeout(function () {
  1780. cos.getBucketTagging({
  1781. Bucket: config.Bucket,
  1782. Region: config.Region
  1783. }, function (err, data) {
  1784. assert.ok(comparePlainObject(Tags, data.Tags));
  1785. done();
  1786. });
  1787. }, 1000);
  1788. });
  1789. });
  1790. test('deleteBucketTagging()', function (done, assert) {
  1791. cos.deleteBucketTagging({
  1792. Bucket: config.Bucket,
  1793. Region: config.Region
  1794. }, function (err, data) {
  1795. assert.ok(!err);
  1796. setTimeout(function () {
  1797. cos.getBucketTagging({
  1798. Bucket: config.Bucket,
  1799. Region: config.Region
  1800. }, function (err, data) {
  1801. assert.ok(comparePlainObject([], data.Tags));
  1802. done();
  1803. });
  1804. }, 1000);
  1805. });
  1806. });
  1807. test('putBucketTagging() multi', function (done, assert) {
  1808. Tags[0].Value = Date.now().toString(36);
  1809. cos.putBucketTagging({
  1810. Bucket: config.Bucket,
  1811. Region: config.Region,
  1812. Tagging: {
  1813. Tags: TagsMulti
  1814. }
  1815. }, function (err, data) {
  1816. assert.ok(!err);
  1817. setTimeout(function () {
  1818. cos.getBucketTagging({
  1819. Bucket: config.Bucket,
  1820. Region: config.Region
  1821. }, function (err, data) {
  1822. assert.ok(comparePlainObject(TagsMulti, data.Tags));
  1823. done();
  1824. });
  1825. }, 1000);
  1826. });
  1827. });
  1828. });
  1829. group('BucketPolicy', function () {
  1830. var Prefix = Date.now().toString(36);
  1831. var Policy = {
  1832. "version": "2.0",
  1833. "principal": {"qcs": ["qcs::cam::uin/10001:uin/10001"]}, // 这里的 10001 是 QQ 号
  1834. "statement": [{
  1835. "effect": "allow",
  1836. "action": [
  1837. "name/cos:GetBucket",
  1838. "name/cos:PutObject",
  1839. "name/cos:PostObject",
  1840. "name/cos:PutObjectCopy",
  1841. "name/cos:InitiateMultipartUpload",
  1842. "name/cos:UploadPart",
  1843. "name/cos:UploadPartCopy",
  1844. "name/cos:CompleteMultipartUpload",
  1845. "name/cos:AbortMultipartUpload",
  1846. "name/cos:AppendObject"
  1847. ],
  1848. "resource": ["qcs::cos:" + config.Region + ":uid/" + AppId + ":" + BucketLongName + "//" + AppId + "/" + BucketShortName + "/" + Prefix + "/*"] // 1250000000 是 appid
  1849. }]
  1850. };
  1851. var getRes = function (s) {
  1852. var t = s && s[0];
  1853. var res = t && t.resource && t.resource[0];
  1854. return res;
  1855. };
  1856. test('putBucketPolicy(),getBucketPolicy()', function (done, assert) {
  1857. cos.putBucketPolicy({
  1858. Bucket: config.Bucket,
  1859. Region: config.Region,
  1860. Policy: Policy
  1861. }, function (err, data) {
  1862. assert.ok(!err);
  1863. cos.getBucketPolicy({
  1864. Bucket: config.Bucket,
  1865. Region: config.Region
  1866. }, function (err, data) {
  1867. assert.ok(getRes(Policy.statement) === getRes(data.Policy.Statement));
  1868. done();
  1869. });
  1870. });
  1871. });
  1872. test('putBucketPolicy() s3', function (done, assert) {
  1873. cos.putBucketPolicy({
  1874. Bucket: config.Bucket,
  1875. Region: config.Region,
  1876. Policy: JSON.stringify(Policy)
  1877. }, function (err, data) {
  1878. assert.ok(!err);
  1879. cos.getBucketPolicy({
  1880. Bucket: config.Bucket,
  1881. Region: config.Region
  1882. }, function (err, data) {
  1883. assert.ok(getRes(Policy.statement) === getRes(data.Policy.Statement));
  1884. done();
  1885. });
  1886. });
  1887. });
  1888. test('deleteBucketPolicy()', function (done, assert) {
  1889. cos.deleteBucketPolicy({
  1890. Bucket: config.Bucket,
  1891. Region: config.Region,
  1892. Policy: JSON.stringify(Policy)
  1893. }, function (err, data) {
  1894. assert.ok(!err);
  1895. cos.getBucketPolicy({
  1896. Bucket: config.Bucket,
  1897. Region: config.Region
  1898. }, function (err, data) {
  1899. assert.ok(err.ErrorStatus === 'Policy Not Found');
  1900. done();
  1901. });
  1902. });
  1903. });
  1904. });
  1905. group('BucketLocation', function () {
  1906. test('getBucketLocation()', function (done, assert) {
  1907. cos.getBucketLocation({
  1908. Bucket: config.Bucket,
  1909. Region: config.Region
  1910. }, function (err, data) {
  1911. var map1 = {
  1912. 'tianjin': 'ap-beijing-1',
  1913. 'cn-south-2': 'ap-guangzhou-2',
  1914. 'cn-south': 'ap-guangzhou',
  1915. 'cn-east': 'ap-shanghai',
  1916. 'cn-southwest': 'ap-chengdu',
  1917. };
  1918. var map2 = {
  1919. 'ap-beijing-1': 'tianjin',
  1920. 'ap-guangzhou-2': 'cn-south-2',
  1921. 'ap-guangzhou': 'cn-south',
  1922. 'ap-shanghai': 'cn-east',
  1923. 'ap-chengdu': 'cn-southwest',
  1924. };
  1925. assert.ok(data.LocationConstraint === config.Region || data.LocationConstraint === map1[config.Region] ||
  1926. data.LocationConstraint === map2[config.Region]);
  1927. done();
  1928. });
  1929. });
  1930. });
  1931. group('BucketLifecycle', function () {
  1932. var Rules = [{
  1933. 'ID': '1',
  1934. 'Filter': {
  1935. 'Prefix': 'test_' + Date.now().toString(36),
  1936. },
  1937. 'Status': 'Enabled',
  1938. 'Transition': {
  1939. 'Date': '2018-07-29T16:00:00.000Z',
  1940. 'StorageClass': 'STANDARD_IA'
  1941. }
  1942. }];
  1943. var RulesMulti = [{
  1944. 'ID': '1',
  1945. 'Filter': {
  1946. 'Prefix': 'test1_' + Date.now().toString(36),
  1947. },
  1948. 'Status': 'Enabled',
  1949. 'Transition': {
  1950. 'Date': '2018-07-29T16:00:00.000Z',
  1951. 'StorageClass': 'STANDARD_IA'
  1952. }
  1953. }, {
  1954. 'ID': '2',
  1955. 'Filter': {
  1956. 'Prefix': 'test2_' + Date.now().toString(36),
  1957. },
  1958. 'Status': 'Enabled',
  1959. 'Transition': {
  1960. 'Date': '2018-07-29T16:00:00.000Z',
  1961. 'StorageClass': 'STANDARD_IA'
  1962. }
  1963. }];
  1964. test('deleteBucketLifecycle()', function (done, assert) {
  1965. cos.deleteBucketLifecycle({
  1966. Bucket: config.Bucket,
  1967. Region: config.Region
  1968. }, function (err, data) {
  1969. assert.ok(!err);
  1970. setTimeout(function () {
  1971. cos.getBucketLifecycle({
  1972. Bucket: config.Bucket,
  1973. Region: config.Region
  1974. }, function (err, data) {
  1975. assert.ok(comparePlainObject([], data.Rules));
  1976. done();
  1977. });
  1978. }, 2000);
  1979. });
  1980. });
  1981. test('putBucketLifecycle(),getBucketLifecycle()', function (done, assert) {
  1982. Rules[0].Filter.Prefix = 'test_' + Date.now().toString(36);
  1983. cos.putBucketLifecycle({
  1984. Bucket: config.Bucket,
  1985. Region: config.Region,
  1986. LifecycleConfiguration: {
  1987. Rules: Rules
  1988. }
  1989. }, function (err, data) {
  1990. assert.ok(!err);
  1991. setTimeout(function () {
  1992. cos.getBucketLifecycle({
  1993. Bucket: config.Bucket,
  1994. Region: config.Region
  1995. }, function (err, data) {
  1996. assert.ok(comparePlainObject(Rules, data && data.Rules));
  1997. done();
  1998. });
  1999. }, 2000);
  2000. });
  2001. });
  2002. test('putBucketLifecycle() multi', function (done, assert) {
  2003. Rules[0].Filter.Prefix = 'test_' + Date.now().toString(36);
  2004. cos.putBucketLifecycle({
  2005. Bucket: config.Bucket,
  2006. Region: config.Region,
  2007. LifecycleConfiguration: {
  2008. Rules: RulesMulti
  2009. }
  2010. }, function (err, data) {
  2011. assert.ok(!err);
  2012. setTimeout(function () {
  2013. cos.getBucketLifecycle({
  2014. Bucket: config.Bucket,
  2015. Region: config.Region
  2016. }, function (err, data) {
  2017. assert.ok(comparePlainObject(RulesMulti, data.Rules));
  2018. done();
  2019. });
  2020. }, 2000);
  2021. });
  2022. });
  2023. });
  2024. group('BucketWebsite', function () {
  2025. var RoutingRules = [{
  2026. Condition: {
  2027. HttpErrorCodeReturnedEquals: "404"
  2028. },
  2029. Redirect: {
  2030. Protocol: "https",
  2031. ReplaceKeyWith: "404.html"
  2032. }
  2033. }, {
  2034. Condition: {
  2035. KeyPrefixEquals: "docs/"
  2036. },
  2037. Redirect: {
  2038. Protocol: "https",
  2039. ReplaceKeyPrefixWith: "documents/"
  2040. }
  2041. }, {
  2042. Condition: {
  2043. KeyPrefixEquals: "img/"
  2044. },
  2045. Redirect: {
  2046. Protocol: "https",
  2047. ReplaceKeyWith: "picture.jpg"
  2048. }
  2049. }];
  2050. var WebsiteConfiguration = {
  2051. IndexDocument: {
  2052. Suffix: "index.html"
  2053. },
  2054. RedirectAllRequestsTo: {
  2055. Protocol: "https"
  2056. },
  2057. ErrorDocument: {
  2058. Key: "error.html"
  2059. },
  2060. };
  2061. test('putBucketWebsite(),getBucketWebsite()', function (done, assert) {
  2062. cos.putBucketWebsite({
  2063. Bucket: config.Bucket,
  2064. Region: config.Region,
  2065. WebsiteConfiguration: WebsiteConfiguration
  2066. }, function (err, data) {
  2067. assert.ok(!err);
  2068. setTimeout(function () {
  2069. cos.getBucketWebsite({
  2070. Bucket: config.Bucket,
  2071. Region: config.Region
  2072. }, function (err, data) {
  2073. assert.ok(comparePlainObject(WebsiteConfiguration, data.WebsiteConfiguration));
  2074. done();
  2075. });
  2076. }, 2000);
  2077. });
  2078. });
  2079. test('putBucketWebsite() multi RoutingRules', function (done, assert) {
  2080. WebsiteConfiguration.RoutingRules = RoutingRules;
  2081. cos.putBucketWebsite({
  2082. Bucket: config.Bucket,
  2083. Region: config.Region,
  2084. WebsiteConfiguration: WebsiteConfiguration
  2085. }, function (err, data) {
  2086. assert.ok(!err);
  2087. setTimeout(function () {
  2088. cos.getBucketWebsite({
  2089. Bucket: config.Bucket,
  2090. Region: config.Region
  2091. }, function (err, data) {
  2092. assert.ok(comparePlainObject(WebsiteConfiguration, data.WebsiteConfiguration));
  2093. done();
  2094. });
  2095. }, 2000);
  2096. });
  2097. });
  2098. test('deleteBucketWebsite()', function (done, assert) {
  2099. cos.deleteBucketWebsite({
  2100. Bucket: config.Bucket,
  2101. Region: config.Region
  2102. }, function (err, data) {
  2103. assert.ok(!err);
  2104. setTimeout(function () {
  2105. cos.getBucketWebsite({
  2106. Bucket: config.Bucket,
  2107. Region: config.Region
  2108. }, function (err, data) {
  2109. assert.ok(comparePlainObject({}, data.WebsiteConfiguration));
  2110. done();
  2111. });
  2112. }, 2000);
  2113. });
  2114. });
  2115. });
  2116. group('BucketDomain', function () {
  2117. var DomainRule = [{
  2118. Status: "DISABLED",
  2119. Name: "www.testDomain1.com",
  2120. Type: "REST"
  2121. },
  2122. {
  2123. Status: "DISABLED",
  2124. Name: "www.testDomain2.com",
  2125. Type: "WEBSITE"
  2126. }];
  2127. test('putBucketDomain(),getBucketDomain()', function (done, assert) {
  2128. cos.putBucketDomain({
  2129. Bucket: config.Bucket,
  2130. Region: config.Region,
  2131. DomainRule: DomainRule
  2132. }, function (err, data) {
  2133. assert.ok(!err);
  2134. setTimeout(function () {
  2135. cos.getBucketDomain({
  2136. Bucket: config.Bucket,
  2137. Region: config.Region
  2138. }, function (err, data) {
  2139. assert.ok(comparePlainObject(DomainRule, data.DomainRule));
  2140. done();
  2141. });
  2142. }, 2000);
  2143. });
  2144. });
  2145. // test('putBucketDomain() multi', function (done, assert) {
  2146. // cos.putBucketDomain({
  2147. // Bucket: config.Bucket,
  2148. // Region: config.Region,
  2149. // DomainRule: DomainRuleMulti
  2150. // }, function (err, data) {
  2151. // assert.ok(!err);
  2152. // setTimeout(function () {
  2153. // cos.getBucketDomain({
  2154. // Bucket: config.Bucket,
  2155. // Region: config.Region
  2156. // }, function (err, data) {
  2157. // assert.ok(comparePlainObject(DomainRuleMulti, data.DomainRule));
  2158. // done();
  2159. // });
  2160. // }, 2000);
  2161. // });
  2162. // });
  2163. test('deleteBucketDomain()', function (done, assert) {
  2164. cos.deleteBucketDomain({
  2165. Bucket: config.Bucket,
  2166. Region: config.Region
  2167. }, function (err, data) {
  2168. assert.ok(!err);
  2169. setTimeout(function () {
  2170. cos.getBucketDomain({
  2171. Bucket: config.Bucket,
  2172. Region: config.Region
  2173. }, function (err, data) {
  2174. assert.ok(comparePlainObject([], data.DomainRule));
  2175. done();
  2176. });
  2177. }, 2000);
  2178. });
  2179. });
  2180. });
  2181. group('params check Region', function () {
  2182. test('params check', function (done, assert) {
  2183. cos.headBucket({
  2184. Bucket: config.Bucket,
  2185. Region: 'cos.ap-guangzhou'
  2186. }, function (err, data) {
  2187. assert.ok(err.message === 'param Region should not be start with "cos."');
  2188. done();
  2189. });
  2190. });
  2191. test('params check Region', function (done, assert) {
  2192. cos.headBucket({
  2193. Bucket: config.Bucket,
  2194. Region: 'gz'
  2195. }, function (err, data) {
  2196. assert.ok(err);
  2197. done();
  2198. });
  2199. });
  2200. });
  2201. group('Key 特殊字符处理', function () {
  2202. test('Key 特殊字符处理', function (done, assert) {
  2203. var Key = '中文→↓←→↖↗↙↘! $&\'()+,-.0123456789=@ABCDEFGHIJKLMNOPQRSTUV?WXYZ[]^_`abcdefghijklmnopqrstuvwxyz{}~.jpg';
  2204. cos.putObject({
  2205. Bucket: config.Bucket,
  2206. Region: config.Region,
  2207. Key: Key,
  2208. Body: 'hello',
  2209. }, function (err, data) {
  2210. assert.ok(!err);
  2211. cos.deleteObject({
  2212. Bucket: config.Bucket,
  2213. Region: config.Region,
  2214. Key: Key,
  2215. Body: 'hello',
  2216. }, function (err, data) {
  2217. assert.ok(!err);
  2218. cos.deleteMultipleObject({
  2219. Bucket: config.Bucket,
  2220. Region: config.Region,
  2221. Objects: {
  2222. Key: Key,
  2223. },
  2224. }, function (err, data) {
  2225. assert.ok(!err);
  2226. done();
  2227. });
  2228. });
  2229. });
  2230. });
  2231. });
  2232. group('Bucket 格式有误', function () {
  2233. test('Bucket 带有中文', function (done, assert) {
  2234. cos.headBucket({
  2235. Bucket: '中文-1250000000',
  2236. Region: config.Region,
  2237. }, function (err, data) {
  2238. assert.ok(err && err.message === 'Bucket should format as "test-1250000000".');
  2239. done();
  2240. });
  2241. });
  2242. test('Bucket 带有 /', function (done, assert) {
  2243. cos.headBucket({
  2244. Bucket: 'te/st-1250000000',
  2245. Region: config.Region,
  2246. }, function (err, data) {
  2247. assert.ok(err && err.message === 'Bucket should format as "test-1250000000".');
  2248. done();
  2249. });
  2250. });
  2251. test('Bucket 带有 .', function (done, assert) {
  2252. cos.headBucket({
  2253. Bucket: 'te.st-1250000000',
  2254. Region: config.Region,
  2255. }, function (err, data) {
  2256. assert.ok(err && err.message === 'Bucket should format as "test-1250000000".');
  2257. done();
  2258. });
  2259. });
  2260. test('Bucket 带有 :', function (done, assert) {
  2261. cos.headBucket({
  2262. Bucket: 'te:st-1250000000',
  2263. Region: config.Region,
  2264. }, function (err, data) {
  2265. assert.ok(err && err.message === 'Bucket should format as "test-1250000000".');
  2266. done();
  2267. });
  2268. });
  2269. });
  2270. group('Region 格式有误', function () {
  2271. test('Region 带有中文', function (done, assert) {
  2272. cos.headBucket({
  2273. Bucket: 'test-1250000000',
  2274. Region: '中文',
  2275. }, function (err, data) {
  2276. assert.ok(err && err.message === 'Region format error.');
  2277. done();
  2278. });
  2279. });
  2280. test('Region 带有 /', function (done, assert) {
  2281. cos.headBucket({
  2282. Bucket: 'test-1250000000',
  2283. Region: 'test/',
  2284. }, function (err, data) {
  2285. assert.ok(err && err.message === 'Region format error.');
  2286. done();
  2287. });
  2288. });
  2289. test('Region 带有 :', function (done, assert) {
  2290. cos.headBucket({
  2291. Bucket: 'test-1250000000',
  2292. Region: 'test:',
  2293. }, function (err, data) {
  2294. assert.ok(err && err.message === 'Region format error.');
  2295. done();
  2296. });
  2297. });
  2298. });
  2299. group('复制文件', function () {
  2300. test('sliceCopyFile() 正常分片复制', function (done, assert) {
  2301. var filename = '10m.zip';
  2302. var Key = '10mb.copy.zip';
  2303. var blob = util.createFile({size: 1024 * 1024 * 10});
  2304. var lastPercent;
  2305. cos.putObject({
  2306. Bucket: config.Bucket,
  2307. Region: config.Region,
  2308. Key: filename,
  2309. Body: blob,
  2310. }, function (err, data) {
  2311. cos.sliceCopyFile({
  2312. Bucket: config.Bucket,
  2313. Region: config.Region,
  2314. Key: Key,
  2315. CopySource: config.Bucket + '.cos.' + config.Region + '.myqcloud.com/' + filename,
  2316. SliceSize: 5 * 1024 * 1024,
  2317. onProgress: function (info) {
  2318. lastPercent = info.percent;
  2319. }
  2320. }, function (err, data) {
  2321. assert.ok(data && data.ETag, '成功进行分片复制');
  2322. done();
  2323. });
  2324. });
  2325. });
  2326. test('sliceCopyFile() 单片复制', function (done, assert) {
  2327. var filename = '10m.zip';
  2328. var Key = '10mb.copy.zip';
  2329. cos.sliceCopyFile({
  2330. Bucket: config.Bucket,
  2331. Region: config.Region,
  2332. Key: Key,
  2333. CopySource: config.Bucket + '.cos.' + config.Region + '.myqcloud.com/' + filename,
  2334. SliceSize: 10 * 1024 * 1024,
  2335. }, function (err, data) {
  2336. if (err) throw err;
  2337. assert.ok(data && data.ETag, '成功进行单片复制');
  2338. done();
  2339. });
  2340. });
  2341. });
  2342. group('putObject 中文 Content-MD5', function () {
  2343. var fileBlob = dataURItoUploadBody('data:text/plain;base64,5Lit5paH');
  2344. // 这里两个用户正式测试的时候需要给 putObject 计算并加上 Content-MD5 字段
  2345. test('putObject 中文文件内容 带 Content-MD5', function (done, assert) {
  2346. var Key = '中文.txt';
  2347. cos.putObject({
  2348. Bucket: config.Bucket,
  2349. Region: config.Region,
  2350. Key: Key,
  2351. Body: fileBlob,
  2352. }, function (err, data) {
  2353. assert.ok(data && data.ETag, '成功进行上传');
  2354. done();
  2355. });
  2356. });
  2357. test('putObject 中文字符串 带 Content-MD5', function (done, assert) {
  2358. var Key = '中文.txt';
  2359. cos.putObject({
  2360. Bucket: config.Bucket,
  2361. Region: config.Region,
  2362. Key: Key,
  2363. Body: '中文',
  2364. }, function (err, data) {
  2365. assert.ok(data && data.ETag, '成功进行上传');
  2366. done();
  2367. });
  2368. });
  2369. });
  2370. group('deleteMultipleObject Key 带中文字符', function () {
  2371. test('deleteMultipleObject Key 带中文字符', function (done, assert) {
  2372. cos.deleteMultipleObject({
  2373. Bucket: config.Bucket,
  2374. Region: config.Region,
  2375. Objects: [
  2376. {Key: '中文/中文.txt'},
  2377. {Key: '中文/中文.zip', VersionId: 'MTg0NDY3NDI1MzM4NzM0ODA2MTI'},
  2378. {Key: unescape(encodeURIComponent('中文'))},
  2379. {Key: unescape('%e8%af%b4%2e%70%72%70%72')},
  2380. ]
  2381. }, function (err, data) {
  2382. assert.ok(!err, '成功进行批量删除');
  2383. done();
  2384. });
  2385. });
  2386. });
  2387. group('upload Content-Type', function () {
  2388. // putObject
  2389. test('putObject empty string Content-Type null -> text/plain', function (done, assert) {
  2390. cos.putObject({
  2391. Bucket: config.Bucket,
  2392. Region: config.Region,
  2393. Key: '1',
  2394. Body: '',
  2395. }, function (err, data) {
  2396. cos.headObject({
  2397. Bucket: config.Bucket,
  2398. Region: config.Region,
  2399. Key: '1',
  2400. }, function (err, data) {
  2401. assert.ok(data.headers['content-type'] === 'text/plain', 'Content-Type 正确');
  2402. done();
  2403. });
  2404. });
  2405. });
  2406. test('putObject string Content-Type null -> text/plain', function (done, assert) {
  2407. cos.putObject({
  2408. Bucket: config.Bucket,
  2409. Region: config.Region,
  2410. Key: '1.zip',
  2411. Body: '12345',
  2412. }, function (err, data) {
  2413. cos.headObject({
  2414. Bucket: config.Bucket,
  2415. Region: config.Region,
  2416. Key: '1.zip',
  2417. }, function (err, data) {
  2418. assert.ok(data.headers['content-type'] === 'text/plain', 'Content-Type 正确');
  2419. done();
  2420. });
  2421. });
  2422. });
  2423. test('putObject string Content-Type text/xml -> text/xml', function (done, assert) {
  2424. cos.putObject({
  2425. Bucket: config.Bucket,
  2426. Region: config.Region,
  2427. Key: '1.zip',
  2428. ContentType: 'text/xml',
  2429. Body: util.createFile({size: 1, type: 'text/html'}),
  2430. }, function (err, data) {
  2431. cos.headObject({
  2432. Bucket: config.Bucket,
  2433. Region: config.Region,
  2434. Key: '1.zip',
  2435. }, function (err, data) {
  2436. assert.ok(data.headers['content-type'] === 'text/xml', 'Content-Type 正确');
  2437. done();
  2438. });
  2439. });
  2440. });
  2441. test('putObject blob Content-Type text/xml -> text/xml', function (done, assert) {
  2442. cos.putObject({
  2443. Bucket: config.Bucket,
  2444. Region: config.Region,
  2445. Key: '1.zip',
  2446. ContentType: 'text/xml',
  2447. Body: util.createFile({size: 1, type: 'text/html'}),
  2448. }, function (err, data) {
  2449. cos.headObject({
  2450. Bucket: config.Bucket,
  2451. Region: config.Region,
  2452. Key: '1.zip',
  2453. }, function (err, data) {
  2454. assert.ok(data.headers['content-type'] === 'text/xml', 'Content-Type 正确');
  2455. done();
  2456. });
  2457. });
  2458. });
  2459. test('putObject blob Content-Type text/html -> text/html', function (done, assert) {
  2460. cos.putObject({
  2461. Bucket: config.Bucket,
  2462. Region: config.Region,
  2463. Key: '1.zip',
  2464. Body: util.createFile({size: 1, type: 'text/html'}),
  2465. }, function (err, data) {
  2466. cos.headObject({
  2467. Bucket: config.Bucket,
  2468. Region: config.Region,
  2469. Key: '1.zip',
  2470. }, function (err, data) {
  2471. assert.ok(data.headers['content-type'] === 'text/html', 'Content-Type 正确');
  2472. done();
  2473. });
  2474. });
  2475. });
  2476. test('putObject blob Content-Type null -> application/zip or application/octet-stream', function (done, assert) {
  2477. cos.putObject({
  2478. Bucket: config.Bucket,
  2479. Region: config.Region,
  2480. Key: '1.zip',
  2481. Body: util.createFile({size: 1}),
  2482. }, function (err, data) {
  2483. cos.headObject({
  2484. Bucket: config.Bucket,
  2485. Region: config.Region,
  2486. Key: '1.zip',
  2487. }, function (err, data) {
  2488. assert.ok(data.headers['content-type'] === 'application/zip', 'Content-Type 正确');
  2489. done();
  2490. });
  2491. });
  2492. });
  2493. test('putObject blob Content-Type null application/octet-stream', function (done, assert) {
  2494. cos.putObject({
  2495. Bucket: config.Bucket,
  2496. Region: config.Region,
  2497. Key: '1',
  2498. Body: util.createFile({size: 1}),
  2499. }, function (err, data) {
  2500. cos.headObject({
  2501. Bucket: config.Bucket,
  2502. Region: config.Region,
  2503. Key: '1',
  2504. }, function (err, data) {
  2505. assert.ok(data.headers['content-type'] === 'application/octet-stream', 'Content-Type 正确');
  2506. done();
  2507. });
  2508. });
  2509. });
  2510. test('putObject empty blob Content-Type null application/octet-stream', function (done, assert) {
  2511. cos.putObject({
  2512. Bucket: config.Bucket,
  2513. Region: config.Region,
  2514. Key: '1',
  2515. Body: util.createFile({size: 0}),
  2516. }, function (err, data) {
  2517. cos.headObject({
  2518. Bucket: config.Bucket,
  2519. Region: config.Region,
  2520. Key: '1',
  2521. }, function (err, data) {
  2522. assert.ok(data.headers['content-type'] === 'application/octet-stream', 'Content-Type 正确');
  2523. done();
  2524. });
  2525. });
  2526. });
  2527. // sliceUploadFile
  2528. test('sliceUploadFile string Content-Type null -> text/plain', function (done, assert) {
  2529. cos.sliceUploadFile({
  2530. Bucket: config.Bucket,
  2531. Region: config.Region,
  2532. Key: '1.zip',
  2533. Body: '12345',
  2534. }, function (err, data) {
  2535. cos.headObject({
  2536. Bucket: config.Bucket,
  2537. Region: config.Region,
  2538. Key: '1.zip',
  2539. }, function (err, data) {
  2540. assert.ok(data.headers['content-type'] === 'text/plain', 'Content-Type 正确');
  2541. done();
  2542. });
  2543. });
  2544. });
  2545. test('sliceUploadFile string Content-Type text/xml -> text/xml', function (done, assert) {
  2546. cos.sliceUploadFile({
  2547. Bucket: config.Bucket,
  2548. Region: config.Region,
  2549. Key: '1.zip',
  2550. ContentType: 'text/xml',
  2551. Body: util.createFile({size: 1, type: 'text/html'}),
  2552. }, function (err, data) {
  2553. cos.headObject({
  2554. Bucket: config.Bucket,
  2555. Region: config.Region,
  2556. Key: '1.zip',
  2557. }, function (err, data) {
  2558. assert.ok(data.headers['content-type'] === 'text/xml', 'Content-Type 正确');
  2559. done();
  2560. });
  2561. });
  2562. });
  2563. test('sliceUploadFile blob Content-Type text/xml -> text/xml', function (done, assert) {
  2564. cos.sliceUploadFile({
  2565. Bucket: config.Bucket,
  2566. Region: config.Region,
  2567. Key: '1.zip',
  2568. ContentType: 'text/xml',
  2569. Body: util.createFile({size: 1, type: 'text/html'}),
  2570. }, function (err, data) {
  2571. cos.headObject({
  2572. Bucket: config.Bucket,
  2573. Region: config.Region,
  2574. Key: '1.zip',
  2575. }, function (err, data) {
  2576. assert.ok(data.headers['content-type'] === 'text/xml', 'Content-Type 正确');
  2577. done();
  2578. });
  2579. });
  2580. });
  2581. test('sliceUploadFile blob Content-Type text/html -> text/html', function (done, assert) {
  2582. cos.sliceUploadFile({
  2583. Bucket: config.Bucket,
  2584. Region: config.Region,
  2585. Key: '1.zip',
  2586. Body: util.createFile({size: 1, type: 'text/html'}),
  2587. }, function (err, data) {
  2588. cos.headObject({
  2589. Bucket: config.Bucket,
  2590. Region: config.Region,
  2591. Key: '1.zip',
  2592. }, function (err, data) {
  2593. assert.ok(data.headers['content-type'] === 'text/html', 'Content-Type 正确');
  2594. done();
  2595. });
  2596. });
  2597. });
  2598. test('sliceUploadFile blob Content-Type null -> application/zip or application/octet-stream', function (done, assert) {
  2599. cos.sliceUploadFile({
  2600. Bucket: config.Bucket,
  2601. Region: config.Region,
  2602. Key: '1.zip',
  2603. Body: util.createFile({size: 1}),
  2604. }, function (err, data) {
  2605. cos.headObject({
  2606. Bucket: config.Bucket,
  2607. Region: config.Region,
  2608. Key: '1.zip',
  2609. }, function (err, data) {
  2610. var userAgent = navigator.userAgent || '';
  2611. var m = userAgent.match(/ TBS\/(\d{6}) /);
  2612. if (location.protocol === 'http:' && m && m[1].length <= 6 && m[1] < '044429') {
  2613. assert.ok(data.headers['content-type'] === 'application/octet-stream', 'Content-Type 正确');
  2614. } else {
  2615. assert.ok(data.headers['content-type'] === 'application/zip', 'Content-Type 正确');
  2616. }
  2617. done();
  2618. });
  2619. });
  2620. });
  2621. test('sliceUploadFile blob Content-Type null application/octet-stream', function (done, assert) {
  2622. cos.sliceUploadFile({
  2623. Bucket: config.Bucket,
  2624. Region: config.Region,
  2625. Key: '1',
  2626. Body: util.createFile({size: 1}),
  2627. }, function (err, data) {
  2628. cos.headObject({
  2629. Bucket: config.Bucket,
  2630. Region: config.Region,
  2631. Key: '1',
  2632. }, function (err, data) {
  2633. assert.ok(data.headers['content-type'] === 'application/octet-stream', 'Content-Type 正确');
  2634. done();
  2635. });
  2636. });
  2637. });
  2638. });
  2639. group('Cache-Control', function (val) {
  2640. var isNormalCacheControl = function (val) {
  2641. return val === undefined
  2642. || val === 'no-cache'
  2643. || val === 'max-age=259200'
  2644. // || val === 'no-cache, max-age=259200' // IE 10
  2645. // || val === 'no-cache, max-age=7200' // firefox
  2646. };
  2647. // putObject
  2648. test('putObject Cache-Control: null -> Cache-Control: null or max-age=259200', function (done, assert) {
  2649. cos.putObject({
  2650. Bucket: config.Bucket,
  2651. Region: config.Region,
  2652. Key: '1mb.zip',
  2653. Body: '',
  2654. }, function (err, data) {
  2655. cos.headObject({
  2656. Bucket: config.Bucket,
  2657. Region: config.Region,
  2658. Key: '1mb.zip',
  2659. }, function (err, data) {
  2660. assert.ok(isNormalCacheControl(data.headers['cache-control']), 'cache-control 正确');
  2661. done();
  2662. });
  2663. });
  2664. });
  2665. test('putObject Cache-Control: max-age=7200 -> Cache-Control: max-age=7200', function (done, assert) {
  2666. cos.putObject({
  2667. Bucket: config.Bucket,
  2668. Region: config.Region,
  2669. Key: '1mb.zip',
  2670. Body: '',
  2671. CacheControl: 'max-age=7200',
  2672. }, function (err, data) {
  2673. cos.headObject({
  2674. Bucket: config.Bucket,
  2675. Region: config.Region,
  2676. Key: '1mb.zip',
  2677. }, function (err, data) {
  2678. assert.ok(data.headers['cache-control'] === 'max-age=7200', 'cache-control 正确');
  2679. done();
  2680. });
  2681. });
  2682. });
  2683. test('putObject Cache-Control: no-cache -> Cache-Control: no-cache', function (done, assert) {
  2684. cos.putObject({
  2685. Bucket: config.Bucket,
  2686. Region: config.Region,
  2687. Key: '1mb.zip',
  2688. Body: '',
  2689. CacheControl: 'no-cache',
  2690. }, function (err, data) {
  2691. cos.headObject({
  2692. Bucket: config.Bucket,
  2693. Region: config.Region,
  2694. Key: '1mb.zip',
  2695. }, function (err, data) {
  2696. assert.ok(data.headers['cache-control'] === 'no-cache' || data.headers['cache-control'] === 'no-cache, max-age=259200', 'cache-control 正确');
  2697. done();
  2698. });
  2699. });
  2700. });
  2701. // sliceUploadFile
  2702. test('sliceUploadFile Cache-Control: null -> Cache-Control: null or max-age=259200', function (done, assert) {
  2703. cos.sliceUploadFile({
  2704. Bucket: config.Bucket,
  2705. Region: config.Region,
  2706. Key: '1mb.zip',
  2707. Body: '',
  2708. }, function (err, data) {
  2709. cos.headObject({
  2710. Bucket: config.Bucket,
  2711. Region: config.Region,
  2712. Key: '1mb.zip',
  2713. }, function (err, data) {
  2714. assert.ok(data.headers['cache-control'] === undefined || data.headers['cache-control'] === 'max-age=259200' || data.headers['cache-control'] === 'no-cache, max-age=259200', 'cache-control 正确');
  2715. done();
  2716. });
  2717. });
  2718. });
  2719. test('sliceUploadFile Cache-Control: max-age=7200 -> Cache-Control: max-age=7200', function (done, assert) {
  2720. cos.sliceUploadFile({
  2721. Bucket: config.Bucket,
  2722. Region: config.Region,
  2723. Key: '1mb.zip',
  2724. Body: '',
  2725. CacheControl: 'max-age=7200',
  2726. }, function (err, data) {
  2727. cos.headObject({
  2728. Bucket: config.Bucket,
  2729. Region: config.Region,
  2730. Key: '1mb.zip',
  2731. }, function (err, data) {
  2732. assert.ok(data.headers['cache-control'] === 'max-age=7200', 'cache-control 正确');
  2733. done();
  2734. });
  2735. });
  2736. });
  2737. test('sliceUploadFile Cache-Control: no-cache -> Cache-Control: no-cache', function (done, assert) {
  2738. cos.sliceUploadFile({
  2739. Bucket: config.Bucket,
  2740. Region: config.Region,
  2741. Key: '1mb.zip',
  2742. Body: '',
  2743. CacheControl: 'no-cache',
  2744. }, function (err, data) {
  2745. cos.headObject({
  2746. Bucket: config.Bucket,
  2747. Region: config.Region,
  2748. Key: '1mb.zip',
  2749. }, function (err, data) {
  2750. assert.ok(data.headers['cache-control'] === 'no-cache' || data.headers['cache-control'] === 'no-cache, max-age=259200', 'cache-control 正确');
  2751. done();
  2752. });
  2753. });
  2754. });
  2755. });
  2756. group('BucketLogging', function () {
  2757. var TargetBucket = config.Bucket;
  2758. var TargetPrefix = 'bucket-logging-prefix' + Date.now().toString(36) + '/';
  2759. var BucketLoggingStatus = {
  2760. LoggingEnabled: {
  2761. TargetBucket: TargetBucket,
  2762. TargetPrefix: TargetPrefix
  2763. }
  2764. };
  2765. test('putBucketLogging(), getBucketLogging()', function (done, assert) {
  2766. cos.putBucketLogging({
  2767. Bucket: config.Bucket,
  2768. Region: config.Region,
  2769. BucketLoggingStatus: BucketLoggingStatus
  2770. }, function (err, data) {
  2771. assert.ok(!err);
  2772. cos.getBucketLogging({
  2773. Bucket: config.Bucket,
  2774. Region: config.Region
  2775. }, function (err, data) {
  2776. assert.ok(comparePlainObject(BucketLoggingStatus, data.BucketLoggingStatus));
  2777. done();
  2778. });
  2779. });
  2780. });
  2781. test('putBucketLogging() 删除 logging 配置', function (done, assert) {
  2782. cos.putBucketLogging({
  2783. Bucket: config.Bucket,
  2784. Region: config.Region,
  2785. BucketLoggingStatus: ''
  2786. }, function (err, data) {
  2787. assert.ok(!err);
  2788. cos.getBucketLogging({
  2789. Bucket: config.Bucket,
  2790. Region: config.Region
  2791. }, function (err, data) {
  2792. assert.ok(data.BucketLoggingStatus === '');
  2793. done();
  2794. });
  2795. });
  2796. });
  2797. });
  2798. group('BucketInventory', function () {
  2799. var TargetBucket = config.Bucket;
  2800. var InventoryConfiguration = {
  2801. Id: 'inventory_test',
  2802. IsEnabled: 'true',
  2803. Destination: {
  2804. COSBucketDestination: {
  2805. Format: 'CSV',
  2806. AccountId: config.Uin,
  2807. Bucket: 'qcs::cos:' + config.Region + '::' + TargetBucket,
  2808. Prefix: 'inventory_prefix_1',
  2809. Encryption: {
  2810. SSECOS: ''
  2811. }
  2812. }
  2813. },
  2814. Schedule: {
  2815. Frequency: 'Daily'
  2816. },
  2817. Filter: {
  2818. Prefix: 'myPrefix'
  2819. },
  2820. IncludedObjectVersions: 'All',
  2821. OptionalFields: [
  2822. 'Size'
  2823. ]
  2824. };
  2825. var InventoryConfigurationNoEncryption = {
  2826. Id: 'inventory_test',
  2827. IsEnabled: 'true',
  2828. Destination: {
  2829. COSBucketDestination: {
  2830. Format: 'CSV',
  2831. AccountId: config.Uin,
  2832. Bucket: 'qcs::cos:' + config.Region + '::' + TargetBucket,
  2833. Prefix: 'inventory_prefix_1'
  2834. }
  2835. },
  2836. Schedule: {
  2837. Frequency: 'Daily'
  2838. },
  2839. Filter: {
  2840. Prefix: 'myPrefix'
  2841. },
  2842. IncludedObjectVersions: 'All',
  2843. OptionalFields: [
  2844. 'Size'
  2845. ]
  2846. };
  2847. test('putBucketInventory(), getBucketInventory()', function (done, assert) {
  2848. cos.putBucketInventory({
  2849. Bucket: config.Bucket,
  2850. Region: config.Region,
  2851. Id: InventoryConfiguration.Id,
  2852. InventoryConfiguration: InventoryConfiguration
  2853. }, function (err, data) {
  2854. assert.ok(!err);
  2855. cos.getBucketInventory({
  2856. Bucket: config.Bucket,
  2857. Region: config.Region,
  2858. Id: InventoryConfiguration.Id
  2859. }, function (err, data) {
  2860. assert.ok(comparePlainObject(InventoryConfiguration, data.InventoryConfiguration));
  2861. done();
  2862. });
  2863. });
  2864. });
  2865. test('listBucketInventory()', function (done, assert) {
  2866. cos.listBucketInventory({
  2867. Bucket: config.Bucket,
  2868. Region: config.Region
  2869. }, function (err, data) {
  2870. var targetInventory;
  2871. data.InventoryConfigurations.forEach(function (item) {
  2872. if (item.Id === InventoryConfiguration.Id) {
  2873. targetInventory = item;
  2874. }
  2875. });
  2876. assert.ok(comparePlainObject(InventoryConfiguration, targetInventory));
  2877. assert.ok(data.IsTruncated === 'false' || data.IsTruncated === 'true');
  2878. done();
  2879. });
  2880. });
  2881. test('putBucketInventory() 不设置 SSECOS', function (done, assert) {
  2882. cos.putBucketInventory({
  2883. Bucket: config.Bucket,
  2884. Region: config.Region,
  2885. Id: InventoryConfigurationNoEncryption.Id,
  2886. InventoryConfiguration: InventoryConfigurationNoEncryption
  2887. }, function (err, data) {
  2888. assert.ok(!err);
  2889. cos.getBucketInventory({
  2890. Bucket: config.Bucket,
  2891. Region: config.Region,
  2892. Id: InventoryConfigurationNoEncryption.Id
  2893. }, function (err, data) {
  2894. assert.ok(comparePlainObject(InventoryConfigurationNoEncryption, data.InventoryConfiguration));
  2895. done();
  2896. });
  2897. });
  2898. });
  2899. test('deleteBucketInventory()', function (done, assert) {
  2900. cos.deleteBucketInventory({
  2901. Bucket: config.Bucket,
  2902. Region: config.Region,
  2903. Id: InventoryConfiguration.Id
  2904. }, function (err, data) {
  2905. assert.ok(!err);
  2906. cos.getBucketInventory({
  2907. Bucket: config.Bucket,
  2908. Region: config.Region,
  2909. Id: InventoryConfiguration.Id
  2910. }, function (err, data) {
  2911. assert.ok(err && err.statusCode === 404);
  2912. done();
  2913. });
  2914. });
  2915. });
  2916. });
  2917. var tagging2str = function (obj) {
  2918. var arr = [];
  2919. obj.forEach(function (v) {
  2920. arr.push(v.Key + '=' + encodeURIComponent(v.Value));
  2921. })
  2922. return arr.join('&');
  2923. }
  2924. group('上传带 tagging', function () {
  2925. var Tags = [
  2926. {Key: "k1", Value: "v1"},
  2927. {Key: "k2", Value: "v2"},
  2928. ];
  2929. var key = '1.txt';
  2930. test('putObject 带 x-cos-tagging', function (done, assert) {
  2931. Tags[0].Value = Date.now().toString(36);
  2932. var tagStr = tagging2str(Tags);
  2933. // 调用方法
  2934. cos.putObject({
  2935. Bucket: config.Bucket,
  2936. Region: config.Region,
  2937. Key: key,
  2938. Body: 'hello!',
  2939. Headers: {
  2940. 'x-cos-tagging': tagStr,
  2941. },
  2942. }, function (err1, data1) {
  2943. cos.headObject({
  2944. Bucket: config.Bucket,
  2945. Region: config.Region,
  2946. Key: key,
  2947. }, function (err2, data2) {
  2948. var taggingCount = data2 && data2.headers['x-cos-tagging-count'];
  2949. assert.ok(taggingCount === '2', '返回 x-cos-tagging-count: ' + taggingCount);
  2950. cos.getObjectTagging({
  2951. Bucket: config.Bucket,
  2952. Region: config.Region,
  2953. Key: key,
  2954. }, function (err3, data3) {
  2955. assert.ok(comparePlainObject(Tags, data3.Tags));
  2956. done();
  2957. });
  2958. });
  2959. });
  2960. });
  2961. // test('sliceUploadFile 带 x-cos-tagging', function (done, assert) {
  2962. // Tags[0].Value = Date.now().toString(36);
  2963. // var tagStr = tagging2str(Tags);
  2964. // // 调用方法
  2965. // cos.sliceUploadFile({
  2966. // Bucket: config.Bucket,
  2967. // Region: config.Region,
  2968. // Key: key,
  2969. // Body: 'hello!',
  2970. // Headers: {
  2971. // 'x-cos-tagging': tagStr,
  2972. // },
  2973. // }, function (err1, data1) {
  2974. // cos.headObject({
  2975. // Bucket: config.Bucket,
  2976. // Region: config.Region,
  2977. // Key: key,
  2978. // }, function (err2, data2) {
  2979. // var taggingCount = data2 && data2.headers['x-cos-tagging-count'];
  2980. // assert.ok(taggingCount === '1', '返回 x-cos-tagging-count: ' + taggingCount);
  2981. // cos.getObjectTagging({
  2982. // Bucket: config.Bucket,
  2983. // Region: config.Region,
  2984. // Key: key,
  2985. // }, function (err3, data3) {
  2986. // assert.ok(data3 && data3.Tags && comparePlainObject(Tags, data3.Tags));
  2987. // done();
  2988. // });
  2989. // });
  2990. // });
  2991. // });
  2992. });
  2993. group('ObjectTagging', function () {
  2994. var key = '1.txt';
  2995. var Tags = [
  2996. {Key: "k1", Value: "v1"},
  2997. {Key: "k2", Value: "v2"},
  2998. ];
  2999. test('putObjectTagging(),getObjectTagging()', function (done, assert) {
  3000. Tags[0].Value = Date.now().toString(36);
  3001. cos.putObjectTagging({
  3002. Bucket: config.Bucket,
  3003. Region: config.Region,
  3004. Key: key,
  3005. Tagging: {
  3006. Tags: Tags
  3007. },
  3008. }, function (err, data) {
  3009. assert.ok(!err);
  3010. setTimeout(function () {
  3011. cos.getObjectTagging({
  3012. Bucket: config.Bucket,
  3013. Region: config.Region,
  3014. Key: key,
  3015. }, function (err, data) {
  3016. assert.ok(comparePlainObject(Tags, data.Tags));
  3017. done();
  3018. });
  3019. }, 1000);
  3020. });
  3021. });
  3022. test('deleteObjectTagging()', function (done, assert) {
  3023. cos.deleteObjectTagging({
  3024. Bucket: config.Bucket,
  3025. Region: config.Region,
  3026. Key: key,
  3027. }, function (err, data) {
  3028. assert.ok(!err);
  3029. setTimeout(function () {
  3030. cos.getObjectTagging({
  3031. Bucket: config.Bucket,
  3032. Region: config.Region,
  3033. Key: key,
  3034. }, function (err, data) {
  3035. assert.ok(comparePlainObject([], data.Tags));
  3036. done();
  3037. });
  3038. }, 1000);
  3039. });
  3040. });
  3041. });
  3042. group('getBucketAccelerate', function () {
  3043. test('putBucketAccelerate(),getBucketAccelerate() Enabled', function (done, assert) {
  3044. cos.putBucketAccelerate({
  3045. Bucket: config.Bucket,
  3046. Region: config.Region,
  3047. AccelerateConfiguration: {
  3048. Status: 'Enabled', // Suspended、Enabled
  3049. },
  3050. }, function (err, data) {
  3051. assert.ok(!err);
  3052. setTimeout(function () {
  3053. cos.getBucketAccelerate({
  3054. Bucket: config.Bucket,
  3055. Region: config.Region,
  3056. }, function (err2, data2) {
  3057. assert.ok(data2 && data2.AccelerateConfiguration && data2.AccelerateConfiguration.Status === 'Enabled');
  3058. done();
  3059. });
  3060. }, 2000);
  3061. });
  3062. });
  3063. test('putBucketAccelerate(),getBucketAccelerate() Suspended', function (done, assert) {
  3064. cos.putBucketAccelerate({
  3065. Bucket: config.Bucket,
  3066. Region: config.Region,
  3067. AccelerateConfiguration: {
  3068. Status: 'Suspended', // Suspended、Enabled
  3069. },
  3070. }, function (err, data) {
  3071. assert.ok(!err);
  3072. setTimeout(function () {
  3073. cos.getBucketAccelerate({
  3074. Bucket: config.Bucket,
  3075. Region: config.Region,
  3076. }, function (err2, data2) {
  3077. assert.ok(data2 && data2.AccelerateConfiguration && data2.AccelerateConfiguration.Status === 'Suspended');
  3078. done();
  3079. });
  3080. }, 1000);
  3081. });
  3082. });
  3083. });
  3084. group('Promise', function () {
  3085. test('headBucket callback', function (done, assert) {
  3086. var res = cos.headBucket({
  3087. Bucket: config.Bucket,
  3088. Region: config.Region,
  3089. }, function (err, data) {
  3090. assert.ok(!err && data);
  3091. done();
  3092. });
  3093. assert.ok(!res);
  3094. });
  3095. test('Promise() getObjectUrl', function (done, assert) {
  3096. var res = cos.getObjectUrl({
  3097. Bucket: config.Bucket,
  3098. Region: config.Region,
  3099. Key: '123.txt',
  3100. });
  3101. assert.ok(!res.then);
  3102. done();
  3103. });
  3104. test('Promise() headBucket', function (done, assert) {
  3105. cos.headBucket({
  3106. Bucket: config.Bucket,
  3107. Region: config.Region,
  3108. }).then(function (data) {
  3109. assert.ok(data);
  3110. done();
  3111. }).catch(function () {
  3112. assert.ok(false);
  3113. done();
  3114. });
  3115. });
  3116. test('headBucket callback', function (done, assert) {
  3117. var res = cos.headBucket({
  3118. Bucket: config.Bucket,
  3119. Region: config.Region,
  3120. }, function (err, data) {
  3121. assert.ok(!err && data);
  3122. done();
  3123. });
  3124. assert.ok(!res);
  3125. });
  3126. test('Promise() headBucket error', function (done, assert) {
  3127. cos.headBucket({
  3128. Bucket: config.Bucket,
  3129. Region: config.Region + '/',
  3130. }).then(function (data) {
  3131. assert.ok(!data);
  3132. done();
  3133. }).catch(function (err) {
  3134. assert.ok(err && err.message === 'Region format error.');
  3135. done();
  3136. });
  3137. });
  3138. });
  3139. group('Query 的键值带有特殊字符', function () {
  3140. test('getAuth() 特殊字符', function (done, assert) {
  3141. var content = Date.now().toString();
  3142. var key = '1.txt';
  3143. cos.putObject({
  3144. Bucket: config.Bucket,
  3145. Region: config.Region,
  3146. Key: key,
  3147. Body: content,
  3148. }, function (err, data) {
  3149. var str = 'qwertyuiopasdfghjklzxcvbnmQWERTYUIOPASDFGHJKLZXCVBNM,./;\'[]\\-=0987654321`~!@#$%^&*()_+{}|":>?<';
  3150. var qs = {};
  3151. qs[str] = str;
  3152. cos.options.getAuthorization({
  3153. Method: 'get',
  3154. Key: key,
  3155. Scope: [{
  3156. action: 'GetObject',
  3157. bucket: config.Bucket,
  3158. region: config.Region,
  3159. prefix: key,
  3160. }],
  3161. Query: qs,
  3162. }, function (AuthData) {
  3163. if (typeof AuthData === 'string') {
  3164. AuthData = {Authorization: AuthData};
  3165. }
  3166. if (!AuthData.Authorization) {
  3167. AuthData.Authorization = COS.getAuthorization({
  3168. SecretId: AuthData.TmpSecretId,
  3169. SecretKey: AuthData.TmpSecretKey,
  3170. Method: 'get',
  3171. Key: key,
  3172. SystemClockOffset: cos.options.SystemClockOffset,
  3173. });
  3174. }
  3175. var link = 'http://' + config.Bucket + '.cos.' + config.Region + '.myqcloud.com' + '/' +
  3176. camSafeUrlEncode(key).replace(/%2F/g, '/') + '?' + AuthData.Authorization +
  3177. (AuthData.SecurityToken ? '&x-cos-security-token=' + AuthData.SecurityToken : '') +
  3178. '&' + camSafeUrlEncode(str) + '=' + camSafeUrlEncode(str);
  3179. request({
  3180. method: 'GET',
  3181. url: link,
  3182. }, function (err, response, body) {
  3183. assert.ok(response.statusCode === 200);
  3184. assert.ok(body === content);
  3185. done();
  3186. });
  3187. });
  3188. });
  3189. });
  3190. test('getAuth() 特殊字符 ?sign=', function (done, assert) {
  3191. var content = Date.now().toString();
  3192. var key = '1.txt';
  3193. cos.putObject({
  3194. Bucket: config.Bucket,
  3195. Region: config.Region,
  3196. Key: key,
  3197. Body: content,
  3198. }, function (err, data) {
  3199. var str = 'qwertyuiopasdfghjklzxcvbnmQWERTYUIOPASDFGHJKLZXCVBNM,./;\'[]\\-=0987654321`~!@#$%^&*()_+{}|":>?<';
  3200. var qs = {};
  3201. qs[str] = str;
  3202. cos.options.getAuthorization({
  3203. Method: 'get',
  3204. Key: key,
  3205. Scope: [{
  3206. action: 'GetObject',
  3207. bucket: config.Bucket,
  3208. region: config.Region,
  3209. prefix: key,
  3210. }],
  3211. Query: qs,
  3212. }, function (AuthData) {
  3213. if (typeof AuthData === 'string') {
  3214. AuthData = {Authorization: AuthData};
  3215. }
  3216. if (!AuthData.Authorization) {
  3217. AuthData.Authorization = COS.getAuthorization({
  3218. SecretId: AuthData.TmpSecretId,
  3219. SecretKey: AuthData.TmpSecretKey,
  3220. Method: 'get',
  3221. Key: key,
  3222. SystemClockOffset: cos.options.SystemClockOffset,
  3223. });
  3224. }
  3225. var link = 'http://' + config.Bucket + '.cos.' + config.Region + '.myqcloud.com' + '/' +
  3226. camSafeUrlEncode(key).replace(/%2F/g, '/') +
  3227. '?sign=' + camSafeUrlEncode(AuthData.Authorization) +
  3228. (AuthData.SecurityToken ? '&x-cos-security-token=' + AuthData.SecurityToken : '') +
  3229. '&' + camSafeUrlEncode(str) + '=' + camSafeUrlEncode(str);
  3230. request({
  3231. method: 'GET',
  3232. url: link,
  3233. }, function (err, response, body) {
  3234. assert.ok(response.statusCode === 200);
  3235. assert.ok(body === content);
  3236. done();
  3237. });
  3238. });
  3239. });
  3240. });
  3241. });
  3242. group('selectObjectContent(),selectObjectContentStream()', function () {
  3243. var key = '1.json';
  3244. var selectJsonOpt = {
  3245. Bucket: config.Bucket,
  3246. Region: config.Region,
  3247. Key: key,
  3248. SelectType: 2,
  3249. SelectRequest: {
  3250. Expression: "Select * from COSObject",
  3251. ExpressionType: "SQL",
  3252. InputSerialization: {JSON: {Type: "DOCUMENT",},},
  3253. OutputSerialization: {JSON: {RecordDelimiter: "\n"},},
  3254. RequestProgress: {Enabled: "FALSE"}
  3255. },
  3256. };
  3257. test('selectObjectContent', function (done, assert) {
  3258. var time = Date.now();
  3259. var content = `{"a":123,"b":"中文${time}","c":{"d":456}}`;
  3260. cos.putObject({
  3261. Bucket: config.Bucket,
  3262. Region: config.Region,
  3263. Key: key,
  3264. Body: content,
  3265. }, function (err, data) {
  3266. cos.selectObjectContent(selectJsonOpt, function (err, data) {
  3267. assert.ok(data.Payload === content + '\n');
  3268. done();
  3269. });
  3270. });
  3271. });
  3272. test('selectObjectContent', function (done, assert) {
  3273. var time = Date.now();
  3274. var content = `{"a":123,"b":"${time}","c":{"d":456}`;
  3275. cos.putObject({
  3276. Bucket: config.Bucket,
  3277. Region: config.Region,
  3278. Key: key,
  3279. Body: content,
  3280. }, function (err, data) {
  3281. var bufList = [];
  3282. cos.selectObjectContent(selectJsonOpt, function (err, data) {
  3283. assert.ok(err);
  3284. done();
  3285. });
  3286. });
  3287. });
  3288. });
  3289. group('BucketReplication', function () {
  3290. var prepared = false;
  3291. var repBucket = config.Bucket.replace(/^(.*)(-\d+)$/, '$1-replication$2')
  3292. var repBucketName = repBucket.replace(/(-\d+)$/, '')
  3293. var repRegion = 'ap-chengdu';
  3294. var prepareBucket = function (callback) {
  3295. cos.putBucket({
  3296. Bucket: repBucket,
  3297. Region: repRegion,
  3298. }, function (err, data) {
  3299. cos.putBucketVersioning({
  3300. Bucket: config.Bucket,
  3301. Region: config.Region,
  3302. VersioningConfiguration: {
  3303. Status: 'Enabled'
  3304. }
  3305. }, function (err, data) {
  3306. cos.putBucketVersioning({
  3307. Bucket: repBucket,
  3308. Region: repRegion,
  3309. VersioningConfiguration: {
  3310. Status: 'Enabled'
  3311. }
  3312. }, function (err, data) {
  3313. prepared = true
  3314. callback();
  3315. });
  3316. });
  3317. });
  3318. };
  3319. test('putBucketReplication();getBucketReplication()', function (done, assert) {
  3320. var ruleId = Date.now().toString(36);
  3321. prepareBucket(function () {
  3322. cos.putBucketReplication({
  3323. Bucket: config.Bucket,
  3324. Region: config.Region,
  3325. ReplicationConfiguration: {
  3326. Role: "qcs::cam::uin/10001:uin/10001",
  3327. Rules: [{
  3328. ID: ruleId,
  3329. Status: "Enabled",
  3330. Prefix: "sync/",
  3331. Destination: {
  3332. Bucket: `qcs:id/0:cos:${repRegion}:appid/${AppId}:${repBucketName}`,
  3333. }
  3334. }]
  3335. }
  3336. }, function (err, data) {
  3337. assert.ok(!err);
  3338. cos.getBucketReplication({
  3339. Bucket: config.Bucket,
  3340. Region: config.Region,
  3341. }, function (err, data) {
  3342. assert.ok(data.ReplicationConfiguration.Rules[0].ID === ruleId);
  3343. done();
  3344. });
  3345. });
  3346. });
  3347. });
  3348. test('deleteBucketReplication()', function (done, assert) {
  3349. cos.deleteBucketReplication({
  3350. Bucket: config.Bucket,
  3351. Region: config.Region,
  3352. VersioningConfiguration: {
  3353. Status: 'Suspended'
  3354. }
  3355. }, function (err, data) {
  3356. assert.ok(!err);
  3357. setTimeout(function () {
  3358. cos.getBucketReplication({
  3359. Bucket: config.Bucket,
  3360. Region: config.Region,
  3361. }, function (err, data) {
  3362. assert.ok(err && err.statusCode === 404);
  3363. done();
  3364. });
  3365. }, 2000);
  3366. });
  3367. });
  3368. });
  3369. group('putBucketVersioning(),getBucketVersioning()', function () {
  3370. test('Enabled', function (done, assert) {
  3371. cos.deleteBucketReplication({
  3372. Bucket: config.Bucket,
  3373. Region: config.Region,
  3374. VersioningConfiguration: {
  3375. Status: "Enabled"
  3376. }
  3377. }, function (err, data) {
  3378. cos.putBucketVersioning({
  3379. Bucket: config.Bucket,
  3380. Region: config.Region,
  3381. VersioningConfiguration: {
  3382. Status: "Enabled"
  3383. }
  3384. }, function (err, data) {
  3385. setTimeout(function () {
  3386. cos.getBucketVersioning({
  3387. Bucket: config.Bucket,
  3388. Region: config.Region,
  3389. }, function (err, data) {
  3390. assert.ok(data.VersioningConfiguration.Status === 'Enabled');
  3391. done();
  3392. });
  3393. }, 2000);
  3394. });
  3395. });
  3396. });
  3397. test('Suspended', function (done, assert) {
  3398. cos.putBucketVersioning({
  3399. Bucket: config.Bucket,
  3400. Region: config.Region,
  3401. VersioningConfiguration: {
  3402. Status: 'Suspended'
  3403. }
  3404. }, function (err, data) {
  3405. assert.ok(!err);
  3406. setTimeout(function () {
  3407. cos.getBucketVersioning({
  3408. Bucket: config.Bucket,
  3409. Region: config.Region,
  3410. }, function (err, data) {
  3411. console.log(data.VersioningConfiguration.Status);
  3412. assert.ok(data.VersioningConfiguration.Status === 'Suspended');
  3413. done();
  3414. });
  3415. }, 2000);
  3416. });
  3417. });
  3418. });
  3419. group('BucketOrigin', function () {
  3420. test('putBucketOrigin(),getBucketOrigin()', function (done, assert) {
  3421. var prefix = Date.now().toString(36) + '/';
  3422. cos.putBucketOrigin({
  3423. Bucket: config.Bucket,
  3424. Region: config.Region,
  3425. OriginRule: [{
  3426. OriginType: 'Mirror',
  3427. OriginCondition: {HTTPStatusCode: 404, Prefix: ''},
  3428. OriginParameter: {
  3429. Protocol: 'HTTP',
  3430. FollowQueryString: 'true',
  3431. HttpHeader: {
  3432. NewHttpHeader: {
  3433. Header: [{
  3434. Key: 'a',
  3435. Value: 'a'
  3436. }]
  3437. }
  3438. },
  3439. FollowRedirection: 'true',
  3440. HttpRedirectCode: ['301', '302']
  3441. },
  3442. OriginInfo: {
  3443. HostInfo: {HostName: 'qq.com'},
  3444. FileInfo: {
  3445. PrefixConfiguration: {Prefix: prefix},
  3446. SuffixConfiguration: {Suffix: '.jpg'}
  3447. }
  3448. },
  3449. RulePriority: 1
  3450. }]
  3451. }, function (err, data) {
  3452. assert.ok(!err);
  3453. cos.getBucketOrigin({
  3454. Bucket: config.Bucket,
  3455. Region: config.Region
  3456. }, function (err, data) {
  3457. assert.ok(data.OriginRule[0].OriginInfo.FileInfo.PrefixConfiguration.Prefix === prefix);
  3458. done();
  3459. });
  3460. });
  3461. });
  3462. test('deleteBucketOrigin()', function (done, assert) {
  3463. cos.deleteBucketOrigin({
  3464. Bucket: config.Bucket,
  3465. Region: config.Region
  3466. }, function (err, data) {
  3467. assert.ok(!err);
  3468. setTimeout(function () {
  3469. cos.getBucketOrigin({
  3470. Bucket: config.Bucket,
  3471. Region: config.Region
  3472. }, function (err, data) {
  3473. assert.ok(err);
  3474. done();
  3475. });
  3476. }, 2000);
  3477. });
  3478. });
  3479. });
  3480. group('BucketReferer', function () {
  3481. test('putBucketReferer(),getBucketReferer()', function (done, assert) {
  3482. var conf = {
  3483. Status: 'Enabled',
  3484. RefererType: 'White-List',
  3485. DomainList: {
  3486. Domains: [
  3487. Date.now().toString(36) + '.qq.com',
  3488. '*.qcloud.com',
  3489. ]
  3490. },
  3491. EmptyReferConfiguration: 'Allow',
  3492. };
  3493. cos.putBucketReferer({
  3494. Bucket: config.Bucket,
  3495. Region: config.Region,
  3496. RefererConfiguration: conf
  3497. }, function (err, data) {
  3498. assert.ok(!err);
  3499. setTimeout(function () {
  3500. cos.getBucketReferer({
  3501. Bucket: config.Bucket,
  3502. Region: config.Region
  3503. }, function (err, data) {
  3504. assert.ok(comparePlainObject(conf, data.RefererConfiguration));
  3505. done();
  3506. });
  3507. }, 2000);
  3508. });
  3509. });
  3510. });
  3511. group('restoreObject()', function () {
  3512. test('restoreObject()', function (done, assert) {
  3513. cos.putObject({
  3514. Bucket: config.Bucket,
  3515. Region: config.Region,
  3516. Key: '1.jpg',
  3517. Body: '123',
  3518. StorageClass: 'ARCHIVE'
  3519. }, function (err, data) {
  3520. assert.ok(!err);
  3521. cos.restoreObject({
  3522. Bucket: config.Bucket,
  3523. Region: config.Region,
  3524. Key: '1.jpg',
  3525. RestoreRequest: {
  3526. Days: 1,
  3527. CASJobParameters: {
  3528. Tier: 'Expedited'
  3529. }
  3530. },
  3531. }, function (err, data) {
  3532. assert.ok(data && Math.floor(data.statusCode / 100) === 2);
  3533. done();
  3534. });
  3535. });
  3536. });
  3537. });
  3538. group('uploadFile()', function () {
  3539. // 高级上传
  3540. test('uploadFile() 高级上传', function (done, assert) {
  3541. var filename = '3m.zip';
  3542. var blob = util.createFile({size: 1024 * 1024 * 3});
  3543. cos.uploadFile({
  3544. Bucket: config.Bucket,
  3545. Region: config.Region,
  3546. Key: filename,
  3547. Body: blob,
  3548. }, function (err, data) {
  3549. console.log(data);
  3550. assert.ok(!err);
  3551. done();
  3552. });
  3553. });
  3554. test('uploadFile() 高级上传内容为空', function (done, assert) {
  3555. var filename = '3m.zip';
  3556. cos.uploadFile({
  3557. Bucket: config.Bucket,
  3558. Region: config.Region,
  3559. Key: filename,
  3560. Body: '',
  3561. }, function (err, data) {
  3562. assert.ok(!err);
  3563. done();
  3564. });
  3565. });
  3566. test('uploadFile() 高级上传 大于5mb则分块上传', function (done, assert) {
  3567. var filename = '3m.zip';
  3568. var blob = util.createFile({size: 1024 * 1024 * 3});
  3569. cos.uploadFile({
  3570. Bucket: config.Bucket,
  3571. Region: config.Region,
  3572. Key: filename,
  3573. Body: blob,
  3574. SliceSize: 1024 * 1024 * 5,
  3575. }, function (err, data) {
  3576. assert.ok(!err);
  3577. done();
  3578. });
  3579. });
  3580. });
  3581. group('uploadFiles()', function () {
  3582. test('uploadFiles()', function (done, assert) {
  3583. var filename = '1.zip';
  3584. cos.uploadFiles({
  3585. files: [{
  3586. Bucket: config.Bucket,
  3587. Region: config.Region,
  3588. Key: filename,
  3589. Body: '123456',
  3590. }],
  3591. }, function (err, data) {
  3592. assert.ok(!data.files.error);
  3593. done();
  3594. });
  3595. });
  3596. });
  3597. group('multipartAbort()', function () {
  3598. test('multipartAbort()', function (done, assert) {
  3599. var Key = '1.jpg'
  3600. cos.multipartInit({
  3601. Bucket: config.Bucket,
  3602. Region: config.Region,
  3603. Key: Key,
  3604. }, function (err, data) {
  3605. assert.ok(!err);
  3606. var UploadId = data.UploadId;
  3607. cos.multipartAbort({
  3608. Bucket: config.Bucket,
  3609. Region: config.Region,
  3610. Key: Key,
  3611. UploadId: UploadId,
  3612. }, function (err, data) {
  3613. assert.ok(!err);
  3614. cos.multipartListPart({
  3615. Bucket: config.Bucket,
  3616. Region: config.Region,
  3617. Key: Key,
  3618. UploadId: UploadId,
  3619. }, function (err, data) {
  3620. assert.ok(err);
  3621. done();
  3622. });
  3623. });
  3624. });
  3625. });
  3626. });
  3627. group('sliceUploadFile() 续传', function () {
  3628. test('multipartAbort()', function (done, assert) {
  3629. var Key = '3.zip'
  3630. cos.multipartInit({
  3631. Bucket: config.Bucket,
  3632. Region: config.Region,
  3633. Key: Key,
  3634. }, function (err, data) {
  3635. assert.ok(!err);
  3636. var UploadId = data.UploadId;
  3637. cos.multipartUpload({
  3638. Bucket: config.Bucket,
  3639. Region: config.Region,
  3640. Key: Key,
  3641. UploadId: UploadId,
  3642. PartNumber: 1,
  3643. Body: util.createFile({size: 1024 * 1024}),
  3644. }, function (err, data) {
  3645. assert.ok(!err);
  3646. cos.sliceUploadFile({
  3647. Bucket: config.Bucket,
  3648. Region: config.Region,
  3649. Key: Key,
  3650. Body: util.createFile({size: 1024 * 1024 * 3}),
  3651. ChunkSize: 1024 * 1024,
  3652. }, function (err, data) {
  3653. assert.ok(data);
  3654. done();
  3655. });
  3656. });
  3657. });
  3658. });
  3659. });
  3660. group('appendObject', function () {
  3661. test('appendObject()', function (done, assert) {
  3662. cos.headObject({
  3663. Bucket: config.Bucket, // Bucket 格式:test-1250000000
  3664. Region: config.Region,
  3665. Key: 'append.txt', /* 必须 */
  3666. }, function(err, data) {
  3667. assert.ok(!err);
  3668. if (err) return console.log(err);
  3669. // 首先取到要追加的文件当前长度,即需要上送的Position
  3670. var position = data.headers['content-length'];
  3671. cos.appendObject({
  3672. Bucket: config.Bucket, // Bucket 格式:test-1250000000
  3673. Region: config.Region,
  3674. Key: 'append.txt', /* 必须 */
  3675. Body: '66666',
  3676. Position: position,
  3677. },
  3678. function(err, data) {
  3679. assert.ok(!err);
  3680. done();
  3681. })
  3682. });
  3683. });
  3684. });
  3685. group('数据万象', function () {
  3686. test('describeMediaBuckets()', function (done, assert) {
  3687. var host = 'ci.' + config.Region + '.myqcloud.com';
  3688. var url = 'https://' + host + '/mediabucket';
  3689. cos.request({
  3690. Bucket: config.Bucket,
  3691. Region: config.Region,
  3692. Method: 'GET',
  3693. Key: 'mediabucket', /** 固定值,必须 */
  3694. Url: url,
  3695. Query: {
  3696. pageNumber: '1', /** 第几页,非必须 */
  3697. pageSize: '10', /** 每页个数,非必须 */
  3698. // regions: 'ap-chengdu', /** 地域信息,例如'ap-beijing',支持多个值用逗号分隔如'ap-shanghai,ap-beijing',非必须 */
  3699. // bucketNames: 'test-1250000000', /** 存储桶名称,精确搜索,例如'test-1250000000',支持多个值用逗号分隔如'test1-1250000000,test2-1250000000',非必须 */
  3700. // bucketName: 'test', /** 存储桶名称前缀,前缀搜索,例如'test',支持多个值用逗号分隔如'test1,test2',非必须 */
  3701. }
  3702. }, function (err, data) {
  3703. assert.ok(!err);
  3704. done();
  3705. });
  3706. });
  3707. test('getMediaInfo()', function (done, assert) {
  3708. cos.request({
  3709. Bucket: config.Bucket,
  3710. Region: config.Region,
  3711. Method: 'GET',
  3712. Key: 'test.mp4',
  3713. Query: {
  3714. 'ci-process': 'videoinfo' /** 固定值,必须 */
  3715. }
  3716. }, function (err, data) {
  3717. assert.ok(!err);
  3718. done();
  3719. });
  3720. });
  3721. test('getSnapshot()', function (done, assert) {
  3722. cos.request({
  3723. Bucket: config.Bucket,
  3724. Region: config.Region,
  3725. Method: 'GET',
  3726. Key: 'test.mp4',
  3727. Query: {
  3728. 'ci-process': 'snapshot', /** 固定值,必须 */
  3729. time: 1, /** 截图的时间点,单位为秒,必须 */
  3730. // width: 0, /** 截图的宽,非必须 */
  3731. // height: 0, /** 截图的高,非必须 */
  3732. // format: 'jpg', /** 截图的格式,支持 jpg 和 png,默认 jpg,非必须 */
  3733. // rotate: 'auto', /** 图片旋转方式,默认为'auto',非必须 */
  3734. // mode: 'exactframe', /** 截帧方式,默认为'exactframe',非必须 */
  3735. },
  3736. RawBody: true,
  3737. },
  3738. function(err, data){
  3739. assert.ok(!err);
  3740. done();
  3741. });
  3742. });
  3743. });