neo4j-driver-bolt-connection - npm Package Compare versions

Comparing version 4.4.0 to 4.4.1

lib/channel/browser/browser-channel.js

@@ -24,3 +24,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-var browser_buf_1 = __importDefault(require("./browser-buf"));
+var channel_buf_1 = __importDefault(require("../channel-buf"));
 var neo4j_driver_core_1 = require("neo4j-driver-core");
@@ -80,3 +80,3 @@ var _a = neo4j_driver_core_1.internal.util, ENCRYPTION_OFF = _a.ENCRYPTION_OFF, ENCRYPTION_ON = _a.ENCRYPTION_ON;
             if (self.onmessage) {
-                var b = new browser_buf_1.default(event.data);
+                var b = new channel_buf_1.default(event.data);
                 self.onmessage(b);
@@ -116,3 +116,3 @@ }
      * Write the passed in buffer to connection
-     * @param {HeapBuffer} buffer - Buffer to write
+     * @param {ChannelBuffer} buffer - Buffer to write
      */
@@ -125,3 +125,3 @@ WebSocketChannel.prototype.write = function (buffer) {
         }
-        else if (buffer instanceof browser_buf_1.default) {
+        else if (buffer instanceof channel_buf_1.default) {
             try {
@@ -128,0 +128,0 @@ this._ws.send(buffer._buffer);

lib/channel/browser/index.js

@@ -24,7 +24,5 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.utf8 = exports.HostNameResolver = exports.Channel = exports.alloc = void 0;
-var browser_buf_1 = __importDefault(require("./browser-buf"));
+exports.HostNameResolver = exports.Channel = void 0;
 var browser_channel_1 = __importDefault(require("./browser-channel"));
 var browser_host_name_resolver_1 = __importDefault(require("./browser-host-name-resolver"));
-var browser_utf8_1 = __importDefault(require("./browser-utf8"));
 /*
@@ -40,6 +38,3 @@
  */
-var alloc = function (arg) { return new browser_buf_1.default(arg); };
-exports.alloc = alloc;
 exports.Channel = browser_channel_1.default;
 exports.HostNameResolver = browser_host_name_resolver_1.default;
-exports.utf8 = browser_utf8_1.default;

lib/channel/chunking.js

@@ -41,3 +41,3 @@ "use strict";
 var base_buf_1 = __importDefault(require("../buf/base-buf"));
-var node_1 = require("./node");
+var channel_buf_1 = require("./channel-buf");
 var combined_buf_1 = __importDefault(require("./combined-buf"));
@@ -57,3 +57,3 @@ var _CHUNK_HEADER_SIZE = 2;
         _this._ch = channel;
-        _this._buffer = (0, node_1.alloc)(_this._bufferSize);
+        _this._buffer = (0, channel_buf_1.alloc)(_this._bufferSize);
         _this._currentChunkStart = 0;
@@ -99,3 +99,3 @@ _this._chunkOpen = false;
             // Alloc a new output buffer. We assume we're using NodeJS's buffer pooling under the hood here!
-            this._buffer = (0, node_1.alloc)(this._bufferSize);
+            this._buffer = (0, channel_buf_1.alloc)(this._bufferSize);
             this._chunkOpen = false;
@@ -102,0 +102,0 @@ }

lib/channel/combined-buf.js

@@ -37,3 +37,3 @@ "use strict";
 var buf_1 = require("../buf");
-var node_1 = require("./node");
+var channel_buf_1 = require("./channel-buf");
 /**
@@ -83,3 +83,3 @@ * Buffer that combines multiple buffers, exposing them as one single buffer.
         // we want to read and depend on the platform impl of IEEE 754.
-        var b = (0, node_1.alloc)(8);
+        var b = (0, channel_buf_1.alloc)(8);
         for (var i = 0; i < 8; i++) {
@@ -86,0 +86,0 @@ b.putUInt8(i, this.getUInt8(position + i));

lib/channel/index.js

 "use strict";
-var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
-}) : (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    o[k2] = m[k];
-}));
-var __exportStar = (this && this.__exportStar) || function(m, exports) {
-    for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports, p)) __createBinding(exports, m, p);
-};
-var __importDefault = (this && this.__importDefault) || function (mod) {
-    return (mod && mod.__esModule) ? mod : { "default": mod };
-};
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.ChannelConfig = void 0;
 /**
@@ -35,2 +20,17 @@ * Copyright (c) "Neo4j"
  */
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __exportStar = (this && this.__exportStar) || function(m, exports) {
+    for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports, p)) __createBinding(exports, m, p);
+};
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.utf8 = exports.alloc = exports.ChannelConfig = void 0;
 __exportStar(require("./node"), exports);
