How to use callREST method of org.cerberus.service.rest.impl.RestService class

Best Cerberus-source code snippet using org.cerberus.service.rest.impl.RestService.callREST

Source:ServiceService.java

...315                            case AppService.METHOD_HTTPPOST:316                                /**317                                 * Call REST and store it into the execution.318                                 */319                                result = restService.callREST(decodedServicePath, decodedRequest, appService.getMethod(),320                                        appService.getHeaderList(), appService.getContentList(), token, timeOutMs, system);321                                message = result.getResultMessage();322                                break;323                            case AppService.METHOD_HTTPDELETE:324                                result = restService.callREST(decodedServicePath, decodedRequest, appService.getMethod(),325                                        appService.getHeaderList(), appService.getContentList(), token, timeOutMs, system);326                                message = result.getResultMessage();327                                break;328                            case AppService.METHOD_HTTPPUT:329                            	 result = restService.callREST(decodedServicePath, decodedRequest, appService.getMethod(),330                                         appService.getHeaderList(), appService.getContentList(), token, timeOutMs, system);331                                 message = result.getResultMessage();332                                 break;333                            case AppService.METHOD_HTTPPATCH:334                            	 result = restService.callREST(decodedServicePath, decodedRequest, appService.getMethod(),335                                         appService.getHeaderList(), appService.getContentList(), token, timeOutMs, system);336                                 message = result.getResultMessage();337                                 break;338                       339                            default:340                                message = new MessageEvent(MessageEventEnum.ACTION_FAILED_CALLSERVICE);341                                message.setDescription(message.getDescription().replace("%DESCRIPTION%", "Method : '" + appService.getMethod() + "' for REST Service is not supported by the engine."));342                                result.setResultMessage(message);343                        }344                        break;345                    default:346                        message = new MessageEvent(MessageEventEnum.ACTION_FAILED_CALLSERVICE);347                        message.setDescription(message.getDescription().replace("%SERVICE%", service));348                        message.setDescription(message.getDescription().replace("%DESCRIPTION%", "Service Type : '" + appService.getType() + "' is not supported by the engine."));...

Source:ExecutorService.java

