Best Karate code snippet using com.intuit.karate.ScenarioActions.bytes
Source:MockHandler.java
1/*2 * The MIT License3 *4 * Copyright 2020 Intuit Inc.5 *6 * Permission is hereby granted, free of charge, to any person obtaining a copy7 * of this software and associated documentation files (the "Software"), to deal8 * in the Software without restriction, including without limitation the rights9 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell10 * copies of the Software, and to permit persons to whom the Software is11 * furnished to do so, subject to the following conditions:12 *13 * The above copyright notice and this permission notice shall be included in14 * all copies or substantial portions of the Software.15 *16 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR17 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,18 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE19 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER20 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,21 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN22 * THE SOFTWARE.23 */24package com.intuit.karate.core;25import com.intuit.karate.ScenarioActions;26import com.intuit.karate.Suite;27import com.intuit.karate.StringUtils;28import com.intuit.karate.Json;29import com.intuit.karate.KarateException;30import com.intuit.karate.graal.JsValue;31import com.intuit.karate.http.HttpUtils;32import com.intuit.karate.http.Request;33import com.intuit.karate.http.ResourceType;34import com.intuit.karate.http.Response;35import com.intuit.karate.http.ServerHandler;36import java.util.*;37import java.util.function.BiFunction;38import java.util.function.Function;39import org.slf4j.Logger;40import org.slf4j.LoggerFactory;41/**42 *43 * @author pthomas344 */45public class MockHandler implements ServerHandler {46 private static final Logger logger = LoggerFactory.getLogger(MockHandler.class);47 private static final String REQUEST_BYTES = "requestBytes";48 private static final String REQUEST_PARAMS = "requestParams";49 private static final String REQUEST_PARTS = "requestParts";50 private static final String RESPONSE_DELAY = "responseDelay";51 private static final String PATH_MATCHES = "pathMatches";52 private static final String METHOD_IS = "methodIs";53 private static final String TYPE_CONTAINS = "typeContains";54 private static final String ACCEPT_CONTAINS = "acceptContains";55 private static final String HEADER_CONTAINS = "headerContains";56 private static final String PARAM_VALUE = "paramValue";57 private static final String PARAM_EXISTS = "paramExists";58 private static final String PATH_PARAMS = "pathParams";59 private static final String BODY_PATH = "bodyPath";60 private final LinkedHashMap<Feature, ScenarioRuntime> features = new LinkedHashMap<>(); // feature + holds global config and vars61 private final Map<String, Variable> globals = new HashMap<>();62 private boolean corsEnabled;63 protected static final ThreadLocal<Request> LOCAL_REQUEST = new ThreadLocal<>();64 private String prefix = "";65 public MockHandler withPrefix(String prefix) {66 this.prefix = prefix;67 return this;68 }69 public MockHandler(Feature feature) {70 this(feature, null);71 }72 public MockHandler(Feature feature, Map<String, Object> args) {73 this(Collections.singletonList(feature), args);74 }75 public MockHandler(List<Feature> features) {76 this(features, null);77 }78 public MockHandler(List<Feature> features, Map<String, Object> args) {79 for (Feature feature : features) {80 FeatureRuntime featureRuntime = FeatureRuntime.of(Suite.forTempUse(), feature, args);81 FeatureSection section = new FeatureSection();82 section.setIndex(-1); // TODO util for creating dummy scenario83 Scenario dummy = new Scenario(feature, section, -1);84 section.setScenario(dummy);85 ScenarioRuntime runtime = new ScenarioRuntime(featureRuntime, dummy);86 initRuntime(runtime);87 if (feature.isBackgroundPresent()) {88 // if we are within a scenario already e.g. karate.start(), preserve context89 ScenarioEngine prevEngine = ScenarioEngine.get();90 try {91 ScenarioEngine.set(runtime.engine);92 for (Step step : feature.getBackground().getSteps()) {93 Result result = StepRuntime.execute(step, runtime.actions);94 if (result.isFailed()) {95 String message = "mock-server background failed - " + feature + ":" + step.getLine();96 runtime.logger.error(message);97 throw new KarateException(message, result.getError());98 }99 }100 } finally {101 ScenarioEngine.set(prevEngine);102 }103 }104 corsEnabled = corsEnabled || runtime.engine.getConfig().isCorsEnabled();105 globals.putAll(runtime.engine.detachVariables());106 runtime.logger.info("mock server initialized: {}", feature);107 this.features.put(feature, runtime);108 }109 }110 private void initRuntime(ScenarioRuntime runtime) {111 runtime.engine.setVariable(PATH_MATCHES, (Function<String, Boolean>) this::pathMatches);112 runtime.engine.setVariable(PARAM_EXISTS, (Function<String, Boolean>) this::paramExists);113 runtime.engine.setVariable(PARAM_VALUE, (Function<String, String>) this::paramValue);114 runtime.engine.setVariable(METHOD_IS, (Function<String, Boolean>) this::methodIs);115 runtime.engine.setVariable(TYPE_CONTAINS, (Function<String, Boolean>) this::typeContains);116 runtime.engine.setVariable(ACCEPT_CONTAINS, (Function<String, Boolean>) this::acceptContains);117 runtime.engine.setVariable(HEADER_CONTAINS, (BiFunction<String, String, Boolean>) this::headerContains);118 runtime.engine.setVariable(BODY_PATH, (Function<String, Object>) this::bodyPath);119 runtime.engine.init();120 }121 private static final Result PASSED = Result.passed(0);122 private static final String ALLOWED_METHODS = "GET, HEAD, POST, PUT, DELETE, PATCH";123 @Override124 public synchronized Response handle(Request req) { // note the [synchronized]125 if (corsEnabled && "OPTIONS".equals(req.getMethod())) {126 Response response = new Response(200);127 response.setHeader("Allow", ALLOWED_METHODS);128 response.setHeader("Access-Control-Allow-Origin", "*");129 response.setHeader("Access-Control-Allow-Methods", ALLOWED_METHODS);130 List<String> requestHeaders = req.getHeaderValues("Access-Control-Request-Headers");131 if (requestHeaders != null) {132 response.setHeader("Access-Control-Allow-Headers", requestHeaders);133 }134 return response;135 }136 String path = req.getPath();137 if (!path.isEmpty()) {138 req.setPath(path.substring(prefix.length()));139 }140 for (Map.Entry<Feature, ScenarioRuntime> entry : this.features.entrySet()) {141 Feature feature = entry.getKey();142 ScenarioRuntime runtime = entry.getValue();143 // important for graal to work properly144 Thread.currentThread().setContextClassLoader(runtime.featureRuntime.suite.classLoader);145 LOCAL_REQUEST.set(req);146 req.processBody();147 ScenarioEngine engine = createScenarioEngine(req, runtime);148 Map<String, List<Map<String, Object>>> parts = req.getMultiParts();149 if (parts != null) {150 engine.setHiddenVariable(REQUEST_PARTS, parts);151 }152 for (FeatureSection fs : feature.getSections()) {153 if (fs.isOutline()) {154 runtime.logger.warn("skipping scenario outline - {}:{}", feature, fs.getScenarioOutline().getLine());155 break;156 }157 Scenario scenario = fs.getScenario();158 if (isMatchingScenario(scenario, engine)) {159 Map<String, Object> configureHeaders;160 Variable response, responseStatus, responseHeaders, responseDelay;161 ScenarioActions actions = new ScenarioActions(engine);162 Result result = PASSED;163 result = executeScenarioSteps(feature, runtime, scenario, actions, result);164 engine.mockAfterScenario();165 configureHeaders = engine.mockConfigureHeaders();166 response = engine.vars.remove(ScenarioEngine.RESPONSE);167 responseStatus = engine.vars.remove(ScenarioEngine.RESPONSE_STATUS);168 responseHeaders = engine.vars.remove(ScenarioEngine.RESPONSE_HEADERS);169 responseDelay = engine.vars.remove(RESPONSE_DELAY);170 globals.putAll(engine.detachVariables());171 Response res = new Response(200);172 if (result.isFailed()) {173 response = new Variable(result.getError().getMessage());174 responseStatus = new Variable(500);175 } else {176 if (corsEnabled) {177 res.setHeader("Access-Control-Allow-Origin", "*");178 }179 res.setHeaders(configureHeaders);180 if (responseHeaders != null && responseHeaders.isMap()) {181 res.setHeaders(responseHeaders.getValue());182 }183 if (responseDelay != null) {184 res.setDelay(responseDelay.getAsInt());185 }186 }187 if (response != null && !response.isNull()) {188 res.setBody(response.getAsByteArray());189 if (res.getContentType() == null) {190 ResourceType rt = ResourceType.fromObject(response.getValue());191 if (rt != null) {192 res.setContentType(rt.contentType);193 }194 }195 }196 if (responseStatus != null) {197 res.setStatus(responseStatus.getAsInt());198 }199 return res;200 }201 }202 }203 logger.warn("no scenarios matched, returning 404: {}", req); // NOTE: not logging with engine.logger204 return new Response(404);205 }206 private Result executeScenarioSteps(Feature feature, ScenarioRuntime runtime, Scenario scenario, ScenarioActions actions, Result result) {207 for (Step step : scenario.getSteps()) {208 result = StepRuntime.execute(step, actions);209 if (result.isAborted()) {210 runtime.logger.debug("abort at {}:{}", feature, step.getLine());211 break;212 }213 if (result.isFailed()) {214 String message = "server-side scenario failed, " + feature + ":" + step.getLine()215 + "\n" + step.toString() + "\n" + result.getError().getMessage();216 runtime.logger.error(message);217 break;218 }219 }220 return result;221 }222 private ScenarioEngine createScenarioEngine(Request req, ScenarioRuntime runtime) {223 ScenarioEngine engine = new ScenarioEngine(runtime, new HashMap<>(globals));224 ScenarioEngine.set(engine);225 engine.init();226 engine.setVariable(ScenarioEngine.REQUEST_URL_BASE, req.getUrlBase());227 engine.setVariable(ScenarioEngine.REQUEST_URI, req.getPath());228 engine.setVariable(ScenarioEngine.REQUEST_METHOD, req.getMethod());229 engine.setVariable(ScenarioEngine.REQUEST_HEADERS, req.getHeaders());230 engine.setVariable(ScenarioEngine.REQUEST, req.getBodyConverted());231 engine.setVariable(REQUEST_PARAMS, req.getParams());232 engine.setVariable(REQUEST_BYTES, req.getBody());233 return engine;234 }235 private boolean isMatchingScenario(Scenario scenario, ScenarioEngine engine) {236 String expression = StringUtils.trimToNull(scenario.getName() + scenario.getDescription());237 if (expression == null) {238 engine.logger.debug("default scenario matched at line: {}", scenario.getLine());239 return true;240 }241 try {242 Variable v = engine.evalJs(expression);243 if (v.isTrue()) {244 engine.logger.debug("scenario matched at line {}: {}", scenario.getLine(), expression);245 return true;246 } else {247 engine.logger.trace("scenario skipped at line {}: {}", scenario.getLine(), expression);248 return false;249 }250 } catch (Exception e) {251 engine.logger.warn("scenario match evaluation failed at line {}: {} - {}", scenario.getLine(), expression, e + "");252 return false;253 }254 }255 public boolean pathMatches(String pattern) {256 String uri = LOCAL_REQUEST.get().getPath();257 Map<String, String> pathParams = HttpUtils.parseUriPattern(pattern, uri);258 if (pathParams == null) {259 return false;260 } else {261 ScenarioEngine.get().setVariable(PATH_PARAMS, pathParams);262 return true;263 }264 }265 public boolean paramExists(String name) {266 Map<String, List<String>> params = LOCAL_REQUEST.get().getParams();267 return params != null && params.containsKey(name);268 }269 public String paramValue(String name) {270 return LOCAL_REQUEST.get().getParam(name);271 }272 public boolean methodIs(String name) { // TODO no more supporting array arg273 return LOCAL_REQUEST.get().getMethod().equalsIgnoreCase(name);274 }275 public boolean typeContains(String text) {276 String contentType = LOCAL_REQUEST.get().getContentType();277 return contentType != null && contentType.contains(text);278 }279 public boolean acceptContains(String text) {280 String acceptHeader = LOCAL_REQUEST.get().getHeader("Accept");281 return acceptHeader != null && acceptHeader.contains(text);282 }283 public boolean headerContains(String name, String value) {284 List<String> values = LOCAL_REQUEST.get().getHeaderValues(name);285 if (values != null) {286 for (String v : values) {287 if (v.contains(value)) {288 return true;289 }290 }291 }292 return false;293 }294 public Object bodyPath(String path) {295 Object body = LOCAL_REQUEST.get().getBodyConverted();296 if (body == null) {297 return null;298 }299 if (path.startsWith("/")) {300 Variable v = ScenarioEngine.evalXmlPath(new Variable(body), path);301 if (v.isNotPresent()) {302 return null;303 } else {304 return JsValue.fromJava(v.getValue());305 }306 } else {307 Json json = Json.of(body);308 Object result;309 try {310 result = json.get(path);311 } catch (Exception e) {312 return null;313 }314 return JsValue.fromJava(result);315 }316 }317}...
bytes
Using AI Code Generation
1def bytes = com.intuit.karate.ScenarioActions.bytes('hello')2def bytes = com.intuit.karate.ScenarioActions.bytes('hello', 'UTF-8')3def bytes = com.intuit.karate.ScenarioActions.bytes('hello', 'UTF-8', 0, 5)4def bytes = com.intuit.karate.ScenarioActions.bytes('hello', 0, 5)5def bytes = com.intuit.karate.ScenarioActions.bytes('hello', 'UTF-8', 0)6def bytes = com.intuit.karate.ScenarioActions.bytes('hello', 'UTF-8', 5)7def bytes = com.intuit.karate.ScenarioActions.bytes('hello', 0)8def bytes = com.intuit.karate.ScenarioActions.bytes('hello', 'UTF-8')9def bytes = com.intuit.karate.ScenarioActions.bytes('hello', 5)10def bytes = com.intuit.karate.ScenarioActions.bytes('hello', 'UTF-8', 0, 5)11def bytes = com.intuit.karate.ScenarioActions.bytes('hello', 0, 5)
bytes
Using AI Code Generation
1* def bytes = read('classpath:my-file.txt').bytes2* def bytes = read('classpath:my-file.txt').bytes('UTF-8')3* def bytes = read('classpath:my-file.txt').bytes('UTF-8', 0, 10)4* def bytes = read('classpath:my-file.txt').bytes(0, 10)5* def bytes = read('classpath:my-file.txt').bytes(0)6* def bytes = read('classpath:my-file.txt').bytes(0, 10, 'UTF-8')7* def bytes = read('classpath:my-file.txt').bytes(0, 'UTF-8')8* def bytes = read('classpath:my-file.txt').bytes(0, 10, 'UTF-8')9* def bytes = read('classpath:my-file.txt').bytes(0, 10, 'UTF-8', true)10* def string = read('classpath:my-file.txt').string11* def string = read('classpath:my-file.txt').string('UTF-8')12* def string = read('classpath:my-file.txt').string('UTF-8', 0, 10)13* def string = read('classpath:my-file.txt').string(0, 10)14* def string = read('classpath:my-file.txt').string(0)15* def string = read('classpath:my-file.txt').string(0, 10, 'UTF-8')16* def string = read('classpath:my-file.txt').string(0, 'UTF-8')17* def string = read('classpath:my-file.txt').string(0, 10, 'UTF-8')18* def string = read('classpath:my-file.txt').string(0, 10, 'UTF-8', true)19* def stream = read('classpath:my-file.txt').asInputStream20* def stream = read('classpath:my-file.txt').asInputStream('UTF-8')21* def stream = read('classpath:my-file.txt').asInputStream('UTF-8', 0, 10)22* def stream = read('classpath:my-file.txt').asInputStream(0, 10)23* def stream = read('classpath:my-file
bytes
Using AI Code Generation
1def bytes = karate.convert('hello', 'bytes')2def base64 = karate.convert(bytes, 'base64')3def hex = karate.convert(bytes, 'hex')4def utf8 = karate.convert(bytes, 'utf8')5def url = karate.convert(bytes, 'url')6def xml = karate.convert(bytes, 'xml')7* def json = karate.convert(bytes, 'json')8* def yaml = karate.convert(bytes, 'yaml')9* def csv = karate.convert(bytes, 'csv')10* def html = karate.convert(bytes, 'html')11* def text = karate.convert(bytes, 'text')12def bytes = FileUtils.toBytes('hello')13def base64 = FileUtils.toBase64(bytes)14def hex = FileUtils.toHex(bytes)15def utf8 = FileUtils.toUtf8(bytes)16def url = FileUtils.toUrl(bytes)17def xml = FileUtils.toXml(bytes)18* def json = FileUtils.toJson(bytes)19* def yaml = FileUtils.toYaml(bytes)20* def csv = FileUtils.toCsv(bytes)21* def html = FileUtils.toHtml(bytes)22* def text = FileUtils.toText(bytes)23* def bytes = karate.convert('hello', 'bytes')24* def bytes = FileUtils.toBytes('hello')
bytes
Using AI Code Generation
1def string = bytes.toString()2def string = bytes.toString()3def string = bytes.toString()4def string = bytes.toString()5def string = bytes.toString()6def string = bytes.toString()7def string = bytes.toString()8def string = bytes.toString()9def string = bytes.toString()10def string = bytes.toString()11def string = bytes.toString()12def string = bytes.toString()
bytes
Using AI Code Generation
1def bytes = bytes('hello world')2def hex = bytes('hello world').hex3def b64 = bytes('hello world').base644def b64url = bytes('hello world').base64url5def b64url = bytes('hello world').base64url6def b64url = bytes('hello world').base64url7def b64url = bytes('hello world').base64url8def b64url = bytes('hello world').base64url9def b64url = bytes('hello world').base64url10def b64url = bytes('hello world').base64url11def b64url = bytes('hello world').base64url
bytes
Using AI Code Generation
1 * def bytes = com.intuit.karate.ScenarioActions.bytes('hello world')2 * def bytes = com.intuit.karate.ScenarioActions.bytes('{ "hello": "world" }')3 * def bytes = com.intuit.karate.ScenarioActions.bytes('{ "hello": "world" }')4 * def file = karate.call('classpath:com/intuit/karate/demo/demo.feature@multipart-file')5 Content-Type: multipart/form-data; boundary=----WebKitFormBoundary7MA4YWxkTrZu0gW6 Content-Disposition: form-data; name="file"; filename="demo.json"7 { "hello": "world" }
bytes
Using AI Code Generation
1And def string = bytes.toString()2And def string = bytes.toString()3And def string = bytes.toString()4And def string = bytes.toString()5And def string = bytes.toString()6And def string = bytes.toString()7And def string = bytes.toString()8And def string = bytes.toString()9And def string = bytes.toString()10And def string = bytes.toString()
bytes
Using AI Code Generation
1def bytes = { s -> s.bytes() }2def base64 = { s -> s.bytes().base64 }3def base64Url = { s -> s.bytes().base64Url }4* def bytes = 'hello world'.bytes()5* def bytes = 'hello world'.bytes()6* def bytes = bytes('hello world')7* def bytes = base64('hello world')8* def bytes = base64Url('hello world')9* def bytes = bytes('hello world')10* def bytes = bytes('hello world')11* def bytes = bytes('hello world')12* def bytes = bytes('hello world')13* def bytes = bytes('hello world')14* def bytes = bytes('hello world')15* def bytes = bytes('hello world')
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.
You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.
Get 100 minutes of automation test minutes FREE!!