opentok-accelerator-core - npm Package Compare versions

Comparing version 0.0.10 to 0.0.11

browser/opentok-acc-core.js

@@ -6,2 +6,4 @@ (function e(t,n,r){function s(o,u){if(!n[o]){if(!t[o]){var a=typeof require=="function"&&require;if(!u&&a)return a(o,!0);if(i)return i(o,!0);var f=new Error("Cannot find module '"+o+"'");throw f.code="MODULE_NOT_FOUND",f}var l=n[o]={exports:{}};t[o][0].call(l.exports,function(e){var n=t[o][1][e];return s(n?n:e)},l,l.exports,e,t,n,r)}return n[o].exports}var i=typeof require=="function"&&require;for(var o=0;o<r.length;o++)s(r[o]);return s})({1:[function(require,module,exports){
 
+var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol" ? function (obj) { return typeof obj; } : function (obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; };
+
 /* global OT */
@@ -220,7 +222,18 @@
     publish().then(function () {
-      var streams = state.getStreams();
-      var initialSubscriptions = Object.keys(streams).map(function (id) {
-        return subscribe(streams[id]);
-      });
-      Promise.all(initialSubscriptions).then(function () {
+      var initialSubscriptions = function initialSubscriptions() {
+        if (autoSubscribe) {
+          var _ret2 = function () {
+            var streams = state.getStreams();
+            return {
+              v: Object.keys(streams).map(function (id) {
+                return subscribe(streams[id]);
+              })
+            };
+          }();
+
+          if ((typeof _ret2 === 'undefined' ? 'undefined' : _typeof(_ret2)) === "object") return _ret2.v;
+        }
+        return [Promise.resolve()];
+      };
+      Promise.all(initialSubscriptions()).then(function () {
         var pubSubData = state.getPubSub();
@@ -227,0 +240,0 @@ triggerEvent('startCall', pubSubData);

dist/communication.js

 'use strict';
 
+var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol" ? function (obj) { return typeof obj; } : function (obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol ? "symbol" : typeof obj; };
+
 /* global OT */
@@ -216,7 +218,18 @@
     publish().then(function () {
-      var streams = state.getStreams();
-      var initialSubscriptions = Object.keys(streams).map(function (id) {
-        return subscribe(streams[id]);
-      });
-      Promise.all(initialSubscriptions).then(function () {
+      var initialSubscriptions = function initialSubscriptions() {
+        if (autoSubscribe) {
+          var _ret2 = function () {
+            var streams = state.getStreams();
+            return {
+              v: Object.keys(streams).map(function (id) {
+                return subscribe(streams[id]);
+              })
+            };
+          }();
+
+          if ((typeof _ret2 === 'undefined' ? 'undefined' : _typeof(_ret2)) === "object") return _ret2.v;
+        }
+        return [Promise.resolve()];
+      };
+      Promise.all(initialSubscriptions()).then(function () {
         var pubSubData = state.getPubSub();
@@ -223,0 +236,0 @@ triggerEvent('startCall', pubSubData);

package.json

 {
   "name": "opentok-accelerator-core",
-  "version": "0.0.10",
+  "version": "0.0.11",
   "description": "Opentok Accelerator Core",
@@ -29,3 +29,3 @@ "repository": "https://github.com/opentok/accelerator-core/tree/master/js",
     "eslint": "^3.5.0",
-    "eslint-config-airbnb": "^11.1.0",
+    "eslint-config-airbnb": "^11.2.0",
     "eslint-plugin-import": "^1.15.0",
@@ -32,0 +32,0 @@ "eslint-plugin-jsx-a11y": "^2.2.2",

react-sample-app/src/ot-core/communication.js

 'use strict';
 
+var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol" ? function (obj) { return typeof obj; } : function (obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol ? "symbol" : typeof obj; };
+
 /* global OT */
@@ -216,7 +218,18 @@
     publish().then(function () {
-      var streams = state.getStreams();
-      var initialSubscriptions = Object.keys(streams).map(function (id) {
-        return subscribe(streams[id]);
-      });
-      Promise.all(initialSubscriptions).then(function () {
+      var initialSubscriptions = function initialSubscriptions() {
+        if (autoSubscribe) {
+          var _ret2 = function () {
+            var streams = state.getStreams();
+            return {
+              v: Object.keys(streams).map(function (id) {
+                return subscribe(streams[id]);
+              })
+            };
+          }();
+
+          if ((typeof _ret2 === 'undefined' ? 'undefined' : _typeof(_ret2)) === "object") return _ret2.v;
+        }
+        return [Promise.resolve()];
+      };
+      Promise.all(initialSubscriptions()).then(function () {
         var pubSubData = state.getPubSub();
@@ -223,0 +236,0 @@ triggerEvent('startCall', pubSubData);

src/communication.js

@@ -201,5 +201,10 @@ /* global OT */
       .then(() => {
-        const streams = state.getStreams();
-        const initialSubscriptions = Object.keys(streams).map(id => subscribe(streams[id]));
-        Promise.all(initialSubscriptions).then(() => {
+        const initialSubscriptions = () => {
+          if (autoSubscribe) {
+            const streams = state.getStreams();
+            return Object.keys(streams).map(id => subscribe(streams[id]));
+          }
+          return [Promise.resolve()];
+        }
+        Promise.all(initialSubscriptions()).then(() => {
           const pubSubData = state.getPubSub();
@@ -206,0 +211,0 @@ triggerEvent('startCall', pubSubData);

vanilla-js-sample-app/public/js/components/opentok-acc-core.js

@@ -6,2 +6,4 @@ (function e(t,n,r){function s(o,u){if(!n[o]){if(!t[o]){var a=typeof require=="function"&&require;if(!u&&a)return a(o,!0);if(i)return i(o,!0);var f=new Error("Cannot find module '"+o+"'");throw f.code="MODULE_NOT_FOUND",f}var l=n[o]={exports:{}};t[o][0].call(l.exports,function(e){var n=t[o][1][e];return s(n?n:e)},l,l.exports,e,t,n,r)}return n[o].exports}var i=typeof require=="function"&&require;for(var o=0;o<r.length;o++)s(r[o]);return s})({1:[function(require,module,exports){
 
+var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol" ? function (obj) { return typeof obj; } : function (obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; };
+
 /* global OT */
@@ -220,7 +222,18 @@
     publish().then(function () {
-      var streams = state.getStreams();
-      var initialSubscriptions = Object.keys(streams).map(function (id) {
-        return subscribe(streams[id]);
-      });
-      Promise.all(initialSubscriptions).then(function () {
+      var initialSubscriptions = function initialSubscriptions() {
+        if (autoSubscribe) {
+          var _ret2 = function () {
+            var streams = state.getStreams();
+            return {
+              v: Object.keys(streams).map(function (id) {
+                return subscribe(streams[id]);
+              })
+            };
+          }();
+
+          if ((typeof _ret2 === 'undefined' ? 'undefined' : _typeof(_ret2)) === "object") return _ret2.v;
+        }
+        return [Promise.resolve()];
+      };
+      Promise.all(initialSubscriptions()).then(function () {
         var pubSubData = state.getPubSub();
@@ -227,0 +240,0 @@ triggerEvent('startCall', pubSubData);

No alert changes

Improved metrics

Total package byte prevSize

422424

increased by0.61%

Lines of code

10098

increased by0.49%

No dependency changes