refactor(router): create pipeable recognize function (#25740)
PR Close #25740
This commit is contained in:
parent
4d544bcb46
commit
4decc8521d
|
@ -0,0 +1,28 @@
|
||||||
|
/**
|
||||||
|
* @license
|
||||||
|
* Copyright Google Inc. All Rights Reserved.
|
||||||
|
*
|
||||||
|
* Use of this source code is governed by an MIT-style license that can be
|
||||||
|
* found in the LICENSE file at https://angular.io/license
|
||||||
|
*/
|
||||||
|
|
||||||
|
import {Type} from '@angular/core';
|
||||||
|
import {Observable, OperatorFunction} from 'rxjs';
|
||||||
|
import {mergeMap} from 'rxjs/operators';
|
||||||
|
|
||||||
|
import {Route} from '../config';
|
||||||
|
import {recognize as recognizeFn} from '../recognize';
|
||||||
|
import {RouterStateSnapshot} from '../router_state';
|
||||||
|
import {UrlTree} from '../url_tree';
|
||||||
|
|
||||||
|
export function recognize(
|
||||||
|
rootComponentType: Type<any>| null, config: Route[], serializer: (url: UrlTree) => string,
|
||||||
|
paramsInheritanceStrategy: 'emptyOnly' |
|
||||||
|
'always'): OperatorFunction<UrlTree, RouterStateSnapshot> {
|
||||||
|
return function(source: Observable<UrlTree>) {
|
||||||
|
return source.pipe(mergeMap(
|
||||||
|
(appliedUrl: UrlTree) => recognizeFn(
|
||||||
|
rootComponentType, config, appliedUrl, serializer(appliedUrl),
|
||||||
|
paramsInheritanceStrategy)));
|
||||||
|
};
|
||||||
|
}
|
|
@ -9,15 +9,15 @@
|
||||||
import {Location} from '@angular/common';
|
import {Location} from '@angular/common';
|
||||||
import {Compiler, Injector, NgModuleFactoryLoader, NgModuleRef, NgZone, Optional, Type, isDevMode, ɵConsole as Console} from '@angular/core';
|
import {Compiler, Injector, NgModuleFactoryLoader, NgModuleRef, NgZone, Optional, Type, isDevMode, ɵConsole as Console} from '@angular/core';
|
||||||
import {BehaviorSubject, Observable, Subject, Subscription, of } from 'rxjs';
|
import {BehaviorSubject, Observable, Subject, Subscription, of } from 'rxjs';
|
||||||
import {concatMap, map, mergeMap} from 'rxjs/operators';
|
import {concatMap, map, mergeMap, tap} from 'rxjs/operators';
|
||||||
|
|
||||||
import {applyRedirects} from './apply_redirects';
|
import {applyRedirects} from './apply_redirects';
|
||||||
import {LoadedRouterConfig, QueryParamsHandling, Route, Routes, standardizeConfig, validateConfig} from './config';
|
import {LoadedRouterConfig, QueryParamsHandling, Route, Routes, standardizeConfig, validateConfig} from './config';
|
||||||
import {createRouterState} from './create_router_state';
|
import {createRouterState} from './create_router_state';
|
||||||
import {createUrlTree} from './create_url_tree';
|
import {createUrlTree} from './create_url_tree';
|
||||||
import {ActivationEnd, ChildActivationEnd, Event, GuardsCheckEnd, GuardsCheckStart, NavigationCancel, NavigationEnd, NavigationError, NavigationStart, NavigationTrigger, ResolveEnd, ResolveStart, RouteConfigLoadEnd, RouteConfigLoadStart, RoutesRecognized} from './events';
|
import {ActivationEnd, ChildActivationEnd, Event, GuardsCheckEnd, GuardsCheckStart, NavigationCancel, NavigationEnd, NavigationError, NavigationStart, NavigationTrigger, ResolveEnd, ResolveStart, RouteConfigLoadEnd, RouteConfigLoadStart, RoutesRecognized} from './events';
|
||||||
|
import {recognize} from './operators/recognize';
|
||||||
import {PreActivation} from './pre_activation';
|
import {PreActivation} from './pre_activation';
|
||||||
import {recognize} from './recognize';
|
|
||||||
import {DefaultRouteReuseStrategy, DetachedRouteHandleInternal, RouteReuseStrategy} from './route_reuse_strategy';
|
import {DefaultRouteReuseStrategy, DetachedRouteHandleInternal, RouteReuseStrategy} from './route_reuse_strategy';
|
||||||
import {RouterConfigLoader} from './router_config_loader';
|
import {RouterConfigLoader} from './router_config_loader';
|
||||||
import {ChildrenOutletContexts} from './router_outlet_context';
|
import {ChildrenOutletContexts} from './router_outlet_context';
|
||||||
|
@ -699,18 +699,20 @@ export class Router {
|
||||||
const redirectsApplied$ =
|
const redirectsApplied$ =
|
||||||
applyRedirects(moduleInjector, this.configLoader, this.urlSerializer, url, this.config);
|
applyRedirects(moduleInjector, this.configLoader, this.urlSerializer, url, this.config);
|
||||||
|
|
||||||
urlAndSnapshot$ = redirectsApplied$.pipe(mergeMap((appliedUrl: UrlTree) => {
|
urlAndSnapshot$ = redirectsApplied$.pipe(mergeMap(
|
||||||
return recognize(
|
(appliedUrl: UrlTree) =>
|
||||||
this.rootComponentType, this.config, appliedUrl, this.serializeUrl(appliedUrl),
|
recognize(
|
||||||
this.paramsInheritanceStrategy, this.relativeLinkResolution)
|
this.rootComponentType, this.config, (url) => this.serializeUrl(url),
|
||||||
.pipe(map((snapshot: any) => {
|
this.paramsInheritanceStrategy)(of (appliedUrl))
|
||||||
(this.events as Subject<Event>)
|
.pipe(
|
||||||
.next(new RoutesRecognized(
|
map((snapshot: RouterStateSnapshot) => ({appliedUrl, snapshot})),
|
||||||
id, this.serializeUrl(url), this.serializeUrl(appliedUrl), snapshot));
|
tap(({appliedUrl,
|
||||||
|
snapshot}: {appliedUrl: UrlTree, snapshot: RouterStateSnapshot}) =>
|
||||||
|
(this.events as Subject<Event>)
|
||||||
|
.next(new RoutesRecognized(
|
||||||
|
id, this.serializeUrl(url), this.serializeUrl(appliedUrl),
|
||||||
|
snapshot))))));
|
||||||
|
|
||||||
return {appliedUrl, snapshot};
|
|
||||||
}));
|
|
||||||
}));
|
|
||||||
} else {
|
} else {
|
||||||
urlAndSnapshot$ = of ({appliedUrl: url, snapshot: precreatedState});
|
urlAndSnapshot$ = of ({appliedUrl: url, snapshot: precreatedState});
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue