fixing coverage

Runnable · Sep 28, 2016 · 58e56e1 · 58e56e1
1 parent b2f33f2
commit 58e56e1
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git a/src/rabbitmq.js b/src/rabbitmq.js
@@ -677,12 +677,10 @@ class RabbitMQ {
       timestamp: Date.now(),
       headers: {}
     }
+    const ns = getNamespace('ponos')
+    jobMeta.headers.previousEvent = ns && ns.get('previousEvent')
     // add tid to message if one does not exist
     if (!content.tid) {
-      const ns = getNamespace('ponos')
-      if (ns) {
-        jobMeta.headers.previousEvent = ns.get('previousEvent')
-      }
       const tid = ns && ns.get('tid')
       content.tid = tid || uuid()
     }

diff --git a/test/unit/rabbitmq.js b/test/unit/rabbitmq.js
@@ -760,6 +760,12 @@ describe('rabbitmq', () => {
         })
       })
     })
+
+    it('should not set previousEvent if namespace does not exist', () => {
+      const payload = RabbitMQ.buildPayload({})
+      assert.isUndefined(payload.jobMeta.headers.previousEvent)
+    })
+
     describe('stringify error', function () {
       beforeEach(() => {
         sinon.stub(JSON, 'stringify').throws(new Error('custom json error'))