KaneAI - World’s First E2E Software Testing Agent.Signup for Private Beta Join TestMu Conference

How to use onClientConnect method in Best

Best JavaScript code snippet using best

player-connections-tests.js

Source:player-connections-tests.js

...46    getByDevice.restore();47  });48  describe('when a player connects', function () {49    beforeEach(done => {50      onClientConnect(undefined, player1, save1)51        .then(() => done())52        .catch(() => done());53    });54    it('should send an error if no player found');55    it('should send an error if more than one player per device');56    it('should send the device number', function () {57      expect(player1.emit.secondCall.args).toEqual(['deviceNumber', 1]);58    });59    it('should add a new player connection', function () {60      expect(connectedCount(save1.id)).toEqual(1);61    });62    it('should not emit a OnNewPlayer connection', function () {63        expect(fakeOn.newPlayer.called).toEqual(true);64        expect(fakeOn.newPlayer.firstCall.args).toEqual([save1, 1]);65      });66    it('should publish the players and their status in the game', function () {67      expect(fakeOn.playerGroupChange.firstCall.args).toEqual([[{ number: 1, status: 'online', playerId: 1, devices: [1], onSameSubnet: true}, {number: 2, status: 'not-joined', devices: [], onSameSubnet: true}, {number: 3, status: 'not-joined', devices: [], onSameSubnet: true}], 1]);68    });69    it('should partion players into games', function (done) {70      onClientConnect(undefined, player2, save1)71        .then(() => {72          expect(connectedCount(save1.id)).toEqual(2);73        })74        .then(() => onClientConnect(undefined, player1, save2) )75        .then(() => {76          expect(connectedCount(save2.id)).toEqual(1);77        })78        .then(() => done() )79        .catch(() => done() );80    });81    it('should start the update loop', function () {82      expect(startStatePusher.called).toEqual(true);83    });84    describe('when the same player connects again on a different client', function () {85      beforeEach(function (done) {86        fakeOn.playerGroupChange.reset();87        player1Device2.emit.reset();88        onClientConnect(undefined, player1Device2, save1)89          .then(() => done())90          .catch(() => done());91      });92      it('should not add a new player connection', function () {93        expect(connectedCount(save1.id)).toEqual(1);94      });95      it('should send a new device number', function () {96        expect(player1Device2.emit.secondCall.args).toEqual(['deviceNumber', 2]);97      });98      it('should indicate the player has two devices', function () {99        expect(fakeOn.playerGroupChange.firstCall.args[0][0].devices).toEqual([1, 11]);100      });101      it.skip('should determine if the clients are on the same subnet');102      it('should publish the players and their status in the game', function () {103        var callArgs = fakeOn.playerGroupChange.firstCall.args;104        expect(callArgs[0][0].number).toEqual(1);105        expect(callArgs[0][0].status).toEqual('online');106        expect(callArgs[0][0].playerId).toEqual(1);107        expect(callArgs[0][1]).toEqual(108          {number: 2, status: 'not-joined', devices: [], onSameSubnet: true}109        );110        expect(callArgs[0][2]).toEqual(111          {number: 3, status: 'not-joined', devices: [], onSameSubnet: true}112        );113      });114      describe('when the player disconnects their first device and then then tries to reconnect it', function () {115        beforeEach(function (done) {116          onClientDisconnect(undefined, player1, save1)117            .then(() => {118              fakeOn.playerGroupChange.reset();119              player1.emit.reset();120            })121            .then(() => onClientConnect(undefined, player1, save1))122            .then(() => done())123            .catch(() => done());124        });125        it('should not reuse the first connections device number', function () {126          expect(player1.emit.secondCall.args).toEqual(['deviceNumber', 3]);127        });128      });129    });130    describe('when a player disconnects', function () {131      beforeEach(function (done) {132        fakeOn.playerGroupChange.reset();133        onClientDisconnect(undefined, player1, save1)134          .then(() => done());135      });136      it('should publish the players and their status in the game', function () {137        expect(fakeOn.playerGroupChange.firstCall.args).toEqual([[{ number: 1, status: 'offline', playerId: 1, devices: [], onSameSubnet: true}, {number: 2, status: 'not-joined', devices: [], onSameSubnet: true}, {number: 3, status: 'not-joined', devices: [], onSameSubnet: true}], 1]);138      });139      it('should stop pushing state to that device', () => {140        expect(stopStatePusher.firstCall.args).toEqual([save1, 1, 1]);141      })142      it('should set the device to spare');143    });144    describe('when a player disconnects one of their devices', function () {145      beforeEach(function (done) {146        onClientConnect(undefined, player1Device2, save1)147          .then(() => {148            fakeOn.playerGroupChange.reset();149            return onClientDisconnect(undefined, player1, save1);150          })151          .then(() => done());152      });153      it('should not mark players as "offline" if they have at least one device connected', function () {154        expect(fakeOn.playerGroupChange.firstCall.args[0][0].number).toEqual(1);155        expect(fakeOn.playerGroupChange.firstCall.args[0][0].status).toEqual('online');156        expect(fakeOn.playerGroupChange.firstCall.args[0][0].playerId).toEqual(1);157        expect(fakeOn.playerGroupChange.firstCall.args[0][0].devices).toEqual([11]);158        expect(fakeOn.playerGroupChange.firstCall.args[0][1]).toEqual(159          {number: 2, status: 'not-joined', devices: [], onSameSubnet: true}160        );161        expect(fakeOn.playerGroupChange.firstCall.args[0][2]).toEqual(162          {number: 3, status: 'not-joined', devices: [], onSameSubnet: true}163        );164      });165    });166    describe('when the same player reconnects after disconnecting', function () {167      beforeEach(function (done) {168        fakeOn.newPlayer.reset();169        onClientDisconnect(undefined, player1, save1)170          .then(() => fakeOn.playerGroupChange.reset())171          .then(() => onClientConnect(undefined, player1, save1))172          .then(() => done())173          .catch(() => done());174      });175      it('should not add a new player connection', function () {176        expect(connectedCount(save1.id)).toEqual(1);177      });178      it('should not emit a OnNewPlayer connection', function () {179        expect(fakeOn.newPlayer.called).toEqual(false);180      });181      it('should publish the players and their status in the game', function () {182        expect(fakeOn.playerGroupChange.firstCall.args).toEqual([[183          { number: 1, status: 'online', playerId: 1, devices: [1], onSameSubnet: true},184          {number: 2, status: 'not-joined', devices: [], onSameSubnet: true},185          {number: 3, status: 'not-joined', devices: [], onSameSubnet: true}186        ], 1]);187      });188    });189    describe('when the maxPlayers is exceeded', function () {190      beforeEach(function (done) {191        onClientConnect(undefined, player1, save1)192          .then(() => getByDevice.returns(Bluebird.resolve([{id: 2}])))193          .then(() => onClientConnect(undefined, player2, save1))194          .then(() => getByDevice.returns(Bluebird.resolve([{id: 3}])))195          .then(() => onClientConnect(undefined, player3, save1))196          .then(() => done())197          .catch(() => done() );198      });199      it('should not add a new player connection', function () {200        expect(connectedCount(save1.id)).toEqual(3);201      });202    });203  });204  describe('when a second player connects', function () {205    beforeEach(function (done) {206      getByDevice.returns(Bluebird.resolve([{id: 1}]));207      onClientConnect(undefined, player1, save1)208        .then(() => fakeOn.playerGroupChange.reset())209        .then(() => getByDevice.returns(Bluebird.resolve([{id: 2}])))210        .then(() => onClientConnect(undefined, player2, save1))211        .then(() => done())212        .catch(() => done());213    });214    it('should publish the players and their status in the game', function () {215      expect(fakeOn.playerGroupChange.firstCall.args).toEqual([[{ number: 1, status: 'online', playerId: 1, devices: [1], onSameSubnet: true}, {number: 2, status: 'online', playerId: 2, devices: [2], onSameSubnet: true}, {number: 3, status: 'not-joined', devices: [], onSameSubnet: true}], 1]);216    });217  });218  describe('when the number of connected players gets above the minimum', function () {219    it('should set waitingForPlayers to false', function (done) {220      onClientConnect(undefined, player1, save1)221        .then(result => {222          expect(result).toEqual(['ensemble.waitingForPlayers', true]);223        })224        .then(() => onClientConnect(undefined, player2, save1) )225        .then(result => {226          expect(result).toEqual(['ensemble.waitingForPlayers', false]);227        })228        .then(() => done())229        .catch(() => done() );230    });231  });232  describe('when the number of connected players falls below the minimum', function () {233    it('should set waitingForPlayers to true', function (done) {234      onClientConnect(undefined, player1, save1)235        .then(result => {236          expect(result).toEqual(['ensemble.waitingForPlayers', true]);237        })238        .then(() => onClientConnect(undefined, player2, save1) )239        .then(result => {240          expect(result).toEqual(['ensemble.waitingForPlayers', false]);241        })242        .then(() => onClientDisconnect(undefined, player2, save1) )243        .then(result => {244          expect(result).toEqual(['ensemble.waitingForPlayers', true]);245        })246        .then(() => done())247        .catch(() => done());248    });249  });250  describe('connectedCount', function () {251    it('should count the number of online player connections', done => {252      onClientConnect(undefined, player1, save1)253        .then(() => onClientConnect(undefined, player2, save1) )254        .then(() => expect(connectedCount(save1.id)).toEqual(2))255        .then(() => done() )256        .catch(() => done() );257    });258    it('should keep each games player count separate', done => {259      onClientConnect(undefined, player1, save1)260        .then(() => onClientConnect(undefined, player1, save2))261        .then(() => onClientConnect(undefined, player2, save2))262        .then(() => {263          expect(connectedCount(save1.id)).toEqual(1);264          expect(connectedCount(save2.id)).toEqual(2);265        })266        .then(() => done() )267        .catch(() => done() );268    });269  });...

