testing

Author: Luisgustavom1

test/subscriber.ts

@@ -719,6 +719,50 @@ describe('Subscriber', () => {
     });
   });
 
+  describe('nackWithResponse', () => {
+    it('should modAck the message with a 0 deadline', async () => {
+      const stub = sandbox.stub(subscriber, 'modAck');
+
+      await subscriber.nackWithResponse(message);
+
+      const [msg, deadline] = stub.lastCall.args;
+
+      assert.strictEqual(msg, message);
+      assert.strictEqual(deadline, 0);
+    });
+
+    it('should remove the message from the inventory', async () => {
+      const inventory: FakeLeaseManager = stubs.get('inventory');
+      const stub = sandbox.stub(inventory, 'remove').withArgs(message);
+
+      await subscriber.nackWithResponse(message);
+
+      assert.strictEqual(stub.callCount, 1);
+    });
+  });
+
+  describe('ackWithResponse', () => {
+    it('should modAck the message with a 0 deadline', async () => {
+      const stub = sandbox.stub(subscriber, 'modAck');
+
+      await subscriber.ackWithResponse(message);
+
+      const [msg, deadline] = stub.lastCall.args;
+
+      assert.strictEqual(msg, message);
+      assert.strictEqual(deadline, 0);
+    });
+
+    it('should remove the message from the inventory', async () => {
+      const inventory: FakeLeaseManager = stubs.get('inventory');
+      const stub = sandbox.stub(inventory, 'remove').withArgs(message);
+
+      await subscriber.ackWithResponse(message);
+
+      assert.strictEqual(stub.callCount, 1);
+    });
+  });
+
   describe('open', () => {
     beforeEach(() => subscriber.close());