FatboarProject/angular-client/src/app/services/auth.service.ts

import { environment } from 'src/environments/environment';
import { User } from './../models/userResponse';
import { Token, payloadToken } from './../models/token';
import { Injectable } from '@angular/core';
import { HttpClient, HttpHeaders } from '@angular/common/http';
import { BehaviorSubject, Observable } from 'rxjs';
import { Router } from '@angular/router';
import { MatSnackBar } from '@angular/material/snack-bar';
import { AlertMessageComponent } from 'src/app/components/shared/alert-message/alert-message.component'
import { map, tap } from 'rxjs/operators';
import * as jwt_decode from 'jwt-decode';



@Injectable({
  providedIn: 'root'
})
export class AuthService {

  //url api
  private apiUrl = environment.apiUrl

  private currentUserSubject: BehaviorSubject<User> = new BehaviorSubject<User>(null);
  public currentUser: Observable<User> = this.currentUserSubject.asObservable();

  


  private tokenSubject: BehaviorSubject<Token>;
  public token: Observable<Token>;

  private user_infoSubject: BehaviorSubject<User>;
  public user_info: Observable<User>;

  private messageSource = new BehaviorSubject('default message');
  currentMessage = this.messageSource.asObservable();

  constructor(private http: HttpClient, public router: Router, public snackBar: MatSnackBar) {

    this.tokenSubject = new BehaviorSubject<Token>(JSON.parse(localStorage.getItem('token')));
    this.token = this.tokenSubject.asObservable();

    this.user_infoSubject = new BehaviorSubject<User>(JSON.parse(localStorage.getItem('user')));
    this.user_info = this.user_infoSubject.asObservable();
    
  }

  changeMessage(message: string) {
    this.messageSource.next(message)
  }

  //get token
  public get tokenValue(): Token {
    return this.tokenSubject.value;
  }

  //get user Info
  public get userValue(): User {
    return this.user_infoSubject.value;
  }

  // login get  token on login 
  signIn(credentials): Observable<Token> {
     //debugger;
    console.log("url ========",this.apiUrl);

    return this.http.post<Token>(`${this.apiUrl}/api/auth/login`, credentials)
      .pipe(map(token => {
        // store jwt token in local storage 
        localStorage.setItem('token', JSON.stringify(token));
        this.tokenSubject.next(token);
        return token;
      }));
  }

  signInWithGoogle(): Observable<any> {
    return this.http.get('/api/auth/google').pipe(
      tap((data) => {
        const token = data.token;
        localStorage.setItem('token', JSON.stringify(token));
        this.getCurrentUser().subscribe((user) => {
          this.currentUserSubject.next(user);
        });
      })
    );
  }
  
   // login google
    // signGoogle(): Observable<User> {
    //   //debugger;
    // console.log("url ========",this.apiUrl);
    //   return this.http.get<User>(`${this.apiUrl}/api/auth/google`)
    //   .pipe(map(user => {
    //     // store jwt token in local storage 
    //     localStorage.setItem('token', JSON.stringify(user));
    //     console.log("test",user);
    //     return user;
    //   }));
    // }  
    // login get  token on login admin
    signInAdmin(credentials): Observable<Token> {
       //debugger;
      console.log("url ========",this.apiUrl);
  
      return this.http.post<Token>(`${this.apiUrl}/api/auth/admin`, credentials)
        .pipe(map(token => {
          // store jwt token in local storage 
          localStorage.setItem('token', JSON.stringify(token));
          this.tokenSubject.next(token);
          return token;
        }));
    }



  // iscription get  token on login 
  signUP(data): Observable<Token> {

    return this.http.post<Token>(`${this.apiUrl}/api/auth/signup`, data)
      .pipe(map(token => {
        // store jwt token in local storage 
        localStorage.setItem('token', JSON.stringify(token));
        this.tokenSubject.next(token);
        return token;
      }));
  }



// mot de passe oublie 
lostPassword(email): Observable<any> {
  return this.http.put<any>(`${this.apiUrl}/api/auth/forgot-password`, email)
}


// réinitialiser mot de passe  
resetPassword(data): Observable<any> {
  return this.http.put<any>(`${this.apiUrl}/api/auth/reset-password`, data)
}

  // isLoggedIn
  public isLoggedIn() {
    return localStorage.getItem('token') !== null;
  }

  getCurrentUser(): Observable<User> {
    return this.http.get<User>('/api/auth/user').pipe(
      tap((user) => {
        this.currentUserSubject.next(user);
      })
    );
  }

  //logout
  public logout() {
    // remove token from local storage 
    localStorage.removeItem('token');
    this.tokenSubject.next(null);
    // remove user from local storage 
    localStorage.removeItem('user');
    this.user_infoSubject.next(null);
    this.router.navigate(['/login']);
    setTimeout(() => {
      document.location.reload()
    },1000)
  }

  // get info user 
  getUserInfo(): Observable<User> {
    let token = this.tokenSubject.value.token;
    if (token) {
      // User is authenticated locally
      let decodedToken: payloadToken = jwt_decode(token);
      return this.http.get<User>(`${this.apiUrl}/api/users/${decodedToken.userId}`).pipe(
        map(user => {
          // Store user info in local storage
          localStorage.setItem('user', JSON.stringify(user));
          this.user_infoSubject.next(user);
          return user;
        })
      );
    } else {
      // User is authenticated via Google
      return this.http.get<User>(`${this.apiUrl}/api/auth/google/userinfo`).pipe(
        map(user => {
          // Store user info in local storage
          localStorage.setItem('user', JSON.stringify(user));
          this.user_infoSubject.next(user);
          return user;
        })
      );
    }
  }
  

  openSnackBar(message: string) {
    this.snackBar.openFromComponent(AlertMessageComponent, {
      data: message,
      panelClass: ['blue-snackbar'],
      duration: 10000
    });
  }


}