How to use createSocket method in wpt

Best JavaScript code snippet using wpt

feedback.js

Source:feedback.js Github

copy

Full Screen

...212 removeSocketStub();213 });214 it("loads credentials", function(done) {215 var feedback = Feedback({ pfx: "myCredentials.pfx" });216 feedback.createSocket().finally(function() {217 expect(feedback.loadCredentials).to.have.been.calledOnce;218 done();219 });220 });221 describe("with valid credentials", function() {222 it("resolves", function() {223 var feedback = Feedback({224 cert: "myCert.pem",225 key: "myKey.pem"226 });227 return expect(feedback.createSocket()).to.be.fulfilled;228 });229 describe("the call to create socket", function() {230 var createSocket;231 it("passes PFX data", function() {232 createSocket = Feedback({233 pfx: "myCredentials.pfx",234 passphrase: "apntest"235 }).createSocket();236 return createSocket.then(function() {237 var socketOptions = socketStub.args[0][1];238 expect(socketOptions.pfx).to.equal("pfxData");239 });240 });241 it("passes the passphrase", function() {242 createSocket = Feedback({243 passphrase: "apntest",244 cert: "myCert.pem",245 key: "myKey.pem"246 }).createSocket();247 return createSocket.then(function() {248 var socketOptions = socketStub.args[0][1];249 expect(socketOptions.passphrase).to.equal("apntest");250 });251 });252 it("passes the cert", function() {253 createSocket = Feedback({254 cert: "myCert.pem",255 key: "myKey.pem"256 }).createSocket();257 return createSocket.then(function() {258 var socketOptions = socketStub.args[0][1];259 expect(socketOptions.cert).to.equal("certData");260 });261 });262 it("passes the key", function() {263 createSocket = Feedback({264 cert: "test/credentials/support/cert.pem",265 key: "test/credentials/support/key.pem"266 }).createSocket();267 return createSocket.then(function() {268 var socketOptions = socketStub.args[0][1];269 expect(socketOptions.key).to.equal("keyData");270 });271 });272 it("passes the ca certificates", function() {273 createSocket = Feedback({274 cert: "test/credentials/support/cert.pem",275 key: "test/credentials/support/key.pem",276 ca: [ "test/credentials/support/issuerCert.pem" ]277 }).createSocket();278 return createSocket.then(function() {279 var socketOptions = socketStub.args[0][1];280 expect(socketOptions.ca[0]).to.equal("caData1");281 });282 });283 });284 });285 describe("intialization failure", function() {286 it("is rejected", function() {287 var feedback = Feedback({ pfx: "a-non-existant-file-which-really-shouldnt-exist.pfx" });288 feedback.on("error", function() {});289 feedback.loadCredentials.returns(Q.reject(new Error("loadCredentials failed")));290 return expect(feedback.createSocket()).to.be.rejectedWith("loadCredentials failed");291 });292 });293 });294 describe("cancel", function() {295 it("should clear interval after cancel", function() {296 var feedback = new Feedback();297 feedback.interval = 1;298 feedback.cancel();299 expect(feedback.interval).to.be.undefined;300 });301 });...

Full Screen

Full Screen

dgram_test.js

Source:dgram_test.js Github

copy

Full Screen

