added sentry exception tracking

Author: dillonchr

bookmancy/main.js

@@ -1,4 +1,5 @@
 const bookmancy = require('bookmancy');
+const Raven = require('raven');
 const slackResponder = require('./slack-responder');
 const confirmMessage = require('./confirmation-messages');
 const is = {
@@ -21,14 +22,22 @@ module.exports = c => {
                 year: format && !isNaN(format) ? format : !isNaN(year) && year,
                 format: isNaN(year) ? year : format
             };
-            
+
             bookmancy.abe.searchWithUrlInResponse(query)
                 .then(({results, url}) => {
                     const searchTitle = messagePieces.join(' - ');
                     b.reply(m, slackResponder(searchTitle, url, results));
                 })
                 .catch(err => {
-                    console.error(err.message || err.toString(), err.stack);
+                    Raven.context(() => {
+                        Raven.setContext({
+                            module: {
+                                name: 'bookmancy',
+                                cmd: m.text
+                            }
+                        });
+                        Raven.captureException(err);
+                    })
                     b.reply(m, {
                         response_type: 'ephemeral',
                         text: 'There was a problem processing your search. Try again soon.'
@@ -40,7 +49,8 @@ module.exports = c => {
             const isLive = is.live(command);
             const query = command.replace(isLive ? /live/i : /sold/i, '').trim();
             return bookmancy.ebay[`search${isLive ? 'Live' : 'Sold'}Listings`](query)
-                .then(r => b.reply(m, slackResponder(query, '', r, true)));
+                .then(r => b.reply(m, slackResponder(query, '', r, true)))
+                .catch(err => Raven.captureException(err));
         }
     });
 };

fired/fired.js

@@ -2,6 +2,7 @@ const getDom = require('../utils/getDom');
 const SimpleDb = require('../utils/simple-db');
 const ROSTER_URL = 'https://consumeraffairs.com/about/staff/';
 const COLL_NAME = 'employees';
+const Raven = require('raven');
 
 class Fired extends SimpleDb {
     constructor() {
@@ -24,7 +25,7 @@ class Fired extends SimpleDb {
                         fired: false
                     }));
                 if (!roster || !roster.length) {
-                    throw new Error('no employee data found on domQuery');
+                    Raven.captureException(new Error('FIRED: no employee data found on domQuery'));
                 }
                 return roster;
             });
@@ -39,7 +40,7 @@ class Fired extends SimpleDb {
         if (!oldRoster.length) {
             this.saveMany(nowRoster)
                 .then(() => console.log('No news. Saved current roster for future comparisons.'))
-                .catch(err => console.error(err));
+                .catch(err => Raven.captureException(err));
             return [];
         } else {
             //  employees that aren't found in the newly loaded roster
@@ -56,7 +57,7 @@ class Fired extends SimpleDb {
 
             if (newHires.length) {
                 this.saveMany(newHires)
-                    .catch(err => console.log('problem saving yo'));
+                    .catch(err => Raven.captureException(err));
             }
             if (newFires.length) {
                 const wait = newFires

index.js

@@ -1,9 +1,12 @@
 require('dotenv').config();
+const Raven = require('raven');
+Raven.config(process.env.SENTRY_URL).install();
 const Botkit = require('botkit/lib/Botkit.js');
 const os = require('os');
 
 if (!process.env.token) {
     console.log('Error: Specify token in environment');
+    Raven.captureException(new Error('no token in environment'));
     process.exit(1);
 }
 const controller = Botkit.slackbot({debug: false});

package-lock.json

@@ -18,7 +18,8 @@
     "dotenv": "^4.0.0",
     "jsdom": "^9.9.1",
     "momentjs": "^2.0.0",
-    "mongodb": "^2.2.29"
+    "mongodb": "^2.2.29",
+    "raven": "^2.4.0"
   },
   "devDependencies": {
     "jest": "^20.0.4"

package.json

@@ -1,11 +1,13 @@
 const jsdom = require('jsdom');
+const Raven = require('raven');
 
 module.exports = url => {
     return new Promise((resolve, reject) => {
         jsdom.env(url, (err, w) => {
             if (!err && !!w) {
                 resolve(w.document);
             } else {
+                Raven.captureException(err);
                 reject(err);
             }
         });

utils/getDom.js

@@ -1,4 +1,5 @@
 const MongoClient = require('mongodb').MongoClient;
+const Raven = require('raven');
 
 class SimpleDb {
     constructor(collectionName) {
@@ -15,33 +16,99 @@ class SimpleDb {
 
     getCollection() {
         return this.getDb()
-            .then(d => d.collection(this.collection));
+            .then(d => d.collection(this.collection))
+            .catch(err => {
+                Raven.context(() => {
+                    Raven.setContext({
+                        module: {
+                            name: 'db',
+                            cmd: 'get-collection'
+                        }
+                    });
+                    Raven.captureException(err);
+                });
+            });
     }
 
     getDocumentById(id) {
         return this.getCollection()
-            .then(c => c.findOne({_id: id}));
+            .then(c => c.findOne({_id: id}))
+            .catch(err => {
+                Raven.context(() => {
+                    Raven.setContext({
+                        module: {
+                            name: 'db',
+                            cmd: 'get-doc-by-id'
+                        }
+                    });
+                    Raven.captureException(err);
+                });
+            });
     }
 
     saveDocument(doc, searchPredicate) {
         searchPredicate = searchPredicate || {_id: doc._id};
         return this.getCollection()
-            .then(c => c.update(searchPredicate, doc));
+            .then(c => c.update(searchPredicate, doc))
+            .catch(err => {
+                Raven.context(() => {
+                    Raven.setContext({
+                        module: {
+                            name: 'db',
+                            cmd: 'save-doc'
+                        }
+                    });
+                    Raven.captureException(err);
+                });
+            });
     }
 
     saveMany(docs) {
         return this.getCollection()
-            .then(c => c.insertMany(docs));
+            .then(c => c.insertMany(docs))
+            .catch(err => {
+                Raven.context(() => {
+                    Raven.setContext({
+                        module: {
+                            name: 'db',
+                            cmd: 'save-many'
+                        }
+                    });
+                    Raven.captureException(err);
+                });
+            });
     }
 
     getAllDocuments() {
         return this.getCollection()
-            .then(c => c.find().toArray());
+            .then(c => c.find().toArray())
+            .catch(err => {
+                Raven.context(() => {
+                    Raven.setContext({
+                        module: {
+                            name: 'db',
+                            cmd: 'get-all-docs'
+                        }
+                    });
+                    Raven.captureException(err);
+                });
+            });
     }
 
     removeAllDocuments(template) {
         return this.getCollection()
-            .then(c => c.remove({}));
+            .then(c => c.remove({}))
+            .catch(err => {
+                Raven.context(() => {
+                    Raven.setContext({
+                        module: {
+                            name: 'db',
+                            cmd: 'remove-all-docs'
+                        }
+                    });
+                    Raven.captureException(err);
+                });
+            });
     }
 }