@clickhouse/client - npm Package Compare versions

Comparing version 0.2.2 to 0.2.3

dist/connection/node_base_connection.d.ts

@@ -47,2 +47,3 @@ /// <reference types="node" />
     exec(params: ConnBaseQueryParams): Promise<ConnExecResult<Stream.Readable>>;
+    drainHttpResponse(stream: Stream.Readable): Promise<void>;
     insert(params: ConnInsertParams<Stream.Readable>): Promise<ConnInsertResult>;
@@ -49,0 +50,0 @@ close(): Promise<void>;

dist/connection/node_base_connection.js

@@ -291,2 +291,30 @@ "use strict";
     }
+    async drainHttpResponse(stream) {
+        return new Promise((resolve, reject) => {
+            function dropData() {
+                // We don't care about the data
+            }
+            function onEnd() {
+                removeListeners();
+                resolve();
+            }
+            function onError(err) {
+                removeListeners();
+                reject(err);
+            }
+            function onClose() {
+                removeListeners();
+            }
+            function removeListeners() {
+                stream.removeListener('data', dropData);
+                stream.removeListener('end', onEnd);
+                stream.removeListener('error', onError);
+                stream.removeListener('onClose', onClose);
+            }
+            stream.on('data', dropData);
+            stream.on('end', onEnd);
+            stream.on('error', onError);
+            stream.on('close', onClose);
+        });
+    }
     async insert(params) {
@@ -309,3 +337,3 @@ const query_id = getQueryId(params.query_id);
         });
-        stream.destroy();
+        await this.drainHttpResponse(stream);
         return { query_id };
@@ -312,0 +340,0 @@ }

dist/version.d.ts

@@ -1,2 +0,2 @@
-declare const _default: "0.2.2";
+declare const _default: "0.2.3";
 export default _default;

dist/version.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.default = '0.2.2';
+exports.default = '0.2.3';
 //# sourceMappingURL=version.js.map

package.json

@@ -5,3 +5,3 @@ {
   "homepage": "https://clickhouse.com",
-  "version": "0.2.2",
+  "version": "0.2.3",
   "license": "Apache-2.0",
@@ -27,4 +27,4 @@ "keywords": [
   "dependencies": {
-    "@clickhouse/client-common": "0.2.2"
+    "@clickhouse/client-common": "0.2.3"
   }
 }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

77042

increased by2.46%

Lines of code

998

increased by2.99%

Dependency changes

• + Added@clickhouse/client-common@0.2.3(transitive)

• - Removed@clickhouse/client-common@0.2.2(transitive)

• Updated@clickhouse/client-common@0.2.3