...15}16describe('dgram', () => {17 it('create/close', () => {18 var t = false;19 const s = dgram.createSocket('udp4');20 s.close(() => {21 t = true;22 });23 coroutine.sleep(100);24 assert.isTrue(t);25 });26 it('throw close on closed socket', () => {27 const s = dgram.createSocket('udp4');28 s.close();29 assert.throws(() => {30 s.close();31 });32 });33 it('bind', () => {34 const s = dgram.createSocket('udp4');35 s.bind(base_port + 1000);36 const s1 = dgram.createSocket('udp4');37 assert.throws(() => {38 s1.bind(base_port + 1000);39 });40 s.close();41 s1.close();42 });43 it('throw bind on bound socket', () => {44 const s = dgram.createSocket('udp4');45 s.bind(base_port + 1001);46 assert.throws(() => {47 s.bind(base_port + 1002);48 });49 s.close();50 });51 it('setRecvBufferSize', () => {52 const s = dgram.createSocket('udp4');53 s.bind(0);54 s.setRecvBufferSize(5120);55 var sz = s.getRecvBufferSize();56 s.setRecvBufferSize(1024);57 assert.notEqual(s.getRecvBufferSize(), sz);58 sz = s.getRecvBufferSize();59 s.setRecvBufferSize(4096);60 assert.notEqual(s.getRecvBufferSize(), sz);61 s.close();62 });63 it('setSendBufferSize', () => {64 const s = dgram.createSocket('udp4');65 s.bind(0);66 s.setSendBufferSize(5120);67 var sz = s.getSendBufferSize();68 s.setSendBufferSize(1024);69 assert.notEqual(s.getSendBufferSize(), sz);70 sz = s.getSendBufferSize();71 s.setSendBufferSize(4096);72 assert.notEqual(s.getSendBufferSize(), sz);73 s.close();74 });75 it('option', () => {76 const s = dgram.createSocket('udp4');77 s.bind(0);78 var recv_size = s.getRecvBufferSize();79 var send_size = s.getSendBufferSize();80 s.close();81 const socket = dgram.createSocket({82 type: 'udp4',83 recvBufferSize: 1234,84 sendBufferSize: 123485 });86 socket.bind(0);87 assert.notEqual(socket.getRecvBufferSize(), recv_size);88 assert.notEqual(socket.getSendBufferSize(), send_size);89 socket.close();90 });91 it('address', done => {92 const socket = dgram.createSocket('udp4');93 socket.on('listening', () => {94 try {95 const address = socket.address();96 assert.strictEqual(address.address, "127.0.0.1");97 assert.strictEqual(typeof address.port, 'number');98 assert.ok(address.port > 0);99 assert.strictEqual(address.family, 'IPv4');100 done();101 } catch (e) {102 done(e);103 } finally {104 socket.close();105 }106 });107 socket.bind(0, "127.0.0.1");108 });109 describe("send/recv", () => {110 function test_message(name, value, port) {111 it(`send ${name}`, done => {112 var t = false;113 const s = dgram.createSocket('udp4');114 s.on('message', (msg, addr) => {115 s.off('message');116 s.on('message', (msg, addr) => {117 c.close();118 s.close();119 done();120 });121 assert.equal(msg.toString(), value);122 s.send(msg, addr.port, addr.address);123 });124 s.bind(base_port + port);125 const c = dgram.createSocket('udp4');126 c.on('message', (msg, addr) => {127 assert.equal(msg.toString(), value);128 c.send(msg, addr.port, addr.address);129 });130 c.send(value, base_port + port);131 });132 }133 test_message('message', "123456", 1002);134 test_message('empty message', "", 1003);135 test_message('big message', new Buffer(4000).hex(), 1004);136 });137 it("broadcast", () => {138 var t = false;139 const s = dgram.createSocket('udp4');140 s.on('message', (msg, addr) => {141 assert.equal(msg.toString(), '123456');142 t = true;143 });144 s.bind(base_port + 1006);145 const c = dgram.createSocket('udp4');146 assert.throws(() => {147 c.send('123456', base_port + 1006, "255.255.255.255");148 });149 c.setBroadcast(true);150 c.send('123456', base_port + 1006, "255.255.255.255");151 coroutine.sleep(100);152 c.close();153 s.close();154 assert.isTrue(t);155 });156 if (has_ipv6)157 describe("ipv6", () => {158 it('ipv6 address', done => {159 const socket = dgram.createSocket('udp6');160 socket.on('listening', () => {161 try {162 const address = socket.address();163 assert.strictEqual(address.address, "::1");164 assert.strictEqual(typeof address.port, 'number');165 assert.ok(address.port > 0);166 assert.strictEqual(address.family, 'IPv6');167 done();168 } catch (e) {169 done(e);170 } finally {171 socket.close();172 }173 });174 socket.bind(0, "::1");175 });176 it('send/message ipv6', done => {177 var t = false;178 const s = dgram.createSocket({179 type: 'udp6',180 ipv6Only: true181 });182 s.on('message', (msg, addr) => {183 s.off('message');184 s.on('message', (msg, addr) => {185 c.close();186 s.close();187 done();188 });189 assert.equal(msg.toString(), "0123456");190 s.send(msg, addr.port, addr.address);191 });192 s.bind(base_port + 1005);193 const c = dgram.createSocket('udp6');194 c.on('message', (msg, addr) => {195 assert.equal(msg.toString(), "0123456");196 c.send(msg, addr.port, addr.address);197 });198 c.send("0123456", base_port + 1005);199 });200 });201 describe("gc", () => {202 it("gc", () => {203 test_util.gc();204 var n = test_util.countObject("DgramSocket");205 var s = dgram.createSocket('udp4');206 s.bind(0);207 s.close();208 s = undefined;209 test_util.gc();210 assert.equal(n, test_util.countObject("DgramSocket"));211 });212 it("not keep unclosed socket in gc", () => {213 test_util.gc();214 var n = test_util.countObject("DgramSocket");215 var s = dgram.createSocket('udp4');216 s = undefined;217 test_util.gc();218 assert.equal(n, test_util.countObject("DgramSocket"));219 });220 it("hold bind socket in gc", () => {221 test_util.gc();222 var c = dgram.createSocket('udp4');223 var n = test_util.countObject("DgramSocket");224 var s = dgram.createSocket('udp4');225 s.on('message', function (msg) {226 this.close();227 })228 s.bind(base_port + 1007);229 s = undefined;230 test_util.gc();231 assert.equal(n + 1, test_util.countObject("DgramSocket"));232 c.send('', base_port + 1007);233 coroutine.sleep(100);234 test_util.gc();235 assert.equal(n, test_util.countObject("DgramSocket"));236 c.close();237 });238 });239 it('FIX: crash in send', () => {240 const c = dgram.createSocket('udp4');241 c.send('123456', 1, 2, base_port + 1008);242 c.close();243 });244});...

