teskit: Fine tunning stress tests to run in testkit

Fix the way the url is generated during the stress test enabling to use configurations came from the test environment.
Skipping the non-cluster-safe stress test commands to avoid unstable behaviours and flaky tests.

Author: bigmontz

test/internal/shared-neo4j.js

@@ -123,6 +123,11 @@ const env = global.__karma__ ? global.__karma__.config.env : process.env
 const username = env.TEST_NEO4J_USER || 'neo4j'
 const password = env.TEST_NEO4J_PASS || 'password'
 const hostname = env.TEST_NEO4J_HOST || 'localhost'
+const scheme = env.TEST_NEO4J_SCHEME || 'bolt'
+const cluster =
+  env.TEST_NEO4J_IS_CLUSTER !== undefined
+    ? env.TEST_NEO4J_IS_CLUSTER === '1'
+    : false
 const edition = env.TEST_NEO4J_EDITION || 'enterprise'
 const ipv6Enabled =
   env.TEST_NEO4J_IPV6_ENABLED !== undefined
@@ -369,5 +374,7 @@ export default {
   getEdition: getEdition,
   hostname: hostname,
   ipv6Enabled: ipv6Enabled,
-  edition: edition
+  edition: edition,
+  scheme: scheme,
+  cluster: cluster
 }

test/stress.test.js

@@ -25,6 +25,11 @@ import sharedNeo4j from './internal/shared-neo4j'
 
 describe('#integration stress tests', () => {
   const TEST_MODES = {
+    fastest: {
+      commandsCount: 10000,
+      parallelism: 24,
+      maxRunTimeMs: 3 * 60000 // 3 minutes
+    },
     fast: {
       commandsCount: 5000,
       parallelism: 8,
@@ -44,7 +49,7 @@ describe('#integration stress tests', () => {
   const TEST_MODE = modeFromEnvOrDefault('STRESS_TEST_MODE')
   const DATABASE_URI = fromEnvOrDefault(
     'STRESS_TEST_DATABASE_URI',
-    `bolt://${sharedNeo4j.hostname}`
+    `${sharedNeo4j.scheme}://${sharedNeo4j.hostname}:${sharedNeo4j.port}`
   )
 
   const USERNAME = fromEnvOrDefault(
@@ -57,10 +62,11 @@ describe('#integration stress tests', () => {
   )
 
   function isRemoteCluster () {
-    return (
-      fromEnvOrDefault('STRESS_TEST_DATABASE_URI') !== undefined &&
-      fromEnvOrDefault('STRESS_TEST_DATABASE_URI') !== undefined
-    )
+    return fromEnvOrDefault('STRESS_TEST_DATABASE_URI') !== undefined
+  }
+
+  function isCluster () {
+    return sharedNeo4j.cluster || isRemoteCluster()
   }
 
   const LOGGING_ENABLED = fromEnvOrDefault('STRESS_TEST_LOGGING_ENABLED', false)
@@ -128,19 +134,27 @@ describe('#integration stress tests', () => {
   }
 
   function createUniqueCommands (context) {
+    const clusterSafeCommands = [
+      readQueryInTxFunctionCommand(context),
+      readQueryInTxFunctionWithBookmarkCommand(context),
+      writeQueryInTxFunctionWithBookmarkCommand(context),
+      writeQueryInTxFunctionCommand(context)
+    ]
+
+    if (isCluster()) {
+      return clusterSafeCommands
+    }
+
     return [
+      ...clusterSafeCommands,
       readQueryCommand(context),
       readQueryWithBookmarkCommand(context),
       readQueryInTxCommand(context),
-      readQueryInTxFunctionCommand(context),
       readQueryInTxWithBookmarkCommand(context),
-      readQueryInTxFunctionWithBookmarkCommand(context),
       writeQueryCommand(context),
       writeQueryWithBookmarkCommand(context),
       writeQueryInTxCommand(context),
-      writeQueryInTxFunctionCommand(context),
-      writeQueryInTxWithBookmarkCommand(context),
-      writeQueryInTxFunctionWithBookmarkCommand(context)
+      writeQueryInTxWithBookmarkCommand(context)
     ]
   }
 
@@ -243,6 +257,13 @@ describe('#integration stress tests', () => {
   ) {
     return callback => {
       const commandId = context.nextCommandId()
+      if (isCluster()) {
+        console.log(
+          'SKIPPED: session.run is not safe to in clusters environments'
+        )
+        callback()
+        return
+      }
       const session = newSession(context, accessMode, useBookmark)
       const params = paramsSupplier()
 
@@ -319,6 +340,13 @@ describe('#integration stress tests', () => {
   ) {
     return callback => {
       const commandId = context.nextCommandId()
+      if (isCluster()) {
+        console.log(
+          'SKIPPED: session.begintTransaction is not safe to in clusters environments'
+        )
+        callback()
+        return
+      }
       const session = newSession(context, accessMode, useBookmark)
       const tx = session.beginTransaction()
       const params = paramsSupplier()
@@ -415,7 +443,7 @@ describe('#integration stress tests', () => {
   function verifyServers (context) {
     const routing = DATABASE_URI.indexOf('neo4j') === 0
 
-    if (routing) {
+    if (routing && isCluster()) {
       return verifyCausalClusterMembers(context)
     }
     return verifySingleInstance(context)