util.js 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756
  1. 'use strict';
  2. var md5 = require('../lib/md5');
  3. var CryptoJS = require('../lib/crypto');
  4. var xml2json = require('../lib/xml2json');
  5. var json2xml = require('../lib/json2xml');
  6. function camSafeUrlEncode(str) {
  7. return encodeURIComponent(str)
  8. .replace(/!/g, '%21')
  9. .replace(/'/g, '%27')
  10. .replace(/\(/g, '%28')
  11. .replace(/\)/g, '%29')
  12. .replace(/\*/g, '%2A');
  13. }
  14. function getObjectKeys(obj, forKey) {
  15. var list = [];
  16. for (var key in obj) {
  17. if (obj.hasOwnProperty(key)) {
  18. list.push(forKey ? camSafeUrlEncode(key).toLowerCase() : key);
  19. }
  20. }
  21. return list.sort(function (a, b) {
  22. a = a.toLowerCase();
  23. b = b.toLowerCase();
  24. return a === b ? 0 : (a > b ? 1 : -1);
  25. });
  26. };
  27. /**
  28. * obj转为string
  29. * @param {Object} obj 需要转的对象,必须
  30. * @param {Boolean} lowerCaseKey key是否转为小写,默认false,非必须
  31. * @return {String} data 返回字符串
  32. */
  33. var obj2str = function (obj, lowerCaseKey) {
  34. var i, key, val;
  35. var list = [];
  36. var keyList = getObjectKeys(obj);
  37. for (i = 0; i < keyList.length; i++) {
  38. key = keyList[i];
  39. val = (obj[key] === undefined || obj[key] === null) ? '' : ('' + obj[key]);
  40. key = lowerCaseKey? camSafeUrlEncode(key).toLowerCase() : camSafeUrlEncode(key);
  41. val = camSafeUrlEncode(val) || '';
  42. list.push(key + '=' + val)
  43. }
  44. return list.join('&');
  45. };
  46. // 可以签入签名的headers
  47. var signHeaders = ['content-disposition', 'content-encoding', 'content-length', 'content-md5',
  48. 'expect', 'host', 'if-match', 'if-modified-since', 'if-none-match', 'if-unmodified-since',
  49. 'origin', 'range', 'response-cache-control', 'response-content-disposition', 'response-content-encoding',
  50. 'response-content-language', 'response-content-type', 'response-expires', 'transfer-encoding', 'versionid'];
  51. var getSignHeaderObj = function (headers) {
  52. var signHeaderObj = {};
  53. for (var i in headers) {
  54. var key = i.toLowerCase();
  55. if (key.indexOf('x-cos-') > -1 || signHeaders.indexOf(key) > -1) {
  56. signHeaderObj[i] = headers[i];
  57. }
  58. }
  59. return signHeaderObj;
  60. }
  61. //测试用的key后面可以去掉
  62. var getAuth = function (opt) {
  63. opt = opt || {};
  64. var SecretId = opt.SecretId;
  65. var SecretKey = opt.SecretKey;
  66. var KeyTime = opt.KeyTime;
  67. var method = (opt.method || opt.Method || 'get').toLowerCase();
  68. var queryParams = clone(opt.Query || opt.params || {});
  69. var headers = getSignHeaderObj(clone(opt.Headers || opt.headers || {}));
  70. var Key = opt.Key || '';
  71. var pathname;
  72. if (opt.UseRawKey) {
  73. pathname = opt.Pathname || opt.pathname || '/' + Key;
  74. } else {
  75. pathname = opt.Pathname || opt.pathname || Key;
  76. pathname.indexOf('/') !== 0 && (pathname = '/' + pathname);
  77. }
  78. // ForceSignHost明确传入false才不加入host签名
  79. var forceSignHost = opt.ForceSignHost === false ? false : true;
  80. // 如果有传入存储桶且需要强制签名,那么签名默认加 Host 参与计算,避免跨桶访问
  81. if (!headers.Host && !headers.host && opt.Bucket && opt.Region && forceSignHost) headers.Host = opt.Bucket + '.cos.' + opt.Region + '.myqcloud.com';
  82. if (!SecretId) throw new Error('missing param SecretId');
  83. if (!SecretKey) throw new Error('missing param SecretKey');
  84. // 签名有效起止时间
  85. var now = Math.round(getSkewTime(opt.SystemClockOffset) / 1000) - 1;
  86. var exp = now;
  87. var Expires = opt.Expires || opt.expires;
  88. if (Expires === undefined) {
  89. exp += 900; // 签名过期时间为当前 + 900s
  90. } else {
  91. exp += (Expires * 1) || 0;
  92. }
  93. // 要用到的 Authorization 参数列表
  94. var qSignAlgorithm = 'sha1';
  95. var qAk = SecretId;
  96. var qSignTime = KeyTime || now + ';' + exp;
  97. var qKeyTime = KeyTime || now + ';' + exp;
  98. var qHeaderList = getObjectKeys(headers, true).join(';').toLowerCase();
  99. var qUrlParamList = getObjectKeys(queryParams, true).join(';').toLowerCase();
  100. // 签名算法说明文档:https://www.qcloud.com/document/product/436/7778
  101. // 步骤一:计算 SignKey
  102. var signKey = CryptoJS.HmacSHA1(qKeyTime, SecretKey).toString();
  103. // 步骤二:构成 FormatString
  104. var formatString = [method, pathname, util.obj2str(queryParams, true), util.obj2str(headers, true), ''].join('\n');
  105. // 步骤三:计算 StringToSign
  106. var stringToSign = ['sha1', qSignTime, CryptoJS.SHA1(formatString).toString(), ''].join('\n');
  107. // 步骤四:计算 Signature
  108. var qSignature = CryptoJS.HmacSHA1(stringToSign, signKey).toString();
  109. // 步骤五:构造 Authorization
  110. var authorization = [
  111. 'q-sign-algorithm=' + qSignAlgorithm,
  112. 'q-ak=' + qAk,
  113. 'q-sign-time=' + qSignTime,
  114. 'q-key-time=' + qKeyTime,
  115. 'q-header-list=' + qHeaderList,
  116. 'q-url-param-list=' + qUrlParamList,
  117. 'q-signature=' + qSignature
  118. ].join('&');
  119. return authorization;
  120. };
  121. var readIntBE = function (chunk, size, offset) {
  122. var bytes = size / 8;
  123. var buf = chunk.slice(offset, offset + bytes);
  124. new Uint8Array(buf).reverse();
  125. return new ({8: Uint8Array, 16: Uint16Array, 32: Uint32Array})[size](buf)[0];
  126. };
  127. var buf2str = function (chunk, start, end, isUtf8) {
  128. var buf = chunk.slice(start, end);
  129. var str = '';
  130. new Uint8Array(buf).forEach(function (charCode) {
  131. str += String.fromCharCode(charCode)
  132. });
  133. if (isUtf8) str = decodeURIComponent(escape(str));
  134. return str;
  135. };
  136. var parseSelectPayload = function (chunk) {
  137. var header = {};
  138. var body = buf2str(chunk);
  139. var result = {records:[]};
  140. while (chunk.byteLength) {
  141. var totalLength = readIntBE(chunk, 32, 0);
  142. var headerLength = readIntBE(chunk, 32, 4);
  143. var payloadRestLength = totalLength - headerLength - 16;
  144. var offset = 0;
  145. var content;
  146. chunk = chunk.slice(12);
  147. // 获取 Message 的 header 信息
  148. while (offset < headerLength) {
  149. var headerNameLength = readIntBE(chunk, 8, offset);
  150. var headerName = buf2str(chunk, offset + 1, offset + 1 + headerNameLength);
  151. var headerValueLength = readIntBE(chunk, 16, offset + headerNameLength + 2);
  152. var headerValue = buf2str(chunk, offset + headerNameLength + 4, offset + headerNameLength + 4 + headerValueLength);
  153. header[headerName] = headerValue;
  154. offset += headerNameLength + 4 + headerValueLength;
  155. }
  156. if (header[':event-type'] === 'Records') {
  157. content = buf2str(chunk, offset, offset + payloadRestLength, true);
  158. result.records.push(content);
  159. } else if (header[':event-type'] === 'Stats') {
  160. content = buf2str(chunk, offset, offset + payloadRestLength, true);
  161. result.stats = util.xml2json(content).Stats;
  162. } else if (header[':event-type'] === 'error') {
  163. var errCode = header[':error-code'];
  164. var errMessage = header[':error-message'];
  165. var err = new Error(errMessage);
  166. err.message = errMessage;
  167. err.name = err.code = errCode;
  168. result.error = err;
  169. } else if (['Progress', 'Continuation', 'End'].includes(header[':event-type'])) {
  170. // do nothing
  171. }
  172. chunk = chunk.slice(offset + payloadRestLength + 4);
  173. }
  174. return {
  175. payload: result.records.join(''),
  176. body: body,
  177. };
  178. };
  179. var getSourceParams = function (source) {
  180. var parser = this.options.CopySourceParser;
  181. if (parser) return parser(source);
  182. var m = source.match(/^([^.]+-\d+)\.cos(v6|-cdc)?\.([^.]+)\.myqcloud\.com\/(.+)$/);
  183. if (!m) return null;
  184. return { Bucket: m[1], Region: m[3], Key: m[4] };
  185. };
  186. var noop = function () {
  187. };
  188. // 清除对象里值为的 undefined 或 null 的属性
  189. var clearKey = function (obj) {
  190. var retObj = {};
  191. for (var key in obj) {
  192. if (obj.hasOwnProperty(key) && obj[key] !== undefined && obj[key] !== null) {
  193. retObj[key] = obj[key];
  194. }
  195. }
  196. return retObj;
  197. };
  198. var readAsBinaryString = function (blob, callback) {
  199. var readFun;
  200. var fr = new FileReader();
  201. if (FileReader.prototype.readAsBinaryString) {
  202. readFun = FileReader.prototype.readAsBinaryString;
  203. fr.onload = function () {
  204. callback(this.result);
  205. };
  206. } else if (FileReader.prototype.readAsArrayBuffer) { // 在 ie11 添加 readAsBinaryString 兼容
  207. readFun = function (fileData) {
  208. var binary = "";
  209. var pt = this;
  210. var reader = new FileReader();
  211. reader.onload = function (e) {
  212. var bytes = new Uint8Array(reader.result);
  213. var length = bytes.byteLength;
  214. for (var i = 0; i < length; i++) {
  215. binary += String.fromCharCode(bytes[i]);
  216. }
  217. callback(binary);
  218. };
  219. reader.readAsArrayBuffer(fileData);
  220. };
  221. } else {
  222. console.error('FileReader not support readAsBinaryString');
  223. }
  224. readFun.call(fr, blob);
  225. };
  226. var fileSliceNeedCopy = (function () {
  227. var compareVersion = function(a, b) {
  228. a = a.split('.');
  229. b = b.split('.');
  230. for (var i = 0; i < b.length; i++) {
  231. if (a[i] !== b[i]) {
  232. return parseInt(a[i]) > parseInt(b[i]) ? 1 : -1;
  233. }
  234. }
  235. return 0;
  236. };
  237. var check = function (ua) {
  238. if (!ua) return false;
  239. var ChromeVersion = (ua.match(/Chrome\/([.\d]+)/) || [])[1];
  240. var QBCoreVersion = (ua.match(/QBCore\/([.\d]+)/) || [])[1];
  241. var QQBrowserVersion = (ua.match(/QQBrowser\/([.\d]+)/) || [])[1];
  242. var need = ChromeVersion && compareVersion(ChromeVersion, '53.0.2785.116') < 0
  243. && QBCoreVersion && compareVersion(QBCoreVersion, '3.53.991.400') < 0
  244. && QQBrowserVersion && compareVersion(QQBrowserVersion, '9.0.2524.400') <= 0 || false;
  245. return need;
  246. };
  247. return check(typeof navigator !== 'undefined' && navigator.userAgent);
  248. })();
  249. // 获取文件分片
  250. var fileSlice = function (file, start, end, isUseToUpload, callback) {
  251. var blob;
  252. if (file.slice) {
  253. blob = file.slice(start, end);
  254. } else if (file.mozSlice) {
  255. blob = file.mozSlice(start, end);
  256. } else if (file.webkitSlice) {
  257. blob = file.webkitSlice(start, end);
  258. }
  259. if (isUseToUpload && fileSliceNeedCopy) {
  260. var reader = new FileReader();
  261. reader.onload = function (e) {
  262. blob = null;
  263. callback(new Blob([reader.result]));
  264. };
  265. reader.readAsArrayBuffer(blob);
  266. } else {
  267. callback(blob);
  268. }
  269. };
  270. // 获取文件内容的 MD5
  271. var getBodyMd5 = function (UploadCheckContentMd5, Body, callback, onProgress) {
  272. callback = callback || noop;
  273. if (UploadCheckContentMd5) {
  274. if (typeof Body === 'string') {
  275. callback(util.md5(Body, true));
  276. } else if (Blob && Body instanceof Blob) {
  277. util.getFileMd5(Body, function (err, md5) {
  278. callback(md5);
  279. }, onProgress);
  280. } else {
  281. callback();
  282. }
  283. } else {
  284. callback();
  285. }
  286. };
  287. // 获取文件 md5 值
  288. var md5ChunkSize = 1024 * 1024;
  289. var getFileMd5 = function (blob, callback, onProgress) {
  290. var size = blob.size;
  291. var loaded = 0;
  292. var md5ctx = md5.getCtx();
  293. var next = function (start) {
  294. if (start >= size) {
  295. var hash = md5ctx.digest('hex');
  296. callback(null, hash);
  297. return;
  298. }
  299. var end = Math.min(size, start + md5ChunkSize);
  300. util.fileSlice(blob, start, end, false, function (chunk) {
  301. readAsBinaryString(chunk, function (content) {
  302. chunk = null;
  303. md5ctx = md5ctx.update(content, true);
  304. loaded += content.length;
  305. content = null;
  306. if (onProgress) onProgress({loaded: loaded, total: size, percent: Math.round(loaded / size * 10000) / 10000});
  307. next(start + md5ChunkSize);
  308. });
  309. });
  310. };
  311. next(0);
  312. };
  313. function clone(obj) {
  314. return map(obj, function (v) {
  315. return typeof v === 'object' && v !== null ? clone(v) : v;
  316. });
  317. }
  318. function attr(obj, name, defaultValue) {
  319. return obj && name in obj ? obj[name] : defaultValue;
  320. }
  321. function extend(target, source) {
  322. each(source, function (val, key) {
  323. target[key] = source[key];
  324. });
  325. return target;
  326. }
  327. function isArray(arr) {
  328. return arr instanceof Array;
  329. }
  330. function isInArray(arr, item) {
  331. var flag = false;
  332. for (var i = 0; i < arr.length; i++) {
  333. if (item === arr[i]) {
  334. flag = true;
  335. break;
  336. }
  337. }
  338. return flag;
  339. }
  340. function makeArray(arr) {
  341. return isArray(arr) ? arr : [arr];
  342. }
  343. function each(obj, fn) {
  344. for (var i in obj) {
  345. if (obj.hasOwnProperty(i)) {
  346. fn(obj[i], i);
  347. }
  348. }
  349. }
  350. function map(obj, fn) {
  351. var o = isArray(obj) ? [] : {};
  352. for (var i in obj) {
  353. if (obj.hasOwnProperty(i)) {
  354. o[i] = fn(obj[i], i);
  355. }
  356. }
  357. return o;
  358. }
  359. function filter(obj, fn) {
  360. var iaArr = isArray(obj);
  361. var o = iaArr ? [] : {};
  362. for (var i in obj) {
  363. if (obj.hasOwnProperty(i)) {
  364. if (fn(obj[i], i)) {
  365. if (iaArr) {
  366. o.push(obj[i]);
  367. } else {
  368. o[i] = obj[i];
  369. }
  370. }
  371. }
  372. }
  373. return o;
  374. }
  375. var binaryBase64 = function (str) {
  376. var i, len, char, res = '';
  377. for (i = 0, len = str.length / 2; i < len; i++) {
  378. char = parseInt(str[i * 2] + str[i * 2 + 1], 16);
  379. res += String.fromCharCode(char);
  380. }
  381. return btoa(res);
  382. };
  383. var uuid = function () {
  384. var S4 = function () {
  385. return (((1 + Math.random()) * 0x10000) | 0).toString(16).substring(1);
  386. };
  387. return (S4() + S4() + "-" + S4() + "-" + S4() + "-" + S4() + "-" + S4() + S4() + S4());
  388. };
  389. var hasMissingParams = function (apiName, params) {
  390. var Bucket = params.Bucket;
  391. var Region = params.Region;
  392. var Key = params.Key;
  393. var Domain = this.options.Domain;
  394. var checkBucket = !Domain || typeof Domain === 'string' && Domain.indexOf('{Bucket}') > -1;
  395. var checkRegion = !Domain || typeof Domain === 'string' && Domain.indexOf('{Region}') > -1;
  396. if (apiName.indexOf('Bucket') > -1 || apiName === 'deleteMultipleObject' || apiName === 'multipartList' || apiName === 'listObjectVersions') {
  397. if (checkBucket && !Bucket) return 'Bucket';
  398. if (checkRegion && !Region) return 'Region';
  399. } else if (apiName.indexOf('Object') > -1 || apiName.indexOf('multipart') > -1 || apiName === 'sliceUploadFile' || apiName === 'abortUploadTask') {
  400. if (checkBucket && !Bucket) return 'Bucket';
  401. if (checkRegion && !Region) return 'Region';
  402. if (!Key) return 'Key';
  403. }
  404. return false;
  405. };
  406. var formatParams = function (apiName, params) {
  407. // 复制参数对象
  408. params = extend({}, params);
  409. // 统一处理 Headers
  410. if (apiName !== 'getAuth' && apiName !== 'getV4Auth' && apiName !== 'getObjectUrl') {
  411. var Headers = params.Headers || {};
  412. if (params && typeof params === 'object') {
  413. (function () {
  414. for (var key in params) {
  415. if (params.hasOwnProperty(key) && key.indexOf('x-cos-') > -1) {
  416. Headers[key] = params[key];
  417. }
  418. }
  419. })();
  420. var headerMap = {
  421. // params headers
  422. 'x-cos-mfa': 'MFA',
  423. 'Content-MD5': 'ContentMD5',
  424. 'Content-Length': 'ContentLength',
  425. 'Content-Type': 'ContentType',
  426. 'Expect': 'Expect',
  427. 'Expires': 'Expires',
  428. 'Cache-Control': 'CacheControl',
  429. 'Content-Disposition': 'ContentDisposition',
  430. 'Content-Encoding': 'ContentEncoding',
  431. 'Range': 'Range',
  432. 'If-Modified-Since': 'IfModifiedSince',
  433. 'If-Unmodified-Since': 'IfUnmodifiedSince',
  434. 'If-Match': 'IfMatch',
  435. 'If-None-Match': 'IfNoneMatch',
  436. 'x-cos-copy-source': 'CopySource',
  437. 'x-cos-copy-source-Range': 'CopySourceRange',
  438. 'x-cos-metadata-directive': 'MetadataDirective',
  439. 'x-cos-copy-source-If-Modified-Since': 'CopySourceIfModifiedSince',
  440. 'x-cos-copy-source-If-Unmodified-Since': 'CopySourceIfUnmodifiedSince',
  441. 'x-cos-copy-source-If-Match': 'CopySourceIfMatch',
  442. 'x-cos-copy-source-If-None-Match': 'CopySourceIfNoneMatch',
  443. 'x-cos-acl': 'ACL',
  444. 'x-cos-grant-read': 'GrantRead',
  445. 'x-cos-grant-write': 'GrantWrite',
  446. 'x-cos-grant-full-control': 'GrantFullControl',
  447. 'x-cos-grant-read-acp': 'GrantReadAcp',
  448. 'x-cos-grant-write-acp': 'GrantWriteAcp',
  449. 'x-cos-storage-class': 'StorageClass',
  450. 'x-cos-traffic-limit': 'TrafficLimit',
  451. 'x-cos-mime-limit': 'MimeLimit',
  452. // SSE-C
  453. 'x-cos-server-side-encryption-customer-algorithm': 'SSECustomerAlgorithm',
  454. 'x-cos-server-side-encryption-customer-key': 'SSECustomerKey',
  455. 'x-cos-server-side-encryption-customer-key-MD5': 'SSECustomerKeyMD5',
  456. // SSE-COS、SSE-KMS
  457. 'x-cos-server-side-encryption': 'ServerSideEncryption',
  458. 'x-cos-server-side-encryption-cos-kms-key-id': 'SSEKMSKeyId',
  459. 'x-cos-server-side-encryption-context': 'SSEContext',
  460. };
  461. util.each(headerMap, function (paramKey, headerKey) {
  462. if (params[paramKey] !== undefined) {
  463. Headers[headerKey] = params[paramKey];
  464. }
  465. });
  466. params.Headers = clearKey(Headers);
  467. }
  468. }
  469. return params;
  470. };
  471. var apiWrapper = function (apiName, apiFn) {
  472. return function (params, callback) {
  473. var self = this;
  474. // 处理参数
  475. if (typeof params === 'function') {
  476. callback = params;
  477. params = {};
  478. }
  479. // 整理参数格式
  480. params = formatParams(apiName, params);
  481. // 代理回调函数
  482. var formatResult = function (result) {
  483. if (result && result.headers) {
  484. result.headers['x-cos-request-id'] && (result.RequestId = result.headers['x-cos-request-id']);
  485. result.headers['x-ci-request-id'] && (result.RequestId = result.headers['x-ci-request-id']);
  486. result.headers['x-cos-version-id'] && (result.VersionId = result.headers['x-cos-version-id']);
  487. result.headers['x-cos-delete-marker'] && (result.DeleteMarker = result.headers['x-cos-delete-marker']);
  488. }
  489. return result;
  490. };
  491. var _callback = function (err, data) {
  492. callback && callback(formatResult(err), formatResult(data));
  493. };
  494. var checkParams = function () {
  495. if (apiName !== 'getService' && apiName !== 'abortUploadTask') {
  496. // 判断参数是否完整
  497. var missingResult = hasMissingParams.call(self, apiName, params)
  498. if (missingResult) {
  499. return 'missing param ' + missingResult;
  500. }
  501. // 判断 region 格式
  502. if (params.Region) {
  503. if (self.options.CompatibilityMode) {
  504. if (!/^([a-z\d-.]+)$/.test(params.Region)) {
  505. return 'Region format error.';
  506. }
  507. } else {
  508. if (params.Region.indexOf('cos.') > -1) {
  509. return 'param Region should not be start with "cos."';
  510. } else if (!/^([a-z\d-]+)$/.test(params.Region)) {
  511. return 'Region format error.';
  512. }
  513. }
  514. // 判断 region 格式
  515. if (!self.options.CompatibilityMode
  516. && params.Region.indexOf('-') === -1
  517. && params.Region !== 'yfb'
  518. && params.Region !== 'default'
  519. && params.Region !== 'accelerate' ) {
  520. console.warn('warning: param Region format error, find help here: https://cloud.tencent.com/document/product/436/6224');
  521. }
  522. }
  523. // 兼容不带 AppId 的 Bucket
  524. if (params.Bucket) {
  525. if (!/^([a-z\d-]+)-(\d+)$/.test(params.Bucket)) {
  526. if (params.AppId) {
  527. params.Bucket = params.Bucket + '-' + params.AppId;
  528. } else if (self.options.AppId) {
  529. params.Bucket = params.Bucket + '-' + self.options.AppId;
  530. } else {
  531. return 'Bucket should format as "test-1250000000".';
  532. }
  533. }
  534. if (params.AppId) {
  535. console.warn('warning: AppId has been deprecated, Please put it at the end of parameter Bucket(E.g Bucket:"test-1250000000" ).');
  536. delete params.AppId;
  537. }
  538. }
  539. // 如果 Key 是 / 开头,强制去掉第一个 /
  540. if (!self.options.UseRawKey && params.Key && params.Key.substr(0, 1) === '/') {
  541. params.Key = params.Key.substr(1);
  542. }
  543. }
  544. };
  545. var errMsg = checkParams();
  546. var isSync = apiName === 'getAuth' || apiName === 'getObjectUrl';
  547. if (typeof Promise === 'function' && !isSync && !callback) {
  548. return new Promise(function (resolve, reject) {
  549. callback = function (err, data) {
  550. err ? reject(err) : resolve(data);
  551. };
  552. if (errMsg) return _callback(util.error(new Error(errMsg)));
  553. apiFn.call(self, params, _callback);
  554. });
  555. } else {
  556. if (errMsg) return _callback(util.error(new Error(errMsg)));
  557. var res = apiFn.call(self, params, _callback);
  558. if (isSync) return res;
  559. }
  560. }
  561. };
  562. var throttleOnProgress = function (total, onProgress) {
  563. var self = this;
  564. var size0 = 0;
  565. var size1 = 0;
  566. var time0 = Date.now();
  567. var time1;
  568. var timer;
  569. function update() {
  570. timer = 0;
  571. if (onProgress && (typeof onProgress === 'function')) {
  572. time1 = Date.now();
  573. var speed = Math.max(0, Math.round((size1 - size0) / ((time1 - time0) / 1000) * 100) / 100) || 0;
  574. var percent;
  575. if (size1 === 0 && total === 0) {
  576. percent = 1;
  577. } else {
  578. percent = Math.floor(size1 / total * 100) / 100 || 0;
  579. }
  580. time0 = time1;
  581. size0 = size1;
  582. try {
  583. onProgress({loaded: size1, total: total, speed: speed, percent: percent});
  584. } catch (e) {
  585. }
  586. }
  587. }
  588. return function (info, immediately) {
  589. if (info) {
  590. size1 = info.loaded;
  591. total = info.total;
  592. }
  593. if (immediately) {
  594. clearTimeout(timer);
  595. update();
  596. } else {
  597. if (timer) return;
  598. timer = setTimeout(update, self.options.ProgressInterval);
  599. }
  600. };
  601. };
  602. var getFileSize = function (api, params, callback) {
  603. var size;
  604. if (typeof params.Body === 'string') {
  605. params.Body = new Blob([params.Body], {type: 'text/plain'});
  606. } else if (params.Body instanceof ArrayBuffer) {
  607. params.Body = new Blob([params.Body]);
  608. }
  609. if ((params.Body && (params.Body instanceof Blob || params.Body.toString() === '[object File]' || params.Body.toString() === '[object Blob]'))) {
  610. size = params.Body.size;
  611. } else {
  612. callback(util.error(new Error('params body format error, Only allow File|Blob|String.')));
  613. return;
  614. }
  615. params.ContentLength = size;
  616. callback(null, size);
  617. };
  618. // 获取调正的时间戳
  619. var getSkewTime = function (offset) {
  620. return Date.now() + (offset || 0);
  621. };
  622. var error = function (err, opt) {
  623. var sourceErr = err;
  624. err.message = err.message || null;
  625. if (typeof opt === 'string') {
  626. err.error = opt;
  627. err.message = opt;
  628. } else if (typeof opt === 'object' && opt !== null) {
  629. extend(err, opt);
  630. if (opt.code || opt.name) err.code = opt.code || opt.name;
  631. if (opt.message) err.message = opt.message;
  632. if (opt.stack) err.stack = opt.stack;
  633. }
  634. if (typeof Object.defineProperty === 'function') {
  635. Object.defineProperty(err, 'name', {writable: true, enumerable: false});
  636. Object.defineProperty(err, 'message', {enumerable: true});
  637. }
  638. err.name = opt && opt.name || err.name || err.code || 'Error';
  639. if (!err.code) err.code = err.name;
  640. if (!err.error) err.error = clone(sourceErr); // 兼容老的错误格式
  641. return err;
  642. }
  643. var isNode = function () {
  644. return typeof window !== 'object' && typeof process === 'object' && typeof require === 'function';
  645. }
  646. var isCIHost = function(url) {
  647. return /^https?:\/\/([^/]+\.)?ci\.[^/]+/.test(url);
  648. }
  649. var util = {
  650. noop: noop,
  651. formatParams: formatParams,
  652. apiWrapper: apiWrapper,
  653. xml2json: xml2json,
  654. json2xml: json2xml,
  655. md5: md5,
  656. clearKey: clearKey,
  657. fileSlice: fileSlice,
  658. getBodyMd5: getBodyMd5,
  659. getFileMd5: getFileMd5,
  660. binaryBase64: binaryBase64,
  661. extend: extend,
  662. isArray: isArray,
  663. isInArray: isInArray,
  664. makeArray: makeArray,
  665. each: each,
  666. map: map,
  667. filter: filter,
  668. clone: clone,
  669. attr: attr,
  670. uuid: uuid,
  671. camSafeUrlEncode: camSafeUrlEncode,
  672. throttleOnProgress: throttleOnProgress,
  673. getFileSize: getFileSize,
  674. getSkewTime: getSkewTime,
  675. error: error,
  676. obj2str: obj2str,
  677. getAuth: getAuth,
  678. parseSelectPayload: parseSelectPayload,
  679. getSourceParams: getSourceParams,
  680. isBrowser: true,
  681. isNode: isNode,
  682. isCIHost: isCIHost,
  683. };
  684. module.exports = util;