Add setting to specify read transactions on cypher queries

src/browser/modules/Sidebar/UserSettings.tsx

@@ -102,6 +102,14 @@ const visualSettings = [
             'The timeout in milliseconds when establishing a connection to Neo4j.',
           type: 'input'
         }
+      },
+      {
+        useReadTransactions: {
+          displayName: 'Use read transactions for cypher queries.',
+          tooltip:
+            'This setting can be useful in a cluster environment where you want to ensure that read queries are sent to secondaries.',
+          type: 'checkbox'
+        }
       }
     ]
   },

src/shared/modules/commands/cypher.test.ts

@@ -57,6 +57,14 @@ jest.mock('shared/modules/dbMeta/dbMetaDuck', () => {
   }
 })
 
+jest.mock('shared/modules/settings/settingsDuck', () => {
+  const orig = require.requireActual('shared/modules/dbMeta/dbMetaDuck')
+  return {
+    ...orig,
+    shouldUseReadTransactions: () => false
+  }
+})
+
 describe('tx metadata with cypher', () => {
   afterEach(() => {
     bolt.routedWriteTransaction.mockClear()
@@ -153,24 +161,26 @@ multiline comment
     action.$$responseChannel = $$responseChannel
 
     bus.send(action.type, action)
-    flushPromises().then(() => {
-      expect(bolt.routedWriteTransaction).toHaveBeenCalledTimes(1)
-      expect(bolt.routedWriteTransaction).toHaveBeenCalledWith(
-        `// comment
+    flushPromises()
+      .then(() => {
+        expect(bolt.routedWriteTransaction).toHaveBeenCalledTimes(1)
+        expect(bolt.routedWriteTransaction).toHaveBeenCalledWith(
+          `// comment
 /*
 multiline comment
 */
 // comment
 
 // comment
 /*:auto*/ RETURN ":auto"`,
-        {},
-        expect.objectContaining({
-          autoCommit: true
-        })
-      )
-      done()
-    })
+          {},
+          expect.objectContaining({
+            autoCommit: true
+          })
+        )
+        done()
+      })
+      .catch(e => console.error(e))
   })
   test('it sends the autoCommit flag = false to tx functions on regular cypher', done => {
     // Given

src/shared/modules/commands/helpers/cypher.ts

@@ -23,6 +23,7 @@ import bolt from 'services/bolt/bolt'
 import { applyGraphTypes } from 'services/bolt/boltMappings'
 import { arrayToObject } from 'services/utils'
 import { send } from 'shared/modules/requests/requestsDuck'
+import { v4 } from 'uuid'
 
 export const applyParamGraphTypes = (params = {} as any) =>
   arrayToObject(
@@ -38,17 +39,20 @@ export const handleCypherCommand = (
   txMetadata = {},
   autoCommit = false
 ): [string, Promise<QueryResult>] => {
-  const [id, request] = bolt.routedWriteTransaction(
-    action.query,
-    applyParamGraphTypes(params),
-    {
-      requestId: action.requestId,
-      cancelable: true,
-      ...txMetadata,
-      autoCommit,
-      useDb: action.useDb
-    }
-  )
+  const parameters = applyParamGraphTypes(params)
+  const requestMetaData = {
+    requestId: action.requestId || v4(),
+    cancelable: true,
+    ...txMetadata,
+    autoCommit,
+    useDb: action.useDb
+  }
+
+  const id = requestMetaData.requestId
+  const request = action.useReadTransaction
+    ? bolt.routedReadTransaction(action.query, parameters, requestMetaData)
+    : bolt.routedWriteTransaction(action.query, parameters, requestMetaData)[1]
+
   put(send(id))
   return [id, request]
 }

src/shared/modules/commands/use-db-ww.test.ts

@@ -41,6 +41,14 @@ jest.mock('shared/modules/params/paramsDuck', () => {
   }
 })
 
+jest.mock('shared/modules/settings/settingsDuck', () => {
+  const orig = require.requireActual('shared/modules/dbMeta/dbMetaDuck')
+  return {
+    ...orig,
+    shouldUseReadTransactions: () => false
+  }
+})
+
 jest.mock('shared/modules/dbMeta/dbMetaDuck', () => {
   const orig = jest.requireActual('shared/modules/dbMeta/dbMetaDuck')
   return {

src/shared/modules/settings/__snapshots__/settingsDuck.test.ts.snap

@@ -25,5 +25,6 @@ Object {
   "showWheelZoomInfo": true,
   "theme": "auto",
   "useBoltRouting": false,
+  "useReadTransactions": false,
 }
 `;

src/shared/modules/settings/settingsDuck.ts

@@ -70,6 +70,8 @@ export const shouldEnableMultiStatementMode = (state: any) =>
   state[NAME].enableMultiStatementMode
 export const shouldShowPerformanceOverlay = (state: any): boolean =>
   state[NAME].showPerformanceOverlay === true
+export const shouldUseReadTransactions = (state: any) =>
+  state[NAME].useReadTransactions || initialState.useReadTransactions
 
 const browserSyncConfig = (host = 'https://auth.neo4j.com') => ({
   authWindowUrl: `${host}/indexNewBrowser.html`,
@@ -122,6 +124,7 @@ export type SettingsState = {
   allowCrashReports: boolean
   allowUserStats: boolean
   showWheelZoomInfo: boolean
+  useReadTransactions: boolean
 }
 
 export const initialState: SettingsState = {
@@ -146,7 +149,8 @@ export const initialState: SettingsState = {
   showPerformanceOverlay: false,
   allowCrashReports: true,
   allowUserStats: true,
-  showWheelZoomInfo: true
+  showWheelZoomInfo: true,
+  useReadTransactions: false
 }
 
 export default function settings(state = initialState, action: any) {

src/shared/services/commandInterpreterHelper.ts

@@ -95,7 +95,10 @@ import {
   getRequest,
   update as updateQueryResult
 } from 'shared/modules/requests/requestsDuck'
-import { getSettings } from 'shared/modules/settings/settingsDuck'
+import {
+  getSettings,
+  shouldUseReadTransactions
+} from 'shared/modules/settings/settingsDuck'
 import { open } from 'shared/modules/sidebar/sidebarDuck'
 import {
   backgroundTxMetadata,
@@ -439,6 +442,7 @@ const availableCommands = [
         query.substring(prefixIndex + autoPrefix.length)
 
       action.query = isAutocommit ? withoutAutoPrefix : query
+      action.useReadTransaction = shouldUseReadTransactions(state)
 
       const [id, request] = handleCypherCommand(
         action,