javascriptangulartypescriptngrxngrx-entity

How to display a success message NgRX Effects and dispatch events


reducer:

export const reducer = (state = initialstate, action: any) => {
  switch (action.type) {
    case ADD_USER: {
      return {
        ...state,
        userAdded: false
        }
      },
    case ADD_USER_SUCCESS: {
      return {
        ...state,
        user: action.payload
        userAdded: true
        }
      },
    case ADD_USER_FAIL: {
      return {
        ...state,
        userAdded: false
        }
      }  
    }
}

Effect:

login$ = createEffect(() =>
    this.actions$.pipe(
      ofType(UserAction.ADD_USER),
      exhaustMap(action =>
        this.userService.addUser("USER").pipe(
          map(user => UserAction.AddUserSuccess({ "user" })),
          catchError(error => of(UserAction.AddUserFail({ error })))
        )
      )
    )
  );

component.ts:

onClickAddUser(): void {
  this.store.dispatch(new AddUser('USER'));
  this.store.pipe(select(getUser), take(1)).subscribe((isUserAdded) => {
    if(isUserAdded) {
      this.router.navigateByUrl('/success'); // Expectation is to navigate to success page
    } else {
      this.router.navigateByUrl('/home'); // for first time it's always going to home screen even the success action being dispatched and the value been set to true.
    }
  });
}

on click of the method, an action being dispatched and following up with an effect, my case the api call is success and an success action being dispatched as well (in my reducer I set a flag to true), right after the AddUser action being dispatched from the click method, I'm subscribing to the flag(isUserAdded) to navigate the user to /success screen if the API return success response, in my case by the time i'm subscribing to the flag it's not updated in the store and hence the user navigated to home screen (but the expectation is to navigate to success screen as the API is success). Is that possible to wait for the value to updated in the store and then subscribe to it or is there any best practice to handle this scenario ??

I can write an effect to navigate the user once the success action being dispatched but I mean I do have other functionalities to handle once the flag set true, hence has to do everything in the component.


Solution

  • The sequence of events is as follows:

    1. You dispatch an AddUser action
    this.store.dispatch(new AddUser('USER'));
    
    1. Reducer is called, the state is mutated and userAdded is set to false
        case ADD_USER: {
          return {
            ...state,
            userAdded: false
            }
          },
    
    1. selectors are called and subscribers are notified but you do not have any subscribtions yet
    2. Effect ADD_USER is called and async request is sent to userService
    login$ = createEffect(() =>
        this.actions$.pipe(
          ofType(UserAction.ADD_USER),
          exhaustMap(action =>
            this.userService.addUser("USER").pipe(
              map(user => UserAction.AddUserSuccess({ "user" })),
              catchError(error => of(UserAction.AddUserFail({ error })))
            )
          )
        )
      );
    
    1. You subscribe to getUser selector with take(1) operator in a pipe
      this.store.pipe(select(getUser), take(1)).subscribe((isUserAdded) => {
        if(isUserAdded) {
          this.router.navigateByUrl('/success');
        } else {
          this.router.navigateByUrl('/home');
        }
      });
    
    1. Selector returns a value of the userAdded flag from the store which is false, your callback function is called, subscription is cancelled by take(1) operator
    2. Router navigates to '/home'
    3. Response from userService is returned and userAdded flag is set to true but your subscription is already canceled

    If you want a simple solution right in component.ts, just try to subscribe with take(2), skip(1):

      this.store.pipe(select(getUser), take(2), skip(1)).subscribe((isUserAdded) => {
        if(isUserAdded) {
          this.router.navigateByUrl('/success');
        } else {
          this.router.navigateByUrl('/home');
        }
      });