Removed Unhandled rejection warning

Author: pontusmelke

src/v1/driver.js

@@ -117,7 +117,7 @@ class Driver {
       if (this.onError && err.code === SERVICE_UNAVAILABLE) {
         this.onError(err);
       } else {
-        return Promise.reject(err);
+        //we don't need to tell the driver about this error
       }
     });
     return this._createSession(connectionPromise, (cb) => {
@@ -130,13 +130,14 @@ class Driver {
 
       // Queue up a 'reset', to ensure the next user gets a clean
       // session to work with.
+
       connectionPromise.then( (conn) => {
         conn.reset();
         conn.sync();
 
         // Return connection to the pool
         conn._release();
-      });
+      }).catch( () => {/*ignore errors here*/});
 
       // Call user callback
       if (cb) {
@@ -165,7 +166,6 @@ class Driver {
       if (this._openSessions.hasOwnProperty(sessionId)) {
         this._openSessions[sessionId].close();
       }
-
       this._pool.purgeAll();
     }
   }

src/v1/error.js

@@ -23,7 +23,7 @@
 let SERVICE_UNAVAILABLE = 'ServiceUnavailable';
 let SESSION_EXPIRED = 'SessionExpired';
 function newError(message, code="N/A") {
-  // TODO: Idea is that we can check the cod here and throw sub-classes
+  // TODO: Idea is that we can check the code here and throw sub-classes
   // of Neo4jError as appropriate
   return new Neo4jError(message, code);
 }

src/v1/routing-driver.js

@@ -63,7 +63,7 @@ class RoutingDriver extends Driver {
         } else {
           connectionPromise.then((conn) => {
             this._forget(conn.url);
-          });
+          }).catch(() => {/*ignore*/});
         }
         return err;
       } else if (code === 'Neo.ClientError.Cluster.NotALeader') {
@@ -74,7 +74,7 @@ class RoutingDriver extends Driver {
         } else {
           connectionPromise.then((conn) => {
             this._clusterView.writers.remove(conn.url);
-          });
+          }).catch(() => {/*ignore*/});
         }
         return newError("No longer possible to write to server at " + url, SESSION_EXPIRED);
       } else {
@@ -87,19 +87,19 @@ class RoutingDriver extends Driver {
     if (!this._clusterView.needsUpdate()) {
       return Promise.resolve(this._clusterView);
     } else {
+      let p = () => {
+        let conn = this._pool.acquire(routers.hop());
+        let session = this._createSession(Promise.resolve(conn));
+        return newClusterView(session).catch((err) => {
+          this._forget(conn);
+          return Promise.reject(err);
+        });
+      };
       let routers = this._clusterView.routers;
       let acc = Promise.reject();
       for (let i = 0; i < routers.size(); i++) {
-        acc = acc.catch(() => {
-          let conn = this._pool.acquire(routers.hop());
-          let session = this._createSession(Promise.resolve(conn));
-          return newClusterView(session).catch((err) => {
-            this._forget(conn);
-            return Promise.reject(err);
-          });
-        });
+        acc = acc.catch(p);
       }
-
       return acc;
     }
   }
@@ -139,7 +139,7 @@ class RoutingDriver extends Driver {
       } else {
         return Promise.reject(m + " is not a valid option");
       }
-    });
+    }).catch((err) => {return Promise.reject(err)});
   }
 
   _forget(url) {

test/v1/routing.driver.boltkit.it.js

@@ -123,16 +123,19 @@ describe('routing driver ', function() {
 
     kit.run(function () {
       var driver = neo4j.driver("bolt+routing://127.0.0.1:9001", neo4j.auth.basic("neo4j", "neo4j"));
+
       // When
       var session = driver.session(neo4j.READ);
       session.run("MATCH (n) RETURN n.name").catch(function (err) {
         expect(err.code).toEqual(neo4j.error.SERVICE_UNAVAILABLE);
+
+        session.close();
         driver.close();
         server.exit(function (code) {
           expect(code).toEqual(0);
           done();
         });
-      });
+      }).catch(function (err) {console.log(err)});
     });
   });