bugfix: correctly create new connection for canceling copy to query

anton · brianc · commit 8ea2f259edfc · 2013-01-20T19:45:41.000-06:00
diff --git a/lib/client.js b/lib/client.js
@@ -111,7 +111,9 @@ p.connect = function(callback) {
     con.on('copyOutResponse', function(msg) {
       if (self.activeQuery.stream  === undefined) {
         self.activeQuery._canceledDueToError = new Error('No destination stream defined');
-        (new self.constructor(self.config)).cancel(self, self.activeQuery);
+        //canceling query requires creation of new connection 
+        //look for postgres frontend/backend protocol
+        (new self.constructor({port: self.port, host: self.host})).cancel(self, self.activeQuery);
       }
     });
     con.on('copyData', function (msg) {
diff --git a/lib/native/index.js b/lib/native/index.js
@@ -203,7 +203,7 @@ var clientBuilder = function(config) {
   connection.on('copyOutResponse', function(msg) {
     if (connection._activeQuery.stream  === undefined) {
       connection._activeQuery._canceledDueToError = new Error('No destination stream defined');
-      (new clientBuilder(connection.config)).cancel(connection, connection._activeQuery);
+      (new clientBuilder({port: connection.port, host: connection.host})).cancel(connection, connection._activeQuery);
    }
   });
   connection.on('copyData', function (chunk) {

Original file line number	Diff line number	Diff line change
`@@ -203,7 +203,7 @@ var clientBuilder = function(config) {`
`203`	`203`	`connection.on('copyOutResponse', function(msg) {`
`204`	`204`	`if (connection._activeQuery.stream === undefined) {`
`205`	`205`	`connection._activeQuery._canceledDueToError = new Error('No destination stream defined');`
`206`		`- (new clientBuilder(connection.config)).cancel(connection, connection._activeQuery);`
	`206`	`+ (new clientBuilder({port: connection.port, host: connection.host})).cancel(connection, connection._activeQuery);`
`207`	`207`	`}`
`208`	`208`	`});`
`209`	`209`	`connection.on('copyData', function (chunk) {`