Send hello message including routing

Author: Peter Wilhelmsson

src/internal/bolt-protocol-v4x1.js

@@ -18,11 +18,39 @@
  */
 import BoltProtocolV4 from './bolt-protocol-v4x0'
 import RequestMessage, { ALL } from './request-message'
-import { ResultStreamObserver } from './stream-observers'
 import { BOLT_PROTOCOL_V4_1 } from './constants'
+import { LoginObserver } from './stream-observers'
 
 export default class BoltProtocol extends BoltProtocolV4 {
+  /**
+   * @constructor
+   * @param {Connection} connection the connection.
+   * @param {Chunker} chunker the chunker.
+   * @param {boolean} disableLosslessIntegers if this connection should convert all received integers to native JS numbers.
+   * @param {Object} serversideRouting
+   */
+  constructor (connection, chunker, disableLosslessIntegers, serversideRouting) {
+    super(connection, chunker, disableLosslessIntegers)
+    this._serversideRouting = serversideRouting
+  }
+
   get version () {
     return BOLT_PROTOCOL_V4_1
   }
+
+  initialize ({ userAgent, authToken, onError, onComplete } = {}) {
+    const observer = new LoginObserver({
+      connection: this._connection,
+      afterError: onError,
+      afterComplete: onComplete
+    })
+
+    this._connection.write(
+      RequestMessage.hello(userAgent, authToken, this._serversideRouting),
+      observer,
+      true
+    )
+
+    return observer
+  }
 }

src/internal/request-message.js

@@ -100,10 +100,14 @@ export default class RequestMessage {
    * Create a new HELLO message.
    * @param {string} userAgent the user agent.
    * @param {Object} authToken the authentication token.
+   * @param {Object} optional server side routing, set to routing context to turn on server side routing (> 4.1)
    * @return {RequestMessage} new HELLO message.
    */
-  static hello (userAgent, authToken) {
+  static hello (userAgent, authToken, routing = null) {
     const metadata = Object.assign({ user_agent: userAgent }, authToken)
+    if (routing != null) {
+      metadata.routing = routing
+    }
     return new RequestMessage(
       HELLO,
       [metadata],