packages/angular_devkit/schematics/src/rules/base_spec.ts - main - githubmirror/angular-cli

packages/angular_devkit/schematics/src/rules/base_spec.ts
231 строка7 KB
Kristiyan Kostadinov
build: update to TypeScript 6
04 мар 2026, 16:11
04 мар 2026, 16:111d7fceb
/**
 * @license
 * Copyright Google LLC 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.dev/license
 */

import { Path, virtualFs } from '@angular-devkit/core';
import { lastValueFrom, of as observableOf } from 'rxjs';
import { Rule, SchematicContext, Source } from '../engine/interface';
import { HostTree } from '../tree/host-tree';
import { MergeStrategy, Tree } from '../tree/interface';
import { empty } from '../tree/static';
import { apply, applyToSubtree, chain, partitionApplyMerge } from './base';
import { callRule, callSource } from './call';
import { move } from './move';

const context: SchematicContext = {
  engine: null,
  debug: false,
  strategy: MergeStrategy.Default,
} as {} as SchematicContext;

describe('chain', () => {
  it('works with simple rules', async () => {
    const rulesCalled: Tree[] = [];

    const tree0 = empty();
    const tree1 = empty();
    const tree2 = empty();
    const tree3 = empty();

    const rule0: Rule = (tree: Tree) => ((rulesCalled[0] = tree), tree1);
    const rule1: Rule = (tree: Tree) => ((rulesCalled[1] = tree), tree2);
    const rule2: Rule = (tree: Tree) => ((rulesCalled[2] = tree), tree3);

    const result = await lastValueFrom(
      callRule(chain([rule0, rule1, rule2]), observableOf(tree0), context),
    );
    expect(result).not.toBe(tree0);
    expect(rulesCalled[0]).toBe(tree0);
    expect(rulesCalled[1]).toBe(tree1);
    expect(rulesCalled[2]).toBe(tree2);
    expect(result).toBe(tree3);
  });

  it('works with async rules', async () => {
    const rulesCalled: Tree[] = [];

    const tree0 = empty();
    const tree1 = empty();
    const tree2 = empty();
    const tree3 = empty();

    const rule0: Rule = async (tree: Tree) => ((rulesCalled[0] = tree), tree1);
    const rule1: Rule = async (tree: Tree) => ((rulesCalled[1] = tree), tree2);
    const rule2: Rule = async (tree: Tree) => ((rulesCalled[2] = tree), tree3);

    const result = await lastValueFrom(callRule(chain([rule0, rule1, rule2]), tree0, context));
    expect(result).not.toBe(tree0);
    expect(rulesCalled[0]).toBe(tree0);
    expect(rulesCalled[1]).toBe(tree1);
    expect(rulesCalled[2]).toBe(tree2);
    expect(result).toBe(tree3);
  });

  it('works with a sync generator of rules', async () => {
    const rulesCalled: Tree[] = [];

    const tree0 = empty();
    const tree1 = empty();
    const tree2 = empty();
    const tree3 = empty();

    const rule0: Rule = (tree: Tree) => ((rulesCalled[0] = tree), tree1);
    const rule1: Rule = (tree: Tree) => ((rulesCalled[1] = tree), tree2);
    const rule2: Rule = (tree: Tree) => ((rulesCalled[2] = tree), tree3);

    function* generateRules() {
      yield rule0;
      yield rule1;
      yield rule2;
    }

    const result = await lastValueFrom(callRule(chain(generateRules()), tree0, context));

    expect(result).not.toBe(tree0);
    expect(rulesCalled[0]).toBe(tree0);
    expect(rulesCalled[1]).toBe(tree1);
    expect(rulesCalled[2]).toBe(tree2);
    expect(result).toBe(tree3);
  });

  it('works with an async generator of rules', async () => {
    const rulesCalled: Tree[] = [];

    const tree0 = empty();
    const tree1 = empty();
    const tree2 = empty();
    const tree3 = empty();

    const rule0: Rule = (tree: Tree) => ((rulesCalled[0] = tree), tree1);
    const rule1: Rule = (tree: Tree) => ((rulesCalled[1] = tree), tree2);
    const rule2: Rule = (tree: Tree) => ((rulesCalled[2] = tree), tree3);

    async function* generateRules() {
      yield rule0;
      yield rule1;
      yield rule2;
    }

    const result = await lastValueFrom(callRule(chain(generateRules()), tree0, context));

    expect(result).not.toBe(tree0);
    expect(rulesCalled[0]).toBe(tree0);
    expect(rulesCalled[1]).toBe(tree1);
    expect(rulesCalled[2]).toBe(tree2);
    expect(result).toBe(tree3);
  });

  it('works with observable rules', async () => {
    const rulesCalled: Tree[] = [];

    const tree0 = empty();
    const tree1 = empty();
    const tree2 = empty();
    const tree3 = empty();

    const rule0: Rule = (tree: Tree) => ((rulesCalled[0] = tree), observableOf(tree1));
    const rule1: Rule = (tree: Tree) => ((rulesCalled[1] = tree), observableOf(tree2));
    const rule2: Rule = (tree: Tree) => ((rulesCalled[2] = tree), tree3);

    const result = await lastValueFrom(
      callRule(chain([rule0, rule1, rule2]), observableOf(tree0), context),
    );
    expect(result).not.toBe(tree0);
    expect(rulesCalled[0]).toBe(tree0);
    expect(rulesCalled[1]).toBe(tree1);
    expect(rulesCalled[2]).toBe(tree2);
    expect(result).toBe(tree3);
  });
});

