123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666 |
- /**
- * @licstart The following is the entire license notice for the
- * Javascript code in this page
- *
- * Copyright 2019 Mozilla Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- * @licend The above is the entire license notice for the
- * Javascript code in this page
- */
- "use strict";
- Object.defineProperty(exports, "__esModule", {
- value: true
- });
- exports.PDFNodeStream = void 0;
- var _regenerator = _interopRequireDefault(require("@babel/runtime/regenerator"));
- var _util = require("../shared/util");
- var _network_utils = require("./network_utils");
- function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { "default": obj }; }
- function _typeof(obj) { if (typeof Symbol === "function" && typeof Symbol.iterator === "symbol") { _typeof = function _typeof(obj) { return typeof obj; }; } else { _typeof = function _typeof(obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; }; } return _typeof(obj); }
- function _possibleConstructorReturn(self, call) { if (call && (_typeof(call) === "object" || typeof call === "function")) { return call; } return _assertThisInitialized(self); }
- function _assertThisInitialized(self) { if (self === void 0) { throw new ReferenceError("this hasn't been initialised - super() hasn't been called"); } return self; }
- function _getPrototypeOf(o) { _getPrototypeOf = Object.setPrototypeOf ? Object.getPrototypeOf : function _getPrototypeOf(o) { return o.__proto__ || Object.getPrototypeOf(o); }; return _getPrototypeOf(o); }
- function _inherits(subClass, superClass) { if (typeof superClass !== "function" && superClass !== null) { throw new TypeError("Super expression must either be null or a function"); } subClass.prototype = Object.create(superClass && superClass.prototype, { constructor: { value: subClass, writable: true, configurable: true } }); if (superClass) _setPrototypeOf(subClass, superClass); }
- function _setPrototypeOf(o, p) { _setPrototypeOf = Object.setPrototypeOf || function _setPrototypeOf(o, p) { o.__proto__ = p; return o; }; return _setPrototypeOf(o, p); }
- function asyncGeneratorStep(gen, resolve, reject, _next, _throw, key, arg) { try { var info = gen[key](arg); var value = info.value; } catch (error) { reject(error); return; } if (info.done) { resolve(value); } else { Promise.resolve(value).then(_next, _throw); } }
- function _asyncToGenerator(fn) { return function () { var self = this, args = arguments; return new Promise(function (resolve, reject) { var gen = fn.apply(self, args); function _next(value) { asyncGeneratorStep(gen, resolve, reject, _next, _throw, "next", value); } function _throw(err) { asyncGeneratorStep(gen, resolve, reject, _next, _throw, "throw", err); } _next(undefined); }); }; }
- function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
- function _defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } }
- function _createClass(Constructor, protoProps, staticProps) { if (protoProps) _defineProperties(Constructor.prototype, protoProps); if (staticProps) _defineProperties(Constructor, staticProps); return Constructor; }
- var fs = require('fs');
- var http = require('http');
- var https = require('https');
- var url = require('url');
- var fileUriRegex = /^file:\/\/\/[a-zA-Z]:\//;
- function parseUrl(sourceUrl) {
- var parsedUrl = url.parse(sourceUrl);
- if (parsedUrl.protocol === 'file:' || parsedUrl.host) {
- return parsedUrl;
- }
- if (/^[a-z]:[/\\]/i.test(sourceUrl)) {
- return url.parse("file:///".concat(sourceUrl));
- }
- if (!parsedUrl.host) {
- parsedUrl.protocol = 'file:';
- }
- return parsedUrl;
- }
- var PDFNodeStream =
- /*#__PURE__*/
- function () {
- function PDFNodeStream(source) {
- _classCallCheck(this, PDFNodeStream);
- this.source = source;
- this.url = parseUrl(source.url);
- this.isHttp = this.url.protocol === 'http:' || this.url.protocol === 'https:';
- this.isFsUrl = this.url.protocol === 'file:';
- this.httpHeaders = this.isHttp && source.httpHeaders || {};
- this._fullRequestReader = null;
- this._rangeRequestReaders = [];
- }
- _createClass(PDFNodeStream, [{
- key: "getFullReader",
- value: function getFullReader() {
- (0, _util.assert)(!this._fullRequestReader);
- this._fullRequestReader = this.isFsUrl ? new PDFNodeStreamFsFullReader(this) : new PDFNodeStreamFullReader(this);
- return this._fullRequestReader;
- }
- }, {
- key: "getRangeReader",
- value: function getRangeReader(start, end) {
- if (end <= this._progressiveDataLength) {
- return null;
- }
- var rangeReader = this.isFsUrl ? new PDFNodeStreamFsRangeReader(this, start, end) : new PDFNodeStreamRangeReader(this, start, end);
- this._rangeRequestReaders.push(rangeReader);
- return rangeReader;
- }
- }, {
- key: "cancelAllRequests",
- value: function cancelAllRequests(reason) {
- if (this._fullRequestReader) {
- this._fullRequestReader.cancel(reason);
- }
- var readers = this._rangeRequestReaders.slice(0);
- readers.forEach(function (reader) {
- reader.cancel(reason);
- });
- }
- }, {
- key: "_progressiveDataLength",
- get: function get() {
- return this._fullRequestReader ? this._fullRequestReader._loaded : 0;
- }
- }]);
- return PDFNodeStream;
- }();
- exports.PDFNodeStream = PDFNodeStream;
- var BaseFullReader =
- /*#__PURE__*/
- function () {
- function BaseFullReader(stream) {
- _classCallCheck(this, BaseFullReader);
- this._url = stream.url;
- this._done = false;
- this._storedError = null;
- this.onProgress = null;
- var source = stream.source;
- this._contentLength = source.length;
- this._loaded = 0;
- this._filename = null;
- this._disableRange = source.disableRange || false;
- this._rangeChunkSize = source.rangeChunkSize;
- if (!this._rangeChunkSize && !this._disableRange) {
- this._disableRange = true;
- }
- this._isStreamingSupported = !source.disableStream;
- this._isRangeSupported = !source.disableRange;
- this._readableStream = null;
- this._readCapability = (0, _util.createPromiseCapability)();
- this._headersCapability = (0, _util.createPromiseCapability)();
- }
- _createClass(BaseFullReader, [{
- key: "read",
- value: function () {
- var _read = _asyncToGenerator(
- /*#__PURE__*/
- _regenerator["default"].mark(function _callee() {
- var chunk, buffer;
- return _regenerator["default"].wrap(function _callee$(_context) {
- while (1) {
- switch (_context.prev = _context.next) {
- case 0:
- _context.next = 2;
- return this._readCapability.promise;
- case 2:
- if (!this._done) {
- _context.next = 4;
- break;
- }
- return _context.abrupt("return", {
- value: undefined,
- done: true
- });
- case 4:
- if (!this._storedError) {
- _context.next = 6;
- break;
- }
- throw this._storedError;
- case 6:
- chunk = this._readableStream.read();
- if (!(chunk === null)) {
- _context.next = 10;
- break;
- }
- this._readCapability = (0, _util.createPromiseCapability)();
- return _context.abrupt("return", this.read());
- case 10:
- this._loaded += chunk.length;
- if (this.onProgress) {
- this.onProgress({
- loaded: this._loaded,
- total: this._contentLength
- });
- }
- buffer = new Uint8Array(chunk).buffer;
- return _context.abrupt("return", {
- value: buffer,
- done: false
- });
- case 14:
- case "end":
- return _context.stop();
- }
- }
- }, _callee, this);
- }));
- function read() {
- return _read.apply(this, arguments);
- }
- return read;
- }()
- }, {
- key: "cancel",
- value: function cancel(reason) {
- if (!this._readableStream) {
- this._error(reason);
- return;
- }
- this._readableStream.destroy(reason);
- }
- }, {
- key: "_error",
- value: function _error(reason) {
- this._storedError = reason;
- this._readCapability.resolve();
- }
- }, {
- key: "_setReadableStream",
- value: function _setReadableStream(readableStream) {
- var _this = this;
- this._readableStream = readableStream;
- readableStream.on('readable', function () {
- _this._readCapability.resolve();
- });
- readableStream.on('end', function () {
- readableStream.destroy();
- _this._done = true;
- _this._readCapability.resolve();
- });
- readableStream.on('error', function (reason) {
- _this._error(reason);
- });
- if (!this._isStreamingSupported && this._isRangeSupported) {
- this._error(new _util.AbortException('streaming is disabled'));
- }
- if (this._storedError) {
- this._readableStream.destroy(this._storedError);
- }
- }
- }, {
- key: "headersReady",
- get: function get() {
- return this._headersCapability.promise;
- }
- }, {
- key: "filename",
- get: function get() {
- return this._filename;
- }
- }, {
- key: "contentLength",
- get: function get() {
- return this._contentLength;
- }
- }, {
- key: "isRangeSupported",
- get: function get() {
- return this._isRangeSupported;
- }
- }, {
- key: "isStreamingSupported",
- get: function get() {
- return this._isStreamingSupported;
- }
- }]);
- return BaseFullReader;
- }();
- var BaseRangeReader =
- /*#__PURE__*/
- function () {
- function BaseRangeReader(stream) {
- _classCallCheck(this, BaseRangeReader);
- this._url = stream.url;
- this._done = false;
- this._storedError = null;
- this.onProgress = null;
- this._loaded = 0;
- this._readableStream = null;
- this._readCapability = (0, _util.createPromiseCapability)();
- var source = stream.source;
- this._isStreamingSupported = !source.disableStream;
- }
- _createClass(BaseRangeReader, [{
- key: "read",
- value: function () {
- var _read2 = _asyncToGenerator(
- /*#__PURE__*/
- _regenerator["default"].mark(function _callee2() {
- var chunk, buffer;
- return _regenerator["default"].wrap(function _callee2$(_context2) {
- while (1) {
- switch (_context2.prev = _context2.next) {
- case 0:
- _context2.next = 2;
- return this._readCapability.promise;
- case 2:
- if (!this._done) {
- _context2.next = 4;
- break;
- }
- return _context2.abrupt("return", {
- value: undefined,
- done: true
- });
- case 4:
- if (!this._storedError) {
- _context2.next = 6;
- break;
- }
- throw this._storedError;
- case 6:
- chunk = this._readableStream.read();
- if (!(chunk === null)) {
- _context2.next = 10;
- break;
- }
- this._readCapability = (0, _util.createPromiseCapability)();
- return _context2.abrupt("return", this.read());
- case 10:
- this._loaded += chunk.length;
- if (this.onProgress) {
- this.onProgress({
- loaded: this._loaded
- });
- }
- buffer = new Uint8Array(chunk).buffer;
- return _context2.abrupt("return", {
- value: buffer,
- done: false
- });
- case 14:
- case "end":
- return _context2.stop();
- }
- }
- }, _callee2, this);
- }));
- function read() {
- return _read2.apply(this, arguments);
- }
- return read;
- }()
- }, {
- key: "cancel",
- value: function cancel(reason) {
- if (!this._readableStream) {
- this._error(reason);
- return;
- }
- this._readableStream.destroy(reason);
- }
- }, {
- key: "_error",
- value: function _error(reason) {
- this._storedError = reason;
- this._readCapability.resolve();
- }
- }, {
- key: "_setReadableStream",
- value: function _setReadableStream(readableStream) {
- var _this2 = this;
- this._readableStream = readableStream;
- readableStream.on('readable', function () {
- _this2._readCapability.resolve();
- });
- readableStream.on('end', function () {
- readableStream.destroy();
- _this2._done = true;
- _this2._readCapability.resolve();
- });
- readableStream.on('error', function (reason) {
- _this2._error(reason);
- });
- if (this._storedError) {
- this._readableStream.destroy(this._storedError);
- }
- }
- }, {
- key: "isStreamingSupported",
- get: function get() {
- return this._isStreamingSupported;
- }
- }]);
- return BaseRangeReader;
- }();
- function createRequestOptions(url, headers) {
- return {
- protocol: url.protocol,
- auth: url.auth,
- host: url.hostname,
- port: url.port,
- path: url.path,
- method: 'GET',
- headers: headers
- };
- }
- var PDFNodeStreamFullReader =
- /*#__PURE__*/
- function (_BaseFullReader) {
- _inherits(PDFNodeStreamFullReader, _BaseFullReader);
- function PDFNodeStreamFullReader(stream) {
- var _this3;
- _classCallCheck(this, PDFNodeStreamFullReader);
- _this3 = _possibleConstructorReturn(this, _getPrototypeOf(PDFNodeStreamFullReader).call(this, stream));
- var handleResponse = function handleResponse(response) {
- if (response.statusCode === 404) {
- var error = new _util.MissingPDFException("Missing PDF \"".concat(_this3._url, "\"."));
- _this3._storedError = error;
- _this3._headersCapability.reject(error);
- return;
- }
- _this3._headersCapability.resolve();
- _this3._setReadableStream(response);
- var getResponseHeader = function getResponseHeader(name) {
- return _this3._readableStream.headers[name.toLowerCase()];
- };
- var _validateRangeRequest = (0, _network_utils.validateRangeRequestCapabilities)({
- getResponseHeader: getResponseHeader,
- isHttp: stream.isHttp,
- rangeChunkSize: _this3._rangeChunkSize,
- disableRange: _this3._disableRange
- }),
- allowRangeRequests = _validateRangeRequest.allowRangeRequests,
- suggestedLength = _validateRangeRequest.suggestedLength;
- _this3._isRangeSupported = allowRangeRequests;
- _this3._contentLength = suggestedLength || _this3._contentLength;
- _this3._filename = (0, _network_utils.extractFilenameFromHeader)(getResponseHeader);
- };
- _this3._request = null;
- if (_this3._url.protocol === 'http:') {
- _this3._request = http.request(createRequestOptions(_this3._url, stream.httpHeaders), handleResponse);
- } else {
- _this3._request = https.request(createRequestOptions(_this3._url, stream.httpHeaders), handleResponse);
- }
- _this3._request.on('error', function (reason) {
- _this3._storedError = reason;
- _this3._headersCapability.reject(reason);
- });
- _this3._request.end();
- return _this3;
- }
- return PDFNodeStreamFullReader;
- }(BaseFullReader);
- var PDFNodeStreamRangeReader =
- /*#__PURE__*/
- function (_BaseRangeReader) {
- _inherits(PDFNodeStreamRangeReader, _BaseRangeReader);
- function PDFNodeStreamRangeReader(stream, start, end) {
- var _this4;
- _classCallCheck(this, PDFNodeStreamRangeReader);
- _this4 = _possibleConstructorReturn(this, _getPrototypeOf(PDFNodeStreamRangeReader).call(this, stream));
- _this4._httpHeaders = {};
- for (var property in stream.httpHeaders) {
- var value = stream.httpHeaders[property];
- if (typeof value === 'undefined') {
- continue;
- }
- _this4._httpHeaders[property] = value;
- }
- _this4._httpHeaders['Range'] = "bytes=".concat(start, "-").concat(end - 1);
- var handleResponse = function handleResponse(response) {
- if (response.statusCode === 404) {
- var error = new _util.MissingPDFException("Missing PDF \"".concat(_this4._url, "\"."));
- _this4._storedError = error;
- return;
- }
- _this4._setReadableStream(response);
- };
- _this4._request = null;
- if (_this4._url.protocol === 'http:') {
- _this4._request = http.request(createRequestOptions(_this4._url, _this4._httpHeaders), handleResponse);
- } else {
- _this4._request = https.request(createRequestOptions(_this4._url, _this4._httpHeaders), handleResponse);
- }
- _this4._request.on('error', function (reason) {
- _this4._storedError = reason;
- });
- _this4._request.end();
- return _this4;
- }
- return PDFNodeStreamRangeReader;
- }(BaseRangeReader);
- var PDFNodeStreamFsFullReader =
- /*#__PURE__*/
- function (_BaseFullReader2) {
- _inherits(PDFNodeStreamFsFullReader, _BaseFullReader2);
- function PDFNodeStreamFsFullReader(stream) {
- var _this5;
- _classCallCheck(this, PDFNodeStreamFsFullReader);
- _this5 = _possibleConstructorReturn(this, _getPrototypeOf(PDFNodeStreamFsFullReader).call(this, stream));
- var path = decodeURIComponent(_this5._url.path);
- if (fileUriRegex.test(_this5._url.href)) {
- path = path.replace(/^\//, '');
- }
- fs.lstat(path, function (error, stat) {
- if (error) {
- if (error.code === 'ENOENT') {
- error = new _util.MissingPDFException("Missing PDF \"".concat(path, "\"."));
- }
- _this5._storedError = error;
- _this5._headersCapability.reject(error);
- return;
- }
- _this5._contentLength = stat.size;
- _this5._setReadableStream(fs.createReadStream(path));
- _this5._headersCapability.resolve();
- });
- return _this5;
- }
- return PDFNodeStreamFsFullReader;
- }(BaseFullReader);
- var PDFNodeStreamFsRangeReader =
- /*#__PURE__*/
- function (_BaseRangeReader2) {
- _inherits(PDFNodeStreamFsRangeReader, _BaseRangeReader2);
- function PDFNodeStreamFsRangeReader(stream, start, end) {
- var _this6;
- _classCallCheck(this, PDFNodeStreamFsRangeReader);
- _this6 = _possibleConstructorReturn(this, _getPrototypeOf(PDFNodeStreamFsRangeReader).call(this, stream));
- var path = decodeURIComponent(_this6._url.path);
- if (fileUriRegex.test(_this6._url.href)) {
- path = path.replace(/^\//, '');
- }
- _this6._setReadableStream(fs.createReadStream(path, {
- start: start,
- end: end - 1
- }));
- return _this6;
- }
- return PDFNodeStreamFsRangeReader;
- }(BaseRangeReader);
|