QT-9589: Added Web socket check in test-rtc

.eslintrc

@@ -65,6 +65,7 @@
     "arrayMax": true,
     "arrayMin": true,
     "TURN_URL": true,
+    "WEBSOCKET_URL": true,
     "Ssim": true,
     "VideoFrameChecker": true,
     "StatisticsAggregate": true,

Gruntfile.js

@@ -79,7 +79,8 @@ module.exports = function(grunt) {
         compress: {
           global_defs: {
             'API_KEY': process.env.API_KEY,
-            'TURN_URL': 'https://test-api.pod.ai/api/external/testrtc/turn-credentials/'
+            'TURN_URL': 'https://test-api.pod.ai/api/external/testrtc/turn-credentials/',
+            'WEBSOCKET_URL': 'wss://test-api.pod.ai/api/web-socket-session/',
           },
           dead_code: true,
         },

src/js/call.js

@@ -210,6 +210,10 @@ Call.isHost = function(candidate) {
   return candidate.type === 'host';
 };
 
+Call.isWebSocket = function(candidate) {
+  return candidate.type === 'web socket';
+};
+
 Call.isIpv6 = function(candidate) {
   return candidate.address.indexOf(':') !== -1;
 };

src/js/conntest.js

@@ -34,6 +34,15 @@ addTest(
       runConnectivityTest.start();
     });
 
+// Set up a websocket connection between two peers and verify data can be
+// transmitted and received
+addTest(
+    testSuiteName.CONNECTIVITY, testCaseName.WEBSOCKETCONNECTIVITY,
+    function(test) {
+      var runConnectivityTest = new RunConnectivityTest(test, Call.isWebSocket);
+      runConnectivityTest.checkWSConnection();
+    });
+
 function RunConnectivityTest(test, iceCandidateFilter) {
   this.test = test;
   this.iceCandidateFilter = iceCandidateFilter;
@@ -94,6 +103,39 @@ RunConnectivityTest.prototype = {
     this.timeout = setTimeout(this.hangup.bind(this, 'Timed out'), 5000);
   },
 
+  // It creates a websocket connection with backnd server and check that data
+  // can be sent and received successfully
+  checkWSConnection: function(config) {
+    this.call = new Call(config, this.test);
+    this.call.setIceCandidateFilter(this.iceCandidateFilter);
+
+    this.timeout = setTimeout(
+        this.hangup.bind(this,'Websocket connection timed out'),
+        5000
+    );
+    var socket = new WebSocket(WEBSOCKET_URL);
+
+    socket.addEventListener('open', function() {
+      socket.send('ping');
+    });
+
+    socket.addEventListener('error', function() {
+      socket.close();
+      this.hangup('Web socket connection error');
+    }.bind(this));
+
+    socket.addEventListener('message', function(event) {
+      var receivedMessage = event.data;
+      if (receivedMessage === 'pong') {
+        this.test.reportSuccess('Data transmitted successfully');
+      } else {
+        this.test.reportError('Invalid data received.');
+      }
+      socket.close();
+      this.hangup();
+    }.bind(this));
+  },
+
   findParsedCandidateOfSpecifiedType: function(candidateTypeMethod) {
     for (var candidate in this.parsedCandidates) {
       if (candidateTypeMethod(this.parsedCandidates[candidate])) {

src/js/testcasename.js

@@ -31,7 +31,8 @@ function TestCaseNames() {
     VIDEOBANDWIDTH: 'Video bandwidth',
     RELAYCONNECTIVITY: 'Relay connectivity',
     REFLEXIVECONNECTIVITY: 'Reflexive connectivity',
-    HOSTCONNECTIVITY: 'Host connectivity'
+    HOSTCONNECTIVITY: 'Host connectivity',
+    WEBSOCKETCONNECTIVITY: 'Web socket connectivity'
   };
   return this.testCases;
 }