Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

How to use cleanUpOldExecutions method in redwood

Best JavaScript code snippet using redwood

command.js

Source:command.js

...52    }53    else if(command.command == "cleanup"){54        common.logger.info("cleaning up");55        setTimeout(function(){56            //cleanUpOldExecutions(command.executionID);57        },1*60*1000);58        var count = 0;59        var cleanUpDirs = function(){60            deleteDir(baseExecutionDir + "/"+command.executionID,function(){61            });62            res.send('{"error":null,"success":true}');63        };64        if (Object.keys(launcherConn).length != 0){65            var toDelete = [];66            for(var propt in launcherConn){67                count++;68                if(propt.toString().indexOf(command.executionID) != -1){69                    toDelete.push(propt);70                    stopLauncher(command.executionID,parseInt(propt.substr(propt.length - 4)),function(){71                        //cleanUpDirs()72                    });73                }74                if(count == Object.keys(launcherConn).length){75                    toDelete.forEach(function(conn){76                        console.log("should delete:"+conn);77                        delete launcherConn[conn];78                    });79                    //cleanUpDirs()80                }81            }82        }83        else{84            //cleanUpDirs();85        }86    }87    else if (command.command == "start launcher"){88        res.send(JSON.stringify({"error":null}));89        return;90        common.logger.info("starting launcher: ThreadID: "+command.threadID);91        startLauncher(command.executionID,command.threadID,"java",function(err){92            if(err){93                res.send(JSON.stringify({"error":err}));94                return95            }96            startLauncher(command.executionID,command.threadID,"python",function(err){97                res.send(JSON.stringify({"error":err}));98            });99        });100    }101    else if (command.command == "files loaded"){102        //fs.exists(baseExecutionDir+"/"+command.executionID+"/launcher/RedwoodHQLauncher.jar",function(exists){103		fs.exists(baseExecutionDir+"/launcher/RedwoodHQLauncher.jar",function(exists){104            res.send(JSON.stringify({"loaded":exists}));105        })106    }107};108function startLauncher_debug(callback){109            launcherConn = net.connect(basePort, function(){110                callback(null);111                var cache = "";112                launcherConn.on('data', function(data) {113                    cache += data.toString();114                    common.logger.info('data:', data.toString());115                    if (cache.indexOf("--EOM--") != -1){116                        var msg = JSON.parse(cache.substring(0,cache.length - 7));117                        if (msg.command == "action finished"){118                            sendActionResult(msg);119                        }120                        cache = "";121                    }122                });123                launcherConn.on('error', function(err) {124                    callback(err);125                });126            });127}128function checkForDupLauncher(){129}130function startLauncher(executionID,threadID,type,callback){131	//var libPath = baseExecutionDir+"/"+executionID+"/lib/";132	var libPath = baseExecutionDir+"/lib/";133    //var launcherPath  = baseExecutionDir+"/"+executionID+"/launcher/";134	var launcherPath  = baseExecutionDir+"/launcher/";135    var javaPath = "";136    var portNumber;137    if(type == "java"){138        portNumber = basePort + threadID;139    }140    else if(type == "python"){141        portNumber = basePythonPort + threadID;142    }143    else if(type == "csharp"){144        portNumber = baseCSharpPort + threadID;145    }146    var classPath = "";147    //check if there is a process with same port already running148    var foundConn = null;149    for(var propt in launcherConn){150        if (propt.indexOf(portNumber.toString(), propt.length - portNumber.toString().length) !== -1){151            foundConn = launcherConn[propt];152        }153    }154    var startProcess = function(){155        /*if (fs.existsSync(baseExecutionDir+"/"+executionID+"/bin") == false){156            fs.mkdirSync(baseExecutionDir+"/"+executionID+"/bin");157        }*/158		if (fs.existsSync(baseExecutionDir+"/bin") == false){159            fs.mkdirSync(baseExecutionDir+"/bin");160        }161        var pathDivider = ";";162        if(require('os').platform() == "linux" || (require('os').platform() == "darwin")) {163            pathDivider = ":"164        }165        if(type == "java"){166            javaPath = path.resolve(__dirname,"../../vendor/Java/bin")+"/java";167			common.logger.info("javapath: " + javaPath);168            classPath = libPath+'*'+pathDivider+launcherPath+'*';169			common.logger.info("classPath: " + classPath);170            /*171            if(require('os').platform() == "linux"){172                javaPath = path.resolve(__dirname,"../../vendor/Java/bin")+"/java";173                classPath = libPath+'*:'+launcherPath+'*';174            }175            if(require('os').platform() == "darwin"){176                javaPath = path.resolve(__dirname,"../../vendor/Java/bin")+"/java";177                classPath = libPath+'*:'+launcherPath+'*';178            }179            else{180                javaPath = path.resolve(__dirname,"../../vendor/Java/bin")+"/java";181                classPath = libPath+'*;'+launcherPath+'*';182            }183            */184			common.logger.info("inside startLauncher 1");185            //launcherProc[executionID+portNumber.toString()] = spawn(javaPath,["-cp",classPath,"-Xmx512m","-Dfile.encoding=UTF8","redwood.launcher.Launcher",portNumber.toString()],{env:{PATH:baseExecutionDir+"/"+executionID+"/bin/:/usr/local/bin:/bin:/sbin:/usr/bin:/usr/sbin"},cwd:baseExecutionDir+"/"+executionID+"/bin/"});186			launcherProc[executionID+portNumber.toString()] = spawn(javaPath,["-cp",classPath,"-Xmx512m","-Dfile.encoding=UTF8","redwood.launcher.Launcher",portNumber.toString()],{env:{PATH:baseExecutionDir+"/bin/:/usr/local/bin:/bin:/sbin:/usr/bin:/usr/sbin"},cwd:baseExecutionDir+"/bin/"});187			common.logger.info("inside startLauncher 2");188        }189        else if(type == "python"){190            var pythonPath = baseExecutionDir+"/"+executionID+"/python";191            var pythonLauncherPath = path.resolve(__dirname,"../lib")+"/pythonLauncher.py";192            //launcherProc[executionID+portNumber.toString()] = spawn(pythonPath,[pythonLauncherPath,portNumber.toString()],{env:{PYTHONPATH:baseExecutionDir+"/"+executionID+"/src/"},cwd:baseExecutionDir+"/"+executionID+"/bin/"});193            launcherProc[executionID+portNumber.toString()] = spawn(pythonPath,[pythonLauncherPath,portNumber.toString()],{env:{PYTHONPATH:path.resolve(__dirname,"../../vendor/Python/DLLs")+pathDivider+path.resolve(__dirname,"../../vendor/Python/Lib")+pathDivider+baseExecutionDir+"/"+executionID+"/src/"},cwd:baseExecutionDir+"/"+executionID+"/bin/"});194        }195        else if(type == "csharp"){196            var csharpLauncherPath = baseExecutionDir+"/"+executionID+"/lib/CSharpLauncher.exe";197            launcherProc[executionID+portNumber.toString()] = spawn(csharpLauncherPath,[portNumber.toString(),baseExecutionDir+"/"+executionID+"/lib/RedwoodHQAutomation.dll"],{cwd:baseExecutionDir+"/"+executionID+"/bin/"});198        }199        //launcherProc[executionID+portNumber.toString()] = require('child_process').execFile(javaPath+ " -cp " + classPath + " -Xmx512m "+"redwood.launcher.Launcher "+portNumber.toString(),{env:{PATH:baseExecutionDir+"/"+executionID+"/bin/"},cwd:baseExecutionDir+"/"+executionID+"/bin/"});200        //fs.writeFileSync(baseExecutionDir+"/"+executionID+"/"+threadID+type+"_launcher.pid",launcherProc[executionID+portNumber.toString()].pid);201		fs.writeFileSync(baseExecutionDir+"/"+threadID+type+"_launcher.pid",launcherProc[executionID+portNumber.toString()].pid);202        launcherProc[executionID+portNumber.toString()].stderr.on('data', function (data) {203            sendLog({message:"STDOUT ERROR: " + data.toString(),date:new Date(),actionName:actionCache[portNumber].name,resultID:actionCache[portNumber].resultID,executionID:executionID},common.Config.AppServerIPHost,common.Config.AppServerPort);204            if(data.toString().indexOf("WARNING") != -1) return;205            if(data.toString().indexOf("JavaScript error") != -1) return;206            common.logger.error("launcher error:"+data.toString());207            if (actionCache[portNumber]){208                launcherProc[executionID+portNumber.toString()] = null;209                //org.jclouds.logging.jdk.JDKLogger210                if(data.toString().indexOf("org.jclouds.logging.jdk.JDKLogger") != -1 && data.toString().indexOf("SEVERE") != -1){211                    //actionCache[portNumber].error = data.toString();212                    //actionCache[portNumber].result = "Failed";213                    //sendActionResult(actionCache[portNumber],common.Config.AppServerIPHost,common.Config.AppServerPort);214                    //delete actionCache[portNumber];215                }216            }217            //callback(data.toString());218        });219        common.logger.info("starting port:"+portNumber);220        //var launcherRetry = 1;221        var checkForCrush = function(portNumber){222            if (actionCache[portNumber]){223                actionCache[portNumber].error = "Launcher crashed";224                actionCache[portNumber].result = "Failed";225                sendActionResult(actionCache[portNumber],common.Config.AppServerIPHost,common.Config.AppServerPort);226                delete actionCache[portNumber];227            }228        };229        launcherProc[executionID+portNumber.toString()].on('close', function (data) {230            if(launcherProc[executionID+portNumber.toString()]){231                delete launcherProc[executionID+portNumber.toString()];232                setTimeout(checkForCrush(portNumber),1000);233            }234            callback(data.toString());235        });236		common.logger.info("inside startLauncher 3");237        var cmdCache = "";238        launcherProc[executionID+portNumber.toString()].stdout.on('data', function (data) {239            common.logger.info("inside startLauncher 4");240			cmdCache += data.toString();241            common.logger.info('stdout: ' + data.toString());242            if (data.toString().indexOf("launcher running.") != -1){243                cmdCache = "";244                launcherConn[executionID+portNumber.toString()] = net.connect(portNumber, function(){245                    callback(null);246                    var cache = "";247                    launcherConn[executionID+portNumber.toString()].on('data', function(tcpData) {248                        cache += tcpData.toString();249                        common.logger.info('data:', tcpData.toString());250                        if (cache.indexOf("--EOM--") != -1){251                            //var msg = JSON.parse(cache.substring(0,cache.length - 7));252                            var msg = JSON.parse(cache.substring(0,cache.indexOf("--EOM--")));253                            if (msg.command == "action finished"){254                                if(msg.matchID != actionCache[portNumber].matchID){255                                    cache = "";256                                    return;257                                }258                                delete actionCache[portNumber];259                                if(msg.screenshot){260                                    common.sendFileToServer(baseExecutionDir+"/"+executionID + "/bin/" + msg.screenshot,msg.screenshot,"/screenshots",common.Config.AppServerIPHost,common.Config.AppServerPort,"executionID="+executionID+";resultID="+msg.resultID,function(){261                                        sendActionResult(msg,common.Config.AppServerIPHost,common.Config.AppServerPort);262                                    })263                                }264                                else{265                                    sendActionResult(msg,common.Config.AppServerIPHost,common.Config.AppServerPort);266                                }267                                cache = "";268                            }269                            if (msg.command == "Log Message"){270                                //if()271                                msg.date=new Date();272                                sendLog(msg,common.Config.AppServerIPHost,common.Config.AppServerPort);273                            }274                            cache = cache.substring(cache.indexOf("--EOM--") + 7,cache.length);275                        }276                    });277                });278                launcherConn[executionID+portNumber.toString()].on('error', function(err) {279                    common.logger.error("Error connecting to launcher on port "+portNumber+": "+err);280                    //sendActionResult(msg,common.Config.AppServerIPHost,common.Config.AppServerPort);281                    //checkForCrush(portNumber);282                    callback("Error connecting to launcher on port "+portNumber+": "+err);283                });284            }285            else{286                if (cmdCache.indexOf("\n") != -1){287                    if (cmdCache.length <= 2) {288                        cmdCache = "";289                        return;290                    }291                    cmdCache.split("\r\n").forEach(function(message,index,array){292                        if(index == array.length - 1){293                            if (cmdCache.lastIndexOf("\r\n")+2 !== cmdCache.length){294                                cmdCache = cmdCache.substring(cmdCache.lastIndexOf("\r\n") + 2,cmdCache.length);295                            }else{296                                if (message != ""){297                                    common.logger.info("sending:"+message);298                                    sendLog({executionID:executionID,message:message,date:new Date(),actionName:actionCache[portNumber].name,resultID:actionCache[portNumber].resultID},common.Config.AppServerIPHost,common.Config.AppServerPort);299                                }300                                cmdCache = "";301                            }302                        }303                        if (message != ""){304                            common.logger.info("sending:"+message);305                            if(actionCache[portNumber]){306                                sendLog({message:message,date:new Date(),actionName:actionCache[portNumber].name,executionID:executionID,runType:actionCache[portNumber].runType,resultID:actionCache[portNumber].resultID,username:actionCache[portNumber].username},common.Config.AppServerIPHost,common.Config.AppServerPort);307                            }308                        }309                    });310                }311            }312        });313    };314    if (foundConn != null){315        stopLauncher(executionID,basePort + threadID,function(){316            stopLauncher(executionID,basePythonPort + threadID,function(){317                stopLauncher(executionID,baseCSharpPort + threadID,function(){318                    startProcess();319                });320            });321        });322    }323    else{324        try{325            foundConn = net.connect(portNumber, function(){326                foundConn.write(JSON.stringify({command:"exit"})+"\r\n",function(){327                    setTimeout(startProcess(),5000);328                });329            });330            foundConn.on("error",function(err){331                //common.logger.error(err);332                startProcess();333            })334        }335        catch(err){336            startProcess();337        }338    }339}340function stopLauncher(executionID,port,callback){341    if (launcherProc[executionID+port.toString()] != null){342        sendLauncherCommand({command:"exit",executionID:executionID},port,function(){343            try{344                process.kill(launcherProc[executionID+port.toString()].pid);345            }346            catch(exception){347                common.logger.error(exception);348            }349            delete launcherProc[executionID+port.toString()];350        });351    }352    //if there is runaway launcher try to kill it353    else{354        var conn;355        conn = net.connect(port, function(){356            conn.write(JSON.stringify({command:"exit"})+"\r\n");357        }).on('error', function(err) {358                //deleteDir(baseExecutionDir+"/"+executionID+"/launcher/",callback)359        });360    }361    if (fs.existsSync(baseExecutionDir+"/"+executionID+"/"+port.toString()+"java_launcher.pid") == true){362        var jpid = fs.readFileSync(baseExecutionDir+"/"+executionID+"/"+port.toString+"java_launcher.pid").toString();363        try{364            process.kill(jpid,"SIGTERM");365        }366        catch(err){}367    }368    if (fs.existsSync(baseExecutionDir+"/"+executionID+"/"+port.toString()+"python_launcher.pid") == true){369        var ppid = fs.readFileSync(baseExecutionDir+"/"+executionID+"/"+port.toString()+"python_launcher.pid").toString();370        try{371            process.kill(ppid,"SIGTERM");372        }373        catch(err){}374    }375    if (fs.existsSync(baseExecutionDir+"/"+executionID+"/"+port.toString()+"csharp_launcher.pid") == true){376        var ppid = fs.readFileSync(baseExecutionDir+"/"+executionID+"/"+port.toString()+"csharp_launcher.pid").toString();377        try{378            process.kill(ppid,"SIGTERM");379        }380        catch(err){}381    }382    delete launcherConn[port];383    setTimeout(function() { callback();}, 4000);384}385exports.cleanUp = function(){386    cleanUpOldExecutions();387};388function cleanUpOldExecutions(ignoreExecution){389    fs.readdir(baseExecutionDir,function(err,list){390        if (!list) return;391        list.forEach(function(dir){392            if((ignoreExecution)&&(ignoreExecution == dir)) return;393            getExecutionStatus(common.Config.AppServerIPHost,common.Config.AppServerPort,dir,function(result){394                if((result.execution == null) || (result.execution.status == "Ready To Run")){395                    fs.readdir(baseExecutionDir+"/"+dir,function(err,list){396                        var dirs = [];397                        if (list){398                            list.forEach(function(file,index){399                                try{400                                    if (file.indexOf(".pid") != -1){401                                        var pid = fs.readFileSync(baseExecutionDir+"/"+dir+"/launcher/"+file).toString();402                                        process.kill(pid,"SIGTERM");...

command original.js

Source:command original.js

...52    }53    else if(command.command == "cleanup"){54        common.logger.info("cleaning up");55        setTimeout(function(){56            //cleanUpOldExecutions(command.executionID);57        },1*60*1000);58        var count = 0;59        var cleanUpDirs = function(){60            deleteDir(baseExecutionDir + "/"+command.executionID,function(){61            });62            res.send('{"error":null,"success":true}');63        };64        if (Object.keys(launcherConn).length != 0){65            var toDelete = [];66            for(var propt in launcherConn){67                count++;68                if(propt.toString().indexOf(command.executionID) != -1){69                    toDelete.push(propt);70                    stopLauncher(command.executionID,parseInt(propt.substr(propt.length - 4)),function(){71                        cleanUpDirs()72                    });73                }74                if(count == Object.keys(launcherConn).length){75                    toDelete.forEach(function(conn){76                        console.log("should delete:"+conn);77                        delete launcherConn[conn];78                    });79                    cleanUpDirs()80                }81            }82        }83        else{84            cleanUpDirs();85        }86    }87    else if (command.command == "start launcher"){88        res.send(JSON.stringify({"error":null}));89        return;90        common.logger.info("starting launcher: ThreadID: "+command.threadID);91        startLauncher(command.executionID,command.threadID,"java",function(err){92            if(err){93                res.send(JSON.stringify({"error":err}));94                return95            }96            startLauncher(command.executionID,command.threadID,"python",function(err){97                res.send(JSON.stringify({"error":err}));98            });99        });100    }101    else if (command.command == "files loaded"){102        fs.exists(baseExecutionDir+"/"+command.executionID+"/launcher/RedwoodHQLauncher.jar",function(exists){103            res.send(JSON.stringify({"loaded":exists}));104        })105    }106};107function startLauncher_debug(callback){108            launcherConn = net.connect(basePort, function(){109                callback(null);110                var cache = "";111                launcherConn.on('data', function(data) {112                    cache += data.toString();113                    common.logger.info('data:', data.toString());114                    if (cache.indexOf("--EOM--") != -1){115                        var msg = JSON.parse(cache.substring(0,cache.length - 7));116                        if (msg.command == "action finished"){117                            sendActionResult(msg);118                        }119                        cache = "";120                    }121                });122                launcherConn.on('error', function(err) {123                    callback(err);124                });125            });126}127function checkForDupLauncher(){128}129function startLauncher(executionID,threadID,type,callback){130    var libPath = baseExecutionDir+"/"+executionID+"/lib/";131    var launcherPath  = baseExecutionDir+"/"+executionID+"/launcher/";132    var javaPath = "";133    var portNumber;134    if(type == "java"){135        portNumber = basePort + threadID;136    }137    else if(type == "python"){138        portNumber = basePythonPort + threadID;139    }140    else if(type == "csharp"){141        portNumber = baseCSharpPort + threadID;142    }143    var classPath = "";144    //check if there is a process with same port already running145    var foundConn = null;146    for(var propt in launcherConn){147        if (propt.indexOf(portNumber.toString(), propt.length - portNumber.toString().length) !== -1){148            foundConn = launcherConn[propt];149        }150    }151    var startProcess = function(){152        if (fs.existsSync(baseExecutionDir+"/"+executionID+"/bin") == false){153            fs.mkdirSync(baseExecutionDir+"/"+executionID+"/bin");154        }155        var pathDivider = ";";156        if(require('os').platform() == "linux" || (require('os').platform() == "darwin")) {157            pathDivider = ":"158        }159        if(type == "java"){160            javaPath = path.resolve(__dirname,"../../vendor/Java/bin")+"/java";161            classPath = libPath+'*'+pathDivider+launcherPath+'*';162            /*163            if(require('os').platform() == "linux"){164                javaPath = path.resolve(__dirname,"../../vendor/Java/bin")+"/java";165                classPath = libPath+'*:'+launcherPath+'*';166            }167            if(require('os').platform() == "darwin"){168                javaPath = path.resolve(__dirname,"../../vendor/Java/bin")+"/java";169                classPath = libPath+'*:'+launcherPath+'*';170            }171            else{172                javaPath = path.resolve(__dirname,"../../vendor/Java/bin")+"/java";173                classPath = libPath+'*;'+launcherPath+'*';174            }175            */176            launcherProc[executionID+portNumber.toString()] = spawn(javaPath,["-cp",classPath,"-Xmx512m","-Dfile.encoding=UTF8","redwood.launcher.Launcher",portNumber.toString()],{env:{PATH:baseExecutionDir+"/"+executionID+"/bin/:/usr/local/bin:/bin:/sbin:/usr/bin:/usr/sbin"},cwd:baseExecutionDir+"/"+executionID+"/bin/"});177        }178        else if(type == "python"){179            var pythonPath = baseExecutionDir+"/"+executionID+"/python";180            var pythonLauncherPath = path.resolve(__dirname,"../lib")+"/pythonLauncher.py";181            //launcherProc[executionID+portNumber.toString()] = spawn(pythonPath,[pythonLauncherPath,portNumber.toString()],{env:{PYTHONPATH:baseExecutionDir+"/"+executionID+"/src/"},cwd:baseExecutionDir+"/"+executionID+"/bin/"});182            launcherProc[executionID+portNumber.toString()] = spawn(pythonPath,[pythonLauncherPath,portNumber.toString()],{env:{PYTHONPATH:path.resolve(__dirname,"../../vendor/Python/DLLs")+pathDivider+path.resolve(__dirname,"../../vendor/Python/Lib")+pathDivider+baseExecutionDir+"/"+executionID+"/src/"},cwd:baseExecutionDir+"/"+executionID+"/bin/"});183        }184        else if(type == "csharp"){185            var csharpLauncherPath = baseExecutionDir+"/"+executionID+"/lib/CSharpLauncher.exe";186            launcherProc[executionID+portNumber.toString()] = spawn(csharpLauncherPath,[portNumber.toString(),baseExecutionDir+"/"+executionID+"/lib/RedwoodHQAutomation.dll"],{cwd:baseExecutionDir+"/"+executionID+"/bin/"});187        }188        //launcherProc[executionID+portNumber.toString()] = require('child_process').execFile(javaPath+ " -cp " + classPath + " -Xmx512m "+"redwood.launcher.Launcher "+portNumber.toString(),{env:{PATH:baseExecutionDir+"/"+executionID+"/bin/"},cwd:baseExecutionDir+"/"+executionID+"/bin/"});189        fs.writeFileSync(baseExecutionDir+"/"+executionID+"/"+threadID+type+"_launcher.pid",launcherProc[executionID+portNumber.toString()].pid);190        launcherProc[executionID+portNumber.toString()].stderr.on('data', function (data) {191            sendLog({message:"STDOUT ERROR: " + data.toString(),date:new Date(),actionName:actionCache[portNumber].name,resultID:actionCache[portNumber].resultID,executionID:executionID},common.Config.AppServerIPHost,common.Config.AppServerPort);192            if(data.toString().indexOf("WARNING") != -1) return;193            if(data.toString().indexOf("JavaScript error") != -1) return;194            common.logger.error("launcher error:"+data.toString());195            if (actionCache[portNumber]){196                launcherProc[executionID+portNumber.toString()] = null;197                //org.jclouds.logging.jdk.JDKLogger198                if(data.toString().indexOf("org.jclouds.logging.jdk.JDKLogger") != -1 && data.toString().indexOf("SEVERE") != -1){199                    //actionCache[portNumber].error = data.toString();200                    //actionCache[portNumber].result = "Failed";201                    //sendActionResult(actionCache[portNumber],common.Config.AppServerIPHost,common.Config.AppServerPort);202                    //delete actionCache[portNumber];203                }204            }205            //callback(data.toString());206        });207        common.logger.info("starting port:"+portNumber);208        //var launcherRetry = 1;209        var checkForCrush = function(portNumber){210            if (actionCache[portNumber]){211                actionCache[portNumber].error = "Launcher crashed";212                actionCache[portNumber].result = "Failed";213                sendActionResult(actionCache[portNumber],common.Config.AppServerIPHost,common.Config.AppServerPort);214                delete actionCache[portNumber];215            }216        };217        launcherProc[executionID+portNumber.toString()].on('close', function (data) {218            if(launcherProc[executionID+portNumber.toString()]){219                delete launcherProc[executionID+portNumber.toString()];220                setTimeout(checkForCrush(portNumber),1000);221            }222            callback(data.toString());223        });224        var cmdCache = "";225        launcherProc[executionID+portNumber.toString()].stdout.on('data', function (data) {226            cmdCache += data.toString();227            common.logger.info('stdout: ' + data.toString());228            if (data.toString().indexOf("launcher running.") != -1){229                cmdCache = "";230                launcherConn[executionID+portNumber.toString()] = net.connect(portNumber, function(){231                    callback(null);232                    var cache = "";233                    launcherConn[executionID+portNumber.toString()].on('data', function(tcpData) {234                        cache += tcpData.toString();235                        common.logger.info('data:', tcpData.toString());236                        if (cache.indexOf("--EOM--") != -1){237                            //var msg = JSON.parse(cache.substring(0,cache.length - 7));238                            var msg = JSON.parse(cache.substring(0,cache.indexOf("--EOM--")));239                            if (msg.command == "action finished"){240                                if(msg.matchID != actionCache[portNumber].matchID){241                                    cache = "";242                                    return;243                                }244                                delete actionCache[portNumber];245                                if(msg.screenshot){246                                    common.sendFileToServer(baseExecutionDir+"/"+executionID + "/bin/" + msg.screenshot,msg.screenshot,"/screenshots",common.Config.AppServerIPHost,common.Config.AppServerPort,"executionID="+executionID+";resultID="+msg.resultID,function(){247                                        sendActionResult(msg,common.Config.AppServerIPHost,common.Config.AppServerPort);248                                    })249                                }250                                else{251                                    sendActionResult(msg,common.Config.AppServerIPHost,common.Config.AppServerPort);252                                }253                                cache = "";254                            }255                            if (msg.command == "Log Message"){256                                //if()257                                msg.date=new Date();258                                sendLog(msg,common.Config.AppServerIPHost,common.Config.AppServerPort);259                            }260                            cache = cache.substring(cache.indexOf("--EOM--") + 7,cache.length);261                        }262                    });263                });264                launcherConn[executionID+portNumber.toString()].on('error', function(err) {265                    common.logger.error("Error connecting to launcher on port "+portNumber+": "+err);266                    //sendActionResult(msg,common.Config.AppServerIPHost,common.Config.AppServerPort);267                    //checkForCrush(portNumber);268                    callback("Error connecting to launcher on port "+portNumber+": "+err);269                });270            }271            else{272                if (cmdCache.indexOf("\n") != -1){273                    if (cmdCache.length <= 2) {274                        cmdCache = "";275                        return;276                    }277                    cmdCache.split("\r\n").forEach(function(message,index,array){278                        if(index == array.length - 1){279                            if (cmdCache.lastIndexOf("\r\n")+2 !== cmdCache.length){280                                cmdCache = cmdCache.substring(cmdCache.lastIndexOf("\r\n") + 2,cmdCache.length);281                            }else{282                                if (message != ""){283                                    common.logger.info("sending:"+message);284                                    sendLog({executionID:executionID,message:message,date:new Date(),actionName:actionCache[portNumber].name,resultID:actionCache[portNumber].resultID},common.Config.AppServerIPHost,common.Config.AppServerPort);285                                }286                                cmdCache = "";287                            }288                        }289                        if (message != ""){290                            common.logger.info("sending:"+message);291                            if(actionCache[portNumber]){292                                sendLog({message:message,date:new Date(),actionName:actionCache[portNumber].name,executionID:executionID,runType:actionCache[portNumber].runType,resultID:actionCache[portNumber].resultID,username:actionCache[portNumber].username},common.Config.AppServerIPHost,common.Config.AppServerPort);293                            }294                        }295                    });296                }297            }298        });299    };300    if (foundConn != null){301        stopLauncher(executionID,basePort + threadID,function(){302            stopLauncher(executionID,basePythonPort + threadID,function(){303                stopLauncher(executionID,baseCSharpPort + threadID,function(){304                    startProcess();305                });306            });307        });308    }309    else{310        try{311            foundConn = net.connect(portNumber, function(){312                foundConn.write(JSON.stringify({command:"exit"})+"\r\n",function(){313                    setTimeout(startProcess(),5000);314                });315            });316            foundConn.on("error",function(err){317                //common.logger.error(err);318                startProcess();319            })320        }321        catch(err){322            startProcess();323        }324    }325}326function stopLauncher(executionID,port,callback){327    if (launcherProc[executionID+port.toString()] != null){328        sendLauncherCommand({command:"exit",executionID:executionID},port,function(){329            try{330                process.kill(launcherProc[executionID+port.toString()].pid);331            }332            catch(exception){333                common.logger.error(exception);334            }335            delete launcherProc[executionID+port.toString()];336        });337    }338    //if there is runaway launcher try to kill it339    else{340        var conn;341        conn = net.connect(port, function(){342            conn.write(JSON.stringify({command:"exit"})+"\r\n");343        }).on('error', function(err) {344                //deleteDir(baseExecutionDir+"/"+executionID+"/launcher/",callback)345        });346    }347    if (fs.existsSync(baseExecutionDir+"/"+executionID+"/"+port.toString()+"java_launcher.pid") == true){348        var jpid = fs.readFileSync(baseExecutionDir+"/"+executionID+"/"+port.toString+"java_launcher.pid").toString();349        try{350            process.kill(jpid,"SIGTERM");351        }352        catch(err){}353    }354    if (fs.existsSync(baseExecutionDir+"/"+executionID+"/"+port.toString()+"python_launcher.pid") == true){355        var ppid = fs.readFileSync(baseExecutionDir+"/"+executionID+"/"+port.toString()+"python_launcher.pid").toString();356        try{357            process.kill(ppid,"SIGTERM");358        }359        catch(err){}360    }361    if (fs.existsSync(baseExecutionDir+"/"+executionID+"/"+port.toString()+"csharp_launcher.pid") == true){362        var ppid = fs.readFileSync(baseExecutionDir+"/"+executionID+"/"+port.toString()+"csharp_launcher.pid").toString();363        try{364            process.kill(ppid,"SIGTERM");365        }366        catch(err){}367    }368    delete launcherConn[port];369    setTimeout(function() { callback();}, 4000);370}371exports.cleanUp = function(){372    cleanUpOldExecutions();373};374function cleanUpOldExecutions(ignoreExecution){375    fs.readdir(baseExecutionDir,function(err,list){376        if (!list) return;377        list.forEach(function(dir){378            if((ignoreExecution)&&(ignoreExecution == dir)) return;379            getExecutionStatus(common.Config.AppServerIPHost,common.Config.AppServerPort,dir,function(result){380                if((result.execution == null) || (result.execution.status == "Ready To Run")){381                    fs.readdir(baseExecutionDir+"/"+dir,function(err,list){382                        var dirs = [];383                        if (list){384                            list.forEach(function(file,index){385                                try{386                                    if (file.indexOf(".pid") != -1){387                                        var pid = fs.readFileSync(baseExecutionDir+"/"+dir+"/launcher/"+file).toString();388                                        process.kill(pid,"SIGTERM");...

Using AI Code Generation

1import { cleanUpOldExecutions } from '@redwoodjs/api'2export const handler = async () => {3  const result = await cleanUpOldExecutions()4  return {5    body: JSON.stringify(result),6  }7}

Using AI Code Generation

1import { db } from 'src/lib/db'2import { logger } from 'src/lib/logger'3import { cleanUpOldExecutions } from '@redwoodjs/api'4export const handler = async () => {5  logger.info('Cleaning up old executions')6  await cleanUpOldExecutions(db, {7  })8  logger.info('Finished cleaning up old executions')9}10import { getExecutions, deleteExecution } from '@redwoodjs/api'11export const cleanUpOldExecutions = async (12  { logger, daysToKeep = 1, maxExecutionsToKeep = 100 }13) => {14  const executions = await getExecutions(db, {15  })16  const executionsToDelete = executions.filter((execution) => {17    const executionDate = new Date(execution.createdAt)18    const now = new Date()19    const daysOld = (now - executionDate) / (1000 * 60 * 60 * 24)20  })21  for (const execution of executionsToDelete) {22    logger.info(`Deleting execution ${execution.id}`)23    await deleteExecution(db, { id: execution.id })24  }25}

Using AI Code Generation

1var redwood = require('redwood');2redwood.cleanUpOldExecutions(7, function(err, data) {3  if (err) {4    console.log(err, err.stack);5  } else {6    console.log(data);7  }8});

Using AI Code Generation

1var redwood = require('./redwood.js');2redwood.cleanUpOldExecutions();3var cleanUpOldExecutions = function(){4}5module.exports.cleanUpOldExecutions = cleanUpOldExecutions;6var redwood = require('./redwood.js');7redwood.cleanUpOldExecutions();8You can also use the require method to import a module that is installed in the node_modules folder. For example, you can use the following code to import the lodash module:9var _ = require('lodash');10_.forEach([1, 2], function(value) {11  console.log(value);12});13You can also use the require method to import a file that is in the same folder as the file where you want to use it. For example, you can use the following code to import the redwood.js file that is in the same folder as the test.js file:14var redwood = require('./redwood.js');15redwood.cleanUpOldExecutions();16You can also use the require method to import a file that is in a different folder as the file where you want to use it. For example, you can use the following code to import the redwood.js

Using AI Code Generation

1import { cleanUpOldExecutions } from '@redwoodjs/api'2export const handler = async () => {3  console.log(await cleanUpOldExecutions({ days: 2 }))4}5import { db } from 'src/lib/db'6export const cleanUpOldExecutions = async ({ days }) => {7  const result = await db.execution.deleteMany({8    where: {9      createdAt: {10        lte: new Date(new Date().setDate(new Date().getDate() - days)),11      },12    },13  })14}15import { PrismaClient } from '@prisma/client'16const prisma = new PrismaClient()17datasource db {18  url      = env("DATABASE_URL")19}20generator client {21}22model Execution {23  id          Int      @id @default(autoincrement())24  createdAt   DateTime @default(now())25}

Using AI Code Generation

1var redwood = require('redwoodjs');2var redwood = require('redwoodjs').redwood;3var redwood = require('redwoodjs').redwood();4var redwood = require('redwoodjs').redwood;5redwood.cleanUpOldExecutions();6var redwood = require('redwoodjs').redwood();7redwood.cleanUpOldExecutions();8var redwood = require('redwoodjs').redwood;9redwood.cleanUpOldExecutions;10var redwood = require('redwoodjs').redwood();11redwood.cleanUpOldExecutions;12var redwood = require('redwoodjs').redwood();13redwood.cleanUpOldExecutions();14var redwood = require('redwoodjs').redwood;15redwood.cleanUpOldExecutions();16var redwood = require('redwoodjs').redwood();17redwood.cleanUpOldExecutions();18var redwood = require('redwoodjs').redwood;19redwood.cleanUpOldExecutions();20var redwood = require('redwoodjs').redwood;21redwood.cleanUpOldExecutions();22var redwood = require('redwoodjs').redwood;23redwood.cleanUpOldExecutions();24var redwood = require('redwoodjs').redwood;25redwood.cleanUpOldExecutions();26var redwood = require('redwoodjs').redwood;27redwood.cleanUpOldExecutions();28var redwood = require('redwoodjs').redwood;29redwood.cleanUpOldExecutions();30var redwood = require('redwoodjs').redwood;31redwood.cleanUpOldExecutions();32var redwood = require('redwoodjs').redwood;33redwood.cleanUpOldExecutions();34var redwood = require('redwoodjs').redwood;35redwood.cleanUpOldExecutions();36var redwood = require('redwoodjs').redwood;37redwood.cleanUpOldExecutions();38var redwood = require('redwoodjs').redwood;39redwood.cleanUpOldExecutions();40var redwood = require('redwoodjs').redwood;41redwood.cleanUpOldExecutions();42var redwood = require('redwoodjs').redwood;43redwood.cleanUpOldExecutions();44var redwood = require('redwoodjs').redwood;45redwood.cleanUpOldExecutions();46var redwood = require('redwoodjs').redwood;47redwood.cleanUpOldExecutions();

Using AI Code Generation

1var redwood = require('redwood');2var config = require('./config.js');3var redwoodClient = new redwood.Client(config.redwood);4redwoodClient.cleanUpOldExecutions(function(err, response) {5  if (err) {6    console.log('Error: ' + err);7  } else {8    console.log('Response: ' + response);9  }10});

Using AI Code Generation

1var redwoodHQ = require('redwoodhq');2redwoodHQ.cleanUpOldExecutions('Test Project', 'Test Suite', 2);3var redwoodHQ = require('redwoodhq');4redwoodHQ.cleanUpOldExecutions('Test Project', 'Test Suite', 2, 'Test Case');5var redwoodHQ = require('redwoodhq');6redwoodHQ.cleanUpOldExecutions('Test Project', 'Test Suite', 2, 'Test Case', 'Test Step');7var redwoodHQ = require('redwoodhq');8redwoodHQ.cleanUpOldExecutions('Test Project', 'Test Suite', 2, 'Test Case', 'Test Step', 1);9var redwoodHQ = require('redwoodhq');10redwoodHQ.cleanUpOldExecutions('Test Project', 'Test Suite', 2, 'Test Case', 'Test Step', 1, 'Test Step Action');11var redwoodHQ = require('redwoodhq');12redwoodHQ.cleanUpOldExecutions('Test Project', 'Test Suite', 2, 'Test Case', 'Test Step', 1, 'Test Step Action', 'Test Step Action Input');13var redwoodHQ = require('redwoodhq');14redwoodHQ.cleanUpOldExecutions('Test Project', 'Test Suite', 2, 'Test Case', 'Test Step', 1, 'Test Step Action', 'Test Step Action Input', 'Test Step Action Output');15var redwoodHQ = require('redwoodhq');16redwoodHQ.cleanUpOldExecutions('Test Project', 'Test Suite', 2, 'Test Case', 'Test Step', 1, 'Test

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.