request.js 4.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137
  1. function camSafeUrlEncode(str) {
  2. return encodeURIComponent(str)
  3. .replace(/!/g, '%21')
  4. .replace(/'/g, '%27')
  5. .replace(/\(/g, '%28')
  6. .replace(/\)/g, '%29')
  7. .replace(/\*/g, '%2A');
  8. }
  9. function getObjectKeys(obj, forKey) {
  10. var list = [];
  11. for (var key in obj) {
  12. if (obj.hasOwnProperty(key)) {
  13. list.push(forKey ? camSafeUrlEncode(key).toLowerCase() : key);
  14. }
  15. }
  16. return list.sort(function (a, b) {
  17. a = a.toLowerCase();
  18. b = b.toLowerCase();
  19. return a === b ? 0 : (a > b ? 1 : -1);
  20. });
  21. };
  22. var obj2str = function (obj, lowerCaseKey) {
  23. var i, key, val;
  24. var list = [];
  25. var keyList = getObjectKeys(obj);
  26. for (i = 0; i < keyList.length; i++) {
  27. key = keyList[i];
  28. val = (obj[key] === undefined || obj[key] === null) ? '' : ('' + obj[key]);
  29. key = lowerCaseKey? camSafeUrlEncode(key).toLowerCase() : camSafeUrlEncode(key);
  30. val = camSafeUrlEncode(val) || '';
  31. list.push(key + '=' + val)
  32. }
  33. return list.join('&');
  34. };
  35. var request = function (params, callback) {
  36. var filePath = params.filePath;
  37. var headers = params.headers || {};
  38. var url = params.url || params.Url;
  39. var method = params.method;
  40. var onProgress = params.onProgress;
  41. var requestTask;
  42. var cb = function (err, response) {
  43. var H = response.header
  44. var headers = {};
  45. if (H) for (var key in H) {
  46. if (H.hasOwnProperty(key)) headers[key.toLowerCase()] = H[key];
  47. }
  48. callback(err, {statusCode: response.statusCode, headers: headers}, response.data);
  49. };
  50. if (filePath) {
  51. var fileKey;
  52. var m = url.match(/^(https?:\/\/[^/]+\/)([^/]*\/?)(.*)$/);
  53. if (params.pathStyle) {
  54. fileKey = decodeURIComponent(m[3] || '');
  55. url = m[1] + m[2];
  56. } else {
  57. fileKey = decodeURIComponent(m[2] + m[3] || '');
  58. url = m[1];
  59. }
  60. // 整理 postObject 参数
  61. var formData = {
  62. 'key': fileKey,
  63. 'success_action_status': 200,
  64. 'Signature': headers.Authorization,
  65. };
  66. var headerKeys = [
  67. 'Cache-Control',
  68. 'Content-Type',
  69. 'Content-Disposition',
  70. 'Content-Encoding',
  71. 'Expires',
  72. 'x-cos-storage-class',
  73. 'x-cos-security-token',
  74. 'x-ci-security-token',
  75. ];
  76. for (var i in params.headers) {
  77. if (params.headers.hasOwnProperty(i) && (i.indexOf('x-cos-meta-') > -1 || headerKeys.indexOf(i) > -1)) {
  78. formData[i] = params.headers[i];
  79. }
  80. }
  81. headers['x-cos-acl'] && (formData.acl = headers['x-cos-acl']);
  82. !formData['Content-Type'] && (formData['Content-Type'] = '');
  83. requestTask = wx.uploadFile({
  84. url: url,
  85. method: method,
  86. name: 'file',
  87. header: headers,
  88. filePath: filePath,
  89. formData: formData,
  90. timeout: params.timeout,
  91. success: function (response) {
  92. cb(null, response);
  93. },
  94. fail: function (response) {
  95. cb(response.errMsg, response);
  96. }
  97. });
  98. requestTask.onProgressUpdate(function (res) {
  99. onProgress && onProgress({
  100. loaded: res.totalBytesSent,
  101. total: res.totalBytesExpectedToSend,
  102. progress: res.progress / 100
  103. });
  104. });
  105. } else {
  106. var qsStr = params.qs && obj2str(params.qs) || '';
  107. if (qsStr) {
  108. url += (url.indexOf('?') > -1 ? '&' : '?') + qsStr;
  109. }
  110. headers['Content-Length'] && (delete headers['Content-Length']);
  111. requestTask = wx.request({
  112. url: url,
  113. method: method,
  114. header: headers,
  115. dataType: 'text',
  116. data: params.body,
  117. timeout: params.timeout,
  118. success: function (response) {
  119. cb(null, response);
  120. },
  121. fail: function (response) {
  122. cb(response.errMsg, response);
  123. }
  124. });
  125. }
  126. return requestTask;
  127. };
  128. module.exports = request;