util.js 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860
  1. 'use strict';
  2. var md5 = require('../lib/md5');
  3. var CryptoJS = require('../lib/crypto');
  4. var base64 = require('../lib/base64');
  5. var btoa = base64.btoa;
  6. var wxfs = wx.getFileSystemManager();
  7. var Tracker = require('./tracker');
  8. var { XMLParser, XMLBuilder } = require('fast-xml-parser');
  9. var xmlParser = new XMLParser({
  10. ignoreDeclaration: true, // 忽略 XML 声明
  11. ignoreAttributes: true, // 忽略属性
  12. parseTagValue: false, // 关闭自动解析
  13. });
  14. var xmlBuilder = new XMLBuilder();
  15. // XML 对象转 JSON 对象
  16. var xml2json = function (bodyStr) {
  17. var d = xmlParser.parse(bodyStr);
  18. return d;
  19. };
  20. // JSON 对象转 XML 对象
  21. var json2xml = function (json) {
  22. var xml = xmlBuilder.build(json);
  23. return xml;
  24. };
  25. function camSafeUrlEncode(str) {
  26. return encodeURIComponent(str)
  27. .replace(/!/g, '%21')
  28. .replace(/'/g, '%27')
  29. .replace(/\(/g, '%28')
  30. .replace(/\)/g, '%29')
  31. .replace(/\*/g, '%2A');
  32. }
  33. function getObjectKeys(obj, forKey) {
  34. var list = [];
  35. for (var key in obj) {
  36. if (obj.hasOwnProperty(key)) {
  37. list.push(forKey ? camSafeUrlEncode(key).toLowerCase() : key);
  38. }
  39. }
  40. return list.sort(function (a, b) {
  41. a = a.toLowerCase();
  42. b = b.toLowerCase();
  43. return a === b ? 0 : a > b ? 1 : -1;
  44. });
  45. }
  46. /**
  47. * obj转为string
  48. * @param {Object} obj 需要转的对象,必须
  49. * @param {Boolean} lowerCaseKey key是否转为小写,默认false,非必须
  50. * @return {String} data 返回字符串
  51. */
  52. var obj2str = function (obj, lowerCaseKey) {
  53. var i, key, val;
  54. var list = [];
  55. var keyList = getObjectKeys(obj);
  56. for (i = 0; i < keyList.length; i++) {
  57. key = keyList[i];
  58. val = obj[key] === undefined || obj[key] === null ? '' : '' + obj[key];
  59. key = lowerCaseKey ? camSafeUrlEncode(key).toLowerCase() : camSafeUrlEncode(key);
  60. val = camSafeUrlEncode(val) || '';
  61. list.push(key + '=' + val);
  62. }
  63. return list.join('&');
  64. };
  65. // 可以签入签名的headers
  66. var signHeaders = [
  67. 'cache-control',
  68. 'content-disposition',
  69. 'content-encoding',
  70. 'content-length',
  71. 'content-md5',
  72. 'expect',
  73. 'expires',
  74. 'host',
  75. 'if-match',
  76. 'if-modified-since',
  77. 'if-none-match',
  78. 'if-unmodified-since',
  79. 'origin',
  80. 'range',
  81. 'transfer-encoding',
  82. 'pic-operations',
  83. ];
  84. var getSignHeaderObj = function (headers) {
  85. var signHeaderObj = {};
  86. for (var i in headers) {
  87. var key = i.toLowerCase();
  88. if (key.indexOf('x-cos-') > -1 || signHeaders.indexOf(key) > -1) {
  89. signHeaderObj[i] = headers[i];
  90. }
  91. }
  92. return signHeaderObj;
  93. };
  94. //测试用的key后面可以去掉
  95. var getAuth = function (opt) {
  96. opt = opt || {};
  97. var SecretId = opt.SecretId;
  98. var SecretKey = opt.SecretKey;
  99. var KeyTime = opt.KeyTime;
  100. var method = (opt.method || opt.Method || 'get').toLowerCase();
  101. var queryParams = clone(opt.Query || opt.params || {});
  102. var headers = getSignHeaderObj(clone(opt.Headers || opt.headers || {}));
  103. var Key = opt.Key || '';
  104. var pathname;
  105. if (opt.UseRawKey) {
  106. pathname = opt.Pathname || opt.pathname || '/' + Key;
  107. } else {
  108. pathname = opt.Pathname || opt.pathname || Key;
  109. pathname.indexOf('/') !== 0 && (pathname = '/' + pathname);
  110. }
  111. // ForceSignHost明确传入false才不加入host签名
  112. var forceSignHost = opt.ForceSignHost === false ? false : true;
  113. // 如果有传入存储桶,那么签名默认加 Host 参与计算,避免跨桶访问
  114. if (!headers.Host && !headers.host && opt.Bucket && opt.Region && forceSignHost)
  115. headers.Host = opt.Bucket + '.cos.' + opt.Region + '.myqcloud.com';
  116. if (!SecretId) return console.error('missing param SecretId');
  117. if (!SecretKey) return console.error('missing param SecretKey');
  118. // 签名有效起止时间
  119. var now = Math.round(getSkewTime(opt.SystemClockOffset) / 1000) - 1;
  120. var exp = now;
  121. var Expires = opt.Expires || opt.expires;
  122. if (Expires === undefined) {
  123. exp += 900; // 签名过期时间为当前 + 900s
  124. } else {
  125. exp += Expires * 1 || 0;
  126. }
  127. // 要用到的 Authorization 参数列表
  128. var qSignAlgorithm = 'sha1';
  129. var qAk = SecretId;
  130. var qSignTime = KeyTime || now + ';' + exp;
  131. var qKeyTime = KeyTime || now + ';' + exp;
  132. var qHeaderList = getObjectKeys(headers, true).join(';').toLowerCase();
  133. var qUrlParamList = getObjectKeys(queryParams, true).join(';').toLowerCase();
  134. // 签名算法说明文档:https://www.qcloud.com/document/product/436/7778
  135. // 步骤一:计算 SignKey
  136. var signKey = CryptoJS.HmacSHA1(qKeyTime, SecretKey).toString();
  137. // 步骤二:构成 FormatString
  138. var formatString = [method, pathname, util.obj2str(queryParams, true), util.obj2str(headers, true), ''].join('\n');
  139. // 步骤三:计算 StringToSign
  140. var stringToSign = ['sha1', qSignTime, CryptoJS.SHA1(formatString).toString(), ''].join('\n');
  141. // 步骤四:计算 Signature
  142. var qSignature = CryptoJS.HmacSHA1(stringToSign, signKey).toString();
  143. // 步骤五:构造 Authorization
  144. var authorization = [
  145. 'q-sign-algorithm=' + qSignAlgorithm,
  146. 'q-ak=' + qAk,
  147. 'q-sign-time=' + qSignTime,
  148. 'q-key-time=' + qKeyTime,
  149. 'q-header-list=' + qHeaderList,
  150. 'q-url-param-list=' + qUrlParamList,
  151. 'q-signature=' + qSignature,
  152. ].join('&');
  153. return authorization;
  154. };
  155. var getSourceParams = function (source) {
  156. var parser = this.options.CopySourceParser;
  157. if (parser) return parser(source);
  158. var m = source.match(/^([^.]+-\d+)\.cos(v6|-cdc|-internal)?\.([^.]+)\.((myqcloud\.com)|(tencentcos\.cn))\/(.+)$/);
  159. if (!m) return null;
  160. return { Bucket: m[1], Region: m[3], Key: m[7] };
  161. };
  162. var noop = function () {};
  163. // 清除对象里值为的 undefined 或 null 的属性
  164. var clearKey = function (obj) {
  165. var retObj = {};
  166. for (var key in obj) {
  167. if (obj.hasOwnProperty(key) && obj[key] !== undefined && obj[key] !== null) {
  168. retObj[key] = obj[key];
  169. }
  170. }
  171. return retObj;
  172. };
  173. // 获取文件分片
  174. var fileSlice = function (FilePath, start, end, callback) {
  175. if (FilePath) {
  176. wxfs.readFile({
  177. filePath: FilePath,
  178. position: start,
  179. length: end - start,
  180. success: function (res) {
  181. callback(res.data);
  182. },
  183. fail: function () {
  184. callback(null);
  185. },
  186. });
  187. } else {
  188. callback(null);
  189. }
  190. };
  191. // 获取文件内容的 MD5
  192. var getBodyMd5 = function (UploadCheckContentMd5, Body, callback) {
  193. callback = callback || noop;
  194. if (UploadCheckContentMd5) {
  195. if (Body && Body instanceof ArrayBuffer) {
  196. util.getFileMd5(Body, function (err, md5) {
  197. callback(md5);
  198. });
  199. } else {
  200. callback();
  201. }
  202. } else {
  203. callback();
  204. }
  205. };
  206. // 获取文件 md5 值
  207. var getFileMd5 = function (body, callback) {
  208. var hash = md5(body);
  209. callback && callback(hash);
  210. return hash;
  211. };
  212. function clone(obj) {
  213. return map(obj, function (v) {
  214. return typeof v === 'object' && v !== null ? clone(v) : v;
  215. });
  216. }
  217. function attr(obj, name, defaultValue) {
  218. return obj && name in obj ? obj[name] : defaultValue;
  219. }
  220. function extend(target, source) {
  221. each(source, function (val, key) {
  222. target[key] = source[key];
  223. });
  224. return target;
  225. }
  226. function isArray(arr) {
  227. return arr instanceof Array;
  228. }
  229. function isInArray(arr, item) {
  230. var flag = false;
  231. for (var i = 0; i < arr.length; i++) {
  232. if (item === arr[i]) {
  233. flag = true;
  234. break;
  235. }
  236. }
  237. return flag;
  238. }
  239. function makeArray(arr) {
  240. return isArray(arr) ? arr : [arr];
  241. }
  242. function each(obj, fn) {
  243. for (var i in obj) {
  244. if (obj.hasOwnProperty(i)) {
  245. fn(obj[i], i);
  246. }
  247. }
  248. }
  249. function map(obj, fn) {
  250. var o = isArray(obj) ? [] : {};
  251. for (var i in obj) {
  252. if (obj.hasOwnProperty(i)) {
  253. o[i] = fn(obj[i], i);
  254. }
  255. }
  256. return o;
  257. }
  258. function filter(obj, fn) {
  259. var iaArr = isArray(obj);
  260. var o = iaArr ? [] : {};
  261. for (var i in obj) {
  262. if (obj.hasOwnProperty(i)) {
  263. if (fn(obj[i], i)) {
  264. if (iaArr) {
  265. o.push(obj[i]);
  266. } else {
  267. o[i] = obj[i];
  268. }
  269. }
  270. }
  271. }
  272. return o;
  273. }
  274. var binaryBase64 = function (str) {
  275. var i,
  276. len,
  277. char,
  278. res = '';
  279. for (i = 0, len = str.length / 2; i < len; i++) {
  280. char = parseInt(str[i * 2] + str[i * 2 + 1], 16);
  281. res += String.fromCharCode(char);
  282. }
  283. return btoa(res);
  284. };
  285. var uuid = function () {
  286. var S4 = function () {
  287. return (((1 + Math.random()) * 0x10000) | 0).toString(16).substring(1);
  288. };
  289. return S4() + S4() + '-' + S4() + '-' + S4() + '-' + S4() + '-' + S4() + S4() + S4();
  290. };
  291. var hasMissingParams = function (apiName, params) {
  292. var Bucket = params.Bucket;
  293. var Region = params.Region;
  294. var Key = params.Key;
  295. if (
  296. apiName.indexOf('Bucket') > -1 ||
  297. apiName === 'deleteMultipleObject' ||
  298. apiName === 'multipartList' ||
  299. apiName === 'listObjectVersions'
  300. ) {
  301. if (!Bucket) return 'Bucket';
  302. if (!Region) return 'Region';
  303. } else if (
  304. apiName.indexOf('Object') > -1 ||
  305. apiName.indexOf('multipart') > -1 ||
  306. apiName === 'sliceUploadFile' ||
  307. apiName === 'abortUploadTask' ||
  308. apiName === 'uploadFile'
  309. ) {
  310. if (!Bucket) return 'Bucket';
  311. if (!Region) return 'Region';
  312. if (!Key) return 'Key';
  313. }
  314. return false;
  315. };
  316. var formatParams = function (apiName, params) {
  317. // 复制参数对象
  318. params = extend({}, params);
  319. // 统一处理 Headers
  320. if (apiName !== 'getAuth' && apiName !== 'getV4Auth' && apiName !== 'getObjectUrl') {
  321. var Headers = params.Headers || {};
  322. if (params && typeof params === 'object') {
  323. (function () {
  324. for (var key in params) {
  325. if (params.hasOwnProperty(key) && key.indexOf('x-cos-') > -1) {
  326. Headers[key] = params[key];
  327. }
  328. }
  329. })();
  330. var headerMap = {
  331. // params headers
  332. 'x-cos-mfa': 'MFA',
  333. 'Content-MD5': 'ContentMD5',
  334. 'Content-Length': 'ContentLength',
  335. 'Content-Type': 'ContentType',
  336. Expect: 'Expect',
  337. Expires: 'Expires',
  338. 'Cache-Control': 'CacheControl',
  339. 'Content-Disposition': 'ContentDisposition',
  340. 'Content-Encoding': 'ContentEncoding',
  341. Range: 'Range',
  342. 'If-Modified-Since': 'IfModifiedSince',
  343. 'If-Unmodified-Since': 'IfUnmodifiedSince',
  344. 'If-Match': 'IfMatch',
  345. 'If-None-Match': 'IfNoneMatch',
  346. 'x-cos-copy-source': 'CopySource',
  347. 'x-cos-copy-source-Range': 'CopySourceRange',
  348. 'x-cos-metadata-directive': 'MetadataDirective',
  349. 'x-cos-copy-source-If-Modified-Since': 'CopySourceIfModifiedSince',
  350. 'x-cos-copy-source-If-Unmodified-Since': 'CopySourceIfUnmodifiedSince',
  351. 'x-cos-copy-source-If-Match': 'CopySourceIfMatch',
  352. 'x-cos-copy-source-If-None-Match': 'CopySourceIfNoneMatch',
  353. 'x-cos-acl': 'ACL',
  354. 'x-cos-grant-read': 'GrantRead',
  355. 'x-cos-grant-write': 'GrantWrite',
  356. 'x-cos-grant-full-control': 'GrantFullControl',
  357. 'x-cos-grant-read-acp': 'GrantReadAcp',
  358. 'x-cos-grant-write-acp': 'GrantWriteAcp',
  359. 'x-cos-storage-class': 'StorageClass',
  360. 'x-cos-traffic-limit': 'TrafficLimit',
  361. 'x-cos-mime-limit': 'MimeLimit',
  362. 'x-cos-forbid-overwrite': 'ForbidOverwrite',
  363. // SSE-C
  364. 'x-cos-server-side-encryption-customer-algorithm': 'SSECustomerAlgorithm',
  365. 'x-cos-server-side-encryption-customer-key': 'SSECustomerKey',
  366. 'x-cos-server-side-encryption-customer-key-MD5': 'SSECustomerKeyMD5',
  367. // SSE-COS、SSE-KMS
  368. 'x-cos-server-side-encryption': 'ServerSideEncryption',
  369. 'x-cos-server-side-encryption-cos-kms-key-id': 'SSEKMSKeyId',
  370. 'x-cos-server-side-encryption-context': 'SSEContext',
  371. // 上传时图片处理
  372. 'Pic-Operations': 'PicOperations',
  373. };
  374. util.each(headerMap, function (paramKey, headerKey) {
  375. if (params[paramKey] !== undefined) {
  376. Headers[headerKey] = params[paramKey];
  377. }
  378. });
  379. params.Headers = clearKey(Headers);
  380. }
  381. }
  382. return params;
  383. };
  384. var apiWrapper = function (apiName, apiFn) {
  385. return function (params, callback) {
  386. var self = this;
  387. // 处理参数
  388. if (typeof params === 'function') {
  389. callback = params;
  390. params = {};
  391. }
  392. // 整理参数格式
  393. params = formatParams(apiName, params);
  394. // tracker传递
  395. var tracker;
  396. if (self.options.EnableReporter) {
  397. if (params.calledBySdk === 'sliceUploadFile' || params.calledBySdk === 'sliceCopyFile') {
  398. // 分块上传内部方法使用sliceUploadFile的子链路
  399. tracker = params.tracker && params.tracker.generateSubTracker({ apiName });
  400. } else if (['uploadFile', 'uploadFiles'].includes(apiName)) {
  401. // uploadFile、uploadFiles方法在内部处理,此处不处理
  402. tracker = null;
  403. } else {
  404. var fileSize = 0;
  405. if (params.Body) {
  406. fileSize =
  407. typeof params.Body === 'string' ? params.Body.length : params.Body.size || params.Body.byteLength || 0;
  408. }
  409. const accelerate =
  410. self.options.UseAccelerate ||
  411. (typeof self.options.Domain === 'string' && self.options.Domain.includes('accelerate.'));
  412. tracker = new Tracker({
  413. Beacon: self.options.BeaconReporter,
  414. clsReporter: self.options.ClsReporter,
  415. bucket: params.Bucket,
  416. region: params.Region,
  417. apiName: apiName,
  418. realApi: apiName,
  419. accelerate,
  420. fileKey: params.Key,
  421. fileSize: fileSize,
  422. deepTracker: self.options.DeepTracker,
  423. customId: self.options.CustomId,
  424. delay: self.options.TrackerDelay,
  425. });
  426. }
  427. }
  428. params.tracker = tracker;
  429. // 代理回调函数
  430. var formatResult = function (result) {
  431. if (result && result.headers) {
  432. result.headers['x-cos-request-id'] && (result.RequestId = result.headers['x-cos-request-id']);
  433. result.headers['x-ci-request-id'] && (result.RequestId = result.headers['x-ci-request-id']);
  434. result.headers['x-cos-version-id'] && (result.VersionId = result.headers['x-cos-version-id']);
  435. result.headers['x-cos-delete-marker'] && (result.DeleteMarker = result.headers['x-cos-delete-marker']);
  436. }
  437. return result;
  438. };
  439. var _callback = function (err, data) {
  440. // 格式化上报参数并上报
  441. tracker && tracker.report(err, data);
  442. callback && callback(formatResult(err), formatResult(data));
  443. };
  444. var checkParams = function () {
  445. if (apiName !== 'getService' && apiName !== 'abortUploadTask') {
  446. // 判断参数是否完整
  447. var missingResult = hasMissingParams(apiName, params);
  448. if (missingResult) {
  449. return 'missing param ' + missingResult;
  450. }
  451. // 判断 region 格式
  452. if (params.Region) {
  453. if (params.Region.indexOf('cos.') > -1) {
  454. return 'param Region should not be start with "cos."';
  455. } else if (!/^([a-z\d-]+)$/.test(params.Region)) {
  456. return 'Region format error.';
  457. }
  458. // 判断 region 格式
  459. if (
  460. !self.options.CompatibilityMode &&
  461. params.Region.indexOf('-') === -1 &&
  462. params.Region !== 'yfb' &&
  463. params.Region !== 'default' &&
  464. params.Region !== 'accelerate'
  465. ) {
  466. console.warn(
  467. 'warning: param Region format error, find help here: https://cloud.tencent.com/document/product/436/6224'
  468. );
  469. }
  470. }
  471. // 兼容不带 AppId 的 Bucket
  472. if (params.Bucket) {
  473. if (!/^([a-z\d-]+)-(\d+)$/.test(params.Bucket)) {
  474. if (params.AppId) {
  475. params.Bucket = params.Bucket + '-' + params.AppId;
  476. } else if (self.options.AppId) {
  477. params.Bucket = params.Bucket + '-' + self.options.AppId;
  478. } else {
  479. return 'Bucket should format as "test-1250000000".';
  480. }
  481. }
  482. if (params.AppId) {
  483. console.warn(
  484. 'warning: AppId has been deprecated, Please put it at the end of parameter Bucket(E.g Bucket:"test-1250000000" ).'
  485. );
  486. delete params.AppId;
  487. }
  488. }
  489. // 如果 Key 是 / 开头,强制去掉第一个 /
  490. if (params.Key && params.Key.substr(0, 1) === '/') {
  491. params.Key = params.Key.substr(1);
  492. }
  493. }
  494. };
  495. var errMsg = checkParams();
  496. var isSync = ['getAuth', 'getObjectUrl'].includes(apiName);
  497. if (!isSync && !callback) {
  498. return new Promise(function (resolve, reject) {
  499. callback = function (err, data) {
  500. err ? reject(err) : resolve(data);
  501. };
  502. if (errMsg) return _callback({ error: errMsg });
  503. apiFn.call(self, params, _callback);
  504. });
  505. } else {
  506. if (errMsg) return _callback({ error: errMsg });
  507. var res = apiFn.call(self, params, _callback);
  508. if (isSync) return res;
  509. }
  510. };
  511. };
  512. var throttleOnProgress = function (total, onProgress) {
  513. var self = this;
  514. var size0 = 0;
  515. var size1 = 0;
  516. var time0 = Date.now();
  517. var time1;
  518. var timer;
  519. function update() {
  520. timer = 0;
  521. if (onProgress && typeof onProgress === 'function') {
  522. time1 = Date.now();
  523. var speed = Math.max(0, Math.round(((size1 - size0) / ((time1 - time0) / 1000)) * 100) / 100) || 0;
  524. var percent;
  525. if (size1 === 0 && total === 0) {
  526. percent = 1;
  527. } else {
  528. percent = Math.floor((size1 / total) * 100) / 100 || 0;
  529. }
  530. time0 = time1;
  531. size0 = size1;
  532. try {
  533. onProgress({
  534. loaded: size1,
  535. total: total,
  536. speed: speed,
  537. percent: percent,
  538. });
  539. } catch (e) {}
  540. }
  541. }
  542. return function (info, immediately) {
  543. if (info) {
  544. size1 = info.loaded;
  545. total = info.total;
  546. }
  547. if (immediately) {
  548. clearTimeout(timer);
  549. update();
  550. } else {
  551. if (timer) return;
  552. timer = setTimeout(update, self.options.ProgressInterval);
  553. }
  554. };
  555. };
  556. // 通过FilePath获取上传文件的内容
  557. var getFileBody = function (FilePath) {
  558. return new Promise((resolve, reject) => {
  559. wxfs.readFile({
  560. filePath: FilePath,
  561. success: function (res) {
  562. resolve(res.data);
  563. },
  564. fail: function (res) {
  565. reject(res?.errMsg || '');
  566. },
  567. });
  568. });
  569. };
  570. var getFileSize = async function (api, params, callback) {
  571. if (api === 'postObject') {
  572. callback();
  573. } else if (api === 'putObject') {
  574. if (params.Body === undefined && params.FilePath) {
  575. try {
  576. params.Body = await getFileBody(params.FilePath);
  577. } catch (e) {
  578. params.Body = undefined;
  579. callback({ error: `readFile error, ${e}` });
  580. return;
  581. }
  582. }
  583. if (params.Body !== undefined) {
  584. params.ContentLength = params.Body.byteLength;
  585. callback(null, params.ContentLength);
  586. } else {
  587. callback({ error: 'missing param Body' });
  588. }
  589. } else {
  590. if (params.FilePath) {
  591. wxfs.stat({
  592. path: params.FilePath,
  593. success: function (res) {
  594. var stats = res.stats;
  595. params.FileStat = stats;
  596. params.FileStat.FilePath = params.FilePath;
  597. var size = stats.isDirectory() ? 0 : stats.size;
  598. params.ContentLength = size = size || 0;
  599. callback(null, size);
  600. },
  601. fail: function (err) {
  602. callback(err);
  603. },
  604. });
  605. } else {
  606. callback({ error: 'missing param FilePath' });
  607. }
  608. }
  609. };
  610. // 通过FilePath获取上传文件的大小
  611. var getFileSizeByPath = function (filePath) {
  612. return new Promise((resolve, reject) => {
  613. wxfs.stat({
  614. path: filePath,
  615. success: function (res) {
  616. var stats = res.stats;
  617. var size = stats.isDirectory() ? 0 : stats.size;
  618. resolve(size);
  619. },
  620. fail: function (res) {
  621. reject(res?.errMsg || '');
  622. },
  623. });
  624. });
  625. };
  626. var getSkewTime = function (offset) {
  627. return Date.now() + (offset || 0);
  628. };
  629. var compareVersion = function (v1, v2) {
  630. v1 = v1.split('.');
  631. v2 = v2.split('.');
  632. var len = Math.max(v1.length, v2.length);
  633. while (v1.length < len) {
  634. v1.push('0');
  635. }
  636. while (v2.length < len) {
  637. v2.push('0');
  638. }
  639. for (var i = 0; i < len; i++) {
  640. var num1 = parseInt(v1[i]);
  641. var num2 = parseInt(v2[i]);
  642. if (num1 > num2) {
  643. return 1;
  644. } else if (num1 < num2) {
  645. return -1;
  646. }
  647. }
  648. return 0;
  649. };
  650. var canFileSlice = (function () {
  651. var systemInfo = wx.getSystemInfoSync();
  652. var support = compareVersion(systemInfo.SDKVersion, '2.10.0') >= 0;
  653. var needWarning = !support && systemInfo.platform === 'devtools';
  654. return function () {
  655. if (needWarning) console.warn('当前小程序版本小于 2.10.0,不支持分片上传,请更新软件。');
  656. needWarning = false;
  657. return support;
  658. };
  659. })();
  660. var isCIHost = function (url) {
  661. return /^https?:\/\/([^/]+\.)?ci\.[^/]+/.test(url);
  662. };
  663. var error = function (err, opt) {
  664. var sourceErr = err;
  665. err.message = err.message || null;
  666. if (typeof opt === 'string') {
  667. err.error = opt;
  668. err.message = opt;
  669. } else if (typeof opt === 'object' && opt !== null) {
  670. extend(err, opt);
  671. if (opt.code || opt.name) err.code = opt.code || opt.name;
  672. if (opt.message) err.message = opt.message;
  673. if (opt.stack) err.stack = opt.stack;
  674. }
  675. if (typeof Object.defineProperty === 'function') {
  676. Object.defineProperty(err, 'name', { writable: true, enumerable: false });
  677. Object.defineProperty(err, 'message', { enumerable: true });
  678. }
  679. err.name = (opt && opt.name) || err.name || err.code || 'Error';
  680. if (!err.code) err.code = err.name;
  681. if (!err.error) err.error = clone(sourceErr); // 兼容老的错误格式
  682. return err;
  683. };
  684. const encodeBase64 = function (str, safe) {
  685. let base64Str = base64.encode(str);
  686. // 万象使用的安全base64格式需要特殊处理
  687. if (safe) {
  688. base64Str = base64Str.replaceAll('+', '-').replaceAll('/', '_').replaceAll('=', '');
  689. }
  690. return base64Str;
  691. };
  692. var simplifyPath = function (path) {
  693. const names = path.split('/');
  694. const stack = [];
  695. for (const name of names) {
  696. if (name === '..') {
  697. if (stack.length) {
  698. stack.pop();
  699. }
  700. } else if (name.length && name !== '.') {
  701. stack.push(name);
  702. }
  703. }
  704. return '/' + stack.join('/');
  705. };
  706. // 将ArrayBuffer转换为字符串
  707. var arrayBufferToString = function (arrayBuffer) {
  708. const decoder = new TextDecoder('utf-8');
  709. return decoder.decode(arrayBuffer);
  710. };
  711. // 解析响应体,兼容 xml、json
  712. var parseResBody = function (responseBody) {
  713. var json;
  714. if (responseBody && typeof responseBody === 'string') {
  715. var trimBody = responseBody.trim();
  716. var isXml = trimBody.indexOf('<') === 0;
  717. var isJson = trimBody.indexOf('{') === 0;
  718. if (isXml) {
  719. // xml 解析,解析失败返回{}
  720. json = util.xml2json(responseBody) || {};
  721. } else if (isJson) {
  722. // json解析,解析失败返回原始 Body
  723. try {
  724. // 替换 json 中的换行符为空格,否则解析会出错
  725. var formatBody = responseBody.replace(/\n/g, ' ');
  726. var parsedBody = JSON.parse(formatBody);
  727. // 确保解析出 json 对象
  728. if (Object.prototype.toString.call(parsedBody) === '[object Object]') {
  729. json = parsedBody;
  730. } else {
  731. json = responseBody;
  732. }
  733. } catch (e) {
  734. json = responseBody;
  735. }
  736. } else {
  737. json = responseBody;
  738. }
  739. } else {
  740. json = responseBody || {};
  741. }
  742. return json;
  743. };
  744. var util = {
  745. noop: noop,
  746. formatParams: formatParams,
  747. apiWrapper: apiWrapper,
  748. xml2json: xml2json,
  749. json2xml: json2xml,
  750. md5: md5,
  751. clearKey: clearKey,
  752. fileSlice: fileSlice,
  753. getBodyMd5: getBodyMd5,
  754. getFileMd5: getFileMd5,
  755. binaryBase64: binaryBase64,
  756. extend: extend,
  757. isArray: isArray,
  758. isInArray: isInArray,
  759. makeArray: makeArray,
  760. each: each,
  761. map: map,
  762. filter: filter,
  763. clone: clone,
  764. attr: attr,
  765. uuid: uuid,
  766. camSafeUrlEncode: camSafeUrlEncode,
  767. throttleOnProgress: throttleOnProgress,
  768. getFileSize: getFileSize,
  769. getFileSizeByPath: getFileSizeByPath,
  770. getSkewTime: getSkewTime,
  771. obj2str: obj2str,
  772. getAuth: getAuth,
  773. compareVersion: compareVersion,
  774. canFileSlice: canFileSlice,
  775. isCIHost: isCIHost,
  776. error: error,
  777. getSourceParams: getSourceParams,
  778. encodeBase64: encodeBase64,
  779. simplifyPath: simplifyPath,
  780. arrayBufferToString: arrayBufferToString,
  781. parseResBody: parseResBody,
  782. };
  783. module.exports = util;