Change the java driver to use neokit to manage server start

Author: Zhen

.gitmodules

@@ -0,0 +1,3 @@
+[submodule "neokit"]
+	path = neokit
+	url = https://github.com/neo-technology/neokit.git

gulpfile.js

@@ -165,46 +165,9 @@ gulp.task('watch-n-test', ['test-nodejs'], function () {
   return gulp.watch(['src/**/*.js', "test/**/*.js"], ['test-nodejs'] );
 });
 
-var neo4jLinuxUrl = 'http://alpha.neohq.net/dist/neo4j-enterprise-3.0.0-NIGHTLY-unix.tar.gz';
-var neo4jWinUrl   = 'http://alpha.neohq.net/dist/neo4j-enterprise-3.0.0-NIGHTLY-windows.zip';
-var neo4jHome     = './build/neo4j-enterprise-3.0.0';
-var isWin         = /^win/.test(process.platform);
-
-gulp.task('download-neo4j', function() {
-  if( !fs.existsSync(neo4jHome) ) {
-    // Need to download
-    if(isWin) {
-        return download(neo4jWinUrl)
-              .pipe(decompress({strip: 1}))
-              .pipe(gulp.dest(neo4jHome));
-    }
-    else {
-        return download(neo4jLinuxUrl)
-              .pipe(decompress({strip: 1}))
-              .pipe(gulp.dest(neo4jHome));
-    }
-  }
-});
-
-gulp.task('set-password', ['download-neo4j'], function() {
-  var setPassword = gulp.src('test/resources/auth')
-  .pipe(gulp.dest(neo4jHome + "/data/dbms/"));
-
-  if(isWin)
-  {
-    var setServerName = gulp.src('test/resources/neo4j-wrapper.conf')
-    .pipe(gulp.dest(neo4jHome + "/conf/"));
-
-    return merge(setPassword, setServerName);
-  }
-  else
-  {
-    return setPassword;
-  }
-});
 
 var featureFiles   = 'https://s3-eu-west-1.amazonaws.com/remoting.neotechnology.com/driver-compliance/tck.tar.gz';
-var featureHome     = './build/tck';
+var featureHome    = './build/tck';
 
 gulp.task('download-tck', function() {
   return download(featureFiles)
@@ -220,21 +183,6 @@ gulp.task('run-tck', ['download-tck', 'nodejs'], function() {
     }));
 });
 
