workflow execution stats

Author: PeterAronZentai

index.js

@@ -178,7 +178,7 @@ var workflow = {
 
 
             return function execute(done) {
-
+                var wfStartTime = new Date().getTime()
 
                 if (!checkCondition(context))
                     return done()
@@ -266,6 +266,9 @@ var workflow = {
                     }
 
                     debug("Finished executing WF %s", getStepName(workflowDefinition))
+                    if (context.$$$stats) {
+                      context.$$$stats.push(getStepName(workflowDefinition) + " execution time: " + (new Date().getTime() - wfStartTime) +"ms")
+                    }
                     var originalDone = context.originalTerminate || done;
                     var donePosition = context.completionStack.indexOf(originalDone);
                     context.completionStack.splice(donePosition, 1)

test/workflow-stats.js

@@ -0,0 +1,46 @@
+var worksmith = require('..')
+var assert = require('assert')
+
+describe("workflow status", function() {
+    it("should be created", function(done) {
+        this.slow()
+        var wf = worksmith([
+          {
+            name:"t1",
+            taskName:"t1",
+            task: function(def) {
+              return function build(context) {
+                return function execute(d) {
+
+                    //console.log("d1")
+                    setTimeout(function() {
+                      d()
+                    }, 500)
+                }
+              }
+            }
+          },
+          {
+            taskName:"t2",
+            name: "t2",
+            task: function(def) {
+              return function build(context) {
+                return function execute(d) {
+                    //console.log("d2")
+                    setTimeout(function() {
+                      d()
+                    }, 500)
+                }
+              }
+            }
+          }
+
+        ]);
+        var before = Date.now()
+        var ctx = { $$$stats: []}
+        wf(ctx, function(err, result, ctx) {
+            assert(ctx.$$$stats.join("").match(/t1 execution time: [0-9]{3}mst2 execution time: [0-9]{3}mssequence execution time: [0-9]{4}ms/))
+              done(null, result)
+        })
+    })
+})