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

Copied to Clipboard!

How to use rid method in wpt

Best JavaScript code snippet using wpt

TransportSession.js.uncompressed.js

Source:TransportSession.js.uncompressed.js

1// wrapped by build app2define("dojox/xmpp/TransportSession", ["dijit","dojo","dojox","dojo/require!dojox/xmpp/bosh,dojox/xmpp/util,dojox/data/dom"], function(dijit,dojo,dojox){3dojo.provide("dojox.xmpp.TransportSession");4dojo.require("dojox.xmpp.bosh");5dojo.require("dojox.xmpp.util");6dojo.require("dojox.data.dom");7dojox.xmpp.TransportSession = function(props) {8	// we have to set this here because "this" doesn't work9	// in the dojo.extend call.10	this.sendTimeout = (this.wait+20)*1000;11	//mixin any options that we want to provide to this service12	if (props && dojo.isObject(props)) {13		dojo.mixin(this, props);14		if(this.useScriptSrcTransport){15			this.transportIframes = [];16		}17	}18	19};20dojo.extend(dojox.xmpp.TransportSession, {21		/* options/defaults */22		rid: 0,23		hold: 1,24		polling:1000,25		secure: false,26		wait: 60,27		lang: 'en',28		submitContentType: 'text/xml; charset=utf=8',29		serviceUrl: '/httpbind',30		defaultResource: "dojoIm",31		domain: 'imserver.com',32		sendTimeout: 0, //(this.wait+20)*100033		34		useScriptSrcTransport:false,35		36		37		keepAliveTimer:null,38		//status39		state: "NotReady",40		transmitState: "Idle",41		protocolPacketQueue: [],42		outboundQueue: [],43		outboundRequests: {},44		inboundQueue: [],45		deferredRequests: {},46		matchTypeIdAttribute: {},47		open: function() {48			this.status = "notReady";49			this.rid = Math.round(Math.random() * 1000000000);50			this.protocolPacketQueue = [];51			this.outboundQueue = [];52			this.outboundRequests = {};53			this.inboundQueue = [];54			this.deferredRequests = {};55			this.matchTypeIdAttribute = {};56			57		58			this.keepAliveTimer = setTimeout(dojo.hitch(this, "_keepAlive"), 10000);59			60			if(this.useScriptSrcTransport){61				dojox.xmpp.bosh.initialize({62					iframes: this.hold+1,63					load: dojo.hitch(this, function(){64						this._sendLogin();65					})66				});67			} else {68				this._sendLogin();69			}70		},71		72		_sendLogin: function() {73				var rid = this.rid++;74				var req = {75					content: this.submitContentType,76					hold: this.hold,77					rid: rid,78					to: this.domain,79					secure: this.secure,80					wait: this.wait,81					"xml:lang": this.lang,82					"xmpp:version": "1.0",83					xmlns: dojox.xmpp.xmpp.BODY_NS,84					"xmlns:xmpp": "urn:xmpp:xbosh"85				};86				var msg = dojox.xmpp.util.createElement("body", req, true);87				this.addToOutboundQueue(msg, rid);88		},89		_sendRestart: function(){90			var rid = this.rid++;91			var req = {92				rid: rid,93				sid: this.sid,94				to: this.domain,95				"xmpp:restart": "true",96				"xml:lang": this.lang,97				xmlns: dojox.xmpp.xmpp.BODY_NS,98				"xmlns:xmpp": "urn:xmpp:xbosh"99			};100			var msg = dojox.xmpp.util.createElement("body", req, true);101			this.addToOutboundQueue(msg, rid);102		},103		104		processScriptSrc: function(msg, rid) {105			//console.log("processScriptSrc::", rid, msg);106		//	var msgDom = dojox.xml.DomParser.parse(msg);107			var msgDom = dojox.xml.parser.parse(msg, "text/xml");108			//console.log("parsed mgs", msgDom);109			//console.log("Queue", this.outboundQueue);110			if(msgDom) {111				this.processDocument(msgDom, rid);112			} else {113				//console.log("Recived bad document from server",msg);114			}115		},116		117		_keepAlive: function(){118			if (this.state=="wait" || this.isTerminated()) {119				return;120			}121			this._dispatchPacket();122			this.keepAliveTimer = setTimeout(dojo.hitch(this, "_keepAlive"), 10000);123		},124		125		126		close: function(protocolMsg){127	128			var rid = this.rid++;129			var req = {130				131				sid: this.sid,132				rid: rid,133				type: "terminate"134			};135			var envelope = null;136			if (protocolMsg) {137				envelope = new dojox.string.Builder(dojox.xmpp.util.createElement("body", req, false));138				envelope.append(protocolMsg);139				envelope.append("</body>");140			} else {141				envelope = new dojox.string.Builder(dojox.xmpp.util.createElement("body", req, false));142			}143		//	this.sendXml(envelope,rid);144			this.addToOutboundQueue(envelope.toString(), rid);145			this.state=="Terminate";146		},147		dispatchPacket: function(msg, protocolMatchType, matchId, matchProperty){148			// summary:149			//		Main Packet dispatcher, most calls should be made with this other150			//		than a few setup calls which use add items to the queue directly151			//		protocolMatchType, matchId, and matchProperty are optional params152			//		that allow a deferred to be tied to a protocol response instad of the whole153			//		rid154	155		//	//console.log("In dispatchPacket ", msg, protocolMatchType, matchId, matchProperty);156			if (msg){157				this.protocolPacketQueue.push(msg);158			}159			160			var def = new dojo.Deferred();161			//def.rid = req.rid;162			if (protocolMatchType && matchId){163				def.protocolMatchType = protocolMatchType;164				def.matchId = matchId;165				def.matchProperty = matchProperty || "id";166				if(def.matchProperty != "id") {167					this.matchTypeIdAttribute[protocolMatchType] = def.matchProperty;168				}169			}170			this.deferredRequests[def.protocolMatchType + "-" +def.matchId]=def;171			if(!this.dispatchTimer) {172				this.dispatchTimer = setTimeout(dojo.hitch(this, "_dispatchPacket"), 600);173			}174			return def;175		},176	177		_dispatchPacket: function(){178			179			clearTimeout(this.dispatchTimer);180			delete this.dispatchTimer;181			182			if (!this.sid){183				console.debug("TransportSession::dispatchPacket() No SID, packet dropped.")184				return;185			}186			if (!this.authId){187				//FIXME according to original nodes, this should wait a little while and try188				//		again up to three times to see if we get this data.189				console.debug("TransportSession::dispatchPacket() No authId, packet dropped [FIXME]")190				return;191			}192		193			//if there is a pending request with the server, don't poll194			if (this.transmitState != "error" && (this.protocolPacketQueue.length == 0) && (this.outboundQueue.length > 0)) {195				return;196			}197			if (this.state=="wait" || this.isTerminated()) {198				return;199			}200			var req = {201				sid: this.sid,202				xmlns: dojox.xmpp.xmpp.BODY_NS203			}204			var envelope205			if (this.protocolPacketQueue.length > 0){206				req.rid= this.rid++;207				envelope = new dojox.string.Builder(dojox.xmpp.util.createElement("body", req, false));208				envelope.append(this.processProtocolPacketQueue());209				envelope.append("</body>");210				delete this.lastPollTime;211			} else {212				//console.log("Nothing to send, I'm just polling.");213				if(this.lastPollTime) {214					var now = new Date().getTime();215					if(now - this.lastPollTime < this.polling) {216						//console.log("Waiting to poll ", this.polling - (now - this.lastPollTime)+10);217						this.dispatchTimer = setTimeout(dojo.hitch(this, "_dispatchPacket"), this.polling - (now - this.lastPollTime)+10);218						return;219					}220				221				}222				req.rid= this.rid++;223				this.lastPollTime = new Date().getTime();224				envelope = new dojox.string.Builder(dojox.xmpp.util.createElement("body", req, true));225			}226		227			this.addToOutboundQueue(envelope.toString(),req.rid);228		},229		redispatchPacket: function(rid){230			var env = this.outboundRequests[rid];231			this.sendXml(env, rid);232		},233		addToOutboundQueue: function(msg, rid){234			this.outboundQueue.push({msg: msg,rid: rid});235			this.outboundRequests[rid]=msg;236			this.sendXml(msg, rid);237		},238		removeFromOutboundQueue: function(rid){239			for(var i=0; i<this.outboundQueue.length;i++){240				if (rid == this.outboundQueue[i]["rid"]){241					this.outboundQueue.splice(i, 1);242					break;243				}244			}245			delete this.outboundRequests[rid];246		},247		processProtocolPacketQueue: function(){248			var packets = new dojox.string.Builder();249			for(var i=0; i<this.protocolPacketQueue.length;i++){250				packets.append(this.protocolPacketQueue[i]);251			}252			this.protocolPacketQueue=[];253			return packets.toString();254		},255		sendXml: function(message, rid){256			if(this.isTerminated()) {257				return false;258			}259			//console.log("TransportSession::sendXml()"+ new Date().getTime() + " RID: ", rid, " MSG: ", message);260			this.transmitState = "transmitting";261			var def = null;262			if(this.useScriptSrcTransport) {263				//console.log("using script src to transmit");264				def = dojox.xmpp.bosh.get({265					rid: rid,266					url: this.serviceUrl+'?'+encodeURIComponent(message),267					error: dojo.hitch(this, function(res, io){268						this.setState("Terminate", "error");269						return false;270					}),271					timeout: this.sendTimeout272				});273			} else {274				def = dojo.rawXhrPost({275					contentType: "text/xml",276					url: this.serviceUrl,277					postData: message,278					handleAs: "xml",279					error: dojo.hitch(this, function(res, io) {280						////console.log("foo", res, io.xhr.responseXML, io.xhr.status);281						return this.processError(io.xhr.responseXML, io.xhr.status , rid);282					}),283					timeout: this.sendTimeout284				});285			}286			//process the result document287			def.addCallback(this, function(res){288				return this.processDocument(res, rid);289			});290			return def;291		},292		processDocument: function(doc, rid){293			if(this.isTerminated() || !doc.firstChild) {294				return false;295			}296			//console.log("TransportSession:processDocument() ", doc, rid);297			this.transmitState = "idle";298			var body = doc.firstChild;299			if (body.nodeName != 'body'){300				//console.log("TransportSession::processDocument() firstChild is not <body> element ", doc, " RID: ", rid);301			}302			if (this.outboundQueue.length<1){return false;}303			var expectedId = this.outboundQueue[0]["rid"];304			//console.log("expectedId", expectedId);305			if (rid==expectedId){306				this.removeFromOutboundQueue(rid);307				this.processResponse(body, rid);308				this.processInboundQueue();309			}else{310				//console.log("TransportSession::processDocument() rid: ", rid, " expected: ", expectedId);311				var gap = rid-expectedId;312			313				if (gap < this.hold + 2){314					this.addToInboundQueue(doc,rid);315				}else{316					//console.log("TransportSession::processDocument() RID is outside of the expected response window");317				}318			}319			return doc;320		},321		processInboundQueue: function(){322			while (this.inboundQueue.length > 0) {323				var item = this.inboundQueue.shift();324				this.processDocument(item["doc"], item["rid"]);325			}326		},327		addToInboundQueue: function(doc,rid){328			for (var i=0; i<this.inboundQueue.length;i++){329				if (rid < this.inboundQueue[i]["rid"]){continue;}330				this.inboundQueue.splice(i,0,{doc: doc, rid: rid});331			}332		},333		processResponse: function(body,rid){334			////console.log("TransportSession:processResponse() ", body, " RID: ", rid);335			if (body.getAttribute("type")=='terminate'){336				var reasonNode = body.firstChild.firstChild;337				var errorMessage = "";338					if(reasonNode.nodeName == "conflict") {339						errorMessage = "conflict"340					}341				this.setState("Terminate", errorMessage);342	343				return;344			}345			if ((this.state != 'Ready')&&(this.state != 'Terminate')) {346				var sid=body.getAttribute("sid");347				if (sid){348					this.sid=sid;349				} else {350					throw new Error("No sid returned during xmpp session startup");351				}352				this.authId = body.getAttribute("authid");353				if (this.authId == "") {354					if (this.authRetries-- < 1) {355						console.error("Unable to obtain Authorization ID");356						this.terminateSession();357					}358				}359				this.wait= body.getAttribute("wait");360				if( body.getAttribute("polling")){361					this.polling= parseInt(body.getAttribute("polling"))*1000;362				}363			364				//console.log("Polling value ", this.polling);365				this.inactivity = body.getAttribute("inactivity");366				this.setState("Ready");367			}368			dojo.forEach(body.childNodes, function(node){369				this.processProtocolResponse(node, rid);370			}, this);371			//need to make sure, since if you use sendXml directly instead of using372			//dispatch packets, there wont' be a call back function here373			//normally the deferred will get fired by a child message at the protocol level374			//but if it hasn't fired by now, go ahead and fire it with the full body375			/*if (this.deferredRequests[rid] && this.deferredRequests[rid].fired==-1){376				this.deferredRequests[rid].callback(body);377			}*/378			//delete from the list of outstanding requests379			//delete this.deferredRequests[rid];380			if (this.transmitState == "idle"){381				this.dispatchPacket();382			}383		},384		processProtocolResponse: function(msg, rid){385			// summary:386			//		process the individual protocol messages and if there387			//		is a matching set of protocolMatchType, matchId, and matchPropery388			//		fire off the deferred389			this.onProcessProtocolResponse(msg);390			var key = msg.nodeName + "-" +msg.getAttribute("id");391			var def = this.deferredRequests[key];392			if (def){393				def.callback(msg);394				delete this.deferredRequests[key];395			}396		},397		setState: function(state, message){398			if (this.state != state) {399				if (this["on"+state]){400					this["on"+state](state, this.state, message);401				}402				this.state=state;403			}404		},405		406		isTerminated: function() {407			408			return this.state=="Terminate";409		},410		processError: function(err, httpStatusCode,rid){411			//console.log("Processing server error ", err, httpStatusCode,rid);412			if(this.isTerminated()) {413				return false;414			}415			416			417			if(httpStatusCode != 200) {418				if(httpStatusCode >= 400 && httpStatusCode < 500){419					/* Any status code between 400 and 500 should terminate420					 * the connection */421					this.setState("Terminate", errorMessage);422					return false;423				}else{424					this.removeFromOutboundQueue(rid);425					setTimeout(dojo.hitch(this, function(){ this.dispatchPacket(); }), 200);426					return true;427				}428				return false;429			}430			431			if (err && err.dojoType && err.dojoType=="timeout"){432				//console.log("Wait timeout");433			}434			435			this.removeFromOutboundQueue(rid);436			//FIXME conditional processing if request will be needed based on type of error.437			if(err && err.firstChild) {438			//console.log("Error ", err.firstChild.getAttribute("type") + " status code " + httpStatusCode);439			440				if (err.firstChild.getAttribute("type")=='terminate'){441					var reasonNode = err.firstChild.firstChild;442					var errorMessage = "";443					if(reasonNode && reasonNode.nodeName == "conflict") {444						errorMessage = "conflict"445					}446					this.setState("Terminate", errorMessage);447					return false;448				}449			}450			this.transmitState = "error";451			setTimeout(dojo.hitch(this, function(){ this.dispatchPacket(); }), 200);452			//console.log("Error: ", arguments);453			return true;454		},455		//events456		onTerminate: function(newState, oldState, message){ },457		onProcessProtocolResponse: function(msg){},458		onReady: function(newState, oldState){}459});...

