✨ check that backend support versioning

Author: DarkIsDude

lib/routes/routeBackbeat.js

@@ -663,21 +663,34 @@ function putMetadata(request, response, bucketInfo, objMd, log, callback) {
                 });
             },
             async () => {
-                if (versioning && !objMd) {
-                    const masterObjectAndBucket =
-                        await metadata.getBucketAndObjectMDPromised(bucketName, objectKey, {}, log);
+                if (!versioning || objMd) {
+                    return;
+                }
 
-                    if (!masterObjectAndBucket.obj) {
-                        return;
-                    }
+                const storageType = headers['x-scal-storage-type'];
 
-                    const masterObject = JSON.parse(masterObjectAndBucket.obj);
-                    const versioningPreprocessingResult =
-                        await versioningPreprocessingPromised(bucketName, bucketInfo, objectKey, masterObject, log);
+                if (constants.versioningNotImplBackends[storageType]) {
+                    log.debug(
+                        'versioning is not implemented on the destination backend',
+                        { method: 'putMetadata', error: errors.NotImplemented },
+                    );
 
-                    if (versioningPreprocessingResult?.nullVersionId) {
-                        omVal.nullVersionId = versioningPreprocessingResult.nullVersionId;
-                    }
+                    return;
+                }
+
+                const masterObjectAndBucket =
+                    await metadata.getBucketAndObjectMDPromised(bucketName, objectKey, {}, log);
+
+                if (!masterObjectAndBucket.obj) {
+                    return;
+                }
+
+                const masterObject = JSON.parse(masterObjectAndBucket.obj);
+                const versioningPreprocessingResult =
+                    await versioningPreprocessingPromised(bucketName, bucketInfo, objectKey, masterObject, log);
+
+                if (versioningPreprocessingResult?.nullVersionId) {
+                    omVal.nullVersionId = versioningPreprocessingResult.nullVersionId;
                 }
             },
             next => {

tests/multipleBackend/routes/routeBackbeat.js

@@ -2467,14 +2467,18 @@ describe('backbeat routes', () => {
             ], done);
         });
 
-        it('should put tags if the source is Azure and tags are provided ' +
+        it.only('should put tags if the source is Azure and tags are provided ' +
         'when completing the multipart upload', done => {
             const containerName = getAzureContainerName(azureLocation);
             const blob = uuidv4();
             const multipleBackendPath =
                 `/_/backbeat/multiplebackenddata/${containerName}/${blob}`;
             const uploadId = uuidv4().replace(/-/g, '');
             let partData;
+
+            console.info(`Azure container name: ${containerName}`);
+            console.info({ azureLocation });
+
             async.series([
                 next =>
                     makeRequest({
@@ -2528,7 +2532,16 @@ describe('backbeat routes', () => {
                             const tags = JSON.parse(result.metadata.tags);
                             assert.deepStrictEqual(tags, { key1: 'value1' });
                             return next();
-                        }, next),
+                        }, err => {
+                            console.error({ err });
+                            console.error('error getting blob properties 1');
+                            next;
+                        })
+                        .catch(err => {
+                            console.error({ err });
+                            console.error('error getting blob properties 2', err);
+                            return next(err);
+                        }),
             ], done);
         });
     });