remit - npm Package Compare versions

Comparing version 2.0.0-beta.5 to 2.0.0-beta.7

index.js

@@ -33,12 +33,2 @@ const packageJson = require('./package.json')
 
-  this.delayedEmit = Request.apply(this, [{
-    expectReply: false,
-
-    before: (remit, options) => {
-      options.demission = true
-
-      return options
-    }
-  }])
-
   this.respond = Response.apply(this, [{
@@ -49,7 +39,2 @@ shouldAck: false,
 
-  this.respondQueue = Response.apply(this, [{
-    shouldAck: true,
-    shouldReply: true
-  }])
-
   this.listen = Response.apply(this, [{
@@ -56,0 +41,0 @@ shouldAck: true,

lib/Request.js

@@ -58,3 +58,3 @@ const debug = require('debug')('remit:request')
     const extra = Array.from(arguments)
-    const data = extra.shift()
+    const data = extra.shift() || {}
     const localOpts = Object.assign({}, request._options, extra.shift() || {})
@@ -76,3 +76,3 @@ const now = +new Date()
       .then(() => {
-        if (!options.demission) {
+        if (isNaN(localOpts.delay) && !localOpts.schedule) {
           return getPublishChannel.apply(remit)
@@ -92,4 +92,2 @@ }
         if (expiration <= 0) {
-          options.demission = false
-
           return getPublishChannel.apply(remit)
@@ -175,3 +173,3 @@ }
 
-        if (options.demission) {
+        if (localOpts.schedule || localOpts.delay) {
           if (localOpts.schedule) {
@@ -178,0 +176,0 @@ messageOptions.headers.schedule = +localOpts.schedule

lib/Response.js

@@ -22,7 +22,3 @@ const debug = require('debug')('remit:response')
     if (!options.queue) {
-      if (masterOptions.listener) {
-        options.queue = `${event}:l:${remit._options.name}:${++remit._internal.listenerCount}`
-      } else {
-        options.queue = options.event
-      }
+      options.queue = options.event
     }
@@ -29,0 +25,0 @@

package.json

 {
   "name": "remit",
-  "version": "2.0.0-beta.5",
+  "version": "2.0.0-beta.7",
   "description": "A small set of functionality used to create microservices that don't need to be aware of one-another's existence.",
@@ -57,3 +57,8 @@ "main": "index.js",
   },
-  "homepage": "https://github.com/jpwilliams/remit#readme"
+  "homepage": "https://github.com/jpwilliams/remit#readme",
+  "files": [
+    "test",
+    "resources",
+    "lib"
+  ]
 }

resources/aliases.json

 {
   "request": ["req"],
   "emit": [],
-  "delayedEmit": ["demit"],
   "respond": ["res", "endpoint"],
-  "respondQueue": ["resq", "queue"],
   "listen": ["on"]
 }

No alert changes

Worsened metrics

Total package byte prevSize

43414

-68.77%

Number of package files

21

-50%

Lines of code

941

-40.63%

No dependency changes