feat: CMS-2637 CMS-2638 expose EventEmitter on Core, send event

src/Accounts.js

@@ -150,6 +150,7 @@ export default class Accounts extends Core {
     })
     .then(([token]) => {
       this.tokenStore.set(token.token);
+      this.events.emit('login', token.token);
 
       return token.token;
     });
@@ -174,6 +175,7 @@ export default class Accounts extends Core {
       return post(this.environment, request);
     })
     .then(() => {
+      this.events.emit('logout');
       this.tokenStore.del();
       return Promise.resolve();
     });

src/Core.js

@@ -1,6 +1,7 @@
 import traverson from 'traverson';
 import HalAdapter from 'traverson-hal';
-import TokenStoreFactory  from './TokenStore';
+import TokenStoreFactory from './TokenStore';
+import events from './EventEmitter';
 
 traverson.registerMediaType(HalAdapter.mediaType, HalAdapter);
 
@@ -16,6 +17,7 @@ export default class Core {
       throw new Error('url must be defined');
     }
 
+    this.events = events;
     this.tokenStore = TokenStoreFactory('live');
     this.traversal = traverson.from(url).jsonHal()
     .addRequestOptions({ headers: { Accept: 'application/hal+json' } });
@@ -57,4 +59,26 @@ export default class Core {
     this.tokenStore.set(token);
     return this;
   }
+
+  /**
+   * Attaches a listener on the underlying EventEmitter.
+   *
+   * @param {string} label the event type
+   * @param {function} listener the listener
+   * @returns {undefined}
+   */
+  on(label, listener) {
+    return this.events.on(label, listener);
+  }
+
+  /**
+   * Removes a previously attached listener from the underlying EventEmitter.
+   *
+   * @param {string} label the event type
+   * @param {function} listener the listener
+   * @returns {boolean} whether or not the listener was removed
+   */
+  removeListener(label, listener) {
+    return this.events.removeListener(label, listener);
+  }
 }

src/helper.js

@@ -76,7 +76,7 @@ function traversonWrapper(func, environment, t, body) {
         if (TokenStoreFactory(environment) && err instanceof Problem &&
           (err.code % 1000 === 401 || err.code % 1000 === 402)) {
           TokenStoreFactory(environment).del();
-          events.emit('loggedOut', err);
+          events.emit('logout', err);
         }
 
         events.emit('error', err);

test/Core.test.js

@@ -55,6 +55,17 @@ describe('Core', () => {
     };
     throws.should.throw(Error);
   });
+  it('should attach listener', () => {
+    core.on('attachTest', () => undefined);
+    emitter.listeners.get('attachTest').length.should.be.equal(1);
+  });
+  it('should remove listener', () => {
+    const listener = () => undefined;
+    core.on('removeTest', listener);
+    emitter.listeners.get('removeTest').length.should.be.equal(1);
+    core.removeListener('removeTest', listener);
+    emitter.listeners.get('removeTest').length.should.be.equal(0);
+  });
 });
 
 describe('Network Helper', () => {
@@ -67,7 +78,7 @@ describe('Network Helper', () => {
     errorSpy = sinon.spy();
     loggedOutSpy = sinon.spy();
     emitter.on('error', errorSpy);
-    emitter.on('loggedOut', loggedOutSpy);
+    emitter.on('logout', loggedOutSpy);
   });
   beforeEach(() => {
     errorSpy.reset();

typings/Core.d.ts

@@ -4,6 +4,10 @@ export declare class Core {
   newRequest(): any;
 
   setToken(token: string): Core;
+
+  on(label: string, callback: () => void): void;
+
+  removeListener(label: string, callback: () => void): boolean;
 }
 
 type environment = 'live' | 'stage' | 'nightly' | 'develop';