import { map, firstValueFrom } from 'rxjs';
import { Inject, Injectable } from '@angular/core';
import { HttpClient } from '@angular/common/http';
import { APP_BASE_HREF } from '@angular/common';
import { ConfigService } from './config.service';
import { UtilityService } from './utility.service';
import { HttpClientService } from './httpClient.service';
import { LoggerService } from './logger.service';
import { merge as _merge } from 'lodash-es';
export interface User {
id: string;
username: string;
password: string;
type: string;
name: string;
email: string;
token: string;
roles: Role[];
newRoles: Role[];
roleStr: string;
}
export interface Role {
id: string;
name: string;
users: User[];
hasRole: boolean;
}
export interface UserLoginResult {
id: string;
message: string;
user: User;
url: string;
}
export interface SaveResult {
status: boolean;
message: string;
}
/**
* User-centric functions.
*
* Note: functions will be ported over as these are consumed by the apps/
*
* Author: <a href='https://github.com/shilob' target='_blank'>Shilo Banihit</a>
*
*
*/
@Injectable()
export class UserService extends HttpClientService {
protected infoUrl: string = "";
protected loginUrl: string = "";
private requestOptions:any = null as any;
constructor(
@Inject(HttpClient) protected override http: HttpClient,
@Inject(APP_BASE_HREF) public override rootContext: string,
@Inject(UtilityService) protected override utilService: UtilityService,
@Inject(ConfigService) protected override configService: ConfigService,
@Inject(LoggerService) private loggerService: LoggerService
) {
super(http, rootContext, utilService, configService);
}
public getInfo(): Promise<User> {
const req = this.http.get<User>(this.infoUrl, {responseType: 'json', observe: 'body', context: this.httpContext});
req.pipe(
map((data:any) => {
return data as User;
})
);
return firstValueFrom(req);
}
loginLocal(username: string, password: string): Promise<any> {
this.loggerService.debug(`Logging in locally using brand: ${this.config.branding}, portal: ${this.config.portal}:: ${this.loginUrl}`);
const req = this.http.post(this.loginUrl, {username: username, password:password, branding:this.config.branding, portal: this.config.portal}, {responseType: 'json', observe: 'body', context: this.httpContext});
req.pipe(
map((data: any) => {
return data as UserLoginResult
})
);
return firstValueFrom(req);
}
public override async waitForInit(): Promise<any> {
await super.waitForInit();
this.infoUrl = `${this.baseUrlWithContext}/user/info`;
this.loginUrl = `${this.baseUrlWithContext}/user/login_local`;
this.requestOptions = this.reqOptsJsonBodyOnly;
this.enableCsrfHeader();
_merge(this.requestOptions, {context: this.httpContext});
return this;
}
public getLoginUrl(): string {
return this.loginUrl;
}
public getInfoUrl(): string {
return this.infoUrl;
}
// old options from angular legacy
// headersObj['X-Source'] = 'jsclient';
// headersObj['Content-Type'] = 'application/json;charset=utf-8';
// headersObj['X-CSRF-Token'] = this.config.csrfToken;
public async getUsers() {
let url = `${this.brandingAndPortalUrl}/admin/users/get`;
const result$ = this.http.get(url, this.requestOptions).pipe(map(res => res));
let result = await firstValueFrom(result$);
return result; // old function in angular legacy returned User[]
}
public async updateUserDetails(userid: any, details: any) {
let url = `${this.brandingAndPortalUrl}/admin/users/update`;
const result$ = this.http.post(url, {userid: userid, details:details}, this.requestOptions).pipe(map(res => res));
let result = await firstValueFrom(result$);
return result; // old function in angular legacy returned SaveResult[]
}
public async addLocalUser(username: any, details: any) {
let url = `${this.brandingAndPortalUrl}/admin/users/newUser`;
const result$ = this.http.post(url, {username: username, details:details}, this.requestOptions).pipe(map(res => res));
let result = await firstValueFrom(result$);
return result; // old function in angular legacy returned SaveResult[]
}
public async genKey(userid: any) {
let url = `${this.brandingAndPortalUrl}/admin/users/genKey`;
const result$ = this.http.post(url, {userid: userid}, this.requestOptions).pipe(map(res => res));
let result = await firstValueFrom(result$);
return result; // old function in angular legacy returned SaveResult[]
}
public async revokeKey(userid: any) {
let url = `${this.brandingAndPortalUrl}/admin/users/revokeKey`;
const result$ = this.http.post(url, {userid: userid}, this.requestOptions).pipe(map(res => res));
let result = await firstValueFrom(result$);
return result; // old function in angular legacy returned SaveResult[]
}
public async getBrandRoles() {
let url = `${this.brandingAndPortalUrl}/admin/roles/get`;
const result$ = this.http.get(url,this.requestOptions).pipe(map(res => res));
let result = await firstValueFrom(result$);
return result; // old function in angular legacy returned Role[]
}
public async updateUserRoles(userid: any, roleIds: any) {
let url = `${this.brandingAndPortalUrl}/admin/roles/user`;
const result$ = this.http.post(url, {userid: userid, roles:roleIds},this.requestOptions).pipe(map(res => res));
let result = await firstValueFrom(result$);
return result; // old function in angular legacy returned SaveResult[]
}
}