import { Injectable, OnDestroy } from '@angular/core'; import { Router } from '@angular/router'; import { HttpClient } from '@angular/common/http'; import { BehaviorSubject, Observable, of, Subscription } from 'rxjs'; import { map, tap, delay, finalize } from 'rxjs/operators'; import { IPharmacyHead } from '../interfaces'; import { environment } from '../../../environments/environment'; interface LoginResult { username: string; role: string; originalUserName?: string; accessToken: string; refreshToken: string; head?: IPharmacyHead; } @Injectable({ providedIn: 'root', }) export class AuthService implements OnDestroy { private readonly apiUrl = `${environment.baseApiUrl}api/pharmacyhead`; private timer: Subscription; private _user = new BehaviorSubject(null); user$: Observable = this._user.asObservable(); private storageEventListener(event: StorageEvent) { if (event.storageArea === localStorage) { if (event.key === 'logout-event') { this.stopTokenTimer(); this._user.next(null); } if (event.key === 'login-event') { this.stopTokenTimer(); this.http.get(`${this.apiUrl}/user`).subscribe((x) => { this._user.next({ Email: x.username, Passwd: x.head.Passwd, Role: x.role, originalUserName: x.originalUserName, Name: x.head.Name, PharmacyMedicines: x.head.PharmacyMedicines, Pharmacy: x.head.Pharmacy }); }); } } } constructor(private router: Router, private http: HttpClient) { window.addEventListener('storage', this.storageEventListener.bind(this)); console.log(this.apiUrl); } ngOnDestroy(): void { window.removeEventListener('storage', this.storageEventListener.bind(this)); } login(username: string, password: string) { return this.http .post(`${this.apiUrl}/login`, { username, password }) .pipe( map((x) => { this._user.next({ Email: x.username, Passwd: x.head.Passwd, Role: x.role, originalUserName: x.originalUserName, Name: x.head.Name, PharmacyMedicines: x.head.PharmacyMedicines, Pharmacy: x.head.Pharmacy }); this.setLocalStorage(x); this.startTokenTimer(); return x; }) ); } logout() { this.http .post(`${this.apiUrl}/logout`, {}) .pipe( finalize(() => { this.clearLocalStorage(); this._user.next(null); this.stopTokenTimer(); this.router.navigate(['login']); }) ) .subscribe(); } refreshToken() { const refreshToken = localStorage.getItem('refresh_token'); if (!refreshToken) { this.clearLocalStorage(); return of(null); } return this.http .post(`${this.apiUrl}/refresh-token`, { refreshToken }) .pipe( map((x) => { this._user.next({ Email: x.username, Passwd: x.head.Passwd, Role: x.role, originalUserName: x.originalUserName, Name: x.head.Name, PharmacyMedicines: x.head.PharmacyMedicines, Pharmacy: x.head.Pharmacy }); this.setLocalStorage(x); this.startTokenTimer(); return x; }) ); } setLocalStorage(x: LoginResult) { localStorage.setItem('access_token', x.accessToken); localStorage.setItem('refresh_token', x.refreshToken); localStorage.setItem('login-event', 'login' + Math.random()); } clearLocalStorage() { localStorage.removeItem('access_token'); localStorage.removeItem('refresh_token'); localStorage.setItem('logout-event', 'logout' + Math.random()); } getUser() { return this.user$; } private getTokenRemainingTime() { const accessToken = localStorage.getItem('access_token'); if (!accessToken) { return 0; } const jwtToken = JSON.parse(atob(accessToken.split('.')[1])); const expires = new Date(jwtToken.exp * 1000); return expires.getTime() - Date.now(); } private startTokenTimer() { const timeout = this.getTokenRemainingTime(); this.timer = of(true) .pipe( delay(timeout), tap(() => this.refreshToken().subscribe()) ) .subscribe(); } private stopTokenTimer() { this.timer?.unsubscribe(); } }