add tests for close garbage collector and expiration processor

Author: SylvainSenechal

tests/unit/gc/GarbageCollector.spec.js

@@ -92,4 +92,47 @@ describe('garbage collector', function garbageCollector() {
               .setAttribute('target.owner', ownerId);
         gcTask.processActionEntry(action, done);
     });
+
+    describe('close() garbage collector', () => {
+        it('should call close on the consumer when it exists', done => {
+            const gcWithConsumer = new GarbageCollector({
+                kafkaConfig: {},
+                s3Config: { host: 'localhost', port: 7777 },
+                gcConfig: {
+                    topic: 'backbeat-gc',
+                    auth: { type: 'account', account: 'bart' },
+                    consumer: { groupId: 'backbeat-gc-consumer-group' },
+                },
+            });
+            let closeCalled = false;
+            gcWithConsumer._consumer = {
+                close: cb => {
+                    closeCalled = true;
+                    cb();
+                },
+            };
+            gcWithConsumer.close(err => {
+                assert.ifError(err);
+                assert.strictEqual(closeCalled, true);
+                done();
+            });
+        });
+
+        it('should call callback immediately when consumer is null', done => {
+            const gcNoConsumer = new GarbageCollector({
+                kafkaConfig: {},
+                s3Config: { host: 'localhost', port: 7777 },
+                gcConfig: {
+                    topic: 'backbeat-gc',
+                    auth: { type: 'account', account: 'bart' },
+                    consumer: { groupId: 'backbeat-gc-consumer-group' },
+                },
+            });
+            assert.strictEqual(gcNoConsumer._consumer, null);
+            gcNoConsumer.close(err => {
+                assert.ifError(err);
+                done();
+            });
+        });
+    });
 });

tests/unit/lifecycle/LifecycleObjectExpirationProcessor.spec.js

@@ -23,4 +23,37 @@ describe('LifecycleObjectExpirationProcessor', () => {
             config.extensions.lifecycle.objectTasksTopic,
         );
     });
+
+    describe('close() expiration processor', () => {
+        it('should call close on consumers when they exist', done => {
+            let closeCalled = false;
+            objectProcessor._consumers = {
+                close: cb => {
+                    closeCalled = true;
+                    cb();
+                },
+            };
+            objectProcessor.close(err => {
+                assert.ifError(err);
+                assert.strictEqual(closeCalled, true);
+                done();
+            });
+        });
+
+        it('should call callback immediately when consumers is null', done => {
+            assert.strictEqual(objectProcessor._consumers, null);
+            objectProcessor.close(err => {
+                assert.ifError(err);
+                done();
+            });
+        });
+
+        it('should clear deleteInactiveCredentialsInterval if set', done => {
+            objectProcessor._deleteInactiveCredentialsInterval = setInterval(() => {}, 100000);
+            objectProcessor.close(err => {
+                assert.ifError(err);
+                done();
+            });
+        });
+    });
 });