Full Screen

Full Screen

agent.js

Source:agent.js Github

copy

Full Screen

...68 } while (!createSocket)69 if (!createSocket) {70 createSocket = http.Agent.prototype.createSocket71 }72 assert(createSocket, '.createSocket() method not found')73 return createSocket74}75proto._connect = function _connect (options, callback) {76 var self = this77 var state = this._spdyState78 var protocols = state.options.protocols || [79 'h2',80 'spdy/3.1', 'spdy/3', 'spdy/2',81 'http/1.1', 'http/1.0'82 ]83 // TODO(indutny): reconnect automatically?84 var socket = this.createConnection(Object.assign({85 NPNProtocols: protocols,86 ALPNProtocols: protocols,87 servername: options.servername || options.host88 }, options))89 state.socket = socket90 socket.setNoDelay(true)91 function onError (err) {92 return callback(err)93 }94 socket.on('error', onError)95 socket.on(state.secure ? 'secureConnect' : 'connect', function () {96 socket.removeListener('error', onError)97 var protocol98 if (state.secure) {99 protocol = socket.npnProtocol ||100 socket.alpnProtocol ||101 state.options.protocol102 } else {103 protocol = state.options.protocol104 }105 // HTTP server - kill socket and switch to the fallback mode106 if (!protocol || protocol === 'http/1.1' || protocol === 'http/1.0') {107 debug('activating fallback')108 socket.destroy()109 state.fallback = true110 return111 }112 debug('connected protocol=%j', protocol)113 var connection = transport.connection.create(socket, Object.assign({114 protocol: /spdy/.test(protocol) ? 'spdy' : 'http2',115 isServer: false116 }, state.options.connection || {}))117 // Pass connection level errors are passed to the agent.118 connection.on('error', function (err) {119 self.emit('error', err)120 })121 // Set version when we are certain122 if (protocol === 'h2') {123 connection.start(4)124 } else if (protocol === 'spdy/3.1') {125 connection.start(3.1)126 } else if (protocol === 'spdy/3') {127 connection.start(3)128 } else if (protocol === 'spdy/2') {129 connection.start(2)130 } else {131 socket.destroy()132 callback(new Error('Unexpected protocol: ' + protocol))133 return134 }135 if (state.options['x-forwarded-for'] !== undefined) {136 connection.sendXForwardedFor(state.options['x-forwarded-for'])137 }138 callback(null, connection)139 })140}141proto._createSocket = function _createSocket (req, options, callback) {142 var state = this._spdyState143 if (state.fallback) { return state.createSocket(req, options) }144 var handle = spdy.handle.create(null, null, state.socket)145 var socketOptions = {146 handle: handle,147 allowHalfOpen: true148 }149 var socket150 if (state.secure) {151 socket = new spdy.Socket(state.socket, socketOptions)152 } else {153 socket = new net.Socket(socketOptions)154 }155 handle.assignSocket(socket)156 handle.assignClientRequest(req)157 // Create stream only once `req.end()` is called158 var self = this159 handle.once('needStream', function () {160 if (state.connection === null) {161 self.once('_connect', function () {162 handle.setStream(self._createStream(req, handle))163 })164 } else {165 handle.setStream(self._createStream(req, handle))166 }167 })168 // Yes, it is in reverse169 req.on('response', function (res) {170 handle.assignRequest(res)171 })172 handle.assignResponse(req)173 // Handle PUSH174 req.addListener('newListener', spdy.request.onNewListener)175 // For v0.8176 socket.readable = true177 socket.writable = true178 if (callback) {179 return callback(null, socket)180 }181 return socket182}183if (mode === 'modern' || mode === 'normal') {184 proto.createSocket = proto._createSocket185} else {186 proto.createSocket = function createSocket (name, host, port, addr, req) {187 var state = this._spdyState188 if (state.fallback) {189 return state.createSocket(name, host, port, addr, req)190 }191 return this._createSocket(req, {192 host: host,193 port: port194 })195 }196}197proto._createStream = function _createStream (req, handle) {198 var state = this._spdyState199 var self = this200 return state.connection.reserveStream({201 method: req.method,202 path: req.path,203 headers: req._headers,204 host: state.host205 }, function (err, stream) {...

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1var wpt = require('wpt');2var wpt = new WebPageTest('www.webpagetest.org');3 if (err) {4 console.log(err);5 } else {6 console.log(data);7 }8});

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1var wpt = require('webpagetest');2var options = {host: 'www.webpagetest.org', port: 80, timeout: 30000};3var wpt = new WebPageTest(options);4wpt.createSocket(function(err, socket) {5 if (err) {6 console.log(err);7 } else {8 console.log('socket created');9 }10});11var wpt = require('webpagetest');12var options = {host: 'www.webpagetest.org', port: 80, timeout: 30000};13var wpt = new WebPageTest(options);14wpt.createSocket(function(err, socket) {15 if (err) {16 console.log(err);17 } else {18 console.log('socket created');19 }20});21var wpt = require('webpagetest');22var options = {host: 'www.webpagetest.org', port: 80, timeout: 30000};23var wpt = new WebPageTest(options);24wpt.createSocket(function(err, socket) {25 if (err) {26 console.log(err);27 } else {28 console.log('socket created');29 }30});31var wpt = require('webpagetest');32var options = {host: 'www.webpagetest.org', port: 80, timeout: 30000};33var wpt = new WebPageTest(options);34wpt.createSocket(function(err, socket) {35 if (err) {36 console.log(err);37 } else {38 console.log('socket created');39 }40});41var wpt = require('webpagetest');42var options = {host: 'www.webpagetest.org', port: 80, timeout: 30000};43var wpt = new WebPageTest(options);44wpt.createSocket(function(err, socket) {45 if (err) {46 console.log(err);47 } else {48 console.log('socket created');49 }50});

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1var wpt = require('wpt');2var wpt = new wpt('API_KEY');3var options = {4};5wpt.createTest(options, function(err, data) {6 if (err) {7 console.log('Error: ' + err);8 } else {9 console.log('Test Created: ' + JSON.stringify(data));10 }11});12var wpt = require('wpt');13var wpt = new wpt('API_KEY');14var options = {15};16wpt.createTest(options, function(err, data) {17 if (err) {18 console.log('Error: ' + err);19 } else {20 console.log('Test Created: ' + JSON.stringify(data));21 }22});23var wpt = require('wpt');24var wpt = new wpt('API_KEY');25wpt.getTestStatus('141008_7F_5E8', function(err, data) {26 if (err) {27 console.log('Error: ' + err);28 } else {29 console.log('Test Status: ' + JSON.stringify(data));30 }31});32var wpt = require('wpt');33var wpt = new wpt('API_KEY');34wpt.getTestResults('141008_7F_5E8', function(err, data) {35 if (err) {36 console.log('Error: ' + err);37 } else {38 console.log('Test Results: ' + JSON.stringify(data));39 }40});41var wpt = require('

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1var wpt = require('wpt');2var socket = wpt.createSocket();3socket.runTest('www.google.com', { location: 'Dulles:Chrome' }, function (err, data) {4 if (err) {5 console.log('error occured ' + err);6 }7 console.log(data);8});9socket.disconnect();10var wpt = require('wpt');11wpt.runTest('www.google.com', { location: 'Dulles:Chrome' }, function (err, data) {12 if (err) {13 console.log('error occured ' + err);14 }15 console.log(data);16});17var wpt = require('wpt');18wpt.runTest('www.google.com', { location: 'Dulles:Chrome' })19 .then(function (data) {20 console.log(data);21 })22 .catch(function (err) {23 console.log('error occured ' + err);24 });25var wpt = require('wpt');26var socket = wpt.createSocket();27socket.getTestResults('150929_6B_1A1', function (err, data) {28 if (err) {29 console.log('error occured ' + err);30 }31 console.log(data);32});33socket.disconnect();

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1var wpt = require('wpt');2var socket = wpt.createSocket('localhost', 5000, function() {3 console.log('connected');4});5var wpt = require('wpt');6var socket = wpt.createSocket('localhost', 5000, function() {7 console.log('connected');8});9socket.on('message', function(message) {10 console.log('message received: ' + message);11});12socket.on('close', function() {13 console.log('connection closed');14});15socket.send('Hello World');16socket.close();17var wpt = require('wpt');18var socket = wpt.createSocket('localhost', 5000, function() {19 console.log('connected');20});21socket.on('message', function(message) {22 console.log('message received: ' + message);23});24socket.on('close', function() {25 console.log('connection closed');26});27socket.send('Hello World');28socket.close();29var wpt = require('wpt');30var socket = wpt.createSocket('localhost', 5000, function() {31 console.log('connected');32});33socket.on('message', function(message) {34 console.log('message received: ' + message);35});36socket.on('close', function() {37 console.log('connection closed');38});39socket.send('Hello World');40socket.close();41var wpt = require('wpt');42var socket = wpt.createSocket('localhost', 5000, function() {43 console.log('connected');44});45socket.on('message', function(message) {46 console.log('message received: ' + message);47});48socket.on('close', function() {49 console.log('connection closed');50});51socket.send('Hello World');52socket.close();53var wpt = require('wpt');54var socket = wpt.createSocket('localhost', 5000, function() {55 console.log('connected');56});57socket.on('message', function(message) {58 console.log('message received: ' + message);59});60socket.on('close', function() {61 console.log('connection closed');62});63socket.send('Hello World');64socket.close();65var wpt = require('wpt');66var socket = wpt.createSocket('localhost', 5000, function() {67 console.log('connected');68});

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1var wpt = require('wpt');2var socket = wpt.createSocket();3socket.on('connect', function() {4 console.log('Connected to WebPageTest server');5});6socket.on('data', function(data) {7 console.log('Data received from server: ' + data);8});9socket.on('error', function(err) {10 console.log('Error: ' + err);11});12socket.on('close', function() {13 console.log('Connection closed');14});15socket.on('end', function() {16 console.log('Connection ended');17});18socket.on('timeout', function() {19 console.log('Connection timed out');20});21socket.on('drain', function() {22 console.log('Data sent to server');23});24socket.on('lookup', function(err, address, family, host) {25 console.log('Lookup event occurred');26});27socket.on('ready', function() {28 console.log('Socket is ready to send data');29});30socket.on('connect', function() {31 console.log('Socket is connected');32});33socket.on('secureConnect', function() {34 console.log('Socket is connected via SSL/TLS');35});36socket.on('upgrade', function(request, socket, head) {37 console.log('Socket is upgraded');38});39socket.on('continue', function() {40 console.log('Continue event');41});42socket.on('checkContinue', function(request, response) {43 console.log('Check continue event');44});45socket.on('checkExpectation', function(request, response) {46 console.log('Check expectation event');47});48socket.on('clientError', function(exception, socket) {49 console.log('Client error event');50});51socket.on('request', function(request, response) {52 console.log('Request event');53});54socket.on('upgrade', function(request, socket, head) {55 console.log('Upgrade event');56});

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1var wpt = require('webpagetest');2var wpt = new WebPageTest('www.webpagetest.org');3wpt.createSocket(80, 'www.webpagetest.org', function(err, socket) {4 if (err) {5 console.log('Error creating socket: ' + err);6 } else {7 console.log('Socket created');8 }9});10var wpt = require('webpagetest');11var wpt = new WebPageTest('www.webpagetest.org');12wpt.createSocket(80, 'www.webpagetest.org', function(err, socket) {13 if (err) {14 console.log('Error creating socket: ' + err);15 } else {16 console.log('Socket created');17 }18});19var wpt = require('webpagetest');20var wpt = new WebPageTest('www.webpagetest.org');21wpt.createSocket(80, 'www.webpagetest.org', function(err, socket) {22 if (err) {23 console.log('Error creating socket: ' + err);24 } else {25 console.log('Socket created');26 }27});28var wpt = require('webpagetest');29var wpt = new WebPageTest('www.webpagetest.org');30wpt.createSocket(80, 'www.webpagetest.org', function(err, socket) {31 if (err) {32 console.log('Error creating socket: ' + err);33 } else {34 console.log('Socket created');35 }36});37var wpt = require('webpagetest');38var wpt = new WebPageTest('www.webpagetest.org');39wpt.createSocket(80, 'www.webpagetest.org', function(err, socket) {40 if (err) {

Full Screen

Full Screen

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:

YouTube

You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.

Run wpt automation tests on LambdaTest cloud grid

Perform automation testing on 3000+ real desktop and mobile devices online.

... View sample repo... View DocumentationSign up Free
›
_

Try LambdaTest Now !!

Get 100 minutes of automation test minutes FREE!!

...
Sign up with GoogleSign up with Email
Next-Gen App & Browser Testing Cloud

Was this article helpful?

Helpful

NotHelpful