Routing WIP

Author: pontusmelke

src/v1/driver.js

@@ -238,7 +238,10 @@ class RoutingDriver extends Driver {
     while (!this._routers.empty() && !success) {
       let url = this._routers.hop();
       try {
+        console.log("awaiting resulyt");
         let res = await this._call(url);
+        console.log("got result");
+        console.log(res);
         if (res.records.length != 1) continue;
         let record = res.records[0];
         //Note we are loosing precision here but we are not
@@ -266,7 +269,7 @@ class RoutingDriver extends Driver {
         //these are no longer valid according to server
         let self = this;
         seen.forEach((key) => {
-          self._pool.purge(key);
+          self._pools.purge(key);
         });
         success = true;
         return;
@@ -319,7 +322,6 @@ class RoutingDriver extends Driver {
   async _call(url) {
     let conn = this._pool.acquire(url);
     let session = this._createSession(conn);
-    console.log("calling " + GET_SERVERS);
     return session.run(GET_SERVERS)
       .then((res) => {
         session.close();

test/v1/routing.driver.test.js

@@ -19,27 +19,25 @@
 
 var neo4j = require("../../lib/v1");
 var boltkit = require('./boltkit');
-xdescribe('routing driver ', function() {
+describe('routing driver ', function() {
 
-  it('should discover server', function (done) {
+  fit('should discover server', function (done) {
     if (!boltkit.BoltKitSupport) {
       done();
       return;
     }
     // Given
-    var kit = new boltkit.BoltKit();
+    var kit = new boltkit.BoltKit(true);
     var server = kit.start('./test/resources/boltkit/discover_servers.script', 9001);
 
     kit.run(function () {
       var driver = neo4j.driver("bolt+routing://localhost:9001", neo4j.auth.basic("neo4j", "neo4j"));
-
-      setTimeout(function () {
+      console.log("got driver");
         driver.close();
         server.exit(function (code) {
           expect(code).toEqual(0);
           done();
         });
-      }, 1000);
     });
   });
 });