Standard Feature Store Module - Effects

standard-feature-store-module-effects.ts

import { Injectable } from '@angular/core';
import { Actions, Effect, ofType } from '@ngrx/effects';
import { Action } from '@ngrx/store';
import { Observable, of as observableOf } from 'rxjs';
import { catchError, map, startWith, switchMap } from 'rxjs/operators';
import { DataService } from '../../services/data.service';
import * as featureActions from './actions';

@Injectable()
export class MyFeatureStoreEffects {
  constructor(private dataService: DataService, private actions$: Actions) {}

  @Effect()
  loginRequestEffect$: Observable<Action> = this.actions$.pipe(
    ofType<featureActions.LoginRequestAction>(
      featureActions.ActionTypes.LOGIN_REQUEST
    ),
    switchMap(action =>
      this.dataService
	.login(action.payload.userName, action.payload.password)
	.pipe(
	  map(
	    user =>
	      new featureActions.LoginSuccessAction({
		user
	      })
	  ),
	  catchError(error =>
	    observableOf(new featureActions.LoginFailureAction({ error }))
	  )
	)
    )
  );
}