Implement WorkerManager.prototype.isReady

lib/worker-manager.js

@@ -29,6 +29,10 @@ export default class WorkerManager {
     this.createNewWorker();
   }
 
+  isReady() {
+    return this.activeWorker.isReady();
+  }
+
   request(data) {
     if (this.destroyed) { throw new Error('Worker is destroyed'); }
     let operation;
@@ -82,6 +86,10 @@ export default class WorkerManager {
     return this.activeWorker;
   }
 
+  getReadyPromise() {
+    return this.activeWorker.getReadyPromise();
+  }
+
   destroy(force) {
     this.destroyed = true;
     this.workers.forEach(worker => worker.destroy(force));
@@ -112,6 +120,10 @@ export class Worker {
     });
   }
 
+  isReady() {
+    return this.rendererProcess.isReady();
+  }
+
   getLoadUrl(operationCountLimit) {
     const htmlPath = path.join(getPackageRoot(), 'lib', 'renderer.html');
     const rendererJsPath = path.join(getPackageRoot(), 'lib', 'worker.js');
@@ -234,9 +246,14 @@ export class RendererProcess {
       this.emitter,
     );
 
+    this.ready = false;
     this.readyPromise = new Promise(resolve => { this.resolveReady = resolve; });
   }
 
+  isReady() {
+    return this.ready;
+  }
+
   @autobind
   handleDestroy(...args) {
     this.destroy();
@@ -253,6 +270,7 @@ export class RendererProcess {
     ipc.on(Worker.channelName, handleMessages);
     this.emitter.on('renderer-ready', ({pid}) => {
       this.pid = pid;
+      this.ready = true;
       this.resolveReady();
     });
     this.emitter.on('git-data', this.onData);

test/worker-manager.test.js

@@ -14,6 +14,19 @@ describe('WorkerManager', function() {
     workerManager.destroy(true);
   });
 
+  describe('isReady()', function() {
+    it('returns true if its worker is ready', async function() {
+      assert.isFalse(workerManager.isReady());
+      await workerManager.getReadyPromise();
+      assert.isTrue(workerManager.isReady());
+
+      workerManager.onSick(workerManager.getActiveWorker());
+      assert.isFalse(workerManager.isReady());
+      await workerManager.getReadyPromise();
+      assert.isTrue(workerManager.isReady());
+    });
+  });
+
   describe('when a worker process crashes', function() {
     it('creates a new worker process (with the same operation count limit) and executes remaining operations', async function() {
       workerManager.createNewWorker({operationCountLimit: 40});