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

Do not resume internal connection stream (handled properly in the pg-copy-stream module)

Browse Source
This commit is contained in:
Daniel García Aubert 2019-05-24 17:31:56 +02:00
parent e57f7b6ecf
commit 19b9aab042
1 changed files with 4 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
app/services/stream_copy.js
View File

@ -46,17 +46,14 @@ module.exports = class StreamCopy {
this.clientProcessID = client.processID;
const streamMaker = action === ACTION_TO ? copyTo : copyFrom;
this.stream = streamMaker(this.sql);
this.stream = action === ACTION_TO ? copyTo(this.sql) : copyFrom(this.sql);
const pgstream = client.query(this.stream);
if (action === ACTION_TO) {
pgstream.on('end', () => {
pgstream.connection.stream.resume();
done();
});
pgstream.on('end', () => done());
} else if (action === ACTION_FROM) {
pgstream.on('finish', () => done())
pgstream.on('finish', () => done());
}
pgstream.on('error', err => done(err));