smqp - npm Package Compare versions

Comparing version 5.1.2 to 5.1.3

CHANGELOG.md

 Changelog
 =========
 
+# 5.1.3
+
+- minor, probably futile, tweaks
+
 # 5.1.2
@@ -5,0 +9,0 @@

dist/src/Message.js

@@ -12,3 +12,2 @@ "use strict";
 const onConsumedSymbol = Symbol.for('onConsumed');
-const publicMethods = ['ack', 'nack', 'reject'];
 
@@ -32,7 +31,5 @@ function Message(fields, content, properties, onConsumed) {
   this.properties = mproperties;
-
-  for (let i = 0; i < publicMethods.length; i++) {
-    const fn = publicMethods[i];
-    this[fn] = Message.prototype[fn].bind(this);
-  }
+  this.ack = this.ack.bind(this);
+  this.nack = this.nack.bind(this);
+  this.reject = this.reject.bind(this);
 }
@@ -39,0 +36,0 @@

dist/src/Queue.js

@@ -316,6 +316,4 @@ "use strict";
 
-  for (let idx = 1; idx < this.messages.length; idx++) {
-    if (!this.messages[idx].pending) {
-      return this.messages[idx];
-    }
+  for (const msg of this.messages) {
+    if (!msg.pending) return msg;
   }
@@ -322,0 +320,0 @@ };

package.json

 {
   "name": "smqp",
-  "version": "5.1.2",
+  "version": "5.1.3",
   "description": "Synchronous message queueing package",
@@ -61,8 +61,8 @@ "author": {
     "@babel/cli": "^7.16.0",
-    "@babel/core": "^7.16.0",
-    "@babel/preset-env": "^7.16.0",
-    "@babel/register": "^7.16.0",
+    "@babel/core": "^7.16.5",
+    "@babel/preset-env": "^7.16.5",
+    "@babel/register": "^7.16.5",
     "chai": "^4.2.0",
     "chronokinesis": "^3.0.0",
-    "eslint": "^8.2.0",
+    "eslint": "^8.5.0",
     "markdown-toc": "^1.2.0",
@@ -69,0 +69,0 @@ "mocha": "^9.1.3",

README.md

 SMQP
 ====
 
-[![Build Status](https://travis-ci.com/paed01/smqp.svg?branch=default)](https://travis-ci.com/paed01/smqp)[![Build status](https://ci.appveyor.com/api/projects/status/8dy3yrde5pe8mk6m/branch/default?svg=true)](https://ci.appveyor.com/project/paed01/smqp/branch/default)[![Coverage Status](https://coveralls.io/repos/github/paed01/smqp/badge.svg?branch=default)](https://coveralls.io/github/paed01/smqp?branch=default)[![Project Status: Active – The project has reached a stable, usable state and is being actively developed.](https://www.repostatus.org/badges/latest/active.svg)](https://www.repostatus.org/#active)
+[![Build Status](https://app.travis-ci.com/paed01/smqp.svg?branch=default)](https://app.travis-ci.com/paed01/smqp)[![Build status](https://ci.appveyor.com/api/projects/status/8dy3yrde5pe8mk6m/branch/default?svg=true)](https://ci.appveyor.com/project/paed01/smqp/branch/default)[![Coverage Status](https://coveralls.io/repos/github/paed01/smqp/badge.svg?branch=default)](https://coveralls.io/github/paed01/smqp?branch=default)[![Project Status: Active – The project has reached a stable, usable state and is being actively developed.](https://www.repostatus.org/badges/latest/active.svg)](https://www.repostatus.org/#active)
 
@@ -6,0 +6,0 @@ Synchronous message queueing package. Used as an alternative, and frontend ready, event handler when you expect events to be handled in sequence.

src/Message.js

@@ -8,4 +8,2 @@ import { generateId } from './shared';
 
-const publicMethods = ['ack', 'nack', 'reject'];
-
 function Message(fields, content, properties, onConsumed) {
@@ -27,6 +25,6 @@ this[onConsumedSymbol] = [null, onConsumed];
   this.properties = mproperties;
-  for (let i = 0; i < publicMethods.length; i++) {
-    const fn = publicMethods[i];
-    this[fn] = Message.prototype[fn].bind(this);
-  }
+
+  this.ack = this.ack.bind(this);
+  this.nack = this.nack.bind(this);
+  this.reject = this.reject.bind(this);
 }
@@ -33,0 +31,0 @@

src/Queue.js

@@ -290,6 +290,4 @@ import {generateId, sortByPriority} from './shared';
 
-  for (let idx = 1; idx < this.messages.length; idx++) {
-    if (!this.messages[idx].pending) {
-      return this.messages[idx];
-    }
+  for (const msg of this.messages) {
+    if (!msg.pending) return msg;
   }
@@ -296,0 +294,0 @@ };

No alert changes

Worsened metrics

Total package byte prevSize

107321

decreased by-0.21%

Lines of code

2894

decreased by-0.28%

No dependency changes