...116            LOG.debug("Getting nb of Hits so far from URL : " + url);117            Integer i = 0;118            for (i = 0; i < maxLoop; i++) {119                AnswerItem<AppService> result = new AnswerItem<>();120                result = restService.callREST(url, "", AppService.METHOD_HTTPGET, new ArrayList<>(), new ArrayList<>(), null, 10000, "", true, null);121                if (result.isCodeStringEquals("OK")) {122                    AppService appSrv = result.getItem();123                    JSONObject stats = new JSONObject(appSrv.getResponseHTTPBody());124                    nbHitsPrev = nbHits;125                    nbHits = stats.getInt("hits");126                    LOG.debug("Nb Hits so far : " + nbHits);127                    if (nbHits.equals(nbHitsPrev)) {128                        LOG.debug("Nb of hits (" + nbHits + ") is the same as before (" + nbHitsPrev + ") --> so network is idle.");129                        break;130                    }131                    Thread.sleep(sleepPeriod);132                } else {133                    LOG.warn("Failed getting nb of Hits from URL (Maybe cerberus-executor is not at the correct version) : '" + url + "'");134                    return new MessageEvent(MessageEventEnum.ACTION_FAILED_WAITNETWORKTRAFFICIDLE).resolveDescription("DETAIL", "Failed getting nb of Hits from URL (Maybe cerberus-executor is not reachable) : '" + url + "'");135                }136            }137            if (nbHits.equals(nbHitsPrev)) {138                return new MessageEvent(MessageEventEnum.ACTION_SUCCESS_WAITNETWORKTRAFFICIDLE).resolveDescription("HITS", nbHits.toString())139                        .resolveDescription("NB", i.toString()).resolveDescription("TIME", sleepPeriod.toString());140            } else {141                return new MessageEvent(MessageEventEnum.ACTION_SUCCESS_WAITNETWORKTRAFFICIDLE_TIMEOUT).resolveDescription("HITS", nbHits.toString())142                        .resolveDescription("NB", i.toString()).resolveDescription("TIME", sleepPeriod.toString());143            }144        } catch (InterruptedException ex) {145            LOG.warn("Exception when waiting for idle.", ex);146            return new MessageEvent(MessageEventEnum.ACTION_FAILED_WAITNETWORKTRAFFICIDLE).resolveDescription("DETAIL", ex.toString());147        } catch (JSONException ex) {148            LOG.warn("Exception when waiting for idle (interpreting JSON answer from URL : '" + url + "').");149            return new MessageEvent(MessageEventEnum.ACTION_FAILED_WAITNETWORKTRAFFICIDLE).resolveDescription("DETAIL", "Failed getting nb of Hits from URL (Maybe cerberus-executor is not at the correct version) : '" + url + "'");150        }151    }152    @Override153    public JSONObject getHar(String urlFilter, boolean withContent, String exHost, Integer exPort, String exUuid, String system, Integer indexFrom) {154        JSONObject har = new JSONObject();155        try {156            // Generate URL to Cerberus executor with parameter to reduce the answer size by removing response content.157            String url = getExecutorURL("", withContent, exHost, exPort, exUuid);158            LOG.debug("Getting Network Traffic content from URL : " + url);159            AnswerItem<AppService> result = new AnswerItem<>();160            result = restService.callREST(url, "", AppService.METHOD_HTTPGET, new ArrayList<>(), new ArrayList<>(), null, 10000, "", true, null);161            AppService appSrv = result.getItem();162            har = new JSONObject(appSrv.getResponseHTTPBody());163            // remove the 1st entries and filter them based on the url.164            har = harService.removeFirstHitsandFilterURL(har, indexFrom, urlFilter);165            return har;166        } catch (JSONException ex) {167            LOG.error("Exception when parsing JSON.", ex);168        }169        return har;170    }171    @Override172    public String getExecutorURL(String urlFilter, boolean withContent, String exHost, Integer exPort, String exUuid) {173        LOG.debug("Building URL : " + exUuid);174        String url = "http://" + exHost + ":" + exPort175                + "/getHar?uuid=" + exUuid;176        if (!StringUtil.isNullOrEmpty(urlFilter)) {177            url += "&requestUrl=" + urlFilter;178        }179        if (!withContent) {180            url += "&emptyResponseContentText=true";181        }182        return url;183    }184    @Override185    public Integer getHitsNb(String exHost, Integer exPort, String exUuid) throws CerberusEventException {186        String url = "http://" + exHost + ":" + exPort + "/getStats?uuid=" + exUuid;187        Integer nbHits = 0;188        try {189            AnswerItem<AppService> result = new AnswerItem<>();190            result = restService.callREST(url, "", AppService.METHOD_HTTPGET, new ArrayList<>(), new ArrayList<>(), null, 10000, "", true, null);191            if (result.isCodeStringEquals("OK")) {192                AppService appSrv = result.getItem();193                JSONObject stats = new JSONObject(appSrv.getResponseHTTPBody());194                nbHits = stats.getInt("hits");195                LOG.debug("Nb of Hits collected : " + nbHits);196                return nbHits;197            } else {198                LOG.warn("Failed getting nb of Hits from URL (Maybe cerberus-executor is not at the correct version) : '" + url + "'");199//                    return new MessageEvent(MessageEventEnum.ACTION_FAILED_WAITNETWORKTRAFFICIDLE).resolveDescription("DETAIL", "Failed getting nb of Hits from URL (Maybe cerberus-executor is not reachable) : '" + url + "'");200            }201        } catch (JSONException ex) {202            LOG.warn("Exception when getting nb of hits (interpreting JSON answer from URL : '" + url + "').");203//            return new MessageEvent(MessageEventEnum.ACTION_FAILED_WAITNETWORKTRAFFICIDLE).resolveDescription("DETAIL", "Failed getting nb of Hits from URL (Maybe cerberus-executor is not at the correct version) : '" + url + "'");204        }...

callREST

Using AI Code Generation

1import org.cerberus.service.rest.impl.RestService;2import org.cerberus.util.StringUtil;3import org.springframework.context.ApplicationContext;4import org.springframework.context.support.ClassPathXmlApplicationContext;5public class 3 {6    public static void main(String[] args) throws Exception {7        ApplicationContext appContext = new ClassPathXmlApplicationContext("applicationContext.xml");8        RestService restService = appContext.getBean(RestService.class);9        System.out.println(result);10    }11}12{13  "contentTable": {14  }15}

callREST

Using AI Code Generation

1package org.cerberus.service.rest.impl;2import java.io.IOException;3import java.util.ArrayList;4import java.util.List;5import org.cerberus.service.rest.impl.RestService;6import org.apache.http.HttpResponse;7import org.apache.http.NameValuePair;8import org.apache.http.client.HttpClient;9import org.apache.http.client.entity.UrlEncodedFormEntity;10import org.apache.http.client.methods.HttpPost;11import org.apache.http.impl.client.HttpClientBuilder;12import org.apache.http.message.BasicNameValuePair;13import org.apache.http.util.EntityUtils;14public class CallRestService {15    public static void main(String[] args) throws IOException {16        HttpClient client = HttpClientBuilder.create().build();17        List<NameValuePair> urlParameters = new ArrayList<NameValuePair>();18        urlParameters.add(new BasicNameValuePair("campaign", "MyCampaign"));19        urlParameters.add(new BasicNameValuePair("test", "MyTest"));20        urlParameters.add(new BasicNameValuePair("environment", "MyEnv"));21        urlParameters.add(new BasicNameValuePair("country", "MyCountry"));22        post.setEntity(new UrlEncodedFormEntity(urlParameters));23        HttpResponse response = client.execute(post);24        System.out.println("Response Code : " + response.getStatusLine().getStatusCode());25        System.out.println("Response Message : " + EntityUtils.toString(response.getEntity()));26    }27}28package org.cerberus.service.rest.impl;29import java.io.IOException;30import java.util.ArrayList;31import java.util.List;32import org.cerberus.service.rest.impl.RestService;33import org.apache.http.HttpResponse;34import org.apache.http.NameValuePair;35import org.apache.http.client.HttpClient;36import org.apache.http.client.entity.UrlEncodedFormEntity;37import org.apache.http.client.methods.HttpPost;38import org.apache.http.impl.client.HttpClientBuilder;39import org.apache.http.message.BasicNameValuePair;40import org.apache.http.util.EntityUtils;41public class CallRestService {42    public static void main(String[] args) throws IOException {43        HttpClient client = HttpClientBuilder.create().build();44        List<NameValuePair> urlParameters = new ArrayList<NameValuePair>();45        urlParameters.add(new BasicNameValuePair("campaign", "MyCampaign"));

callREST

Using AI Code Generation

1package com.cerberus.service.rest;2import java.util.HashMap;3import org.cerberus.service.rest.impl.RestService;4public class RestServiceClient {5public static void main(String[] args) {6RestService restService = new RestService();7System.out.println("Response:" + response);8}9}10package com.cerberus.service.rest;11import java.util.HashMap;12import org.cerberus.service.rest.impl.RestService;13public class RestServiceClient {14public static void main(String[] args) {15RestService restService = new RestService();16System.out.println("Response:" + response);17}18}19package com.cerberus.service.rest;20import java.util.HashMap;21import org.cerberus.service.rest.impl.RestService;22public class RestServiceClient {23public static void main(String[] args) {24RestService restService = new RestService();25System.out.println("Response:" + response);26}27}28package com.cerberus.service.rest;29import java.util.HashMap;30import org.cerberus.service.rest.impl.RestService;31public class RestServiceClient {32public static void main(String[] args) {33RestService restService = new RestService();34System.out.println("Response:" + response);35}36}

callREST

Using AI Code Generation

1import org.cerberus.service.rest.impl.RestService;2import org.cerberus.service.rest.impl.RESTServiceException;3public class 3 {4    public static void main(String[] args) {5        String operation = "myOperation";6        String message = "Hello World!";7        try {8            String response = RestService.callREST(service, operation, message);9            System.out.println("Response: " + response);10        } catch (RESTServiceException e) {11            e.printStackTrace();12        }13    }14}15import org.cerberus.service.rest.impl.RESTClient;16import org.cerberus.service.rest.impl.RESTServiceException;17public class 4 {18    public static void main(String[] args) {19        String operation = "myOperation";20        String message = "Hello World!";21        try {22            String response = RESTClient.callREST(service, operation, message);23            System.out.println("Response: " + response);24        } catch (RESTServiceException e) {25            e.printStackTrace();26        }27    }28}29import org.cerberus.service.rest.impl.RESTClient;30import org.cerberus.service.rest.impl.RESTServiceException;31public class 5 {32    public static void main(String[] args) {33        String operation = "myOperation";34        String message = "Hello World!";35        try {36            String response = RESTClient.callREST(service, operation

callREST

Using AI Code Generation

1import org.cerberus.service.rest.impl.RestService;2import org.cerberus.service.rest.impl.RestServiceFactory;3import org.cerberus.service.rest.impl.RestServiceFactoryImpl;4public class 3 {5    public static void main(String[] args) {6        RestServiceFactory rsf = new RestServiceFactoryImpl();7        RestService rs = rsf.createRestService();8        System.out.println(response);9    }10}11import org.cerberus.service.rest.impl.RestService;12import org.cerberus.service.rest.impl.RestServiceFactory;13import org.cerberus.service.rest.impl.RestServiceFactoryImpl;14public class 4 {15    public static void main(String[] args) {16        RestServiceFactory rsf = new RestServiceFactoryImpl();17        RestService rs = rsf.createRestService();18        System.out.println(response);19    }20}21import org.cerberus.service.rest.impl.RestService;22import org.cerberus.service.rest.impl.RestServiceFactory;23import org.cerberus.service.rest.impl.RestServiceFactoryImpl;24public class 5 {25    public static void main(String[] args) {26        RestServiceFactory rsf = new RestServiceFactoryImpl();27        RestService rs = rsf.createRestService();28        System.out.println(response);29    }30}31import org.cerberus.service.rest.impl.RestService;32import org.cerberus.service.rest.impl.Rest

callREST

Using AI Code Generation

1import org.cerberus.service.rest.impl.RestService;2import org.cerberus.service.rest.pojo.RestResponse;3import org.cerberus.service.rest.pojo.RestResponseObject;4import org.json.JSONArray;5import org.json.JSONObject;6import org.json.JSONException;7import java.util.ArrayList;8import java.util.List;9public class 3 {10    public static void main(String[] args) {11        try {12            RestService restService = new RestService();13            System.out.println(response);14            JSONObject jsonObj = new JSONObject(response);15            JSONArray jsonArr = jsonObj.getJSONArray("contentTable");16            for (int i = 0; i < jsonArr.length(); i++) {17                JSONObject obj = jsonArr.getJSONObject(i);18                System.out.println("Application: " + obj.getString("application"));19                System.out.println("Country: " + obj.getString("country"));20                System.out.println("Environment: " + obj.getString("environment"));21                System.out.println("Browser: " + obj.getString("browser"));22                System.out.println("BrowserVersion: " + obj.getString("browserVersion"));23                System.out.println("Platform: " + obj.getString("platform"));24                System.out.println("Status: " + obj.getString("status"));25                System.out.println("ControlStatus: " + obj.getString("controlStatus"));26                System.out.println("ControlMessage: " + obj.getString("controlMessage"));27                System.out.println("Build: " + obj.getString("build"));28                System.out.println("Revision: " + obj.getString("revision"));29                System.out.println("Version: " + obj.getString("version"));30                System.out.println("Comment: " + obj.getString("comment"));31                System.out.println("Verbose: " + obj.getString("verbose"));32                System.out.println("Screenshot: " + obj.getString("screenshot"));33                System.out.println("PageSource: " + obj.getString("pageSource"));34                System.out.println("Start: " + obj.getString("start"));35                System.out.println("End: " + obj.getString("end"));36                System.out.println("Elapsed: " + obj.getString("elapsed"));37                System.out.println("Ip: " + obj.getString("

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.