aswh - npm Package Compare versions

Comparing version 1.4.0 to 1.4.1

components/Keuss.js

@@ -22,2 +22,10 @@ var _ =     require('lodash');
   //////////////////////////////////////////////////////////////////////////////////////////////////
+  _compose_keuss_url (qgroup) {
+    const url = new URL(this._opts.keuss.base_url);
+    url.pathname = `${url.pathname}_${qgroup}`;
+    return url.toString(); 
+  }
+
+
+  //////////////////////////////////////////////////////////////////////////////////////////////////
   init (context, cb) {
@@ -28,5 +36,6 @@ var tasks_mq = [];
     _.each (this._opts.keuss.queue_groups, (qg, qg_name)  => {
-      var keuss_factories_opts = {
+      const keuss_factories_opts = {
         name: qg_name,
-        url: `${this._opts.keuss.base_url}_${qg_name}`,
+        // TODO extract qs
+        url: this._compose_keuss_url (qg_name),
         deadletter: {
@@ -33,0 +42,0 @@ max_ko: qg.max_retries || this._opts.defaults.retry.max

index.js

@@ -15,2 +15,3 @@
     keuss: {
+      base_url: 'mongodb://localhost/aswh',
       queue_groups: {
@@ -61,3 +62,3 @@ default: {
   .env ()
-  .file(`${__dirname}/etc/config.js`, {ignore_missing: true})
+  .file(`${__dirname}/etc/config.js`,                        {ignore_missing: true})
   .file(`${__dirname}/etc/config-{NODE_ENV:development}.js`, {ignore_missing: true})
@@ -64,0 +65,0 @@ .env ()

package.json

 {
   "name": "aswh",
   "description": "Asynchronous WebHook delivery, or generic store-and-forward HTTP proxy",
-  "version": "1.4.0",
+  "version": "1.4.1",
   "keywords": [
@@ -29,3 +29,3 @@ "webhook",
     "body-parser": "~1.20.2",
-    "cascade-config": "~1.6.0",
+    "cascade-config": "~1.7.0",
     "cron-parser": "~4.9.0",
@@ -32,0 +32,0 @@ "express": "~4.18.2",

No alert changes

Improved metrics

Total package byte prevSize

197409

increased by0.18%

Lines of code

2753

increased by0.29%

Dependency changes

• + Addedcascade-config@1.7.0(transitive)

• Updatedcascade-config@~1.7.0