added disconnect API

src/index.js

@@ -64,6 +64,19 @@ class PgBoss extends EventEmitter {
             });
     }
 
+    disconnect() {
+        if(!this.isReady) return Promise.reject(`boss ain't ready.  Use start() or connect() to get started.`);
+        return this.manager.close.apply(this.manager, arguments).then(() => this.isReady = false);
+    }
+
+    // stop() {
+    //     return Promise.all([
+    //         this.disconnect(),
+    //         this.manager.stopSupervise(),
+    //         this.boss.stopMonitor()
+    //     ]);
+    // }
+
     cancel(){
         if(!this.isReady) return Promise.reject(`boss ain't ready.  Use start() or connect() to get started.`);
         return this.manager.cancel.apply(this.manager, arguments);

src/manager.js

@@ -42,6 +42,12 @@ class Manager extends EventEmitter {
         }
     }
 
+    close() {
+        this.workers.forEach(worker => worker.stop());
+        this.workers.length = 0;
+        return Promise.resolve(true);
+    }
+
     subscribe(name, ...args){
 
         let self = this;

src/worker.js

@@ -12,12 +12,17 @@ class Worker extends EventEmitter {
         checkForWork();
 
         function checkForWork(){
-            self.config.fetcher()
-                .then(job => { if(job) self.emit(self.config.name, job); })
-                .catch(error => self.emit('error', error))
-                .then(() => setTimeout(checkForWork, self.config.interval));
+            if(!self.stopped)
+                self.config.fetcher()
+                    .then(job => { if(job) self.emit(self.config.name, job); })
+                    .catch(error => self.emit('error', error))
+                    .then(() => setTimeout(checkForWork, self.config.interval));
         }
     }
+
+    stop() {
+        this.stopped = true;
+    }
 }
 
 module.exports = Worker;

test/connectTest.js

@@ -13,6 +13,10 @@ describe('connect', function() {
             });
     });
 
+    afterEach(function(finished){
+        boss.disconnect().then(finished);
+    });
+
     it('should fail if connecting to an older schema version', function (finished) {
         helper.getDb().executeSql(`UPDATE ${helper.config.schema}.version SET VERSION = '0.0.0'`)
             .then(() => {

test/delayTest.js

@@ -13,6 +13,10 @@ describe('delayed jobs', function(){
             });
     });
 
+    after(function(finished){
+        boss.disconnect().then(finished);
+    });
+
     it('should wait before processing a delayed job submission', function(finished) {
 
         var delaySeconds = 2;

test/publishTest.js

@@ -13,6 +13,10 @@ describe('publish', function(){
             });
     });
 
+    after(function(finished){
+        boss.disconnect().then(finished);
+    });
+
     it('should fail with no arguments', function(finished) {
         boss.publish().catch(error => {
             assert(true);

test/retryTest.js

@@ -12,6 +12,10 @@ describe('retries', function() {
                 finished();
             });
     });
+
+    after(function(finished){
+        boss.disconnect().then(finished);
+    });
 
     it('should retry a job that didn\'t complete', function (finished) {
 

test/speedTest.js

@@ -13,6 +13,10 @@ describe('speed', function() {
             });
     });
 
+    after(function(finished){
+        boss.disconnect().then(finished);
+    });
+
     var expectedSeconds = 4;
     var jobCount = 1000;
 

test/throttleTest.js

@@ -13,6 +13,10 @@ describe('throttle', function() {
             });
     });
 
+    after(function(finished){
+        boss.disconnect().then(finished);
+    });
+
     it('should process at most 1 job per second', function (finished) {
 
         var singletonSeconds = 1;