Merge pull request #281 from disoul/feature/changeheaders

BucketManager: add changeHeaders

Author: jemygraw

docs/nodejs-sdk-v7.md

@@ -499,6 +499,30 @@ bucketManager.changeMime(bucket, key, newMime, function(err, respBody, respInfo)
 });
 ```
 
+<a id="rs-chgm-h"></a>
+## 修改文件Headers
+
+```
+var bucket = 'if-pbl';
+var key = 'qiniu.mp4';
+var headers = {
+  'Content-Type': 'application/octet-stream',
+  'Last-Modified': 'Web, 21 Oct 2015 07:00:00 GMT',
+  'x-custom-header-xx': 'value',
+};
+
+bucketManager.changeHeaders(bucket, key, headers, function(err, respBody, respInfo) {
+  if (err) {
+    console.log(err);
+    //throw err;
+  } else {
+    //200 is success
+    console.log(respInfo.statusCode);
+    console.log(respBody);
+  }
+});
+```
+
 <a id="rs-chtype"></a>
 ## 修改文件存储类型
 

index.d.ts

@@ -496,6 +496,17 @@ export declare namespace rs {
          */
         changeMime(bucket: string, key: string, newMime: string, callback: callback): void;
 
+        /**
+         * 修改文件的Headers
+         * @see TODO
+         *
+         * @param bucket 空间名称
+         * @param key 文件名称
+         * @param headers Headers对象
+         * @param callback
+         */
+        changeHeaders(bucket: string, key: string, headers: { [k: string]: string }, callback: callback): void;
+
         /**
          * 移动或重命名文件，当bucketSrc==bucketDest相同的时候，就是重命名文件操作
          * @see https://developer.qiniu.com/kodo/api/1288/move
@@ -658,6 +669,14 @@ export declare namespace rs {
      */
     function changeMimeOp(bucket: string, key: string, newMime: string): string;
 
+    /**
+     *
+     * @param bucket
+     * @param key
+     * @param headers
+     */
+    function changeHeadersOp(bucket: string, key: string, headers: { [k: string]: string }): string;
+
     /**
      *
      * @param bucket

qiniu/storage/rs.js

@@ -110,6 +110,55 @@ function changeMimeReq(mac, config, bucket, key, newMime, callbackFunc) {
   rpc.postWithoutForm(requestURI, digest, callbackFunc);
 }
 
+
+// 修改文件返回的Headers内容
+// @link TODO
+// @param bucket  空间名称
+// @param key     文件名称
+// @param headers 需要修改的headers
+// @param callbackFunc(err, respBody, respInfo) 回调函数
+BucketManager.prototype.changeHeaders = function(bucket, key, headers,
+  callbackFunc) {
+  var useCache = false;
+  var that = this;
+  if (this.config.zone) {
+    if (this.config.zoneExpire == -1) {
+      useCache = true;
+    } else {
+      if (!util.isTimestampExpired(this.config.zoneExpire)) {
+        useCache = true;
+      }
+    }
+  }
+
+  if (useCache) {
+    changeHeadersReq(this.mac, this.config, bucket, key, headers, callbackFunc);
+  } else {
+    zone.getZoneInfo(this.mac.accessKey, bucket, function(err, cZoneInfo,
+      cZoneExpire) {
+      if (err) {
+        callbackFunc(err, null, null);
+        return;
+      }
+
+      //update object
+      that.config.zone = cZoneInfo;
+      that.config.zoneExpire = cZoneExpire;
+      //req
+      changeHeadersReq(that.mac, that.config, bucket, key, headers,
+        callbackFunc);
+    });
+  }
+}
+
+function changeHeadersReq(mac, config, bucket, key, headers, callbackFunc) {
+  var scheme = config.useHttpsDomain ? "https://" : "http://";
+  var changeHeadersOp = exports.changeHeadersOp(bucket, key, headers);
+  var requestURI = scheme + config.zone.rsHost + changeHeadersOp;
+  var digest = util.generateAccessToken(mac, requestURI, null);
+  rpc.postWithoutForm(requestURI, digest, callbackFunc);
+}
+
 // 移动或重命名文件，当bucketSrc==bucketDest相同的时候，就是重命名文件操作
 // @link https://developer.qiniu.com/kodo/api/1257/delete
 // @param srcBucket  源空间名称
@@ -594,6 +643,19 @@ exports.changeMimeOp = function(bucket, key, newMime) {
   return '/chgm/' + encodedEntryURI + '/mime/' + encodedMime;
 }
 
+exports.changeHeadersOp = function(bucket, key, headers) {
+  var encodedEntryURI = util.encodedEntry(bucket, key);
+  var prefix = 'x-qn-meta-!';
+  var path = '/chgm/' + encodedEntryURI;
+  for (var headerKey in headers) {
+    var encodedValue = util.urlsafeBase64Encode(headers[headerKey]);
+    var prefixedHeaderKey = prefix + headerKey;
+    path += "/" + prefixedHeaderKey + "/" + encodedValue;
+  }
+
+  return path;
+}
+
 exports.changeTypeOp = function(bucket, key, newType) {
   var encodedEntryURI = util.encodedEntry(bucket, key);
   return '/chtype/' + encodedEntryURI + '/type/' + newType;

test/rs.test.js

@@ -105,4 +105,39 @@ describe('test start bucket manager', function() {
       });
     });
   });
+
+  describe('test changeMime', function() {
+    it('test changeMime', function(done) {
+      var key = "test_file";
+      var bucket = srcBucket;
+
+      bucketManager.changeMime(bucket, key, "text/html",
+        function (err, respBody, respInfo) {
+          should.not.exist(err);
+          assert.equal(respInfo.statusCode, 200);
+          done();
+        }
+      );
+    });
+  });
+
+  describe('test changeHeaders', function() {
+    it('test changeHeaders', function(done) {
+      var key = "test_file";
+      var bucket = srcBucket;
+
+      bucketManager.changeHeaders(bucket, key, {
+        'Content-Type': 'text/plain',
+        'Last-Modified': 'Wed, 21 Oct 2015 07:28:00 GMT',
+        'x-qn-test-custom-header': '0',
+      },
+        function (err, respBody, respInfo) {
+          console.log(respInfo);
+          should.not.exist(err);
+          assert.equal(respInfo.statusCode, 200);
+          done();
+        }
+      );
+    });
+  });
 });