packages/core/test/resource/chain_spec.ts - main - githubmirror/angular

packages/core/test/resource/chain_spec.ts
98 строк3 KB
Miles Malerba
feat(core): add special return statuses for resource params
02 мар 2026, 19:47
02 мар 2026, 19:472206efa
/**
 * @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 {
  Injector,
  ResourceDependencyError,
  resourceFromSnapshots,
  ResourceParamsStatus,
  signal,
  type ResourceSnapshot,
} from '@angular/core';
import {TestBed} from '@angular/core/testing';
import {timeout} from '@angular/private/testing';
import {paramsContext, resource} from '../../src/resource/resource';

describe('chain', () => {
  it('should throw idle if resource is idle', () => {
    const state = signal<ResourceSnapshot<number>>({status: 'idle', value: 0});
    const res = resourceFromSnapshots(state);
    expect(() => paramsContext.chain(res)).toThrow(ResourceParamsStatus.IDLE);
  });

  it('should throw loading if resource is loading', () => {
    const state = signal<ResourceSnapshot<number>>({status: 'loading', value: 0});
    const res = resourceFromSnapshots(state);
    expect(() => paramsContext.chain(res)).toThrow(ResourceParamsStatus.LOADING);
  });

  it('should throw loading if resource is reloading', () => {
    const state = signal<ResourceSnapshot<number>>({status: 'reloading', value: 2});
    const res = resourceFromSnapshots(state);
    expect(() => paramsContext.chain(res)).toThrow(ResourceParamsStatus.LOADING);
  });

  it('should throw dependency error if resource is error', () => {
    const state = signal<ResourceSnapshot<number>>({status: 'error', error: new Error('fail')});
    const res = resourceFromSnapshots(state);
    expect(() => paramsContext.chain(res)).toThrow(jasmine.any(ResourceDependencyError));
  });

  it('should return value when resolved', () => {
    const state = signal<ResourceSnapshot<number>>({status: 'resolved', value: 2});
    const res = resourceFromSnapshots(state);
    expect(paramsContext.chain(res)).toEqual(2);
  });

  it('should chain resources together', async () => {
    const state = signal<ResourceSnapshot<number>>({status: 'idle', value: 0});
    const res1 = resourceFromSnapshots(state);
    const loaderSpy = jasmine.createSpy('loader');
    const res2 = resource({
      params: () => paramsContext.chain(res1) * 2,
      loader: async ({params}) => {
        loaderSpy();
        return params;
      },
      injector: TestBed.inject(Injector),
    });

    // Idle because res1 is idle
    expect(res2.status()).toBe('idle');
    expect(loaderSpy).not.toHaveBeenCalled();

    state.set({status: 'loading', value: 0});
    TestBed.tick();

    // Loading because res1 is loading, res2 loader not run yet.
    expect(res2.status()).toBe('loading');
    expect(loaderSpy).not.toHaveBeenCalled();

    state.set({status: 'resolved', value: 2});
    TestBed.tick();

    // Loading because res2 loader is running.
    expect(res2.status()).toBe('loading');
    expect(loaderSpy).toHaveBeenCalled();

    await timeout();

    // Resolved.
    expect(res2.status()).toBe('resolved');
    expect(res2.value()).toBe(4);

    const error = Error('fail');
    state.set({status: 'error', error});
    TestBed.tick();

    // Error due to error in res1.
    expect(res2.status()).toBe('error');
    expect(res2.error()).toBeInstanceOf(ResourceDependencyError);
    expect(res2.error()?.cause).toBe(error);
  });
});