@@ -40,1 +40,5 @@ __exportStar(require("./chunking"), exports);
 Object.defineProperty(exports, "ChannelConfig", { enumerable: true, get: function () { return __importDefault(channel_config_1).default; } });
+var channel_buf_1 = require("./channel-buf");
+Object.defineProperty(exports, "alloc", { enumerable: true, get: function () { return channel_buf_1.alloc; } });
+var utf8_1 = require("./utf8");
+Object.defineProperty(exports, "utf8", { enumerable: true, get: function () { return __importDefault(utf8_1).default; } });

lib/channel/node/index.js

@@ -24,7 +24,5 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.utf8 = exports.HostNameResolver = exports.Channel = exports.alloc = void 0;
-var node_buf_1 = __importDefault(require("./node-buf"));
+exports.HostNameResolver = exports.Channel = void 0;
 var node_channel_1 = __importDefault(require("./node-channel"));
 var node_host_name_resolver_1 = __importDefault(require("./node-host-name-resolver"));
-var node_utf8_1 = __importDefault(require("./node-utf8"));
 /*
@@ -40,6 +38,3 @@
  */
-var alloc = function (arg) { return new node_buf_1.default(arg); };
-exports.alloc = alloc;
 exports.Channel = node_channel_1.default;
 exports.HostNameResolver = node_host_name_resolver_1.default;
-exports.utf8 = node_utf8_1.default;

lib/channel/node/node-channel.js

@@ -27,3 +27,3 @@ "use strict";
 var fs_1 = __importDefault(require("fs"));
-var node_buf_1 = __importDefault(require("./node-buf"));
+var channel_buf_1 = __importDefault(require("../channel-buf"));
 var neo4j_driver_core_1 = require("neo4j-driver-core");
@@ -205,3 +205,3 @@ var _a = neo4j_driver_core_1.internal.util, ENCRYPTION_OFF = _a.ENCRYPTION_OFF, ENCRYPTION_ON = _a.ENCRYPTION_ON, isEmptyObjectOrNull = _a.isEmptyObjectOrNull;
                 if (self.onmessage) {
-                    self.onmessage(new node_buf_1.default(buffer));
+                    self.onmessage(new channel_buf_1.default(buffer));
                 }
@@ -285,3 +285,3 @@ });
      * Write the passed in buffer to connection
-     * @param {NodeBuffer} buffer - Buffer to write
+     * @param {ChannelBuffer} buffer - Buffer to write
      */
@@ -294,3 +294,3 @@ NodeChannel.prototype.write = function (buffer) {
         }
-        else if (buffer instanceof node_buf_1.default) {
+        else if (buffer instanceof channel_buf_1.default) {
             this._conn.write(buffer._buffer);
@@ -297,0 +297,0 @@ }

lib/connection/connection-channel.js

@@ -303,3 +303,3 @@ "use strict";
         if (this._log.isErrorEnabled()) {
-            this._log.error("experienced a fatal error " + neo4j_driver_core_1.json.stringify(this._error));
+            this._log.error("experienced a fatal error caused by " + this._error + " (" + neo4j_driver_core_1.json.stringify(this._error) + ")");
         }
@@ -306,0 +306,0 @@ this._protocol.notifyFatalError(this._error);

package.json

 {
   "name": "neo4j-driver-bolt-connection",
-  "version": "4.4.0",
+  "version": "4.4.1",
   "description": "Implements the connection with the Neo4j Database using the Bolt Protocol",
@@ -41,6 +41,7 @@ "main": "lib/index.js",
   "dependencies": {
-    "neo4j-driver-core": "^4.4.0",
-    "text-encoding-utf-8": "^1.0.2"
+    "buffer": "^6.0.3",
+    "neo4j-driver-core": "^4.4.1",
+    "string_decoder": "^1.3.0"
   },
-  "gitHead": "473235e64579ecd32e46510de9a8d9b8b83c63e6"
+  "gitHead": "0414e921ed4a8769e7b0fd5aa8e28815320a05de"
 }

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

Worsened metrics

Total package byte prevSize

425109

decreased by-1.26%

Dependency count

3

increased by50%

Number of package files

63

decreased by-3.08%

Lines of code

9271

decreased by-1.44%

Dependency changes

• + Addedbuffer@^6.0.3

• + Addedstring_decoder@^1.3.0

• + Addedbase64-js@1.5.1(transitive)

• + Addedbuffer@6.0.3(transitive)

• + Addedieee754@1.2.1(transitive)

• + Addedsafe-buffer@5.2.1(transitive)

• + Addedstring_decoder@1.3.0(transitive)

• - Removedtext-encoding-utf-8@^1.0.2

• - Removedtext-encoding-utf-8@1.0.2(transitive)

• Updatedneo4j-driver-core@^4.4.1