TransportSession.js

Source:TransportSession.js

1dojo.provide("dojox.xmpp.TransportSession");2dojo.require("dojox.xmpp.bosh");3dojo.require("dojox.xmpp.util");4dojo.require("dojox.data.dom");5dojox.xmpp.TransportSession = function(props) {6	// we have to set this here because "this" doesn't work7	// in the dojo.extend call.8	this.sendTimeout = (this.wait+20)*1000;9	//mixin any options that we want to provide to this service10	if (props && dojo.isObject(props)) {11		dojo.mixin(this, props);12		if(this.useScriptSrcTransport){13			this.transportIframes = [];14		}15	}16	17};18dojo.extend(dojox.xmpp.TransportSession, {19		/* options/defaults */20		rid: 0,21		hold: 1,22		polling:1000,23		secure: false,24		wait: 60,25		lang: 'en',26		submitContentType: 'text/xml; charset=utf=8',27		serviceUrl: '/httpbind',28		defaultResource: "dojoIm",29		domain: 'imserver.com',30		sendTimeout: 0, //(this.wait+20)*100031		32		useScriptSrcTransport:false,33		34		35		keepAliveTimer:null,36		//status37		state: "NotReady",38		transmitState: "Idle",39		protocolPacketQueue: [],40		outboundQueue: [],41		outboundRequests: {},42		inboundQueue: [],43		deferredRequests: {},44		matchTypeIdAttribute: {},45		open: function() {46			this.status = "notReady";47			this.rid = Math.round(Math.random() * 1000000000);48			this.protocolPacketQueue = [];49			this.outboundQueue = [];50			this.outboundRequests = {};51			this.inboundQueue = [];52			this.deferredRequests = {};53			this.matchTypeIdAttribute = {};54			55		56			this.keepAliveTimer = setTimeout(dojo.hitch(this, "_keepAlive"), 10000);57			58			if(this.useScriptSrcTransport){59				dojox.xmpp.bosh.initialize({60					iframes: this.hold+1,61					load: dojo.hitch(this, function(){62						this._sendLogin();63					})64				});65			} else {66				this._sendLogin();67			}68		},69		70		_sendLogin: function() {71				var rid = this.rid++;72				var req = {73					content: this.submitContentType,74					hold: this.hold,75					rid: rid,76					to: this.domain,77					secure: this.secure,78					wait: this.wait,79					"xml:lang": this.lang,80					"xmpp:version": "1.0",81					xmlns: dojox.xmpp.xmpp.BODY_NS,82					"xmlns:xmpp": "urn:xmpp:xbosh"83				};84				var msg = dojox.xmpp.util.createElement("body", req, true);85				this.addToOutboundQueue(msg, rid);86		},87		_sendRestart: function(){88			var rid = this.rid++;89			var req = {90				rid: rid,91				sid: this.sid,92				to: this.domain,93				"xmpp:restart": "true",94				"xml:lang": this.lang,95				xmlns: dojox.xmpp.xmpp.BODY_NS,96				"xmlns:xmpp": "urn:xmpp:xbosh"97			};98			var msg = dojox.xmpp.util.createElement("body", req, true);99			this.addToOutboundQueue(msg, rid);100		},101		102		processScriptSrc: function(msg, rid) {103			//console.log("processScriptSrc::", rid, msg);104		//	var msgDom = dojox.xml.DomParser.parse(msg);105			var msgDom = dojox.xml.parser.parse(msg, "text/xml");106			//console.log("parsed mgs", msgDom);107			//console.log("Queue", this.outboundQueue);108			if(msgDom) {109				this.processDocument(msgDom, rid);110			} else {111				//console.log("Recived bad document from server",msg);112			}113		},114		115		_keepAlive: function(){116			if (this.state=="wait" || this.isTerminated()) {117				return;118			}119			this._dispatchPacket();120			this.keepAliveTimer = setTimeout(dojo.hitch(this, "_keepAlive"), 10000);121		},122		123		124		close: function(protocolMsg){125	126			var rid = this.rid++;127			var req = {128				129				sid: this.sid,130				rid: rid,131				type: "terminate"132			};133			var envelope = null;134			if (protocolMsg) {135				envelope = new dojox.string.Builder(dojox.xmpp.util.createElement("body", req, false));136				envelope.append(protocolMsg);137				envelope.append("</body>");138			} else {139				envelope = new dojox.string.Builder(dojox.xmpp.util.createElement("body", req, false));140			}141		//	this.sendXml(envelope,rid);142			this.addToOutboundQueue(envelope.toString(), rid);143			this.state=="Terminate";144		},145		dispatchPacket: function(msg, protocolMatchType, matchId, matchProperty){146			// summary:147			//		Main Packet dispatcher, most calls should be made with this other148			//		than a few setup calls which use add items to the queue directly149			//		protocolMatchType, matchId, and matchProperty are optional params150			//		that allow a deferred to be tied to a protocol response instad of the whole151			//		rid152	153		//	//console.log("In dispatchPacket ", msg, protocolMatchType, matchId, matchProperty);154			if (msg){155				this.protocolPacketQueue.push(msg);156			}157			158			var def = new dojo.Deferred();159			//def.rid = req.rid;160			if (protocolMatchType && matchId){161				def.protocolMatchType = protocolMatchType;162				def.matchId = matchId;163				def.matchProperty = matchProperty || "id";164				if(def.matchProperty != "id") {165					this.matchTypeIdAttribute[protocolMatchType] = def.matchProperty;166				}167			}168			this.deferredRequests[def.protocolMatchType + "-" +def.matchId]=def;169			if(!this.dispatchTimer) {170				this.dispatchTimer = setTimeout(dojo.hitch(this, "_dispatchPacket"), 600);171			}172			return def;173		},174	175		_dispatchPacket: function(){176			177			clearTimeout(this.dispatchTimer);178			delete this.dispatchTimer;179			180			if (!this.sid){181				console.debug("TransportSession::dispatchPacket() No SID, packet dropped.")182				return;183			}184			if (!this.authId){185				//FIXME according to original nodes, this should wait a little while and try186				//		again up to three times to see if we get this data.187				console.debug("TransportSession::dispatchPacket() No authId, packet dropped [FIXME]")188				return;189			}190		191			//if there is a pending request with the server, don't poll192			if (this.transmitState != "error" && (this.protocolPacketQueue.length == 0) && (this.outboundQueue.length > 0)) {193				return;194			}195			if (this.state=="wait" || this.isTerminated()) {196				return;197			}198			var req = {199				sid: this.sid,200				xmlns: dojox.xmpp.xmpp.BODY_NS201			}202			var envelope203			if (this.protocolPacketQueue.length > 0){204				req.rid= this.rid++;205				envelope = new dojox.string.Builder(dojox.xmpp.util.createElement("body", req, false));206				envelope.append(this.processProtocolPacketQueue());207				envelope.append("</body>");208				delete this.lastPollTime;209			} else {210				//console.log("Nothing to send, I'm just polling.");211				if(this.lastPollTime) {212					var now = new Date().getTime();213					if(now - this.lastPollTime < this.polling) {214						//console.log("Waiting to poll ", this.polling - (now - this.lastPollTime)+10);215						this.dispatchTimer = setTimeout(dojo.hitch(this, "_dispatchPacket"), this.polling - (now - this.lastPollTime)+10);216						return;217					}218				219				}220				req.rid= this.rid++;221				this.lastPollTime = new Date().getTime();222				envelope = new dojox.string.Builder(dojox.xmpp.util.createElement("body", req, true));223			}224		225			this.addToOutboundQueue(envelope.toString(),req.rid);226		},227		redispatchPacket: function(rid){228			var env = this.outboundRequests[rid];229			this.sendXml(env, rid);230		},231		addToOutboundQueue: function(msg, rid){232			this.outboundQueue.push({msg: msg,rid: rid});233			this.outboundRequests[rid]=msg;234			this.sendXml(msg, rid);235		},236		removeFromOutboundQueue: function(rid){237			for(var i=0; i<this.outboundQueue.length;i++){238				if (rid == this.outboundQueue[i]["rid"]){239					this.outboundQueue.splice(i, 1);240					break;241				}242			}243			delete this.outboundRequests[rid];244		},245		processProtocolPacketQueue: function(){246			var packets = new dojox.string.Builder();247			for(var i=0; i<this.protocolPacketQueue.length;i++){248				packets.append(this.protocolPacketQueue[i]);249			}250			this.protocolPacketQueue=[];251			return packets.toString();252		},253		sendXml: function(message, rid){254			if(this.isTerminated()) {255				return false;256			}257			//console.log("TransportSession::sendXml()"+ new Date().getTime() + " RID: ", rid, " MSG: ", message);258			this.transmitState = "transmitting";259			var def = null;260			if(this.useScriptSrcTransport) {261				//console.log("using script src to transmit");262				def = dojox.xmpp.bosh.get({263					rid: rid,264					url: this.serviceUrl+'?'+encodeURIComponent(message),265					error: dojo.hitch(this, function(res, io){266						this.setState("Terminate", "error");267						return false;268					}),269					timeout: this.sendTimeout270				});271			} else {272				def = dojo.rawXhrPost({273					contentType: "text/xml",274					url: this.serviceUrl,275					postData: message,276					handleAs: "xml",277					error: dojo.hitch(this, function(res, io) {278						////console.log("foo", res, io.xhr.responseXML, io.xhr.status);279						return this.processError(io.xhr.responseXML, io.xhr.status , rid);280					}),281					timeout: this.sendTimeout282				});283			}284			//process the result document285			def.addCallback(this, function(res){286				return this.processDocument(res, rid);287			});288			return def;289		},290		processDocument: function(doc, rid){291			if(this.isTerminated() || !doc.firstChild) {292				return false;293			}294			//console.log("TransportSession:processDocument() ", doc, rid);295			this.transmitState = "idle";296			var body = doc.firstChild;297			if (body.nodeName != 'body'){298				//console.log("TransportSession::processDocument() firstChild is not <body> element ", doc, " RID: ", rid);299			}300			if (this.outboundQueue.length<1){return false;}301			var expectedId = this.outboundQueue[0]["rid"];302			//console.log("expectedId", expectedId);303			if (rid==expectedId){304				this.removeFromOutboundQueue(rid);305				this.processResponse(body, rid);306				this.processInboundQueue();307			}else{308				//console.log("TransportSession::processDocument() rid: ", rid, " expected: ", expectedId);309				var gap = rid-expectedId;310			311				if (gap < this.hold + 2){312					this.addToInboundQueue(doc,rid);313				}else{314					//console.log("TransportSession::processDocument() RID is outside of the expected response window");315				}316			}317			return doc;318		},319		processInboundQueue: function(){320			while (this.inboundQueue.length > 0) {321				var item = this.inboundQueue.shift();322				this.processDocument(item["doc"], item["rid"]);323			}324		},325		addToInboundQueue: function(doc,rid){326			for (var i=0; i<this.inboundQueue.length;i++){327				if (rid < this.inboundQueue[i]["rid"]){continue;}328				this.inboundQueue.splice(i,0,{doc: doc, rid: rid});329			}330		},331		processResponse: function(body,rid){332			////console.log("TransportSession:processResponse() ", body, " RID: ", rid);333			if (body.getAttribute("type")=='terminate'){334				var reasonNode = body.firstChild.firstChild;335				var errorMessage = "";336					if(reasonNode.nodeName == "conflict") {337						errorMessage = "conflict"338					}339				this.setState("Terminate", errorMessage);340	341				return;342			}343			if ((this.state != 'Ready')&&(this.state != 'Terminate')) {344				var sid=body.getAttribute("sid");345				if (sid){346					this.sid=sid;347				} else {348					throw new Error("No sid returned during xmpp session startup");349				}350				this.authId = body.getAttribute("authid");351				if (this.authId == "") {352					if (this.authRetries-- < 1) {353						console.error("Unable to obtain Authorization ID");354						this.terminateSession();355					}356				}357				this.wait= body.getAttribute("wait");358				if( body.getAttribute("polling")){359					this.polling= parseInt(body.getAttribute("polling"))*1000;360				}361			362				//console.log("Polling value ", this.polling);363				this.inactivity = body.getAttribute("inactivity");364				this.setState("Ready");365			}366			dojo.forEach(body.childNodes, function(node){367				this.processProtocolResponse(node, rid);368			}, this);369			//need to make sure, since if you use sendXml directly instead of using370			//dispatch packets, there wont' be a call back function here371			//normally the deferred will get fired by a child message at the protocol level372			//but if it hasn't fired by now, go ahead and fire it with the full body373			/*if (this.deferredRequests[rid] && this.deferredRequests[rid].fired==-1){374				this.deferredRequests[rid].callback(body);375			}*/376			//delete from the list of outstanding requests377			//delete this.deferredRequests[rid];378			if (this.transmitState == "idle"){379				this.dispatchPacket();380			}381		},382		processProtocolResponse: function(msg, rid){383			// summary:384			//		process the individual protocol messages and if there385			//		is a matching set of protocolMatchType, matchId, and matchPropery386			//		fire off the deferred387			this.onProcessProtocolResponse(msg);388			var key = msg.nodeName + "-" +msg.getAttribute("id");389			var def = this.deferredRequests[key];390			if (def){391				def.callback(msg);392				delete this.deferredRequests[key];393			}394		},395		setState: function(state, message){396			if (this.state != state) {397				if (this["on"+state]){398					this["on"+state](state, this.state, message);399				}400				this.state=state;401			}402		},403		404		isTerminated: function() {405			406			return this.state=="Terminate";407		},408		processError: function(err, httpStatusCode,rid){409			//console.log("Processing server error ", err, httpStatusCode,rid);410			if(this.isTerminated()) {411				return false;412			}413			414			415			if(httpStatusCode != 200) {416				if(httpStatusCode >= 400 && httpStatusCode < 500){417					/* Any status code between 400 and 500 should terminate418					 * the connection */419					this.setState("Terminate", errorMessage);420					return false;421				}else{422					this.removeFromOutboundQueue(rid);423					setTimeout(dojo.hitch(this, function(){ this.dispatchPacket(); }), 200);424					return true;425				}426				return false;427			}428			429			if (err && err.dojoType && err.dojoType=="timeout"){430				//console.log("Wait timeout");431			}432			433			this.removeFromOutboundQueue(rid);434			//FIXME conditional processing if request will be needed based on type of error.435			if(err && err.firstChild) {436			//console.log("Error ", err.firstChild.getAttribute("type") + " status code " + httpStatusCode);437			438				if (err.firstChild.getAttribute("type")=='terminate'){439					var reasonNode = err.firstChild.firstChild;440					var errorMessage = "";441					if(reasonNode && reasonNode.nodeName == "conflict") {442						errorMessage = "conflict"443					}444					this.setState("Terminate", errorMessage);445					return false;446				}447			}448			this.transmitState = "error";449			setTimeout(dojo.hitch(this, function(){ this.dispatchPacket(); }), 200);450			//console.log("Error: ", arguments);451			return true;452		},453		//events454		onTerminate: function(newState, oldState, message){ },455		onProcessProtocolResponse: function(msg){},456		onReady: function(newState, oldState){}...

canOpenRoom.js

Source:canOpenRoom.js

1import database from '../database';2import store from '../createStore';3const restTypes = {4	channel: 'channels', direct: 'im', group: 'groups'5};6async function open({ type, rid, name }) {7	try {8		const params = rid ? { roomId: rid } : { roomName: name };9		// if it's a direct link without rid we'll create a new dm10		// if the dm already exists it'll return the existent11		if (type === 'direct' && !rid) {12			const result = await this.createDirectMessage(name);13			if (result.success) {14				const { room } = result;15				room.rid = room._id;16				return room;17			}18		}19		// if it's a group we need to check if you can open20		if (type === 'group') {21			try {22				// RC 0.61.023				await this.sdk.post(`${ restTypes[type] }.open`, params);24			} catch (e) {25				if (!(e.data && /is already open/.test(e.data.error))) {26					return false;27				}28			}29		}30		// if it's a channel or group and the link don't have rid31		// we'll get info from the room32		if ((type === 'channel' || type === 'group') && !rid) {33			// RC 0.72.034			const result = await this.sdk.get(`${ restTypes[type] }.info`, params);35			if (result.success) {36				const room = result[type];37				room.rid = room._id;38				return room;39			}40		}41		// if rid was sent by link42		if (rid) {43			return { rid };44		}45		return false;46	} catch (e) {47		return false;48	}49}50export default async function canOpenRoom({ rid, path, isCall }) {51	try {52		const db = database.active;53		const subsCollection = db.get('subscriptions');54		if (isCall && !rid) {55			// Extract rid from a Jitsi URL56			// Eg.: [Jitsi_URL_Room_Prefix][uniqueID][rid][?jwt]57			const { Jitsi_URL_Room_Prefix, uniqueID } = store.getState().settings;58			rid = path.replace(`${ Jitsi_URL_Room_Prefix }${ uniqueID }`, '').replace(/\?(.*)/g, '');59		}60		if (rid) {61			try {62				const room = await subsCollection.find(rid);63				return {64					rid,65					t: room.t,66					name: room.name,67					fname: room.fname,68					prid: room.prid,69					uids: room.uids,70					usernames: room.usernames71				};72			} catch (e) {73				// Do nothing74			}75		}76		const [type, name] = path.split('/');77		try {78			const result = await open.call(this, { type, rid, name });79			return result;80		} catch (e) {81			return false;82		}83	} catch (e) {84		return false;85	}...

Using AI Code Generation

1const wpt = require('webpagetest');2const wptClient = wpt('www.webpagetest.org');3  if (err) return console.error(err);4  console.log(data);5  wptClient.rid(data.data.testId, (err, data) => {6    if (err) return console.error(err);7    console.log(data);8  });9});

Using AI Code Generation

1var wpt = require('webpagetest');2var test = wpt('www.webpagetest.org');3}, function(err, data) {4    if (err) return console.error(err);5    console.log(data);6    test.getTestResults(data.data.testId, function(err, data) {7        if (err) return console.error(err);8        console.log(data);9    });10});11var wpt = require('webpagetest');12var test = wpt('www.webpagetest.org');13}, function(err, data) {14    if (err) return console.error(err);15    console.log(data);16    test.getTestResults(data.data.testId, function(err, data) {17        if (err) return console.error(err);18        console.log(data);19    });20});

