Added integration tests, reduced sensitive logging

Author: zubairov

lib/actions/publish.js

@@ -2,6 +2,7 @@
 const co = require('co');
 const amqp = require('amqplib');
 const encryptor = require('../encryptor.js');
+const debug = require('debug')('publish');
 
 let channel;
 
@@ -14,15 +15,15 @@ module.exports.init = init;
  * @param cfg
  */
 function init(cfg) {
-    console.log('Starting initialization, cfg=%j', cfg);
+    console.log('Starting initialization');
     const amqpURI = cfg.amqpURI;
     const amqpExchange = cfg.topic;
     return co(function* gen() {
-        console.log('Connecting to amqpURI=%s', amqpURI);
+        debug('Connecting to amqpURI=%s', amqpURI);
         const conn = yield amqp.connect(amqpURI);
-        console.log('Creating a confirm channel');
+        debug('Creating a confirm channel');
         channel = yield conn.createConfirmChannel();
-        console.log('Asserting topic exchange exchange=%s', amqpExchange);
+        debug('Asserting topic exchange exchange=%s', amqpExchange);
         yield channel.assertExchange(amqpExchange, 'topic');
     });
 }

lib/triggers/consume.js

@@ -15,7 +15,7 @@ let listening;
  * @param cfg
  */
 function init(cfg) {
-    console.log('Starting initialization, cfg=%j queueName=%s', cfg, queueName);
+    console.log('Starting initialization, queueName=%s', queueName);
     const amqpURI = cfg.amqpURI;
     const amqpExchange = cfg.topic;
     const keys = (cfg.bindingKeys || '#').split(',').map((s) => s.trim());
@@ -51,7 +51,7 @@ function init(cfg) {
  * @param cfg configuration that is account information and configuration field values
  */
 function processAction(msg, cfg) {
-    console.log('Trigger started, cfg=%j', cfg);
+    console.log('Trigger started');
     if (listening) {
         console.log('Trigger was called again, we will ignore this run');
         return Promise.resolve();