Peg to specific bcoin commitvue

1 files changed, 46 insertions, 52 deletions

diff --git a/bcoin.js b/bcoin.js
index d903283a..78cee250 100644
--- a/bcoin.js
+++ b/bcoin.js
@@ -1,104 +1,98 @@
 (function() {
-  var bcoin, config, db, twilio;
-
-  bcoin = require('bcoin');
-
-  config = require('./config');
-
-  db = require('./redis');
-
-  twilio = require('twilio');
+  const bcoin = require('bcoin')
+  const config = require('./config')
+  const db = require('./redis')
+  const twilio = require('twilio')
 
   module.exports = {
     init: function(app) {
-      var chain, pool, users;
-      users = {};
+      var chain, pool, users
+      users = {}
       chain = new bcoin.chain({
         db: 'leveldb',
         name: 'spvchain',
         location: __dirname + '/db/spvchain',
         spv: true
-      });
+      })
       pool = new bcoin.pool({
         chain: chain,
         spv: true,
         size: 1,
         maxPeers: 1,
         seeds: ['dctrl.ca']
-      });
+      })
       return pool.open().then(function() {
         db.keysAsync("user:*").then(function(keys) {
           return Promise.all(keys.map(function(key) {
             return db.hgetallAsync(key).then(function(user) {
               if (user.address) {
-                pool.watchAddress(user.address);
+                pool.watchAddress(user.address)
                 return users[user.address] = {
                   email: user.email,
                   currency: user.currency,
                   symbol: user.symbol,
                   phone: user.phone
-                };
+                }
               }
-            });
-          }));
-        });
-        pool.connect();
-        pool.startSync();
+            })
+          }))
+        })
+        pool.connect().then(function() { pool.startSync() })
         pool.on('error', function(err) {
-          return console.log(err);
-        });
+          return console.log(err)
+        })
         return pool.on('tx', function(tx) {
-          var address, client, i, len, output, ref, results, value;
-          ref = tx.outputs;
-          results = [];
+          var address, client, i, len, output, ref, results, value
+          ref = tx.outputs
+          results = []
           for (i = 0, len = ref.length; i < len; i++) {
-            output = ref[i];
-            value = (output.value / 100000000).toFixed(8);
-            address = output.getAddress().toBase58();
+            output = ref[i]
+            value = (output.value / 100000000).toFixed(8)
+            address = output.getAddress().toBase58()
             if (Object.keys(users).includes(address)) {
               app.render('payment', {
                 value: value,
                 address: address
               }, function(err, html) {
-                var content, from_email, helper, mail, request, sg, subject, to_email;
-                helper = require('sendgrid').mail;
-                from_email = new helper.Email('[email protected]');
-                to_email = new helper.Email(users[address].email);
-                subject = 'Received Payment';
-                content = new helper.Content('text/html', html);
-                mail = new helper.Mail(from_email, subject, to_email, content);
-                sg = require('sendgrid')(config.sendgrid_token);
+                var content, from_email, helper, mail, request, sg, subject, to_email
+                helper = require('sendgrid').mail
+                from_email = new helper.Email('[email protected]')
+                to_email = new helper.Email(users[address].email)
+                subject = 'Received Payment'
+                content = new helper.Content('text/html', html)
+                mail = new helper.Mail(from_email, subject, to_email, content)
+                sg = require('sendgrid')(config.sendgrid_token)
                 request = sg.emptyRequest({
                   method: 'POST',
                   path: '/v3/mail/send',
                   body: mail.toJSON()
-                });
+                })
                 return sg.API(request, function(error, response) {
-                  console.log(response.statusCode);
-                  console.log(response.body);
-                  return console.log(response.headers);
-                });
-              });
+                  console.log(response.statusCode)
+                  console.log(response.body)
+                  return console.log(response.headers)
+                })
+              })
               if (users[address].phone) {
-                client = new twilio.RestClient(config.twilio_sid, config.twilio_token);
+                client = new twilio.RestClient(config.twilio_sid, config.twilio_token)
                 results.push(client.messages.create({
                   to: user.phone,
                   from: config.twilio_number,
                   body: "You received a payment of " + value + " BTC"
                 }, function(err, message) {
-                  return console.log(message.sid);
-                }));
+                  return console.log(message.sid)
+                }))
               } else {
-                results.push(void 0);
+                results.push(void 0)
               }
             } else {
-              results.push(void 0);
+              results.push(void 0)
             }
           }
-          return results;
-        });
-      });
+          return results
+        })
+      })
     }
-  };
+  }
 
-}).call(this);
+}).call(this)