Skip to content

Commit

Permalink
Attempt to throw MissingPDFException when applicable in `node_strea…
Browse files Browse the repository at this point in the history
…m.js` (issue 9791)
  • Loading branch information
Snuffleupagus committed Aug 6, 2018
1 parent c8ee633 commit f78efd8
Show file tree
Hide file tree
Showing 2 changed files with 25 additions and 14 deletions.
34 changes: 25 additions & 9 deletions src/display/node_stream.js
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ let https = __non_webpack_require__('https');
let url = __non_webpack_require__('url');

import {
AbortException, assert, createPromiseCapability
AbortException, assert, createPromiseCapability, MissingPDFException
} from '../shared/util';
import {
extractFilenameFromHeader, validateRangeRequestCapabilities
Expand Down Expand Up @@ -300,6 +300,12 @@ class PDFNodeStreamFullReader extends BaseFullReader {
super(stream);

let handleResponse = (response) => {
if (response.statusCode === 404) {
const error = new MissingPDFException(`Missing PDF "${this._url}".`);
this._storedError = error;
this._headersCapability.reject(error);
return;
}
this._headersCapability.resolve();
this._setReadableStream(response);

Expand Down Expand Up @@ -359,17 +365,24 @@ class PDFNodeStreamRangeReader extends BaseRangeReader {
}
this._httpHeaders['Range'] = `bytes=${start}-${end - 1}`;

let handleResponse = (response) => {
if (response.statusCode === 404) {
const error = new MissingPDFException(`Missing PDF "${this._url}".`);
this._storedError = error;
return;
}
this._setReadableStream(response);
};

this._request = null;
if (this._url.protocol === 'http:') {
this._request = http.request(createRequestOptions(
this._url, this._httpHeaders), (response) => {
this._setReadableStream(response);
});
this._request = http.request(
createRequestOptions(this._url, this._httpHeaders),
handleResponse);
} else {
this._request = https.request(createRequestOptions(
this._url, this._httpHeaders), (response) => {
this._setReadableStream(response);
});
this._request = https.request(
createRequestOptions(this._url, this._httpHeaders),
handleResponse);
}

this._request.on('error', (reason) => {
Expand All @@ -392,6 +405,9 @@ class PDFNodeStreamFsFullReader extends BaseFullReader {

fs.lstat(path, (error, stat) => {
if (error) {
if (error.code === 'ENOENT') {
error = new MissingPDFException(`Missing PDF "${path}".`);
}
this._storedError = error;
this._headersCapability.reject(error);
return;
Expand Down
5 changes: 0 additions & 5 deletions test/unit/api_spec.js
Original file line number Diff line number Diff line change
Expand Up @@ -164,11 +164,6 @@ describe('api', function() {
});
});
it('creates pdf doc from non-existent URL', function(done) {
if (isNodeJS()) {
pending('Fix `src/display/node_stream.js` to actually throw ' +
'a `MissingPDFException` in all cases where a PDF file ' +
'cannot be found, such that this test-case can be enabled.');
}
var loadingTask = getDocument(
buildGetDocumentParams('non-existent.pdf'));
loadingTask.promise.then(function(error) {
Expand Down

0 comments on commit f78efd8

Please sign in to comment.