Merge pull request #42 from SylvainEstevez/add-event-emitter

Add event emitter

src/event-emitter.js

@@ -0,0 +1,7 @@
+'use strict';
+
+const EventEmitter = require('events');
+
+const restypieEventEmitter = new EventEmitter();
+
+module.exports = restypieEventEmitter;

src/index.js

@@ -45,6 +45,11 @@ const Restypie = module.exports = {
 
   RESERVED_WORDS: ['limit', 'offset', 'sort', 'select', 'format', 'populate', 'options'],
 
+  EventTypes: {
+    ERROR: 'error',
+    WARN: 'warn'
+  },
+
   isSupportedRouterType(type) {
     return _.contains(_.values(Restypie.RouterTypes), type);
   },
@@ -291,6 +296,7 @@ const Restypie = module.exports = {
   get Query() { return require('./client/lib/query'); },
   get Logger() { return require('./logger'); },
   get QueryScore() { return require('./query-score'); },
-  get ResourceTester() { return require('./resource-tester'); }
+  get ResourceTester() { return require('./resource-tester'); },
+  get EventEmitter() { return require('./event-emitter'); }
 
 };

src/resources/lib/abstract-resource.js

@@ -1267,14 +1267,18 @@ module.exports = class AbstractResource extends Restypie.Resources.AbstractCoreR
     switch (true) {
       case !statusCode:
         Restypie.Logger.error('No statusCode for request on ' + bundle.req.url);
+        Restypie.EventEmitter.emit(Restypie.EventTypes.ERROR,
+          new Error('No statusCode for request on ' + bundle.req.url));
         break;
       case statusCode === Restypie.Codes.InternalServerError:
         debugError(bundle.err.stack);
         Restypie.Logger.error(bundle.err.stack, bundle.err);
+        Restypie.EventEmitter.emit(Restypie.EventTypes.ERROR, bundle.err);
         break;
       case statusCode >= Restypie.Codes.BadRequest:
         debugWarn(bundle.err.stack);
         Restypie.Logger.warn(bundle.err.stack, bundle.err);
+        Restypie.EventEmitter.emit(Restypie.EventTypes.WARN, bundle.err);
         break;
     }
 

test/event-emitter.test.js

@@ -0,0 +1,16 @@
+'use strict';
+
+describe('Restypie.EventEmitter', function () {
+
+  describe('.emit()', function () {
+    it('should emit error event', function () {
+      let err = null;
+      Restypie.EventEmitter.on(Restypie.EventTypes.ERROR, function (error) {
+        err = error;
+      });
+      Restypie.EventEmitter.emit(Restypie.EventTypes.ERROR, new Error('message'));
+      err.message.should.equal('message');
+    });
+  });
+
+});