neo4j
diff --git a/‎packages/bolt-connection/src/bolt/bolt-protocol-v1.js
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion b/‎packages/bolt-connection/src/bolt/bolt-protocol-v1.js
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/‎packages/bolt-connection/src/bolt/bolt-protocol-v2.js
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion b/‎packages/bolt-connection/src/bolt/bolt-protocol-v2.js
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/‎packages/bolt-connection/src/bolt/bolt-protocol-v3.js
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion b/‎packages/bolt-connection/src/bolt/bolt-protocol-v3.js
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/‎packages/bolt-connection/src/bolt/bolt-protocol-v4x0.js
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion b/‎packages/bolt-connection/src/bolt/bolt-protocol-v4x0.js
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/‎packages/bolt-connection/src/bolt/bolt-protocol-v4x1.js
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion b/‎packages/bolt-connection/src/bolt/bolt-protocol-v4x1.js
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/‎packages/bolt-connection/src/bolt/bolt-protocol-v4x2.js
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion b/‎packages/bolt-connection/src/bolt/bolt-protocol-v4x2.js
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/‎packages/bolt-connection/src/bolt/bolt-protocol-v4x3.js
Copy file name to clipboard
+50-2Lines changed: 50 additions & 2 deletions b/‎packages/bolt-connection/src/bolt/bolt-protocol-v4x3.js
Copy file name to clipboard
+50-2Lines changed: 50 additions & 2 deletions
diff --git a/‎packages/bolt-connection/src/bolt/bolt-protocol-v4x4.js
Copy file name to clipboard
+9-1Lines changed: 9 additions & 1 deletion b/‎packages/bolt-connection/src/bolt/bolt-protocol-v4x4.js
Copy file name to clipboard
+9-1Lines changed: 9 additions & 1 deletion
diff --git a/‎packages/bolt-connection/src/bolt/bolt-protocol-v5x0.js
Copy file name to clipboard
+28-1Lines changed: 28 additions & 1 deletion b/‎packages/bolt-connection/src/bolt/bolt-protocol-v5x0.js
Copy file name to clipboard
+28-1Lines changed: 28 additions & 1 deletion
diff --git a/‎packages/bolt-connection/src/bolt/bolt-protocol-v5x0.transformer.js
Copy file name to clipboard
+8-1Lines changed: 8 additions & 1 deletion b/‎packages/bolt-connection/src/bolt/bolt-protocol-v5x0.transformer.js
Copy file name to clipboard
+8-1Lines changed: 8 additions & 1 deletion
@@ -87,7 +87,7 @@ export default class BoltProtocol {
 
   get transformer () {
     if (this._transformer === undefined) {
-      this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config)))
+      this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config, this._log)))
     }
     return this._transformer
   }
 
@@ -37,7 +37,7 @@ export default class BoltProtocol extends BoltProtocolV1 {
 
   get transformer () {
     if (this._transformer === undefined) {
-      this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config)))
+      this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config, this._log)))
     }
     return this._transformer
   }
 
@@ -48,7 +48,7 @@ export default class BoltProtocol extends BoltProtocolV2 {
 
   get transformer () {
     if (this._transformer === undefined) {
-      this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config)))
+      this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config, this._log)))
     }
     return this._transformer
   }
 
@@ -46,7 +46,7 @@ export default class BoltProtocol extends BoltProtocolV3 {
 
   get transformer () {
     if (this._transformer === undefined) {
-      this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config)))
+      this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config, this._log)))
     }
     return this._transformer
   }
 
@@ -67,7 +67,7 @@ export default class BoltProtocol extends BoltProtocolV4 {
 
   get transformer () {
     if (this._transformer === undefined) {
-      this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config)))
+      this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config, this._log)))
     }
     return this._transformer
   }
 
@@ -34,7 +34,7 @@ export default class BoltProtocol extends BoltProtocolV41 {
 
   get transformer () {
     if (this._transformer === undefined) {
-      this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config)))
+      this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config, this._log)))
     }
     return this._transformer
   }
 
@@ -18,9 +18,10 @@
  */
 import BoltProtocolV42 from './bolt-protocol-v4x2'
 import RequestMessage from './request-message'
-import { RouteObserver } from './stream-observers'
+import { LoginObserver, RouteObserver } from './stream-observers'
 
 import transformersFactories from './bolt-protocol-v4x3.transformer'
+import utcTransformersFactories from './bolt-protocol-v5x0.utc.transformer'
 import Transformer from './transformer'
 
 import { internal } from 'neo4j-driver-core'
