add event bus call logging

Author: gondzo

src/events/busApi.js

@@ -28,7 +28,7 @@ module.exports = (app, logger) => {
       projectId: project.id,
       projectName: project.name,
       initiatorUserId: req.authUser.userId,
-    });
+    }, logger);
   });
 
   /**
@@ -43,7 +43,7 @@ module.exports = (app, logger) => {
         projectId: updated.id,
         projectName: updated.name,
         initiatorUserId: req.authUser.userId,
-      });
+      }, logger);
     } else if (
       !_.isEqual(original.details, updated.details) ||
       !_.isEqual(original.name, updated.name) ||
@@ -53,14 +53,14 @@ module.exports = (app, logger) => {
         projectId: updated.id,
         projectName: updated.name,
         initiatorUserId: req.authUser.userId,
-      });
+      }, logger);
     } else if (!_.isEqual(original.bookmarks, updated.bookmarks)) {
       logger.debug('project bookmarks is updated');
       createEvent(BUS_API_EVENT.PROJECT_LINK_CREATED, {
         projectId: updated.id,
         projectName: updated.name,
         initiatorUserId: req.authUser.userId,
-      });
+      }, logger);
     }
   });
 
@@ -93,7 +93,7 @@ module.exports = (app, logger) => {
         projectName: project.name,
         userId: member.userId,
         initiatorUserId: req.authUser.userId,
-      });
+      }, logger);
     }).catch(err => null);    // eslint-disable-line no-unused-vars
   });
 
@@ -121,7 +121,7 @@ module.exports = (app, logger) => {
           projectName: project.name,
           userId: member.userId,
           initiatorUserId: req.authUser.userId,
-        });
+        }, logger);
       }
     }).catch(err => null);    // eslint-disable-line no-unused-vars
   });
@@ -144,7 +144,7 @@ module.exports = (app, logger) => {
             projectName: project.name,
             userId: updated.userId,
             initiatorUserId: req.authUser.userId,
-          });
+          }, logger);
         }
       }).catch(err => null);    // eslint-disable-line no-unused-vars
     }
@@ -167,7 +167,7 @@ module.exports = (app, logger) => {
         projectName: project.name,
         fileName: attachment.filePath.replace(/^.*[\\\/]/, ''),    // eslint-disable-line
         initiatorUserId: req.authUser.userId,
-      });
+      }, logger);
     }).catch(err => null);    // eslint-disable-line no-unused-vars
   });
 };

src/services/busApi.js

@@ -36,16 +36,27 @@ function getClient() {
  * Any errors will be simply ignored
  * @param {String} type the event type, should be a dot separated fully qualitied name
  * @param {Object} message the message, should be a JSON object
+ * @param {Object} logger object
  * @return {Promise} new event promise
  */
-function createEvent(type, message) {
+function createEvent(type, message, logger) {
   const body = JSON.stringify(message);
+  logger.debug(`Sending message: ${JSON.stringify(message)}`);
   return getClient().post('/eventbus/events', {
     type,
     message: body,
   })
-  .then(resp => resp)
-  .catch(error => Promise.resolve());    // eslint-disable-line
+  .then((resp) => {
+    logger.debug('Sent event to bus-api');
+    logger.debug(`Sent event to bus-api [data]: ${resp.data}`);
+    logger.debug(`Sent event to bus-api [status]: ${resp.status}`);
+  })
+  .catch((error) => {
+    logger.debug('Error sending event to bus-api');
+    logger.debug(`Error sending event to bus-api [message]: ${error.message}`);
+    logger.debug(`Error sending event to bus-api [detail]: ${error.response.data.message}`);
+    Promise.resolve();     // eslint-disable-line
+  });
 }