describe('apply', () => {
  it('works with simple rules', async () => {
    const rulesCalled: Tree[] = [];
    const tree0 = empty();
    const tree1 = empty();
    const tree2 = empty();
    const tree3 = empty();

    const source: Source = () => tree0;
    const rule0: Rule = (tree: Tree) => ((rulesCalled[0] = tree), tree1);
    const rule1: Rule = (tree: Tree) => ((rulesCalled[1] = tree), tree2);
    const rule2: Rule = (tree: Tree) => ((rulesCalled[2] = tree), tree3);

    const result = await lastValueFrom(callSource(apply(source, [rule0, rule1, rule2]), context));
    expect(result).not.toBe(tree0);
    expect(rulesCalled[0]).toBe(tree0);
    expect(rulesCalled[1]).toBe(tree1);
    expect(rulesCalled[2]).toBe(tree2);
    expect(result).toBe(tree3);
  });

  it('works with observable rules', async () => {
    const rulesCalled: Tree[] = [];
    const tree0 = empty();
    const tree1 = empty();
    const tree2 = empty();
    const tree3 = empty();

    const source: Source = () => tree0;
    const rule0: Rule = (tree: Tree) => ((rulesCalled[0] = tree), observableOf(tree1));
    const rule1: Rule = (tree: Tree) => ((rulesCalled[1] = tree), observableOf(tree2));
    const rule2: Rule = (tree: Tree) => ((rulesCalled[2] = tree), tree3);

    const result = await lastValueFrom(callSource(apply(source, [rule0, rule1, rule2]), context));
    expect(result).not.toBe(tree0);
    expect(rulesCalled[0]).toBe(tree0);
    expect(rulesCalled[1]).toBe(tree1);
    expect(rulesCalled[2]).toBe(tree2);
    expect(result).toBe(tree3);
  });
});

describe('partitionApplyMerge', () => {
  it('works with simple rules', async () => {
    const host = new virtualFs.test.TestHost({
      '/test1': '',
      '/test2': '',
    });
    const tree = new HostTree(host);
    const predicate = (path: Path) => path.indexOf('1') != -1;

    const ruleYes: Rule = (tree: Tree) => {
      expect(tree.exists('/test1')).toBe(true);
      expect(tree.exists('/test2')).toBe(false);

      return empty();
    };
    const ruleNo: Rule = (tree: Tree) => {
      expect(tree.exists('/test1')).toBe(false);
      expect(tree.exists('/test2')).toBe(true);

      return empty();
    };

    const result = await lastValueFrom(
      callRule(partitionApplyMerge(predicate, ruleYes, ruleNo), observableOf(tree), context),
    );
    expect(result.exists('/test1')).toBe(false);
    expect(result.exists('/test2')).toBe(false);
  });
});

describe('applyToSubtree', () => {
  it('works', async () => {
    const tree = new HostTree();
    tree.create('a/b/file1', 'hello world');
    tree.create('a/b/file2', 'hello world');
    tree.create('a/c/file3', 'hello world');

    const result = await lastValueFrom(
      callRule(applyToSubtree('a/b', [move('x')]), observableOf(tree), context),
    );
    expect(result.exists('a/b/x/file1')).toBe(true);
    expect(result.exists('a/b/x/file2')).toBe(true);
    expect(result.exists('a/c/file3')).toBe(true);
  });
});