KaneAI - World’s First E2E Software Testing Agent.Signup for Private Beta Join TestMu Conference

How to use ITestCaseExecutionQueueDepService class of org.cerberus.crud.service package

Best Cerberus-source code snippet using org.cerberus.crud.service.ITestCaseExecutionQueueDepService

Source:CreateTestCaseExecutionQueue.java

...32import org.cerberus.crud.service.ILogEventService;33import org.cerberus.crud.service.ITestCaseExecutionQueueService;34import org.cerberus.crud.factory.IFactoryTestCaseExecutionQueue;35import org.cerberus.crud.service.ITagService;36import org.cerberus.crud.service.ITestCaseExecutionQueueDepService;37import org.cerberus.crud.service.impl.LogEventService;38import org.cerberus.engine.entity.MessageEvent;39import org.cerberus.engine.queuemanagement.IExecutionThreadPoolService;40import org.cerberus.enums.MessageEventEnum;41import org.cerberus.exception.CerberusException;42import org.cerberus.exception.FactoryCreationException;43import org.cerberus.util.ParameterParserUtil;44import org.cerberus.util.StringUtil;45import org.cerberus.util.answer.Answer;46import org.cerberus.util.answer.AnswerItem;47import org.cerberus.util.answer.AnswerUtil;48import org.cerberus.util.servlet.ServletUtil;49import org.json.JSONArray;50import org.json.JSONException;51import org.json.JSONObject;52import org.owasp.html.PolicyFactory;53import org.owasp.html.Sanitizers;54import org.springframework.beans.BeansException;55import org.springframework.context.ApplicationContext;56import org.springframework.web.context.support.WebApplicationContextUtils;57/**58 *59 * @author bcivel60 */61@WebServlet(name = "CreateTestCaseExecutionQueue", urlPatterns = {"/CreateTestCaseExecutionQueue"})62public class CreateTestCaseExecutionQueue extends HttpServlet {63    private static final Logger LOG = LogManager.getLogger(CreateTestCaseExecutionQueue.class);64    private ITestCaseExecutionQueueDepService tceQueueDep;65    private IExecutionThreadPoolService executionThreadPoolService;66    private ITagService tagService;67    private ITestCaseExecutionQueueService executionQueueService;68    private IFactoryTestCaseExecutionQueue executionQueueFactory;69    private ILogEventService logEventService;70    /**71     * Processes requests for both HTTP <code>GET</code> and <code>POST</code>72     * methods.73     *74     * @param request servlet request75     * @param response servlet response76     * @throws ServletException if a servlet-specific error occurs77     * @throws IOException if an I/O error occurs78     * @throws org.cerberus.exception.CerberusException79     * @throws org.json.JSONException80     */81    protected void processRequest(HttpServletRequest request, HttpServletResponse response)82            throws ServletException, IOException, CerberusException, JSONException {83        JSONObject jsonResponse = new JSONObject();84        JSONObject executionQueue = new JSONObject();85        ApplicationContext appContext = WebApplicationContextUtils.getWebApplicationContext(this.getServletContext());86        Answer ans = new Answer();87        AnswerItem ansItem = new AnswerItem<>();88        MessageEvent msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_UNEXPECTED);89        msg.setDescription(msg.getDescription().replace("%DESCRIPTION%", ""));90        ans.setResultMessage(msg);91        PolicyFactory policy = Sanitizers.FORMATTING.and(Sanitizers.LINKS);92        String charset = request.getCharacterEncoding() == null ? "UTF-8" : request.getCharacterEncoding();93        response.setContentType("application/json");94        // Calling Servlet Transversal Util.95        ServletUtil.servletStart(request);96        /**97         * Parsing and securing all required parameters.98         */99        // Parameter that are already controled by GUI (no need to decode) --> We SECURE them100        String actionState = policy.sanitize(request.getParameter("actionState"));101        String actionSave = policy.sanitize(request.getParameter("actionSave"));102        String environment = policy.sanitize(request.getParameter("environment"));103        String country = policy.sanitize(request.getParameter("country"));104        String manualEnvData = policy.sanitize(request.getParameter("manualEnvData"));105        // Parameter that needs to be secured --> We SECURE+DECODE them106        String test = ParameterParserUtil.parseStringParamAndDecodeAndSanitize(request.getParameter("test"), "", charset);107        String testcase = ParameterParserUtil.parseStringParamAndDecodeAndSanitize(request.getParameter("testCase"), "", charset);108        int manualURL = ParameterParserUtil.parseIntegerParamAndDecode(request.getParameter("manualURL"), 0, charset);109        String manualHost = ParameterParserUtil.parseStringParamAndDecodeAndSanitize(request.getParameter("manualHost"), "", charset);110        String manualContextRoot = ParameterParserUtil.parseStringParamAndDecodeAndSanitize(request.getParameter("manualContextRoot"), "", charset);111        String manualLoginRelativeURL = ParameterParserUtil.parseStringParamAndDecodeAndSanitize(request.getParameter("manualLoginRelativeURL"), "", charset);112        String tag = ParameterParserUtil.parseStringParamAndDecodeAndSanitize(request.getParameter("tag"), "", charset);113        String robot = ParameterParserUtil.parseStringParamAndDecodeAndSanitize(request.getParameter("robot"), "", charset);114        String robotIP = ParameterParserUtil.parseStringParamAndDecodeAndSanitize(request.getParameter("robotIP"), "", charset);115        String robotPort = ParameterParserUtil.parseStringParamAndDecodeAndSanitize(request.getParameter("robotPort"), "", charset);116        String browser = ParameterParserUtil.parseStringParamAndDecodeAndSanitize(request.getParameter("browser"), "", charset);117        String browserVersion = ParameterParserUtil.parseStringParamAndDecodeAndSanitize(request.getParameter("browserVersion"), "", charset);118        String platform = ParameterParserUtil.parseStringParamAndDecodeAndSanitize(request.getParameter("platform"), "", charset);119        String screenSize = ParameterParserUtil.parseStringParamAndDecodeAndSanitize(request.getParameter("screenSize"), "", charset);120        int verbose = ParameterParserUtil.parseIntegerParamAndDecode(request.getParameter("verbose"), 1, charset);121        int screenshot = ParameterParserUtil.parseIntegerParamAndDecode(request.getParameter("screenshot"), 0, charset);122        int pageSource = ParameterParserUtil.parseIntegerParamAndDecode(request.getParameter("pageSource"), 0, charset);123        int seleniumLog = ParameterParserUtil.parseIntegerParamAndDecode(request.getParameter("seleniumLog"), 0, charset);124        String timeout = ParameterParserUtil.parseStringParamAndDecodeAndSanitize(request.getParameter("timeout"), "", charset);125        int retries = ParameterParserUtil.parseIntegerParamAndDecode(request.getParameter("retries"), 0, charset);126        String manualExecution = ParameterParserUtil.parseStringParamAndDecodeAndSanitize(request.getParameter("manualExecution"), "", charset);127        String debugFlag = ParameterParserUtil.parseStringParamAndDecodeAndSanitize(request.getParameter("debugFlag"), "N", charset);128        // Parameter that we cannot secure as we need the html --> We DECODE them129        String[] myIds = request.getParameterValues("id");130        if (myIds == null) {131            myIds = new String[1];132            myIds[0] = "0";133        }134        long id = 0;135        Integer priority = TestCaseExecutionQueue.PRIORITY_DEFAULT;136        boolean prio_error = false;137        try {138            if (request.getParameter("priority") != null && !request.getParameter("priority").equals("")) {139                priority = Integer.valueOf(policy.sanitize(request.getParameter("priority")));140            }141        } catch (Exception ex) {142            prio_error = true;143        }144        boolean id_error = false;145        executionThreadPoolService = appContext.getBean(IExecutionThreadPoolService.class);146        // Create Tag when exist.147        if (!StringUtil.isNullOrEmpty(tag)) {148            // We create or update it.149            tagService = appContext.getBean(ITagService.class);150            List<String> envList = new ArrayList<>();151            envList.add(environment);152            List<String> countryList = new ArrayList<>();153            countryList.add(country);154            tagService.createAuto(tag, "", request.getRemoteUser(), new JSONArray(envList), new JSONArray(countryList));155        }156        // If action is toQUEUEDwithDEP, that means that we also need to trigger the dependency executions.157        // So we enrish the input list with dependencies.158        boolean withNewDep = false;159        List<Long> idList = new ArrayList<>();160        for (String myId : myIds) {161            id_error = false;162            id = 0;163            try {164                id = Long.valueOf(myId);165            } catch (NumberFormatException ex) {166                id_error = true;167            }168            idList.add(id);169        }170        if (actionState.equals("toQUEUEDwithDep")) {171            withNewDep = true;172            tceQueueDep = appContext.getBean(ITestCaseExecutionQueueDepService.class);173            idList = tceQueueDep.enrichWithDependencies(idList);174        }175        // Prepare the final answer.176        MessageEvent msg1 = new MessageEvent(MessageEventEnum.GENERIC_OK);177        Answer finalAnswer = new Answer(msg1);178        List<TestCaseExecutionQueue> insertedList = new ArrayList<>();179        for (Long myId : idList) {180            id = myId;181            /**182             * Checking all constrains before calling the services.183             */184            if (id_error) {185                msg = new MessageEvent(MessageEventEnum.DATA_OPERATION_ERROR_EXPECTED);186                msg.setDescription(msg.getDescription().replace("%ITEM%", "Execution Queue")...