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

Comparing version 5.25.0 to 5.26.0

lib/bolt/bolt-protocol-v1.js

 "use strict";
+var __assign = (this && this.__assign) || function () {
+    __assign = Object.assign || function(t) {
+        for (var s, i = 1, n = arguments.length; i < n; i++) {
+            s = arguments[i];
+            for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))
+                t[p] = s[p];
+        }
+        return t;
+    };
+    return __assign.apply(this, arguments);
+};
 var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
@@ -55,2 +66,7 @@ if (k2 === undefined) k2 = k;
 var Bookmarks = neo4j_driver_core_1.internal.bookmarks.Bookmarks, _a = neo4j_driver_core_1.internal.constants, ACCESS_MODE_WRITE = _a.ACCESS_MODE_WRITE, BOLT_PROTOCOL_V1 = _a.BOLT_PROTOCOL_V1, Logger = neo4j_driver_core_1.internal.logger.Logger, TxConfig = neo4j_driver_core_1.internal.txConfig.TxConfig;
+var DEFAULT_DIAGNOSTIC_RECORD = Object.freeze({
+    OPERATION: '',
+    OPERATION_CODE: '0',
+    CURRENT_SCHEMA: '/'
+});
 var BoltProtocol = /** @class */ (function () {
@@ -180,2 +196,5 @@ /**
     };
+    BoltProtocol.prototype.enrichErrorMetadata = function (metadata) {
+        return __assign(__assign({}, metadata), { diagnostic_record: metadata.diagnostic_record !== null ? __assign(__assign({}, DEFAULT_DIAGNOSTIC_RECORD), metadata.diagnostic_record) : null });
+    };
     /**
@@ -182,0 +201,0 @@ * Perform initialization and authentication of the underlying connection.

lib/bolt/create.js

@@ -38,2 +38,3 @@ "use strict";
 var bolt_protocol_v5x6_1 = __importDefault(require("./bolt-protocol-v5x6"));
+var bolt_protocol_v5x7_1 = __importDefault(require("./bolt-protocol-v5x7"));
 // eslint-disable-next-line no-unused-vars
@@ -62,2 +63,3 @@ var channel_1 = require("../channel");
             transformMetadata: protocol.transformMetadata.bind(protocol),
+            enrichErrorMetadata: protocol.enrichErrorMetadata.bind(protocol),
             log: log,
@@ -116,2 +118,4 @@ observer: observer
             return new bolt_protocol_v5x6_1.default(server, chunker, packingConfig, createResponseHandler, log, onProtocolError, serversideRouting);
+        case 5.7:
+            return new bolt_protocol_v5x7_1.default(server, chunker, packingConfig, createResponseHandler, log, onProtocolError, serversideRouting);
         default:
@@ -118,0 +122,0 @@ throw (0, neo4j_driver_core_1.newError)('Unknown Bolt protocol version: ' + version);

lib/bolt/handshake.js

@@ -69,3 +69,3 @@ "use strict";
     return createHandshakeMessage([
-        [version(5, 6), version(5, 0)],
+        [version(5, 7), version(5, 0)],
         [version(4, 4), version(4, 2)],
@@ -72,0 +72,0 @@ version(4, 1),

lib/bolt/response-handler.js

@@ -71,6 +71,7 @@ "use strict";
     function ResponseHandler(_a) {
-        var _b = _a === void 0 ? {} : _a, transformMetadata = _b.transformMetadata, log = _b.log, observer = _b.observer;
+        var _b = _a === void 0 ? {} : _a, transformMetadata = _b.transformMetadata, enrichErrorMetadata = _b.enrichErrorMetadata, log = _b.log, observer = _b.observer;
         this._pendingObservers = [];
         this._log = log;
         this._transformMetadata = transformMetadata || NO_OP_IDENTITY;
+        this._enrichErrorMetadata = enrichErrorMetadata || NO_OP_IDENTITY;
         this._observer = Object.assign({
@@ -116,5 +117,3 @@ onObserversCountChange: NO_OP,
                 try {
-                    var standardizedCode = _standardizeCode(payload.code);
-                    var error = (0, neo4j_driver_core_1.newError)(payload.message, standardizedCode);
-                    this._currentFailure = this._observer.onErrorApplyTransformation(error);
+                    this._currentFailure = this._handleErrorPayload(this._enrichErrorMetadata(payload));
                     this._currentObserver.onError(this._currentFailure);
@@ -194,2 +193,13 @@ }
     };
+    ResponseHandler.prototype._handleErrorPayload = function (payload) {
+        var standardizedCode = _standardizeCode(payload.code);
+        var cause = payload.cause != null ? this._handleErrorCause(payload.cause) : undefined;
+        var error = (0, neo4j_driver_core_1.newError)(payload.message, standardizedCode, cause, payload.gql_status, payload.description, payload.diagnostic_record);
+        return this._observer.onErrorApplyTransformation(error);
+    };
+    ResponseHandler.prototype._handleErrorCause = function (payload) {
+        var cause = payload.cause != null ? this._handleErrorCause(payload.cause) : undefined;
+        var error = (0, neo4j_driver_core_1.newGQLError)(payload.message, cause, payload.gql_status, payload.description, payload.diagnostic_record);
+        return this._observer.onErrorApplyTransformation(error);
+    };
     return ResponseHandler;
@@ -196,0 +206,0 @@ }());

lib/connection/connection-channel.js

@@ -462,3 +462,3 @@ "use strict";
                     else {
-                        var neo4jError = _this._handleProtocolError('Received FAILURE as a response for RESET: ' + error);
+                        var neo4jError = _this._handleProtocolError("Received FAILURE as a response for RESET: ".concat(error));
                         reject(neo4jError);
@@ -465,0 +465,0 @@ }

package.json

 {
   "name": "neo4j-driver-bolt-connection",
-  "version": "5.25.0",
+  "version": "5.26.0",
   "description": "Implements the connection with the Neo4j Database using the Bolt Protocol",
@@ -43,6 +43,6 @@ "main": "lib/index.js",
     "buffer": "^6.0.3",
-    "neo4j-driver-core": "5.25.0",
+    "neo4j-driver-core": "5.26.0",
     "string_decoder": "^1.3.0"
   },
-  "gitHead": "da5b75b4e9e2568b1e4122b7d55d8cfe951b0750"
+  "gitHead": "e8901ff36e5caa6fdcefe74e172006a03474d47b"
 }

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

Mixed license

License

(Experimental) Package contains multiple licenses.

Found 1 instance in 1 package

Unidentified License

License

(Experimental) Something that seems like a license was found, but its contents could not be matched with a known license.

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

621077

increased by1.19%

Number of package files

98

increased by2.08%

Lines of code

13280

increased by1.21%

Worsened metrics

Number of low license alerts

2

increased byInfinity%

License quality

80

decreased by-20%

Dependency changes

• + Addedneo4j-driver-core@5.26.0(transitive)

• - Removedneo4j-driver-core@5.25.0(transitive)

• Updatedneo4j-driver-core@5.26.0