CLDSRV-636: Migrate SSE on CopyObject and init MPU

Author: BourgoisMickael

lib/api/initiateMultipartUpload.js

@@ -21,6 +21,7 @@ const { getObjectSSEConfiguration } = require('./apiUtils/bucket/bucketEncryptio
 const { setExpirationHeaders } = require('./apiUtils/object/expirationHeaders');
 const { data } = require('../data/wrapper');
 const { setSSEHeaders } = require('./apiUtils/object/sseHeaders');
+const { updateEncryption } = require('./apiUtils/bucket/updateEncryption');
 
 /*
 Sample xml response:
@@ -272,6 +273,8 @@ function initiateMultipartUpload(authInfo, request, log, callback) {
 
     async.waterfall([
         next => metadataValidateBucketAndObj(metadataValParams, log,
+            (error, destinationBucket, destObjMD) =>
+                updateEncryption(error, destinationBucket, destObjMD, objectKey, log, { skipObject: true },
             (error, destinationBucket) => {
                 const corsHeaders = collectCorsHeaders(request.headers.origin,
                     request.method, destinationBucket);
@@ -284,7 +287,7 @@ function initiateMultipartUpload(authInfo, request, log, callback) {
                     return next(error, corsHeaders);
                 }
                 return next(null, corsHeaders, destinationBucket);
-            }),
+            })),
         (corsHeaders, destinationBucket, next) => {
             if (destinationBucket.hasDeletedFlag() && accountCanonicalID !== destinationBucket.getOwner()) {
                 log.trace('deleted flag on bucket and request from non-owner account');

lib/api/objectCopy.js

@@ -24,6 +24,7 @@ const monitoring = require('../utilities/metrics');
 const { getObjectSSEConfiguration } = require('./apiUtils/bucket/bucketEncryption');
 const { setExpirationHeaders } = require('./apiUtils/object/expirationHeaders');
 const { setSSEHeaders } = require('./apiUtils/object/sseHeaders');
+const { updateEncryption } = require('./apiUtils/bucket/updateEncryption');
 
 const versionIdUtils = versioning.VersionID;
 const locationHeader = constants.objectLocationConstraintHeader;
@@ -251,6 +252,8 @@ function objectCopy(authInfo, request, sourceBucket,
     return async.waterfall([
         function checkDestAuth(next) {
             return metadataValidateBucketAndObj(valPutParams, log,
+                (err, destBucketMD, destObjMD) =>
+                    updateEncryption(err, destBucketMD, destObjMD, destObjectKey, log, { skipObject: true },
                 (err, destBucketMD, destObjMD) => {
                     if (err) {
                         log.debug('error validating put part of request',
@@ -265,7 +268,7 @@ function objectCopy(authInfo, request, sourceBucket,
                         return next(errors.NoSuchBucket);
                     }
                     return next(null, destBucketMD, destObjMD);
-                });
+                }));
         },
         function checkSourceAuthorization(destBucketMD, destObjMD, next) {
             return metadataValidateBucketAndObj(valGetParams, log,