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

import {
  AuthenticationActions as AUTH,
  MeActions as ME,
  NavigationActions as NAV,
} from "../actions";
import { AppService,AuthenticationService } from "../services";
import { me$,auth$ } from "../selectors";
import { User } from "../models";

@Injectable()
export class AuthenticationEffects {
  constructor(
    private actions$:Actions,
    private auth:AuthenticationService,
    private app:AppService,
  ){}
  Signup$:Observable<Action> = createEffect(() => this.actions$.pipe(
    ofType(AUTH.signup),
    map(o => o.payload),
    mergeMap(o => this.auth.signup(o).pipe(
      mergeMap(user => ([
        AUTH.load(),
        ME.load(user),
        NAV.go({url:"/secur01/verify"}),
      ])),
      catchError(error => of(AUTH.error(error)))))));
  Verify$:Observable<Action> = createEffect(() => this.actions$.pipe(
    ofType(AUTH.verify),
    map(o => o.payload),
    mergeMap(o => this.auth.verify(o).pipe(
      mergeMap(user => ([
        AUTH.load(),
        ME.load(user),
        NAV.go({url:"/secur01/register"}),
      ])),
      catchError(error => of(AUTH.error(error)))))));
  Register$:Observable<Action> = createEffect(() => this.actions$.pipe(
    ofType(AUTH.register),
    map(o => o.payload),
    mergeMap(o => this.auth.register(o).pipe(
      mergeMap(user => ([
        AUTH.load(),
        ME.load(user),
        NAV.go({url:"/secur01/register-ext"}),
      ])),
      catchError(error => of(AUTH.error(error)))))));
  RegisterExt$:Observable<Action> = createEffect(() => this.actions$.pipe(
    ofType(AUTH.registerExt),
    map(o => o.payload),
    mergeMap(o => this.auth.registerExt(o).pipe(
      mergeMap(user => ([
        AUTH.load(),
        ME.load(user),
        NAV.go({url:"/secur01/update-pin"}),
      ])),
      catchError(error => of(AUTH.error(error)))))));
  UpdatePin$:Observable<Action> = createEffect(() => this.actions$.pipe(
    ofType(AUTH.updatePin),
    map(o => o.payload),
    mergeMap(o => this.auth.updatePin(o).pipe(
      mergeMap(user => ([
        AUTH.load(),
        ME.load(user),
        NAV.go({url:"/me"}),
      ])),
      catchError(error => of(AUTH.error(error)))))));
  /*
  Signin$:Observable<Action> = createEffect(() => this.actions$.pipe(
    ofType(AUTH.signin),
    map(o => o.payload),
    mergeMap(o => this.auth.signin(o).pipe(
      mergeMap(auth => ([
        AUTH.load(auth),
        NAV.go({url:"/secur01/login"}),
      ])),
      catchError(error => of(AUTH.error(error)))))));
  Signout$:Observable<Action> = createEffect(() => this.actions$.pipe(
    ofType(AUTH.signout),
    mergeMap(() => this.app.select(authid$)),
    mergeMap(id => this.auth.signout().pipe(
      mergeMap(auth => ([
        AUTH.load({}),
        ME.load({}),
        NAV.go({url:"/secur01/verify"}),
      ])),
      catchError(error => of(AUTH.error(error)))))));
  
  Login$:Observable<Action> = createEffect(() => this.actions$.pipe(
    ofType(AUTH.login),
    map(o => o.payload),
    withLatestFrom(this.app.select(me$)),
    map(([o,_o]) => ({...o,username:_o?_o.username||"":""})),
    mergeMap(o => this.auth.login(o).pipe(
      mergeMap(auth => ([
        AUTH.load(auth),
        ME.load(auth),
        NAV.go({url:"/me"}),
      ])),
      catchError(error => of(AUTH.error(error)))))));
  ForgotName$:Observable<Action> = createEffect(() => this.actions$.pipe(
    ofType(AUTH.forgotName),
    map(o => o.payload),
    mergeMap(o => this.auth.forgotName(o).pipe(
      mergeMap(auth => ([
        AUTH.load(auth),
        ME.load(auth),
        NAV.go({url:"/me"}),
      ])),
      catchError(error => of(AUTH.error(error)))))));
  ForgotPin$:Observable<Action> = createEffect(() => this.actions$.pipe(
    ofType(AUTH.forgotPin),
    map(o => o.payload),
    mergeMap(o => this.auth.forgotPin(o).pipe(
      mergeMap(auth => ([
        AUTH.load(auth),
        ME.load(auth),
        NAV.go({url:"/secur01/reset"}),
      ])),
      catchError(error => of(AUTH.error(error)))))));
  UpdateAuthStatus$:Observable<Action> = createEffect(() => this.actions$.pipe(
    ofType(AUTH.load),
    map(o => o.payload),
    mergeMap(o => [AUTH.load(this.auth.getAuthStatus(o))])));
*/
}