api.js 60 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905
  1. /**
  2. * @licstart The following is the entire license notice for the
  3. * JavaScript code in this page
  4. *
  5. * Copyright 2022 Mozilla Foundation
  6. *
  7. * Licensed under the Apache License, Version 2.0 (the "License");
  8. * you may not use this file except in compliance with the License.
  9. * You may obtain a copy of the License at
  10. *
  11. * http://www.apache.org/licenses/LICENSE-2.0
  12. *
  13. * Unless required by applicable law or agreed to in writing, software
  14. * distributed under the License is distributed on an "AS IS" BASIS,
  15. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16. * See the License for the specific language governing permissions and
  17. * limitations under the License.
  18. *
  19. * @licend The above is the entire license notice for the
  20. * JavaScript code in this page
  21. */
  22. "use strict";
  23. Object.defineProperty(exports, "__esModule", {
  24. value: true
  25. });
  26. exports.build = exports.RenderTask = exports.PDFWorkerUtil = exports.PDFWorker = exports.PDFPageProxy = exports.PDFDocumentProxy = exports.PDFDocumentLoadingTask = exports.PDFDataRangeTransport = exports.LoopbackPort = exports.DefaultStandardFontDataFactory = exports.DefaultCanvasFactory = exports.DefaultCMapReaderFactory = void 0;
  27. exports.getDocument = getDocument;
  28. exports.setPDFNetworkStreamFactory = setPDFNetworkStreamFactory;
  29. exports.version = void 0;
  30. var _util = require("../shared/util.js");
  31. var _annotation_storage = require("./annotation_storage.js");
  32. var _display_utils = require("./display_utils.js");
  33. var _font_loader = require("./font_loader.js");
  34. var _canvas = require("./canvas.js");
  35. var _worker_options = require("./worker_options.js");
  36. var _is_node = require("../shared/is_node.js");
  37. var _message_handler = require("../shared/message_handler.js");
  38. var _metadata = require("./metadata.js");
  39. var _optional_content_config = require("./optional_content_config.js");
  40. var _transport_stream = require("./transport_stream.js");
  41. var _xfa_text = require("./xfa_text.js");
  42. const DEFAULT_RANGE_CHUNK_SIZE = 65536;
  43. const RENDERING_CANCELLED_TIMEOUT = 100;
  44. let DefaultCanvasFactory = _display_utils.DOMCanvasFactory;
  45. exports.DefaultCanvasFactory = DefaultCanvasFactory;
  46. let DefaultCMapReaderFactory = _display_utils.DOMCMapReaderFactory;
  47. exports.DefaultCMapReaderFactory = DefaultCMapReaderFactory;
  48. let DefaultStandardFontDataFactory = _display_utils.DOMStandardFontDataFactory;
  49. exports.DefaultStandardFontDataFactory = DefaultStandardFontDataFactory;
  50. if (_is_node.isNodeJS) {
  51. const {
  52. NodeCanvasFactory,
  53. NodeCMapReaderFactory,
  54. NodeStandardFontDataFactory
  55. } = require("./node_utils.js");
  56. exports.DefaultCanvasFactory = DefaultCanvasFactory = NodeCanvasFactory;
  57. exports.DefaultCMapReaderFactory = DefaultCMapReaderFactory = NodeCMapReaderFactory;
  58. exports.DefaultStandardFontDataFactory = DefaultStandardFontDataFactory = NodeStandardFontDataFactory;
  59. }
  60. let createPDFNetworkStream;
  61. function setPDFNetworkStreamFactory(pdfNetworkStreamFactory) {
  62. createPDFNetworkStream = pdfNetworkStreamFactory;
  63. }
  64. function getDocument(src) {
  65. const task = new PDFDocumentLoadingTask();
  66. let source;
  67. if (typeof src === "string" || src instanceof URL) {
  68. source = {
  69. url: src
  70. };
  71. } else if ((0, _util.isArrayBuffer)(src)) {
  72. source = {
  73. data: src
  74. };
  75. } else if (src instanceof PDFDataRangeTransport) {
  76. source = {
  77. range: src
  78. };
  79. } else {
  80. if (typeof src !== "object") {
  81. throw new Error("Invalid parameter in getDocument, " + "need either string, URL, TypedArray, or parameter object.");
  82. }
  83. if (!src.url && !src.data && !src.range) {
  84. throw new Error("Invalid parameter object: need either .data, .range or .url");
  85. }
  86. source = src;
  87. }
  88. const params = Object.create(null);
  89. let rangeTransport = null,
  90. worker = null;
  91. for (const key in source) {
  92. const value = source[key];
  93. switch (key) {
  94. case "url":
  95. if (typeof window !== "undefined") {
  96. try {
  97. params[key] = new URL(value, window.location).href;
  98. continue;
  99. } catch (ex) {
  100. (0, _util.warn)(`Cannot create valid URL: "${ex}".`);
  101. }
  102. } else if (typeof value === "string" || value instanceof URL) {
  103. params[key] = value.toString();
  104. continue;
  105. }
  106. throw new Error("Invalid PDF url data: " + "either string or URL-object is expected in the url property.");
  107. case "range":
  108. rangeTransport = value;
  109. continue;
  110. case "worker":
  111. worker = value;
  112. continue;
  113. case "data":
  114. if (_is_node.isNodeJS && typeof Buffer !== "undefined" && value instanceof Buffer) {
  115. params[key] = new Uint8Array(value);
  116. } else if (value instanceof Uint8Array) {
  117. break;
  118. } else if (typeof value === "string") {
  119. params[key] = (0, _util.stringToBytes)(value);
  120. } else if (typeof value === "object" && value !== null && !isNaN(value.length)) {
  121. params[key] = new Uint8Array(value);
  122. } else if ((0, _util.isArrayBuffer)(value)) {
  123. params[key] = new Uint8Array(value);
  124. } else {
  125. throw new Error("Invalid PDF binary data: either TypedArray, " + "string, or array-like object is expected in the data property.");
  126. }
  127. continue;
  128. }
  129. params[key] = value;
  130. }
  131. params.CMapReaderFactory = params.CMapReaderFactory || DefaultCMapReaderFactory;
  132. params.StandardFontDataFactory = params.StandardFontDataFactory || DefaultStandardFontDataFactory;
  133. params.ignoreErrors = params.stopAtErrors !== true;
  134. params.fontExtraProperties = params.fontExtraProperties === true;
  135. params.pdfBug = params.pdfBug === true;
  136. params.enableXfa = params.enableXfa === true;
  137. if (!Number.isInteger(params.rangeChunkSize) || params.rangeChunkSize < 1) {
  138. params.rangeChunkSize = DEFAULT_RANGE_CHUNK_SIZE;
  139. }
  140. if (typeof params.docBaseUrl !== "string" || (0, _display_utils.isDataScheme)(params.docBaseUrl)) {
  141. params.docBaseUrl = null;
  142. }
  143. if (!Number.isInteger(params.maxImageSize) || params.maxImageSize < -1) {
  144. params.maxImageSize = -1;
  145. }
  146. if (typeof params.cMapUrl !== "string") {
  147. params.cMapUrl = null;
  148. }
  149. if (typeof params.standardFontDataUrl !== "string") {
  150. params.standardFontDataUrl = null;
  151. }
  152. if (typeof params.useWorkerFetch !== "boolean") {
  153. params.useWorkerFetch = params.CMapReaderFactory === _display_utils.DOMCMapReaderFactory && params.StandardFontDataFactory === _display_utils.DOMStandardFontDataFactory;
  154. }
  155. if (typeof params.isEvalSupported !== "boolean") {
  156. params.isEvalSupported = true;
  157. }
  158. if (typeof params.isOffscreenCanvasSupported !== "boolean") {
  159. params.isOffscreenCanvasSupported = !_is_node.isNodeJS;
  160. }
  161. if (typeof params.disableFontFace !== "boolean") {
  162. params.disableFontFace = _is_node.isNodeJS;
  163. }
  164. if (typeof params.useSystemFonts !== "boolean") {
  165. params.useSystemFonts = !_is_node.isNodeJS && !params.disableFontFace;
  166. }
  167. if (typeof params.ownerDocument !== "object" || params.ownerDocument === null) {
  168. params.ownerDocument = globalThis.document;
  169. }
  170. if (typeof params.disableRange !== "boolean") {
  171. params.disableRange = false;
  172. }
  173. if (typeof params.disableStream !== "boolean") {
  174. params.disableStream = false;
  175. }
  176. if (typeof params.disableAutoFetch !== "boolean") {
  177. params.disableAutoFetch = false;
  178. }
  179. (0, _util.setVerbosityLevel)(params.verbosity);
  180. if (!worker) {
  181. const workerParams = {
  182. verbosity: params.verbosity,
  183. port: _worker_options.GlobalWorkerOptions.workerPort
  184. };
  185. worker = workerParams.port ? PDFWorker.fromPort(workerParams) : new PDFWorker(workerParams);
  186. task._worker = worker;
  187. }
  188. const docId = task.docId;
  189. worker.promise.then(function () {
  190. if (task.destroyed) {
  191. throw new Error("Loading aborted");
  192. }
  193. const workerIdPromise = _fetchDocument(worker, params, rangeTransport, docId);
  194. const networkStreamPromise = new Promise(function (resolve) {
  195. let networkStream;
  196. if (rangeTransport) {
  197. networkStream = new _transport_stream.PDFDataTransportStream({
  198. length: params.length,
  199. initialData: params.initialData,
  200. progressiveDone: params.progressiveDone,
  201. contentDispositionFilename: params.contentDispositionFilename,
  202. disableRange: params.disableRange,
  203. disableStream: params.disableStream
  204. }, rangeTransport);
  205. } else if (!params.data) {
  206. networkStream = createPDFNetworkStream({
  207. url: params.url,
  208. length: params.length,
  209. httpHeaders: params.httpHeaders,
  210. withCredentials: params.withCredentials,
  211. rangeChunkSize: params.rangeChunkSize,
  212. disableRange: params.disableRange,
  213. disableStream: params.disableStream
  214. });
  215. }
  216. resolve(networkStream);
  217. });
  218. return Promise.all([workerIdPromise, networkStreamPromise]).then(function ([workerId, networkStream]) {
  219. if (task.destroyed) {
  220. throw new Error("Loading aborted");
  221. }
  222. const messageHandler = new _message_handler.MessageHandler(docId, workerId, worker.port);
  223. const transport = new WorkerTransport(messageHandler, task, networkStream, params);
  224. task._transport = transport;
  225. messageHandler.send("Ready", null);
  226. });
  227. }).catch(task._capability.reject);
  228. return task;
  229. }
  230. async function _fetchDocument(worker, source, pdfDataRangeTransport, docId) {
  231. if (worker.destroyed) {
  232. throw new Error("Worker was destroyed");
  233. }
  234. if (pdfDataRangeTransport) {
  235. source.length = pdfDataRangeTransport.length;
  236. source.initialData = pdfDataRangeTransport.initialData;
  237. source.progressiveDone = pdfDataRangeTransport.progressiveDone;
  238. source.contentDispositionFilename = pdfDataRangeTransport.contentDispositionFilename;
  239. }
  240. const workerId = await worker.messageHandler.sendWithPromise("GetDocRequest", {
  241. docId,
  242. apiVersion: '3.0.279',
  243. data: source.data,
  244. password: source.password,
  245. disableAutoFetch: source.disableAutoFetch,
  246. rangeChunkSize: source.rangeChunkSize,
  247. length: source.length,
  248. docBaseUrl: source.docBaseUrl,
  249. enableXfa: source.enableXfa,
  250. evaluatorOptions: {
  251. maxImageSize: source.maxImageSize,
  252. disableFontFace: source.disableFontFace,
  253. ignoreErrors: source.ignoreErrors,
  254. isEvalSupported: source.isEvalSupported,
  255. isOffscreenCanvasSupported: source.isOffscreenCanvasSupported,
  256. fontExtraProperties: source.fontExtraProperties,
  257. useSystemFonts: source.useSystemFonts,
  258. cMapUrl: source.useWorkerFetch ? source.cMapUrl : null,
  259. standardFontDataUrl: source.useWorkerFetch ? source.standardFontDataUrl : null
  260. }
  261. });
  262. if (source.data) {
  263. source.data = null;
  264. }
  265. if (worker.destroyed) {
  266. throw new Error("Worker was destroyed");
  267. }
  268. return workerId;
  269. }
  270. class PDFDocumentLoadingTask {
  271. static #docId = 0;
  272. constructor() {
  273. this._capability = (0, _util.createPromiseCapability)();
  274. this._transport = null;
  275. this._worker = null;
  276. this.docId = `d${PDFDocumentLoadingTask.#docId++}`;
  277. this.destroyed = false;
  278. this.onPassword = null;
  279. this.onProgress = null;
  280. this.onUnsupportedFeature = null;
  281. }
  282. get promise() {
  283. return this._capability.promise;
  284. }
  285. async destroy() {
  286. this.destroyed = true;
  287. await this._transport?.destroy();
  288. this._transport = null;
  289. if (this._worker) {
  290. this._worker.destroy();
  291. this._worker = null;
  292. }
  293. }
  294. }
  295. exports.PDFDocumentLoadingTask = PDFDocumentLoadingTask;
  296. class PDFDataRangeTransport {
  297. constructor(length, initialData, progressiveDone = false, contentDispositionFilename = null) {
  298. this.length = length;
  299. this.initialData = initialData;
  300. this.progressiveDone = progressiveDone;
  301. this.contentDispositionFilename = contentDispositionFilename;
  302. this._rangeListeners = [];
  303. this._progressListeners = [];
  304. this._progressiveReadListeners = [];
  305. this._progressiveDoneListeners = [];
  306. this._readyCapability = (0, _util.createPromiseCapability)();
  307. }
  308. addRangeListener(listener) {
  309. this._rangeListeners.push(listener);
  310. }
  311. addProgressListener(listener) {
  312. this._progressListeners.push(listener);
  313. }
  314. addProgressiveReadListener(listener) {
  315. this._progressiveReadListeners.push(listener);
  316. }
  317. addProgressiveDoneListener(listener) {
  318. this._progressiveDoneListeners.push(listener);
  319. }
  320. onDataRange(begin, chunk) {
  321. for (const listener of this._rangeListeners) {
  322. listener(begin, chunk);
  323. }
  324. }
  325. onDataProgress(loaded, total) {
  326. this._readyCapability.promise.then(() => {
  327. for (const listener of this._progressListeners) {
  328. listener(loaded, total);
  329. }
  330. });
  331. }
  332. onDataProgressiveRead(chunk) {
  333. this._readyCapability.promise.then(() => {
  334. for (const listener of this._progressiveReadListeners) {
  335. listener(chunk);
  336. }
  337. });
  338. }
  339. onDataProgressiveDone() {
  340. this._readyCapability.promise.then(() => {
  341. for (const listener of this._progressiveDoneListeners) {
  342. listener();
  343. }
  344. });
  345. }
  346. transportReady() {
  347. this._readyCapability.resolve();
  348. }
  349. requestDataRange(begin, end) {
  350. (0, _util.unreachable)("Abstract method PDFDataRangeTransport.requestDataRange");
  351. }
  352. abort() {}
  353. }
  354. exports.PDFDataRangeTransport = PDFDataRangeTransport;
  355. class PDFDocumentProxy {
  356. constructor(pdfInfo, transport) {
  357. this._pdfInfo = pdfInfo;
  358. this._transport = transport;
  359. }
  360. get annotationStorage() {
  361. return this._transport.annotationStorage;
  362. }
  363. get numPages() {
  364. return this._pdfInfo.numPages;
  365. }
  366. get fingerprints() {
  367. return this._pdfInfo.fingerprints;
  368. }
  369. get stats() {
  370. return this._transport.stats;
  371. }
  372. get isPureXfa() {
  373. return !!this._transport._htmlForXfa;
  374. }
  375. get allXfaHtml() {
  376. return this._transport._htmlForXfa;
  377. }
  378. getPage(pageNumber) {
  379. return this._transport.getPage(pageNumber);
  380. }
  381. getPageIndex(ref) {
  382. return this._transport.getPageIndex(ref);
  383. }
  384. getDestinations() {
  385. return this._transport.getDestinations();
  386. }
  387. getDestination(id) {
  388. return this._transport.getDestination(id);
  389. }
  390. getPageLabels() {
  391. return this._transport.getPageLabels();
  392. }
  393. getPageLayout() {
  394. return this._transport.getPageLayout();
  395. }
  396. getPageMode() {
  397. return this._transport.getPageMode();
  398. }
  399. getViewerPreferences() {
  400. return this._transport.getViewerPreferences();
  401. }
  402. getOpenAction() {
  403. return this._transport.getOpenAction();
  404. }
  405. getAttachments() {
  406. return this._transport.getAttachments();
  407. }
  408. getJavaScript() {
  409. return this._transport.getJavaScript();
  410. }
  411. getJSActions() {
  412. return this._transport.getDocJSActions();
  413. }
  414. getOutline() {
  415. return this._transport.getOutline();
  416. }
  417. getOptionalContentConfig() {
  418. return this._transport.getOptionalContentConfig();
  419. }
  420. getPermissions() {
  421. return this._transport.getPermissions();
  422. }
  423. getMetadata() {
  424. return this._transport.getMetadata();
  425. }
  426. getMarkInfo() {
  427. return this._transport.getMarkInfo();
  428. }
  429. getData() {
  430. return this._transport.getData();
  431. }
  432. saveDocument() {
  433. return this._transport.saveDocument();
  434. }
  435. getDownloadInfo() {
  436. return this._transport.downloadInfoCapability.promise;
  437. }
  438. cleanup(keepLoadedFonts = false) {
  439. return this._transport.startCleanup(keepLoadedFonts || this.isPureXfa);
  440. }
  441. destroy() {
  442. return this.loadingTask.destroy();
  443. }
  444. get loadingParams() {
  445. return this._transport.loadingParams;
  446. }
  447. get loadingTask() {
  448. return this._transport.loadingTask;
  449. }
  450. getFieldObjects() {
  451. return this._transport.getFieldObjects();
  452. }
  453. hasJSActions() {
  454. return this._transport.hasJSActions();
  455. }
  456. getCalculationOrderIds() {
  457. return this._transport.getCalculationOrderIds();
  458. }
  459. }
  460. exports.PDFDocumentProxy = PDFDocumentProxy;
  461. class PDFPageProxy {
  462. constructor(pageIndex, pageInfo, transport, ownerDocument, pdfBug = false) {
  463. this._pageIndex = pageIndex;
  464. this._pageInfo = pageInfo;
  465. this._ownerDocument = ownerDocument;
  466. this._transport = transport;
  467. this._stats = pdfBug ? new _display_utils.StatTimer() : null;
  468. this._pdfBug = pdfBug;
  469. this.commonObjs = transport.commonObjs;
  470. this.objs = new PDFObjects();
  471. this._bitmaps = new Set();
  472. this.cleanupAfterRender = false;
  473. this.pendingCleanup = false;
  474. this._intentStates = new Map();
  475. this._annotationPromises = new Map();
  476. this.destroyed = false;
  477. }
  478. get pageNumber() {
  479. return this._pageIndex + 1;
  480. }
  481. get rotate() {
  482. return this._pageInfo.rotate;
  483. }
  484. get ref() {
  485. return this._pageInfo.ref;
  486. }
  487. get userUnit() {
  488. return this._pageInfo.userUnit;
  489. }
  490. get view() {
  491. return this._pageInfo.view;
  492. }
  493. getViewport({
  494. scale,
  495. rotation = this.rotate,
  496. offsetX = 0,
  497. offsetY = 0,
  498. dontFlip = false
  499. } = {}) {
  500. return new _display_utils.PageViewport({
  501. viewBox: this.view,
  502. scale,
  503. rotation,
  504. offsetX,
  505. offsetY,
  506. dontFlip
  507. });
  508. }
  509. getAnnotations({
  510. intent = "display"
  511. } = {}) {
  512. const intentArgs = this._transport.getRenderingIntent(intent);
  513. let promise = this._annotationPromises.get(intentArgs.cacheKey);
  514. if (!promise) {
  515. promise = this._transport.getAnnotations(this._pageIndex, intentArgs.renderingIntent);
  516. this._annotationPromises.set(intentArgs.cacheKey, promise);
  517. }
  518. return promise;
  519. }
  520. getJSActions() {
  521. return this._jsActionsPromise ||= this._transport.getPageJSActions(this._pageIndex);
  522. }
  523. async getXfa() {
  524. return this._transport._htmlForXfa?.children[this._pageIndex] || null;
  525. }
  526. render({
  527. canvasContext,
  528. viewport,
  529. intent = "display",
  530. annotationMode = _util.AnnotationMode.ENABLE,
  531. transform = null,
  532. canvasFactory = null,
  533. background = null,
  534. optionalContentConfigPromise = null,
  535. annotationCanvasMap = null,
  536. pageColors = null,
  537. printAnnotationStorage = null
  538. }) {
  539. this._stats?.time("Overall");
  540. const intentArgs = this._transport.getRenderingIntent(intent, annotationMode, printAnnotationStorage);
  541. this.pendingCleanup = false;
  542. if (!optionalContentConfigPromise) {
  543. optionalContentConfigPromise = this._transport.getOptionalContentConfig();
  544. }
  545. let intentState = this._intentStates.get(intentArgs.cacheKey);
  546. if (!intentState) {
  547. intentState = Object.create(null);
  548. this._intentStates.set(intentArgs.cacheKey, intentState);
  549. }
  550. if (intentState.streamReaderCancelTimeout) {
  551. clearTimeout(intentState.streamReaderCancelTimeout);
  552. intentState.streamReaderCancelTimeout = null;
  553. }
  554. const canvasFactoryInstance = canvasFactory || new DefaultCanvasFactory({
  555. ownerDocument: this._ownerDocument
  556. });
  557. const intentPrint = !!(intentArgs.renderingIntent & _util.RenderingIntentFlag.PRINT);
  558. if (!intentState.displayReadyCapability) {
  559. intentState.displayReadyCapability = (0, _util.createPromiseCapability)();
  560. intentState.operatorList = {
  561. fnArray: [],
  562. argsArray: [],
  563. lastChunk: false,
  564. separateAnnots: null
  565. };
  566. this._stats?.time("Page Request");
  567. this._pumpOperatorList(intentArgs);
  568. }
  569. const complete = error => {
  570. intentState.renderTasks.delete(internalRenderTask);
  571. if (this.cleanupAfterRender || intentPrint) {
  572. this.pendingCleanup = true;
  573. }
  574. this._tryCleanup();
  575. if (error) {
  576. internalRenderTask.capability.reject(error);
  577. this._abortOperatorList({
  578. intentState,
  579. reason: error instanceof Error ? error : new Error(error)
  580. });
  581. } else {
  582. internalRenderTask.capability.resolve();
  583. }
  584. this._stats?.timeEnd("Rendering");
  585. this._stats?.timeEnd("Overall");
  586. };
  587. const internalRenderTask = new InternalRenderTask({
  588. callback: complete,
  589. params: {
  590. canvasContext,
  591. viewport,
  592. transform,
  593. background
  594. },
  595. objs: this.objs,
  596. commonObjs: this.commonObjs,
  597. annotationCanvasMap,
  598. operatorList: intentState.operatorList,
  599. pageIndex: this._pageIndex,
  600. canvasFactory: canvasFactoryInstance,
  601. useRequestAnimationFrame: !intentPrint,
  602. pdfBug: this._pdfBug,
  603. pageColors
  604. });
  605. (intentState.renderTasks ||= new Set()).add(internalRenderTask);
  606. const renderTask = internalRenderTask.task;
  607. Promise.all([intentState.displayReadyCapability.promise, optionalContentConfigPromise]).then(([transparency, optionalContentConfig]) => {
  608. if (this.pendingCleanup) {
  609. complete();
  610. return;
  611. }
  612. this._stats?.time("Rendering");
  613. internalRenderTask.initializeGraphics({
  614. transparency,
  615. optionalContentConfig
  616. });
  617. internalRenderTask.operatorListChanged();
  618. }).catch(complete);
  619. return renderTask;
  620. }
  621. getOperatorList({
  622. intent = "display",
  623. annotationMode = _util.AnnotationMode.ENABLE,
  624. printAnnotationStorage = null
  625. } = {}) {
  626. function operatorListChanged() {
  627. if (intentState.operatorList.lastChunk) {
  628. intentState.opListReadCapability.resolve(intentState.operatorList);
  629. intentState.renderTasks.delete(opListTask);
  630. }
  631. }
  632. const intentArgs = this._transport.getRenderingIntent(intent, annotationMode, printAnnotationStorage, true);
  633. let intentState = this._intentStates.get(intentArgs.cacheKey);
  634. if (!intentState) {
  635. intentState = Object.create(null);
  636. this._intentStates.set(intentArgs.cacheKey, intentState);
  637. }
  638. let opListTask;
  639. if (!intentState.opListReadCapability) {
  640. opListTask = Object.create(null);
  641. opListTask.operatorListChanged = operatorListChanged;
  642. intentState.opListReadCapability = (0, _util.createPromiseCapability)();
  643. (intentState.renderTasks ||= new Set()).add(opListTask);
  644. intentState.operatorList = {
  645. fnArray: [],
  646. argsArray: [],
  647. lastChunk: false,
  648. separateAnnots: null
  649. };
  650. this._stats?.time("Page Request");
  651. this._pumpOperatorList(intentArgs);
  652. }
  653. return intentState.opListReadCapability.promise;
  654. }
  655. streamTextContent({
  656. disableCombineTextItems = false,
  657. includeMarkedContent = false
  658. } = {}) {
  659. const TEXT_CONTENT_CHUNK_SIZE = 100;
  660. return this._transport.messageHandler.sendWithStream("GetTextContent", {
  661. pageIndex: this._pageIndex,
  662. combineTextItems: disableCombineTextItems !== true,
  663. includeMarkedContent: includeMarkedContent === true
  664. }, {
  665. highWaterMark: TEXT_CONTENT_CHUNK_SIZE,
  666. size(textContent) {
  667. return textContent.items.length;
  668. }
  669. });
  670. }
  671. getTextContent(params = {}) {
  672. if (this._transport._htmlForXfa) {
  673. return this.getXfa().then(xfa => {
  674. return _xfa_text.XfaText.textContent(xfa);
  675. });
  676. }
  677. const readableStream = this.streamTextContent(params);
  678. return new Promise(function (resolve, reject) {
  679. function pump() {
  680. reader.read().then(function ({
  681. value,
  682. done
  683. }) {
  684. if (done) {
  685. resolve(textContent);
  686. return;
  687. }
  688. Object.assign(textContent.styles, value.styles);
  689. textContent.items.push(...value.items);
  690. pump();
  691. }, reject);
  692. }
  693. const reader = readableStream.getReader();
  694. const textContent = {
  695. items: [],
  696. styles: Object.create(null)
  697. };
  698. pump();
  699. });
  700. }
  701. getStructTree() {
  702. return this._structTreePromise ||= this._transport.getStructTree(this._pageIndex);
  703. }
  704. _destroy() {
  705. this.destroyed = true;
  706. const waitOn = [];
  707. for (const intentState of this._intentStates.values()) {
  708. this._abortOperatorList({
  709. intentState,
  710. reason: new Error("Page was destroyed."),
  711. force: true
  712. });
  713. if (intentState.opListReadCapability) {
  714. continue;
  715. }
  716. for (const internalRenderTask of intentState.renderTasks) {
  717. waitOn.push(internalRenderTask.completed);
  718. internalRenderTask.cancel();
  719. }
  720. }
  721. this.objs.clear();
  722. for (const bitmap of this._bitmaps) {
  723. bitmap.close();
  724. }
  725. this._bitmaps.clear();
  726. this._annotationPromises.clear();
  727. this._jsActionsPromise = null;
  728. this._structTreePromise = null;
  729. this.pendingCleanup = false;
  730. return Promise.all(waitOn);
  731. }
  732. cleanup(resetStats = false) {
  733. this.pendingCleanup = true;
  734. return this._tryCleanup(resetStats);
  735. }
  736. _tryCleanup(resetStats = false) {
  737. if (!this.pendingCleanup) {
  738. return false;
  739. }
  740. for (const {
  741. renderTasks,
  742. operatorList
  743. } of this._intentStates.values()) {
  744. if (renderTasks.size > 0 || !operatorList.lastChunk) {
  745. return false;
  746. }
  747. }
  748. this._intentStates.clear();
  749. this.objs.clear();
  750. this._annotationPromises.clear();
  751. this._jsActionsPromise = null;
  752. this._structTreePromise = null;
  753. if (resetStats && this._stats) {
  754. this._stats = new _display_utils.StatTimer();
  755. }
  756. for (const bitmap of this._bitmaps) {
  757. bitmap.close();
  758. }
  759. this._bitmaps.clear();
  760. this.pendingCleanup = false;
  761. return true;
  762. }
  763. _startRenderPage(transparency, cacheKey) {
  764. const intentState = this._intentStates.get(cacheKey);
  765. if (!intentState) {
  766. return;
  767. }
  768. this._stats?.timeEnd("Page Request");
  769. intentState.displayReadyCapability?.resolve(transparency);
  770. }
  771. _renderPageChunk(operatorListChunk, intentState) {
  772. for (let i = 0, ii = operatorListChunk.length; i < ii; i++) {
  773. intentState.operatorList.fnArray.push(operatorListChunk.fnArray[i]);
  774. intentState.operatorList.argsArray.push(operatorListChunk.argsArray[i]);
  775. }
  776. intentState.operatorList.lastChunk = operatorListChunk.lastChunk;
  777. intentState.operatorList.separateAnnots = operatorListChunk.separateAnnots;
  778. for (const internalRenderTask of intentState.renderTasks) {
  779. internalRenderTask.operatorListChanged();
  780. }
  781. if (operatorListChunk.lastChunk) {
  782. this._tryCleanup();
  783. }
  784. }
  785. _pumpOperatorList({
  786. renderingIntent,
  787. cacheKey,
  788. annotationStorageMap
  789. }) {
  790. const readableStream = this._transport.messageHandler.sendWithStream("GetOperatorList", {
  791. pageIndex: this._pageIndex,
  792. intent: renderingIntent,
  793. cacheKey,
  794. annotationStorage: annotationStorageMap
  795. });
  796. const reader = readableStream.getReader();
  797. const intentState = this._intentStates.get(cacheKey);
  798. intentState.streamReader = reader;
  799. const pump = () => {
  800. reader.read().then(({
  801. value,
  802. done
  803. }) => {
  804. if (done) {
  805. intentState.streamReader = null;
  806. return;
  807. }
  808. if (this._transport.destroyed) {
  809. return;
  810. }
  811. this._renderPageChunk(value, intentState);
  812. pump();
  813. }, reason => {
  814. intentState.streamReader = null;
  815. if (this._transport.destroyed) {
  816. return;
  817. }
  818. if (intentState.operatorList) {
  819. intentState.operatorList.lastChunk = true;
  820. for (const internalRenderTask of intentState.renderTasks) {
  821. internalRenderTask.operatorListChanged();
  822. }
  823. this._tryCleanup();
  824. }
  825. if (intentState.displayReadyCapability) {
  826. intentState.displayReadyCapability.reject(reason);
  827. } else if (intentState.opListReadCapability) {
  828. intentState.opListReadCapability.reject(reason);
  829. } else {
  830. throw reason;
  831. }
  832. });
  833. };
  834. pump();
  835. }
  836. _abortOperatorList({
  837. intentState,
  838. reason,
  839. force = false
  840. }) {
  841. if (!intentState.streamReader) {
  842. return;
  843. }
  844. if (!force) {
  845. if (intentState.renderTasks.size > 0) {
  846. return;
  847. }
  848. if (reason instanceof _display_utils.RenderingCancelledException) {
  849. intentState.streamReaderCancelTimeout = setTimeout(() => {
  850. this._abortOperatorList({
  851. intentState,
  852. reason,
  853. force: true
  854. });
  855. intentState.streamReaderCancelTimeout = null;
  856. }, RENDERING_CANCELLED_TIMEOUT);
  857. return;
  858. }
  859. }
  860. intentState.streamReader.cancel(new _util.AbortException(reason.message)).catch(() => {});
  861. intentState.streamReader = null;
  862. if (this._transport.destroyed) {
  863. return;
  864. }
  865. for (const [curCacheKey, curIntentState] of this._intentStates) {
  866. if (curIntentState === intentState) {
  867. this._intentStates.delete(curCacheKey);
  868. break;
  869. }
  870. }
  871. this.cleanup();
  872. }
  873. get stats() {
  874. return this._stats;
  875. }
  876. }
  877. exports.PDFPageProxy = PDFPageProxy;
  878. class LoopbackPort {
  879. #listeners = [];
  880. #deferred = Promise.resolve();
  881. postMessage(obj, transfers) {
  882. const event = {
  883. data: structuredClone(obj, transfers)
  884. };
  885. this.#deferred.then(() => {
  886. for (const listener of this.#listeners) {
  887. listener.call(this, event);
  888. }
  889. });
  890. }
  891. addEventListener(name, listener) {
  892. this.#listeners.push(listener);
  893. }
  894. removeEventListener(name, listener) {
  895. const i = this.#listeners.indexOf(listener);
  896. this.#listeners.splice(i, 1);
  897. }
  898. terminate() {
  899. this.#listeners.length = 0;
  900. }
  901. }
  902. exports.LoopbackPort = LoopbackPort;
  903. const PDFWorkerUtil = {
  904. isWorkerDisabled: false,
  905. fallbackWorkerSrc: null,
  906. fakeWorkerId: 0
  907. };
  908. exports.PDFWorkerUtil = PDFWorkerUtil;
  909. {
  910. if (_is_node.isNodeJS && typeof require === "function") {
  911. PDFWorkerUtil.isWorkerDisabled = true;
  912. PDFWorkerUtil.fallbackWorkerSrc = "../pdf.worker.js";
  913. } else if (typeof document === "object") {
  914. const pdfjsFilePath = document?.currentScript?.src;
  915. if (pdfjsFilePath) {
  916. PDFWorkerUtil.fallbackWorkerSrc = pdfjsFilePath.replace(/(\.(?:min\.)?js)(\?.*)?$/i, ".worker$1$2");
  917. }
  918. }
  919. PDFWorkerUtil.isSameOrigin = function (baseUrl, otherUrl) {
  920. let base;
  921. try {
  922. base = new URL(baseUrl);
  923. if (!base.origin || base.origin === "null") {
  924. return false;
  925. }
  926. } catch (e) {
  927. return false;
  928. }
  929. const other = new URL(otherUrl, base);
  930. return base.origin === other.origin;
  931. };
  932. PDFWorkerUtil.createCDNWrapper = function (url) {
  933. const wrapper = `importScripts("${url}");`;
  934. return URL.createObjectURL(new Blob([wrapper]));
  935. };
  936. }
  937. class PDFWorker {
  938. static #workerPorts = new WeakMap();
  939. constructor({
  940. name = null,
  941. port = null,
  942. verbosity = (0, _util.getVerbosityLevel)()
  943. } = {}) {
  944. if (port && PDFWorker.#workerPorts.has(port)) {
  945. throw new Error("Cannot use more than one PDFWorker per port.");
  946. }
  947. this.name = name;
  948. this.destroyed = false;
  949. this.verbosity = verbosity;
  950. this._readyCapability = (0, _util.createPromiseCapability)();
  951. this._port = null;
  952. this._webWorker = null;
  953. this._messageHandler = null;
  954. if (port) {
  955. PDFWorker.#workerPorts.set(port, this);
  956. this._initializeFromPort(port);
  957. return;
  958. }
  959. this._initialize();
  960. }
  961. get promise() {
  962. return this._readyCapability.promise;
  963. }
  964. get port() {
  965. return this._port;
  966. }
  967. get messageHandler() {
  968. return this._messageHandler;
  969. }
  970. _initializeFromPort(port) {
  971. this._port = port;
  972. this._messageHandler = new _message_handler.MessageHandler("main", "worker", port);
  973. this._messageHandler.on("ready", function () {});
  974. this._readyCapability.resolve();
  975. this._messageHandler.send("configure", {
  976. verbosity: this.verbosity
  977. });
  978. }
  979. _initialize() {
  980. if (!PDFWorkerUtil.isWorkerDisabled && !PDFWorker._mainThreadWorkerMessageHandler) {
  981. let {
  982. workerSrc
  983. } = PDFWorker;
  984. try {
  985. if (!PDFWorkerUtil.isSameOrigin(window.location.href, workerSrc)) {
  986. workerSrc = PDFWorkerUtil.createCDNWrapper(new URL(workerSrc, window.location).href);
  987. }
  988. const worker = new Worker(workerSrc);
  989. const messageHandler = new _message_handler.MessageHandler("main", "worker", worker);
  990. const terminateEarly = () => {
  991. worker.removeEventListener("error", onWorkerError);
  992. messageHandler.destroy();
  993. worker.terminate();
  994. if (this.destroyed) {
  995. this._readyCapability.reject(new Error("Worker was destroyed"));
  996. } else {
  997. this._setupFakeWorker();
  998. }
  999. };
  1000. const onWorkerError = () => {
  1001. if (!this._webWorker) {
  1002. terminateEarly();
  1003. }
  1004. };
  1005. worker.addEventListener("error", onWorkerError);
  1006. messageHandler.on("test", data => {
  1007. worker.removeEventListener("error", onWorkerError);
  1008. if (this.destroyed) {
  1009. terminateEarly();
  1010. return;
  1011. }
  1012. if (data) {
  1013. this._messageHandler = messageHandler;
  1014. this._port = worker;
  1015. this._webWorker = worker;
  1016. this._readyCapability.resolve();
  1017. messageHandler.send("configure", {
  1018. verbosity: this.verbosity
  1019. });
  1020. } else {
  1021. this._setupFakeWorker();
  1022. messageHandler.destroy();
  1023. worker.terminate();
  1024. }
  1025. });
  1026. messageHandler.on("ready", data => {
  1027. worker.removeEventListener("error", onWorkerError);
  1028. if (this.destroyed) {
  1029. terminateEarly();
  1030. return;
  1031. }
  1032. try {
  1033. sendTest();
  1034. } catch (e) {
  1035. this._setupFakeWorker();
  1036. }
  1037. });
  1038. const sendTest = () => {
  1039. const testObj = new Uint8Array();
  1040. messageHandler.send("test", testObj, [testObj.buffer]);
  1041. };
  1042. sendTest();
  1043. return;
  1044. } catch (e) {
  1045. (0, _util.info)("The worker has been disabled.");
  1046. }
  1047. }
  1048. this._setupFakeWorker();
  1049. }
  1050. _setupFakeWorker() {
  1051. if (!PDFWorkerUtil.isWorkerDisabled) {
  1052. (0, _util.warn)("Setting up fake worker.");
  1053. PDFWorkerUtil.isWorkerDisabled = true;
  1054. }
  1055. PDFWorker._setupFakeWorkerGlobal.then(WorkerMessageHandler => {
  1056. if (this.destroyed) {
  1057. this._readyCapability.reject(new Error("Worker was destroyed"));
  1058. return;
  1059. }
  1060. const port = new LoopbackPort();
  1061. this._port = port;
  1062. const id = `fake${PDFWorkerUtil.fakeWorkerId++}`;
  1063. const workerHandler = new _message_handler.MessageHandler(id + "_worker", id, port);
  1064. WorkerMessageHandler.setup(workerHandler, port);
  1065. const messageHandler = new _message_handler.MessageHandler(id, id + "_worker", port);
  1066. this._messageHandler = messageHandler;
  1067. this._readyCapability.resolve();
  1068. messageHandler.send("configure", {
  1069. verbosity: this.verbosity
  1070. });
  1071. }).catch(reason => {
  1072. this._readyCapability.reject(new Error(`Setting up fake worker failed: "${reason.message}".`));
  1073. });
  1074. }
  1075. destroy() {
  1076. this.destroyed = true;
  1077. if (this._webWorker) {
  1078. this._webWorker.terminate();
  1079. this._webWorker = null;
  1080. }
  1081. PDFWorker.#workerPorts.delete(this._port);
  1082. this._port = null;
  1083. if (this._messageHandler) {
  1084. this._messageHandler.destroy();
  1085. this._messageHandler = null;
  1086. }
  1087. }
  1088. static fromPort(params) {
  1089. if (!params?.port) {
  1090. throw new Error("PDFWorker.fromPort - invalid method signature.");
  1091. }
  1092. if (this.#workerPorts.has(params.port)) {
  1093. return this.#workerPorts.get(params.port);
  1094. }
  1095. return new PDFWorker(params);
  1096. }
  1097. static get workerSrc() {
  1098. if (_worker_options.GlobalWorkerOptions.workerSrc) {
  1099. return _worker_options.GlobalWorkerOptions.workerSrc;
  1100. }
  1101. if (PDFWorkerUtil.fallbackWorkerSrc !== null) {
  1102. if (!_is_node.isNodeJS) {
  1103. (0, _display_utils.deprecated)('No "GlobalWorkerOptions.workerSrc" specified.');
  1104. }
  1105. return PDFWorkerUtil.fallbackWorkerSrc;
  1106. }
  1107. throw new Error('No "GlobalWorkerOptions.workerSrc" specified.');
  1108. }
  1109. static get _mainThreadWorkerMessageHandler() {
  1110. try {
  1111. return globalThis.pdfjsWorker?.WorkerMessageHandler || null;
  1112. } catch (ex) {
  1113. return null;
  1114. }
  1115. }
  1116. static get _setupFakeWorkerGlobal() {
  1117. const loader = async () => {
  1118. const mainWorkerMessageHandler = this._mainThreadWorkerMessageHandler;
  1119. if (mainWorkerMessageHandler) {
  1120. return mainWorkerMessageHandler;
  1121. }
  1122. if (_is_node.isNodeJS && typeof require === "function") {
  1123. const worker = eval("require")(this.workerSrc);
  1124. return worker.WorkerMessageHandler;
  1125. }
  1126. await (0, _display_utils.loadScript)(this.workerSrc);
  1127. return window.pdfjsWorker.WorkerMessageHandler;
  1128. };
  1129. return (0, _util.shadow)(this, "_setupFakeWorkerGlobal", loader());
  1130. }
  1131. }
  1132. exports.PDFWorker = PDFWorker;
  1133. class WorkerTransport {
  1134. #docStats = null;
  1135. #pageCache = new Map();
  1136. #pagePromises = new Map();
  1137. #metadataPromise = null;
  1138. constructor(messageHandler, loadingTask, networkStream, params) {
  1139. this.messageHandler = messageHandler;
  1140. this.loadingTask = loadingTask;
  1141. this.commonObjs = new PDFObjects();
  1142. this.fontLoader = new _font_loader.FontLoader({
  1143. onUnsupportedFeature: this._onUnsupportedFeature.bind(this),
  1144. ownerDocument: params.ownerDocument,
  1145. styleElement: params.styleElement
  1146. });
  1147. this._params = params;
  1148. if (!params.useWorkerFetch) {
  1149. this.CMapReaderFactory = new params.CMapReaderFactory({
  1150. baseUrl: params.cMapUrl,
  1151. isCompressed: params.cMapPacked
  1152. });
  1153. this.StandardFontDataFactory = new params.StandardFontDataFactory({
  1154. baseUrl: params.standardFontDataUrl
  1155. });
  1156. }
  1157. this.destroyed = false;
  1158. this.destroyCapability = null;
  1159. this._passwordCapability = null;
  1160. this._networkStream = networkStream;
  1161. this._fullReader = null;
  1162. this._lastProgress = null;
  1163. this.downloadInfoCapability = (0, _util.createPromiseCapability)();
  1164. this.setupMessageHandler();
  1165. }
  1166. get annotationStorage() {
  1167. return (0, _util.shadow)(this, "annotationStorage", new _annotation_storage.AnnotationStorage());
  1168. }
  1169. get stats() {
  1170. return this.#docStats;
  1171. }
  1172. getRenderingIntent(intent, annotationMode = _util.AnnotationMode.ENABLE, printAnnotationStorage = null, isOpList = false) {
  1173. let renderingIntent = _util.RenderingIntentFlag.DISPLAY;
  1174. let annotationMap = null;
  1175. switch (intent) {
  1176. case "any":
  1177. renderingIntent = _util.RenderingIntentFlag.ANY;
  1178. break;
  1179. case "display":
  1180. break;
  1181. case "print":
  1182. renderingIntent = _util.RenderingIntentFlag.PRINT;
  1183. break;
  1184. default:
  1185. (0, _util.warn)(`getRenderingIntent - invalid intent: ${intent}`);
  1186. }
  1187. switch (annotationMode) {
  1188. case _util.AnnotationMode.DISABLE:
  1189. renderingIntent += _util.RenderingIntentFlag.ANNOTATIONS_DISABLE;
  1190. break;
  1191. case _util.AnnotationMode.ENABLE:
  1192. break;
  1193. case _util.AnnotationMode.ENABLE_FORMS:
  1194. renderingIntent += _util.RenderingIntentFlag.ANNOTATIONS_FORMS;
  1195. break;
  1196. case _util.AnnotationMode.ENABLE_STORAGE:
  1197. renderingIntent += _util.RenderingIntentFlag.ANNOTATIONS_STORAGE;
  1198. const annotationStorage = renderingIntent & _util.RenderingIntentFlag.PRINT && printAnnotationStorage instanceof _annotation_storage.PrintAnnotationStorage ? printAnnotationStorage : this.annotationStorage;
  1199. annotationMap = annotationStorage.serializable;
  1200. break;
  1201. default:
  1202. (0, _util.warn)(`getRenderingIntent - invalid annotationMode: ${annotationMode}`);
  1203. }
  1204. if (isOpList) {
  1205. renderingIntent += _util.RenderingIntentFlag.OPLIST;
  1206. }
  1207. return {
  1208. renderingIntent,
  1209. cacheKey: `${renderingIntent}_${_annotation_storage.AnnotationStorage.getHash(annotationMap)}`,
  1210. annotationStorageMap: annotationMap
  1211. };
  1212. }
  1213. destroy() {
  1214. if (this.destroyCapability) {
  1215. return this.destroyCapability.promise;
  1216. }
  1217. this.destroyed = true;
  1218. this.destroyCapability = (0, _util.createPromiseCapability)();
  1219. if (this._passwordCapability) {
  1220. this._passwordCapability.reject(new Error("Worker was destroyed during onPassword callback"));
  1221. }
  1222. const waitOn = [];
  1223. for (const page of this.#pageCache.values()) {
  1224. waitOn.push(page._destroy());
  1225. }
  1226. this.#pageCache.clear();
  1227. this.#pagePromises.clear();
  1228. if (this.hasOwnProperty("annotationStorage")) {
  1229. this.annotationStorage.resetModified();
  1230. }
  1231. const terminated = this.messageHandler.sendWithPromise("Terminate", null);
  1232. waitOn.push(terminated);
  1233. Promise.all(waitOn).then(() => {
  1234. this.commonObjs.clear();
  1235. this.fontLoader.clear();
  1236. this.#metadataPromise = null;
  1237. this._getFieldObjectsPromise = null;
  1238. this._hasJSActionsPromise = null;
  1239. if (this._networkStream) {
  1240. this._networkStream.cancelAllRequests(new _util.AbortException("Worker was terminated."));
  1241. }
  1242. if (this.messageHandler) {
  1243. this.messageHandler.destroy();
  1244. this.messageHandler = null;
  1245. }
  1246. this.destroyCapability.resolve();
  1247. }, this.destroyCapability.reject);
  1248. return this.destroyCapability.promise;
  1249. }
  1250. setupMessageHandler() {
  1251. const {
  1252. messageHandler,
  1253. loadingTask
  1254. } = this;
  1255. messageHandler.on("GetReader", (data, sink) => {
  1256. (0, _util.assert)(this._networkStream, "GetReader - no `IPDFStream` instance available.");
  1257. this._fullReader = this._networkStream.getFullReader();
  1258. this._fullReader.onProgress = evt => {
  1259. this._lastProgress = {
  1260. loaded: evt.loaded,
  1261. total: evt.total
  1262. };
  1263. };
  1264. sink.onPull = () => {
  1265. this._fullReader.read().then(function ({
  1266. value,
  1267. done
  1268. }) {
  1269. if (done) {
  1270. sink.close();
  1271. return;
  1272. }
  1273. (0, _util.assert)((0, _util.isArrayBuffer)(value), "GetReader - expected an ArrayBuffer.");
  1274. sink.enqueue(new Uint8Array(value), 1, [value]);
  1275. }).catch(reason => {
  1276. sink.error(reason);
  1277. });
  1278. };
  1279. sink.onCancel = reason => {
  1280. this._fullReader.cancel(reason);
  1281. sink.ready.catch(readyReason => {
  1282. if (this.destroyed) {
  1283. return;
  1284. }
  1285. throw readyReason;
  1286. });
  1287. };
  1288. });
  1289. messageHandler.on("ReaderHeadersReady", data => {
  1290. const headersCapability = (0, _util.createPromiseCapability)();
  1291. const fullReader = this._fullReader;
  1292. fullReader.headersReady.then(() => {
  1293. if (!fullReader.isStreamingSupported || !fullReader.isRangeSupported) {
  1294. if (this._lastProgress) {
  1295. loadingTask.onProgress?.(this._lastProgress);
  1296. }
  1297. fullReader.onProgress = evt => {
  1298. loadingTask.onProgress?.({
  1299. loaded: evt.loaded,
  1300. total: evt.total
  1301. });
  1302. };
  1303. }
  1304. headersCapability.resolve({
  1305. isStreamingSupported: fullReader.isStreamingSupported,
  1306. isRangeSupported: fullReader.isRangeSupported,
  1307. contentLength: fullReader.contentLength
  1308. });
  1309. }, headersCapability.reject);
  1310. return headersCapability.promise;
  1311. });
  1312. messageHandler.on("GetRangeReader", (data, sink) => {
  1313. (0, _util.assert)(this._networkStream, "GetRangeReader - no `IPDFStream` instance available.");
  1314. const rangeReader = this._networkStream.getRangeReader(data.begin, data.end);
  1315. if (!rangeReader) {
  1316. sink.close();
  1317. return;
  1318. }
  1319. sink.onPull = () => {
  1320. rangeReader.read().then(function ({
  1321. value,
  1322. done
  1323. }) {
  1324. if (done) {
  1325. sink.close();
  1326. return;
  1327. }
  1328. (0, _util.assert)((0, _util.isArrayBuffer)(value), "GetRangeReader - expected an ArrayBuffer.");
  1329. sink.enqueue(new Uint8Array(value), 1, [value]);
  1330. }).catch(reason => {
  1331. sink.error(reason);
  1332. });
  1333. };
  1334. sink.onCancel = reason => {
  1335. rangeReader.cancel(reason);
  1336. sink.ready.catch(readyReason => {
  1337. if (this.destroyed) {
  1338. return;
  1339. }
  1340. throw readyReason;
  1341. });
  1342. };
  1343. });
  1344. messageHandler.on("GetDoc", ({
  1345. pdfInfo
  1346. }) => {
  1347. this._numPages = pdfInfo.numPages;
  1348. this._htmlForXfa = pdfInfo.htmlForXfa;
  1349. delete pdfInfo.htmlForXfa;
  1350. loadingTask._capability.resolve(new PDFDocumentProxy(pdfInfo, this));
  1351. });
  1352. messageHandler.on("DocException", function (ex) {
  1353. let reason;
  1354. switch (ex.name) {
  1355. case "PasswordException":
  1356. reason = new _util.PasswordException(ex.message, ex.code);
  1357. break;
  1358. case "InvalidPDFException":
  1359. reason = new _util.InvalidPDFException(ex.message);
  1360. break;
  1361. case "MissingPDFException":
  1362. reason = new _util.MissingPDFException(ex.message);
  1363. break;
  1364. case "UnexpectedResponseException":
  1365. reason = new _util.UnexpectedResponseException(ex.message, ex.status);
  1366. break;
  1367. case "UnknownErrorException":
  1368. reason = new _util.UnknownErrorException(ex.message, ex.details);
  1369. break;
  1370. default:
  1371. (0, _util.unreachable)("DocException - expected a valid Error.");
  1372. }
  1373. loadingTask._capability.reject(reason);
  1374. });
  1375. messageHandler.on("PasswordRequest", exception => {
  1376. this._passwordCapability = (0, _util.createPromiseCapability)();
  1377. if (loadingTask.onPassword) {
  1378. const updatePassword = password => {
  1379. if (password instanceof Error) {
  1380. this._passwordCapability.reject(password);
  1381. } else {
  1382. this._passwordCapability.resolve({
  1383. password
  1384. });
  1385. }
  1386. };
  1387. try {
  1388. loadingTask.onPassword(updatePassword, exception.code);
  1389. } catch (ex) {
  1390. this._passwordCapability.reject(ex);
  1391. }
  1392. } else {
  1393. this._passwordCapability.reject(new _util.PasswordException(exception.message, exception.code));
  1394. }
  1395. return this._passwordCapability.promise;
  1396. });
  1397. messageHandler.on("DataLoaded", data => {
  1398. loadingTask.onProgress?.({
  1399. loaded: data.length,
  1400. total: data.length
  1401. });
  1402. this.downloadInfoCapability.resolve(data);
  1403. });
  1404. messageHandler.on("StartRenderPage", data => {
  1405. if (this.destroyed) {
  1406. return;
  1407. }
  1408. const page = this.#pageCache.get(data.pageIndex);
  1409. page._startRenderPage(data.transparency, data.cacheKey);
  1410. });
  1411. messageHandler.on("commonobj", ([id, type, exportedData]) => {
  1412. if (this.destroyed) {
  1413. return;
  1414. }
  1415. if (this.commonObjs.has(id)) {
  1416. return;
  1417. }
  1418. switch (type) {
  1419. case "Font":
  1420. const params = this._params;
  1421. if ("error" in exportedData) {
  1422. const exportedError = exportedData.error;
  1423. (0, _util.warn)(`Error during font loading: ${exportedError}`);
  1424. this.commonObjs.resolve(id, exportedError);
  1425. break;
  1426. }
  1427. let fontRegistry = null;
  1428. if (params.pdfBug && globalThis.FontInspector?.enabled) {
  1429. fontRegistry = {
  1430. registerFont(font, url) {
  1431. globalThis.FontInspector.fontAdded(font, url);
  1432. }
  1433. };
  1434. }
  1435. const font = new _font_loader.FontFaceObject(exportedData, {
  1436. isEvalSupported: params.isEvalSupported,
  1437. disableFontFace: params.disableFontFace,
  1438. ignoreErrors: params.ignoreErrors,
  1439. onUnsupportedFeature: this._onUnsupportedFeature.bind(this),
  1440. fontRegistry
  1441. });
  1442. this.fontLoader.bind(font).catch(reason => {
  1443. return messageHandler.sendWithPromise("FontFallback", {
  1444. id
  1445. });
  1446. }).finally(() => {
  1447. if (!params.fontExtraProperties && font.data) {
  1448. font.data = null;
  1449. }
  1450. this.commonObjs.resolve(id, font);
  1451. });
  1452. break;
  1453. case "FontPath":
  1454. case "Image":
  1455. this.commonObjs.resolve(id, exportedData);
  1456. break;
  1457. default:
  1458. throw new Error(`Got unknown common object type ${type}`);
  1459. }
  1460. });
  1461. messageHandler.on("obj", ([id, pageIndex, type, imageData]) => {
  1462. if (this.destroyed) {
  1463. return;
  1464. }
  1465. const pageProxy = this.#pageCache.get(pageIndex);
  1466. if (pageProxy.objs.has(id)) {
  1467. return;
  1468. }
  1469. switch (type) {
  1470. case "Image":
  1471. pageProxy.objs.resolve(id, imageData);
  1472. const MAX_IMAGE_SIZE_TO_STORE = 8000000;
  1473. if (imageData) {
  1474. let length;
  1475. if (imageData.bitmap) {
  1476. const {
  1477. bitmap,
  1478. width,
  1479. height
  1480. } = imageData;
  1481. length = width * height * 4;
  1482. pageProxy._bitmaps.add(bitmap);
  1483. } else {
  1484. length = imageData.data?.length || 0;
  1485. }
  1486. if (length > MAX_IMAGE_SIZE_TO_STORE) {
  1487. pageProxy.cleanupAfterRender = true;
  1488. }
  1489. }
  1490. break;
  1491. case "Pattern":
  1492. pageProxy.objs.resolve(id, imageData);
  1493. break;
  1494. default:
  1495. throw new Error(`Got unknown object type ${type}`);
  1496. }
  1497. });
  1498. messageHandler.on("DocProgress", data => {
  1499. if (this.destroyed) {
  1500. return;
  1501. }
  1502. loadingTask.onProgress?.({
  1503. loaded: data.loaded,
  1504. total: data.total
  1505. });
  1506. });
  1507. messageHandler.on("DocStats", data => {
  1508. if (this.destroyed) {
  1509. return;
  1510. }
  1511. this.#docStats = Object.freeze({
  1512. streamTypes: Object.freeze(data.streamTypes),
  1513. fontTypes: Object.freeze(data.fontTypes)
  1514. });
  1515. });
  1516. messageHandler.on("UnsupportedFeature", this._onUnsupportedFeature.bind(this));
  1517. messageHandler.on("FetchBuiltInCMap", data => {
  1518. if (this.destroyed) {
  1519. return Promise.reject(new Error("Worker was destroyed."));
  1520. }
  1521. if (!this.CMapReaderFactory) {
  1522. return Promise.reject(new Error("CMapReaderFactory not initialized, see the `useWorkerFetch` parameter."));
  1523. }
  1524. return this.CMapReaderFactory.fetch(data);
  1525. });
  1526. messageHandler.on("FetchStandardFontData", data => {
  1527. if (this.destroyed) {
  1528. return Promise.reject(new Error("Worker was destroyed."));
  1529. }
  1530. if (!this.StandardFontDataFactory) {
  1531. return Promise.reject(new Error("StandardFontDataFactory not initialized, see the `useWorkerFetch` parameter."));
  1532. }
  1533. return this.StandardFontDataFactory.fetch(data);
  1534. });
  1535. }
  1536. _onUnsupportedFeature({
  1537. featureId
  1538. }) {
  1539. if (this.destroyed) {
  1540. return;
  1541. }
  1542. this.loadingTask.onUnsupportedFeature?.(featureId);
  1543. }
  1544. getData() {
  1545. return this.messageHandler.sendWithPromise("GetData", null);
  1546. }
  1547. saveDocument() {
  1548. if (this.annotationStorage.size <= 0) {
  1549. (0, _util.warn)("saveDocument called while `annotationStorage` is empty, " + "please use the getData-method instead.");
  1550. }
  1551. return this.messageHandler.sendWithPromise("SaveDocument", {
  1552. isPureXfa: !!this._htmlForXfa,
  1553. numPages: this._numPages,
  1554. annotationStorage: this.annotationStorage.serializable,
  1555. filename: this._fullReader?.filename ?? null
  1556. }).finally(() => {
  1557. this.annotationStorage.resetModified();
  1558. });
  1559. }
  1560. getPage(pageNumber) {
  1561. if (!Number.isInteger(pageNumber) || pageNumber <= 0 || pageNumber > this._numPages) {
  1562. return Promise.reject(new Error("Invalid page request."));
  1563. }
  1564. const pageIndex = pageNumber - 1,
  1565. cachedPromise = this.#pagePromises.get(pageIndex);
  1566. if (cachedPromise) {
  1567. return cachedPromise;
  1568. }
  1569. const promise = this.messageHandler.sendWithPromise("GetPage", {
  1570. pageIndex
  1571. }).then(pageInfo => {
  1572. if (this.destroyed) {
  1573. throw new Error("Transport destroyed");
  1574. }
  1575. const page = new PDFPageProxy(pageIndex, pageInfo, this, this._params.ownerDocument, this._params.pdfBug);
  1576. this.#pageCache.set(pageIndex, page);
  1577. return page;
  1578. });
  1579. this.#pagePromises.set(pageIndex, promise);
  1580. return promise;
  1581. }
  1582. getPageIndex(ref) {
  1583. if (typeof ref !== "object" || ref === null || !Number.isInteger(ref.num) || ref.num < 0 || !Number.isInteger(ref.gen) || ref.gen < 0) {
  1584. return Promise.reject(new Error("Invalid pageIndex request."));
  1585. }
  1586. return this.messageHandler.sendWithPromise("GetPageIndex", {
  1587. num: ref.num,
  1588. gen: ref.gen
  1589. });
  1590. }
  1591. getAnnotations(pageIndex, intent) {
  1592. return this.messageHandler.sendWithPromise("GetAnnotations", {
  1593. pageIndex,
  1594. intent
  1595. });
  1596. }
  1597. getFieldObjects() {
  1598. return this._getFieldObjectsPromise ||= this.messageHandler.sendWithPromise("GetFieldObjects", null);
  1599. }
  1600. hasJSActions() {
  1601. return this._hasJSActionsPromise ||= this.messageHandler.sendWithPromise("HasJSActions", null);
  1602. }
  1603. getCalculationOrderIds() {
  1604. return this.messageHandler.sendWithPromise("GetCalculationOrderIds", null);
  1605. }
  1606. getDestinations() {
  1607. return this.messageHandler.sendWithPromise("GetDestinations", null);
  1608. }
  1609. getDestination(id) {
  1610. if (typeof id !== "string") {
  1611. return Promise.reject(new Error("Invalid destination request."));
  1612. }
  1613. return this.messageHandler.sendWithPromise("GetDestination", {
  1614. id
  1615. });
  1616. }
  1617. getPageLabels() {
  1618. return this.messageHandler.sendWithPromise("GetPageLabels", null);
  1619. }
  1620. getPageLayout() {
  1621. return this.messageHandler.sendWithPromise("GetPageLayout", null);
  1622. }
  1623. getPageMode() {
  1624. return this.messageHandler.sendWithPromise("GetPageMode", null);
  1625. }
  1626. getViewerPreferences() {
  1627. return this.messageHandler.sendWithPromise("GetViewerPreferences", null);
  1628. }
  1629. getOpenAction() {
  1630. return this.messageHandler.sendWithPromise("GetOpenAction", null);
  1631. }
  1632. getAttachments() {
  1633. return this.messageHandler.sendWithPromise("GetAttachments", null);
  1634. }
  1635. getJavaScript() {
  1636. return this.messageHandler.sendWithPromise("GetJavaScript", null);
  1637. }
  1638. getDocJSActions() {
  1639. return this.messageHandler.sendWithPromise("GetDocJSActions", null);
  1640. }
  1641. getPageJSActions(pageIndex) {
  1642. return this.messageHandler.sendWithPromise("GetPageJSActions", {
  1643. pageIndex
  1644. });
  1645. }
  1646. getStructTree(pageIndex) {
  1647. return this.messageHandler.sendWithPromise("GetStructTree", {
  1648. pageIndex
  1649. });
  1650. }
  1651. getOutline() {
  1652. return this.messageHandler.sendWithPromise("GetOutline", null);
  1653. }
  1654. getOptionalContentConfig() {
  1655. return this.messageHandler.sendWithPromise("GetOptionalContentConfig", null).then(results => {
  1656. return new _optional_content_config.OptionalContentConfig(results);
  1657. });
  1658. }
  1659. getPermissions() {
  1660. return this.messageHandler.sendWithPromise("GetPermissions", null);
  1661. }
  1662. getMetadata() {
  1663. return this.#metadataPromise ||= this.messageHandler.sendWithPromise("GetMetadata", null).then(results => {
  1664. return {
  1665. info: results[0],
  1666. metadata: results[1] ? new _metadata.Metadata(results[1]) : null,
  1667. contentDispositionFilename: this._fullReader?.filename ?? null,
  1668. contentLength: this._fullReader?.contentLength ?? null
  1669. };
  1670. });
  1671. }
  1672. getMarkInfo() {
  1673. return this.messageHandler.sendWithPromise("GetMarkInfo", null);
  1674. }
  1675. async startCleanup(keepLoadedFonts = false) {
  1676. if (this.destroyed) {
  1677. return;
  1678. }
  1679. await this.messageHandler.sendWithPromise("Cleanup", null);
  1680. for (const page of this.#pageCache.values()) {
  1681. const cleanupSuccessful = page.cleanup();
  1682. if (!cleanupSuccessful) {
  1683. throw new Error(`startCleanup: Page ${page.pageNumber} is currently rendering.`);
  1684. }
  1685. }
  1686. this.commonObjs.clear();
  1687. if (!keepLoadedFonts) {
  1688. this.fontLoader.clear();
  1689. }
  1690. this.#metadataPromise = null;
  1691. this._getFieldObjectsPromise = null;
  1692. this._hasJSActionsPromise = null;
  1693. }
  1694. get loadingParams() {
  1695. const params = this._params;
  1696. return (0, _util.shadow)(this, "loadingParams", {
  1697. disableAutoFetch: params.disableAutoFetch,
  1698. enableXfa: params.enableXfa
  1699. });
  1700. }
  1701. }
  1702. class PDFObjects {
  1703. #objs = Object.create(null);
  1704. #ensureObj(objId) {
  1705. const obj = this.#objs[objId];
  1706. if (obj) {
  1707. return obj;
  1708. }
  1709. return this.#objs[objId] = {
  1710. capability: (0, _util.createPromiseCapability)(),
  1711. data: null
  1712. };
  1713. }
  1714. get(objId, callback = null) {
  1715. if (callback) {
  1716. const obj = this.#ensureObj(objId);
  1717. obj.capability.promise.then(() => callback(obj.data));
  1718. return null;
  1719. }
  1720. const obj = this.#objs[objId];
  1721. if (!obj?.capability.settled) {
  1722. throw new Error(`Requesting object that isn't resolved yet ${objId}.`);
  1723. }
  1724. return obj.data;
  1725. }
  1726. has(objId) {
  1727. const obj = this.#objs[objId];
  1728. return obj?.capability.settled || false;
  1729. }
  1730. resolve(objId, data = null) {
  1731. const obj = this.#ensureObj(objId);
  1732. obj.data = data;
  1733. obj.capability.resolve();
  1734. }
  1735. clear() {
  1736. this.#objs = Object.create(null);
  1737. }
  1738. }
  1739. class RenderTask {
  1740. #internalRenderTask = null;
  1741. constructor(internalRenderTask) {
  1742. this.#internalRenderTask = internalRenderTask;
  1743. this.onContinue = null;
  1744. }
  1745. get promise() {
  1746. return this.#internalRenderTask.capability.promise;
  1747. }
  1748. cancel() {
  1749. this.#internalRenderTask.cancel();
  1750. }
  1751. get separateAnnots() {
  1752. const {
  1753. separateAnnots
  1754. } = this.#internalRenderTask.operatorList;
  1755. if (!separateAnnots) {
  1756. return false;
  1757. }
  1758. const {
  1759. annotationCanvasMap
  1760. } = this.#internalRenderTask;
  1761. return separateAnnots.form || separateAnnots.canvas && annotationCanvasMap?.size > 0;
  1762. }
  1763. }
  1764. exports.RenderTask = RenderTask;
  1765. class InternalRenderTask {
  1766. static #canvasInUse = new WeakSet();
  1767. constructor({
  1768. callback,
  1769. params,
  1770. objs,
  1771. commonObjs,
  1772. annotationCanvasMap,
  1773. operatorList,
  1774. pageIndex,
  1775. canvasFactory,
  1776. useRequestAnimationFrame = false,
  1777. pdfBug = false,
  1778. pageColors = null
  1779. }) {
  1780. this.callback = callback;
  1781. this.params = params;
  1782. this.objs = objs;
  1783. this.commonObjs = commonObjs;
  1784. this.annotationCanvasMap = annotationCanvasMap;
  1785. this.operatorListIdx = null;
  1786. this.operatorList = operatorList;
  1787. this._pageIndex = pageIndex;
  1788. this.canvasFactory = canvasFactory;
  1789. this._pdfBug = pdfBug;
  1790. this.pageColors = pageColors;
  1791. this.running = false;
  1792. this.graphicsReadyCallback = null;
  1793. this.graphicsReady = false;
  1794. this._useRequestAnimationFrame = useRequestAnimationFrame === true && typeof window !== "undefined";
  1795. this.cancelled = false;
  1796. this.capability = (0, _util.createPromiseCapability)();
  1797. this.task = new RenderTask(this);
  1798. this._cancelBound = this.cancel.bind(this);
  1799. this._continueBound = this._continue.bind(this);
  1800. this._scheduleNextBound = this._scheduleNext.bind(this);
  1801. this._nextBound = this._next.bind(this);
  1802. this._canvas = params.canvasContext.canvas;
  1803. }
  1804. get completed() {
  1805. return this.capability.promise.catch(function () {});
  1806. }
  1807. initializeGraphics({
  1808. transparency = false,
  1809. optionalContentConfig
  1810. }) {
  1811. if (this.cancelled) {
  1812. return;
  1813. }
  1814. if (this._canvas) {
  1815. if (InternalRenderTask.#canvasInUse.has(this._canvas)) {
  1816. throw new Error("Cannot use the same canvas during multiple render() operations. " + "Use different canvas or ensure previous operations were " + "cancelled or completed.");
  1817. }
  1818. InternalRenderTask.#canvasInUse.add(this._canvas);
  1819. }
  1820. if (this._pdfBug && globalThis.StepperManager?.enabled) {
  1821. this.stepper = globalThis.StepperManager.create(this._pageIndex);
  1822. this.stepper.init(this.operatorList);
  1823. this.stepper.nextBreakPoint = this.stepper.getNextBreakPoint();
  1824. }
  1825. const {
  1826. canvasContext,
  1827. viewport,
  1828. transform,
  1829. background
  1830. } = this.params;
  1831. this.gfx = new _canvas.CanvasGraphics(canvasContext, this.commonObjs, this.objs, this.canvasFactory, optionalContentConfig, this.annotationCanvasMap, this.pageColors);
  1832. this.gfx.beginDrawing({
  1833. transform,
  1834. viewport,
  1835. transparency,
  1836. background
  1837. });
  1838. this.operatorListIdx = 0;
  1839. this.graphicsReady = true;
  1840. this.graphicsReadyCallback?.();
  1841. }
  1842. cancel(error = null) {
  1843. this.running = false;
  1844. this.cancelled = true;
  1845. this.gfx?.endDrawing();
  1846. if (this._canvas) {
  1847. InternalRenderTask.#canvasInUse.delete(this._canvas);
  1848. }
  1849. this.callback(error || new _display_utils.RenderingCancelledException(`Rendering cancelled, page ${this._pageIndex + 1}`, "canvas"));
  1850. }
  1851. operatorListChanged() {
  1852. if (!this.graphicsReady) {
  1853. if (!this.graphicsReadyCallback) {
  1854. this.graphicsReadyCallback = this._continueBound;
  1855. }
  1856. return;
  1857. }
  1858. this.stepper?.updateOperatorList(this.operatorList);
  1859. if (this.running) {
  1860. return;
  1861. }
  1862. this._continue();
  1863. }
  1864. _continue() {
  1865. this.running = true;
  1866. if (this.cancelled) {
  1867. return;
  1868. }
  1869. if (this.task.onContinue) {
  1870. this.task.onContinue(this._scheduleNextBound);
  1871. } else {
  1872. this._scheduleNext();
  1873. }
  1874. }
  1875. _scheduleNext() {
  1876. if (this._useRequestAnimationFrame) {
  1877. window.requestAnimationFrame(() => {
  1878. this._nextBound().catch(this._cancelBound);
  1879. });
  1880. } else {
  1881. Promise.resolve().then(this._nextBound).catch(this._cancelBound);
  1882. }
  1883. }
  1884. async _next() {
  1885. if (this.cancelled) {
  1886. return;
  1887. }
  1888. this.operatorListIdx = this.gfx.executeOperatorList(this.operatorList, this.operatorListIdx, this._continueBound, this.stepper);
  1889. if (this.operatorListIdx === this.operatorList.argsArray.length) {
  1890. this.running = false;
  1891. if (this.operatorList.lastChunk) {
  1892. this.gfx.endDrawing();
  1893. if (this._canvas) {
  1894. InternalRenderTask.#canvasInUse.delete(this._canvas);
  1895. }
  1896. this.callback();
  1897. }
  1898. }
  1899. }
  1900. }
  1901. const version = '3.0.279';
  1902. exports.version = version;
  1903. const build = 'd0823066c';
  1904. exports.build = build;