Stress test: alculating exec time average for a demanding workflow

Author: feliun

stress-test/stress-test.js

@@ -1,16 +1,38 @@
 var worksmith = require('..')
 var _ = require('lodash')
+var async = require('async')
 packageJson = require('../package.json')
 
 console.log('Stress tests for worksmith version ', packageJson.version)
 
-try {
+var SAMPLE_SIZE = 100
 
+try {
     worksmith.use("lodash", worksmith.createAdapter(require('lodash')))
     var workflow = worksmith("./stress-test/stress-workflows/workflow1.js")
-    var ctx = {}
-    workflow(ctx, function(err, results) { if (err) console.error('There was an error running a workflow: ', err.toString()) })
-
+    console.log('About to execute workflow1')
+    calculateAverageExecTime(function(average) {
+        console.log('The average execution time is: ', average, ' ms')
+    })
 } catch(e) {
-    console.error('There was an error configuring old data deletion: ', e)
+    console.error('There was an error setting up a workflow: ', e)
+}
+
+function calculateAverageExecTime(next) {
+    var average = counter = 0
+    async.whilst(
+        function () { return counter < SAMPLE_SIZE },
+        function (cb) {
+            counter++;
+            var ctx = {}
+            workflow(ctx, function(err, results) {
+                if (err) console.error('There was an error running a workflow: ', err.toString())
+                average += ctx.duration
+                cb()
+            })
+        },
+        function (err) {
+            next(average / SAMPLE_SIZE)
+        }
+    )
 }

stress-test/stress-workflows/workflow1.js

@@ -1,10 +1,6 @@
 module.exports = {
     "task": "sequence",
     "items": [
-        {
-            "task": "log",
-            "message": "Stress test 1"
-        },
         {
             "task": "set",
             "name": "startTime",
@@ -15,12 +11,23 @@ module.exports = {
             "taskPath": "/stress-test/tasks",
             "size": 1000,
             "depth": 3,
+            "prefix": "level",
             "resultTo": "objectList"
         },
         {
             "task": "while",
             "test": "[eval]objectList.length > 0[/eval]",
             "subflow": [
+                {
+                    "task": "lodash/last",
+                    "arguments": [ "@objectList" ],
+                    "resultTo": "object"
+                },
+                {
+                    "task": "set",
+                    "name": "extractedValue",
+                    "value": "@object.level3.level2.level1.level0"
+                },
                 {
                     "task": "lodash/initial",
                     "arguments": [ "@objectList" ],
@@ -32,10 +39,6 @@ module.exports = {
             "task": "set",
             "name": "duration",
             "value": "[eval](new Date()).getTime() - startTime[/eval]"
-        },
-        {
-            "task": "log",
-            "message": "[hbs]End of test. Duration: {{duration}} ms[/hbs]"
         }
     ]
 }

stress-test/tasks/createDeepObjects.js

@@ -3,14 +3,24 @@ var _ = require('lodash')
 module.exports = function(definition) {
     return function build(context) {
 
-        execute.annotations = { inject: ['size', 'depth'] }
+        execute.annotations = { inject: ['size', 'depth', 'prefix'] }
 
-        function execute(size, depth, done) {
+        function execute(size, depth, prefix, done) {
             var objects = []
-            _.times(size, function(n) { objects.push({ number: n }) })
+            _.times(size, function(n) {
+                objects.push(createDeepObject(depth))
+            })
             done(null, objects)
+
+            function createDeepObject(level) {
+                if (level < 0) return { value: _.random(0, 10000)}
+                var newLevel = {}
+                newLevel[prefix + level] = createDeepObject(level - 1)
+                return newLevel
+            }
         }
 
+
         return execute
     }
 }