opentok-accelerator-core
Advanced tools
Comparing version 1.0.28 to 1.0.29
'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 && obj !== Symbol.prototype ? "symbol" : typeof obj; }; | ||
/* global OT */ | ||
@@ -143,23 +145,25 @@ | ||
} else { | ||
// No videoType indicates SIP https://tokbox.com/developer/guides/sip/ | ||
var type = pathOr('sip', 'videoType', stream); | ||
try { | ||
connectionData = JSON.parse(path(['connection', 'data'], stream) || null); | ||
} catch (e) { | ||
connectionData = path(['connection', 'data'], stream); | ||
} | ||
var container = dom.query(streamContainers('subscriber', type, connectionData, streamId)); | ||
var options = type === 'camera' || type === 'sip' ? callProperties : screenProperties; | ||
var subscriber = session.subscribe(stream, container, options, function (error) { | ||
if (error) { | ||
logAnalytics(logAction.subscribe, logVariation.fail); | ||
reject(error); | ||
} else { | ||
state.addSubscriber(subscriber); | ||
triggerEvent('subscribeTo' + properCase(type), Object.assign({}, { subscriber: subscriber }, state.all())); | ||
type === 'screen' && triggerEvent('startViewingSharedScreen', subscriber); // Legacy event | ||
logAnalytics(logAction.subscribe, logVariation.success); | ||
resolve(); | ||
(function () { | ||
// No videoType indicates SIP https://tokbox.com/developer/guides/sip/ | ||
var type = pathOr('sip', 'videoType', stream); | ||
try { | ||
connectionData = JSON.parse(path(['connection', 'data'], stream) || null); | ||
} catch (e) { | ||
connectionData = path(['connection', 'data'], stream); | ||
} | ||
}); | ||
var container = dom.query(streamContainers('subscriber', type, connectionData, streamId)); | ||
var options = type === 'camera' || type === 'sip' ? callProperties : screenProperties; | ||
var subscriber = session.subscribe(stream, container, options, function (error) { | ||
if (error) { | ||
logAnalytics(logAction.subscribe, logVariation.fail); | ||
reject(error); | ||
} else { | ||
state.addSubscriber(subscriber); | ||
triggerEvent('subscribeTo' + properCase(type), Object.assign({}, { subscriber: subscriber }, state.all())); | ||
type === 'screen' && triggerEvent('startViewingSharedScreen', subscriber); // Legacy event | ||
logAnalytics(logAction.subscribe, logVariation.success); | ||
resolve(); | ||
} | ||
}); | ||
})(); | ||
} | ||
@@ -269,6 +273,12 @@ }); | ||
if (autoSubscribe) { | ||
var streams = state.getStreams(); | ||
return Object.keys(streams).map(function (id) { | ||
return subscribe(streams[id]); | ||
}); | ||
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; | ||
} | ||
@@ -275,0 +285,0 @@ return [Promise.resolve()]; |
@@ -242,9 +242,11 @@ 'use strict'; | ||
if (externalWindow) { | ||
// Add subscribers to the external window | ||
var streams = internalState.getStreams(); | ||
var cameraStreams = Object.keys(streams).reduce(function (acc, streamId) { | ||
var stream = streams[streamId]; | ||
return stream.videoType === 'camera' || stream.videoType === 'sip' ? acc.concat(stream) : acc; | ||
}, []); | ||
cameraStreams.forEach(annotation.addSubscriberToExternalWindow); | ||
(function () { | ||
// Add subscribers to the external window | ||
var streams = internalState.getStreams(); | ||
var cameraStreams = Object.keys(streams).reduce(function (acc, streamId) { | ||
var stream = streams[streamId]; | ||
return stream.videoType === 'camera' || stream.videoType === 'sip' ? acc.concat(stream) : acc; | ||
}, []); | ||
cameraStreams.forEach(annotation.addSubscriberToExternalWindow); | ||
})(); | ||
} | ||
@@ -251,0 +253,0 @@ }; |
@@ -53,3 +53,3 @@ 'use strict'; | ||
var otkanalyticsData = { | ||
clientVersion: 'js-vsol-1.0.27', | ||
clientVersion: 'js-vsol-1.0.29', // x.y.z filled by npm build script | ||
source: source, | ||
@@ -56,0 +56,0 @@ componentId: 'acceleratorCore', |
@@ -116,3 +116,2 @@ 'use strict'; | ||
this.session = OT.initSession(credentials.apiKey, credentials.sessionId); | ||
this.setInternalListeners(); | ||
} | ||
@@ -389,2 +388,3 @@ | ||
this.off(); | ||
this.setInternalListeners(); | ||
eventListeners && this.on(eventListeners); | ||
@@ -391,0 +391,0 @@ return new Promise(function (resolve, reject) { |
{ | ||
"name": "opentok-accelerator-core", | ||
"version": "1.0.28", | ||
"version": "1.0.29", | ||
"description": "Opentok Accelerator Core", | ||
@@ -12,3 +12,4 @@ "repository": "https://github.com/opentok/accelerator-core-js", | ||
"build:browser": "npm run build:browser-polyfill && npm run build:browser-browserify && rm src/browser-temp.js", | ||
"build": "npm run build:node && npm run build:browser", | ||
"build:logversion": "replace '(js-vsol-)(x.y.z)' '$1'$npm_package_version dist/* browser/*", | ||
"build": "npm run build:node && npm run build:browser && npm run build:logversion", | ||
"test": "karma start" | ||
@@ -38,3 +39,4 @@ }, | ||
"eslint-plugin-jsx-a11y": "^3.0.2", | ||
"eslint-plugin-react": "^6.9.0" | ||
"eslint-plugin-react": "^6.9.0", | ||
"replace": "^0.3.0" | ||
}, | ||
@@ -41,0 +43,0 @@ "dependencies": { |
@@ -49,3 +49,3 @@ const OTKAnalytics = require('opentok-solutions-logging'); | ||
const otkanalyticsData = { | ||
clientVersion: 'js-vsol-1.0.28', | ||
clientVersion: 'js-vsol-x.y.z', // x.y.z filled by npm build script | ||
source, | ||
@@ -52,0 +52,0 @@ componentId: 'acceleratorCore', |
@@ -98,3 +98,2 @@ /* global OT */ | ||
this.session = OT.initSession(credentials.apiKey, credentials.sessionId); | ||
this.setInternalListeners(); | ||
} | ||
@@ -298,2 +297,3 @@ | ||
this.off(); | ||
this.setInternalListeners(); | ||
eventListeners && this.on(eventListeners); | ||
@@ -300,0 +300,0 @@ return new Promise((resolve, reject) => { |
Sorry, the diff of this file is too big to display
Mixed license
License(Experimental) Package contains multiple licenses.
Found 1 instance in 1 package
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
Environment variable access
Supply chain riskPackage accesses environment variables, which may be a sign of credential stuffing or data theft.
Found 1 instance in 1 package
571988
57
4
4
11
1
13076