Join the 1-day Testing & QA Summit featuring 15+ Expert Speakers.Register for FREE! 
How to use determineProtocol method in Appium Base Driver
Best JavaScript code snippet using appium-base-driver
adbBridge.js
Source:adbBridge.js 
...43 throw Cr.NS_ERROR_UNEXPECTED;44 }45 return false;46}47function determineProtocol(data) {48 var protocolList = ["host:", "shell:"];49 50 for(var i in protocolList){51 var protocol = protocolList[i];52 if(protocol == data.substr(0, protocol.length))53 return protocol;54 }55 return undefined;56}57function doProcotolDefault(is, os, data) {58 var packet = data2Packet(data);59 os.write(packet, packet.length);60 var respData="";61 if(checkRespCode(is, data)){62 var lengthStr = is.readBytes(4);63 var length = parseInt(lengthStr, 16);64 if(length >= 0 && length == is.available()){65 respData = is.readBytes(length);66 } else {67 respData = lengthStr;68 while(is.available())69 respData += is.readBytes(is.available());70 }71 }72 try {73 ASSERT(is.available()==0,"Some data remained... : " + is.readBytes(is.available()));74 } catch(e if e == Cr.NS_BASE_STREAM_CLOSED){75 // Excerpt : https://developer.mozilla.org/en/nsIInputStream#available%28%2976 // Note: Some nsIInputStream implementations automatically close() when eof is reached; some do not.77 throw e;78 } finally {79 return respData;80 }81}82function doProtocolShell(targetPacket, is, os, data) {83 os.write(targetPacket, targetPacket.length);84 ASSERT(checkRespCode(is, data), "\""+targetPacket+"\" is not working properly");85 if(data == "shell:")86 throw Cr.NS_ERROR_NOT_IMPLEMENTED;87 var packet = data2Packet(data);88 os.write(packet, packet.length);89 var respData="";90 try {91 if(checkRespCode(is, data)){92 try {93 // NS_BASE_STREAM_CLOSED exception will be occured on 'is.available()' method.94 // "shell:" protocol will be closed automatically when it prints out all results.95 while(1)96 if(is.available())97 respData += is.readBytes(is.available());98 } catch(e if e == Cr.NS_BASE_STREAM_CLOSED){99 // Excerpt : https://developer.mozilla.org/en/nsIInputStream#available%28%29100 // Note: Some nsIInputStream implementations automatically close() when eof is reached; some do not.101 throw e;102 }103 }104 } finally {105 return respData;106 }107}108var adbBridgeSync = function() {109 var tp = null;110 var _is = null;111 var is = null;112 var os = null;113 var targetPacket=data2Packet("host:transport-any");114 const syncStreamFlags = nsITransport.OPEN_BLOCKING | nsITransport.OPEN_UNBUFFERED;115 function connect() {116 if(tp != null)117 throw Cr.NS_ERROR_ALREADY_INITIALIZED;118 tp = newTransport();119 _is = tp.openInputStream(syncStreamFlags,0,0);120 is = Cc["@mozilla.org/scriptableinputstream;1"]121 .createInstance(nsIScriptableInputStream);122 is.init(_is);123 os = tp.openOutputStream(syncStreamFlags,0,0);124 }125 connect();126 this.reconnect = function() {127 if(!tp)128 throw Cr.NS_ERROR_NOT_INITIALIZED;129 this.disconnect();130 connect();131 }132 this.disconnect = function() {133 os && os.close();134 is && is.close();135 _is && _is.close();136 tp && tp.close(Cr.NS_OK);137 tp = _is = is = os = null;138 };139 this.isAlive = function() {140 if(!tp || !tp.isAlive()) {141 }142 return tp && tp.isAlive();143 };144 this.setTargetPacket = function(androidSerial) {145 targetPacket = data2Packet("host:transport"+(androidSerial?(":"+androidSerial):("-any")));146 };147 this.doProtocol = function(data) {148 if(!tp)149 throw Cr.NS_ERROR_NOT_INITIALIZED;150 else if(!this.isAlive())151 this.reconnect();152 try {153 switch(determineProtocol(data)) {154 case "shell:":155 return doProtocolShell(targetPacket, is, os, data);156 default:157 return doProcotolDefault(is, os, data);158 }159 } catch(e if e == Cr.NS_BASE_STREAM_CLOSED){160 // Excerpt : https://developer.mozilla.org/en/nsIInputStream#available%28%29161 // Note: Some nsIInputStream implementations automatically close() when eof is reached; some do not.162 this.disconnect();163 }164 };165};166(function(){167 adbBridgeSync.prototype.isConnected = function() {...
request.js
Source:request.js
...201 }202 // extract optional abort signal203 const { signal } = opts;204 // delegate to protocol-specific request handler205 const { protocol, socket = null } = await determineProtocol(ctx, url, signal);206 debug(`${url.host} -> ${protocol}`);207 switch (protocol) {208 case ALPN_HTTP2:209 return h2.request(ctx, url, socket ? { ...opts, socket } : opts);210 case ALPN_HTTP2C:211 // plain-text HTTP/2 (h2c)212 // url.protocol = 'http:'; => doesn't work ?!213 return h2.request(214 ctx,215 new URL(`http://${url.host}${url.pathname}${url.hash}${url.search}`),216 socket ? /* istanbul ignore next */ { ...opts, socket } : opts,217 );218 /* istanbul ignore next */ case ALPN_HTTP1_0:219 case ALPN_HTTP1_1:...
requesthandler.js
Source:requesthandler.js
...19var store = require('./store');20var url = require('url');21var prepare = function(body, request, cb, retries, res) {22 var type;23 if (exports.determineProtocol(request.url) === 'RC') {24 type = rcServlet.getType(request, body);25 } else {26 type = webdriverServlet.getType(request);27 }28 handleRequest(body, request, cb, retries, res);29};30var handleRequest = function(body, request, cb, retries, res) {31 if (exports.determineProtocol(request.url) === 'RC') {32 // RC protocol33 rcServlet.handleRequest(request, body, function(type, node, protocolCallback, body, request) {34 if (type === 'ERROR') {35 log.warn("Returning error message: " + node);36 // in this case, node is an error message, dirty37 return cb(new models.Response(404, node));38 }39 process(request, node, body, type, protocolCallback, cb, retries, 'RC', res);40 });41 } else {42 // WebDriver protocol43 webdriverServlet.handleRequest(request, body, function(type, node, protocolCallback, body, request) {44 if (type === 'ERROR') {45 log.warn("Returning error message: " + node);46 // in this case, node is an error message, dirty47 return cb(new models.Response(500, node));48 }49 process(request, node, body, type, protocolCallback, cb, retries, 'WebDriver', res);50 });51 }52};53var process = function(request, node, body, type, protocolCallback, cb, retries, protocol, res) {54 var parameters = {};55 // post data56 if (body.length > 0) {57 var args = body.split('&');58 for (var i = 0, len = args.length; i < len; i++) {59 var d = args[i].split('=');60 parameters[d[0]] = d[1];61 }62 }63 var urlData = url.parse(request.url.toString(), true);64 for (var key in urlData.query) {65 parameters[key] = urlData.query[key];66 }67 if (type === 'NEW_SESSION') {68 var startTime = (new Date());69 forwardRequest(request, node, body, type, protocolCallback, function(response, session, desired_capabilities) {70 var test = {};71 if (parameters['2']) {72 test.url = decodeURIComponent(parameters['2'].replace(/\+/g, '%20'));73 }74 test.startTime = startTime;75 session.startTime = session.lastSentTime = (new Date()).getTime();76 session.lastSentBody = request.url + ", " + JSON.stringify(parameters);77 store.updateSession(session, function() {78 cb(response, session);79 });80 }, retries, cb);81 } else {82 if (protocol === 'RC') {83 registry.getSessionById(parameters['sessionId'], function(session) {84 session.lastSentTime = (new Date()).getTime();85 session.lastSentBody = request.url + ", " + JSON.stringify(parameters);86 session.response = res;87 store.updateSession(session, function() {88 forwardRequest(request, node, body, type, protocolCallback, cb, retries, cb);89 });90 });91 } else {92 registry.getSessionById(webdriverServlet.extractSessionId(request.url), function(session) {93 session.lastSentTime = (new Date()).getTime();94 session.lastSentBody = request.method + ": " + request.url + ", " + JSON.stringify(parameters);95 session.response = res;96 97 store.updateSession(session, function() {98 forwardRequest(request, node, body, type, protocolCallback, cb, retries, cb);99 });100 });101 }102 }103};104var forwardRequest = function(request, node, body, type, protocolCallback, callback, retries, cb) {105 forwarder.forwardRequest(request, node, body, function(responseForwarded) {106 protocolCallback(responseForwarded, function(response, session, desired_capabilities) {107 if (session === null) {108 if (retries < 5) {109 // something went wrong110 log.warn("Failed to start session, try again");111 retries += 1;112 return setTimeout(function() {113 prepare(body, request, cb, retries);114 }, (2000 + (retries * 500)));115 } else {116 log.warn("Giving up retrying");117 return registry.removeNode(node.host, node.port, function() {118 cb(new models.Response(500, response.body));119 });120 }121 }122 // handle error when the proxy forwarding returns a bad response code123 if (responseForwarded.statusCode === 404) {124 log.warn("Received bad status code from node (" + node.host + ":" + node.port + "): for " + session.sessionID + " " + responseForwarded.statusCode);125 responseForwarded.body = "Session is gone, most likely a timeout occurred! " + responseForwarded.body;126 registry.removeSession(session.sessionID, function() {127 return registry.removeNode(node.host, node.port, function() {128 callback(responseForwarded);129 });130 });131 }132 133 // if the forwarder encountered an error, immediately execute callback134 // this happens when communication with the node failed135 if (response.error === true) {136 return callback(response, session, desired_capabilities);137 }138 var cmdParams = [];139 var urlData;140 if (exports.determineProtocol(request.url) === 'RC') {141 urlData = url.parse(request.url.toString(), true).query;142 if (body.length > 0) {143 var args = body.split('&');144 for (var i = 0, len = args.length; i < len; i++) {145 var d = args[i].split('=');146 urlData[d[0]] = d[1];147 }148 }149 for (var i = 0; i < 5; i++) {150 if (urlData[i]) {151 cmdParams.push("\"" + urlData[i].toString() + "\"");152 }153 }154 }...
urlUtils.js
Source:urlUtils.js
...9 static parse(urlString) {10 11 let remaining = { "string" : urlString };12 if (urlString === null) { return null; }13 const protocol = UrlUtils.determineProtocol(remaining);14 const hostAndPort = UrlUtils.determineHostAndPort(remaining);15 const host = UrlUtils.extractHost(hostAndPort);16 const port = UrlUtils.extractPort(hostAndPort);17 const pathsList = UrlUtils.determinePath(remaining);18 const parametersMap = UrlUtils.determineParameters(remaining);19 const bookmark = UrlUtils.determineBookmark(remaining);20 return new Url(protocol, host, port, pathsList, parametersMap, bookmark);21 }22 static determineProtocol(remaining){23 let value = remaining["string"];24 if (!value) {25 return null;26 }27 let protocol = value;28 if (value.indexOf("//") === -1){29 // No '//' to indicate protocol 30 return null;31 }32 let parts = value.split("//");33 if(parts[0].indexOf("/") !== -1){34 // slash should not be in protocol35 return null;36 }...
InstanceDetailPage.js
Source:InstanceDetailPage.js
...34};35instanceLink = function(instance) {36 const port = findWebPort(_.get(instance, 'services.www', null))37 const endpoint = _.get(instance, 'services.www.properties.bigboat.instance.endpoint.path', `:${port}`);38 const protocol = _.get(instance, "services.www.properties.bigboat.instance.endpoint.protocol", determineProtocol(port));39 const fqdn = _.get(instance, "services.www.fqdn", false);40 return fqdn ? `${protocol}://${fqdn}${endpoint}` : null;41};42findServiceLinks = function(instance) {43 return _.mapValues(instance != null ? instance.services : void 0, function(s) {44 var endpoint, port, protocol, ref, ref1;45 port = findWebPort(s);46 endpoint = ((ref = s.endpoint) != null ? ref.path : void 0) || ":" + port;47 protocol = ((ref1 = s.endpoint) != null ? ref1.protocol : void 0) || determineProtocol(port);48 return `${protocol}://${s.fqdn}${endpoint}`;49 });50};51mapStateToProps = function(state, {params}) {52 var instance, ref, ref1, ref2, ref3, ref4, startByUser;53 instance = _.find(state.collections.instances, {54 name: params.name55 });56 startByUser = _.find(state.collections.users, {57 _id: instance != null ? instance.startedBy : void 058 });59 return {60 title: instance != null ? instance.name : void 0,61 instance: instance,...
fake-driver.js
Source:fake-driver.js
...34 if (!this[cmd]) {35 throw new errors.NotYetImplementedError();36 }37 if (cmd === 'createSession') {38 this.protocol = determineProtocol(...args);39 }40 return await this[cmd](...args);41 }42 async deleteSession () {43 this.jwpProxyActive = false;44 this.sessionId = null;45 }46 async getStatus () {47 return "I'm fine";48 }49 async setUrl (url) {50 return `Navigated to: ${url}`;51 }52 async getUrl () {...
is-web.js
Source:is-web.js
...6 http,7 https,8};9// It works but at what cost?10function determineProtocol(port) {11 return port.toString().endsWith("43") ? "https" : "http";12}13module.exports = function (host, port) {14 // Build the url15 const protocol = determineProtocol(port);16 const _url = `${protocol}://${host}:${port}/unexistent-resource-by-port-scanner`;17 const parsed = url.parse(_url);18 parsed.timeout = 3000;19 // Perform the request20 const request = protocols[protocol].get(parsed);21 return new Promise((resolve) => {22 request.on("error", (_) => resolve({ error: true }));23 request.on("response", (response) => {24 resolve({25 error: false,26 data: {27 headers: response.headers,28 isHttps: protocol === "https"29 },...
index.js
Source:index.js
1// transpile:main2import {3 Protocol, isSessionCommand, routeConfiguringFunction, determineProtocol4} from './protocol';5import {6 NO_SESSION_ID_COMMANDS, ALL_COMMANDS, METHOD_MAP,7 routeToCommandName8} from './routes';9import {10 errors, isErrorType, errorFromMJSONWPStatusCode, errorFromW3CJsonCode11} from './errors';12export {13 Protocol, routeConfiguringFunction, errors, isErrorType,14 errorFromMJSONWPStatusCode, errorFromW3CJsonCode, ALL_COMMANDS, METHOD_MAP,15 routeToCommandName, NO_SESSION_ID_COMMANDS, isSessionCommand, determineProtocol,...
Using AI Code Generation
1const BaseDriver = require('appium-base-driver');2const desiredCaps = {3};4const driver = new BaseDriver();5driver.createSession(desiredCaps);6const BaseDriver = require('appium-base-driver');7const desiredCaps = {8};9const driver = new BaseDriver();10driver.createSession(desiredCaps);11const BaseDriver = require('appium-base-driver');12const desiredCaps = {13};14const driver = new BaseDriver();15driver.createSession(desiredCaps);16const BaseDriver = require('appium-base-driver');17const desiredCaps = {18};19const driver = new BaseDriver();20driver.createSession(desiredCaps);21const BaseDriver = require('appium-base-driver');22const desiredCaps = {23};24const driver = new BaseDriver();25driver.createSession(desiredCaps);26const BaseDriver = require('appium-base-driver');27const desiredCaps = {28};29const driver = new BaseDriver();30driver.createSession(desiredCaps);
Using AI Code Generation
1var BaseDriver = require('appium-base-driver').BaseDriver;2var driver = new BaseDriver();3console.log("protocol is: " + protocol);4 at BaseDriver.determineProtocol (C:\Users\user\AppData\Roaming\npm\node_modules\appium-base-driver\lib\basedriver\driver.js:55:32)5 at Object.<anonymous> (C:\Users\user\test.js:6:25)6 at Module._compile (module.js:571:32)7 at Object.Module._extensions..js (module.js:580:10)8 at Module.load (module.js:488:32)9 at tryModuleLoad (module.js:447:12)10 at Function.Module._load (module.js:439:3)11 at Function.Module.runMain (module.js:605:10)12 at startup (bootstrap_node.js:158:16)
Using AI Code Generation
1const BaseDriver = require('appium-base-driver');2const desiredCaps = {3};4const protocol = BaseDriver.determineProtocol(desiredCaps);5console.log(protocol);6const BaseDriver = require('appium-base-driver');7const desiredCaps = {8};9const protocol = BaseDriver.determineProtocol(desiredCaps);10console.log(protocol);
Using AI Code Generation
1var BaseDriver = require('appium-base-driver').BaseDriver;2var driver = new BaseDriver();3console.log(protocol);4Appium Base Driver Docs (version 2.0.0)5Appium Base Driver Docs (version 1.21.0)6Appium Base Driver Docs (version 1.20.0)7Appium Base Driver Docs (version 1.19.0)8Appium Base Driver Docs (version 1.18.0)9Appium Base Driver Docs (version 1.17.0)10Appium Base Driver Docs (version 1.16.0)11Appium Base Driver Docs (version 1.15.0)12Appium Base Driver Docs (version 1.14.0)13Appium Base Driver Docs (version 1.13.0)14Appium Base Driver Docs (version 1.12.0)15Appium Base Driver Docs (version 1.11.0)16Appium Base Driver Docs (version 1.10.0)17Appium Base Driver Docs (version 1.9.0)18Appium Base Driver Docs (version 1.8.0)19Appium Base Driver Docs (version 1.7.0)20Appium Base Driver Docs (version 1.6.0)21Appium Base Driver Docs (version 1.5.0)22Appium Base Driver Docs (version 1.4.0)23Appium Base Driver Docs (version 1.3.0)24Appium Base Driver Docs (version 1.2.0)25Appium Base Driver Docs (version 1.1.0)
Using AI Code Generation
1var BaseDriver = require('appium-base-driver').BaseDriver;2var driver = new BaseDriver();3console.log(protocol);4var AndroidDriver = require('appium-android-driver').AndroidDriver;5var driver = new AndroidDriver();6console.log(protocol);7var IOSDriver = require('appium-ios-driver').IOSDriver;8var driver = new IOSDriver();9console.log(protocol);10var SelendroidDriver = require('appium-selendroid-driver').SelendroidDriver;11var driver = new SelendroidDriver();12console.log(protocol);13var WindowsDriver = require('appium-windows-driver').WindowsDriver;14var driver = new WindowsDriver();15console.log(protocol);16var YouiEngineDriver = require('appium-youiengine-driver').YouiEngineDriver;17var driver = new YouiEngineDriver();18console.log(protocol);19var MacDriver = require('appium-mac-driver').MacDriver;20var driver = new MacDriver();21console.log(protocol);22var XCUITestDriver = require('appium-xcuitest-driver').XCUITestDriver;23var driver = new XCUITestDriver();
Using AI Code Generation
1import BaseDriver from 'appium-base-driver';2console.log(protocol);3import Driver from 'appium-xcuitest-driver';4console.log(protocol);5import Driver from 'appium-android-driver';6console.log(protocol);7import Driver from 'appium-ios-driver';8console.log(protocol);9import Driver from 'appium-windows-driver';10console.log(protocol);11import Driver from 'appium-mac-driver';12console.log(protocol);13import Driver from 'appium-youiengine-driver';14console.log(protocol);15import Driver from 'appium-tizen-driver';16console.log(protocol);17import Driver from 'appium-firefox-driver';18console.log(protocol);19import Driver from 'appium-safari-driver';20console.log(protocol);21import Driver from 'appium-chromedriver';22console.log(protocol);23import Driver
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.
LambdaTest Learning Hubs:
- JUnit Tutorial
- TestNG Tutorial
- Webdriver Tutorial
- WebDriverIO Tutorial
- Protractor Tutorial
- Selenium 4 Tutorial
- Jenkins Tutorial
- NUnit Tutorial
- Jest Tutorial
- Playwright Tutorial
- Cypress Tutorial
- PyTest Tutorial
YouTube
You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.
Run Appium Base Driver automation tests on LambdaTest cloud grid
Perform automation testing on 3000+ real desktop and mobile devices online.
Try LambdaTest Now !!
Get 100 minutes of automation test minutes FREE!!
Was this article helpful?
