import { Injectable } from "@angular/core";
import { Actions, createEffect, ofType,Effect } from "@ngrx/effects";
import { Action } from "@ngrx/store";
import { Observable,of } from "rxjs";
import { mergeMap,map,tap,catchError } from "rxjs/operators";

import { ContactUsMsg } from "../models";
import { ContactUsActions as CONTACTUS } from "../actions";
import { AppService,ContactUsService } from "../services";

@Injectable()
export class ContactUsEffects {
  constructor(
    private actions$:Actions,
    private contactUs:ContactUsService,
    private app:AppService){}
  fetchContactUsMsgs$:Observable<Action> = createEffect(() => this.actions$.pipe(
    ofType(CONTACTUS.fetch),
    mergeMap(() => this.contactUs.fetch().pipe(
      map((msgs:ContactUsMsg[]) => CONTACTUS.load(msgs)),
      catchError(error => of(CONTACTUS.error(error)))))));
  SendContactUsMsg$:Observable<Action> = createEffect(() => this.actions$.pipe(
    ofType(CONTACTUS.send),
    map(o => o.payload),
    mergeMap(o => this.contactUs.send(o).pipe(
      map((msg:ContactUsMsg) => CONTACTUS.loadOne(msg)),
      catchError(error => of(CONTACTUS.error(error)))))));
}