brokerSpec.js

Source:brokerSpec.js

1// ## brokerSpec2// usage: $ DEBUG=brokerSpec mocha3const debug = require('debug')('mqtt-reqres-broker');4const assert = require('assert');5const MqttReqResBroker = require('../lib/mqtt-reqres-broker.js');6const mqtt = require('mqtt');7const serverOptions = {8  hostname: 'localhost',9  port: 999910};11const wsBroker = new MqttReqResBroker();12var mqttClientA, mqttClientB;13const clientAId = 'client-a', 14  clientBId = 'client-b';15const clientAChannelId = 'client-a-channel-id';16function pcatch (reason) {17  debug(reason);18  assert(!reason, reason);19}20function startServer (callback) {21  debug('startServer()');22  wsBroker.initialize(serverOptions, err => {23    if (err) {24      console.error(err.stack);25      callback(err);26    }27    else {28      29      wsBroker.start(null, err => {30        if (err) {31          console.error(err.stack);32        } 33        else {34          console.log(`broker running at http://${wsBroker.hostname}:${wsBroker.port}/`);35        }         36        callback(err);37      });38      39    }40  });41}42function connectClient (clientId) {43  return mqtt.connect({ 44      protocol: 'ws',45      host: serverOptions.hostname, 46      port: serverOptions.port,47      clientId: clientId || Math.random().toString(36).substr(2, 23)48    });49}50function onClientConnect (brokerClient) {51  assert.strictEqual(brokerClient.clientId, onClientConnect.mqttClient.clientId);52  setTimeout(() => {53    assert(onClientConnect.mqttClient.connected, 'mqtt client should be connected');54    onClientConnect.callbackFn();55  }, 100);56}57onClientConnect.configure = function (mqttClient, callbackFn) {58  onClientConnect.mqttClient = mqttClient;59  onClientConnect.callbackFn = callbackFn;60};61describe('broker', function () {62  before(done => {63    startServer(err => {64      wsBroker.mqtt.on('client', onClientConnect);65      done();66    });67  });68  after(done => {69    wsBroker.close(done);70  });71  describe('connecting mqtt clients to broker via websockets', () => {72    it('should connect to mqtt client A', done => {73      mqttClientA = connectClient(clientAId);74      onClientConnect.configure(mqttClientA, done);75    });76    it('should connect to mqtt client B', done => {77      mqttClientB = connectClient(clientBId);78      onClientConnect.configure(mqttClientB, done);79    });80  });81  describe('client subscriptions on topic "connect/&lt;device-id&gt;/+"', () => {82    it('should client A subscribe on topic "connect/' + clientAId + '/+"', done => {83      mqttClientA.subscribe(84        `connect/${clientAId}/+`, 85        {qos: 0}, 86        function (err, granted) {87          assert(!err);88          assert.strictEqual(granted[0].qos, 0);89          done();90        }91      );92    });93    it('should client B subscribe on topic "connect/' + clientBId + '/+"', done => {94      mqttClientA.subscribe(95        `connect/${clientBId}/+`, 96        {qos: 0}, 97        function (err, granted) {98          assert(!err);99          assert.strictEqual(granted[0].qos, 0);100          done();101        }102      );103    });104    it('should refuse to subscribe -t connect on invalid topics', done => {105      function promiseTest (topic) {106        return new Promise(function (resolve) {107          mqttClientA.subscribe(108            topic, 109            {qos: 0}, 110            function (err, granted) {111              assert(!err);112              assert(granted[0].qos > 2, 'should not have subscribed -t connect on topic ' + topic);113              resolve();114            }115          );116        });        117      }118      Promise.all(119        [120          // `connect/${clientBId}/+`, 121          `invalid/${clientBId}/+`, 122          `connect`, 123          `connect/`, 124          `connect//`, 125          `connect/+`, 126          `connect/#`, 127          `connect/${clientBId}/#`, 128          `connect/${clientBId}/`, 129          `connect/${clientBId}`, 130          `connect/${clientBId}/+/invalid`,131          `connect/${clientBId}/invalid/+`132        ].map(promiseTest)133      )134      .then(() => done())135      .catch(pcatch);136    });137  });138  describe('connecting client A to client B', () => {139    it('should subscribe -t message/' + clientBId + '/' + clientAChannelId + '/#  ', done => {140      /*141      open a message channel to enable client-a to send messages:142      143      subscribe -t message/&lt;client-b-id&gt;/&lt;client-a-channel-id&gt;/#  144      */145      mqttClientA.subscribe(146        `message/${clientBId}/${clientAChannelId}/#`, 147        {qos: 0}, 148        function (err, granted) {149          assert(!err);150          assert.strictEqual(granted[0].qos, 0);151          done();152        }153      );154    });155    it('should refuse to subscribe -t message on invalid topics', done => {156      function promiseTest (topic) {157        return new Promise(function (resolve) {158          mqttClientA.subscribe(159            topic, 160            {qos: 0}, 161            function (err, granted) {162              assert(!err);163              assert(granted[0].qos > 2, 'should not have subscribed -t message on topic ' + topic);164              resolve();165            }166          );167        });        168      }169      Promise.all(170        [171          // `message/${clientBId}/${clientAChannelId}/#`, 172          `invalid/${clientBId}/${clientAChannelId}/#`, 173          `message`, 174          `message/`, 175          `message//`, 176          `message//+`, 177          `message/#`, 178          `message/${clientBId}/#`, 179          `message/${clientBId}/${clientAChannelId}/+`,180          `message/${clientBId}/${clientAChannelId}/+/bar`,181          `message/${clientBId}/${clientAChannelId}/foo/bar`,182          `message/from-client-id/`, 183          `message/from-client-id`, 184          `message/from-client-id/+`,185          `message/from-client-id/invalid/+`186        ].map(promiseTest)187      )188      .then(() => done())189      .catch(pcatch);190    });191    it(`should publish -t connect/${clientBId}/${clientAId} -m ${clientAChannelId}`, done => {192      /*193      client-a publishes client-a-channel-id as message to client-b:194      195      publish -t connect/&lt;client-b-id&gt;/&lt;client-a-id&gt; -m &lt;client-a-channel-id&gt; 196      */197      mqttClientA.publish(198        // topic199        `connect/${clientBId}/${clientAId}`, 200        // message201        clientAChannelId,202        // options203        {qos: 0}, 204        // callback205        function (err) {206          assert(!err);207          done();208        }209      );210    });211  });212  describe('sending messages between clients', () => {213    /*214    sending messages215    publish -t message/&lt;from&gt;/&lt;to&gt;216    publish -t message/&lt;from-device-id&gt;/&lt;to-channel-id&gt;217    publish -t message/&lt;client-b-id&gt;/&lt;client-a-channel-id&gt;/foo -m '{packetId:123}' 218    */219    it('should enable client B to send messages to client A', done => {220      mqttClientA.on('message', function (topic, payload) {221        if (topic === `message/${clientBId}/${clientAChannelId}/foo`) {222          assert.strictEqual(payload.toString(), 'bar');  223          done();224        }225      });226      mqttClientB.publish(227        // topic228        `message/${clientBId}/${clientAChannelId}/foo`, 229        // message230        'bar',231        // options232        {qos: 0}233      );234    });235  });236  describe('unsubscription of clients', () => {237    it('should unsubscribe client A', done => {238      assert(mqttClientA.connected);239      mqttClientA.end(false, () => {240        241        assert(!mqttClientA.connected);242        243        mqttClientB.end(false, () => {244          done();245        });246      });247    });248  });...

