Added ability to purge item in pool

We need purging of item in the connection pool since we need a way of removing connections
that are no longer online or in other ways have been removed from a cluster.

Author: pontusmelke

src/v1/internal/pool.js

@@ -42,17 +42,31 @@ class Pool {
   acquire(key) {
     let resource;
     let pool = this._pools[key] || [];
-    while( pool.length ) {
+    while (pool.length) {
       resource = pool.pop();
 
-      if( this._validate(resource) ) {
+      if (this._validate(resource)) {
         return resource;
       }
     }
 
     return this._create(this._release);
   }
 
+  purge(key) {
+    let resource;
+    let pool = this._pools[key] || [];
+    while (pool.length) {
+      resource = pool.pop();
+      this._destroy(resource)
+    }
+    delete this._pools[key]
+  }
+
+  has(key) {
+    return (key in this._pools);
+  }
+
   _release(key, resource) {
     let pool = this._pools[key];
     if (!pool) {

test/internal/pool.test.js

@@ -120,6 +120,38 @@ describe('Pool', function() {
     expect( destroyed[0].id ).toBe( r0.id );
     expect( destroyed[1].id ).toBe( r1.id );
   });
+
+
+  it('purges keys', function() {
+    // Given a pool that allocates
+    var counter = 0;
+    var key1 = "bolt://localhost:7687";
+    var key2 = "bolt://localhost:7688";
+    var pool = new Pool( function (release) { return new Resource(counter++, release) },
+      function (res) {res.destroyed = true; return true}
+    );
+
+    // When
+    var r0 = pool.acquire(key1);
+    var r1 = pool.acquire(key2);
+    r0.close(key1);
+    r1.close(key2);
+    expect(pool.has(key1)).toBe(true);
+    expect(pool.has(key2)).toBe(true);
+    pool.purge(key1);
+    expect(pool.has(key1)).toBe(false);
+    expect(pool.has(key2)).toBe(true);
+
+    var r2 = pool.acquire(key1);
+    var r3 = pool.acquire(key2);
+
+    // Then
+    expect( r0.id ).toBe( 0 );
+    expect( r0.destroyed ).toBe( true );
+    expect( r1.id ).toBe( 1 );
+    expect( r2.id ).toBe( 2 );
+    expect( r3.id ).toBe( 1 );
+  });
 });
 
 function Resource( id, release) {