chore(log): export logging of results

Author: Yassine AZZOUT

index.js

@@ -1,2 +1,3 @@
 module.exports.api = require('./src/api');
 module.exports.core = require('./src/core');
+module.exports.log = require('./src/log');

src/core.js

@@ -183,23 +183,5 @@ module.exports.bulk = async (eventsPath) => {
   const events = require(eventsPath);
   const results =  await api.bulk(events);
 
-  results
-    .filter(result => result.isFulfilled)
-    .map(result => result.value)
-    .forEach(result => {
-      console.log('Event inserted');
-      conf.BULK_RESULT.forEach(property => {
-        if (result[property]) {
-          console.log(` ${property}: ${result[property]}`);
-        }
-      });
-    });
-
-  results
-    .filter(result => result.isRejected)
-    .map(result => result.reason)
-    .forEach(result => {
-      console.error('[ERROR] Error inserting event');
-      log.error(result.reason, true);
-    });
+  log.results(results);
 };

src/log.js

@@ -1,12 +1,41 @@
+const conf = require('./conf');
+
 /**
  * Log error to console
  * @param  {[Object}  err
  * @param  {Boolean}
  */
-module.exports.error = (err, debug = false) => {
+const error = module.exports.error = (err, debug = false) => {
   if (debug) {
     console.error(`[ERROR] ${err.code} ${err.stack}`);
   } else {
     console.error(`[ERROR] ${err.message}`);
   }
 };
+
+/**
+ * Log results to console
+ * @param  {Array}  results
+ * @param  {Boolean}
+ */
+module.exports.results = results => {
+  results
+    .filter(result => result.isFulfilled)
+    .map(result => result.value)
+    .forEach(result => {
+      console.log('Event inserted');
+      conf.BULK_RESULT.forEach(property => {
+        if (result[property]) {
+          console.log(` ${property}: ${result[property]}`);
+        }
+      });
+    });
+
+  results
+    .filter(result => result.isRejected)
+    .map(result => result.reason)
+    .forEach(result => {
+      console.error('[ERROR] Error inserting event');
+      error(result.reason, true);
+    });
+};