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

Copied to Clipboard!

How to use process method of com.paypal.selion.grid.servlets.GridAutoUpgradeDelegateServlet class

Best SeLion code snippet using com.paypal.selion.grid.servlets.GridAutoUpgradeDelegateServlet.process

Source:GridAutoUpgradeDelegateServlet.java

...46 * Requires the hub to also have {@link LoginServlet} available. Furthermore, only nodes which use47 * {@link SeLionRemoteProxy}, {@link NodeAutoUpgradeServlet}, and {@link NodeForceRestartServlet} or implement support48 * for the HTTP requests <b>/extra/NodeAutoUpgradeServlet</b> and <b>/extra/NodeForceRestartServlet</b> are compatible.<br>49 * <br>50 * If there isn't a process, such as SeLion's Grid with <i>continuousRestart</i> on, monitoring and restarting the node51 * on exit(), the node will be shutdown but not restarted.52 */53public class GridAutoUpgradeDelegateServlet extends RegistryBasedServlet {54    private static final long serialVersionUID = 1L;55    private static final SeLionGridLogger LOGGER = SeLionGridLogger.getLogger(GridAutoUpgradeDelegateServlet.class);56    /**57     * Resource path to the grid auto upgrade html template file58     */59    public static final String RESOURCE_PAGE_FILE = "/com/paypal/selion/html/gridAutoUpgradeDelegateServlet.html";60    public static final String PENDING_NODE_FILE = "/com/paypal/selion/html/gridAutoUpgradePendingNode.html";61    /**62     * Request parameter which may contain the list of nodes which fail to upgrade63     */64    public static final String IDS = "ids";65    /**66     * Request parameter which contains the new download.json to apply67     */68    public static final String PARAM_JSON = "downloadJSON";69    public GridAutoUpgradeDelegateServlet() {70        this(null);71    }72    public GridAutoUpgradeDelegateServlet(GridRegistry registry) {73        super(registry);74    }75    @Override76    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {77        process(request, response);78    }79    @Override80    protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {81        process(req, resp);82    }83    /**84     * This method constructs the html page that gets the information pertaining to the jars/binaries and their85     * artifact checksums from the user. The same method can also act as the end point that relays this information86     * to each of the nodes as well.87     *88     * @param request89     *             {@link HttpServletRequest} that represent the servlet request90     * @param response91     *             {@link HttpServletResponse} that represent the servlet response92     * @throws IOException93     */94    protected void process(HttpServletRequest request, HttpServletResponse response) throws IOException {95        // No active session ? Redirect the user to the login page.96        if (request.getSession(false) == null) {97            response.sendRedirect(LoginServlet.class.getSimpleName());98            return;99        }100        // idList will have the list of all the nodes that are failed to auto-upgrade (node may be restarting at the101        // time of issuing the command to upgrade).102        String idList = request.getParameter(IDS);103        String downloadJSON = request.getParameter(PARAM_JSON);104        if (downloadJSON != null) {105            // proceed with relaying the information to each of the nodes if and only if the user has provided all106            // information for performing the upgrade.107            List<String> pendingProxy = new ArrayList<String>();108            if (idList == null) {109                // there were no nodes that failed to auto upgrade110                for (RemoteProxy eachProxy : this.getRegistry().getAllProxies()) {111                    if (eachProxy == null) {112                        continue;113                    }114                    if ((eachProxy instanceof SeLionRemoteProxy)115                            && (((SeLionRemoteProxy) eachProxy).supportsAutoUpgrade())) {116                        if (!((SeLionRemoteProxy) eachProxy).upgradeNode(downloadJSON)) {117                            pendingProxy.add(eachProxy.getId());118                        }119                    } else {120                        LOGGER.warning("Node " + eachProxy.getId() + " can not be auto upgraded.");121                    }122                }123            } else {124                // hmm.. there were one or more nodes that didn't go through125                // with the upgrade (maybe because they were processing some tests).126                for (String eachId : idList.split(",")) {127                    if (!eachId.trim().isEmpty()) {128                        RemoteProxy proxy = getRegistry().getProxyById(eachId.trim());129                        if (proxy == null) {130                            continue;131                        }132                        if ((proxy instanceof SeLionRemoteProxy) && (((SeLionRemoteProxy) proxy).supportsAutoUpgrade())) {133                            if (!((SeLionRemoteProxy) proxy).upgradeNode(downloadJSON)) {134                                pendingProxy.add(proxy.getId());135                            }136                        } else {137                            LOGGER.warning("Node " + proxy.getId() + " can not be auto upgraded.");138                        }139                    }140                }141            }142            if (pendingProxy.size() > 0) {143                String ids = "";144                for (String temp : pendingProxy) {145                    ids = ids + temp + ",";146                }147                ids = StringUtils.chop(ids);148                ServletHelper.respondAsHtmlUsingArgsAndTemplateWithHttpStatus(response, PENDING_NODE_FILE,149                        HttpServletResponse.SC_OK, ids, ids, downloadJSON);150            } else {151                ServletHelper.respondAsHtmlWithMessage(response, "Auto upgrade process initiated on all nodes.");152            }153        } else {154            /*155             * Auto Upgrade form will be displayed. This the default page for GridAutoUpgradeDelegateServlet156             */157            showDefaultPage(response);158        }159    }160    private void showDefaultPage(HttpServletResponse response) throws IOException {161        String downloadJSON = "";162        try {163            downloadJSON = FileUtils.readFileToString(new File(SeLionGridConstants.DOWNLOAD_JSON_FILE), "UTF-8");164        } catch (IOException e) {165            LOGGER.log(Level.SEVERE, "Unable to open download.json file", e);...

process

Using AI Code Generation

1response.setContentType("text/plain");2response.getWriter().println(GridAutoUpgradeDelegateServlet.process(request, response));3response.setContentType("text/plain");4response.getWriter().println(GridAutoUpgradeDelegateServlet.process(request, response));5response.setContentType("text/plain");6response.getWriter().println(GridAutoUpgradeDelegateServlet.process(request, response));7response.setContentType("text/plain");8response.getWriter().println(GridAutoUpgradeDelegateServlet.process(request, response));9response.setContentType("text/plain");10response.getWriter().println(GridAutoUpgradeDelegateServlet.process(request, response));11response.setContentType("text/plain");12response.getWriter().println(GridAutoUpgradeDelegateServlet.process(request, response));13response.setContentType("text/plain");14response.getWriter().println(GridAutoUpgradeDelegateServlet.process(request, response));15response.setContentType("text/plain");16response.getWriter().println(GridAutoUpgradeDelegateServlet.process(request, response));17response.setContentType("text/plain");18response.getWriter().println(GridAutoUpgradeDelegateServlet.process(request, response));

process

Using AI Code Generation

1HttpURLConnection con = (HttpURLConnection) url.openConnection();2con.setRequestMethod("POST");3con.setDoOutput(true);4con.setDoInput(true);5con.setUseCaches(false);6con.setAllowUserInteraction(false);7con.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");8con.setRequestProperty("Accept", "text/plain");9con.setRequestProperty("Content-Length", Integer.toString(data.length));10con.getOutputStream().write(data);11con.getOutputStream().flush();12con.getOutputStream().close();13BufferedReader rd = new BufferedReader(new InputStreamReader(con.getInputStream()));14String line;15StringBuilder sb = new StringBuilder();16while ((line = rd.readLine()) != null) {17    sb.append(line);18}19String response = sb.toString();20rd.close();21con.disconnect();22The process method of the GridAutoUpgradeDelegateServlet class upgrades the hub and the node (

process

Using AI Code Generation

1package com.paypal.selion.grid.servlets;2import java.io.IOException;3import java.util.logging.Level;4import java.util.logging.Logger;5import javax.servlet.ServletException;6import javax.servlet.http.HttpServletRequest;7import javax.servlet.http.HttpServletResponse;8import org.openqa.grid.internal.Registry;9import org.openqa.grid.internal.RemoteProxy;10import org.openqa.grid.internal.TestSession;11import org.openqa.grid.web.servlet.RegistryBasedServlet;12import com.paypal.selion.utils.ServletHelper;13public class UpgradeNode extends RegistryBasedServlet {14    private static final long serialVersionUID = 1L;15    private static final Logger logger = Logger.getLogger(UpgradeNode.class.getName());16    public UpgradeNode() {17        this(null);18    }19    public UpgradeNode(Registry registry) {20        super(registry);21    }22    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException,23            IOException {24        String hubHost = ServletHelper.getHubHost(request);25        String hubPort = ServletHelper.getHubPort(request);26        String nodeHost = ServletHelper.getNodeHost(request);27        String nodePort = ServletHelper.getNodePort(request);28        String sessionId = ServletHelper.getSessionId(request);29        if (hubHost == null || hubPort == null || nodeHost == null || nodePort == null || sessionId == null) {30            logger.log(Level.SEVERE, "Required parameters not passed");31            response.setStatus(HttpServletResponse.SC_BAD_REQUEST);32            return;33        }34        RemoteProxy proxy = registry.getProxyById(nodeHost + ":" + nodePort);35        if (proxy == null) {36            logger.log(Level.SEVERE, "Node not found");37            response.setStatus(HttpServletResponse.SC_NOT_FOUND);38            return;39        }40        TestSession session = proxy.getTestSession(sessionId);41        if (session == null) {42            logger.log(Level.SEVERE, "Session not found");43            response.setStatus(HttpServletResponse.SC_NOT_FOUND);44            return;45        }46        GridAutoUpgradeDelegateServlet servlet = new GridAutoUpgradeDelegateServlet();47        servlet.process(hubHost, hubPort, nodeHost, nodePort, sessionId);48    }49}

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.