BlokdotsSocketIOServer.js

Source:BlokdotsSocketIOServer.js

1import { Server } from "socket.io";2import WebSocket from "ws";3import { networkInterfaces } from "os";4import setupHttpServer from "./setupHttpServer";5export const BLOKDOTS_SOCKET_IO_SERVER_DEFAULT_PORT = 8777;6export const getBlokdotsSocketIOServerAddress = () => {7  const currentIP = Object.values(networkInterfaces())8    .flat()9    .find((i) => i.family === "IPv4" && !i.internal).address;10  return `http://${currentIP}:${BLOKDOTS_SOCKET_IO_SERVER_DEFAULT_PORT}`;11};12class BlokdotsSocketIOServer {13  constructor() {14    this.activeIntegrations = {};15    this.io = null;16  }17  // Init is a separate function, because the constructor can18  // not be async19  async init() {20    return new Promise((resolve) => {21      this.start();22      resolve();23    });24  }25  start() {26    const httpServer = setupHttpServer();27    this.io = new Server(httpServer, {28      wsEngine: WebSocket.Server,29      pingInterval: 5000,30      pingTimeout: 5000,31      allowEIO3: true, // support older websocket clients32      cors: {33        origin: "*",34        methods: ["GET", "POST"],35      },36    });37    httpServer.listen(BLOKDOTS_SOCKET_IO_SERVER_DEFAULT_PORT, "0.0.0.0");38    // Sockets can connect to the general namespace to get updates about39    // all available integrations40    this.io.on("connection", (socket) => {41      // Updates are emitted whenever something about an integration changes,42      // but they can also be explicitely requested43      socket.on("requestInfo", () => {44        this.emitInfo(socket);45      });46      this.emitInfo(socket);47    });48  }49  emitInfo(socket) {50    // If no specific socket requested it, we send it to all51    // sockets in the general namespace52    if (!socket) socket = this.io.sockets;53    socket.emit("info", {54      url: getBlokdotsSocketIOServerAddress(),55      integrations: Object.values(this.activeIntegrations).map((i) => ({56        id: i.id,57        url: i.url,58        connections: i.ioNamespace.sockets.size,59      })),60    });61  }62  stop(callback) {63    this.io.closeServer(callback);64  }65  registerIntegration({66    integrationName,67    handlers = [],68    onClientConnect,69    onClientDisconnect,70  }) {71    let integration = this.activeIntegrations[integrationName];72    // The namespace already exists73    if (integration) {74      // Add the new handlers to the list of handlers to register for new connections75      integration.handlers = integration.handlers.concat(handlers);76      onClientConnect && integration.onClientConnect.push(onClientConnect);77      onClientDisconnect &&78        integration.onClientDisconnect.push(onClientDisconnect);79      // Register the new handlers on the already existing connections80      for (let [, socket] of integration.ioNamespace.sockets) {81        handlers.forEach(({ eventName, callback }) => {82          socket.on(eventName, callback);83        });84      }85    } else {86      // Initialize the namespace for the first time87      this.activeIntegrations[integrationName] = {88        id: integrationName,89        url: `${getBlokdotsSocketIOServerAddress()}/${integrationName}`,90        handlers: [...handlers],91        ioNamespace: this.io.of("/" + integrationName),92        onClientConnect: onClientConnect ? [onClientConnect] : [],93        onClientDisconnect: onClientDisconnect ? [onClientDisconnect] : [],94      };95      integration = this.activeIntegrations[integrationName];96      // When a new socket connects to this namespace97      integration.ioNamespace.on("connection", (socket) => {98        // console.info("ð¹ Client connected to", integrationName);99        // We register all existing handlers to this new socket100        integration.handlers.forEach(({ eventName, callback }) => {101          socket.on(eventName, callback);102        });103        // We emit a message to all other sockets â¦104        integration.ioNamespace.emit("client-connect", {105          integration: integrationName,106          connections: integration.ioNamespace.sockets.size,107        });108        // â¦ as well as to the integration registerers109        integration.onClientConnect.forEach((h) => {110          h({111            integration: integrationName,112            connections: integration.ioNamespace.sockets.size,113          });114        });115        this.emitInfo();116        socket.on("disconnect", (reason) => {117          // We emit a message to all other sockets â¦118          integration.ioNamespace.emit("client-disconnect", {119            reason: reason,120            integration: integrationName,121            connections: integration.ioNamespace.sockets.size,122          });123          // â¦ as well as to the integration registerers124          integration.onClientDisconnect.forEach((h) => {125            h({126              reason: reason,127              integration: integrationName,128              connections: integration.ioNamespace.sockets.size,129            });130          });131          this.emitInfo();132        });133      });134      this.emitInfo();135    }136    return {137      ...integration,138      connections: integration.ioNamespace.sockets.size,139    };140  }141  unregisterIntegration({142    integrationName,143    handlers = [],144    onClientConnect,145    onClientDisconnect,146  }) {147    let integration = this.activeIntegrations[integrationName];148    if (!integration) {149      return;150    }151    // Remove the handlers from the list of handlers to register for new connections152    integration.handlers = integration.handlers.filter((h) =>153      handlers.some(154        (hU) => hU.eventName === h.eventName && hU.callback === h.callback155      )156    );157    integration.onClientConnect = integration.onClientConnect.filter(158      (h) => h !== onClientConnect159    );160    integration.onClientDisconnect = integration.onClientDisconnect.filter(161      (h) => h !== onClientDisconnect162    );163    // Remove the handlers from the existing connections164    for (let [, socket] of integration.ioNamespace.sockets) {165      handlers.forEach(({ eventName, callback }) => {166        socket.off(eventName, callback);167      });168    }169    // Nobody is listening anymore, remove the integration170    if (integration.handlers.length === 0) {171      integration.ioNamespace.disconnectSockets();172      delete this.activeIntegrations[integrationName];173      this.emitInfo();174    }175  }176}177let blokdotsSocketIOServer = null;178const getBlokdotsSocketIOServer = async () => {179  return new Promise((resolve) => {180    // If the server hasnât been setup yet, do that, then resolve the promise181    if (blokdotsSocketIOServer === null) {182      blokdotsSocketIOServer = new BlokdotsSocketIOServer();183      blokdotsSocketIOServer.init().then(() => {184        resolve(blokdotsSocketIOServer);185      });186    } else {187      // Else resolve the promise with the existing server immediately188      resolve(blokdotsSocketIOServer);189    }190  });191};...

Using AI Code Generation

1socket.OnConnect += (s, e) =>2{3    s.Emit("TestMessage", "Hello from the client");4};5socket.Open();6socket.OnConnect += (s, e) =>7{8    s.Emit("TestMessage", "Hello from the client");9};10socket.Open();11socket.OnConnect += (s, e) =>12{13    s.Emit("TestMessage", "Hello from the client");14};15socket.Open();16socket.OnConnect += (s, e) =>17{18    s.Emit("TestMessage", "Hello from the client");19};20socket.Open();21socket.OnConnect += (s, e) =>22{23    s.Emit("TestMessage", "Hello from the client");24};25socket.Open();26socket.OnConnect += (s, e) =>27{28    s.Emit("TestMessage", "Hello from the client");29};30socket.Open();

Using AI Code Generation

1socket.OnConnect += (s) => {2    s.Emit("message", "hello from client");3};4socket.On("message", (s, p) => {5    Debug.Log(p.Json.Args[0].ToString());6});7socket.OnDisconnect += (s, e) => {8    Debug.Log("Disconnected: " + e.Message);9};10socket.OnError += (s, e) => {11    Debug.Log("Error: " + e.Message);12};13socket.OnReconnect += (s, e) => {14    Debug.Log("Reconnected!");15};16socket.OnReconnectAttempt += (s, e) => {17    Debug.Log("Reconnect attempt: " + e.Attempt);18};19socket.OnReconnectFailed += (s, e) => {20    Debug.Log("Reconnect failed: " + e.Message);21};22socket.OnReconnectError += (s, e) => {23    Debug.Log("Reconnect error: " + e.Message);24};25socket.OnReconnecting += (s, e) => {26    Debug.Log("Reconnecting: " + e.Attempt);27};

Using AI Code Generation

1var ip = request.Headers["X-Forwarded-For"];2if (string.IsNullOrEmpty(ip))3{4    ip = request.UserHostAddress;5}6client.Send(ip);7var ip = request.Headers["X-Forwarded-For"];8if (string.IsNullOrEmpty(ip))9{10    ip = request.UserHostAddress;11}12client.Send(ip);13var ip = request.Headers["X-Forwarded-For"];14if (string.IsNullOrEmpty(ip))15{16    ip = request.UserHostAddress;17}18client.Send(ip);

Using AI Code Generation

1function Start () {2    socket.onClientConnect += OnClientConnect;3    socket.onClientDisconnect += OnClientDisconnect;4    socket.onClientReconnect += OnClientReconnect;5}6function OnClientConnect() {7    socket.Emit("playerName", playerName);8}9function OnClientDisconnect() {10    socket.Emit("playerName", playerName);11}12function OnClientReconnect() {13    socket.Emit("playerName", playerName);14}15function Start () {16    socket.onClientConnect += OnClientConnect;17    socket.onClientDisconnect += OnClientDisconnect;18    socket.onClientReconnect += OnClientReconnect;19}20function OnClientConnect() {21    socket.Emit("playerName", playerName);22}23function OnClientDisconnect() {

Using AI Code Generation

1using UnityEngine;2using System.Collections;3using BestHTTP.SocketIO;4using BestHTTP.SocketIO.Events;5public class test4 : MonoBehaviour {6	public SocketManager manager;7	void Start () {8		manager.Socket.On(SocketIOEventTypes.Connect, OnConnect);9		manager.Socket.On("message", OnMessage);10		manager.Socket.Open();11	}12	void OnConnect(Socket socket, Packet packet, params object[] args) {13		socket.Emit("message", "hello");14	}15	void OnMessage(Socket socket, Packet packet, params object[] args) {16		Debug.Log(args[0]);17		socket.Disconnect();18	}19}

Using AI Code Generation

1function OnClientConnect(socketManager)2{3    socketManager.On("chat message", OnChatMessage);4    socketManager.On("user joined", OnUserJoined);5    socketManager.On("user left", OnUserLeft);6    socketManager.On("typing", OnTyping);7    socketManager.On("stop typing", OnStopTyping);8    socketManager.On("login", OnLogin);9    socketManager.On("num users", OnNumUsers);10}11function OnClientConnect(socketManager)12{13    socketManager.On("chat message", OnChatMessage);14    socketManager.On("user joined", OnUserJoined);15    socketManager.On("user left", OnUserLeft);16    socketManager.On("typing", OnTyping);17    socketManager.On("stop typing", OnStopTyping);18    socketManager.On("login", OnLogin);19    socketManager.On("num users", OnNumUsers);20}21function OnClientConnect(socketManager)22{23    socketManager.On("chat message", OnChatMessage);24    socketManager.On("user joined", OnUserJoined);25    socketManager.On("user left", OnUserLeft);26    socketManager.On("typing", OnTyping);27    socketManager.On("stop typing", OnStopTyping);28    socketManager.On("login", OnLogin);29    socketManager.On("num users", OnNumUsers);30}

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.