add versioning supended OOB tests

Issue: ZENKO-4330

Author: Kerkesni

tests/zenko_tests/node_tests/backbeat/ReplicationUtility.js

@@ -487,6 +487,15 @@ class ReplicationUtility {
         ], err => cb(err));
     }
 
+    putBucketVersioning(bucketName, status, cb) {
+        this.s3.putBucketVersioning({
+            Bucket: bucketName,
+            VersioningConfiguration: {
+                Status: status,
+            },
+        }, cb);
+    }
+
     putBucketReplicationMultipleBackend(
         srcBucket,
         destBucket,

tests/zenko_tests/node_tests/backbeat/tests/ingestion/ingestionS3C.js

@@ -27,6 +27,11 @@ describe('Ingesting existing data from RING S3C bucket', () => {
             null,
             next,
         ),
+        next => ringS3CUtils.putBucketVersioning(
+            ingestionSrcBucket,
+            'Enabled',
+            next,
+        ),
         next => scalityUtils.waitUntilEmpty(INGESTION_DEST_BUCKET, next),
         next => scalityUtils.deleteVersionedBucket(INGESTION_DEST_BUCKET, next),
     ], done));
@@ -281,4 +286,64 @@ describe('Ingesting existing data from RING S3C bucket', () => {
             next,
         ),
     ], done));
+
+    it('should ingest a versioning suspended object', done => async.series([
+        next => ringS3CUtils.putBucketVersioning(
+            ingestionSrcBucket,
+            'Suspended',
+            next,
+        ),
+        next => ringS3CUtils.putObject(
+            ingestionSrcBucket,
+            OBJ_KEY,
+            Buffer.alloc(1),
+            next,
+        ),
+        next => scalityUtils.createIngestionBucket(
+            INGESTION_DEST_BUCKET,
+            location,
+            next,
+        ),
+        next => scalityUtils.compareObjectsRINGS3C(
+            ingestionSrcBucket,
+            INGESTION_DEST_BUCKET,
+            OBJ_KEY,
+            'null',
+            undefined,
+            next,
+        ),
+    ], done));
+
+    it('should ingest a null version of a versioned object', done => async.series([
+        next => ringS3CUtils.putObject(
+            ingestionSrcBucket,
+            OBJ_KEY,
+            Buffer.alloc(1),
+            next,
+        ),
+        next => ringS3CUtils.putBucketVersioning(
+            ingestionSrcBucket,
+            'Suspended',
+            next,
+        ),
+        next => ringS3CUtils.putObject(
+            ingestionSrcBucket,
+            OBJ_KEY,
+            Buffer.alloc(1),
+            next,
+        ),
+        next => scalityUtils.createIngestionBucket(
+            INGESTION_DEST_BUCKET,
+            location,
+            next,
+        ),
+        next => scalityUtils.compareObjectsRINGS3C(
+            ingestionSrcBucket,
+            INGESTION_DEST_BUCKET,
+            OBJ_KEY,
+            'null',
+            undefined,
+            next,
+        ),
+    ], done));
 });

tests/zenko_tests/node_tests/backbeat/tests/ingestion/oobS3C.js

@@ -26,6 +26,11 @@ describe('OOB updates for RING S3C bucket', () => {
             null,
             next,
         ),
+        next => ringS3CUtils.putBucketVersioning(
+            ingestionSrcBucket,
+            'Enabled',
+            next,
+        ),
         next => scalityUtils.waitUntilEmpty(INGESTION_DEST_BUCKET, next),
         next => scalityUtils.deleteVersionedBucket(
             INGESTION_DEST_BUCKET,
@@ -161,4 +166,54 @@ describe('OOB updates for RING S3C bucket', () => {
             next,
         ),
     ], done));
+
+    it('should receive OOB update with a versioning suspended object', done => async.series([
+        next => ringS3CUtils.putBucketVersioning(
+            ingestionSrcBucket,
+            'Suspended',
+            next,
+        ),
+        next => ringS3CUtils.putObject(
+            ingestionSrcBucket,
+            OBJ_KEY,
+            Buffer.alloc(1),
+            next,
+        ),
+        next => scalityUtils.compareObjectsRINGS3C(
+            ingestionSrcBucket,
+            INGESTION_DEST_BUCKET,
+            OBJ_KEY,
+            'null',
+            undefined,
+            next,
+        ),
+    ], done));
+
+    it('should receive OOB update with a null version of a versioned object', done => async.series([
+        next => ringS3CUtils.putObject(
+            ingestionSrcBucket,
+            OBJ_KEY,
+            Buffer.alloc(1),
+            next,
+        ),
+        next => ringS3CUtils.putBucketVersioning(
+            ingestionSrcBucket,
+            'Suspended',
+            next,
+        ),
+        next => ringS3CUtils.putObject(
+            ingestionSrcBucket,
+            OBJ_KEY,
+            Buffer.alloc(1),
+            next,
+        ),
+        next => scalityUtils.compareObjectsRINGS3C(
+            ingestionSrcBucket,
+            INGESTION_DEST_BUCKET,
+            OBJ_KEY,
+            'null',
+            undefined,
+            next,
+        ),
+    ], done));
 });