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

fix req events

Browse Source
This commit is contained in:
Simon Martín 2018-05-29 16:19:53 +02:00
parent 5f8533bf99
commit a083eb909c
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
app/services/stream_copy.js
View File

@ -44,7 +44,7 @@ module.exports = {
pgstream
.on('error', err => {
req.unpipe(pgstream);
return cb(err);
return cb(err);
})
.on('end', function () {
metrics.end(copyFromStream.rowCount);
@ -53,10 +53,6 @@ module.exports = {
let requestEnded = false;
if (gzip) {
req = req.pipe(zlib.createGunzip());
}
req
.on('error', err => {
req.unpipe(pgstream);
@ -71,8 +67,13 @@ module.exports = {
}
})
.on('data', data => metrics.size += data.length)
.on('end', () => requestEnded = true)
.pipe(pgstream);
.on('end', () => requestEnded = true);
if (gzip) {
req.pipe(zlib.createGunzip()).pipe(pgstream);
} else {
req.pipe(pgstream);
}
});
}
};