add BucketEncryption APIS

tencentyun · Mar 4, 2021 · a16493c · a16493c
1 parent 801f202
commit a16493c
Show file tree

Hide file tree

Showing 6 changed files with 208 additions and 10 deletions.
diff --git a/demo/demo.js b/demo/demo.js
@@ -857,6 +857,40 @@ function listBucketInventory() {
     });
 }
 
+function putBucketEncryption() {
+cos.putBucketEncryption({
+    Bucket: config.Bucket,
+    Region: config.Region,
+    ServerSideEncryptionConfiguration: {
+        Rule: [{
+            ApplySideEncryptionConfiguration: {
+                SSEAlgorithm: 'AES256',
+            },
+        }],
+    },
+}, function(err, data) {
+    logger.log(err || JSON.stringify(data));
+});
+}
+
+function getBucketEncryption() {
+    cos.getBucketEncryption({
+        Bucket: config.Bucket,
+        Region: config.Region
+    }, function(err, data) {
+        logger.log(err || JSON.stringify(data));
+    });
+}
+
+function deleteBucketEncryption() {
+    cos.deleteBucketEncryption({
+        Bucket: config.Bucket,
+        Region: config.Region
+    }, function(err, data) {
+        logger.log(err || JSON.stringify(data));
+    });
+}
+
 function putObject() {
     // 创建测试文件
     var filename = '1mb.zip';
@@ -1392,6 +1426,9 @@ function deleteFolder() {
         'getBucketInventory',
         'deleteBucketInventory',
         'listBucketInventory',
+        'putBucketEncryption',
+        'getBucketEncryption',
+        'deleteBucketEncryption',
         'deleteBucket',
         'putObjectCopy',
         'getObject',

diff --git a/dist/cos-js-sdk-v5.js b/dist/cos-js-sdk-v5.js
@@ -2221,7 +2221,7 @@ base.init(COS, task);
 advance.init(COS, task);
 
 COS.getAuthorization = util.getAuth;
-COS.version = '1.2.4';
+COS.version = '1.2.5';
 
 module.exports = COS;
 
@@ -5688,9 +5688,7 @@ function getBucketReplication(params, callback) {
             }
             return;
         }
-        if (!err) {
-            !data.ReplicationConfiguration && (data.ReplicationConfiguration = {});
-        }
+        !data.ReplicationConfiguration && (data.ReplicationConfiguration = {});
         if (data.ReplicationConfiguration.Rule) {
             data.ReplicationConfiguration.Rules = util.makeArray(data.ReplicationConfiguration.Rule);
             delete data.ReplicationConfiguration.Rule;
@@ -6478,6 +6476,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 相关
 
 /**
@@ -8219,6 +8296,9 @@ var API_MAP = {
     deleteBucketInventory: deleteBucketInventory,
     putBucketAccelerate: putBucketAccelerate,
     getBucketAccelerate: getBucketAccelerate,
+    putBucketEncryption: putBucketEncryption,
+    getBucketEncryption: getBucketEncryption,
+    deleteBucketEncryption: deleteBucketEncryption,
 
     // Object 相关方法
     getObject: getObject,

diff --git a/dist/cos-js-sdk-v5.min.js b/dist/cos-js-sdk-v5.min.js
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "cos-js-sdk-v5",
-  "version": "1.2.4",
+  "version": "1.2.5",
   "description": "JavaScript SDK for [腾讯云对象存储](https://cloud.tencent.com/product/cos)",
   "main": "index.js",
   "types": "types",

diff --git a/src/base.js b/src/base.js
@@ -871,9 +871,7 @@ function getBucketReplication(params, callback) {
             }
             return;
         }
-        if (!err) {
-            !data.ReplicationConfiguration && (data.ReplicationConfiguration = {});
-        }
+        !data.ReplicationConfiguration && (data.ReplicationConfiguration = {});
         if (data.ReplicationConfiguration.Rule) {
             data.ReplicationConfiguration.Rules = util.makeArray(data.ReplicationConfiguration.Rule);
             delete data.ReplicationConfiguration.Rule;
@@ -1672,6 +1670,86 @@ 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 相关
 
 /**
@@ -3433,6 +3511,9 @@ var API_MAP = {
     deleteBucketInventory: deleteBucketInventory,
     putBucketAccelerate: putBucketAccelerate,
     getBucketAccelerate: getBucketAccelerate,
+    putBucketEncryption: putBucketEncryption,
+    getBucketEncryption: getBucketEncryption,
+    deleteBucketEncryption: deleteBucketEncryption,
 
     // Object 相关方法
     getObject: getObject,

diff --git a/src/cos.js b/src/cos.js
@@ -59,6 +59,6 @@ base.init(COS, task);
 advance.init(COS, task);
 
 COS.getAuthorization = util.getAuth;
-COS.version = '1.2.4';
+COS.version = '1.2.5';
 
 module.exports = COS;