send CopyFail when user close connection

2018-05-30 12:59:49 +02:00 · 2018-05-30 12:59:49 +02:00 · 310f652ae4
commit 310f652ae4
parent a083eb909c
1 changed files with 2 additions and 1 deletions
--- a/app/services/stream_copy.js
+++ b/app/services/stream_copy.js
@ -61,8 +61,9 @@ module.exports = {
                })
                .on('close', () => {
                    if (!requestEnded) {
+                        const connection = client.connection;
+                        connection.sendCopyFail();
                        req.unpipe(pgstream);
-                        pgstream.end();
                        return cb(new Error('Connection closed by client'));
                    }
                })