api.js 55 KB

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