From 27390fef4446208f42fe4af7fd8ad37e862642fc Mon Sep 17 00:00:00 2001
From: Joe Fleming <joe.fleming@gmail.com>
Date: Mon, 11 Jul 2016 10:27:08 -0700
Subject: [PATCH] put job info under job property on success emitter

---
 src/worker.js      |  2 +-
 test/src/worker.js | 12 ++++++++----
 2 files changed, 9 insertions(+), 5 deletions(-)

diff --git a/src/worker.js b/src/worker.js
index 38d710d..a10f1d6 100644
--- a/src/worker.js
+++ b/src/worker.js
@@ -183,10 +183,10 @@ export default class Job extends events.EventEmitter {
       // job execution was successful
       this.debug(`Completed job ${job._id}`);
 
-      const emitJob = formatJobObject(job);
       const completedTime = moment().toISOString();
       const docOutput = this._formatOutput(output);
 
+      const emitJob = { job: formatJobObject(job) };
       const doc = {
         status: constants.JOB_STATUS_COMPLETED,
         completed_at: completedTime,
diff --git a/test/src/worker.js b/test/src/worker.js
index 2f20689..2e80991 100644
--- a/test/src/worker.js
+++ b/test/src/worker.js
@@ -601,13 +601,17 @@ describe('Worker class', function () {
 
         worker.once(constants.EVENT_WORKER_COMPLETE, (workerJob) => {
           try {
-            expect(workerJob).to.have.property('id');
-            expect(workerJob).to.have.property('index');
-            expect(workerJob).to.have.property('type');
+            expect(workerJob).to.not.have.property('_source');
+
+            expect(workerJob).to.have.property('job');
+            expect(workerJob.job).to.have.property('id');
+            expect(workerJob.job).to.have.property('index');
+            expect(workerJob.job).to.have.property('type');
+
             expect(workerJob).to.have.property('output');
             expect(workerJob.output).to.have.property('content');
             expect(workerJob.output).to.have.property('content_type');
-            expect(workerJob).to.not.have.property('_source');
+
             done();
           } catch (e) {
             done(e);