Results from each operation returned sequentially in a list

Author: emmanuel

lib/task.js

@@ -227,16 +227,20 @@ var Task = function(){
     var dbTask = new TaskMdl({steps: steps});
     steps = [];
     index = 0;
+    var results = [];
 
     return dbTask.save().then(function (_task) {
       _task.steps.forEach(function (step) {
         chain = chain.then(function () {
-          return getResolveFunc(step)(step, _task);
+          return getResolveFunc(step)(step, _task, results);
         });
       });
 
-      return chain.then(function () {
-        return _task.remove();
+      return chain.then(function (results) {
+        return _task.remove()
+          .then(function () {
+            return Promise.resolve(results);
+          });
       }).catch(function (err) {
         return Roller.rollOne(_task).then(function () {
           throw err;
@@ -267,10 +271,11 @@ function getResolveFunc(step){
  *
  * @param update the update step
  * @param task the task containing update
+ * @param results array of results from previous operations
  *
  * @returns {Promise|*}
  */
-function performUpdate(update, task) {
+function performUpdate(update, task, results) {
   var Collection = getModel(update.name);
 
   handle$Token(update.condition, true);
@@ -280,11 +285,13 @@ function performUpdate(update, task) {
   return storeOldData(update, task)
     .then(function(){
       return updateState(task, update.index, PENDING)
-        .then(function(_task){
+        .then(function () {
           return Collection.update(update.condition, update.data, update.options)
             .exec()
-            .then(function(){
-              return updateState(_task, update.index, DONE);
+            .then(function (result) {
+              results.push(result);
+
+              return updateState(task, update.index, DONE, results);
             });
         });
     });
@@ -296,10 +303,11 @@ function performUpdate(update, task) {
  *
  * @param save the save step
  * @param task the task containing save
+ * @param results array of results from previous operations
  *
  * @returns {Promise|*}
  */
-function performSave(save, task){
+function performSave(save, task, results) {
   var Collection = getModel(save.name);
   var doc = new Collection(save.data);
   var dataStore = [];
@@ -310,9 +318,11 @@ function performSave(save, task){
   task.steps[save.index].dataStore = dataStore;
   task.steps[save.index].markModified("dataStore");
 
-  return updateState(task, save.index, PENDING).then(function (_task) {
-    return doc.save().then(function () {
-      return updateState(_task, save.index, DONE);
+  return updateState(task, save.index, PENDING).then(function () {
+    return doc.save().then(function (result) {
+      results.push(result);
+
+      return updateState(task, save.index, DONE, results);
     });
   });
 }
@@ -322,18 +332,21 @@ function performSave(save, task){
  *
  * @param remove the remove step
  * @param task the task containing remove
+ * @param results array of results from previous operations
  *
  * @returns {Promise|*}
  */
-function performRemove(remove, task){
+function performRemove(remove, task, results) {
   var Collection = getModel(remove.name);
 
   handle$Token(remove.condition, true);
 
   return storeOldData(remove, task).then(function () {
-    return updateState(task, remove.index, PENDING).then(function (_task) {
-      return Collection.remove(remove.condition).exec().then(function () {
-        return updateState(_task, remove.index, DONE);
+    return updateState(task, remove.index, PENDING).then(function () {
+      return Collection.remove(remove.condition).exec().then(function (result) {
+        results.push(result);
+
+        return updateState(task, remove.index, DONE, results);
       });
     });
   });

lib/utils.js

@@ -5,14 +5,19 @@
  * @since 8/9/16
  */
 var modelCache = {};
+var Promise = require("bluebird");
 
 module.exports = function(_mongoose){
   var mongoose = _mongoose || require("mongoose");
   var Schema = mongoose.Schema;
 
-  function updateState(task, index, state){
+  function updateState(task, index, state, results) {
     task.steps[index].state = state;
-    return task.save();
+
+    return task.save()
+      .then(function () {
+        return Promise.resolve(results);
+      });
   }
 
   function getCollection(name, schema){

tests/task.tests.js

@@ -214,4 +214,18 @@ module.exports = describe("Task", function(){
       return expect(TestMdlB.find().exec()).to.eventually.have.length(2);
     });
   });
+
+  describe("Results Array", function () {
+    it("Should have the results of all operations", function () {
+      var gabe = new TestMdlB({name: "Gabe", age: 34});
+
+      return expect(
+        task.save(gabe)
+          .save(TEST_COLLECTION_A, {name: "Gabe's Owner", age: 60})
+          .update(gabe, {age: 64})
+          .remove(TEST_COLLECTION_A, {name: "Gabe's Owner"})
+          .run()
+      ).to.eventually.have.length(4);
+    });
+  })
 });