Using AI Code Generation

1var wptools = require('wptools');2var fs = require('fs');3var async = require('async');4var request = require('request');5var util = require('util');6var _ = require('underscore');7var csvWriter = require('csv-write-stream');8var writer = csvWriter({ headers: ["title", "image", "caption", "url"] });9writer.pipe(fs.createWriteStream('output.csv'));

Using AI Code Generation

1var wpt = require('webpagetest');2var client = wpt('www.webpagetest.org');3var fs = require('fs');4client.runTest(url, {5}, function(err, data) {6    if (err) return console.error(err);7    console.log(data.data.runs[1].firstView);8    fs.writeFile('test.json', JSON.stringify(data.data.runs[1].firstView, null, 4), function(err) {9        console.log('File successfully written! - Check your project directory for the test.json file');10    })11})

Using AI Code Generation

1const wptools = require('wptools');2wptools.page('Barack_Obama').then(page => {3    return page.get();4}).then(page => {5    console.log(page.infobox);6}).catch(err => {7    console.log(err);8});9const wptools = require('wptools');10wptools.page('Barack_Obama').then(page => {11    return page.get();12}).then(page => {13    console.log(page.infobox);14}).catch(err => {15    console.log(err);16});17const wptools = require('wptools');18wptools.page('Barack_Obama').then(page => {19    return page.get();20}).then(page => {21    console.log(page.infobox);22}).catch(err => {23    console.log(err);24});25const wptools = require('wptools');26wptools.page('Barack_Obama').then(page => {27    return page.get();28}).then(page => {29    console.log(page.infobox);30}).catch(err => {31    console.log(err);32});33const wptools = require('wptools');34wptools.page('Barack_Obama').then(page => {35    return page.get();36}).then(page => {37    console.log(page.infobox);38}).catch(err => {39    console.log(err);40});41const wptools = require('wptools');42wptools.page('Barack_Obama').then(page => {43    return page.get();44}).then(page => {45    console.log(page.infobox);46}).catch(err => {47    console.log(err);48});49const wptools = require('wptools');50wptools.page('Barack_Obama').then(page => {51    return page.get();52}).then(page => {53    console.log(page.infobox);54}).catch(err => {55    console.log(err);56});