-var runPowershell = function( cmd ) {
-    var spawn = childProcess.spawn, child;
-    child = spawn("powershell.exe",[cmd]);
-    child.stdout.on("data",function(data){
-        console.log("Powershell Data: " + data);
-    });
-    child.stderr.on("data",function(data){
-        console.error("Powershell Errors: " + data);
-    });
-    child.on("exit",function(){
-        console.log("Powershell Script finished");
-    });
-    child.stdin.end(); //end input
-};
-
 /** Set the project version, controls package.json and version.js */
 gulp.task('set', function() {
   // Get the --version arg from command line
@@ -247,28 +195,37 @@ gulp.task('set', function() {
 
 });
 
-gulp.task('start-neo4j', ['set-password'], function() {
-  if(isWin) {
-    return runPowershell(neo4jHome + '/bin/neo4j.bat install-service;' + neo4jHome + '/bin/neo4j.bat start');
-  }
-  else {
-    return gulp.src('').pipe(shell([
-      'mkdir -p ' + neo4jHome + '/logs',
-      'mkdir -p ' + neo4jHome + '/run',
-      'mkdir -p ' + neo4jHome + '/plugins',
-      'mkdir -p ' + neo4jHome + '/import',
-      'chmod +x ' + neo4jHome + '/bin/neo4j',
-      neo4jHome + '/bin/neo4j start',
-    ]));
-  }
+
+var neo4jHome  = path.resolve('./build/neo4j');
+var neorunPath = path.resolve('./neokit/neorun.py');
+
+gulp.task('start-neo4j', function() {
+
+    //var neorunArgs = minimist(process.argv.slice(2), { string: 'opts' }).opts;
+    var neorunArgs;
+    neorunArgs = neorunArgs || '-v 3.0.1 -p neo4j';
+
+    return runScript([
+        neorunPath, '--start=' + neo4jHome
+    ].concat( neorunArgs.split(" ") ) );
 });
 
 gulp.task('stop-neo4j', function() {
-  if(isWin) {
-    return runPowershell(neo4jHome + '/bin/neo4j.bat stop;' + neo4jHome + '/bin/neo4j.bat uninstall-service');
-  } else {
-    return gulp.src('').pipe(shell([
-      neo4jHome + '/bin/neo4j stop',
-    ]));
-  }
-});
+    return runScript([
+        neorunPath, '--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
+    }
+};

neokit

@@ -57,7 +57,7 @@ describe('trust-signed-certificates', function() {
     driver = neo4j.driver("bolt://localhost", neo4j.auth.basic("neo4j", "neo4j"), {
       encrypted: true,
       trust: "TRUST_SIGNED_CERTIFICATES",
-      trustedCertificates: ["build/neo4j-enterprise-3.0.0/certificates/neo4j.cert"]
+      trustedCertificates: ["build/neo4j/certificates/neo4j.cert"]
     });
 
     // When

test/internal/tls.test.js

@@ -1,21 +1,24 @@
 var neo4j = require("../../../../lib/v1");
 var util = require("./util");
 
+var CALLBACK_TIMEOUT = 60 * 1000;
+
 module.exports = function () {
 
-  this.Given(/^a running Neo(\d+)j Database$/, {timeout: 60 * 1000}, function (ignored, callback) {
+  this.Given(/^a running Neo(\d+)j Database$/, {timeout: CALLBACK_TIMEOUT}, function (ignored, callback) {
     if (this.driver1) this.driver1.close();
     if (this.driver2) this.driver2.close();
     util.changeCertificates('./test/resources/derived.key', './test/resources/derived.cert');
-    util.restart(callback);
+    util.restart();
+    callback();
   });
 
   this.When(/^I connect via a TLS\-enabled transport for the first time for the given hostname and port$/, function (callback) {
     this.driver1 = _connectWithHostFile(this.knownHosts1);
     callback();
   });
 
-  this.Then(/^sessions should simply work$/, {timeout: 60 * 1000},  function (callback) {
+  this.Then(/^sessions should simply work$/, {timeout: CALLBACK_TIMEOUT},  function (callback) {
     var session = this.driver1.session();
     session.run("RETURN 1").then(function (result) {
       session.close();
@@ -26,15 +29,14 @@ module.exports = function () {
   });
 
   this.Given(/^a running Neo(\d+)j Database that I have connected to with a TLS\-enabled transport in the past$/,
-    {timeout: 60 * 1000}, function (arg1, callback) {
+    {timeout: CALLBACK_TIMEOUT}, function (arg1, callback) {
       util.changeCertificates('./test/resources/derived.key', './test/resources/derived.cert');
       var self = this;
-      util.restart(function () {
-        var driver = _connectWithHostFile(self.knownHosts1);
-        driver.session().run("RETURN 1").then(function (result) {
-          driver.close();
-          callback();
-        });
+      util.restart();
+      var driver = _connectWithHostFile(self.knownHosts1);
+      driver.session().run("RETURN 1").then(function (result) {
+        driver.close();
+        callback();
       });
     });
 
@@ -43,9 +45,10 @@ module.exports = function () {
     callback();
   });
 
-  this.Given(/^the database has changed which certificate it uses$/, {timeout: 60 * 1000}, function (callback) {
+  this.Given(/^the database has changed which certificate it uses$/, {timeout: CALLBACK_TIMEOUT}, function (callback) {
     util.changeCertificates('./test/resources/other.key', './test/resources/other.cert');
-    util.restart(callback);
+    util.restart();
+    callback();
   });
 
   this.Then(/^creating sessions should fail$/, function (callback) {
@@ -114,17 +117,18 @@ module.exports = function () {
   });
 
   this.Given(/^a running Neo(\d+)j Database using a certificate signed by the same trusted certificate$/,
-    {timeout: 60 * 1000}, function (arg1, callback) {
+    {timeout: CALLBACK_TIMEOUT}, function (arg1, callback) {
       util.changeCertificates('./test/resources/derived.key', './test/resources/derived.cert');
-      util.restart(callback);
+      util.restart();
+      callback();
     });
 
   this.When(/^I connect via a TLS\-enabled transport$/, function (callback) {
     this.driver1 = neo4j.driver("bolt://localhost", neo4j.auth.basic("neo4j", "neo4j"), this.config);
     callback();
   });
 
-  this.Given(/^a running Neo(\d+)j Database using that exact trusted certificate$/, {timeout: 60 * 1000}, function (arg1, callback) {
+  this.Given(/^a running Neo(\d+)j Database using that exact trusted certificate$/, {timeout: CALLBACK_TIMEOUT}, function (arg1, callback) {
     //will have to hack a little bit here since the root cert cannot be used by the server since its
     //common name is not set to localhost
     this.config = {
@@ -135,13 +139,15 @@ module.exports = function () {
     };
 
     util.changeCertificates('./test/resources/other.key', './test/resources/other.cert');
-    util.restart(callback);
+    util.restart();
+    callback();
   });
 
-  this.Given(/^a running Neo(\d+)j Database using a certificate not signed by the trusted certificate$/, {timeout: 60 * 1000},
+  this.Given(/^a running Neo(\d+)j Database using a certificate not signed by the trusted certificate$/, {timeout: CALLBACK_TIMEOUT},
     function (arg1, callback) {
       util.changeCertificates('./test/resources/other.key', './test/resources/other.cert');
-      util.restart(callback);
+      util.restart();
+      callback();
     });
 
   this.Then(/^I should get a helpful error explaining that no trusted certificate found$/, function (callback) {
@@ -165,4 +171,4 @@ module.exports = function () {
       encrypted: true
     });
   }
-};
+};

test/resources/auth

@@ -27,8 +27,8 @@ NULL = 'null';
 RELATIONSHIP = 'relationship';
 NODE = 'node';
 PATH = 'path';
-var isWin = /^win/.test(process.platform);
-var neo4jHome     = './build/neo4j-enterprise-3.0.0';
+var neorunPath = './neokit/neorun.py';
+var neo4jHome = './build/neo4j';
 var neo4jCert = neo4jHome + '/certificates/neo4j.cert';
 var neo4jKey = neo4jHome + '/certificates/neo4j.key';
 var childProcess = require("child_process");
@@ -354,48 +354,33 @@ function changeCertificates(keyFile, certFile) {
   fs.writeFileSync(neo4jCert, cert);
 }
 
-function restart(callback) {
+function restart() {
   stopDatabase();
-  setTimeout(function () {
-    startDatabase();
-    setTimeout(function () {
-      callback();}, 5000);
-  }, 5000);
+  startDatabase();
 }
 
 function startDatabase() {
-  if(isWin) {
-    return runPowershell(neo4jHome + '/bin/neo4j.bat install-service;' + neo4jHome + '/bin/neo4j.bat start');
-  } else {
-    childProcess.exec(neo4jHome + '/bin/neo4j start', function (err, stdout, stderr) {
-      console.log("starting");
-      if (err) throw err;
-    });
-  }
+  return runScript([
+    neorunPath, '--start=' + neo4jHome
+  ]);
 }
 
 function stopDatabase() {
-  if(isWin) {
-    runPowershell(neo4jHome + '/bin/neo4j.bat stop;' + neo4jHome + '/bin/neo4j.bat uninstall-service');
-  } else {
-    childProcess.exec(neo4jHome + '/bin/neo4j stop', function (err, stdout, stderr) {
-      console.log("stopping");
-      if (err) throw err;
-    });
-  }
+  return runScript([
+    neorunPath, '--stop=' + neo4jHome
+  ]);
 }
 
-var runPowershell = function( cmd ) {
-    var spawn = childProcess.spawn, child;
-    child = spawn("powershell.exe",[cmd]);
-    child.stdout.on("data",function(data){
-        console.log("Powershell Data: " + data);
-    });
-    child.stderr.on("data",function(data){
-        console.error("Powershell Errors: " + data);
-    });
-    child.on("exit",function(){
-        console.log("Powershell Script finished");
-    });
-    child.stdin.end(); //end input
-};
+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
+  }
+};