refactor(router): get guards only one time and simplify guard operator signature (#26239)

PR Close #26239

packages/router/src/operators/check_guards.ts

@@ -12,28 +12,27 @@ import {concatMap, every, first, map, mergeMap} from 'rxjs/operators';
 
 import {ActivationStart, ChildActivationStart, Event} from '../events';
 import {NavigationTransition} from '../router';
-import {ChildrenOutletContexts} from '../router_outlet_context';
 import {ActivatedRouteSnapshot, RouterStateSnapshot} from '../router_state';
 import {andObservables, wrapIntoObservable} from '../utils/collection';
-import {CanActivate, CanDeactivate, Checks, getAllRouteGuards, getCanActivateChild, getToken} from '../utils/preactivation';
+import {CanActivate, CanDeactivate, getCanActivateChild, getToken} from '../utils/preactivation';
 
-export function checkGuards(
+export function checkGuards(moduleInjector: Injector, forwardEvent?: (evt: Event) => void):
-    rootContexts: ChildrenOutletContexts, moduleInjector: Injector,
+    MonoTypeOperatorFunction<NavigationTransition> {
-    forwardEvent?: (evt: Event) => void): MonoTypeOperatorFunction<NavigationTransition> {
   return function(source: Observable<NavigationTransition>) {
 
     return source.pipe(mergeMap(t => {
-      const {targetSnapshot, currentSnapshot} = t;
+      const {targetSnapshot, currentSnapshot, guards: {canActivateChecks, canDeactivateChecks}} = t;
-      const checks = getAllRouteGuards(targetSnapshot !, currentSnapshot, rootContexts);
+      if (canDeactivateChecks.length === 0 && canActivateChecks.length === 0) {
-      if (checks.canDeactivateChecks.length === 0 && checks.canActivateChecks.length === 0) {
         return of ({...t, guardsResult: true});
       }
 
-      return runCanDeactivateChecks(checks, targetSnapshot !, currentSnapshot, moduleInjector)
+      return runCanDeactivateChecks(
+                 canDeactivateChecks, targetSnapshot !, currentSnapshot, moduleInjector)
           .pipe(
               mergeMap((canDeactivate: boolean) => {
                 return canDeactivate ?
-                    runCanActivateChecks(targetSnapshot !, checks, moduleInjector, forwardEvent) :
+                    runCanActivateChecks(
+                        targetSnapshot !, canActivateChecks, moduleInjector, forwardEvent) :
                     of (false);
               }),
               map(guardsResult => ({...t, guardsResult})));
@@ -42,21 +41,19 @@ export function checkGuards(
 }
 
 function runCanDeactivateChecks(
-    checks: Checks, futureRSS: RouterStateSnapshot, currRSS: RouterStateSnapshot,
+    checks: CanDeactivate[], futureRSS: RouterStateSnapshot, currRSS: RouterStateSnapshot,
     moduleInjector: Injector): Observable<boolean> {
-  return from(checks.canDeactivateChecks)
+  return from(checks).pipe(
-      .pipe(
       mergeMap(
-              (check: CanDeactivate) => runCanDeactivate(
+          (check: CanDeactivate) =>
-                  check.component, check.route, currRSS, futureRSS, moduleInjector)),
+              runCanDeactivate(check.component, check.route, currRSS, futureRSS, moduleInjector)),
       every((result: boolean) => result === true));
 }
 
 function runCanActivateChecks(
-    futureSnapshot: RouterStateSnapshot, checks: Checks, moduleInjector: Injector,
+    futureSnapshot: RouterStateSnapshot, checks: CanActivate[], moduleInjector: Injector,
     forwardEvent?: (evt: Event) => void): Observable<boolean> {
-  return from(checks.canActivateChecks)
+  return from(checks).pipe(
-      .pipe(
       concatMap((check: CanActivate) => andObservables(from([
                   fireChildActivationStart(check.route.parent, forwardEvent),
                   fireActivationStart(check.route, forwardEvent),

packages/router/src/operators/resolve_data.ts

@@ -12,25 +12,23 @@ import {concatMap, last, map, mergeMap, reduce} from 'rxjs/operators';
 
 import {ResolveData} from '../config';
 import {NavigationTransition} from '../router';
-import {ChildrenOutletContexts} from '../router_outlet_context';
 import {ActivatedRouteSnapshot, RouterStateSnapshot, inheritedParamsDataResolve} from '../router_state';
 import {wrapIntoObservable} from '../utils/collection';
 
-import {getAllRouteGuards, getToken} from '../utils/preactivation';
+import {getToken} from '../utils/preactivation';
 
 export function resolveData(
-    rootContexts: ChildrenOutletContexts, paramsInheritanceStrategy: 'emptyOnly' | 'always',
+    paramsInheritanceStrategy: 'emptyOnly' | 'always',
     moduleInjector: Injector): MonoTypeOperatorFunction<NavigationTransition> {
   return function(source: Observable<NavigationTransition>) {
     return source.pipe(mergeMap(t => {
-      const {targetSnapshot, currentSnapshot} = t;
+      const {targetSnapshot, guards: {canActivateChecks}} = t;
-      const checks = getAllRouteGuards(targetSnapshot !, currentSnapshot, rootContexts);
 
-      if (!checks.canActivateChecks.length) {
+      if (!canActivateChecks.length) {
         return of (t);
       }
 
-      return from(checks.canActivateChecks)
+      return from(canActivateChecks)
           .pipe(
               concatMap(
                   check => runResolve(

packages/router/src/router.ts

@@ -28,7 +28,7 @@ import {ActivatedRoute, RouterState, RouterStateSnapshot, createEmptyState} from
 import {Params, isNavigationCancelingError} from './shared';
 import {DefaultUrlHandlingStrategy, UrlHandlingStrategy} from './url_handling_strategy';
 import {UrlSerializer, UrlTree, containsTree, createEmptyUrlTree} from './url_tree';
-import {getAllRouteGuards} from './utils/preactivation';
+import {Checks, getAllRouteGuards} from './utils/preactivation';
 
 
 
@@ -185,6 +185,7 @@ export type NavigationTransition = {
   targetSnapshot: RouterStateSnapshot | null,
   currentRouterState: RouterState,
   targetRouterState: RouterState | null,
+  guards: Checks,
   guardsResult: boolean | null,
 };
 
@@ -354,6 +355,7 @@ export class Router {
       targetSnapshot: null,
       currentRouterState: this.routerState,
       targetRouterState: null,
+      guards: {canActivateChecks: [], canDeactivateChecks: []},
       guardsResult: null,
     });
     this.navigations = this.setupNavigations(this.transitions);
@@ -478,9 +480,13 @@ export class Router {
                 this.triggerEvent(guardsStart);
               }),
 
-              checkGuards(
+              map(t => ({
-                  this.rootContexts, this.ngModule.injector,
+                    ...t,
-                  (evt: Event) => this.triggerEvent(evt)),
+                    guards:
+                        getAllRouteGuards(t.targetSnapshot !, t.currentSnapshot, this.rootContexts)
+                  })),
+
+              checkGuards(this.ngModule.injector, (evt: Event) => this.triggerEvent(evt)),
 
               tap(t => {
                 const guardsEnd = new GuardsCheckEnd(
@@ -503,8 +509,7 @@ export class Router {
 
               // --- RESOLVE ---
               switchTap(t => {
-                if (getAllRouteGuards(t.targetSnapshot !, t.currentSnapshot, this.rootContexts)
+                if (t.guards.canActivateChecks.length) {
-                        .canActivateChecks.length) {
                   return of (t).pipe(
                       tap(t => {
                         const resolveStart = new ResolveStart(
@@ -513,7 +518,7 @@ export class Router {
                         this.triggerEvent(resolveStart);
                       }),
                       resolveData(
-                          this.rootContexts, this.paramsInheritanceStrategy,
+                          this.paramsInheritanceStrategy,
                           this.ngModule.injector),  //
                       tap(t => {
                         const resolveEnd = new ResolveEnd(

packages/router/test/router.spec.ts

@@ -18,6 +18,7 @@ import {NavigationTransition, Router} from '../src/router';
 import {ChildrenOutletContexts} from '../src/router_outlet_context';
 import {RouterStateSnapshot, createEmptyStateSnapshot} from '../src/router_state';
 import {DefaultUrlSerializer} from '../src/url_tree';
+import {getAllRouteGuards} from '../src/utils/preactivation';
 import {TreeNode} from '../src/utils/tree';
 import {RouterTestingModule} from '../testing/src/router_testing_module';
 
@@ -143,9 +144,8 @@ describe('Router', () => {
         const futureState = new (RouterStateSnapshot as any)(
             'url', new TreeNode(empty.root, [new TreeNode(childSnapshot, [])]));
 
-        of ({targetSnapshot: futureState, currentSnapshot: empty})
+        of ({guards: getAllRouteGuards(futureState, empty, new ChildrenOutletContexts())})
-            .pipe(checkGuardsOperator(
+            .pipe(checkGuardsOperator(TestBed, (evt) => { events.push(evt); }))
-                new ChildrenOutletContexts(), TestBed, (evt) => { events.push(evt); }))
             .subscribe((x) => result = !!x.guardsResult, (e) => { throw e; });
 
         expect(result).toBe(true);
@@ -178,9 +178,8 @@ describe('Router', () => {
                   new TreeNode(grandchildSnapshot, [new TreeNode(greatGrandchildSnapshot, [])])
                 ])]));
 
-        of ({targetSnapshot: futureState, currentSnapshot: empty})
+        of ({guards: getAllRouteGuards(futureState, empty, new ChildrenOutletContexts())})
-            .pipe(checkGuardsOperator(
+            .pipe(checkGuardsOperator(TestBed, (evt) => { events.push(evt); }))
-                new ChildrenOutletContexts(), TestBed, (evt) => { events.push(evt); }))
             .subscribe((x) => result = !!x.guardsResult, (e) => { throw e; });
 
         expect(result).toBe(true);
@@ -211,9 +210,8 @@ describe('Router', () => {
             new TreeNode(
                 empty.root, [new TreeNode(childSnapshot, [new TreeNode(grandchildSnapshot, [])])]));
 
-        of ({targetSnapshot: futureState, currentSnapshot: currentState})
+        of ({guards: getAllRouteGuards(futureState, currentState, new ChildrenOutletContexts())})
-            .pipe(checkGuardsOperator(
+            .pipe(checkGuardsOperator(TestBed, (evt) => { events.push(evt); }))
-                new ChildrenOutletContexts(), TestBed, (evt) => { events.push(evt); }))
             .subscribe((x) => result = !!x.guardsResult, (e) => { throw e; });
 
         expect(result).toBe(true);
@@ -257,9 +255,8 @@ describe('Router', () => {
                           greatGrandchildSnapshot, [new TreeNode(greatGreatGrandchildSnapshot, [])])
                     ])])]));
 
-        of ({targetSnapshot: futureState, currentSnapshot: currentState})
+        of ({guards: getAllRouteGuards(futureState, currentState, new ChildrenOutletContexts())})
-            .pipe(checkGuardsOperator(
+            .pipe(checkGuardsOperator(TestBed, (evt) => { events.push(evt); }))
-                new ChildrenOutletContexts(), TestBed, (evt) => { events.push(evt); }))
             .subscribe((x) => result = !!x.guardsResult, (e) => { throw e; });
 
         expect(result).toBe(true);
@@ -538,15 +535,19 @@ describe('Router', () => {
 
 function checkResolveData(
     future: RouterStateSnapshot, curr: RouterStateSnapshot, injector: any, check: any): void {
-  of ({ targetSnapshot: future, currentSnapshot: curr } as Partial<NavigationTransition>)
+  of ({
-      .pipe(resolveDataOperator(new ChildrenOutletContexts(), 'emptyOnly', injector))
+    guards: getAllRouteGuards(future, curr, new ChildrenOutletContexts())
+  } as Partial<NavigationTransition>)
+      .pipe(resolveDataOperator('emptyOnly', injector))
       .subscribe(check, (e) => { throw e; });
 }
 
 function checkGuards(
     future: RouterStateSnapshot, curr: RouterStateSnapshot, injector: any,
     check: (result: boolean) => void): void {
-  of ({ targetSnapshot: future, currentSnapshot: curr } as Partial<NavigationTransition>)
+  of ({
-      .pipe(checkGuardsOperator(new ChildrenOutletContexts(), injector))
+    guards: getAllRouteGuards(future, curr, new ChildrenOutletContexts())
+  } as Partial<NavigationTransition>)
+      .pipe(checkGuardsOperator(injector))
       .subscribe(t => check(!!t.guardsResult), (e) => { throw e; });
 }