Fork abort-controller to react-native repo

Author: retyui

packages/react-native/Libraries/Core/setUpXHR.js

@@ -36,9 +36,10 @@ polyfillGlobal('URL', () => require('../Blob/URL').URL);
 polyfillGlobal('URLSearchParams', () => require('../Blob/URL').URLSearchParams);
 polyfillGlobal(
   'AbortController',
-  () => require('abort-controller/dist/abort-controller').AbortController, // flowlint-line untyped-import:off
+  () => require('../../src/private/webapis/dom/abort-api/AbortController').AbortController, // flowlint-line untyped-import:off
 );
 polyfillGlobal(
   'AbortSignal',
-  () => require('abort-controller/dist/abort-controller').AbortSignal, // flowlint-line untyped-import:off
+  () =>
+    require('../../src/private/webapis/dom/abort-api/AbortSignal').AbortSignal, // flowlint-line untyped-import:off
 );

packages/react-native/src/private/webapis/dom/abort-api/AbortController.js

@@ -0,0 +1,69 @@
+/**
+ * @flow strict
+ * @format
+ */
+import {AbortSignal, abortSignal, createAbortSignal} from './AbortSignal';
+
+/**
+ * The AbortController.
+ * @see https://dom.spec.whatwg.org/#abortcontroller
+ */
+export class AbortController {
+  /**
+   * Initialize this controller.
+   */
+  constructor() {
+    signals.set(this, createAbortSignal());
+  }
+
+  /**
+   * Returns the `AbortSignal` object associated with this object.
+   */
+  // $FlowExpectedError[unsafe-getters-setters]
+  get signal(): AbortSignal {
+    return getSignal(this);
+  }
+
+  /**
+   * Abort and signal to any observers that the associated activity is to be aborted.
+   */
+  abort(): void {
+    abortSignal(getSignal(this));
+  }
+}
+
+/**
+ * Associated signals.
+ */
+const signals = new WeakMap<AbortController, AbortSignal>()
+
+/**
+ * Get the associated signal of a given controller.
+ */
+function getSignal(controller: AbortController): AbortSignal {
+  const signal = signals.get(controller)
+  if (signal == null) {
+    throw new TypeError(
+      `Expected 'this' to be an 'AbortController' object, but got ${
+        // $FlowExpectedError[invalid-compare]
+        controller === null ? 'null' : typeof controller
+      }`,
+    );
+  }
+  return signal
+}
+
+// Properties should be enumerable.
+//$FlowExpectedError[cannot-write]
+Object.defineProperties(AbortController.prototype, {
+  signal: { enumerable: true },
+  abort: { enumerable: true },
+})
+
+if (typeof Symbol === "function" && typeof Symbol.toStringTag === "symbol") {
+  //$FlowExpectedError[cannot-write]
+  Object.defineProperty(AbortController.prototype, Symbol.toStringTag, {
+    configurable: true,
+    value: 'AbortController',
+  });
+}

packages/react-native/src/private/webapis/dom/abort-api/AbortSignal.js

@@ -0,0 +1,114 @@
+/**
+ * @flow strict
+ * @format
+ */
+import Event from '../events/Event';
+import EventTarget from '../events/EventTarget'
+
+
+
+/**
+ * The signal class.
+ * @see https://dom.spec.whatwg.org/#abortsignal
+ */
+export class AbortSignal extends EventTarget {
+  /**
+   * AbortSignal cannot be constructed directly.
+   */
+  constructor() {
+    super();
+    throw new TypeError('AbortSignal cannot be constructed directly');
+  }
+
+  /**
+   * Returns `true` if this `AbortSignal`'s `AbortController` has signaled to abort, and `false` otherwise.
+   */
+  // $FlowExpectedError[unsafe-getters-setters]
+  get aborted(): boolean {
+    const aborted = abortedFlags.get(this);
+    if (typeof aborted !== 'boolean') {
+      throw new TypeError(
+        `Expected 'this' to be an 'AbortSignal' object, but got ${
+          // $FlowExpectedError[invalid-compare]
+          this === null ? 'null' : typeof this
+        }`,
+      );
+    }
+    return aborted;
+  }
+}
+
+const listeners = new WeakMap<AbortSignal, (()=> void)>();
+Object.defineProperty(AbortSignal.prototype, `onabort`, {
+  enumerable: true,
+  configurable: true,
+  get() {
+    // $FlowExpectedError[object-this-reference]
+    return listeners.get(this) || null;
+  },
+  // $FlowExpectedError[missing-local-annot]
+  set(value) {
+    // $FlowExpectedError[object-this-reference]
+    const currentListener = listeners.get(this);
+    if (currentListener === value) return; // same handler? do nothing!
+    if (currentListener) {
+      // Before setting a new listener, remove the old one if exists
+      // $FlowExpectedError[object-this-reference]
+      this.removeEventListener('abort', currentListener);
+    }
+    if (typeof value === 'function') {
+      // $FlowExpectedError[object-this-reference]
+      listeners.set(this, value);
+      // $FlowExpectedError[object-this-reference]
+      this.addEventListener('abort', value);
+    } else {
+      // $FlowExpectedError[object-this-reference]
+      listeners.delete(this);
+    }
+  },
+});
+
+
+/**
+ * Create an AbortSignal object.
+ */
+export function createAbortSignal(): AbortSignal {
+  const signal = Object.create(AbortSignal.prototype);
+  // $FlowExpectedError[incompatible-type]
+  EventTarget.call(signal);
+  abortedFlags.set(signal, false);
+  return signal;
+}
+
+/**
+ * Abort a given signal.
+ */
+export function abortSignal(signal: AbortSignal): void {
+  if (abortedFlags.get(signal) !== false) {
+    return;
+  }
+
+  abortedFlags.set(signal, true);
+  // $FlowExpectedError[incompatible-type]
+  signal.dispatchEvent(new Event('abort'));
+}
+
+/**
+ * Aborted flag for each instances.
+ */
+const abortedFlags = new WeakMap<AbortSignal, boolean>()
+
+// Properties should be enumerable.
+//$FlowExpectedError[cannot-write]
+Object.defineProperties(AbortSignal.prototype, {
+  aborted: {enumerable: true},
+});
+
+
+// `toString()` should return `"[object AbortSignal]"`
+if (typeof Symbol === "function" && typeof Symbol.toStringTag === "symbol") {
+  Object.defineProperty(AbortSignal.prototype, Symbol.toStringTag, {
+    configurable: true,
+    value: "AbortSignal",
+  })
+}