packages/zone.js/lib/common/fetch.ts - main - githubmirror/angular

packages/zone.js/lib/common/fetch.ts
144 строки5 KB
arturovt
fix(zone.js): remove `abort` listener once fetch is settled (#57882)
07 окт 2024, 18:27
07 окт 2024, 18:276976349
/**
 * @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
 */
/**
 * @fileoverview
 * @suppress {missingRequire}
 */

import {ZoneType} from '../zone-impl';

export function patchFetch(Zone: ZoneType): void {
  Zone.__load_patch('fetch', (global: any, Zone: ZoneType, api: _ZonePrivate) => {
    interface FetchTaskData extends TaskData {
      fetchArgs?: any[];
    }
    let fetch = global['fetch'];
    if (typeof fetch !== 'function') {
      return;
    }
    const originalFetch = global[api.symbol('fetch')];
    if (originalFetch) {
      // restore unpatched fetch first
      fetch = originalFetch;
    }
    const ZoneAwarePromise = global.Promise;
    const symbolThenPatched = api.symbol('thenPatched');
    const fetchTaskScheduling = api.symbol('fetchTaskScheduling');
    const OriginalResponse = global.Response;
    const placeholder = function () {};

    const createFetchTask = (
      source: string,
      data: TaskData | undefined,
      originalImpl: any,
      self: any,
      args: any[],
      ac?: AbortController,
    ) =>
      new Promise((resolve, reject) => {
        const task = Zone.current.scheduleMacroTask(
          source,
          placeholder,
          data,
          () => {
            // The promise object returned by the original implementation passed into the
            // function. This might be a `fetch` promise, `Response.prototype.json` promise,
            // etc.
            let implPromise;
            let zone = Zone.current;

            try {
              (zone as any)[fetchTaskScheduling] = true;
              implPromise = originalImpl.apply(self, args);
            } catch (error) {
              reject(error);
              return;
            } finally {
              (zone as any)[fetchTaskScheduling] = false;
            }

            if (!(implPromise instanceof ZoneAwarePromise)) {
              let ctor = implPromise.constructor;
              if (!ctor[symbolThenPatched]) {
                api.patchThen(ctor);
              }
            }

            implPromise.then(
              (resource: any) => {
                if (task.state !== 'notScheduled') {
                  task.invoke();
                }
                resolve(resource);
              },
              (error: any) => {
                if (task.state !== 'notScheduled') {
                  task.invoke();
                }
                reject(error);
              },
            );
          },
          () => {
            ac?.abort();
          },
        );
      });

    global['fetch'] = function () {
      const args = Array.prototype.slice.call(arguments);
      const options = args.length > 1 ? args[1] : {};
      const signal: AbortSignal | undefined = options?.signal;
      const ac = new AbortController();
      const fetchSignal = ac.signal;
      options.signal = fetchSignal;
      args[1] = options;

      let onAbort: () => void;
      if (signal) {
        const nativeAddEventListener =
          signal[Zone.__symbol__('addEventListener') as 'addEventListener'] ||
          signal.addEventListener;

        onAbort = () => ac!.abort();
        nativeAddEventListener.call(signal, 'abort', onAbort, {once: true});
      }

      return createFetchTask(
        'fetch',
        {fetchArgs: args} as FetchTaskData,
        fetch,
        this,
        args,
        ac,
      ).finally(() => {
        // We need to be good citizens and remove the `abort` listener once
        // the fetch is settled. The `abort` listener may not be called at all,
        // which means the event listener closure would retain a reference to
        // the `ac` object even if it goes out of scope. Since browser's garbage
        // collectors work differently, some may not be smart enough to collect a signal.
        signal?.removeEventListener('abort', onAbort);
      });
    };

    if (OriginalResponse?.prototype) {
      // https://fetch.spec.whatwg.org/#body-mixin
      ['arrayBuffer', 'blob', 'formData', 'json', 'text']
        // Safely check whether the method exists on the `Response` prototype before patching.
        .filter((method) => typeof OriginalResponse.prototype[method] === 'function')
        .forEach((method) => {
          api.patchMethod(
            OriginalResponse.prototype,
            method,
            (delegate: Function) => (self, args) =>
              createFetchTask(`Response.${method}`, undefined, delegate, self, args, undefined),
          );
        });
    }
  });
}