Using AI Code Generation

1var wpt = require('webpagetest');2var wpt = new WebPageTest('www.webpagetest.org');3var url = process.argv[2];4var wptKey = process.argv[3];5var wptLocation = process.argv[4];6var testId = process.argv[5];7var options = {8};9wpt.runTest(url, options, function(err, data) {10    if (err) return console.log(err);11    console.log('Test ID:' + data.data.testId);12    wpt.getTestResults(data.data.testId, function(err, data) {13        if (err) return console.log(err);14        console.log('SpeedIndex:' + data.data.average.firstView.SpeedIndex);15        console.log('VisuallyComplete:' + data.data.average.firstView.VisualComplete);16        console.log('TTFB:' + data.data.average.firstView.TTFB);17        console.log('FullyLoaded:' + data.data.average.firstView.fullyLoaded);18        console.log('LoadTime:' + data.data.average.firstView.loadTime);19        console.log('BytesIn:' + data.data.average.firstView.bytesIn);20        console.log('BytesInDoc:' + data.data.average.firstView.bytesInDoc);21        console.log('BytesOut:' + data.data.average.firstView.bytesOut);22        console.log('BytesOutDoc:' + data.data.average.firstView.bytesOutDoc);23        console.log('RequestsDoc:' + data.data.average.firstView.requestsDoc);24        console.log('RequestsFull:' + data.data.average.firstView.requestsFull);25        console.log('DocTime:' + data.data.average.firstView.docTime);26        console.log('TitleTime:' + data.data.average.firstView.titleTime);27        console.log('Render:' + data.data.average.firstView.render);28        console.log('LastVisualChange:' + data.data.average.firstView.lastVisualChange);29        console.log('ScoreCache:' + data.data.average.firstView.score_cache);30        console.log('ScoreCdn:' + data.data.average.firstView.score_cdn);31        console.log('ScoreGzip:' + data.data.average.firstView.score_gzip);32        console.log('ScoreCookies:' + data.data.average.firstView.score_cookies);

Using AI Code Generation

1var wpt = require('webpagetest');2var fs = require('fs');3var options = {4};5var test = wpt(options);6test.runTest(testURL, {video: 1, videoCapture: 1}, function(err, data) {7  if (err) return console.error(err);8  console.log('Test submitted. Polling for results.');9  test.checkTestStatus(data.data.testId, function(err, data) {10    if (err) return console.error(err);11    console.log('Test complete.');12    var results = JSON.stringify(data.data);13    fs.writeFile('results.json', results, 'utf8', function(err) {14      if (err) return console.error(err);15      console.log('Test results saved to results.json');16    });17  });18});

Using AI Code Generation

1var wpt = require('webpagetest');2var options = {3};4var WebPageTest = new wpt('www.webpagetest.org', options);5console.log(WebPageTest);6  if (err) return console.error(err);7  console.log('Test submitted. Polling for results...');8  WebPageTest.waitForTestToComplete(data.data.testId, function(err, data) {9    if (err) return console.error(err);10    console.log('Test completed!');11    console.log(data);12  });13});

Using AI Code Generation

1const wpt = require('webpagetest');2const client = wpt('A.9a9f9d4f4c8a7a4d4f4a4a4a4a4a4a4a4a4a4a4');3const options = {4};5client.runTest(url, options, (err, data) => {6  if (err) return console.error(err);7  console.log(data.data.runs[0].firstView);8  const rid = data.data.testId;9  console.log(rid);10  client.getTestResults(rid, (err, data) => {11    if (err) return console.error(err);12    console.log(data.data.runs[0].firstView);13  });14});

Using AI Code Generation

1var wpt = require('webpagetest');2var options = {3};4var test = new wpt(options);5test.runTest(url, function (err, data) {6    if (err) return console.error(err);7    console.log('Test submitted. Polling for results...');8    test.getTestResults(data.data.testId, function (err, data) {9        if (err) return console.error(err);10        console.log('First View (loadTime): ' + data.data.average.firstView.loadTime);11        console.log('Repeat View (loadTime): ' + data.data.average.repeatView.loadTime);12    });13});

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.