angular-cn/modules/@angular/router/src/router.ts

816 lines
28 KiB
TypeScript
Raw Normal View History

/**
* @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 'rxjs/add/operator/map';
import 'rxjs/add/operator/mergeMap';
import 'rxjs/add/operator/mergeAll';
import 'rxjs/add/operator/reduce';
import 'rxjs/add/operator/every';
2016-06-08 14:13:41 -04:00
import {Location} from '@angular/common';
import {Compiler, ComponentFactoryResolver, Injector, NgModuleFactoryLoader, ReflectiveInjector, Type} from '@angular/core';
2016-06-08 14:13:41 -04:00
import {Observable} from 'rxjs/Observable';
import {Subject} from 'rxjs/Subject';
import {Subscription} from 'rxjs/Subscription';
import {from} from 'rxjs/observable/from';
import {of } from 'rxjs/observable/of';
2016-06-08 14:13:41 -04:00
2016-06-08 19:14:26 -04:00
import {applyRedirects} from './apply_redirects';
2016-07-06 19:19:52 -04:00
import {ResolveData, Routes, validateConfig} from './config';
2016-06-08 14:13:41 -04:00
import {createRouterState} from './create_router_state';
import {createUrlTree} from './create_url_tree';
import {RouterOutlet} from './directives/router_outlet';
import {recognize} from './recognize';
import {LoadedRouterConfig, RouterConfigLoader} from './router_config_loader';
2016-06-08 14:13:41 -04:00
import {RouterOutletMap} from './router_outlet_map';
import {ActivatedRoute, ActivatedRouteSnapshot, RouterState, RouterStateSnapshot, advanceActivatedRoute, createEmptyState} from './router_state';
2016-06-08 14:13:41 -04:00
import {PRIMARY_OUTLET, Params} from './shared';
2016-07-28 20:59:05 -04:00
import {UrlSerializer, UrlTree, containsTree, createEmptyUrlTree} from './url_tree';
2016-07-26 17:39:02 -04:00
import {andObservables, forEach, merge, shallowEqual, waitForMap, wrapIntoObservable} from './utils/collection';
2016-06-08 14:13:41 -04:00
import {TreeNode} from './utils/tree';
declare var Zone: any;
2016-07-18 19:42:33 -04:00
/**
* @experimental
*/
2016-06-08 14:13:41 -04:00
export interface NavigationExtras {
relativeTo?: ActivatedRoute;
queryParams?: Params;
fragment?: string;
preserveQueryParams?: boolean;
preserveFragment?: boolean;
skipLocationChange?: boolean;
replaceUrl?: boolean;
2016-06-08 14:13:41 -04:00
}
2016-06-03 17:28:41 -04:00
/**
* An event triggered when a navigation starts
*
2016-06-28 17:49:29 -04:00
* @stable
2016-06-03 17:28:41 -04:00
*/
2016-06-08 14:13:41 -04:00
export class NavigationStart {
2016-06-14 17:55:59 -04:00
constructor(public id: number, public url: string) {}
2016-06-09 17:32:03 -04:00
2016-06-09 17:33:09 -04:00
toString(): string { return `NavigationStart(id: ${this.id}, url: '${this.url}')`; }
2016-06-08 14:13:41 -04:00
}
2016-06-03 17:28:41 -04:00
/**
* An event triggered when a navigation ends successfully
*
2016-06-28 17:49:29 -04:00
* @stable
2016-06-03 17:28:41 -04:00
*/
2016-06-08 14:13:41 -04:00
export class NavigationEnd {
2016-06-14 17:55:59 -04:00
constructor(public id: number, public url: string, public urlAfterRedirects: string) {}
2016-06-09 17:32:03 -04:00
2016-06-14 17:55:59 -04:00
toString(): string {
return `NavigationEnd(id: ${this.id}, url: '${this.url}', urlAfterRedirects: '${this.urlAfterRedirects}')`;
}
2016-06-08 14:13:41 -04:00
}
2016-06-03 17:28:41 -04:00
/**
* An event triggered when a navigation is canceled
*
2016-06-28 17:49:29 -04:00
* @stable
2016-06-03 17:28:41 -04:00
*/
2016-06-08 14:13:41 -04:00
export class NavigationCancel {
2016-06-14 17:55:59 -04:00
constructor(public id: number, public url: string) {}
2016-06-09 17:32:03 -04:00
2016-06-09 17:33:09 -04:00
toString(): string { return `NavigationCancel(id: ${this.id}, url: '${this.url}')`; }
2016-06-08 14:13:41 -04:00
}
2016-06-03 17:28:41 -04:00
/**
* An event triggered when a navigation fails due to unexpected error
*
2016-06-28 17:49:29 -04:00
* @stable
2016-06-03 17:28:41 -04:00
*/
2016-06-08 14:13:41 -04:00
export class NavigationError {
2016-06-14 17:55:59 -04:00
constructor(public id: number, public url: string, public error: any) {}
2016-06-09 17:32:03 -04:00
toString(): string {
return `NavigationError(id: ${this.id}, url: '${this.url}', error: ${this.error})`;
}
2016-06-08 14:13:41 -04:00
}
2016-06-03 17:28:41 -04:00
/**
* An event triggered when routes are recognized
*
2016-06-28 17:49:29 -04:00
* @stable
*/
export class RoutesRecognized {
2016-06-09 17:33:09 -04:00
constructor(
2016-06-14 17:55:59 -04:00
public id: number, public url: string, public urlAfterRedirects: string,
2016-06-09 17:33:09 -04:00
public state: RouterStateSnapshot) {}
2016-06-09 17:32:03 -04:00
toString(): string {
return `RoutesRecognized(id: ${this.id}, url: '${this.url}', urlAfterRedirects: '${this.urlAfterRedirects}', state: ${this.state})`;
}
}
/**
2016-06-28 17:49:29 -04:00
* @stable
*/
2016-08-05 11:24:40 -04:00
export type Event =
NavigationStart | NavigationEnd | NavigationCancel | NavigationError | RoutesRecognized;
2016-05-24 16:41:37 -04:00
/**
* The `Router` is responsible for mapping URLs to components.
*
* See {@link Routes} for more details and examples.
2016-06-28 17:49:29 -04:00
*
* @stable
2016-05-24 16:41:37 -04:00
*/
export class Router {
private currentUrlTree: UrlTree;
private currentRouterState: RouterState;
private locationSubscription: Subscription;
private routerEvents: Subject<Event>;
2016-06-03 17:07:01 -04:00
private navigationId: number = 0;
private configLoader: RouterConfigLoader;
/**
* Indicates if at least one navigation happened.
*
* @experimental
*/
navigated: boolean = false;
2016-05-24 16:41:37 -04:00
/**
* Creates the router service.
2016-05-24 16:41:37 -04:00
*/
2016-06-08 14:13:41 -04:00
constructor(
private rootComponentType: Type<any>, private urlSerializer: UrlSerializer,
private outletMap: RouterOutletMap, private location: Location, private injector: Injector,
loader: NgModuleFactoryLoader, compiler: Compiler, public config: Routes) {
this.resetConfig(config);
this.routerEvents = new Subject<Event>();
2016-06-07 12:50:35 -04:00
this.currentUrlTree = createEmptyUrlTree();
this.configLoader = new RouterConfigLoader(loader, compiler);
2016-06-14 17:55:59 -04:00
this.currentRouterState = createEmptyState(this.currentUrlTree, this.rootComponentType);
}
/**
* Sets up the location change listener and performs the inital navigation
*/
2016-06-08 14:13:41 -04:00
initialNavigation(): void {
this.setUpLocationChangeListener();
this.navigateByUrl(this.location.path(true), {replaceUrl: true});
}
2016-05-24 16:41:37 -04:00
/**
* Returns the current route state.
*/
2016-06-08 14:13:41 -04:00
get routerState(): RouterState { return this.currentRouterState; }
/**
2016-06-14 17:55:59 -04:00
* Returns the current url.
*/
2016-06-14 17:55:59 -04:00
get url(): string { return this.serializeUrl(this.currentUrlTree); }
2016-05-24 16:41:37 -04:00
2016-06-03 17:28:41 -04:00
/**
* Returns an observable of route events
*/
2016-06-08 14:13:41 -04:00
get events(): Observable<Event> { return this.routerEvents; }
2016-05-24 16:41:37 -04:00
/**
* Resets the configuration used for navigation and generating links.
*
* ### Usage
*
* ```
* router.resetConfig([
* { path: 'team/:id', component: TeamCmp, children: [
* { path: 'simple', component: SimpleCmp },
* { path: 'user/:name', component: UserCmp }
2016-05-24 16:41:37 -04:00
* ] }
* ]);
* ```
*/
2016-07-06 19:19:52 -04:00
resetConfig(config: Routes): void {
validateConfig(config);
this.config = config;
}
ngOnDestroy() { this.dispose(); }
2016-05-24 17:33:34 -04:00
/**
* Disposes of the router.
2016-05-24 17:33:34 -04:00
*/
dispose(): void { this.locationSubscription.unsubscribe(); }
/**
* Applies an array of commands to the current url tree and creates
* a new url tree.
*
* When given an activate route, applies the given commands starting from the route.
* When not given a route, applies the given command starting from the root.
*
* ### Usage
*
* ```
* // create /team/33/user/11
* router.createUrlTree(['/team', 33, 'user', 11]);
*
* // create /team/33;expand=true/user/11
* router.createUrlTree(['/team', 33, {expand: true}, 'user', 11]);
*
* // you can collapse static segments like this (this works only with the first passed-in value):
* router.createUrlTree(['/team/33/user', userId]);
*
* If the first segment can contain slashes, and you do not want the router to split it, you
* can do the following:
*
* router.createUrlTree([{segmentPath: '/one/two'}]);
*
* // create /team/33/(user/11//right:chat)
* router.createUrlTree(['/team', 33, {outlets: {primary: 'user/11', right: 'chat'}}]);
*
* // remove the right secondary node
* router.createUrlTree(['/team', 33, {outlets: {primary: 'user/11', right: null}}]);
*
* // assuming the current url is `/team/33/user/11` and the route points to `user/11`
*
* // navigate to /team/33/user/11/details
* router.createUrlTree(['details'], {relativeTo: route});
*
* // navigate to /team/33/user/22
* router.createUrlTree(['../22'], {relativeTo: route});
*
* // navigate to /team/44/user/22
* router.createUrlTree(['../../team/44/user/22'], {relativeTo: route});
* ```
*/
createUrlTree(
commands: any[], {relativeTo, queryParams, fragment, preserveQueryParams,
preserveFragment}: NavigationExtras = {}): UrlTree {
const a = relativeTo ? relativeTo : this.routerState.root;
const q = preserveQueryParams ? this.currentUrlTree.queryParams : queryParams;
const f = preserveFragment ? this.currentUrlTree.fragment : fragment;
return createUrlTree(a, this.currentUrlTree, commands, q, f);
}
/**
* Navigate based on the provided url. This navigation is always absolute.
*
* Returns a promise that:
* - is resolved with 'true' when navigation succeeds
* - is resolved with 'false' when navigation fails
* - is rejected when an error happens
*
* ### Usage
*
* ```
* router.navigateByUrl("/team/33/user/11");
*
* // Navigate without updating the URL
* router.navigateByUrl("/team/33/user/11", { skipLocationChange: true });
* ```
*
* In opposite to `navigate`, `navigateByUrl` takes a whole URL
* and does not apply any delta to the current one.
*/
navigateByUrl(url: string|UrlTree, extras: NavigationExtras = {skipLocationChange: false}):
Promise<boolean> {
if (url instanceof UrlTree) {
return this.scheduleNavigation(url, extras);
} else {
const urlTree = this.urlSerializer.parse(url);
return this.scheduleNavigation(urlTree, extras);
}
}
/**
* Navigate based on the provided array of commands and a starting point.
* If no starting route is provided, the navigation is absolute.
*
2016-06-03 17:28:41 -04:00
* Returns a promise that:
* - is resolved with 'true' when navigation succeeds
* - is resolved with 'false' when navigation fails
* - is rejected when an error happens
*
* ### Usage
*
* ```
* router.navigate(['team', 33, 'team', '11], {relativeTo: route});
*
* // Navigate without updating the URL
* router.navigate(['team', 33, 'team', '11], {relativeTo: route, skipLocationChange: true });
* ```
*
* In opposite to `navigateByUrl`, `navigate` always takes a delta
* that is applied to the current URL.
*/
navigate(commands: any[], extras: NavigationExtras = {skipLocationChange: false}):
Promise<boolean> {
return this.scheduleNavigation(this.createUrlTree(commands, extras), extras);
}
/**
* Serializes a {@link UrlTree} into a string.
*/
serializeUrl(url: UrlTree): string { return this.urlSerializer.serialize(url); }
/**
* Parse a string into a {@link UrlTree}.
*/
parseUrl(url: string): UrlTree { return this.urlSerializer.parse(url); }
2016-07-28 20:59:05 -04:00
/**
* Returns if the url is activated or not.
*/
isActive(url: string|UrlTree, exact: boolean): boolean {
if (url instanceof UrlTree) {
return containsTree(this.currentUrlTree, url, exact);
} else {
const urlTree = this.urlSerializer.parse(url);
return containsTree(this.currentUrlTree, urlTree, exact);
}
}
private scheduleNavigation(url: UrlTree, extras: NavigationExtras): Promise<boolean> {
2016-06-08 14:13:41 -04:00
const id = ++this.navigationId;
2016-06-14 17:55:59 -04:00
this.routerEvents.next(new NavigationStart(id, this.serializeUrl(url)));
return Promise.resolve().then(
(_) => this.runNavigate(url, extras.skipLocationChange, extras.replaceUrl, id));
2016-06-03 17:07:01 -04:00
}
private setUpLocationChangeListener(): void {
// Zone.current.wrap is needed because of the issue with RxJS scheduler,
// which does not work properly with zone.js in IE and Safari
this.locationSubscription = <any>this.location.subscribe(Zone.current.wrap((change: any) => {
const tree = this.urlSerializer.parse(change['url']);
// we fire multiple events for a single URL change
// we should navigate only once
return this.currentUrlTree.toString() !== tree.toString() ?
this.scheduleNavigation(tree, {skipLocationChange: change['pop'], replaceUrl: true}) :
null;
}));
}
private runNavigate(
url: UrlTree, shouldPreventPushState: boolean, shouldReplaceUrl: boolean,
id: number): Promise<boolean> {
2016-06-03 17:07:01 -04:00
if (id !== this.navigationId) {
2016-06-09 14:02:57 -04:00
this.location.go(this.urlSerializer.serialize(this.currentUrlTree));
2016-06-14 17:55:59 -04:00
this.routerEvents.next(new NavigationCancel(id, this.serializeUrl(url)));
2016-06-03 17:07:01 -04:00
return Promise.resolve(false);
}
2016-06-01 16:34:48 -04:00
2016-06-03 17:07:01 -04:00
return new Promise((resolvePromise, rejectPromise) => {
let state: RouterState;
let navigationIsSuccessful: boolean;
let preActivation: PreActivation;
let appliedUrl: UrlTree;
const storedState = this.currentRouterState;
const storedUrl = this.currentUrlTree;
applyRedirects(this.injector, this.configLoader, url, this.config)
2016-06-08 19:14:26 -04:00
.mergeMap(u => {
appliedUrl = u;
2016-06-14 17:55:59 -04:00
return recognize(
this.rootComponentType, this.config, appliedUrl, this.serializeUrl(appliedUrl));
2016-06-08 19:14:26 -04:00
})
.map((newRouterStateSnapshot) => {
2016-06-14 17:55:59 -04:00
this.routerEvents.next(new RoutesRecognized(
id, this.serializeUrl(url), this.serializeUrl(appliedUrl), newRouterStateSnapshot));
return newRouterStateSnapshot;
2016-06-08 14:13:41 -04:00
})
.map((routerStateSnapshot) => {
return createRouterState(routerStateSnapshot, this.currentRouterState);
})
.map((newState: RouterState) => {
state = newState;
preActivation =
new PreActivation(state.snapshot, this.currentRouterState.snapshot, this.injector);
preActivation.traverse(this.outletMap);
2016-06-08 14:13:41 -04:00
})
.mergeMap(_ => {
return preActivation.checkGuards();
})
.mergeMap(shouldActivate => {
if (shouldActivate) {
return preActivation.resolveData().map(() => shouldActivate);
} else {
return of (shouldActivate);
}
2016-06-08 14:13:41 -04:00
})
.forEach((shouldActivate: boolean) => {
2016-06-08 14:13:41 -04:00
if (!shouldActivate || id !== this.navigationId) {
navigationIsSuccessful = false;
return;
2016-06-08 14:13:41 -04:00
}
this.currentUrlTree = appliedUrl;
2016-06-08 14:13:41 -04:00
this.currentRouterState = state;
new ActivateRoutes(state, storedState).activate(this.outletMap);
if (!shouldPreventPushState) {
let path = this.urlSerializer.serialize(appliedUrl);
if (this.location.isCurrentPathEqualTo(path) || shouldReplaceUrl) {
this.location.replaceState(path);
} else {
this.location.go(path);
}
2016-06-08 14:13:41 -04:00
}
navigationIsSuccessful = true;
2016-06-08 14:13:41 -04:00
})
.then(
() => {
this.navigated = true;
if (navigationIsSuccessful) {
this.routerEvents.next(
new NavigationEnd(id, this.serializeUrl(url), this.serializeUrl(appliedUrl)));
resolvePromise(true);
} else {
this.routerEvents.next(new NavigationCancel(id, this.serializeUrl(url)));
resolvePromise(false);
}
2016-06-08 14:13:41 -04:00
},
e => {
this.currentRouterState = storedState;
this.currentUrlTree = storedUrl;
2016-06-14 17:55:59 -04:00
this.routerEvents.next(new NavigationError(id, this.serializeUrl(url), e));
2016-06-08 14:13:41 -04:00
rejectPromise(e);
});
});
}
}
2016-06-08 14:13:41 -04:00
class CanActivate {
constructor(public path: ActivatedRouteSnapshot[]) {}
get route(): ActivatedRouteSnapshot { return this.path[this.path.length - 1]; }
2016-06-08 14:13:41 -04:00
}
2016-06-08 14:13:41 -04:00
class CanDeactivate {
constructor(public component: Object, public route: ActivatedRouteSnapshot) {}
}
2016-06-02 17:44:57 -04:00
export class PreActivation {
private checks: Array<CanActivate|CanDeactivate> = [];
2016-06-08 14:13:41 -04:00
constructor(
private future: RouterStateSnapshot, private curr: RouterStateSnapshot,
private injector: Injector) {}
traverse(parentOutletMap: RouterOutletMap): void {
const futureRoot = this.future._root;
const currRoot = this.curr ? this.curr._root : null;
this.traverseChildRoutes(futureRoot, currRoot, parentOutletMap, [futureRoot.value]);
}
checkGuards(): Observable<boolean> {
if (this.checks.length === 0) return of (true);
return from(this.checks)
.map(s => {
if (s instanceof CanActivate) {
return andObservables(
from([this.runCanActivate(s.route), this.runCanActivateChild(s.path)]));
} else if (s instanceof CanDeactivate) {
// workaround https://github.com/Microsoft/TypeScript/issues/7271
const s2 = s as CanDeactivate;
return this.runCanDeactivate(s2.component, s2.route);
} else {
throw new Error('Cannot be reached');
}
})
.mergeAll()
.every(result => result === true);
}
resolveData(): Observable<any> {
if (this.checks.length === 0) return of (null);
return from(this.checks)
.mergeMap(s => {
if (s instanceof CanActivate) {
return this.runResolve(s.route);
} else {
return of (null);
}
})
.reduce((_, __) => _);
}
2016-06-08 14:13:41 -04:00
private traverseChildRoutes(
futureNode: TreeNode<ActivatedRouteSnapshot>, currNode: TreeNode<ActivatedRouteSnapshot>,
outletMap: RouterOutletMap, futurePath: ActivatedRouteSnapshot[]): void {
const prevChildren: {[key: string]: any} = nodeChildrenAsMap(currNode);
futureNode.children.forEach(c => {
this.traverseRoutes(c, prevChildren[c.value.outlet], outletMap, futurePath.concat([c.value]));
delete prevChildren[c.value.outlet];
});
forEach(
prevChildren,
(v: any, k: string) => this.deactivateOutletAndItChildren(v, outletMap._outlets[k]));
}
2016-06-08 14:13:41 -04:00
traverseRoutes(
futureNode: TreeNode<ActivatedRouteSnapshot>, currNode: TreeNode<ActivatedRouteSnapshot>,
parentOutletMap: RouterOutletMap, futurePath: ActivatedRouteSnapshot[]): void {
const future = futureNode.value;
const curr = currNode ? currNode.value : null;
2016-06-02 17:44:57 -04:00
const outlet = parentOutletMap ? parentOutletMap._outlets[futureNode.value.outlet] : null;
// reusing the node
2016-06-02 17:44:57 -04:00
if (curr && future._routeConfig === curr._routeConfig) {
if (!shallowEqual(future.params, curr.params)) {
this.checks.push(new CanDeactivate(outlet.component, curr), new CanActivate(futurePath));
} else {
// we need to set the data
future.data = curr.data;
}
// If we have a component, we need to go through an outlet.
if (future.component) {
this.traverseChildRoutes(
futureNode, currNode, outlet ? outlet.outletMap : null, futurePath);
// if we have a componentless route, we recurse but keep the same outlet map.
} else {
this.traverseChildRoutes(futureNode, currNode, parentOutletMap, futurePath);
}
} else {
if (curr) {
// if we had a normal route, we need to deactivate only that outlet.
if (curr.component) {
this.deactivateOutletAndItChildren(curr, outlet);
// if we had a componentless route, we need to deactivate everything!
} else {
this.deactivateOutletMap(parentOutletMap);
}
}
this.checks.push(new CanActivate(futurePath));
// If we have a component, we need to go through an outlet.
if (future.component) {
this.traverseChildRoutes(futureNode, null, outlet ? outlet.outletMap : null, futurePath);
// if we have a componentless route, we recurse but keep the same outlet map.
} else {
this.traverseChildRoutes(futureNode, null, parentOutletMap, futurePath);
}
}
}
2016-06-02 17:44:57 -04:00
private deactivateOutletAndItChildren(route: ActivatedRouteSnapshot, outlet: RouterOutlet): void {
if (outlet && outlet.isActivated) {
this.deactivateOutletMap(outlet.outletMap);
2016-06-07 12:50:35 -04:00
this.checks.push(new CanDeactivate(outlet.component, route));
2016-06-02 17:44:57 -04:00
}
}
private deactivateOutletMap(outletMap: RouterOutletMap): void {
forEach(outletMap._outlets, (v: RouterOutlet) => {
if (v.isActivated) {
this.deactivateOutletAndItChildren(v.activatedRoute.snapshot, v);
}
});
}
private runCanActivate(future: ActivatedRouteSnapshot): Observable<boolean> {
const canActivate = future._routeConfig ? future._routeConfig.canActivate : null;
if (!canActivate || canActivate.length === 0) return of (true);
const obs = from(canActivate).map(c => {
const guard = this.getToken(c, future);
if (guard.canActivate) {
return wrapIntoObservable(guard.canActivate(future, this.future));
} else {
return wrapIntoObservable(guard(future, this.future));
}
});
return andObservables(obs);
}
private runCanActivateChild(path: ActivatedRouteSnapshot[]): Observable<boolean> {
const future = path[path.length - 1];
const canActivateChildGuards = path.slice(0, path.length - 1)
.reverse()
.map(p => this.extractCanActivateChild(p))
.filter(_ => _ !== null);
return andObservables(from(canActivateChildGuards).map(d => {
const obs = from(d.guards).map(c => {
const guard = this.getToken(c, c.node);
if (guard.canActivateChild) {
return wrapIntoObservable(guard.canActivateChild(future, this.future));
} else {
return wrapIntoObservable(guard(future, this.future));
}
});
return andObservables(obs);
}));
}
2016-06-02 17:44:57 -04:00
private extractCanActivateChild(p: ActivatedRouteSnapshot):
{node: ActivatedRouteSnapshot, guards: any[]} {
const canActivateChild = p._routeConfig ? p._routeConfig.canActivateChild : null;
if (!canActivateChild || canActivateChild.length === 0) return null;
return {node: p, guards: canActivateChild};
}
2016-06-02 17:44:57 -04:00
private runCanDeactivate(component: Object, curr: ActivatedRouteSnapshot): Observable<boolean> {
const canDeactivate = curr && curr._routeConfig ? curr._routeConfig.canDeactivate : null;
if (!canDeactivate || canDeactivate.length === 0) return of (true);
return from(canDeactivate)
.map(c => {
const guard = this.getToken(c, curr);
if (guard.canDeactivate) {
return wrapIntoObservable(guard.canDeactivate(component, curr, this.curr));
} else {
return wrapIntoObservable(guard(component, curr, this.curr));
}
})
.mergeAll()
.every(result => result === true);
2016-06-02 17:44:57 -04:00
}
private runResolve(future: ActivatedRouteSnapshot): Observable<any> {
const resolve = future._resolve;
return this.resolveNode(resolve.current, future).map(resolvedData => {
resolve.resolvedData = resolvedData;
future.data = merge(future.data, resolve.flattenedResolvedData);
return null;
});
}
private resolveNode(resolve: ResolveData, future: ActivatedRouteSnapshot): Observable<any> {
return waitForMap(resolve, (k, v) => {
const resolver = this.getToken(v, future);
return resolver.resolve ? wrapIntoObservable(resolver.resolve(future, this.future)) :
wrapIntoObservable(resolver(future, this.future));
});
}
private getToken(token: any, snapshot: ActivatedRouteSnapshot): any {
const config = closestLoadedConfig(snapshot);
const injector = config ? config.injector : this.injector;
return injector.get(token);
}
}
class ActivateRoutes {
constructor(private futureState: RouterState, private currState: RouterState) {}
2016-06-08 14:13:41 -04:00
activate(parentOutletMap: RouterOutletMap): void {
2016-06-01 16:34:48 -04:00
const futureRoot = this.futureState._root;
const currRoot = this.currState ? this.currState._root : null;
advanceActivatedRoute(this.futureState.root);
this.activateChildRoutes(futureRoot, currRoot, parentOutletMap);
}
2016-06-08 14:13:41 -04:00
private activateChildRoutes(
futureNode: TreeNode<ActivatedRoute>, currNode: TreeNode<ActivatedRoute>,
2016-06-08 14:13:41 -04:00
outletMap: RouterOutletMap): void {
const prevChildren: {[key: string]: any} = nodeChildrenAsMap(currNode);
futureNode.children.forEach(c => {
this.activateRoutes(c, prevChildren[c.value.outlet], outletMap);
delete prevChildren[c.value.outlet];
});
forEach(
prevChildren,
(v: any, k: string) => this.deactivateOutletAndItChildren(outletMap._outlets[k]));
}
2016-06-08 14:13:41 -04:00
activateRoutes(
futureNode: TreeNode<ActivatedRoute>, currNode: TreeNode<ActivatedRoute>,
2016-06-08 14:13:41 -04:00
parentOutletMap: RouterOutletMap): void {
const future = futureNode.value;
const curr = currNode ? currNode.value : null;
2016-06-14 17:55:59 -04:00
// reusing the node
if (future === curr) {
// advance the route to push the parameters
2016-06-02 17:44:57 -04:00
advanceActivatedRoute(future);
// If we have a normal route, we need to go through an outlet.
if (future.component) {
const outlet = getOutlet(parentOutletMap, futureNode.value);
this.activateChildRoutes(futureNode, currNode, outlet.outletMap);
// if we have a componentless route, we recurse but keep the same outlet map.
} else {
this.activateChildRoutes(futureNode, currNode, parentOutletMap);
}
} else {
if (curr) {
// if we had a normal route, we need to deactivate only that outlet.
if (curr.component) {
const outlet = getOutlet(parentOutletMap, futureNode.value);
this.deactivateOutletAndItChildren(outlet);
// if we had a componentless route, we need to deactivate everything!
} else {
this.deactivateOutletMap(parentOutletMap);
}
}
// if we have a normal route, we need to advance the route
// and place the component into the outlet. After that recurse.
if (future.component) {
advanceActivatedRoute(future);
const outlet = getOutlet(parentOutletMap, futureNode.value);
const outletMap = new RouterOutletMap();
this.placeComponentIntoOutlet(outletMap, future, outlet);
this.activateChildRoutes(futureNode, null, outletMap);
// if we have a componentless route, we recurse but keep the same outlet map.
} else {
advanceActivatedRoute(future);
this.activateChildRoutes(futureNode, null, parentOutletMap);
}
}
}
private placeComponentIntoOutlet(
2016-06-08 14:13:41 -04:00
outletMap: RouterOutletMap, future: ActivatedRoute, outlet: RouterOutlet): void {
const resolved = <any[]>[{provide: ActivatedRoute, useValue: future}, {
provide: RouterOutletMap,
useValue: outletMap
}];
const config = parentLoadedConfig(future.snapshot);
let loadedFactoryResolver: ComponentFactoryResolver = null;
let loadedInjector: Injector = null;
if (config) {
loadedFactoryResolver = config.factoryResolver;
loadedInjector = config.injector;
resolved.push({provide: ComponentFactoryResolver, useValue: loadedFactoryResolver});
}
outlet.activate(
future, loadedFactoryResolver, loadedInjector, ReflectiveInjector.resolve(resolved),
outletMap);
}
private deactivateOutletAndItChildren(outlet: RouterOutlet): void {
if (outlet && outlet.isActivated) {
this.deactivateOutletMap(outlet.outletMap);
outlet.deactivate();
}
}
private deactivateOutletMap(outletMap: RouterOutletMap): void {
forEach(outletMap._outlets, (v: RouterOutlet) => this.deactivateOutletAndItChildren(v));
}
}
function parentLoadedConfig(snapshot: ActivatedRouteSnapshot): LoadedRouterConfig {
let s = snapshot.parent;
while (s) {
const c: any = s._routeConfig;
if (c && c._loadedConfig) return c._loadedConfig;
if (c && c.component) return null;
s = s.parent;
}
return null;
}
function closestLoadedConfig(snapshot: ActivatedRouteSnapshot): LoadedRouterConfig {
if (!snapshot) return null;
let s = snapshot.parent;
while (s) {
const c: any = s._routeConfig;
if (c && c._loadedConfig) return c._loadedConfig;
s = s.parent;
}
return null;
}
function nodeChildrenAsMap(node: TreeNode<any>) {
return node ? node.children.reduce((m: any, c: TreeNode<any>) => {
2016-06-08 14:13:41 -04:00
m[c.value.outlet] = c;
return m;
}, {}) : {};
}
function getOutlet(outletMap: RouterOutletMap, route: ActivatedRoute): RouterOutlet {
let outlet = outletMap._outlets[route.outlet];
if (!outlet) {
2016-06-14 17:55:59 -04:00
const componentName = (<any>route.component).name;
if (route.outlet === PRIMARY_OUTLET) {
2016-06-14 17:55:59 -04:00
throw new Error(`Cannot find primary outlet to load '${componentName}'`);
} else {
2016-06-14 17:55:59 -04:00
throw new Error(`Cannot find the outlet ${route.outlet} to load '${componentName}'`);
}
}
return outlet;
}