Add bolt 5.1 to handshake

Author: bigmontz

packages/bolt-connection/src/bolt/create.js

@@ -27,6 +27,7 @@ import BoltProtocolV4x2 from './bolt-protocol-v4x2'
 import BoltProtocolV4x3 from './bolt-protocol-v4x3'
 import BoltProtocolV4x4 from './bolt-protocol-v4x4'
 import BoltProtocolV5x0 from './bolt-protocol-v5x0'
+import BoltProtocolV5x1 from './bolt-protocol-v5x1'
 // eslint-disable-next-line no-unused-vars
 import { Chunker, Dechunker } from '../channel'
 import ResponseHandler from './response-handler'
@@ -191,6 +192,16 @@ function createProtocol (
         onProtocolError,
         serversideRouting
       )
+    case 5.1:
+      return new BoltProtocolV5x1(
+        server,
+        chunker,
+        packingConfig,
+        createResponseHandler,
+        log,
+        onProtocolError,
+        serversideRouting
+      )
     default:
       throw newError('Unknown Bolt protocol version: ' + version)
   }

packages/bolt-connection/src/bolt/handshake.js

@@ -76,7 +76,7 @@ function parseNegotiatedResponse (buffer) {
  */
 function newHandshakeBuffer () {
   return createHandshakeMessage([
-    version(5, 0),
+    [version(5, 1), version(5, 0)],
     [version(4, 4), version(4, 2)],
     version(4, 1),
     version(3, 0)

packages/bolt-connection/test/bolt/index.test.js

@@ -31,6 +31,7 @@ import BoltProtocolV4x2 from '../../src/bolt/bolt-protocol-v4x2'
 import BoltProtocolV4x3 from '../../src/bolt/bolt-protocol-v4x3'
 import BoltProtocolV4x4 from '../../src/bolt/bolt-protocol-v4x4'
 import BoltProtocolV5x0 from '../../src/bolt/bolt-protocol-v5x0'
+import BoltProtocolV5x1 from '../../src/bolt/bolt-protocol-v5x1'
 
 const {
   logger: { Logger }
@@ -44,13 +45,13 @@ describe('#unit Bolt', () => {
       const writtenBuffer = channel.written[0]
 
       const boltMagicPreamble = '60 60 b0 17'
-      const protocolVersion5x0 = '00 00 00 05'
+      const protocolVersion5x1to5x0 = '00 01 01 05'
       const protocolVersion4x4to4x2 = '00 02 04 04'
       const protocolVersion4x1 = '00 00 01 04'
       const protocolVersion3 = '00 00 00 03'
 
       expect(writtenBuffer.toHex()).toEqual(
-        `${boltMagicPreamble} ${protocolVersion5x0} ${protocolVersion4x4to4x2} ${protocolVersion4x1} ${protocolVersion3}`
+        `${boltMagicPreamble} ${protocolVersion5x1to5x0} ${protocolVersion4x4to4x2} ${protocolVersion4x1} ${protocolVersion3}`
       )
     })
 
@@ -359,7 +360,8 @@ describe('#unit Bolt', () => {
         v(4.2, BoltProtocolV4x2),
         v(4.3, BoltProtocolV4x3),
         v(4.4, BoltProtocolV4x4),
-        v(5.0, BoltProtocolV5x0)
+        v(5.0, BoltProtocolV5x0),
+        v(5.1, BoltProtocolV5x1)
       ]
 
       availableProtocols.forEach(lambda)

packages/neo4j-driver-deno/lib/bolt-connection/bolt/create.js

@@ -27,6 +27,7 @@ import BoltProtocolV4x2 from './bolt-protocol-v4x2.js'
 import BoltProtocolV4x3 from './bolt-protocol-v4x3.js'
 import BoltProtocolV4x4 from './bolt-protocol-v4x4.js'
 import BoltProtocolV5x0 from './bolt-protocol-v5x0.js'
+import BoltProtocolV5x1 from './bolt-protocol-v5x1.js'
 // eslint-disable-next-line no-unused-vars
 import { Chunker, Dechunker } from '../channel/index.js'
 import ResponseHandler from './response-handler.js'
@@ -191,6 +192,16 @@ function createProtocol (
         onProtocolError,
         serversideRouting
       )
+    case 5.1:
+      return new BoltProtocolV5x1(
+        server,
+        chunker,
+        packingConfig,
+        createResponseHandler,
+        log,
+        onProtocolError,
+        serversideRouting
+      )
     default:
       throw newError('Unknown Bolt protocol version: ' + version)
   }

packages/neo4j-driver-deno/lib/bolt-connection/bolt/handshake.js

@@ -76,7 +76,7 @@ function parseNegotiatedResponse (buffer) {
  */
 function newHandshakeBuffer () {
   return createHandshakeMessage([
-    version(5, 0),
+    [version(5, 1), version(5, 0)],
     [version(4, 4), version(4, 2)],
     version(4, 1),
     version(3, 0)