/modules/uoa-services-library/branches/angular-11/ng-openaire-library/src/app/services/user-management.service.ts - Annotate - D-Net - D-Net project tracking tool

dnet40/modules/uoa-services-library/branches/angular-11/ng-openaire-library/src/app/services/user-management.service.ts @ 61321

-            k.triantaf
+import {Injectable} from '@angular/core';
 import {HttpClient} from '@angular/common/http';
-            k.triantaf
+import {BehaviorSubject, from, Observable, of} from "rxjs";
-            k.triantaf
+import {COOKIE, Session, User} from "../login/utils/helper.class";
-            argiro.kok
+import {map} from "rxjs/operators";
-            k.triantaf
+import {NavigationEnd, Router} from "@angular/router";
-            k.triantaf
+import {properties} from "../../../environments/environment";
-            k.triantaf
+import {StringUtils} from "../utils/string-utils.class";
             k.triantaf
 @Injectable({
   providedIn: 'root'
 })
-            argiro.kok
+export class UserManagementService{
             k.triantaf
-            k.triantaf
+  private getUserInfoSubject: BehaviorSubject<User> = new BehaviorSubject<User>(null);
-            k.triantaf
+  public fixRedirectURL: string = null;
-            k.triantaf
+  private readonly promise: Promise<User>;
-            argiro.kok
+  sub;
   routeSub;
             k.triantaf
-            k.triantaf
+  constructor(private http: HttpClient,
-            k.triantaf
+              private router: Router) {
-            k.triantaf
+    this.promise = new Promise<any>((resolve => {
-            k.triantaf
+      this.updateUserInfo(resolve);
-            k.triantaf
+    }));
-            argiro.kok
+    this.routeSub = this.router.events.subscribe(event => {
-            k.triantaf
+      if (event instanceof NavigationEnd) {
-            k.triantaf
+        const token = COOKIE.getCookie('AccessToken');
-            k.triantaf
+        if (!token && this.getUserInfoSubject.getValue() !== null) {
-            k.triantaf
+          this.getUserInfoSubject.next(null);
+        }
+      }
-            argiro.kok
+    });
             k.triantaf
             argiro.kok
   clearSubscriptions() {
     if(this.routeSub){
       this.routeSub.unsubscribe();
+    }
     if(this.sub){
       this.sub.unsubscribe();
+    }
+  }
             k.triantaf
-            k.triantaf
+  public getUserInfo(subject: boolean = true): Observable<User> {
-            k.triantaf
+    if (subject) {
-            k.triantaf
+      return this.getUserInfoSubject.asObservable();
-            k.triantaf
+    } else {
-            k.triantaf
+      return from(this.getUserInfoAsync());
             k.triantaf
             k.triantaf
             k.triantaf
-            k.triantaf
+  public updateUserInfo(resolve: Function = null) {
-            k.triantaf
+    const token = COOKIE.getCookie('AccessToken');
     if (!token) {
       this.getUserInfoSubject.next(null);
       if(resolve) {
-            k.triantaf
+        resolve();
+      }
-            k.triantaf
+    } else {
-            argiro.kok
+     this.sub = this.http.get<User>(properties.userInfoUrl + token).pipe(map(userInfo => {
-            k.triantaf
+        return this.parseUserInfo(userInfo);
       })).subscribe(user => {
         this.getUserInfoSubject.next(user);
         if(resolve) {
           resolve();
+        }
-            k.triantaf
+      }, error => {
        this.getUserInfoSubject.next(null);
        if(resolve) {
          resolve();
+       }
      });
             k.triantaf
             k.triantaf
-            k.triantaf
+  private async getUserInfoAsync(): Promise<User> {
     await this.promise;
-            argiro.kok
+    if(this.sub){
       this.sub.unsubscribe();
+    }
-            k.triantaf
+    return this.getUserInfoSubject.getValue();
+  }
-            k.triantaf
+  private parseUserInfo(info: any) {
     const user: User = new User();
-            k.triantaf
+    user.id = (info.sub && info.sub.indexOf('@')) ? info.sub.substring(0, info.sub.indexOf('@')) : info.sub;
-            k.triantaf
+    user.firstname = (info.given_name) ? info.given_name : "";
     user.lastname = (info.family_name) ? info.family_name : "";
-            k.triantaf
+    user.email = info.email.toLowerCase(); // TODO remove, is a quick fix
-            k.triantaf
+    user.fullname = (info.name) ? info.name : "";
     if (user.fullname == "") {
       if (user.firstname != "") {
         user.fullname += user.firstname;
+      }
       if (user.lastname != "") {
         user.fullname += user.lastname;
+      }
       if (user.fullname == "") { //fullname is still empty set a default
         user.fullname = "Anonymous user";
+      }
+    }
-            k.triantaf
+    user.role = [];
     if (info.roles) {
       info.roles.forEach(role => {
         user.role.push(role);
       });
-            argiro.kok
+    }else{
       if (info.edu_person_entitlements) {
         user.role = info.edu_person_entitlements;
+      }
             k.triantaf
-            k.triantaf
+    user.expirationDate = info.exp_date;
-            k.triantaf
+    return user;
+  }
             k.triantaf
   public setRedirectUrl(url: string = null) {
     if(url) {
       let parts = url.split('?');
       let path = properties.baseLink + parts[0];
       let params = null;
       if (parts.length == 2) {
         params = parts[1];
+      }
       let hash = path.indexOf("#");
       let fragment = (hash !== -1)?path.slice(hash + 1):null;
       if(fragment) {
         path = path.slice(0, hash);
       } else {
         fragment = "";
+      }
       if(!path.includes('/reload')) {
         Session.setReloadUrl(location.protocol + "//" + location.host, path, params, fragment);
+      }
     } else {
       Session.setReloadUrl(location.protocol + "//" + location.host, location.pathname, location.search, location.hash);
+    }
+  }
   public login() {
-            k.triantaf
+    if(this.fixRedirectURL) {
       this.setRedirectUrl(this.fixRedirectURL);
     } else {
       this.setRedirectUrl();
+    }
-            k.triantaf
+    window.location.href = properties.loginUrl;
+  }
   public logout() {
     this.setRedirectUrl();
     Session.removeUser();
     if (properties.logoutUrl.includes('openid_logout')) {
       window.location.href = properties.logoutUrl;
     } else {
       window.location.href = properties.logoutUrl + StringUtils.URIEncode(location.href);
+    }
+  }
             k.triantaf

Project

General

Profile

D-Net