test transitions

Author: SylvainSenechal

tests/zenko_tests/node_tests/backbeat/LifecycleUtility.js

@@ -233,7 +233,7 @@ class LifecycleUtility extends ReplicationUtility {
     }
 
     putBucketLifecycleConfiguration(transitionDate, cb) {
-        this.s3.send(new PutBucketLifecycleConfigurationCommand({
+        const lifecycleConfig = {
             Bucket: this.bucket,
             LifecycleConfiguration: {
                 Rules: [{
@@ -247,9 +247,19 @@ class LifecycleUtility extends ReplicationUtility {
                     ],
                 }],
             },
-        }))
-            .then(data => cb(null, data))
-            .catch(err => cb(err));
+        };
+        
+        console.log(`[DEBUG] putBucketLifecycleConfiguration: Setting lifecycle for bucket ${this.bucket} with destination ${this.destinationLocation} and date ${transitionDate}`);
+        
+        this.s3.send(new PutBucketLifecycleConfigurationCommand(lifecycleConfig))
+            .then(data => {
+                console.log(`[DEBUG] putBucketLifecycleConfiguration: Successfully set lifecycle configuration`);
+                cb(null, data);
+            })
+            .catch(err => {
+                console.log(`[DEBUG] putBucketLifecycleConfiguration error:`, err.message);
+                cb(err);
+            });
     }
 
     /**
@@ -300,6 +310,7 @@ class LifecycleUtility extends ReplicationUtility {
         return async.doWhilst(
             next => this.s3.send(new HeadObjectCommand(params))
                 .then(data => {
+                    console.log(`AAAAA 21 ${data.StorageClass}, ${this.destinationLocation}`)
                     shouldContinue = data.StorageClass !== this.destinationLocation;
                     if (shouldContinue) {
                         return setTimeout(next, 5000);
@@ -449,7 +460,10 @@ class LifecycleUtility extends ReplicationUtility {
         }
         this.s3.send(new RestoreObjectCommand(params))
             .then(data => cb(null, data))
-            .catch(err => cb(err));
+            .catch(err => {
+                console.log(`[DEBUG] putRestoreObject error:`, err.message);
+                cb(err);
+            });
     }
 
     /**
@@ -478,7 +492,10 @@ class LifecycleUtility extends ReplicationUtility {
                     }
                     return next();
                 })
-                .catch(err => next(err)),
+                .catch(err => {
+                    console.log(`[DEBUG] AAAA 31 waitUntilRestored error:`, err.message);
+                    next(err);
+                }),
             () => shouldContinue,
             cb,
         );

tests/zenko_tests/node_tests/backbeat/tests/lifecycle/transition.js

@@ -29,22 +29,40 @@ function compareTransitionedData(sourceClient, destinationClient, versionId, cb)
 
 function compareTransitionedColdData(sourceClient, versionId, cb) {
     console.log("AAAA 3")
+    console.log(`[DEBUG] compareTransitionedColdData: Starting transition for versionId=${versionId}`);
     return series([
         next => sourceClient.getObject(versionId, next),
-        next => sourceClient.putBucketLifecycleConfiguration(new Date(new Date().setUTCHours(0, 0, 0, 0)), next),
-        next => sourceClient.waitUntilTransitioned(versionId, next),
-    ], cb);
+        next => {
+            console.log(`[DEBUG] compareTransitionedColdData: Setting lifecycle configuration`);
+            sourceClient.putBucketLifecycleConfiguration(new Date(new Date().setUTCHours(0, 0, 0, 0)), next);
+        },
+        next => {
+            console.log(`[DEBUG] compareTransitionedColdData: Waiting for transition`);
+            sourceClient.waitUntilTransitioned(versionId, next);
+        },
+    ], (err) => {
+        if (err) {
+            console.log(`[DEBUG] compareTransitionedColdData error:`, err.message);
+        } else {
+            console.log(`[DEBUG] compareTransitionedColdData: Successfully completed`);
+        }
+        cb(err);
+    });
 }
 
 function checkRestoration(destination, sourceClient, versionId, cb) {
-    console.log("AAAA 4")
+    console.log("AAAA 4", destination.supportsRestore)
     if (!destination.supportsRestore) {
         return process.nextTick(cb);
     }
     return series([
         next => sourceClient.getObject(versionId, err => {
-            assert.strictEqual(err.code, 'InvalidObjectState');
-            assert.strictEqual(err.statusCode, 403);
+            console.log("AAAA 22", err, err.Code, err.$metadata?.httpStatusCode)
+            // AWS SDK v3 uses different error property names
+            const errorCode = err.Code || err.code;
+            const statusCode = err.$metadata?.httpStatusCode || err.statusCode;
+            assert.strictEqual(errorCode, 'InvalidObjectState');
+            assert.strictEqual(statusCode, 403);
             return next();
         }),
         next => sourceClient.putRestoreObject(versionId, next),
@@ -118,6 +136,11 @@ testsToRun.forEach(test => {
 
         before(() => {
             console.log("AAAA 8")
+            console.log(`[DEBUG] Setting up test: from=${test.from} to=${test.to}`);
+            console.log(`[DEBUG] Source location: ${fromLoc.name}`);
+            console.log(`[DEBUG] Destination location: ${toLoc.name}`);
+            console.log(`[DEBUG] Environment COLD_BACKEND_DESTINATION_LOCATION: ${process.env.COLD_BACKEND_DESTINATION_LOCATION}`);
+            
             cloudServer.setSourceLocation(fromLoc.name);
             cloudServer.setDestinationLocation(toLoc.name);
             if (!toLoc.isCold) {