Use boltkit for ITs and TCK

This commit makes integration tests and TCK use boltkit for starting/stopping
a shared database instance. They previously used neokit submodule which is
now outdated.

Author: lutovich

README.md

@@ -50,7 +50,7 @@ We build a special browser version of the driver, which supports connecting to N
 This will make a global `neo4j` object available, where you can access the `v1` API at `neo4j.v1`:
 
 ```javascript
-var driver = neo4j.driver("bolt://localhost", neo4j.auth.basic("neo4j", "neo4j"));
+var driver = neo4j.driver("bolt://localhost", neo4j.auth.basic("username", "password"));
 ```
 
 It is not required to explicitly close the driver on a web page. Web browser should gracefully close all open 
@@ -67,7 +67,7 @@ Driver creation:
 ```javascript
 // Create a driver instance, for the user neo4j with password neo4j.
 // It should be enough to have a single driver per database per application.
-var driver = neo4j.driver("bolt://localhost", neo4j.auth.basic("neo4j", "neo4j"));
+var driver = neo4j.driver("bolt://localhost", neo4j.auth.basic("username", "password"));
 
 // Register a callback to know if driver creation was successful:
 driver.onCompleted = function () {
@@ -126,7 +126,7 @@ Transaction functions API:
 // Transaction functions provide a convenient API with minimal boilerplate and
 // retries on network fluctuations and transient errors. Maximum retry time is
 // configured on the driver level and is 30 seconds by default:
-neo4j.driver("bolt://localhost", neo4j.auth.basic("neo4j", "neo4j"), {maxTransactionRetryTime: 30000});
+neo4j.driver("bolt://localhost", neo4j.auth.basic("username", "password"), {maxTransactionRetryTime: 30000});
 
 // It is possible to execute read transactions that will benefit from automatic
 // retries on both single instance ('bolt' URI scheme) and Causal Cluster

gulpfile.babel.js

@@ -22,7 +22,6 @@ var source = require('vinyl-source-stream');
 var buffer = require('vinyl-buffer');
 var gulp = require('gulp');
 var through = require('through2');
-var gulpif = require('gulp-if');
 var uglify = require('gulp-uglify');
 var concat = require('gulp-concat');
 var gutil = require('gulp-util');
@@ -40,14 +39,14 @@ var decompress = require('gulp-decompress');
 var fs = require("fs-extra");
 var runSequence = require('run-sequence');
 var path = require('path');
-var childProcess = require("child_process");
 var minimist = require('minimist');
 var cucumber = require('gulp-cucumber');
 var merge = require('merge-stream');
 var install = require("gulp-install");
 var os = require('os');
 var file = require('gulp-file');
 var semver = require('semver');
+var sharedNeo4j = require('./test/internal/shared-neo4j').default;
 
 gulp.task('default', ["test"]);
 
@@ -232,43 +231,12 @@ gulp.task('set', function() {
 });
 
 
-var neo4jHome  = path.resolve('./build/neo4j');
-var neorunPath = path.resolve('./neokit/neorun.py');
-var neorunStartArgsName = "--neorun.start.args"; // use this args to provide additional args for running neorun.start
+var neo4jHome = path.resolve('./build/neo4j');
 
-gulp.task('start-neo4j', function() {
-
-    var neorunStartArgs = '-p neo4j'; // default args to neorun.start: change the default password to neo4j
-    process.argv.slice(2).forEach(function (val) {
-        if(val.startsWith(neorunStartArgsName))
-        {
-            neorunStartArgs = val.split("=")[1];
-        }
-    });
-
-    neorunStartArgs = neorunStartArgs.match(/\S+/g) || '';
-
-    return runScript([
-        neorunPath, '--start=' + neo4jHome
-    ].concat( neorunStartArgs ) );
+gulp.task('start-neo4j', function () {
+  sharedNeo4j.start(neo4jHome, process.env.NEOCTRL_ARGS);
 });
 
-gulp.task('stop-neo4j', function() {
-    return runScript([
-        neorunPath, '--stop=' + neo4jHome
-    ]);
+gulp.task('stop-neo4j', function () {
+  sharedNeo4j.stop(neo4jHome);
 });
-
-var runScript = function(cmd) {
-    var spawnSync = childProcess.spawnSync, child, code;
-    child = spawnSync('python', cmd);
-    console.log("Script Outputs:\n" + child.stdout.toString());
-    var error = child.stderr.toString();
-    if (error.trim() !== "")
-        console.log("Script Errors:\n"+ error);
-    code = child.status;
-    if( code !==0 )
-    {
-        throw "Script finished with code " + code
-    }
-};

runTests.ps1

@@ -10,7 +10,7 @@ try
 	}
 	else
 	{
-		$env:NEORUN_START_ARGS="$args"
+		$env:NEOCTRL_ARGS="$args"
 		npm run start-neo4j
 	}
 

runTests.sh

@@ -10,10 +10,9 @@ npm install
 if [ "$1" == "" ]; then
     npm run start-neo4j
 else
-    # Example: ./runTests.sh '-v 3.0.1 -p neo4j'
-    # Example: npm run start-neo4j -- --neorun.start.args='-v 3.0.1 -p neo4j'
-    NEORUN_START_ARGS="$1" npm run start-neo4j
+    # Example: ./runTests.sh '-e 3.1.3'
+    NEOCTRL_ARGS="$1" npm run start-neo4j
 fi
 
 sleep 2
-npm test
+npm test

test/internal/connector.test.js

@@ -23,6 +23,7 @@ import {Packer} from '../../src/v1/internal/packstream';
 import {Chunker} from '../../src/v1/internal/chunking';
 import {alloc} from '../../src/v1/internal/buf';
 import {Neo4jError} from '../../src/v1/error';
+import sharedNeo4j from '../internal/shared-neo4j';
 
 describe('connector', () => {
 
@@ -31,7 +32,7 @@ describe('connector', () => {
     const conn = connect("bolt://localhost");
 
     // When
-    conn.initialize("mydriver/0.0.0", {scheme: "basic", principal: "neo4j", credentials: "neo4j"}, {
+    conn.initialize("mydriver/0.0.0", basicAuthToken(), {
       onCompleted: msg => {
         expect(msg).not.toBeNull();
         conn.close();
@@ -49,7 +50,7 @@ describe('connector', () => {
 
     // When
     const records = [];
-    conn.initialize("mydriver/0.0.0", {scheme: "basic", principal: "neo4j", credentials: "neo4j"});
+    conn.initialize("mydriver/0.0.0", basicAuthToken());
     conn.run("RETURN 1.0", {});
     conn.pullAll({
       onNext: record => {
@@ -70,10 +71,10 @@ describe('connector', () => {
     const conn = connect("bolt://localhost", {channel: DummyChannel.channel});
 
     // When
-    conn.initialize("mydriver/0.0.0", {scheme: "basic", principal: "neo4j", credentials: "neo4j"});
+    conn.initialize("mydriver/0.0.0", basicAuthToken());
     conn.run("RETURN 1", {});
     conn.sync();
-    expect(observer.instance.toHex()).toBe('60 60 b0 17 00 00 00 01 00 00 00 00 00 00 00 00 00 00 00 00 00 41 b2 01 8e 6d 79 64 72 69 76 65 72 2f 30 2e 30 2e 30 a3 86 73 63 68 65 6d 65 85 62 61 73 69 63 89 70 72 69 6e 63 69 70 61 6c 85 6e 65 6f 34 6a 8b 63 72 65 64 65 6e 74 69 61 6c 73 85 6e 65 6f 34 6a 00 00 00 0c b2 10 88 52 45 54 55 52 4e 20 31 a0 00 00 ');
+    expect(observer.instance.toHex()).toBe('60 60 b0 17 00 00 00 01 00 00 00 00 00 00 00 00 00 00 00 00 00 44 b2 01 8e 6d 79 64 72 69 76 65 72 2f 30 2e 30 2e 30 a3 86 73 63 68 65 6d 65 85 62 61 73 69 63 89 70 72 69 6e 63 69 70 61 6c 85 6e 65 6f 34 6a 8b 63 72 65 64 65 6e 74 69 61 6c 73 88 70 61 73 73 77 6f 72 64 00 00 00 0c b2 10 88 52 45 54 55 52 4e 20 31 a0 00 00 ');
     done();
   });
 
@@ -82,7 +83,7 @@ describe('connector', () => {
     const conn = connect("bolt://localhost:7474", {encrypted: false});
 
     // When
-    conn.initialize("mydriver/0.0.0", {scheme: "basic", principal: "neo4j", credentials: "neo4j"}, {
+    conn.initialize("mydriver/0.0.0", basicAuthToken(), {
       onCompleted: msg => {
       },
       onError: err => {
@@ -142,4 +143,12 @@ describe('connector', () => {
     }).toThrow(new Neo4jError(expectedMessage, expectedCode));
   }
 
+  function basicAuthToken() {
+    return {
+      scheme: 'basic',
+      principal: sharedNeo4j.username,
+      credentials: sharedNeo4j.password
+    };
+  }
+
 });