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

copy from: events is series

Browse Source
This commit is contained in:
Simon Martín 2018-06-21 15:58:23 +02:00
parent 195a4866c3
commit 06c40a396b
1 changed files with 5 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
app/controllers/copy_controller.js
View File

@ -114,6 +114,7 @@ function handleCopyFrom (logger) {
} }
req req
.on('data', data => isGzip ? metrics.addGzipSize(data.length) : undefined)
.on('error', err => { .on('error', err => {
metrics.end(null, err); metrics.end(null, err);
pgstream.emit('error', err); pgstream.emit('error', err);
@ -122,9 +123,10 @@ function handleCopyFrom (logger) {
const err = new Error('Connection closed by client'); const err = new Error('Connection closed by client');
pgstream.emit('cancelQuery', err); pgstream.emit('cancelQuery', err);
pgstream.emit('error', err); pgstream.emit('error', err);
}); })
.pipe(isGzip ? zlib.createGunzip() : new PassThrough())
pgstream .on('data', data => metrics.addSize(data.length))
.pipe(pgstream)
.on('error', (err) => { .on('error', (err) => {
metrics.end(null, err); metrics.end(null, err);
req.unpipe(pgstream); req.unpipe(pgstream);
@ -144,13 +146,6 @@ function handleCopyFrom (logger) {
total_rows: rows total_rows: rows
}); });
}); });
const middleStream = isGzip ? zlib.createGunzip() : new PassThrough();
req
.on('data', data => isGzip ? metrics.addGzipSize(data.length) : undefined)
.pipe(middleStream)
.on('data', data => metrics.addSize(data.length))
.pipe(pgstream);
} }
); );
}; };