|
1 | 1 | import { HttpClient } from '@angular/common/http'; |
2 | 2 | import { Injectable } from '@angular/core'; |
3 | | -import { map, Observable, of, ReplaySubject, switchMap, take } from 'rxjs'; |
4 | | -import { Permission, Role, RolesResponse } from 'src/app/models/role.model'; |
| 3 | +import { map, Observable, of, shareReplay, switchMap } from 'rxjs'; |
| 4 | +import { Role, RolesResponse } from 'src/app/models/role.model'; |
5 | 5 | import { environment } from 'src/environments/environment'; |
6 | 6 | import { AuthService } from './auth.service'; |
7 | 7 |
|
8 | 8 | @Injectable({ |
9 | 9 | providedIn: 'root' |
10 | 10 | }) |
11 | 11 | export class PermissionsService { |
12 | | - private readonly roles = new ReplaySubject<Map<string, Role>>(1); |
13 | | - private readonly permissions = new ReplaySubject<Permission[]>(1); |
| 12 | + private readonly roles: Observable<Map<string, Role>>; |
14 | 13 |
|
15 | 14 | constructor(private httpClient: HttpClient, private authService: AuthService) { |
16 | | - this.httpClient.get<RolesResponse>(environment.apiRoot + '/roles').subscribe(roles => { |
17 | | - this.roles.next(new Map(roles.roles.map(role => [role.name, role]))); |
18 | | - this.permissions.next(roles.permissions); |
19 | | - }); |
| 15 | + this.roles = this.httpClient.get<RolesResponse>(environment.apiRoot + '/roles').pipe( |
| 16 | + map(rolesResponse => new Map(rolesResponse.roles.map(role => [role.name, role]))), |
| 17 | + shareReplay(1) |
| 18 | + ); |
20 | 19 | } |
21 | 20 |
|
22 | 21 | public getAllRoles(): Observable<Role[]> { |
23 | 22 | return this.roles.pipe(map(roles => Array.from(roles.values()))); |
24 | 23 | } |
25 | 24 |
|
26 | | - public checkPermissions(permissions: string[]): Observable<boolean> { |
| 25 | + public getCurrentUserPermissions(): Observable<string[]> { |
27 | 26 | return this.authService.getUser().pipe( |
28 | | - take(1), |
29 | | - switchMap(user => user === null ? of(false) : this.roles.pipe(map(roles => |
30 | | - user.role_names.reduce((prev, role) => { |
31 | | - if (prev) { |
32 | | - return true; |
33 | | - } |
34 | | - |
35 | | - if (!roles.has(role)) { |
36 | | - return false; |
37 | | - } |
| 27 | + switchMap(user => user === null ? of([]) |
| 28 | + : this.roles.pipe( |
| 29 | + map(roles => user.role_names.flatMap(role => roles.get(role)?.permissions ?? [])) |
| 30 | + ) |
| 31 | + ) |
| 32 | + ); |
| 33 | + } |
38 | 34 |
|
39 | | - const role_permissions = roles.get(role)!!.permissions; |
40 | | - return permissions.reduce((prev, permission) => prev && role_permissions.includes(permission), true); |
41 | | - }, false) |
42 | | - )) |
43 | | - )); |
| 35 | + public checkPermissions(neededPermissions: string[]): Observable<boolean> { |
| 36 | + return this.getCurrentUserPermissions().pipe( |
| 37 | + map(userPermissions => { |
| 38 | + return neededPermissions.reduce((allowed, neededPermission) => allowed && userPermissions.includes(neededPermission), true); |
| 39 | + }) |
| 40 | + ); |
44 | 41 | } |
45 | 42 | } |
0 commit comments