|
| 1 | +import { inject } from '@angular/core'; |
| 2 | +import { |
| 3 | + ResolveFn, |
| 4 | + Router, |
| 5 | +} from '@angular/router'; |
| 6 | +import { Observable } from 'rxjs'; |
| 7 | +import { tap } from 'rxjs/operators'; |
| 8 | + |
| 9 | +import { getForbiddenRoute } from '../../app-routing-paths'; |
| 10 | +import { hasValue } from '../../shared/empty.util'; |
| 11 | +import { ItemRequestDataService } from '../data/item-request-data.service'; |
| 12 | +import { redirectOn4xx } from '../shared/authorized.operators'; |
| 13 | +import { ItemRequest } from '../shared/item-request.model'; |
| 14 | +import { |
| 15 | + getFirstCompletedRemoteData, |
| 16 | + getFirstSucceededRemoteDataPayload, |
| 17 | +} from '../shared/operators'; |
| 18 | +import { AuthService } from './auth.service'; |
| 19 | + |
| 20 | +export const accessTokenResolver: ResolveFn<ItemRequest> = ( |
| 21 | + route, |
| 22 | + state, |
| 23 | + router: Router = inject(Router), |
| 24 | + authService: AuthService = inject(AuthService), |
| 25 | + itemRequestDataService: ItemRequestDataService = inject(ItemRequestDataService), |
| 26 | +): Observable<ItemRequest> => { |
| 27 | + const accessToken = route.queryParams.accessToken; |
| 28 | + if ( !hasValue(accessToken) ) { |
| 29 | + return null; |
| 30 | + } |
| 31 | + // Get |
| 32 | + return itemRequestDataService.getSanitizedRequestByAccessToken(accessToken).pipe( |
| 33 | + getFirstCompletedRemoteData(), |
| 34 | + redirectOn4xx(router, authService), |
| 35 | + getFirstSucceededRemoteDataPayload(), |
| 36 | + tap(request => { |
| 37 | + if (!hasValue(request)) { |
| 38 | + console.dir('no request found for access token', accessToken); |
| 39 | + router.navigateByUrl(getForbiddenRoute()); |
| 40 | + } |
| 41 | + console.dir('found request: ', request); |
| 42 | + console.dir(request); |
| 43 | + return request; |
| 44 | + }), |
| 45 | + ); |
| 46 | +}; |
0 commit comments