add BucketEncryption API

Author: carsonxu

demo/demo.js

@@ -753,6 +753,40 @@ function getBucketAccelerate() {
     });
 }
 
+function putBucketEncryption() {
+    cos.putBucketEncryption({
+        Bucket: config.Bucket,
+        Region: config.Region,
+        ServerSideEncryptionConfiguration: {
+            Rule: [{
+                ApplySideEncryptionConfiguration: {
+                    SSEAlgorithm: 'AES256',
+                },
+            }],
+        },
+    }, function(err, data) {
+        console.log(JSON.stringify(err || data, null, 2));
+    });
+}
+
+function getBucketEncryption() {
+    cos.getBucketEncryption({
+        Bucket: config.Bucket,
+        Region: config.Region
+    }, function(err, data) {
+        console.log(err || JSON.stringify(data));
+    });
+}
+
+function deleteBucketEncryption() {
+    cos.deleteBucketEncryption({
+        Bucket: config.Bucket,
+        Region: config.Region
+    }, function(err, data) {
+        console.log(err || JSON.stringify(data));
+    });
+}
+
 function putObject() {
     // 创建测试文件
     var filename = '1mb.zip';
@@ -1412,6 +1446,9 @@ function deleteFolder() {
 // listBucketInventory();
 // putBucketAccelerate();
 // getBucketAccelerate();
+// putBucketEncryption();
+// getBucketEncryption();
+// deleteBucketEncryption();
 // deleteBucket();
 // putObjectCopy();
 // getObjectStream();

package.json

@@ -1,6 +1,6 @@
 {
   "name": "cos-nodejs-sdk-v5",
-  "version": "2.9.9",
+  "version": "2.9.10",
   "description": "cos nodejs sdk v5",
   "main": "index.js",
   "types": "types",

sdk/base.js

@@ -1676,6 +1676,85 @@ function getBucketAccelerate(params, callback) {
     });
 }
 
+function putBucketEncryption(params, callback) {
+    var conf = params.ServerSideEncryptionConfiguration || {};
+    var Rules = conf.Rule || conf.Rules || [];
+    var xml = util.json2xml({ServerSideEncryptionConfiguration: {Rule:Rules}});
+
+    var headers = params.Headers;
+    headers['Content-Type'] = 'application/xml';
+    headers['Content-MD5'] = util.binaryBase64(util.md5(xml));
+
+    submitRequest.call(this, {
+        Action: 'name/cos:PutBucketEncryption',
+        method: 'PUT',
+        Bucket: params.Bucket,
+        Region: params.Region,
+        body: xml,
+        action: 'encryption',
+        headers: headers,
+    }, function (err, data) {
+        if (err && err.statusCode === 204) {
+            return callback(null, {statusCode: err.statusCode});
+        } else if (err) {
+            return callback(err);
+        }
+        callback(null, {
+            statusCode: data.statusCode,
+            headers: data.headers,
+        });
+    });
+}
+
+function getBucketEncryption(params, callback) {
+    submitRequest.call(this, {
+        Action: 'name/cos:GetBucketEncryption',
+        method: 'GET',
+        Bucket: params.Bucket,
+        Region: params.Region,
+        headers: params.Headers,
+        action: 'encryption',
+    }, function (err, data) {
+        if (err) {
+            if (err.statusCode === 404 && err.code === 'NoSuchEncryptionConfiguration') {
+                var result = {
+                    EncryptionConfiguration: {Rules: []},
+                    statusCode: err.statusCode,
+                };
+                err.headers && (result.headers = err.headers);
+                callback(null, result);
+            } else {
+                callback(err);
+            }
+            return;
+        }
+        var Rules = util.makeArray(data.EncryptionConfiguration && data.EncryptionConfiguration.Rule || []);
+        data.EncryptionConfiguration = {Rules: Rules};
+        callback(err, data);
+    });
+}
+
+function deleteBucketEncryption(params, callback) {
+    submitRequest.call(this, {
+        Action: 'name/cos:DeleteBucketReplication',
+        method: 'DELETE',
+        Bucket: params.Bucket,
+        Region: params.Region,
+        headers: params.Headers,
+        action: 'encryption',
+    }, function (err, data) {
+        if (err && err.statusCode === 204) {
+            return callback(null, {statusCode: err.statusCode});
+        } else if (err) {
+            return callback(err);
+        }
+        callback(null, {
+            statusCode: data.statusCode,
+            headers: data.headers,
+        });
+    });
+}
+
 // Object 相关
 
 /**
@@ -3713,6 +3792,9 @@ var API_MAP = {
     deleteBucketInventory: deleteBucketInventory,
     putBucketAccelerate: putBucketAccelerate,
     getBucketAccelerate: getBucketAccelerate,
+    putBucketEncryption: putBucketEncryption,
+    getBucketEncryption: getBucketEncryption,
+    deleteBucketEncryption: deleteBucketEncryption,
 
     // Object 相关方法
     getObject: getObject,