Merge pull request #18933 from Snuffleupagus/base-factory-fetchData

Change the `BaseCMapReaderFactory` fetch-helper to return a `Uint8Array`

src/display/base_factory.js

@@ -127,22 +127,27 @@ class BaseCMapReaderFactory {
       throw new Error("CMap name must be specified.");
     }
     const url = this.baseUrl + name + (this.isCompressed ? ".bcmap" : "");
-    const compressionType = this.isCompressed
-      ? CMapCompressionType.BINARY
-      : CMapCompressionType.NONE;
 
-    return this._fetchData(url, compressionType).catch(reason => {
+    return this._fetch(url)
-      throw new Error(
+      .then(cMapData => ({
-        `Unable to load ${this.isCompressed ? "binary " : ""}CMap at: ${url}`
+        cMapData,
-      );
+        compressionType: this.isCompressed
-    });
+          ? CMapCompressionType.BINARY
+          : CMapCompressionType.NONE,
+      }))
+      .catch(reason => {
+        throw new Error(
+          `Unable to load ${this.isCompressed ? "binary " : ""}CMap at: ${url}`
+        );
+      });
   }
 
   /**
    * @ignore
+   * @returns {Promise<Uint8Array>}
    */
-  _fetchData(url, compressionType) {
+  async _fetch(url) {
-    unreachable("Abstract method `_fetchData` called.");
+    unreachable("Abstract method `_fetch` called.");
   }
 }
 
@@ -168,16 +173,17 @@ class BaseStandardFontDataFactory {
     }
     const url = `${this.baseUrl}${filename}`;
 
-    return this._fetchData(url).catch(reason => {
+    return this._fetch(url).catch(reason => {
       throw new Error(`Unable to load font data at: ${url}`);
     });
   }
 
   /**
    * @ignore
+   * @returns {Promise<Uint8Array>}
    */
-  _fetchData(url) {
+  async _fetch(url) {
-    unreachable("Abstract method `_fetchData` called.");
+    unreachable("Abstract method `_fetch` called.");
   }
 }
 

src/display/display_utils.js

@@ -564,17 +564,14 @@ class DOMCMapReaderFactory extends BaseCMapReaderFactory {
   /**
    * @ignore
    */
-  _fetchData(url, compressionType) {
+  async _fetch(url) {
-    return fetchData(
+    const data = await fetchData(
       url,
       /* type = */ this.isCompressed ? "arraybuffer" : "text"
-    ).then(data => ({
+    );
-      cMapData:
+    return data instanceof ArrayBuffer
-        data instanceof ArrayBuffer
+      ? new Uint8Array(data)
-          ? new Uint8Array(data)
+      : stringToBytes(data);
-          : stringToBytes(data),
-      compressionType,
-    }));
   }
 }
 
@@ -582,10 +579,9 @@ class DOMStandardFontDataFactory extends BaseStandardFontDataFactory {
   /**
    * @ignore
    */
-  _fetchData(url) {
+  async _fetch(url) {
-    return fetchData(url, /* type = */ "arraybuffer").then(
+    const data = await fetchData(url, /* type = */ "arraybuffer");
-      data => new Uint8Array(data)
+    return new Uint8Array(data);
-    );
   }
 }
 

src/display/node_utils.js

@@ -113,10 +113,11 @@ class NodePackages {
   }
 }
 
-const fetchData = function (url) {
+async function fetchData(url) {
   const fs = NodePackages.get("fs");
-  return fs.promises.readFile(url).then(data => new Uint8Array(data));
+  const data = await fs.promises.readFile(url);
-};
+  return new Uint8Array(data);
+}
 
 class NodeFilterFactory extends BaseFilterFactory {}
 
@@ -134,8 +135,8 @@ class NodeCMapReaderFactory extends BaseCMapReaderFactory {
   /**
    * @ignore
    */
-  _fetchData(url, compressionType) {
+  async _fetch(url) {
-    return fetchData(url).then(data => ({ cMapData: data, compressionType }));
+    return fetchData(url);
   }
 }
 
@@ -143,12 +144,13 @@ class NodeStandardFontDataFactory extends BaseStandardFontDataFactory {
   /**
    * @ignore
    */
-  _fetchData(url) {
+  async _fetch(url) {
     return fetchData(url);
   }
 }
 
 export {
+  fetchData,
   NodeCanvasFactory,
   NodeCMapReaderFactory,
   NodeFilterFactory,

test/unit/test_utils.js

@@ -16,6 +16,8 @@
 import { assert, isNodeJS } from "../../src/shared/util.js";
 import { NullStream, StringStream } from "../../src/core/stream.js";
 import { Page, PDFDocument } from "../../src/core/document.js";
+import { fetchData as fetchDataDOM } from "../../src/display/display_utils.js";
+import { fetchData as fetchDataNode } from "../../src/display/node_utils.js";
 import { Ref } from "../../src/core/primitives.js";
 
 let fs, http;
@@ -33,27 +35,16 @@ const STANDARD_FONT_DATA_URL = isNodeJS
   ? "./external/standard_fonts/"
   : "../../external/standard_fonts/";
 
-class DOMFileReaderFactory {
+class DefaultFileReaderFactory {
   static async fetch(params) {
-    const response = await fetch(params.path);
+    if (isNodeJS) {
-    if (!response.ok) {
+      return fetchDataNode(params.path);
-      throw new Error(response.statusText);
     }
-    return new Uint8Array(await response.arrayBuffer());
+    const data = await fetchDataDOM(params.path, /* type = */ "arraybuffer");
-  }
-}
-
-class NodeFileReaderFactory {
-  static async fetch(params) {
-    const data = await fs.promises.readFile(params.path);
     return new Uint8Array(data);
   }
 }
 
-const DefaultFileReaderFactory = isNodeJS
-  ? NodeFileReaderFactory
-  : DOMFileReaderFactory;
-
 function buildGetDocumentParams(filename, options) {
   const params = Object.create(null);
   params.url = isNodeJS