remit - npm Package Compare versions

Comparing version 2.3.2 to 2.3.3

lib/Endpoint.js

		@@ -152,4 +152,6 @@ const EventEmitter = require('eventemitter3')

		bubble.set('originId', message.properties.headers.originId)
		if (!bubble.get('bubbleId')) bubble.set('bubbleId', ulid())
		if (message.properties.headers) {
		bubble.set('originId', message.properties.headers.originId)
		if (!bubble.get('bubbleId')) bubble.set('bubbleId', ulid())
		}

		@@ -186,5 +188,7 @@ const event = parseEvent(message.properties, message.fields, data, {

		message.properties.headers.originId = message.properties.headers.originId \|\| bubble.get('originId')
		message.properties.headers.fromBubbleId = message.properties.headers.bubbleId
		message.properties.headers.bubbleId = bubble.get('bubbleId')
		if (message.properties.headers) {
		message.properties.headers.originId = message.properties.headers.originId \|\| bubble.get('originId')
		message.properties.headers.fromBubbleId = message.properties.headers.bubbleId
		message.properties.headers.bubbleId = bubble.get('bubbleId')
		}

		@@ -191,0 +195,0 @@ try {

lib/Listener.js

		@@ -151,4 +151,6 @@ const bubble = require('../utils/bubble')

		bubble.set('originId', message.properties.headers.originId)
		if (!bubble.get('bubbleId')) bubble.set('bubbleId', ulid())
		if (message.properties.headers) {
		bubble.set('originId', message.properties.headers.originId)
		if (!bubble.get('bubbleId')) bubble.set('bubbleId', ulid())
		}

		@@ -155,0 +157,0 @@ const event = parseEvent(message.properties, message.fields, data, {

lib/Request.js

		@@ -46,3 +46,3 @@ const CallableInstance = require('callable-instance')
		fallback (data) {
		if (typeof data === 'undefined') {
		if (arguments.length === 0) {
		delete this._fallback
		@@ -193,3 +193,3 @@ } else {
		}


		this._channel = await this._remit._publishChannels[opts.event]
		@@ -196,0 +196,0 @@

package.json

		{
		"name": "remit",
		"version": "2.3.2",
		"version": "2.3.3",
		"description": "A small set of functionality used to create microservices that don't need to be aware of one-another's existence.",
		@@ -5,0 +5,0 @@ "main": "index.js",

README.md

		@@ -137,3 +137,3 @@ # remit

		You can change the fallback at any point in a request's life and unset it by explicitly passing `undefined`.
		You can change the fallback at any point in a request's life and unset it by passing no arguments to the function.

		@@ -140,0 +140,0 @@ Returns a reference to the `request`, so that calls can be chained.

test/endpoint.test.js

		@@ -621,2 +621,4 @@ /* global describe, it, before, expect */
		})

		it('should not throw when message has no headers property')
		})

test/listener.test.js

		@@ -47,3 +47,5 @@ /* global describe, it, before, expect */
		})

		it('should not throw when message has no headers property')
		})
		})

Fixed alerts