BlockStorage/repertory-ui
Archived
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Catch parse exception

Browse Source
This commit is contained in:
sgraves76
2019-08-27 16:34:32 -05:00
parent c1a9e6cc38
commit d70afb349b
1 changed files with 31 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

58
src/helpers.js
View File

@@ -183,38 +183,42 @@ module.exports.downloadFile = (url, destination, progressCallback, completeCallb
responseType: 'stream', responseType: 'stream',
}) })
.then(response => { .then(response => {
const total = parseInt(response.headers['content-length'], 10); try {
if (total === 0) { const total = parseInt(response.headers['content-length'], 10);
completeCallback(Error('No data available for download')); if (total === 0) {
} else { completeCallback(Error('No data available for download'));
const stream = fs.createWriteStream(destination); } else {
const stream = fs.createWriteStream(destination);
let downloaded = 0; let downloaded = 0;
response.data.on('data', (chunk) => { response.data.on('data', (chunk) => {
stream.write(Buffer.from(chunk)); stream.write(Buffer.from(chunk));
downloaded += chunk.length; downloaded += chunk.length;
if (progressCallback) { if (progressCallback) {
progressCallback((downloaded / total * 100.0).toFixed(2)); progressCallback((downloaded / total * 100.0).toFixed(2));
}
});
response.data.on('end', () => {
stream.end(() => {
if (downloaded === 0) {
completeCallback(Error('Received 0 bytes'));
} else if (downloaded !== total) {
completeCallback(Error('Received incorrect number of bytes'));
} else {
completeCallback();
} }
}); });
});
response.data.on('error', error => { response.data.on('end', () => {
stream.end(() => { stream.end(() => {
completeCallback(error); if (downloaded === 0) {
completeCallback(Error('Received 0 bytes'));
} else if (downloaded !== total) {
completeCallback(Error('Received incorrect number of bytes'));
} else {
completeCallback();
}
});
}); });
});
response.data.on('error', error => {
stream.end(() => {
completeCallback(error);
});
});
}
} catch (error) {
completeCallback(error);
} }
}) })
.catch(error => { .catch(error => {