How to use this.bootstrap.start method in Appium Android Driver

...218      await this.initAUT();219    }220    // start UiAutomator221    this.bootstrap = new helpers.bootstrap(this.adb, this.bootstrapPort, this.opts.websocket);222    await this.bootstrap.start(this.opts.appPackage, this.opts.disableAndroidWatchers, this.opts.acceptSslCerts);223    // handling unexpected shutdown224    this.bootstrap.onUnexpectedShutdown.catch(async (err) => { // eslint-disable-line promise/prefer-await-to-callbacks225      if (!this.bootstrap.ignoreUnexpectedShutdown) {226        await this.startUnexpectedShutdown(err);227      }228    });229    if (!this.opts.skipUnlock) {230      // Let's try to unlock the device231      await helpers.unlock(this, this.adb, this.caps);232    }233    // Set CompressedLayoutHierarchy on the device based on current settings object234    // this has to happen _after_ bootstrap is initialized235    if (this.opts.ignoreUnimportantViews) {236      await this.settings.update({ignoreUnimportantViews: this.opts.ignoreUnimportantViews});...

...56		"should throw on startup when no completed callback given" : function(test) {			57			var _this = this;58			59			assert.throws(function() {60				_this.bootstrap.start();61			}, /no bootstrap completed/i);			62			test.done();63        },        64		65		"bootstrap manager for node joining a ring should initiate sending of bootstrap requests without PNS when PNS off" : function(test) {66			var self = this;67			var sendToAddr = sinon.stub(this.transport, 'sendToAddr');68			this.bootstrap.pendingRequestCheckIntervalMsec = 50;69			this.bootstrap.usePns = false;70			71			this.bootstrap.start('1.2.3.4:1234,5.6.7.8:5678,myhost:8888', sinon.stub());72			73			setTimeout(function() {74				test.ok(sendToAddr.calledWith('p2p:graviti/peers', {joining_node_id : self.transport.nodeId}, {method : 'GET'}, '1.2.3.4', '1234'));75				test.ok(sendToAddr.calledWith('p2p:graviti/peers', {joining_node_id : self.transport.nodeId}, {method : 'GET'}, '5.6.7.8', '5678'));76				test.ok(sendToAddr.calledWith('p2p:graviti/peers', {joining_node_id : self.transport.nodeId}, {method : 'GET'}, 'myhost', '8888'));77				test.done();78			}, 200);79		},80		81		"bootstrap manager for node joining a ring should initiate sending of bootstrap requests with PNS when PNS on" : function(test) {82			var self = this;83			var sendToAddr = sinon.collection.stub(this.transport, 'sendToAddr');84			this.bootstrap.pendingRequestCheckIntervalMsec = 50;85			sinon.collection.stub(this.pns, 'run', function(endpoint, success) {86				success('6.6.6.6:6666');87			});88			89			this.bootstrap.start('1.2.3.4:1234,5.6.7.8:5678,myhost:8888', sinon.stub());90			91			setTimeout(function() {92				test.equal(3, sendToAddr.callCount);93				test.ok(sendToAddr.calledWith('p2p:graviti/peers', {joining_node_id : self.transport.nodeId}, {method : 'GET'}, '6.6.6.6', '6666'));94				test.done();95			}, 200);96		},97		98		"bootstrap manager for node joining a ring should be able to re-send unacknowledged bootstrap requests" : function(test) {99			this.bootstrap.pendingRequestCheckIntervalMsec = 50;100			this.bootstrap.bootstrapRetryIntervalMsec = 50;101			this.bootstrap.usePns = false;102			var callCount = 0;103			var sendToAddr = sinon.stub(this.transport, 'sendToAddr', function() {104				callCount++;105			});106			107			this.bootstrap.start('1.2.3.4:1234,5.6.7.8:5678,myhost:8888', sinon.stub());108			109			setTimeout(function() {110				test.ok(callCount >= 6);111				test.done();112			}, 200);113		}114	}),115	"bootstrap manager shutdown" : testCase({116		setUp : function(done) {117            this.transport = mockutil.stubProto(transport.TransportStack);118			this.pns = mockutil.stubProto(pns.Pns);119			this.cancelAll = sinon.collection.stub(this.pns, 'cancelAll');120            this.bootstrap = new bootstrap.Bootstrapper(this.transport);121			this.bootstrap.pns = this.pns;122			done();123		},124		125		"should stop pns on stop" : function(test) {126			this.bootstrap.stop();127			128			test.ok(this.cancelAll.called);129			test.done();130        },131        "should reset state on stop" : function(test) {132            this.bootstrap.bootstrapping = true;133            this.bootstrap.bootstrapEndpoints = {'1234' : 'localhost'};134            this.bootstrap.bootstrappingIntervalId = setInterval(function() {}, 100000);135            this.bootstrap.stop();136            137            test.equal(false, this.bootstrap.bootstrapping);138            test.deepEqual({}, this.bootstrap.bootstrapEndpoints);139            test.equal(undefined, this.bootstrap.bootstrappingIntervalId);140            test.done();141		}142	}),143	"handling bootstrap requests" : testCase ({144		setUp : function(done) {145			var nodeId = '1234567890123456789012345678901234567890';146			this.transport = mockutil.stubProto(transport.TransportStack);147			this.transport.nodeId = nodeId;148			this.leafset = new leafset.Leafset(nodeId);149			this.routingtable = new routingtable.RoutingTable(nodeId);150			this.pns = mockutil.stubProto(pns.Pns);151			this.bootstrap = new bootstrap.Bootstrapper(this.transport, this.leafset, this.routingtable, undefined, this.pns);152		153			this.msginfo = {154				sender_ap : '2.2.2.2:2222'155			};156			this.sharedRow = {'2' : {'A' : {id :'00A'}}};157			158			this.updateWithProvisional = sinon.collection.stub(this.leafset, 'updateWithProvisional');159			160			this.rtUpdateWithKnownGood= sinon.stub(this.routingtable, 'updateWithKnownGood');161			this.getSharedRow = sinon.stub(this.routingtable, 'getSharedRow').returns(this.sharedRow);162			163			this.sendToAddr = sinon.collection.stub(this.transport, 'sendToAddr');164			this.send = sinon.collection.stub(this.transport, 'send');165			this.sendToId = sinon.collection.stub(this.transport, 'sendToId');166		167			done();168		},169		170		tearDown : function(done) {171			this.bootstrap.stop();172			sinon.collection.restore();173			done();174		},175		176		"when we are nearest to joining node's node id, should respond with final response" : function(test) {			177			var msg = {178				uri : 'p2p:graviti/peers',179				method : 'GET',180				content : {181					joining_node_id : 'ABCDEF1234ABCDEF1234ABCDEF1234ABCDEF1234'					182				}183			};			184			185			this.bootstrap.start('mybootstraps', sinon.stub);186			this.bootstrap._handleReceivedGravitiMessage(msg, this.msginfo);187			test.ok(!this.send.called);188			test.ok(!this.sendToId.called);189			test.ok(this.sendToAddr.calledOnce);190			test.strictEqual(this.sendToAddr.args[0][0], 'p2p:graviti/peers');191			test.deepEqual(this.sendToAddr.args[0][1], 	{192					leafset : this.leafset.compressedLeafset(),193					routing_table : this.sharedRow,194					bootstrap_request_hops : ['1234567890123456789012345678901234567890'],195					last_bootstrap_hop : true196			});197			test.deepEqual(this.sendToAddr.args[0][2], {198					method : 'POST'199			});200			test.strictEqual(this.sendToAddr.args[0][3], '2.2.2.2');201			test.strictEqual(this.sendToAddr.args[0][4], '2222');202			test.done();203		},204		205		"when we are not nearest to joining node's node id, should rebroadcast request into ring" : function(test) {			206			sinon.stub(this.leafset, 'isThisNodeNearestTo').returns(false);207			var msg = {208				uri : 'p2p:graviti/peers',209				method : 'GET',210				content : {211					joining_node_id : 'ABCDEF1234ABCDEF1234ABCDEF1234ABCDEF1234',212					bootstrap_source_ap : '3.3.3.3:3333'213				}214			};215			216			this.bootstrap.start('', sinon.stub);217			this.bootstrap._handleReceivedGravitiMessage(msg, this.msginfo);218			test.ok(!this.send.called);219			test.ok(!this.sendToAddr.called);220			test.ok(this.sendToId.calledOnce);221			test.strictEqual(this.sendToId.args[0][0], 'p2p:graviti/peers');222			test.deepEqual(this.sendToId.args[0][1], {223					joining_node_id : 'ABCDEF1234ABCDEF1234ABCDEF1234ABCDEF1234',224					routing_table : this.sharedRow,225					bootstrap_request_hops : ['1234567890123456789012345678901234567890'],226					bootstrap_source_ap : '3.3.3.3:3333'227			});228			test.deepEqual(this.sendToId.args[0][2], {method : 'GET'});229			test.strictEqual(this.sendToId.args[0][3], 'ABCDEF1234ABCDEF1234ABCDEF1234ABCDEF1234');230			test.done();231		},232		233		"when forwardig a bootstrap request, we should update partial routing table with our own" : function(test) {234			var msg = {235				uri : 'p2p:graviti/peers',236				method : 'GET',237				content : {238					joining_node_id : 'ABCDEF1234ABCDEF1234ABCDEF1234ABCDEF1234',239					routing_table : {'1' : {'4' : {id :'040'}}},240					bootstrap_request_hops : ['BAAD'],241					bootstrap_source_ap : '3.3.3.3:3333'242				}243			};244				245			this.bootstrap.start('', sinon.stub);246			this.bootstrap._handleForwardingGravitiMessage(msg, this.msginfo);247			248			test.ok(!this.send.called);249			test.ok(!this.sendToId.called);250			test.ok(!this.sendToAddr.called);251			test.deepEqual(msg.content, {252				joining_node_id : 'ABCDEF1234ABCDEF1234ABCDEF1234ABCDEF1234',253				routing_table : {254					'1' : {'4' : {id :'040'}},255					'2' : {'A' : {id :'00A'}}256				},257				bootstrap_request_hops : ['BAAD', '1234567890123456789012345678901234567890'],258				bootstrap_source_ap : '3.3.3.3:3333'259			});260			test.done();261		}262	}),263	"handling bootstrap responses" : testCase ({264		setUp : function(done) {265			var _this = this;266			267			var nodeId = '1234567890123456789012345678901234567890';268			this.transport = mockutil.stubProto(transport.TransportStack);269			this.transport.nodeId = nodeId;270			this.leafset = new leafset.Leafset(nodeId);271			this.routingtable = new routingtable.RoutingTable(nodeId);272			this.heartbeater = mockutil.stubProto(heartbeater.Heartbeater);273			this.pns = mockutil.stubProto(pns.Pns);274			this.bootstrap = new bootstrap.Bootstrapper(this.transport, this.leafset, this.routingtable, this.heartbeater, this.pns);275			this.leafsetContent = {'LS' : '5.5.5.5:5555'};276			this.routingTableContent = {'RT' : '5.5.5.5:5555'};277			this.msginfo = {278				sender_ap : '2.2.2.2:2222'279			};280	281			this.updateWithProvisional = sinon.stub(this.leafset, 'updateWithProvisional');282			this.updateWithKnownGood = sinon.stub(this.leafset, 'updateWithKnownGood');283			this.mergeProvisional = sinon.stub(this.routingtable, 'mergeProvisional');284			285			this.leafsetPeers = [{ap:"1.1.1.1:1111"}, {ap:"2.2.2.2:2222"}];286			this.routingTableRows = {287				'0' : { 288			    	'2' : {id : '2345', ap:"2.2.2.2:2222"},289			    	'5' : {id : '5678', ap:"5.5.5.5:5555"}290			    },291			    '1' : {292			    	'6' : {id : '6789', ap:"6.6.6.6:6666"}293			    }294			};295			this.leafsetEach = sinon.stub(this.leafset, 'each', function(cbk) {296				for (var i = 0; i < _this.leafsetPeers.length; i++) {297					cbk('someid', _this.leafsetPeers[i]);298				}299			});300			this.routingTableEachRow = sinon.stub(this.routingtable, 'eachRow', function(cbk) {301				Object.keys(_this.routingTableRows).forEach(function(row) {					302					cbk(row, _this.routingTableRows[row]);					303				});304			});305	306			this.sendHeartbeatToAddr = sinon.collection.stub(this.heartbeater, 'sendHeartbeatToAddr');307			308			done();309		},310		311		tearDown : function(done) {312			this.bootstrap.stop();313			sinon.collection.restore();314			done();315		},316		317		"should emit bootstrap complete event when last bootstrap response received" : function(test) {318			var bootstrapCompletedCallback = sinon.stub();319			var _this = this;320			var msg = {321				uri : 'p2p:graviti/peers',322				method : 'POST',323				source_id : 'ABCDEF1234ABCDEF1234ABCDEF1234ABCDEF1234',324				content : {325					leafset : this.leafsetContent,326					routing_table : this.routingTableContent,327					last_bootstrap_hop : true328				}329			};330					331			this.bootstrap.start('cool-bootstrap', bootstrapCompletedCallback);			332			this.bootstrap._handleReceivedGravitiMessage(msg, this.msginfo);333			334			test.ok(!this.bootstrap.bootstrapping);335			test.ok(bootstrapCompletedCallback.called);336			test.done();337		},		338		339		"should notify peers in state tables when last bootstrap response received" : function(test) {340			var _this = this;341			var msg = {342				uri : 'p2p:graviti/peers',343				method : 'POST',344				content : {345					id : 'ABCDEF1234ABCDEF1234ABCDEF1234ABCDEF1234',346					leafset : this.leafsetContent,347					routing_table : this.routingTableContent,348					last_bootstrap_hop : true349				}350			};351			this.bootstrap.bootstrapping = true;352			this.bootstrap.start('mybootstrap', sinon.stub());353			this.bootstrap._handleReceivedGravitiMessage(msg, this.msginfo);354	355			test.ok(this.sendHeartbeatToAddr.callCount === 4);356			test.ok(this.sendHeartbeatToAddr.calledWith ('1.1.1.1', '1111', {357				leafset : this.leafset.compressedLeafset()358			}));359			test.ok(this.sendHeartbeatToAddr.calledWith ('2.2.2.2', '2222', {360				leafset : this.leafset.compressedLeafset(),361				routing_table : { '0' : this.routingTableRows['0']}362			}));363			test.ok(this.sendHeartbeatToAddr.calledWith ('5.5.5.5', '5555', {364				routing_table : { '0' : this.routingTableRows['0']}365			}));366			test.ok(this.sendHeartbeatToAddr.calledWith ('6.6.6.6', '6666', {...

1var assert = require('assert');2var sinon = require('sinon');3var langutil = require('langutil');4var leafset = require('pastry/leafset');5var bootstrap = require('pastry/bootstrap');6var heartbeater = require('pastry/heartbeater');7var transport = require('transport');8var pastry = require('pastry');9var mockutil = require('testability/mockutil');10var testCase = require('nodeunit').testCase;11var nodeId = 'ABCDEF';12module.exports = {13	"should create a pastry node and its deps" : testCase({14		setUp : function(done) {15			sinon.collection.stub(Function.prototype, 'bind', function() { return this; });16			17			this.transportStack = mockutil.stubProto(transport.TransportStack);18			this.createStack = sinon.collection.stub(transport, 'createStack').returns(this.transportStack);19			this.cbk = sinon.stub();20			done();21		},22		23		tearDown : function(done) {24			sinon.collection.restore();25			done();26		},27		28		"should create a good node object" : function(test) {29			var res = pastry.createNode(nodeId, 1111, '1.1.1.1', this.cbk);30			31			test.equal(res.port, 1111);32			test.equal(res.nodeId, nodeId);33			test.ok(this.createStack.calledWith(nodeId, 1111, '1.1.1.1'));34			test.ok(res.leafset !== undefined);35			test.ok(res.leafset.nodeId === nodeId);36			test.ok(res.transport === this.transportStack);37			test.ok(res.bootstrapper.routingtable.nodeId === nodeId);38			test.ok(res.bootstrapper !== undefined);39			test.ok(res.bootstrapper.pns !== undefined);40			test.ok(res.heartbeater !== undefined);			41			test.ok(res.transport.router !== undefined);42			test.done();43		}44	}),45	"stopping a pastry node" : testCase({46		setUp : function(done) {47			this.transport = mockutil.stubProto(transport.TransportStack);48			this.bootstrapper = mockutil.stubProto(bootstrap.Bootstrapper);49			this.heartbeater = mockutil.stubProto(heartbeater.Heartbeater);50			this.leafset = new leafset.Leafset();51			this.pastryNode = new pastry.PastryNode(this.transport, this.leafset, this.bootstrapper, this.heartbeater);52			done();53		},54		55		tearDown : function(done) {56			sinon.collection.restore();57			done();58		},59		60		"should stop things we started" : function(test) {61			this.bootstrapperStop = sinon.stub(this.bootstrapper, 'stop');62			this.heartbeaterStop = sinon.stub(this.heartbeater, 'stop');63			this.transportStop = sinon.stub(this.transport, 'stop');64			65			this.pastryNode.stop();66			67			test.ok(this.bootstrapperStop.called);68			test.ok(this.heartbeaterStop.called);69			test.ok(this.transportStop.called);70			test.done();71		}72	}),73	"staring and joining a pastry ring" : testCase({74		setUp : function(done) {75			this.transportStack = mockutil.stubProto(transport.TransportStack);76			sinon.stub(this.transportStack, 'start', function(cbk) {77				cbk();78			});79			this.transportStackOn = sinon.stub(this.transportStack, 'on');80			this.bootstrapper = mockutil.stubProto(bootstrap.Bootstrapper);81			this.heartbeater = mockutil.stubProto(heartbeater.Heartbeater);82			this.leafset = new leafset.Leafset();83			this.bootstrapStart = sinon.stub(this.bootstrapper, 'start', function(bootstraps, cbk) {84				cbk();85			});86			this.heartbeaterStart = sinon.stub(this.heartbeater, 'start');			87			this.callback = sinon.stub();88			89			this.pastryNode = new pastry.PastryNode(this.transportStack, this.leafset, this.bootstrapper, this.heartbeater);90			done();91		},92		93		tearDown : function(done) {94			sinon.collection.restore();95			done();96		},97		98		"should start node when starting new ring" : function(test) {99			this.pastryNode.startRing(this.callback);100				101			test.ok(this.bootstrapStart.called);102			test.ok(this.heartbeaterStart.calledWith());103			test.ok(this.callback.called);104			test.done();105		},106		"should start node and initiate bootstrapping when joining an existing ring" : function(test) {107			this.pastryNode.joinRing('127.0.0.1:4567', this.callback);108			109			test.ok(this.bootstrapStart.calledWith('127.0.0.1:4567'));110			test.ok(this.heartbeaterStart.calledWith());111			test.ok(this.callback.called);112			test.done();113		},114		115		"should re-emit peer arrived event for node joining the ring, when this node has started a new ring" : function(test) {116			this.pastryNode.startRing(this.callback);117			this.pastryNode.on('peer-arrived', this.callback);118			119			this.leafset.emit('peer-arrived', 'ABCDEF');120			121			test.ok(this.callback.calledWith('ABCDEF'));122			test.done();123		},124		125		"should re-emit peer departed event for node leaving the ring, when this node has started a new ring" : function(test) {126			this.pastryNode.startRing(this.callback);127			this.pastryNode.on('peer-departed', this.callback);128			this.leafset.emit('peer-departed', 'ABCDEF');129			130			test.ok(this.callback.calledWith('ABCDEF'));131			test.done();132		},133		134		"should re-emit peer arrived event for node joining the ring, when this node has joined an existing ring" : function(test) {135			this.pastryNode.joinRing(undefined, this.callback);136			this.pastryNode.on('peer-arrived', this.callback);137			138			this.leafset.emit('peer-arrived', 'ABCDEF');139			140			test.ok(this.callback.calledWith('ABCDEF'));141			test.done();142		},143		144		"should re-emit app message forwarding events" : function(test) {145			var forwardingHandler = this.transportStackOn.args[0][1];146			var msg = 'msg';147			var msginfo = 'msginfo';148			this.pastryNode.on('app-message-forwarding', this.callback);149			150			forwardingHandler(msg, msginfo);151			152			test.strictEqual(this.transportStackOn.args[0][0], 'app-message-forwarding');153			test.ok(this.callback.calledWith(msg, msginfo));154			test.done();155		},156		157		"should re-emit app message received events" : function(test) {158			var receivedHandler = this.transportStackOn.args[1][1];159			var msg = 'msg';160			var msginfo = 'msginfo';161			this.pastryNode.on('app-message-received', this.callback);162			receivedHandler(msg, msginfo);163			test.strictEqual(this.transportStackOn.args[1][0], 'app-message-received');164			test.ok(this.callback.calledWith(msg, msginfo));165			test.done();166		}167	}),168	169	"sending messages" : testCase({170		setUp : function(done) {171			this.transport = mockutil.stubProto(transport.TransportStack);172			this.leafset = new leafset.Leafset();173			this.pastryNode = new pastry.PastryNode(this.transport, this.leafset);174			done();175		},176		177		"send a messages" : function(test) {178			var transportSend = sinon.stub(this.transport, 'send');179			180			this.pastryNode.send('uri', 'content', 'headers');181			182			test.ok(transportSend.calledWith('uri', 'content', 'headers'));183			test.done();184		},185		186		"reply to a messages" : function(test) {187			var transportSendToId = sinon.stub(this.transport, 'sendToId');188			189			this.pastryNode.reply( {source_id : 'source_id'}, 'uri', 'content', 'headers');190			191			test.ok(transportSendToId.calledWith('uri', 'content', 'headers', 'source_id'));192			test.done();193		}194	})...

...157  this.bootstrap.ignoreUnexpectedShutdown = true;158  try {159    await wrapped();160    await this.adb.restart();161    await this.bootstrap.start(this.opts.appPackage, this.opts.disableAndroidWatchers, this.opts.acceptSslCerts);162  } finally {163    this.bootstrap.ignoreUnexpectedShutdown = false;164  }165};166Object.assign(extensions, commands, helpers);167export { commands, helpers };...