Migrate bolt stub scripts to Bolt V3

Author: ali-ince

test/internal/node/direct.driver.boltkit.test.js

@@ -287,7 +287,7 @@ describe('direct driver with stub server', () => {
 
     boltStub.run(() => {
       const driver = boltStub.newDriver('bolt://127.0.0.1:9001')
-      const session = driver.session()
+      const session = driver.session(neo4j.session.READ)
       session.run('MATCH (n) RETURN n.name').catch(error => {
         expect(error.code).toEqual(neo4j.error.SERVICE_UNAVAILABLE)
 

test/internal/node/routing.driver.boltkit.test.js

@@ -503,15 +503,15 @@ describe('routing driver with stub server', () => {
       9001
     )
     const readServer = boltStub.start(
-      './test/resources/boltstub/dead_read_server.script',
+      './test/resources/boltstub/dead_write_server.script',
       9007
     )
 
     boltStub.run(() => {
       const driver = boltStub.newDriver('bolt+routing://127.0.0.1:9001')
       // When
       const session = driver.session(neo4j.session.WRITE)
-      session.run('MATCH (n) RETURN n.name').catch(err => {
+      session.run("CREATE (n {name:'Bob'})").catch(err => {
         expect(err.code).toEqual(neo4j.error.SESSION_EXPIRED)
         driver.close()
         seedServer.exit(code1 => {
@@ -1909,7 +1909,7 @@ describe('routing driver with stub server', () => {
 
     boltStub.run(() => {
       const driver = boltStub.newDriver('bolt+routing://127.0.0.1:9001')
-      const session = driver.session()
+      const session = driver.session(neo4j.session.READ)
       session.run('MATCH (n) RETURN n.name AS name').then(result => {
         const names = result.records.map(record => record.get('name'))
         expect(names).toEqual(['Alice', 'Bob', 'Eve'])
@@ -2758,7 +2758,7 @@ describe('routing driver with stub server', () => {
       './test/resources/boltstub/address_unavailable_template.script.mst'
     const server = boltStub.startWithTemplate(
       serverTemplateScript,
-      { query: query },
+      { query: query, mode: accessMode === READ ? '"mode": "r"' : '' },
       serverPort
     )
 

test/resources/boltstub/acquire_endpoints.script

@@ -1,8 +1,10 @@
-!: AUTO INIT
+!: BOLT 3
+!: AUTO HELLO
 !: AUTO RESET
 !: AUTO PULL_ALL
+!: AUTO GOODBYE
 
-C: RUN "CALL dbms.cluster.routing.getRoutingTable($context)" {"context": {}}
+C: RUN "CALL dbms.cluster.routing.getRoutingTable($context)" {"context": {}} {}
    PULL_ALL
 S: SUCCESS {"fields": ["ttl", "servers"]}
    RECORD [9223372036854775807, [{"addresses": ["127.0.0.1:9007","127.0.0.1:9008"],"role": "WRITE"}, {"addresses": ["127.0.0.1:9005","127.0.0.1:9006"], "role": "READ"},{"addresses": ["127.0.0.1:9001","127.0.0.1:9002","127.0.0.1:9003"], "role": "ROUTE"}]]

test/resources/boltstub/acquire_endpoints_and_exit.script

@@ -1,8 +1,10 @@
-!: AUTO INIT
+!: BOLT 3
+!: AUTO HELLO
 !: AUTO RESET
 !: AUTO PULL_ALL
+!: AUTO GOODBYE
 
-C: RUN "CALL dbms.cluster.routing.getRoutingTable($context)" {"context": {}}
+C: RUN "CALL dbms.cluster.routing.getRoutingTable($context)" {"context": {}} {}
    PULL_ALL
 S: SUCCESS {"fields": ["ttl", "servers"]}
    RECORD [9223372036854775807, [{"addresses": ["127.0.0.1:9007","127.0.0.1:9008"],"role": "WRITE"}, {"addresses": ["127.0.0.1:9005","127.0.0.1:9006"], "role": "READ"},{"addresses": ["127.0.0.1:9001","127.0.0.1:9002","127.0.0.1:9003"], "role": "ROUTE"}]]

test/resources/boltstub/acquire_endpoints_v3.script

@@ -1,5 +1,6 @@
 !: BOLT 3
 !: AUTO RESET
+!: AUTO GOODBYE
 
 C: HELLO {"scheme": "basic", "principal": "neo4j", "credentials": "password", "user_agent": "neo4j-javascript/0.0.0-dev"}
 S: SUCCESS {"server": "Neo4j/9.9.9", "connection_id": "bolt-123456789"}

test/resources/boltstub/acquire_endpoints_v3_empty.script

@@ -1,6 +1,7 @@
 !: BOLT 3
 !: AUTO HELLO
 !: AUTO RESET
+!: AUTO GOODBYE
 
 C: RUN "CALL dbms.cluster.routing.getRoutingTable($context)" {"context": {}} {}
    PULL_ALL

test/resources/boltstub/acquire_endpoints_v3_point_to_empty_router_and_exit.script

@@ -1,6 +1,7 @@
 !: BOLT 3
 !: AUTO HELLO
 !: AUTO RESET
+!: AUTO GOODBYE
 
 C: RUN "CALL dbms.cluster.routing.getRoutingTable($context)" {"context": {}} {}
    PULL_ALL

test/resources/boltstub/acquire_endpoints_v3_three_servers_and_exit.script

@@ -1,5 +1,6 @@
 !: BOLT 3
 !: AUTO HELLO
+!: AUTO GOODBYE
 
 C: RUN "CALL dbms.cluster.routing.getRoutingTable($context)" {"context": {}} {}
    PULL_ALL

test/resources/boltstub/acquire_endpoints_with_one_of_each.script

@@ -1,8 +1,10 @@
-!: AUTO INIT
+!: BOLT 3
+!: AUTO HELLO
 !: AUTO RESET
 !: AUTO PULL_ALL
+!: AUTO GOODBYE
 
-C: RUN "CALL dbms.cluster.routing.getRoutingTable($context)" {"context": {}}
+C: RUN "CALL dbms.cluster.routing.getRoutingTable($context)" {"context": {}} {}
    PULL_ALL
 S: SUCCESS {"fields": ["ttl", "servers"]}
    RECORD [9223372036854775807, [{"addresses": ["127.0.0.1:9007"],"role": "WRITE"}, {"addresses": ["127.0.0.1:9005"], "role": "READ"},{"addresses": ["127.0.0.1:9001","127.0.0.1:9002"], "role": "ROUTE"}]]

test/resources/boltstub/address_unavailable_template.script.mst

@@ -1,11 +1,13 @@
-!: AUTO INIT
+!: BOLT 3
+!: AUTO HELLO
 !: AUTO RESET
 !: AUTO PULL_ALL
-!: AUTO RUN "ROLLBACK" {}
-!: AUTO RUN "BEGIN" {}
-!: AUTO RUN "COMMIT" {}
+!: AUTO ROLLBACK
+!: AUTO BEGIN
+!: AUTO COMMIT
+!: AUTO GOODBYE
 
-C: RUN "{{{query}}}" {}
+C: RUN "{{{query}}}" {} { {{{mode}}} }
 C: PULL_ALL
 S: FAILURE {"code": "Neo.TransientError.General.DatabaseUnavailable", "message": "Database is busy doing store copy"}
 S: IGNORED