@@ -37,7 +38,7 @@ export default class BoltProtocol extends BoltProtocolV42 {
 
   get transformer () {
     if (this._transformer === undefined) {
-      this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config)))
+      this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config, this._log)))
     }
     return this._transformer
   }
@@ -75,4 +76,51 @@ export default class BoltProtocol extends BoltProtocolV42 {
 
     return observer
   }
+
+  /**
+   * Initialize a connection with the server
+   *
+   * @param {Object} param0 The params
+   * @param {string} param0.userAgent The user agent
+   * @param {any} param0.authToken The auth token
+   * @param {function(error)} param0.onError On error callback
+   * @param {function(onComplte)} param0.onComplete On complete callback
+   * @returns {LoginObserver} The Login observer
+   */
+  initialize ({ userAgent, authToken, onError, onComplete } = {}) {
+    const observer = new LoginObserver({
+      onError: error => this._onLoginError(error, onError),
+      onCompleted: metadata => {
+        if (metadata.patch_bolt !== undefined) {
+          this._applyPatches(metadata.patch_bolt)
+        }
+        return this._onLoginCompleted(metadata, onComplete)
+      }
+    })
+
+    this.write(
+      RequestMessage.hello(userAgent, authToken, this._serversideRouting, ['utc']),
+      observer,
+      true
+    )
+
+    return observer
+  }
+
+  /**
+   *
+   * @param {string[]} patches Patches to be applied to the protocol
+   */
+  _applyPatches (patches) {
+    if (patches.includes('utc')) {
+      this._applyUtcPatch()
+    }
+  }
+
+  _applyUtcPatch () {
+    this._transformer = new Transformer(Object.values({
+      ...transformersFactories,
+      ...utcTransformersFactories
+    }).map(create => create(this._config, this._log)))
+  }
 }
@@ -23,6 +23,7 @@ import RequestMessage from './request-message'
 import { RouteObserver, ResultStreamObserver } from './stream-observers'
 
 import transformersFactories from './bolt-protocol-v4x4.transformer'
+import utcTransformersFactories from './bolt-protocol-v5x0.utc.transformer'
 import Transformer from './transformer'
 
 const {
@@ -37,7 +38,7 @@ export default class BoltProtocol extends BoltProtocolV43 {
 
   get transformer () {
     if (this._transformer === undefined) {
-      this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config)))
+      this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config, this._log)))
     }
     return this._transformer
   }
@@ -163,4 +164,11 @@ export default class BoltProtocol extends BoltProtocolV43 {
 
     return observer
   }
+
+  _applyUtcPatch () {
+    this._transformer = new Transformer(Object.values({
+      ...transformersFactories,
+      ...utcTransformersFactories
+    }).map(create => create(this._config, this._log)))
+  }
 }
@@ -20,6 +20,8 @@ import BoltProtocolV44 from './bolt-protocol-v4x4'
 
 import transformersFactories from './bolt-protocol-v5x0.transformer'
 import Transformer from './transformer'
+import RequestMessage from './request-message'
+import { LoginObserver } from './stream-observers'
 
 import { internal } from 'neo4j-driver-core'
 
@@ -34,8 +36,33 @@ export default class BoltProtocol extends BoltProtocolV44 {
 
   get transformer () {
     if (this._transformer === undefined) {
-      this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config)))
+      this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config, this._log)))
     }
     return this._transformer
   }
+
+  /**
+   * Initialize a connection with the server
+   *
+   * @param {Object} param0 The params
+   * @param {string} param0.userAgent The user agent
+   * @param {any} param0.authToken The auth token
+   * @param {function(error)} param0.onError On error callback
+   * @param {function(onComplte)} param0.onComplete On complete callback
+   * @returns {LoginObserver} The Login observer
+   */
+  initialize ({ userAgent, authToken, onError, onComplete } = {}) {
+    const observer = new LoginObserver({
+      onError: error => this._onLoginError(error, onError),
+      onCompleted: metadata => this._onLoginCompleted(metadata, onComplete)
+    })
+
+    this.write(
+      RequestMessage.hello(userAgent, authToken, this._serversideRouting),
+      observer,
+      true
+    )
+
+    return observer
+  }
 }
@@ -18,8 +18,14 @@
  */
 
 import { structure } from '../packstream'
-import { Node, Relationship, UnboundRelationship } from 'neo4j-driver-core'
+import {
+  Node,
+  Relationship,
+  UnboundRelationship
+} from 'neo4j-driver-core'
+
 import v4x4 from './bolt-protocol-v4x4.transformer'
+import v5x0Utc from './bolt-protocol-v5x0.utc.transformer'
 
 const NODE_STRUCT_SIZE = 4
 const RELATIONSHIP_STRUCT_SIZE = 8
