feat(ErrorHandler): use the angular ErrorHandler for reporting errors

Fixes ngrx#626

BREAKING CHANGE:

Errors are now reported to the @angular/core Errorhandler.
Errors are no longer reported to the console.

modules/effects/spec/effect_sources.spec.ts

@@ -9,30 +9,22 @@ import { _throw } from 'rxjs/observable/throw';
 import { never } from 'rxjs/observable/never';
 import { empty } from 'rxjs/observable/empty';
 import { TestBed } from '@angular/core/testing';
-import { ErrorReporter } from '../src/error_reporter';
-import { CONSOLE } from '../src/tokens';
+import { ErrorHandler } from '@angular/core';
 import { Effect, EffectSources } from '../';
 
 describe('EffectSources', () => {
-  let mockErrorReporter: ErrorReporter;
+  let mockErrorHandler: ErrorHandler;
   let effectSources: EffectSources;
 
   beforeEach(() => {
     TestBed.configureTestingModule({
-      providers: [
-        EffectSources,
-        ErrorReporter,
-        {
-          provide: CONSOLE,
-          useValue: console,
-        },
-      ],
+      providers: [EffectSources, ErrorHandler],
     });
 
-    mockErrorReporter = TestBed.get(ErrorReporter);
+    mockErrorHandler = TestBed.get(ErrorHandler);
     effectSources = TestBed.get(EffectSources);
 
-    spyOn(mockErrorReporter, 'report');
+    spyOn(mockErrorHandler, 'handleError');
   });
 
   it('should have an "addEffects" method to push new source instances', () => {
@@ -103,7 +95,7 @@ describe('EffectSources', () => {
 
       toActions(sources$).subscribe();
 
-      expect(mockErrorReporter.report).toHaveBeenCalled();
+      expect(mockErrorHandler.handleError).toHaveBeenCalled();
     });
 
     it('should not complete the group if just one effect completes', () => {
@@ -118,7 +110,7 @@ describe('EffectSources', () => {
     });
 
     function toActions(source: any): Observable<any> {
-      source['errorReporter'] = mockErrorReporter;
+      source['errorHandler'] = mockErrorHandler;
       return effectSources.toActions.call(source);
     }
   });

modules/effects/src/effect_notification.ts

@@ -1,7 +1,7 @@
 import { Observable } from 'rxjs/Observable';
 import { Notification } from 'rxjs/Notification';
 import { Action } from '@ngrx/store';
-import { ErrorReporter } from './error_reporter';
+import { ErrorHandler } from '@angular/core';
 
 export interface EffectNotification {
   effect: Observable<any> | (() => Observable<any>);
@@ -13,47 +13,50 @@ export interface EffectNotification {
 
 export function verifyOutput(
   output: EffectNotification,
-  reporter: ErrorReporter
+  reporter: ErrorHandler
 ) {
   reportErrorThrown(output, reporter);
   reportInvalidActions(output, reporter);
 }
 
-function reportErrorThrown(
-  output: EffectNotification,
-  reporter: ErrorReporter
-) {
+function reportErrorThrown(output: EffectNotification, reporter: ErrorHandler) {
   if (output.notification.kind === 'E') {
-    const errorReason = `Effect ${getEffectName(output)} threw an error`;
+    const errorReason = new Error(
+      `Effect ${getEffectName(output)} threw an error`
+    );
 
-    reporter.report(errorReason, {
-      Source: output.sourceInstance,
-      Effect: output.effect,
-      Error: output.notification.error,
-      Notification: output.notification,
-    });
+    reporter.handleError(
+      Object.assign(errorReason, {
+        Source: output.sourceInstance,
+        Effect: output.effect,
+        Error: output.notification.error,
+        Notification: output.notification,
+      })
+    );
   }
 }
 
 function reportInvalidActions(
   output: EffectNotification,
-  reporter: ErrorReporter
+  reporter: ErrorHandler
 ) {
   if (output.notification.kind === 'N') {
     const action = output.notification.value;
     const isInvalidAction = !isAction(action);
 
     if (isInvalidAction) {
-      const errorReason = `Effect ${getEffectName(
-        output
-      )} dispatched an invalid action`;
+      const errorReason = new Error(
+        `Effect ${getEffectName(output)} dispatched an invalid action`
+      );
 
-      reporter.report(errorReason, {
-        Source: output.sourceInstance,
-        Effect: output.effect,
-        Dispatched: action,
-        Notification: output.notification,
-      });
+      reporter.handleError(
+        Object.assign(errorReason, {
+          Source: output.sourceInstance,
+          Effect: output.effect,
+          Dispatched: action,
+          Notification: output.notification,
+        })
+      );
     }
   }
 }

modules/effects/src/effect_sources.ts

@@ -8,16 +8,15 @@ import { concat } from 'rxjs/observable/concat';
 import { Observable } from 'rxjs/Observable';
 import { Subject } from 'rxjs/Subject';
 import { Notification } from 'rxjs/Notification';
-import { Injectable } from '@angular/core';
+import { ErrorHandler, Injectable } from '@angular/core';
 import { Action } from '@ngrx/store';
 import { EffectNotification, verifyOutput } from './effect_notification';
 import { getSourceForInstance } from './effects_metadata';
 import { resolveEffectSource } from './effects_resolver';
-import { ErrorReporter } from './error_reporter';
 
 @Injectable()
 export class EffectSources extends Subject<any> {
-  constructor(private errorReporter: ErrorReporter) {
+  constructor(private errorHandler: ErrorHandler) {
     super();
   }
 
@@ -37,7 +36,7 @@ export class EffectSources extends Subject<any> {
             map.call(
               exhaustMap.call(source$, resolveEffectSource),
               (output: EffectNotification) => {
-                verifyOutput(output, this.errorReporter);
+                verifyOutput(output, this.errorHandler);
 
                 return output.notification;
               }

modules/effects/src/effects_module.ts

@@ -1,11 +1,10 @@
 import { NgModule, ModuleWithProviders, Type } from '@angular/core';
 import { EffectSources } from './effect_sources';
 import { Actions } from './actions';
-import { ROOT_EFFECTS, FEATURE_EFFECTS, CONSOLE } from './tokens';
+import { ROOT_EFFECTS, FEATURE_EFFECTS } from './tokens';
 import { EffectsFeatureModule } from './effects_feature_module';
 import { EffectsRootModule } from './effects_root_module';
 import { EffectsRunner } from './effects_runner';
-import { ErrorReporter } from './error_reporter';
 
 @NgModule({})
 export class EffectsModule {
@@ -30,18 +29,13 @@ export class EffectsModule {
       providers: [
         EffectsRunner,
         EffectSources,
-        ErrorReporter,
         Actions,
         rootEffects,
         {
           provide: ROOT_EFFECTS,
           deps: rootEffects,
           useFactory: createSourceInstances,
         },
-        {
-          provide: CONSOLE,
-          useFactory: getConsole,
-        },
       ],
     };
   }
@@ -50,7 +44,3 @@ export class EffectsModule {
 export function createSourceInstances(...instances: any[]) {
   return instances;
 }
-
-export function getConsole() {
-  return console;
-}

modules/effects/src/tokens.ts

@@ -9,4 +9,3 @@ export const ROOT_EFFECTS = new InjectionToken<Type<any>[]>(
 export const FEATURE_EFFECTS = new InjectionToken<any[][]>(
   'ngrx/effects: Feature Effects'
 );
-export const CONSOLE = new InjectionToken<Console>('Browser Console');