Reclassify Transaction.LockClientStopped and Transaction.Terminated as ClientError

The server 5.x already fix this classification error, but the driver has re-classify errors from previous version of the server for a more convenience for the user.

Co-authored-by: Florent Biville <florent.biville@neo4j.com>

Author: bigmontz

packages/bolt-connection/src/bolt/response-handler.js

@@ -117,7 +117,8 @@ export default class ResponseHandler {
           this._log.debug(`S: FAILURE ${json.stringify(msg)}`)
         }
         try {
-          const error = newError(payload.message, payload.code)
+          const standardizedCode = _standardizeCode(payload.code)
+          const error = newError(payload.message, standardizedCode)
           this._currentFailure = this._observer.onErrorApplyTransformation(
             error
           )
@@ -194,3 +195,21 @@ export default class ResponseHandler {
     this._currentFailure = null
   }
 }
+
+/**
+ * Standardize error classification that are different between 5.x and previous versions.
+ *
+ * The transient error were clean-up for being retrieable and because of this
+ * `Terminated` and `LockClientStopped` were reclassified as `ClientError`.
+ *
+ * @param {string} code
+ * @returns {string} the standardized error code
+ */
+function _standardizeCode (code) {
+  if (code === 'Neo.TransientError.Transaction.Terminated') {
+    return 'Neo.ClientError.Transaction.Terminated'
+  } else if (code === 'Neo.TransientError.Transaction.LockClientStopped') {
+    return 'Neo.ClientError.Transaction.LockClientStopped'
+  }
+  return code
+}

packages/bolt-connection/test/bolt/response-handler.test.js

@@ -0,0 +1,74 @@
+/**
+ * Copyright (c) "Neo4j"
+ * Neo4j Sweden AB [http://neo4j.com]
+ *
+ * This file is part of Neo4j.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import ResponseHandler from '../../src/bolt/response-handler'
+import { internal, newError } from 'neo4j-driver-core'
+
+const {
+  logger: { Logger }
+} = internal
+
+const FAILURE = 0x7f // 0111 1111 // FAILURE <metadata>
+
+describe('response-handler', () => {
+  describe('.handleResponse()', () => {
+    it.each([
+      {
+        code: 'Neo.TransientError.Transaction.Terminated',
+        expectedErrorCode: 'Neo.ClientError.Transaction.Terminated'
+      },
+      {
+        code: 'Neo.TransientError.Transaction.LockClientStopped',
+        expectedErrorCode: 'Neo.ClientError.Transaction.LockClientStopped'
+      },
+      {
+        code: 'Neo.ClientError.Transaction.LockClientStopped',
+        expectedErrorCode: 'Neo.ClientError.Transaction.LockClientStopped'
+      },
+      {
+        code: 'Neo.ClientError.Transaction.Terminated',
+        expectedErrorCode: 'Neo.ClientError.Transaction.Terminated'
+      },
+      {
+        code: 'Neo.TransientError.Security.NotYourBusiness',
+        expectedErrorCode: 'Neo.TransientError.Security.NotYourBusiness'
+      }
+    ])('should fix wrong classified error codes', ({ code, expectedErrorCode }) => {
+      const observer = {
+        capturedErrors: [],
+        onFailure: error => observer.capturedErrors.push(error)
+      }
+      const message = 'Something gets wrong'
+      const expectedError = newError(message, expectedErrorCode)
+      const responseHandler = new ResponseHandler({ observer, log: Logger.noOp() })
+      responseHandler._queueObserver({})
+
+      const errorMessage = {
+        signature: FAILURE,
+        fields: [{ message, code }]
+      }
+      responseHandler.handleResponse(errorMessage)
+
+      expect(observer.capturedErrors.length).toBe(1)
+      const [receivedError] = observer.capturedErrors
+      expect(receivedError.message).toBe(expectedError.message)
+      expect(receivedError.code).toBe(expectedError.code)
+    })
+  })
+})

packages/core/src/error.ts

@@ -127,30 +127,16 @@ function _isRetriableCode (code?: Neo4jErrorCode): boolean {
   return code === SERVICE_UNAVAILABLE ||
     code === SESSION_EXPIRED ||
     _isAuthorizationExpired(code) ||
-    _isRetriableTransientError(code)
+    _isTransientError(code)
 }
 
 /**
  * @private
  * @param {string} code the error to check
  * @return {boolean} true if the error is a transient error
  */
-function _isRetriableTransientError (code?: Neo4jErrorCode): boolean {
-  // Retries should not happen when transaction was explicitly terminated by the user.
-  // Termination of transaction might result in two different error codes depending on where it was
-  // terminated. These are really client errors but classification on the server is not entirely correct and
-  // they are classified as transient.
-
-  if (code?.includes('TransientError') === true) {
-    if (
-      code === 'Neo.TransientError.Transaction.Terminated' ||
-      code === 'Neo.TransientError.Transaction.LockClientStopped'
-    ) {
-      return false
-    }
-    return true
-  }
-  return false
+function _isTransientError (code?: Neo4jErrorCode): boolean {
+  return code?.includes('TransientError') === true
 }
 
 /**

packages/core/test/error.test.ts

@@ -132,15 +132,17 @@ function getRetriableCodes (): string[] {
     SESSION_EXPIRED,
     'Neo.ClientError.Security.AuthorizationExpired',
     'Neo.TransientError.Transaction.DeadlockDetected',
-    'Neo.TransientError.Network.CommunicationError'
+    'Neo.TransientError.Network.CommunicationError',
+    'Neo.TransientError.Transaction.Terminated',
+    'Neo.TransientError.Transaction.LockClientStopped'
   ]
 }
 
 function getNonRetriableCodes (): string[] {
   return [
-    'Neo.TransientError.Transaction.Terminated',
     'Neo.DatabaseError.General.UnknownError',
-    'Neo.TransientError.Transaction.LockClientStopped',
-    'Neo.DatabaseError.General.OutOfMemoryError'
+    'Neo.DatabaseError.General.OutOfMemoryError',
+    'Neo.ClientError.Transaction.Terminated',
+    'Neo.ClientError.Transaction.LockClientStopped'
   ]
 }