@@ -118,6 +124,7 @@ function createUnboundRelationshipTransformer (config) {
 
 export default {
   ...v4x4,
+  ...v5x0Utc,
   createNodeTransformer,
   createRelationshipTransformer,
   createUnboundRelationshipTransformer
Original file line number	Diff line number	Diff line change
`@@ -87,7 +87,7 @@ export default class BoltProtocol {`
`87`	`87`
`88`	`88`	`get transformer () {`
`89`	`89`	`if (this._transformer === undefined) {`
`90`		`- this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config)))`
	`90`	`+ this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config, this._log)))`
`91`	`91`	`}`
`92`	`92`	`return this._transformer`
`93`	`93`	`}`
Original file line number	Diff line number	Diff line change
`@@ -37,7 +37,7 @@ export default class BoltProtocol extends BoltProtocolV1 {`
`37`	`37`
`38`	`38`	`get transformer () {`
`39`	`39`	`if (this._transformer === undefined) {`
`40`		`- this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config)))`
	`40`	`+ this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config, this._log)))`
`41`	`41`	`}`
`42`	`42`	`return this._transformer`
`43`	`43`	`}`
Original file line number	Diff line number	Diff line change
`@@ -48,7 +48,7 @@ export default class BoltProtocol extends BoltProtocolV2 {`
`48`	`48`
`49`	`49`	`get transformer () {`
`50`	`50`	`if (this._transformer === undefined) {`
`51`		`- this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config)))`
	`51`	`+ this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config, this._log)))`
`52`	`52`	`}`
`53`	`53`	`return this._transformer`
`54`	`54`	`}`
Original file line number	Diff line number	Diff line change
`@@ -46,7 +46,7 @@ export default class BoltProtocol extends BoltProtocolV3 {`
`46`	`46`
`47`	`47`	`get transformer () {`
`48`	`48`	`if (this._transformer === undefined) {`
`49`		`- this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config)))`
	`49`	`+ this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config, this._log)))`
`50`	`50`	`}`
`51`	`51`	`return this._transformer`
`52`	`52`	`}`
Original file line number	Diff line number	Diff line change
`@@ -67,7 +67,7 @@ export default class BoltProtocol extends BoltProtocolV4 {`
`67`	`67`
`68`	`68`	`get transformer () {`
`69`	`69`	`if (this._transformer === undefined) {`
`70`		`- this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config)))`
	`70`	`+ this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config, this._log)))`
`71`	`71`	`}`
`72`	`72`	`return this._transformer`
`73`	`73`	`}`
Original file line number	Diff line number	Diff line change
`@@ -34,7 +34,7 @@ export default class BoltProtocol extends BoltProtocolV41 {`
`34`	`34`
`35`	`35`	`get transformer () {`
`36`	`36`	`if (this._transformer === undefined) {`
`37`		`- this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config)))`
	`37`	`+ this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config, this._log)))`
`38`	`38`	`}`
`39`	`39`	`return this._transformer`
`40`	`40`	`}`
Original file line number	Diff line number	Diff line change
`@@ -23,6 +23,7 @@ import RequestMessage from './request-message'`
`23`	`23`	`import { RouteObserver, ResultStreamObserver } from './stream-observers'`
`24`	`24`
`25`	`25`	`import transformersFactories from './bolt-protocol-v4x4.transformer'`
	`26`	`+import utcTransformersFactories from './bolt-protocol-v5x0.utc.transformer'`
`26`	`27`	`import Transformer from './transformer'`
`27`	`28`
`28`	`29`	`const {`
`@@ -37,7 +38,7 @@ export default class BoltProtocol extends BoltProtocolV43 {`
`37`	`38`
`38`	`39`	`get transformer () {`
`39`	`40`	`if (this._transformer === undefined) {`
`40`		`- this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config)))`
	`41`	`+ this._transformer = new Transformer(Object.values(transformersFactories).map(create => create(this._config, this._log)))`
`41`	`42`	`}`
`42`	`43`	`return this._transformer`
`43`	`44`	`}`
`@@ -163,4 +164,11 @@ export default class BoltProtocol extends BoltProtocolV43 {`
`163`	`164`
`164`	`165`	`return observer`
`165`	`166`	`}`
	`167`	`+`
	`168`	`+ _applyUtcPatch () {`
	`169`	`+ this._transformer = new Transformer(Object.values({`
	`170`	`+ ...transformersFactories,`
	`171`	`+ ...utcTransformersFactories`
	`172`	`+ }).map(create => create(this._config, this._log)))`
	`173`	`+ }`
`166`	`174`	`}`