cartodb/CartoDB-SQL-API
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Unpipe streams when error

Browse Source
This commit is contained in:
Daniel García Aubert 2019-05-16 17:24:21 +02:00
parent 9b21b813be
commit 17de6e8d4f
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
app/controllers/copy_controller.js
View File

@ -112,8 +112,8 @@ function handleCopyFrom (logger) {
const COPY_FROM_MAX_POST_SIZE_PRETTY = global.settings.copy_from_max_post_size_pretty || '2 GB';
const streamCopy = new StreamCopy(sql, userDbParams, logger);
const metrics = new StreamCopyMetrics(logger, 'copyfrom', sql, user, isGzip);
const decompress = isGzip ? zlib.createGunzip() : new PassThrough();
const metrics = new StreamCopyMetrics(logger, 'copyfrom', sql, user, isGzip);
streamCopy.getPGStream(StreamCopy.ACTION_FROM, (err, pgstream) => {
if (err) {
@ -155,7 +155,8 @@ function handleCopyFrom (logger) {
.pipe(pgstream)
.on('error', err => {
metrics.end(null, err);
req.unpipe(pgstream);
req.unpipe(decompress);
decompress.unpipe(pgstream);
return next(err);
})
.on('end', () => {