CI integration, now executions will show up in real time when they ar…

…e created

app.js

@@ -95,7 +95,7 @@ app.get('/variableTags',auth.auth, variableTags.variableTagsGet);
 app.post('/variableTags',auth.auth, variableTags.variableTagsPost);
 
 //start execution
-app.post('/executionengine/startexecution',auth.auth, executionengine.startexecutionPost);
+app.post('/executionengine/startexecution', executionengine.startexecutionPost);
 
 //stop
 app.post('/executionengine/stopexecution',auth.auth, executionengine.stopexecutionPost);
@@ -143,7 +143,7 @@ app.post('/testcasetags',auth.auth, testcaseTags.testcaseTagsPost);
 //executions
 app.get('/executions',auth.auth, executions.executionsGet);
 app.put('/executions/:id',auth.auth, executions.executionsPut);
-app.post('/executions/:id',auth.auth, executions.executionsPost);
+app.post('/executions/:id',executions.executionsPost);
 app.del('/executions/:id',auth.auth, executions.executionsDelete);
 
 //executionTags

cli/CIExecution.js

@@ -0,0 +1,360 @@
+var argv = require('optimist')
+    .usage('Usage: $0 --name [name] --user [username] --testset [testset name] --machines [hostname1:threads,hostname2:threads] --variables [name=value,name2=value2] --tags [tag1,tag2] --project [projectname] --ignoreScreenshots [true,false]')
+    .demand(['name','testset','machines','project','user'])
+    .argv;
+var common = require('../common');
+var app = require('../common');
+var xml = require('xml-writer');
+var fs = require('fs');
+var db;
+var ObjectID = require('mongodb').ObjectID;
+var http = require("http");
+
+
+common.parseConfig(function(){
+    var execution = {};
+    execution.project = argv.project;
+    execution.user = argv.user;
+    execution.name = argv.name;
+    execution.status = "Ready To Run";
+    execution.locked = true;
+    execution.ignoreStatus = false;
+    execution.lastRunDate = null;
+    execution.testsetname = argv.testset;
+    if(argv.tags){
+        execution.tag = argv.tags.split(",");
+    }
+    if(argv.ignoreScreenshots){
+        if(argv.ignoreScreenshots === "true"){
+            execution.ignoreScreenshots = true;
+        }
+        else{
+            execution.ignoreScreenshots = false;
+        }
+    }
+    else{
+        execution.ignoreScreenshots = false;
+    }
+    execution._id = new ObjectID().toString();
+
+    common.initDB(common.Config.DBPort,function(){
+        db = app.getDB();
+        formatMachines(argv.machines.split(","),function(machines){
+            execution.machines = machines;
+            formatTestSet(argv.testset,argv.project,function(testsetID){
+                execution.testset = testsetID.toString();
+                saveExecutionTestCases(testsetID,execution._id,function(testcases){
+                    if(argv.variables){
+                        formatVariables(argv.variables.split(","),argv.project,function(variables){
+                            execution.variables = variables;
+                            SaveAndRunExecution(execution,testcases,function(){
+
+                            })
+                        })
+                    }
+                    else{
+                        SaveAndRunExecution(execution,testcases,function(){
+
+                        })
+                    }
+                });
+            });
+        });
+
+    });
+});
+
+function saveExecutionTestCases(testsetID,executionID,callback){
+    var testcases = [];
+    var count = 0;
+    db.collection('testsets', function(err, testSetCollection) {
+        db.collection('executiontestcases', function(err, ExeTCCollection) {
+            //console.log(testsetID);
+            testSetCollection.findOne({_id:db.bson_serializer.ObjectID(testsetID.toString())}, {testcases:1}, function(err, dbtestcases) {
+                dbtestcases.testcases.forEach(function(testcase){
+                    db.collection('testcases', function(err, tcCollection) {
+                        tcCollection.findOne({_id:db.bson_serializer.ObjectID(testcase._id.toString())},{name:1},function(err,dbtestcase){
+                            var insertTC = {executionID:executionID,name:dbtestcase.name,tag:testcase.tag,status:"Not Run",testcaseID:testcase._id.toString(),_id: new ObjectID().toString()};
+                            testcases.push(insertTC);
+                            ExeTCCollection.insert(insertTC, {safe:true},function(err,returnData){
+                                count++;
+                                if(count == dbtestcases.testcases.length){
+                                    callback(testcases);
+                                }
+                            });
+                        });
+                    });
+                });
+            });
+        });
+    });
+}
+
+function StartExecution(execution,testcases,callback){
+    var options = {
+        hostname: "localhost",
+        port: common.Config.AppServerPort,
+        path: '/executionengine/startexecution',
+        method: 'POST',
+        agent:false,
+        headers: {
+            'Content-Type': 'application/json',
+            'Cookie': 'username='+execution.user+";project="+execution.project
+        }
+    };
+
+    var req = http.request(options, function(res) {
+        res.setEncoding('utf8');
+        res.on('data', function (chunk) {
+            console.log('BODY: ' + chunk);
+            callback();
+        });
+    });
+
+    req.on('error', function(e) {
+        console.log('problem with request: ' + e.message);
+    });
+
+    // write data to request body
+    req.write(JSON.stringify({ignoreStatus:execution.ignoreStatus,ignoreScreenshots:execution.ignoreScreenshots,testcases:testcases,variables:execution.variables,executionID:execution._id,machines:execution.machines}));
+    req.end();
+}
+
+function SaveExecution(execution,callback){
+    var options = {
+        hostname: "localhost",
+        port: common.Config.AppServerPort,
+        path: '/executions/'+execution._id,
+        method: 'POST',
+        agent:false,
+        headers: {
+            'Content-Type': 'application/json',
+            'Cookie': 'username='+execution.user+";project="+execution.project
+        }
+    };
+
+    var req = http.request(options, function(res) {
+        res.setEncoding('utf8');
+        res.on('data', function (chunk) {
+            console.log('BODY: ' + chunk);
+            callback();
+        });
+    });
+
+    req.on('error', function(e) {
+        console.log('problem with request: ' + e.message);
+    });
+
+    // write data to request body
+    req.write(JSON.stringify(execution));
+    req.end();
+}
+
+function MonitorExecution(execution,callback){
+    var getStatus = function(callback){
+        db.collection('executions', function(err, collection) {
+            collection.findOne({_id:execution._id}, {status:1}, function(err, dbexecution) {
+                callback(dbexecution.status);
+            });
+        });
+    };
+
+    var verifyStatus = function(status){
+        if(status == "Ready To Run"){
+            setTimeout(callback(),10000);
+        }else{
+            setTimeout(getStatus(verifyStatus),10000)
+        }
+    };
+
+    setTimeout(getStatus(verifyStatus),20000)
+
+}
+
+function GenerateReport_old(cliexecution,callback){
+    var xw = new xml();
+    xw.startDocument();
+    xw.startElement('testng-results');
+
+    db.collection('executions', function(err, collection) {
+        collection.findOne({_id:cliexecution._id}, {}, function(err, execution) {
+            xw.writeAttribute('skipped', execution.notRun.toString());
+            xw.writeAttribute('failed', execution.failed.toString());
+            xw.writeAttribute('passed', execution.passed.toString());
+            xw.writeAttribute('total', execution.total.toString());
+            xw.startElement('suite');
+            xw.writeAttribute('name',execution.name);
+            xw.writeAttribute('duration-ms',execution.runtime.toString());
+            xw.writeAttribute('started-at',execution.lastRunDate.toString());
+            xw.writeAttribute('finished-at','0');
+            xw.startElement('groups');
+            xw.endElement();
+            xw.startElement('test');
+            xw.writeAttribute('name',execution.name);
+            xw.writeAttribute('duration-ms',execution.runtime.toString());
+            xw.writeAttribute('started-at',execution.lastRunDate.toString());
+            xw.writeAttribute('finished-at','0');
+            xw.startElement('class');
+            xw.writeAttribute('name',execution.name);
+
+            db.collection('executiontestcases', function(err, collection) {
+                collection.find({executionID:execution._id}, {}, function(err, cursor) {
+                    cursor.each(function(err, testcase) {
+                        if(testcase == null) {
+                            xw.endElement();
+                            xw.endElement();
+                            xw.endElement();
+                            xw.endElement();
+                            xw.endDocument();
+                            //console.log(xw.toString());
+                            fs.writeFile("result.xml",xw.toString(),function(){
+                                callback(0);
+                            });
+                            return;
+                        }
+                        //console.log(testcase);
+                        xw.startElement('test-method');
+                        xw.writeAttribute('name',testcase.name);
+                        xw.writeAttribute('signature',testcase.name);
+                        xw.writeAttribute('duration',testcase.runtime.toString());
+                        xw.writeAttribute('started-at',testcase.startdate.toString());
+                        xw.writeAttribute('finished-at',testcase.enddate.toString());
+                        if (testcase.result == "Passed"){
+                            xw.writeAttribute('status',"PASS");
+                            xw.endElement();
+                        }
+                        else if (testcase.result == "Failed"){
+                            xw.writeAttribute('status',"FAIL");
+                            xw.startElement('exception');
+                            xw.startElement('message');
+                            xw.writeCData(testcase.error);
+                            xw.endElement();
+                            xw.startElement('full-stacktrace');
+                            xw.writeCData(testcase.trace);
+                            xw.endElement();
+                            xw.endElement();
+                            xw.endElement();
+                        }
+                        else{
+                            xw.writeAttribute('status',"SKIPPED");
+                            xw.endElement();
+                        }
+
+                    });
+                })
+            });
+        });
+    });
+}
+
+function GenerateReport(cliexecution,callback){
+    var xw = new xml();
+    xw.startDocument();
+    xw.startElement('testsuite');
+
+    db.collection('executions', function(err, collection) {
+        collection.findOne({_id:cliexecution._id}, {}, function(err, execution) {
+            console.log(execution);
+            xw.writeAttribute('errors', "0");
+            xw.writeAttribute('failures', execution.failed.toString());
+            xw.writeAttribute('tests', execution.total.toString());
+            xw.writeAttribute('name',execution.name);
+            xw.writeAttribute('time',execution.runtime.toString());
+            xw.writeAttribute('timestamp',execution.lastRunDate.toString());
+            xw.startElement('properties');
+            xw.endElement();
+
+            db.collection('executiontestcases', function(err, collection) {
+                collection.find({executionID:execution._id}, {}, function(err, cursor) {
+                    cursor.each(function(err, testcase) {
+                        if(testcase == null) {
+                            xw.endElement();
+                            xw.endDocument();
+                            //console.log(xw.toString());
+                            fs.writeFile("result.xml",xw.toString(),function(){
+                                callback(0);
+                            });
+                            return;
+                        }
+                        //console.log(testcase);
+                        xw.startElement('testcase');
+                        xw.writeAttribute('name',testcase.name);
+                        xw.writeAttribute('classname',testcase.name);
+                        xw.writeAttribute('time',testcase.runtime.toString());
+                        if (testcase.result == "Passed"){
+                            xw.endElement();
+                        }
+                        else if (testcase.result == "Failed"){
+                            xw.startElement('failure');
+                            xw.writeAttribute('type',"Test Case Error");
+                            xw.writeAttribute('message',testcase.error);
+                            xw.writeCData(testcase.trace);
+                            xw.endElement();
+                            xw.endElement();
+                        }
+                        else{
+                            xw.writeAttribute('executed',"false");
+                            xw.endElement();
+                        }
+
+                    });
+                })
+            });
+        });
+    });
+}
+
+function SaveAndRunExecution(execution,testcases,callback){
+    SaveExecution(execution,function(){
+        StartExecution(execution,testcases,function(){
+            MonitorExecution(execution,function(){
+                GenerateReport(execution,function(exitCode){
+                    process.exit(exitCode);
+                })
+            });
+        })
+    })
+}
+
+function formatTestSet(testset,project,callback){
+    db.collection('testsets', function(err, collection) {
+        collection.findOne({name:testset,project:project}, {_id:1}, function(err, dbtestset) {
+            callback(dbtestset._id);
+        });
+    });
+}
+
+function formatVariables(clivariables,project,callback){
+    var variables = [];
+    var count = 0;
+    db.collection('variables', function(err, collection) {
+        clivariables.forEach(function(variable){
+            collection.findOne({name:variable.split("=")[0].trim(),project:project}, {}, function(err, dbvariable) {
+                dbvariable.value = variable.split("=")[1];
+                variables.push(dbvariable);
+                count++;
+                if(count == clivariables.length){
+                    callback(variables);
+                }
+            });
+        });
+    });
+}
+
+function formatMachines(climachines,callback){
+    var machines = [];
+    var count = 0;
+    db.collection('machines', function(err, collection) {
+        climachines.forEach(function(machine){
+            collection.findOne({host:machine.split(":")[0]}, {}, function(err, dbmachine) {
+                dbmachine.threads = machine.split(":")[1];
+                machines.push(dbmachine);
+                count++;
+                if(count == climachines.length){
+                    callback(machines);
+                }
+            });
+        });
+    });
+}
+

package.json

@@ -11,5 +11,6 @@
     , "walk" : "2.2.1"
     , "optimist" : "0.5.2"
     , "forever-monitor" : "1.1.0"
+    , "xml-writer" : "1.4.0"
   }
 }

public/controller/Executions.js

@@ -253,6 +253,7 @@ Ext.define("Redwood.controller.Executions", {
             execution.status = "Ready To Run";
             executionView.dataRecord = this.getStore('Executions').add(execution)[0];
             executionView.dataRecord.set("_id",id);
+            executionView.dataRecord.phantom = true;
             window.history.replaceState("", "", '/index.html?execution='+id+"&project="+Ext.util.Cookies.get('project'));
         }
         else{