style: apply code format

lykmapipo · Jun 8, 2020 · ae19d80 · ae19d80
1 parent 81265f9
commit ae19d80
Show file tree

Hide file tree

Showing 38 changed files with 613 additions and 613 deletions.
diff --git a/lib/campaign.http.router.js b/lib/campaign.http.router.js
@@ -315,4 +315,4 @@ router.delete(
 );
 
 /* expose campaign router */
-module.exports = exports = router;
+module.exports = exports = router;
diff --git a/lib/common.js b/lib/common.js
@@ -20,6 +20,8 @@ const { toE164 } = require('@lykmapipo/phone');
  */
 exports.toE164 = toE164;
 
+// TODO: createContactSchema(schema, optns = { callingCode, mobilePrefix });
+
 /**
  * @description contact sub schema
  * @author lally elias <lallyelias87@gmail.com>
@@ -42,7 +44,7 @@ exports.Contact = createSubSchema({
     index: true,
     searchable: true,
     taggable: true,
-    fake: faker => faker.helpers.replaceSymbolWithNumber('255714######'),
+    fake: (faker) => faker.helpers.replaceSymbolWithNumber('255714######'),
   },
   email: {
     type: String,

diff --git a/lib/message.model.js b/lib/message.model.js
@@ -745,7 +745,7 @@ MessageSchema.methods.isHtml = function _isHtml() {
  * @version 0.1.0
  * @private
  */
-MessageSchema.methods._send = function(done) {
+MessageSchema.methods._send = function (done) {
   //this refer to Message instance context
 
   try {
@@ -771,7 +771,7 @@ MessageSchema.methods._send = function(done) {
           //send message via transport
           transport.send(
             this,
-            function(error, result) {
+            function (error, result) {
               //prepare result
               let _result = _.merge(
                 {},
@@ -905,7 +905,7 @@ MessageSchema.methods.queue = function queue(done) {
   }
 
   //persist message
-  this.save(function(error, message) {
+  this.save(function (error, message) {
     //notify error
     if (error) {
       worker.queue.emit('job error', error);
@@ -936,7 +936,7 @@ MessageSchema.methods.queue = function queue(done) {
       const job = message.runInBackground(jobDetails);
 
       //ensure message has been queued
-      return job.save(function(error) {
+      return job.save(function (error) {
         if (error) {
           worker.queue.emit('job error', error);
           return cb(error);
@@ -1127,8 +1127,8 @@ MessageSchema.statics.resend = function resend(criteria, done) {
         if (unsents) {
           /* @todo make use of parallelism */
           //prepare send work
-          unsents = _.map(unsents, function(unsent) {
-            return function(_next) {
+          unsents = _.map(unsents, function (unsent) {
+            return function (_next) {
               unsent.send(_next); /* @todo spies test */
             };
           });
@@ -1160,7 +1160,7 @@ MessageSchema.statics.resend = function resend(criteria, done) {
  * Message.requeue(criteria);
  *
  */
-MessageSchema.statics.requeue = function(criteria) {
+MessageSchema.statics.requeue = function (criteria) {
   //this refer to Message static context
 
   /* @todo use stream */
@@ -1172,7 +1172,7 @@ MessageSchema.statics.requeue = function(criteria) {
   const Message = this;
 
   //find all unsent message(s) for requeue
-  Message.unsent(_criteria, function(error, unsents) {
+  Message.unsent(_criteria, function (error, unsents) {
     //there is no message queue
     if (!worker.queue) {
       if (error) {
@@ -1193,7 +1193,7 @@ MessageSchema.statics.requeue = function(criteria) {
         worker.queue.emit('job success', unsents);
 
         //re-queue unsent message
-        _.forEach(unsents, function(unsent) {
+        _.forEach(unsents, function (unsent) {
           unsent.queue();
         });
       }