script evaluation test

epoberezkin · epoberezkin · commit 38fced2a6fa7 · 2016-02-14T19:17:28.000Z
diff --git a/package.json b/package.json
@@ -4,7 +4,8 @@
   "description": "JSONScript interpreter in JavaScript",
   "main": "lib/jsonscript.js",
   "scripts": {
-    "test": "mocha --recursive --reporter=spec spec"
+    "test": "mocha spec/*.spec.js -R spec",
+    "test-cov": "istanbul cover -x 'spec/**' node_modules/mocha/bin/_mocha -- spec/*.spec.js -R spec"
   },
   "repository": {
     "type": "git",
@@ -27,6 +28,7 @@
     "jsonscript": "^0.1.0"
   },
   "devDependencies": {
+    "istanbul": "^0.4.2",
     "mocha": "^2.4.5"
   }
 }
diff --git a/spec/evaluate.spec.js b/spec/evaluate.spec.js
@@ -0,0 +1,111 @@
+'use strict';
+
+var JSONScript = require('../lib/jsonscript');
+var assert = require('assert');
+var Ajv = require('ajv');
+var getPromise = require('./testutil').getPromise;
+
+
+describe('script evaluation', function() {
+  var js, callsResolutions;
+
+  before(function() {
+    js = JSONScript();
+    js.addExecutor('router', router);
+  });
+
+  beforeEach(function(){
+    callsResolutions = getPromise.callsResolutions = [];
+  });
+
+  function router(args) {
+    return router.get(args);
+  }
+
+  router.get = function(args) {
+    var path = args.path;
+    callsResolutions.push({ call: 'get: ' + path });
+    var result = path
+                  ? 'you requested ' + path
+                  : new Error('path not specified');
+    return getPromise(result, 10);
+  }
+
+  router.post = function(args) {
+    var path = args.path;
+    var body = args.body;
+    callsResolutions.push({ call: 'post: ' + path });
+    var result = path && body
+                  ? 'you posted ' + JSON.stringify(body) + ' to ' + path
+                  : new Error('path or body not specified');
+    return getPromise(result, 10);
+  }
+
+
+  it('should evaluate router.get script', function() {
+    var script = {
+      $exec: 'router',
+      $args: { path: '/resource' }
+    };
+
+    return js.evaluate(script).then(function (res) {
+      assert.equal(res, 'you requested /resource');
+    });
+  });
+
+  it('should evaluate parallel execution', function() {
+    var script = {
+      a: {
+        $exec: 'router',
+        $args: { path: '/resource' }
+      },
+      b: {
+        $exec: 'router',
+        $method: 'post',
+        $args: { path: '/resource', body: { test: 'test' } }
+      }
+    };
+
+    return js.evaluate(script).then(function (res) {
+      assert.deepEqual(res, {
+        a: 'you requested /resource',
+        b: 'you posted {"test":"test"} to /resource'
+      });
+
+      assert.deepEqual(callsResolutions, [
+        { call: 'get: /resource' },
+        { call: 'post: /resource' },
+        { res: 'you requested /resource' },
+        { res: 'you posted {"test":"test"} to /resource' }
+      ]);
+    });
+  });
+
+  it('should evaluate sequential execution', function() {
+    var script = [
+      {
+        $exec: 'router',
+        $args: { path: '/resource' }
+      },
+      {
+        $exec: 'router',
+        $method: 'post',
+        $args: { path: '/resource', body: { test: 'test' } }
+      }
+    ];
+
+    return js.evaluate(script).then(function (res) {
+      assert.deepEqual(res, [
+        'you requested /resource',
+        'you posted {"test":"test"} to /resource'
+      ]);
+
+      assert.deepEqual(callsResolutions, [
+        { call: 'get: /resource' },
+        { res: 'you requested /resource' },
+        { call: 'post: /resource' },
+        { res: 'you posted {"test":"test"} to /resource' }
+      ]);
+    });
+  });
+});
diff --git a/spec/testutil.js b/spec/testutil.js
@@ -0,0 +1,23 @@
+'use strict';
+
+module.exports = {
+  getPromise: getPromise
+};
+
+
+function getPromise(value, delay) {
+  return new Promise(function (resolve, reject) {
+    setTimeout(function(){
+      if (value instanceof Error) {
+        getPromise.callsResolutions.push({ err: value });
+        reject(value);
+      } else {
+        getPromise.callsResolutions.push({ res: value });
+        resolve(value);
+      }
+    }, delay);
+  });
+}
+
+
+getPromise.callsResolutions = [];
diff --git a/spec/util.spec.js b/spec/util.spec.js
@@ -2,6 +2,7 @@
 
 var util = require('../lib/util');
 var assert = require('assert');
+var getPromise = require('./testutil').getPromise;
 
 
 describe('util', function() {
@@ -46,18 +47,9 @@ describe('util', function() {
     var callsResolutions;
 
     beforeEach(function() {
-      callsResolutions = [];
+      callsResolutions = getPromise.callsResolutions = [];
     });
 
-    function getPromise(value, delay) {
-      return new Promise(function (resolve, reject) {
-        setTimeout(function(){
-          callsResolutions.push({ res: value });
-          resolve(value);
-        }, delay);
-      });
-    }
-
     describe('map function is synchronous', function() {
       function syncMapper(data) {
         callsResolutions.push({ call: data });
