Refactor debug log in ReplicateObject.js and update tests for check s…

…ource replication
scality · Oct 16, 2024 · 108a8b7 · 108a8b7
1 parent 286b401
commit 108a8b7
Showing 1 changed file with 1 addition and 17 deletions.
diff --git a/tests/functional/replication/queueProcessor.js b/tests/functional/replication/queueProcessor.js
@@ -965,23 +965,6 @@ describe('queue processor functional tests with mocking', () => {
             ], done);
         });
 
-        it('should not replicate metadata if already replicated', done => {
-            s3mock.setParam('nbParts', 2);
-            s3mock.setParam('source.md.replicationInfo.status', 'COMPLETED');
-            async.parallel([
-                done => {
-                    s3mock.onPutSourceMd = done;
-                },
-                done => queueProcessorSF.processReplicationEntry(
-                    s3mock.getParam('kafkaEntry'), err => {
-                        assert.ifError(err);
-                        assert.strictEqual(s3mock.hasPutTargetData, false);
-                        assert(s3mock.hasPutTargetMd);
-                        done();
-                    }),
-            ], done);
-        });
-
         it('should retry with full replication if metadata-only returns ' +
         'ObjNotFound', done => {
             s3mock.setParam('nbParts', 2);
@@ -1119,6 +1102,7 @@ describe('queue processor functional tests with mocking', () => {
             it('should skip if replication status is already COMPLETED',
             done => {
                 s3mock.setParam('nbParts', 2);
+                s3mock.setParam('source.md.contentLength', 10000000);
                 // kafka entry contains PENDING status as usual
                 const kafkaEntry = s3mock.getParam('kafkaEntry');
                 // getMetadata shall show a COMPLETED status for toazure