Merge pull request #152 from telefonicaid/error_state

Set state to error instead of completed

Author: xval

lib/evPersistence.js

@@ -44,7 +44,7 @@ function init(emitter) {
         } else {
           type = data.state === MG.STATE_ERROR ? TYPE_ERROR : data.task.headers[MG.HEAD_RELAYER_PERSISTENCE];
           respObj = data.result || data.err || {};
-          respObj['state'] = 'completed';
+          respObj.state = data.state;
         }
 
         doPersistence(data.task, respObj, type, function(error, result) {

test/e2e/persistenceCallbackTest.js

@@ -262,7 +262,7 @@ describe('Feature: Persistence Callback #FPT #FCB', function() {
       ' first callback is incorrect', function() {
 
     it('CallBack Incorrect', function(done) {
-
+	    this.timeout(3000)
       var id, type = 'POST', httpCallBack = 'http://noexiste:2222';
 
       var simpleServer = server.serverListener(
@@ -277,6 +277,7 @@ describe('Feature: Persistence Callback #FPT #FCB', function() {
 
             utils.makeRequest(options, content, function(e, data) {
               id = JSON.parse(data).id;
+	           // console.log(id);
             });
           },
 
@@ -314,7 +315,7 @@ describe('Feature: Persistence Callback #FPT #FCB', function() {
 
               utils.makeRequest(options, '', checkResponse);
 
-            }, 10);
+            }, 30);
           }
       );
 

test/e2e/persistenceTest.js

@@ -157,7 +157,7 @@ describe('Feature: Persistence #FPT', function() {
     options.headers = {};
     options.method = 'POST';
     options.headers['X-Relayer-Host'] = 'notAServer:8014';
-    options.headers['X-relayer-persistence'] = 'BODY';
+    options.headers['X-relayer-persistence'] = 'HEADER';
     options.headers['test-header'] = 'test header';
 
     async.series([
@@ -186,7 +186,7 @@ describe('Feature: Persistence #FPT', function() {
 
             var JSONres = JSON.parse(data);
 
-            if (!checked && res.statusCode !== 404 && JSONres.state === 'completed') {
+            if (!checked && res.statusCode !== 400 && JSONres.state === 'error') {
 
               clearInterval(interval);
 
@@ -202,7 +202,7 @@ describe('Feature: Persistence #FPT', function() {
 
           utils.makeRequest(options, '', checkResponse);
 
-        }, 10);
+        }, 20);
       }
     ], function(err, res) {
       var resGet = res[1];