'use strict';
const { v1: uuid_v1 } = require('uuid');
const constants = require("./constants");
const util = require('./util');
const LoggerObject = require('./util').logger;
const Promise = require('promise-polyfill');
const KalmanFilter = require('kalmanjs');
const browserDetails = require('webrtc-adapter').default.browserDetails;
const LOG_PREFIX = "core";
var coreLogger;
var loggerConf = {push: false, severity: "INFO"};
var isUsingTemasysPlugin = false;
/**
* @namespace Flashphoner
*/
const SESSION_STATUS = constants.SESSION_STATUS;
const STREAM_EVENT = constants.STREAM_EVENT;
const STREAM_EVENT_TYPE = constants.STREAM_EVENT_TYPE;
const STREAM_STATUS = constants.STREAM_STATUS;
const CALL_STATUS = constants.CALL_STATUS;
const CONNECTION_QUALITY = constants.CONNECTION_QUALITY;
const ERROR_INFO = constants.ERROR_INFO;
const VIDEO_RATE_GOOD_QUALITY_PERCENT_DIFFERENCE = 20;
const VIDEO_RATE_BAD_QUALITY_PERCENT_DIFFERENCE = 50;
const LOW_VIDEO_RATE_THRESHOLD_BAD_PERFECT = 50000;
const LOW_VIDEO_RATE_BAD_QUALITY_PERCENT_DIFFERENCE = 150;
const OUTBOUND_VIDEO_RATE = "outboundVideoRate";
const INBOUND_VIDEO_RATE = "inboundVideoRate";
const CONSTRAINT_AUDIO = "audio";
const CONSTRAINT_AUDIO_STEREO = "stereo";
const CONSTRAINT_AUDIO_BITRATE = "bitrate";
const CONSTRAINT_AUDIO_FEC = "fec";
const CONSTRAINT_AUDIO_OUTPUT_ID = "outputId";
const CONSTRAINT_VIDEO = "video";
const CONSTRAINT_VIDEO_BITRATE = "video.bitrate";
const CONSTRAINT_VIDEO_MIN_BITRATE = "video.minBitrate";
const CONSTRAINT_VIDEO_MAX_BITRATE = "video.maxBitrate";
const CONSTRAINT_VIDEO_QUALITY = "video.quality";
const CONSTRAINT_VIDEO_WIDTH = "video.width";
const CONSTRAINT_VIDEO_HEIGHT = "video.height";
var MediaProvider = {};
var sessions = {};
var initialized = false;
var disableConnectionQualityCalculation;
/**
* Static initializer.
*
* @param {Object} options Global api options
* @param {Function=} options.mediaProvidersReadyCallback Callback of initialized WebRTC Plugin
* @param {String=} options.flashMediaProviderSwfLocation Location of media-provider.swf file
* @param {string=} options.preferredMediaProvider DEPRECATED: Use preferred media provider if available
* @param {Array=} options.preferredMediaProviders Use preferred media providers order
* @param {String=} options.receiverLocation Location of WSReceiver.js file
* @param {String=} options.decoderLocation Location of video-worker2.js file
* @param {String=} options.screenSharingExtensionId Chrome screen sharing extension id
* @param {Object=} options.constraints Default local media constraints
* @param {Object=} options.logger Core logger options
* @throws {Error} Error if none of MediaProviders available
* @memberof Flashphoner
*/
var init = function (options) {
if (!initialized) {
if (!options) {
options = {};
}
// init global logger
coreLogger = createLogger(options.logger);
var waitingTemasys = false;
try {
var audioContext = new (window.AudioContext || window.webkitAudioContext)();
} catch (e) {
console.warn("Failed to create audio context");
}
disableConnectionQualityCalculation = options.disableConnectionQualityCalculation;
var webRtcProvider = require("./webrtc-media-provider");
if (webRtcProvider && webRtcProvider.hasOwnProperty('available') && webRtcProvider.available()) {
MediaProvider.WebRTC = webRtcProvider;
// WCS-2996 Fix audio-video out of sync in case of using Samsung browser
var enableGainNode = util.Browser.isSamsungBrowser() || util.Browser.isAndroidFirefox() ? false : options.createMicGainNode;
var webRtcConf = {
constraints: options.constraints || getDefaultMediaConstraints(),
extensionId: options.screenSharingExtensionId,
audioContext: audioContext,
logger: coreLogger,
createMicGainNode: enableGainNode
};
webRtcProvider.configure(webRtcConf);
} else {
webRtcProvider = require("./temasys-media-provider");
if (webRtcProvider && webRtcProvider.hasOwnProperty('available') && AdapterJS) {
waitingTemasys = true;
AdapterJS.webRTCReady(function (isUsingPlugin) {
isUsingTemasysPlugin = isUsingPlugin;
if (isUsingPlugin || webRtcProvider.available()) {
MediaProvider.WebRTC = webRtcProvider;
var webRtcConf = {
constraints: options.constraints || getDefaultMediaConstraints(),
extensionId: options.screenSharingExtensionId,
logger: coreLogger
};
webRtcProvider.configure(webRtcConf);
// Just reorder media provider list
var _MediaProvider = {};
_MediaProvider.WebRTC = MediaProvider.WebRTC;
for (var p in MediaProvider) {
_MediaProvider[p] = MediaProvider[p];
}
MediaProvider = _MediaProvider;
}
if (options.mediaProvidersReadyCallback) {
options.mediaProvidersReadyCallback(Object.keys(MediaProvider));
}
});
}
}
// flashMediaProvider is disables by default due to end of support in the most browsers #WCS-3577
var flashProvider = null;
if (flashProvider && flashProvider.hasOwnProperty('available') && flashProvider.available() &&
(!MediaProvider.WebRTC || (options.preferredMediaProviders && options.preferredMediaProviders.indexOf("Flash") >= 0))) {
MediaProvider.Flash = flashProvider;
var flashConf = {
constraints: options.constraints || getDefaultMediaConstraints(),
flashMediaProviderSwfLocation: options.flashMediaProviderSwfLocation,
logger: coreLogger
};
flashProvider.configure(flashConf);
}
var mediaSourceMediaProvider = require("./media-source-media-provider");
if (mediaSourceMediaProvider && mediaSourceMediaProvider.hasOwnProperty('available') && mediaSourceMediaProvider.available()) {
MediaProvider.MSE = mediaSourceMediaProvider;
var mseConf = {
audioContext: audioContext,
browserDetails: browserDetails.browser
};
mediaSourceMediaProvider.configure(mseConf);
}
var websocketProvider = require("./websocket-media-provider");
if (websocketProvider && websocketProvider.hasOwnProperty('available') && websocketProvider.available(audioContext)) {
MediaProvider.WSPlayer = websocketProvider;
var wsConf = {
receiverLocation: options.receiverLocation,
decoderLocation: options.decoderLocation,
audioContext: audioContext,
logger: coreLogger
};
websocketProvider.configure(wsConf);
}
//check at least 1 provider available
if (getMediaProviders().length == 0) {
throw new Error('None of MediaProviders available');
} else if (options.preferredMediaProvider) {
if (MediaProvider.hasOwnProperty(options.preferredMediaProvider)) {
if (getMediaProviders()[0] != options.preferredMediaProvider) {
// Just reorder media provider list
var _MediaProvider = {};
_MediaProvider[options.preferredMediaProvider] = MediaProvider[options.preferredMediaProvider];
for (var p in MediaProvider) {
_MediaProvider[p] = MediaProvider[p];
}
MediaProvider = _MediaProvider;
}
} else {
corelogger.warn(LOG_PREFIX, "Preferred media provider is not available.");
}
}
if (options.preferredMediaProviders && options.preferredMediaProviders.length > 0) {
var newMediaProvider = {};
for (var i in options.preferredMediaProviders) {
if (options.preferredMediaProviders.hasOwnProperty(i)) {
var pMP = options.preferredMediaProviders[i];
if (MediaProvider.hasOwnProperty(pMP)) {
newMediaProvider[pMP] = MediaProvider[pMP];
}
}
}
if (util.isEmptyObject(newMediaProvider)) {
throw new Error("None of preferred MediaProviders available");
} else {
MediaProvider = newMediaProvider;
}
}
if (!waitingTemasys && options.mediaProvidersReadyCallback) {
options.mediaProvidersReadyCallback(Object.keys(MediaProvider));
}
coreLogger.info(LOG_PREFIX, "Initialized");
initialized = true;
}
};
/**
* Get available MediaProviders.
*
* @returns {Array} Available MediaProviders
* @memberof Flashphoner
*/
var getMediaProviders = function () {
return Object.keys(MediaProvider);
};
/**
* Play audio chunk
* @param {boolean} noise Use noise in playing
* @memberof Flashphoner
*/
var playFirstSound = function(noise) {
var mediaProvider = getMediaProviders()[0];
MediaProvider[mediaProvider].playFirstSound(noise);
};
/**
* Play video chunk
*
* @memberof Flashphoner
*/
var playFirstVideo = function (display, isLocal, src, useControls) {
for (var mp in MediaProvider) {
return MediaProvider[mp].playFirstVideo(display, isLocal, src, useControls);
}
};
/**
* Get core logger
*
* @returns {Object} Logger
* @memberof Flashphoner
*/
var getLogger = function () {
if (!initialized) {
console.warn("Initialize API first.");
} else {
return coreLogger;
}
}
/**
* @typedef Flashphoner.MediaDeviceList
* @type Object
* @property {Flashphoner.MediaDevice[]} audio Audio devices (microphones)
* @property {Flashphoner.MediaDevice[]} video Video devices (cameras)
*/
/**
* @typedef Flashphoner.MediaDevice
* @type Object
* @property {String} type Type of device: mic, camera, screen
* @property {String} id Unique id
* @property {String} label Device label
*/
/**
* Get available local media devices
*
* @param {String=} mediaProvider Media provider that will be asked for device list
* @param {Boolean=} labels Ask user for microphone access before getting device list.
* This will make device label available.
* @param {Flashphoner.constants.MEDIA_DEVICE_KIND} kind Media devices kind to access:
* MEDIA_DEVICE_KIND.INPUT (default) get access to input devices only (camera, mic).
* MEDIA_DEVICE_KIND.OUTPUT get access to output devices only (speaker, headphone).
* MEDIA_DEVICE_KIND.ALL get access to all devices (cam, mic, speaker, headphone).
* @param {Object=} deviceConstraints If labels == true.
* If {audio: true, video: false}, then access to the camera will not be requested.
* If {audio: false, video: true}, then access to the microphone will not be requested.
* @returns {Promise.<Flashphoner.MediaDeviceList>} Promise with media device list on fulfill
* @throws {Error} Error if API is not initialized
* @memberof Flashphoner
*/
var getMediaDevices = function (mediaProvider, labels, kind, deviceConstraints) {
if (!initialized) {
throw new Error("Flashphoner API is not initialized");
}
if (!mediaProvider) {
mediaProvider = getMediaProviders()[0];
}
return MediaProvider[mediaProvider].listDevices(labels, kind, deviceConstraints);
};
/**
* Get access to local media
*
* @param {Object} constraints Media constraints
* @param {Object} constraints.audio Audio constraints
* @param {String=} constraints.audio.deviceId Audio device id
* @param {Object} constraints.video Video constraints
* @param {String=} constraints.video.deviceId Video device id
* @param {number} constraints.video.width Video width
* @param {number} constraints.video.height Video height
* @param {number} constraints.video.frameRate Video fps
* @param {String} constraints.video.type Video device type: camera, screen
* @param {String} constraints.video.mediaSource Video source type for FF: screen, window
* @param {HTMLElement} display Div element local media should be displayed in
* @param {String} mediaProvider Media provider type
* @param {Boolean} disableConstraintsNormalization Disable constraints normalization
* @returns {Promise.<HTMLElement>} Promise with display on fulfill
* @throws {Error} Error if API is not initialized
* @memberof Flashphoner
*/
var getMediaAccess = function (constraints, display, mediaProvider, disableConstraintsNormalization) {
if (!initialized) {
throw new Error("Flashphoner API is not initialized");
}
if (!mediaProvider) {
mediaProvider = getMediaProviders()[0];
}
return MediaProvider[mediaProvider].getMediaAccess(constraints, display, disableConstraintsNormalization);
};
//default constraints helper
//WCS-3016 16:9 ratio
var getDefaultMediaConstraints = function () {
if (browserDetails.browser == "safari") {
return {
audio: true,
video: {
width: {min: 320, max: 640},
height: {min: 180, max: 360}
}
};
}
else {
return {
audio: true,
video: {
width: 320,
height: 240
}
}
}
};
function getConstraintsProperty(constraints, property, defaultValue) {
if (!constraints || !property) return defaultValue;
var res;
var properties = property.split(".");
for (var prop in constraints) {
if (prop == properties[0]) {
res = constraints[prop];
if (properties.length > 1) res = getConstraintsProperty(constraints[prop], properties[1], defaultValue);
} else if (typeof constraints[prop] === "object") {
for (var p in constraints[prop]) {
if (p == property) res = constraints[prop][p];
}
}
}
if (typeof res === "boolean") return res;
return res || defaultValue;
}
/**
* Release local media
*
* @param {HTMLElement} display Div element with local media
* @param {String=} mediaProvider Media provider type
* @returns {Boolean} True if media was found and released
* @throws {Error} Error if API is not initialized
* @memberof Flashphoner
*/
var releaseLocalMedia = function (display, mediaProvider) {
if (!initialized) {
throw new Error("Flashphoner API is not initialized");
}
if (!mediaProvider) {
mediaProvider = getMediaProviders()[0];
}
return MediaProvider[mediaProvider].releaseMedia(display);
};
/**
* Get active sessions.
*
* @returns {Session[]} Array containing active sessions
* @memberof Flashphoner
*/
var getSessions = function () {
return util.copyObjectToArray(sessions);
};
/**
* Get session by id.
*
* @param {string} id Session id
* @returns {Session} Session
* @memberof Flashphoner
*/
var getSession = function (id) {
return sessions[id];
};
// Get logger configuration from options
var getLoggerConf = function(loggerOptions) {
var conf = loggerOptions || loggerConf;
if (loggerOptions !== null) {
conf.enableLogs = true;
}
return conf;
}
// Create a new logger object
var createLogger = function(loggerOptions, parentLogger = coreLogger) {
var newLogger = parentLogger;
if (newLogger === undefined || loggerOptions != undefined) {
var loggerConf = getLoggerConf(loggerOptions);
newLogger = new LoggerObject;
newLogger.init(loggerConf.severity || "INFO", loggerConf.push || false, loggerConf.customLogger, loggerConf.enableLogs);
}
return newLogger;
}
/**
* Create new session and connect to server.
*
* @param {Object} options Session options
* @param {string} options.urlServer Server address in form of [ws,wss]://host.domain:port
* @param {string} options.authToken Token for auth on server with keepalived client
* @param {Boolean=} options.keepAlive Keep alive client on server after disconnect
* @param {string=} options.lbUrl Load-balancer address
* @param {string=} options.flashProto Flash protocol [rtmp,rtmfp]
* @param {Integer=} options.flashPort Flash server port [1935]
* @param {string=} options.appKey REST App key
* @param {Object=} options.custom User provided custom object that will be available in REST App code
* @param {Object=} options.sipOptions Sip configuration
* @param {Object=} options.mediaOptions Media connection configuration
* @param {Integer=} options.timeout Connection timeout in milliseconds
* @param {Integer=} options.pingInterval Server ping interval in milliseconds [0]
* @param {Integer=} options.receiveProbes A maximum subsequental pings received missing count [0]
* @param {Integer=} options.probesInterval Interval to check subsequental pings received [0]
* @param {Object=} options.logger Session logger options
* @returns {Session} Created session
* @throws {Error} Error if API is not initialized
* @throws {TypeError} Error if options.urlServer is not specified
* @memberof Flashphoner
*/
var createSession = function (options) {
if (!initialized) {
throw new Error("Flashphoner API is not initialized");
}
if (!options || !options.urlServer) {
throw new TypeError("options.urlServer must be provided");
}
// Set session logger #WCS-2434
var sessionLogger = createLogger(options.logger)
// Override logger for all low level operations
var logger = sessionLogger;
var id_ = uuid_v1();
var sessionStatus = SESSION_STATUS.PENDING;
var urlServer = options.urlServer;
var lbUrl = options.lbUrl;
var flashProto = options.flashProto || "rtmfp";
var flashPort = options.flashPort || 1935;
var appKey = options.appKey || "defaultApp";
var mediaOptions = options.mediaOptions;
var keepAlive = options.keepAlive;
var timeout = options.timeout;
var wsPingSender = new WSPingSender(options.pingInterval || 0);
var wsPingReceiver = new WSPingReceiver(options.receiveProbes || 0, options.probesInterval || 0);
var connectionTimeout;
var cConfig;
//SIP config
var sipConfig;
if (options.sipOptions) {
sipConfig = {
sipLogin: options.sipOptions.login,
sipAuthenticationName: options.sipOptions.authenticationName,
sipPassword: options.sipOptions.password,
sipDomain: options.sipOptions.domain,
sipOutboundProxy: options.sipOptions.outboundProxy,
sipProxy: options.sipOptions.proxy,
sipPort: options.sipOptions.port,
sipRegisterRequired: options.sipOptions.registerRequired
}
}
//media provider auth token received from server
var authToken = options.authToken;
//object for storing new and active streams
var streams = {};
var calls = {};
var mediaConnections = {};
//session to stream event callbacks
var streamEventRefreshHandlers = {};
//session to stream callbacks
var streamRefreshHandlers = {};
//session to call callbacks
var callRefreshHandlers = {};
/**
* Represents connection to REST App.
* Can create and store Streams.
*
* @see Flashphoner.createSession
* @namespace Session
*/
var session = {};
//callbacks added using session.on()
var callbacks = {};
var wsConnection;
if (lbUrl) {
requestURL(lbUrl);
} else {
createWS(urlServer)
}
//todo remove
var remoteSdpCache = {};
//Request URL from load-balancer
function requestURL(url) {
var request = new XMLHttpRequest();
request.open('GET', url, true);
request.timeout = 5000;
request.ontimeout = function () {
logger.warn(LOG_PREFIX, "Timeout during geting url from balancer!");
createWS(urlServer);
}
request.error = function () {
logger.warn(LOG_PREFIX, "Error during geting url from balancer!")
createWS(urlServer);
}
request.onload = function (e) {
if (request.status == 200 && request.readyState == 4) {
var result = JSON.parse(request.responseText);
if (urlServer.indexOf("wss://") !== -1) {
urlServer = "wss://" + result.server + ":" + result.wss;
} else {
urlServer = "ws://" + result.server + ":" + result.ws;
}
flashPort = result.flash;
logger.debug(LOG_PREFIX, "Got url from load balancer " + result.server);
createWS(urlServer);
}
}
request.send();
}
//connect session to server
function createWS(url) {
wsConnection = new WebSocket(url);
if (timeout != undefined && timeout > 0) {
connectionTimeout = setTimeout(function() {
if (wsConnection.readyState == 0) {
logger.warn(LOG_PREFIX, "WS connection timeout");
wsConnection.close();
}
}, timeout);
}
wsConnection.onerror = function () {
onSessionStatusChange(SESSION_STATUS.FAILED);
};
wsConnection.onclose = function () {
if (sessionStatus !== SESSION_STATUS.FAILED) {
onSessionStatusChange(SESSION_STATUS.DISCONNECTED);
}
};
wsConnection.onopen = function () {
onSessionStatusChange(SESSION_STATUS.CONNECTED);
clearTimeout(connectionTimeout);
cConfig = {
appKey: appKey,
mediaProviders: Object.keys(MediaProvider),
keepAlive: keepAlive,
authToken:authToken,
clientVersion: "2.0",
clientOSVersion: window.navigator.appVersion,
clientBrowserVersion: window.navigator.userAgent,
msePacketizationVersion: 2,
custom: options.custom
};
if (sipConfig) {
util.copyObjectPropsToAnotherObject(sipConfig, cConfig);
}
//connect to REST App
send("connection", cConfig);
logger.setConnection(wsConnection);
// Send ping messages to server to check if connection is still alive #WCS-3410
wsPingSender.start();
// Check subsequintel pings received from server to check if connection is still alive #WCS-3410
wsPingReceiver.start();
};
wsConnection.onmessage = function (event) {
var data = {};
if (event.data instanceof Blob) {
data.message = "binaryData";
} else {
data = JSON.parse(event.data);
var obj = data.data[0];
}
switch (data.message) {
case 'ping':
send("pong", null);
wsPingReceiver.success();
break;
case 'getUserData':
authToken = obj.authToken;
cConfig = obj;
onSessionStatusChange(SESSION_STATUS.ESTABLISHED, obj);
break;
case 'setRemoteSDP':
var mediaSessionId = data.data[0];
var sdp = data.data[1];
if (streamRefreshHandlers[mediaSessionId]) {
//pass server's sdp to stream
streamRefreshHandlers[mediaSessionId](null, sdp);
} else if (callRefreshHandlers[mediaSessionId]) {
//pass server's sdp to call
callRefreshHandlers[mediaSessionId](null, sdp);
} else {
remoteSdpCache[mediaSessionId] = sdp;
logger.info(LOG_PREFIX, "Media not found, id " + mediaSessionId);
}
break;
case 'notifyVideoFormat':
case 'notifyStreamStatusEvent':
if (streamRefreshHandlers[obj.mediaSessionId]) {
//update stream status
streamRefreshHandlers[obj.mediaSessionId](obj);
}
break;
case 'notifyStreamEvent':
if (streamEventRefreshHandlers[obj.mediaSessionId]) {
//update stream status
streamEventRefreshHandlers[obj.mediaSessionId](obj);
}
break;
case 'DataStatusEvent':
restAppCommunicator.resolveData(obj);
break;
case 'OnDataEvent':
if (callbacks[SESSION_STATUS.APP_DATA]) {
callbacks[SESSION_STATUS.APP_DATA](obj);
}
break;
case 'fail':
if (obj.apiMethod && obj.apiMethod == "StreamStatusEvent") {
if (streamRefreshHandlers[obj.id]) {
//update stream status
streamRefreshHandlers[obj.id](obj);
}
}
if (callbacks[SESSION_STATUS.WARN]) {
callbacks[SESSION_STATUS.WARN](obj);
}
break;
case 'registered':
onSessionStatusChange(SESSION_STATUS.REGISTERED);
break;
case 'notifyAudioCodec':
// This case for Flash only
var mediaSessionId = data.data[0];
var codec = data.data[1];
if (callRefreshHandlers[mediaSessionId]) {
callRefreshHandlers[mediaSessionId](null, null, codec);
}
break;
case 'notifyTransferEvent':
callRefreshHandlers[obj.callId](null, null, null, obj);
break;
case 'notifyTryingResponse':
case 'hold':
case 'ring':
case 'talk':
case 'finish':
if (callRefreshHandlers[obj.callId]) {
//update call status
callRefreshHandlers[obj.callId](obj);
}
break;
case 'notifyIncomingCall':
if (callRefreshHandlers[obj.callId]) {
logger.error(LOG_PREFIX, "Call already exists, id " + obj.callId);
}
if (callbacks[SESSION_STATUS.INCOMING_CALL]) {
callbacks[SESSION_STATUS.INCOMING_CALL](createCall(obj));
} else {
//todo hangup call
}
break;
case 'notifySessionDebugEvent':
logger.info(LOG_PREFIX, "Session debug status " + obj.status);
if (callbacks[SESSION_STATUS.DEBUG]) {
callbacks[SESSION_STATUS.DEBUG](obj);
}
break;
case 'availableStream':
var availableStream = {};
availableStream.mediaSessionId = obj.id;
availableStream.available = obj.status;
availableStream.reason = obj.info;
if (streamRefreshHandlers[availableStream.mediaSessionId]) {
streamRefreshHandlers[availableStream.mediaSessionId](availableStream);
}
break;
case OUTBOUND_VIDEO_RATE:
case INBOUND_VIDEO_RATE:
if (streamRefreshHandlers[obj.mediaSessionId]) {
obj.status = data.message;
streamRefreshHandlers[obj.mediaSessionId](obj);
}
break;
default:
//logger.info(LOG_PREFIX, "Unknown server message " + data.message);
}
};
}
//WebSocket send helper
function send(message, data) {
wsConnection.send(JSON.stringify({
message: message,
data: [data]
}));
}
//Session status update helper
function onSessionStatusChange(newStatus, obj) {
sessionStatus = newStatus;
if (sessionStatus == SESSION_STATUS.DISCONNECTED || sessionStatus == SESSION_STATUS.FAILED) {
// Stop pinging server #WCS-3410
wsPingSender.stop();
// Stop checking pings received #WCS-3410
wsPingReceiver.stop();
//remove streams
for (var prop in streamRefreshHandlers) {
if (streamRefreshHandlers.hasOwnProperty(prop) && typeof streamRefreshHandlers[prop] === 'function') {
streamRefreshHandlers[prop]({status: STREAM_STATUS.FAILED});
}
}
//remove session from list
delete sessions[id_];
}
if (callbacks[sessionStatus]) {
callbacks[sessionStatus](session, obj);
}
}
// Websocket periodic ping sender
function WSPingSender(interval) {
this.interval = interval || 0;
this.intervalId = null;
this.start = function() {
if (this.interval > 0) {
this.intervalId = setInterval(function() {
send("ping", null);
}, this.interval);
}
};
this.stop = function() {
if (this.intervalId) {
clearInterval(this.intervalId);
}
};
return(this);
}
// Websocket ping receive prober
function WSPingReceiver(receiveProbes, probesInterval) {
this.maxPings = receiveProbes || 0;
this.interval = probesInterval || 0;
this.intervalId = null;
this.pingsMissing = 0;
this.start = function() {
if (this.maxPings > 0 && this.interval > 0) {
let receiver = this;
this.intervalId = setInterval(function() {
receiver.checkPingsReceived();
}, this.interval);
}
};
this.stop = function() {
if (this.intervalId) {
clearInterval(this.intervalId);
}
this.pingsMissing = 0;
};
this.checkPingsReceived = function() {
this.pingsMissing++;
if (this.pingsMissing >= this.maxPings) {
this.failure();
}
};
this.success = function() {
this.pingsMissing = 0;
};
this.failure = function() {
logger.info(LOG_PREFIX, "Missing " + this.pingsMissing + " pings from server, connection seems to be down");
onSessionStatusChange(SESSION_STATUS.FAILED);
wsConnection.close();
};
return(this);
}
/**
* @callback sdpHook
* @param {Object} sdp Callback options
* @param {String} sdp.sdpString Sdp from the server
* @returns {String} sdp New sdp
*/
/**
* Create call.
*
* @param {Object} options Call options
* @param {string} options.callee Call remote party id
* @param {string=} options.visibleName Call caller visible name
* @param {Object} options.constraints Call constraints
* @param {string} options.mediaProvider MediaProvider type to use with this call
* @param {Boolean=} options.receiveAudio Receive audio
* @param {Boolean=} options.receiveVideo Receive video
* @param {Boolean=} options.cacheLocalResources Display will contain local video after call release
* @param {HTMLElement} options.localVideoDisplay Div element local video should be displayed in
* @param {HTMLElement} options.remoteVideoDisplay Div element remote video should be displayed in
* @param {Object=} options.custom User provided custom object that will be available in REST App code
* @param {string=} options.stripCodecs Comma separated strings of codecs which should be stripped from WebRTC SDP (ex. "SILK,G722")
* @param {Array<string>=} options.sipSDP Array of custom SDP params (ex. bandwidth (b=))
* @param {Array<string>=} options.sipHeaders Array of custom SIP headers
* @param {string=} options.videoContentHint Video content hint for browser ('motion' by default to maintain bitrate and fps), {@link Flashphoner.constants.CONTENT_HINT_TYPE}
* @param {Boolean=} options.useControls Use a standard HTML5 video controls (play, pause, fullscreen). May be a workaround for fullscreen mode to work in Safari 16
* @param {Object=} options.logger Call logger options
* @param {sdpHook} sdpHook The callback that handles sdp from the server
* @returns {Call} Call
* @throws {TypeError} Error if no options provided
* @throws {Error} Error if session state is not REGISTERED
* @memberof Session
* @inner
*/
var createCall = function (options) {
//check session state
if (sessionStatus !== SESSION_STATUS.REGISTERED && sessionStatus !== SESSION_STATUS.ESTABLISHED) {
throw new Error('Invalid session state ' + sessionStatus);
}
//check options
if (!options) {
throw new TypeError("options must be provided");
}
// Set call logger #WCS-2434
var callLogger = createLogger(options.logger, sessionLogger);
// Override logger for all low level operations
var logger = callLogger;
var login = (appKey == 'clickToCallApp') ? '' : cConfig.sipLogin;
var caller_ = (options.incoming) ? options.caller : login;
var callee_ = options.callee;
var visibleName_ = options.visibleName || login;
var id_ = options.callId || uuid_v1();
var mediaProvider = options.mediaProvider || getMediaProviders()[0];
var mediaConnection;
var localDisplay = options.localVideoDisplay;
var remoteDisplay = options.remoteVideoDisplay;
var info_;
var errorInfo_;
// Constraints
if (options.constraints) {
var constraints = options.constraints;
}
if (options.disableConstraintsNormalization) {
var disableConstraintsNormalization = options.disableConstraintsNormalization;
}
var audioOutputId;
var audioProperty = getConstraintsProperty(constraints, CONSTRAINT_AUDIO, undefined);
if (typeof audioProperty === 'object') {
audioOutputId = getConstraintsProperty(audioProperty, CONSTRAINT_AUDIO_OUTPUT_ID, 0);
}
var stripCodecs = options.stripCodecs || [];
// Receive media
var receiveAudio = (typeof options.receiveAudio !== 'undefined') ? options.receiveAudio : true;
var receiveVideo = (typeof options.receiveVideo !== 'undefined') ? options.receiveVideo : true;
var cacheLocalResources = options.cacheLocalResources;
var status_ = CALL_STATUS.NEW;
var callbacks = {};
var hasTransferredCall = false;
var sdpHook = options.sdpHook;
var sipSDP = options.sipSDP;
var sipHeaders = options.sipHeaders;
var videoContentHint = options.videoContentHint;
var useControls = options.useControls;
var minBitrate = getConstraintsProperty(constraints, CONSTRAINT_VIDEO_MIN_BITRATE, 0);
var maxBitrate = getConstraintsProperty(constraints, CONSTRAINT_VIDEO_MAX_BITRATE, 0);
/**
* Represents sip call.
*
* @namespace Call
* @see Session~createCall
*/
var call = {};
callRefreshHandlers[id_] = function (callInfo, sdp, codec, transfer) {
if (transfer) {
if (!mediaConnections[id_]) {
mediaConnections[id_] = mediaConnection;
}
if (transfer.status == "COMPLETED") {
delete mediaConnections[id_];
}
return;
}
//transferred call
if (!mediaConnection && Object.keys(mediaConnections).length != 0) {
for (var mc in mediaConnections) {
mediaConnection = mediaConnections[mc];
hasTransferredCall = true;
delete mediaConnections[mc];
}
}
//set audio codec (Flash only)
if (codec) {
if (mediaProvider == "Flash") {
mediaConnection.changeAudioCodec(codec.name);
}
return;
}
//set remote sdp
if (sdp && sdp !== '') {
sdp = sdpHookHandler(sdp, sdpHook);
// Adjust publishing bitrate #WCS-4013
sdp = util.setPublishingBitrate(sdp, mediaConnection, minBitrate, maxBitrate);
mediaConnection.setRemoteSdp(sdp, hasTransferredCall, id_).then(function () {});
return;
}
var event = callInfo.status;
status_ = event;
//release call
if (event == CALL_STATUS.FAILED || event == CALL_STATUS.FINISH ||
event == CALL_STATUS.BUSY) {
delete calls[id_];
delete callRefreshHandlers[id_];
if (Object.keys(calls).length == 0) {
if (mediaConnection)
mediaConnection.close(cacheLocalResources);
}
}
//fire call event
if (callbacks[event]) {
callbacks[event](call);
}
};
/**
* Initiate outgoing call.
*
* @throws {Error} Error if call status is not {@link Flashphoner.constants.CALL_STATUS.NEW}
* @memberof Call
* @name call
* @inner
*/
var call_ = function () {
if (status_ !== CALL_STATUS.NEW) {
throw new Error("Invalid call state");
}
status_ = CALL_STATUS.PENDING;
var hasAudio = true;
//get access to camera
MediaProvider[mediaProvider].getMediaAccess(constraints, localDisplay, disableConstraintsNormalization).then(function () {
if (status_ == CALL_STATUS.FAILED) {
//call failed while we were waiting for media access, release media
if (!cacheLocalResources) {
releaseLocalMedia(localDisplay, mediaProvider);
}
return;
}
//create mediaProvider connection
MediaProvider[mediaProvider].createConnection({
id: id_,
localDisplay: localDisplay,
remoteDisplay: remoteDisplay,
authToken: authToken,
mainUrl: urlServer,
flashProto: flashProto,
flashPort: flashPort,
bidirectional: true,
login: login,
constraints: constraints,
connectionConfig: mediaOptions,
audioOutputId: audioOutputId,
videoContentHint: videoContentHint,
useControls: useControls,
logger: logger
}).then(function (newConnection) {
mediaConnection = newConnection;
return mediaConnection.createOffer({
sendAudio: true,
sendVideo: true,
receiveAudio: receiveAudio,
receiveVideo: receiveVideo,
stripCodecs: stripCodecs
});
}).then(function (offer) {
send("call", {
callId: id_,
incoming: false,
hasVideo: offer.hasVideo,
hasAudio: offer.hasAudio,
status: status_,
mediaProvider: mediaProvider,
sdp: offer.sdp,
sipSDP: sipSDP,
caller: login,
callee: callee_,
custom: options.custom,
visibleName: visibleName_
});
});
}).catch(function (error) {
logger.error(LOG_PREFIX, error);
status_ = CALL_STATUS.FAILED;
info_ = ERROR_INFO.LOCAL_ERROR;
errorInfo_ = error.message;
callRefreshHandlers[id_]({status: CALL_STATUS.FAILED});
hangup();
});
};
/**
* Hangup call.
*
* @memberof Call
* @inner
*/
var hangup = function () {
if (status_ == CALL_STATUS.NEW) {
callRefreshHandlers[id_]({status: CALL_STATUS.FAILED});
return;
} else if (status_ == CALL_STATUS.PENDING) {
if (!cacheLocalResources) {
releaseLocalMedia(localDisplay, mediaProvider);
}
callRefreshHandlers[id_]({status: CALL_STATUS.FAILED});
if (options.incoming) {
send("hangup", {
callId: id_
});
}
return;
}
send("hangup", {
callId: id_
});
//free media provider
if (mediaConnection) {
mediaConnection.close(cacheLocalResources);
}
};
/**
* @callback sdpHook
* @param {Object} sdp Callback options
* @param {String} sdp.sdpString Sdp from the server
* @returns {String} sdp New sdp
*/
/**
* Answer incoming call.
* @param {Object} answerOptions Call options
* @param {HTMLElement} answerOptions.localVideoDisplay Div element local video should be displayed in
* @param {HTMLElement} answerOptions.remoteVideoDisplay Div element remote video should be displayed in
* @param {Boolean=} answerOptions.receiveAudio Receive audio
* @param {Boolean=} answerOptions.receiveVideo Receive video
* @param {String=} answerOptions.constraints Answer call with constraints
* @param {String=} answerOptions.stripCodecs Comma separated string of codecs which should be stripped from WebRTC SDP (ex. "SILK,G722")
* @param {Array<string>=} answerOptions.sipSDP Array of custom SDP params (ex. bandwidth (b=))
* @param {Array<string>=} answerOptions.sipHeaders Array of custom SIP headers
* @param {sdpHook} sdpHook The callback that handles sdp from the server
* @throws {Error} Error if call status is not {@link Flashphoner.constants.CALL_STATUS.NEW}
* @memberof Call
* @name call
* @inner
*/
var answer = function (answerOptions) {
if (status_ !== CALL_STATUS.NEW && status_ !== CALL_STATUS.RING) {
throw new Error("Invalid call state");
}
localDisplay = answerOptions.localVideoDisplay;
remoteDisplay = answerOptions.remoteVideoDisplay;
constraints = answerOptions.constraints || getDefaultMediaConstraints();
status_ = CALL_STATUS.PENDING;
var sdp;
var sdpHook = answerOptions.sdpHook;
var minBitrate = getConstraintsProperty(constraints, CONSTRAINT_VIDEO_MIN_BITRATE, 0);
var maxBitrate = getConstraintsProperty(constraints, CONSTRAINT_VIDEO_MAX_BITRATE, 0);
sipSDP = answerOptions.sipSDP;
sipHeaders = answerOptions.sipHeaders;
if (!remoteSdpCache[id_]) {
logger.error(LOG_PREFIX, "No remote sdp available");
throw new Error("No remote sdp available");
} else {
sdp = sdpHookHandler(remoteSdpCache[id_], sdpHook);
// Adjust publishing bitrate #WCS-4013
sdp = util.setPublishingBitrate(sdp, null, minBitrate, maxBitrate);
delete remoteSdpCache[id_];
}
if (util.SDP.matchPrefix(sdp, "m=video").length == 0) {
constraints.video = false;
}
var stripCodecs = answerOptions.stripCodecs || [];
var hasAudio = true;
//get access to camera
MediaProvider[mediaProvider].getMediaAccess(constraints, localDisplay, disableConstraintsNormalization).then(function () {
if (status_ == CALL_STATUS.FAILED) {
//call failed while we were waiting for media access, release media
if (!cacheLocalResources) {
releaseLocalMedia(localDisplay, mediaProvider);
}
return;
}
//create mediaProvider connection
MediaProvider[mediaProvider].createConnection({
id: id_,
localDisplay: localDisplay,
remoteDisplay: remoteDisplay,
authToken: authToken,
mainUrl: urlServer,
flashProto: flashProto,
flashPort: flashPort,
bidirectional: true,
login: cConfig.sipLogin,
constraints: constraints,
connectionConfig: mediaOptions,
audioOutputId: audioOutputId,
useControls: useControls
}).then(function (newConnection) {
mediaConnection = newConnection;
// Set publishing bitrate via sender encodings if SDP feature is not supported
mediaConnection.setPublishingBitrate(minBitrate, maxBitrate);
return mediaConnection.setRemoteSdp(sdp);
}).then(function () {
return mediaConnection.createAnswer({
receiveAudio: options.receiveAudio,
receiveVideo: options.receiveVideo,
stripCodecs: stripCodecs
});
}).then(function (sdp) {
if (status_ != CALL_STATUS.FINISH && status_ != CALL_STATUS.FAILED) {
send("answer", {
callId: id_,
incoming: true,
hasVideo: true,
hasAudio: hasAudio,
status: status_,
mediaProvider: mediaProvider,
sdp: sdp,
sipSDP: sipSDP,
caller: cConfig.login,
callee: callee_,
custom: options.custom
});
} else {
hangup();
}
});
}).catch(function (error) {
logger.error(LOG_PREFIX, error);
info_ = ERROR_INFO.LOCAL_ERROR;
errorInfo_ = error.message;
status_ = CALL_STATUS.FAILED;
callRefreshHandlers[id_]({status: CALL_STATUS.FAILED});
});
};
/**
* Get call status.
*
* @returns {string} One of {@link Flashphoner.constants.CALL_STATUS}
* @memberof Call
* @inner
*/
var status = function () {
return status_;
};
/**
* Get call id.
*
* @returns {string} Call id
* @memberof Call
* @inner
*/
var id = function () {
return id_;
};
/**
* Get caller id.
*
* @returns {string} Caller id
* @memberof Call
* @inner
*/
var caller = function () {
return caller_;
};
/**
* Get callee id.
*
* @returns {string} Callee id
* @memberof Call
* @inner
*/
var callee = function () {
return callee_;
};
/**
* Get caller visible name.
*
* @returns {string} Caller visible name
* @memberof Call
* @inner
*/
var visibleName = function () {
return visibleName_;
};
/**
* Media controls
*/
/**
* Set other oupout audio device
*
* @param {string} id Id of output device
* @memberof Call
* @inner
*/
var setAudioOutputId = function(id) {
audioOutputId = id;
if (mediaConnection && mediaConnection.setAudioOutputId) {
return mediaConnection.setAudioOutputId(id);
}
};
/**
* Set volume of remote media
*
* @param {number} volume Volume between 0 and 100
* @memberof Call
* @inner
*/
var setVolume = function (volume) {
if (mediaConnection) {
mediaConnection.setVolume(volume);
}
};
/**
* Get current volume
*
* @returns {number} Volume or -1 if audio is not available
* @memberof Call
* @inner
*/
var getVolume = function () {
if (mediaConnection) {
return mediaConnection.getVolume();
}
return -1;
};
/**
* Mute outgoing audio
*
* @memberof Call
* @inner
*/
var muteAudio = function () {
if (mediaConnection) {
mediaConnection.muteAudio();
}
};
/**
* Unmute outgoing audio
*
* @memberof Call
* @inner
*/
var unmuteAudio = function () {
if (mediaConnection) {
mediaConnection.unmuteAudio();
}
};
/**
* Check outgoing audio mute state
*
* @returns {boolean} True if audio is muted or not available
* @memberof Call
* @inner
*/
var isAudioMuted = function () {
if (mediaConnection) {
return mediaConnection.isAudioMuted();
}
return true;
};
/**
* Mute outgoing video
*
* @memberof Call
* @inner
*/
var muteVideo = function () {
if (mediaConnection) {
mediaConnection.muteVideo();
}
};
/**
* Unmute outgoing video
*
* @memberof Call
* @inner
*/
var unmuteVideo = function () {
if (mediaConnection) {
mediaConnection.unmuteVideo();
}
};
/**
* Check outgoing video mute state
*
* @returns {boolean} True if video is muted or not available
* @memberof Call
* @inner
*/
var isVideoMuted = function () {
if (mediaConnection) {
return mediaConnection.isVideoMuted();
}
return true;
};
/**
* @callback callbackFn
* @param {Object} result
*/
/**
* Get statistics
*
* @param {callbackFn} callbackFn The callback that handles response
* @param {Boolean} nativeStats If true, use native browser statistics
* @returns {Object} Call audio\video statistics
* @memberof Call
* @inner
*/
var getStats = function (callbackFn, nativeStats) {
if (mediaConnection) {
mediaConnection.getStats(callbackFn, nativeStats);
}
};
/**
* Place call on hold
*
* @memberof Call
* @inner
*/
var hold = function () {
send("hold", {callId: id_});
}
/**
* Place call on hold for transfer
*
* @memberof Call
* @inner
*/
var holdForTransfer = function () {
send("hold", {callId: id_, holdForTransfer: true});
}
/**
* Unhold the call
*
* @memberof Call
* @inner
*/
var unhold = function () {
send("unhold", {callId: id_});
}
/**
* Send DTMF
*
* @param {number} number Number
* @param {string=} type DTMF Type (RFC2833, INFO, INFO_RELAY)
* @memberof Call
* @inner
*/
var sendDTMF = function (number, type) {
send("sendDtmf", {
callId: id_,
type: type || "RFC2833",
dtmf: number
});
}
/**
* Transfer call
*
* @param {String} traget Transfer target
* @memberof Call
* @inner
*/
var transfer = function (target) {
send("transfer", {callId: id_, target: target});
}
/**
* Call event callback.
*
* @callback Call~eventCallback
* @param {Call} call Call that corresponds to the event
*/
/**
* Add call event callback.
*
* @param {string} event One of {@link Flashphoner.constants.CALL_STATUS} events
* @param {Call~eventCallback} callback Callback function
* @returns {Call} Call callback was attached to
* @throws {TypeError} Error if event is not specified
* @throws {Error} Error if callback is not a valid function
* @memberof Call
* @inner
*/
var on = function (event, callback) {
if (!event) {
throw new TypeError("Event can't be null");
}
if (!callback || typeof callback !== 'function') {
throw new Error("Callback needs to be a valid function");
}
callbacks[event] = callback;
return call;
};
/**
* Switch camera in real-time.
* Works only with WebRTC
*
* @memberOf Call
* @inner
* @throws {Error} Error if call status is not {@link Flashphoner.constants.CALL_STATUS.ESTABLISHED} and not {@link Flashphoner.constants.CALL_STATUS.HOLD}
*/
var switchCam = function(deviceId) {
if(status_ !== CALL_STATUS.ESTABLISHED && !constraints.video && status_ !== CALL_STATUS.HOLD){
throw new Error('Invalid call state');
}
return mediaConnection.switchCam(deviceId);
};
/**
* Switch mic in real-time.
* Works only with WebRTC
*
* @memberOf Call
* @inner
* @throws {Error} Error if call status is not {@link Flashphoner.constants.CALL_STATUS.ESTABLISHED} and not {@link Flashphoner.constants.CALL_STATUS.HOLD}
*/
var switchMic = function(deviceId) {
if(status_ !== CALL_STATUS.ESTABLISHED && status_ !== CALL_STATUS.HOLD){
throw new Error('Invalid call state');
}
return mediaConnection.switchMic(deviceId);
};
/**
* Switch to screen in real-time.
* Works only with WebRTC
*
* @param {String} source Screen sharing source (for firefox)
* @param {Boolean} woExtension Screen sharing without extension (for chrome)
* @memberOf Call
* @inner
* @throws {Error} Error if stream status is not {@link Flashphoner.constants.STREAM_STATUS.PUBLISHING}
*/
var switchToScreen = function (source, woExtension) {
if(status_ !== CALL_STATUS.ESTABLISHED && status_ !== CALL_STATUS.HOLD){
throw new Error('Invalid call state');
}
return mediaConnection.switchToScreen(source, woExtension);
};
/**
* Switch to cam in real-time.
* Works only with WebRTC
*
* @memberOf Call
* @inner
* @throws {Error} Error if stream status is not {@link Flashphoner.constants.STREAM_STATUS.PUBLISHING}
*/
var switchToCam = function () {
if(status_ !== CALL_STATUS.ESTABLISHED && status_ !== CALL_STATUS.HOLD){
throw new Error('Invalid call state');
}
mediaConnection.switchToCam();
};
/**
* Get call info
* @returns {string} Info
* @memberof Call
* @inner
*/
var getInfo = function () {
return info_;
};
/**
* Get stream error info
* @returns {string} Error info
* @memberof Call
* @inner
*/
var getErrorInfo = function () {
return errorInfo_;
};
/**
* Get call logger
*
* @returns {Object} Logger
* @memberof Call
*/
var getLogger = function () {
return callLogger;
};
call.call = call_;
call.answer = answer;
call.hangup = hangup;
call.id = id;
call.getInfo = getInfo;
call.getErrorInfo = getErrorInfo;
call.status = status;
call.getStats = getStats;
call.setAudioOutputId = setAudioOutputId;
call.setVolume = setVolume;
call.getVolume = getVolume;
call.muteAudio = muteAudio;
call.unmuteAudio = unmuteAudio;
call.isAudioMuted = isAudioMuted;
call.muteVideo = muteVideo;
call.unmuteVideo = unmuteVideo;
call.isVideoMuted = isVideoMuted;
call.caller = caller;
call.callee = callee;
call.visibleName = visibleName;
call.hold = hold;
call.holdForTransfer = holdForTransfer;
call.unhold = unhold;
call.sendDTMF = sendDTMF;
call.transfer = transfer;
call.on = on;
call.switchCam = switchCam;
call.switchMic = switchMic;
call.switchToScreen = switchToScreen;
call.switchToCam = switchToCam;
call.getLogger = getLogger;
calls[id_] = call;
return call;
};
/**
* @callback sdpHook
* @param {Object} sdp Callback options
* @param {String} sdp.sdpString Sdp from the server
* @returns {String} sdp New sdp
*/
/**
* Create stream.
*
* @param {Object} options Stream options
* @param {string} options.name Stream name
* @param {Object=} options.constraints Stream constraints
* @param {Boolean|Object} [options.constraints.audio=true] Specifies if published stream should have audio. Played stream always should have audio: the property should not be set to false in that case.
* @param {string=} [options.constraints.audio.outputId] Set width to publish or play stream with this value
* @param {Boolean|Object} [options.constraints.video=true] Specifies if published or played stream should have video, or sets video constraints
* @param {Integer} [options.constraints.video.width=0] Set width to publish or play stream with this value
* @param {Integer} [options.constraints.video.height=0] Set height to publish or play stream with this value
* @param {Integer} [options.constraints.video.bitrate=0] DEPRECATED FOR PUBLISH: Set bitrate to publish or play stream with this value
* @param {Integer} [options.constraints.video.minBitrate=0] Set minimal bitrate to publish stream with this value
* @param {Integer} [options.constraints.video.maxBitrate=0] Set maximal bitrate to publish stream with this value
* @param {Integer} [options.constraints.video.quality=0] Set quality to play stream with this value
* @param {MediaStream} [options.constraints.customStream] Set a MediaStream for publish stream from canvas.
* @param {Boolean=} options.receiveAudio DEPRECATED: Receive audio
* @param {Boolean=} options.receiveVideo DEPRECATED: Receive video
* @param {Integer=} options.playWidth DEPRECATED: Set width to play stream with this value
* @param {Integer=} options.playHeight DEPRECATED: Set height to play stream with this value
* @param {string=} options.mediaProvider MediaProvider type to use with this stream
* @param {Boolean} [options.record=false] Enable stream recording
* @param {Boolean=} options.cacheLocalResources Display will contain local video after stream release
* @param {HTMLElement} options.display Div element stream should be displayed in
* @param {Object=} options.custom User provided custom object that will be available in REST App code
* @param {Integer} [options.flashBufferTime=0] Specifies how long to buffer messages before starting to display the stream (Flash-only)
* @param {string=} options.stripCodecs Comma separated string of codecs which should be stripped from WebRTC SDP (ex. "H264,PCMA,PCMU,G722")
* @param {string=} options.rtmpUrl Rtmp url stream should be forwarded to
* @param {Object=} options.mediaConnectionConstraints Stream specific constraints for underlying RTCPeerConnection
* @param {Boolean=} options.flashShowFullScreenButton Show full screen button in flash
* @param {string=} options.transport Transport to be used by server for WebRTC media, {@link Flashphoner.constants.TRANSPORT_TYPE}
* @param {Boolean=} options.cvoExtension Enable rtp video orientation extension
* @param {Integer=} options.playoutDelay Time delay between network reception of media and playout
* @param {string=} options.useCanvasMediaStream EXPERIMENTAL: when publish bind browser's media stream to the canvas. It can be useful for image filtering
* @param {string=} options.videoContentHint Video content hint for browser ('motion' by default to maintain bitrate and fps), {@link Flashphoner.constants.CONTENT_HINT_TYPE}
* @param {Boolean=} options.unmutePlayOnStart Unmute playback on start. May be used after user gesture only, so set 'unmutePlayOnStart: false' for autoplay
* @param {Boolean=} options.useControls Use a standard HTML5 video controls (play, pause, fullscreen). May be a workaround for fullscreen mode to work in Safari 16
* @param {Object=} options.logger Stream logger options
* @param {sdpHook} sdpHook The callback that handles sdp from the server
* @returns {Stream} Stream
* @throws {TypeError} Error if no options provided
* @throws {TypeError} Error if options.name is not specified
* @throws {Error} Error if session state is not ESTABLISHED
* @memberof Session
* @inner
*/
var createStream = function (options) {
//Array to transmit promises from stream.available() to streamRefreshHandlers
var availableCallbacks = [];
//check session state
if (sessionStatus !== SESSION_STATUS.ESTABLISHED) {
throw new Error('Invalid session state ' + sessionStatus);
}
//check options
if (!options) {
throw new TypeError("options must be provided");
}
if (!options.name) {
throw new TypeError("options.name must be provided");
}
// Set stream logger #WCS-2434
var streamLogger = createLogger(options.logger, sessionLogger);
// Override logger for all low level operations
var logger = streamLogger;
var clientKf = new KalmanFilter();
var serverKf = new KalmanFilter();
var id_ = uuid_v1();
var name_ = options.name;
var mediaProvider = options.mediaProvider || getMediaProviders()[0];
var mediaConnection;
var display = options.display;
// Constraints
if (options.constraints && Object.keys(options.constraints).length != 0) {
var constraints = options.constraints;
}
if (options.disableConstraintsNormalization) {
var disableConstraintsNormalization = options.disableConstraintsNormalization;
}
var mediaConnectionConstraints = options.mediaConnectionConstraints;
// Receive media
var receiveAudio;
var audioOutputId;
var audioProperty = getConstraintsProperty(constraints, CONSTRAINT_AUDIO, undefined);
if (typeof audioProperty === 'boolean') {
receiveAudio = audioProperty;
} else if (typeof audioProperty === 'object') {
receiveAudio = true;
var _stereo = getConstraintsProperty(audioProperty, CONSTRAINT_AUDIO_STEREO, 0);
var _bitrate = getConstraintsProperty(audioProperty, CONSTRAINT_AUDIO_BITRATE, 0);
var _fec = getConstraintsProperty(audioProperty, CONSTRAINT_AUDIO_FEC, 0);
audioOutputId = getConstraintsProperty(audioProperty, CONSTRAINT_AUDIO_OUTPUT_ID, 0);
var _codecOptions = "";
if (_bitrate) _codecOptions += "maxaveragebitrate=" + _bitrate + ";";
if (_stereo) _codecOptions += "stereo=1;sprop-stereo=1;";
if (_fec) _codecOptions += "useinbandfec=1;";
} else {
receiveAudio = (typeof options.receiveAudio !== 'undefined') ? options.receiveAudio : true;
}
var receiveVideo;
var videoProperty = getConstraintsProperty(constraints, CONSTRAINT_VIDEO, undefined);
if (typeof videoProperty === 'boolean') {
receiveVideo = videoProperty;
} else if (typeof videoProperty === 'object') {
receiveVideo = true;
} else {
receiveVideo = (typeof options.receiveVideo !== 'undefined') ? options.receiveVideo : true;
}
// Bitrate
var bitrate = getConstraintsProperty(constraints, CONSTRAINT_VIDEO_BITRATE, 0);
var minBitrate = getConstraintsProperty(constraints, CONSTRAINT_VIDEO_MIN_BITRATE, 0);
var maxBitrate = getConstraintsProperty(constraints, CONSTRAINT_VIDEO_MAX_BITRATE, 0);
// Quality
var quality = getConstraintsProperty(constraints, CONSTRAINT_VIDEO_QUALITY, 0);
if (quality > 100) quality = 100;
// Play resolution
var playWidth = (typeof options.playWidth !== 'undefined') ? options.playWidth : getConstraintsProperty(constraints, CONSTRAINT_VIDEO_WIDTH, 0);
var playHeight = (typeof options.playHeight !== 'undefined') ? options.playHeight : getConstraintsProperty(constraints, CONSTRAINT_VIDEO_HEIGHT, 0);
var stripCodecs = options.stripCodecs || [];
var resolution = {};
var published_ = false;
var record_ = options.record || false;
var recordFileName = null;
var cacheLocalResources = options.cacheLocalResources;
var status_ = STREAM_STATUS.NEW;
var rtmpUrl = options.rtmpUrl;
var info_;
var errorInfo_;
var remoteBitrate = -1;
var networkBandwidth = -1;
var sdpHook = options.sdpHook;
var transportType = options.transport;
var cvoExtension = options.cvoExtension;
var remoteVideo = options.remoteVideo;
//callbacks added using stream.on()
var callbacks = {};
var playoutDelay = options.playoutDelay;
var useCanvasMediaStream = options.useCanvasMediaStream;
var videoContentHint = options.videoContentHint;
var unmutePlayOnStart = options.unmutePlayOnStart;
var useControls = options.useControls;
var audioState_;
var videoState_;
var connectionQuality;
var videoBytes = 0;
/**
* Represents media stream.
*
* @namespace Stream
* @see Session~createStream
*/
var stream = {};
streamEventRefreshHandlers[id_] = function (streamEvent) {
if (streamEvent.type == STREAM_EVENT_TYPE.NOT_ENOUGH_BANDWIDTH) {
var info = streamEvent.payload.info.split("/");
remoteBitrate = info[0];
networkBandwidth = info[1];
} else if (streamEvent.type == STREAM_EVENT_TYPE.RESIZE) {
resolution.width = streamEvent.payload.streamerVideoWidth;
resolution.height = streamEvent.payload.streamerVideoHeight;
}
if (callbacks[STREAM_EVENT]) {
callbacks[STREAM_EVENT](streamEvent);
}
}
streamRefreshHandlers[id_] = function (streamInfo, sdp) {
//set remote sdp
if (sdp && sdp !== '') {
var _sdp = sdp;
if (_codecOptions) _sdp = util.SDP.writeFmtp(sdp, _codecOptions, "opus");
_sdp = sdpHookHandler(_sdp, sdpHook);
// Adjust publishing bitrate #WCS-4013
_sdp = util.setPublishingBitrate(_sdp, mediaConnection, minBitrate, maxBitrate);
mediaConnection.setRemoteSdp(_sdp).then(function () {});
return;
}
if (streamInfo.available != undefined) {
for (var i = 0; i < availableCallbacks.length; i++) {
info_ = streamInfo.reason;
if (streamInfo.available == "true") {
availableCallbacks[i].resolve(stream);
} else {
availableCallbacks[i].reject(stream);
}
}
availableCallbacks = [];
return;
}
var event = streamInfo.status;
if (event === INBOUND_VIDEO_RATE || event === OUTBOUND_VIDEO_RATE) {
detectConnectionQuality(event, streamInfo);
return;
}
if (event === STREAM_EVENT) {
if (!streamInfo.mediaSessionId)
streamInfo.mediaSessionId = id_;
streamEventRefreshHandlers[id_](streamInfo);
return;
}
//Deprecated. WCS-3228: RESIZE, SNAPSHOT_COMPLETE and NOT_ENOUGH_BANDWIDTH moved to STREAM_EVENT
if (event === STREAM_STATUS.RESIZE) {
resolution.width = streamInfo.streamerVideoWidth;
resolution.height = streamInfo.streamerVideoHeight;
} else if (event === STREAM_STATUS.SNAPSHOT_COMPLETE) {
} else if (event === STREAM_STATUS.NOT_ENOUGH_BANDWIDTH) {
var info = streamInfo.info.split("/");
remoteBitrate = info[0];
networkBandwidth = info[1];
} else {
status_ = event;
}
if (streamInfo.audioState)
audioState_ = streamInfo.audioState;
if (streamInfo.videoState)
videoState_ = streamInfo.videoState;
if (streamInfo.info)
info_ = streamInfo.info;
//release stream
if (event === STREAM_STATUS.FAILED || event === STREAM_STATUS.STOPPED ||
event === STREAM_STATUS.UNPUBLISHED) {
delete streams[id_];
delete streamRefreshHandlers[id_];
delete streamEventRefreshHandlers[id_];
if (mediaConnection) {
mediaConnection.close(cacheLocalResources);
}
}
if (record_ && typeof streamInfo.recordName !== 'undefined') {
recordFileName = streamInfo.recordName;
}
//fire stream event
if (callbacks[event]) {
callbacks[event](stream);
}
};
var detectConnectionQuality = function (event, streamInfo) {
if (disableConnectionQualityCalculation) {
return;
}
mediaConnection.getStats(function (stats) {
var bytesSentReceived = 0;
if (stats) {
if (event == OUTBOUND_VIDEO_RATE && stats.inboundStream && stats.inboundStream.video && stats.inboundStream.video.bytesReceived > 0) {
bytesSentReceived = stats.inboundStream.video.bytesReceived;
} else if (stats.outboundStream && stats.outboundStream.video && stats.outboundStream.video.bytesSent > 0) {
bytesSentReceived = stats.outboundStream.video.bytesSent;
} else {
return;
}
}
if (!videoBytes) {
videoBytes = bytesSentReceived;
return;
}
var currentVideoRate = ((bytesSentReceived - videoBytes) * 8);
if (currentVideoRate == 0) {
return;
}
var clientFiltered = clientKf.filter(currentVideoRate);
var serverFiltered = serverKf.filter(streamInfo.videoRate);
var videoRateDifference = Math.abs((serverFiltered - clientFiltered) / ((serverFiltered + clientFiltered) / 2)) * 100;
var currentQuality;
if (serverFiltered < LOW_VIDEO_RATE_THRESHOLD_BAD_PERFECT || clientFiltered < LOW_VIDEO_RATE_THRESHOLD_BAD_PERFECT) {
if (videoRateDifference > LOW_VIDEO_RATE_BAD_QUALITY_PERCENT_DIFFERENCE) {
currentQuality = CONNECTION_QUALITY.BAD;
} else {
currentQuality = CONNECTION_QUALITY.PERFECT;
}
} else {
if (videoRateDifference > VIDEO_RATE_BAD_QUALITY_PERCENT_DIFFERENCE) {
currentQuality = CONNECTION_QUALITY.BAD;
} else if (videoRateDifference > VIDEO_RATE_GOOD_QUALITY_PERCENT_DIFFERENCE) {
currentQuality = CONNECTION_QUALITY.GOOD;
} else {
currentQuality = CONNECTION_QUALITY.PERFECT;
}
}
if (callbacks[CONNECTION_QUALITY.UPDATE]) {
connectionQuality = currentQuality;
callbacks[CONNECTION_QUALITY.UPDATE](connectionQuality, clientFiltered, serverFiltered);
}
videoBytes = bytesSentReceived;
});
return;
};
/**
* Play stream.
*
* @throws {Error} Error if stream status is not {@link Flashphoner.constants.STREAM_STATUS.NEW}
* @memberof Stream
* @inner
*/
var play = function () {
logger.debug(LOG_PREFIX, "Play stream " + name_);
if (status_ !== STREAM_STATUS.NEW) {
throw new Error("Invalid stream state " + status_);
}
status_ = STREAM_STATUS.PENDING;
//create mediaProvider connection
MediaProvider[mediaProvider].createConnection({
id: id_,
display: display,
authToken: authToken,
mainUrl: urlServer,
flashProto: flashProto,
flashPort: flashPort,
flashBufferTime: options.flashBufferTime || 0,
flashShowFullScreenButton: options.flashShowFullScreenButton || false,
connectionConfig: mediaOptions,
connectionConstraints: mediaConnectionConstraints,
audioOutputId: audioOutputId,
remoteVideo: remoteVideo,
playoutDelay: playoutDelay,
unmutePlayOnStart: unmutePlayOnStart,
useControls: useControls,
logger: logger,
unmuteRequiredEvent: fireUnmuteEvent
}, streamRefreshHandlers[id_]).then(function (newConnection) {
mediaConnection = newConnection;
try {
streamRefreshHandlers[id_]({status: status_});
} catch(e) {
console.warn(e);
}
return mediaConnection.createOffer({
receiveAudio: receiveAudio,
receiveVideo: receiveVideo,
stripCodecs: stripCodecs,
stereo: _stereo
});
}).then(function (offer) {
logger.debug(LOG_PREFIX, "Offer SDP:\n" + offer.sdp);
//request stream with offer sdp from server
send("playStream", {
mediaSessionId: id_,
name: name_,
published: published_,
hasVideo: true,
hasAudio: true,
status: status_,
record: false,
width: playWidth,
height: playHeight,
mediaProvider: mediaProvider,
sdp: offer.sdp,
custom: options.custom,
bitrate: bitrate,
minBitrate: minBitrate,
maxBitrate: maxBitrate,
quality: quality,
constraints: constraints,
transport: transportType,
cvoExtension: cvoExtension
});
if (offer.player) {
offer.player.play(id_);
}
}).catch(function (error) {
//todo fire stream failed status
throw error;
});
};
/**
* Publish stream.
*
* @throws {Error} Error if stream status is not {@link Flashphoner.constants.STREAM_STATUS.NEW}
* @memberof Stream
* @inner
*/
var publish = function () {
logger.debug(LOG_PREFIX, "Publish stream " + name_);
if (status_ !== STREAM_STATUS.NEW) {
throw new Error("Invalid stream state " + status_);
}
status_ = STREAM_STATUS.PENDING;
published_ = true;
var hasAudio = true;
if (constraints && constraints.video && constraints.video.type && constraints.video.type == "screen") {
hasAudio = false;
}
//get access to camera
MediaProvider[mediaProvider].getMediaAccess(constraints, display, disableConstraintsNormalization, useCanvasMediaStream).then(function () {
if (status_ == STREAM_STATUS.FAILED) {
//stream failed while we were waiting for media access, release media
if (!cacheLocalResources) {
releaseLocalMedia(display, mediaProvider);
}
return;
}
//create mediaProvider connection
MediaProvider[mediaProvider].createConnection({
id: id_,
display: display,
authToken: authToken,
mainUrl: urlServer,
flashProto: flashProto,
flashPort: flashPort,
constraints: constraints,
connectionConfig: mediaOptions,
connectionConstraints: mediaConnectionConstraints,
customStream: constraints && constraints.customStream ? constraints.customStream : false,
videoContentHint: videoContentHint,
useControls: useControls,
logger: logger
}).then(function (newConnection) {
mediaConnection = newConnection;
return mediaConnection.createOffer({
stripCodecs: stripCodecs
});
}).then(function (offer) {
logger.debug(LOG_PREFIX, "Offer SDP:\n" + offer.sdp);
//publish stream with offer sdp to server
send("publishStream", {
mediaSessionId: id_,
name: name_,
published: published_,
hasVideo: offer.hasVideo,
hasAudio: offer.hasAudio,
status: status_,
record: record_,
mediaProvider: mediaProvider,
sdp: offer.sdp,
custom: options.custom,
bitrate: bitrate,
minBitrate: minBitrate,
maxBitrate: maxBitrate,
rtmpUrl: rtmpUrl,
constraints: constraints,
transport: transportType,
cvoExtension: cvoExtension
});
});
}).catch(function (error) {
logger.warn(LOG_PREFIX, error);
info_ = ERROR_INFO.LOCAL_ERROR;
errorInfo_ = error.message;
status_ = STREAM_STATUS.FAILED;
//fire stream event
if (callbacks[status_]) {
callbacks[status_](stream);
}
});
};
/**
* Switch camera in real-time.
* Works only with WebRTC
*
* @memberOf Stream
* @inner
* @throws {Error} Error if stream status is not {@link Flashphoner.constants.STREAM_STATUS.PUBLISHING}
*/
var switchCam = function(deviceId) {
if(status_ !== STREAM_STATUS.PUBLISHING){
throw new Error('Invalid stream state');
}
return mediaConnection.switchCam(deviceId);
};
/**
* Switch microphone in real-time.
* Works only with WebRTC
*
* @memberOf Stream
* @inner
* @throws {Error} Error if stream status is not {@link Flashphoner.constants.STREAM_STATUS.PUBLISHING}
*/
var switchMic = function(deviceId) {
if(status_ !== STREAM_STATUS.PUBLISHING){
throw new Error('Invalid stream state');
}
return mediaConnection.switchMic(deviceId);
};
/**
* Switch to screen in real-time.
* Works only with WebRTC
*
* @param {String} source Screen sharing source (for firefox)
* @param {Boolean} woExtension Screen sharing without extension (for chrome)
* @memberOf Stream
* @inner
* @throws {Error} Error if stream status is not {@link Flashphoner.constants.STREAM_STATUS.PUBLISHING}
*/
var switchToScreen = function (source, woExtension) {
if(status_ !== STREAM_STATUS.PUBLISHING){
throw new Error('Invalid stream state');
}
return mediaConnection.switchToScreen(source, woExtension);
};
/**
* Switch to cam in real-time.
* Works only with WebRTC
*
* @memberOf Stream
* @inner
* @throws {Error} Error if stream status is not {@link Flashphoner.constants.STREAM_STATUS.PUBLISHING}
*/
var switchToCam = function () {
if(status_ !== STREAM_STATUS.PUBLISHING){
throw new Error('Invalid stream state');
}
mediaConnection.switchToCam();
};
/**
* Send data from published stream.
*
* @param {Object} payload Any object
* @throws {Error} Error if stream status is not {@link Flashphoner.constants.STREAM_STATUS.PUBLISHING}
* @memberof Stream
* @inner
*/
var sendData = function (payload) {
if(status_ !== STREAM_STATUS.PUBLISHING){
throw new Error('Invalid stream state');
}
sendStreamEvent(STREAM_EVENT_TYPE.DATA, payload);
};
/**
* Unmute remote audio
*
* @memberOf Stream
* @inner
*/
var unmuteRemoteAudio = function () {
if(mediaConnection && mediaProvider != 'Flash') {
mediaConnection.unmuteRemoteAudio();
}
};
/**
* Mute remote audio
*
* @memberOf Stream
* @inner
*/
var muteRemoteAudio = function () {
if(mediaConnection && mediaProvider != 'Flash') {
mediaConnection.muteRemoteAudio();
}
};
/**
* Is remote audio muted
*
* @memberOf Stream
* @inner
*/
var isRemoteAudioMuted = function () {
if(mediaConnection && mediaProvider != 'Flash') {
return mediaConnection.isRemoteAudioMuted();
}
return false;
};
/**
* Set Microphone Gain
*
* @memberOf Stream
* @inner
* @throws {Error} Error if stream status is not {@link Flashphoner.constants.STREAM_STATUS.PUBLISHING}
*/
var setMicrophoneGain = function (volume) {
if(status_ !== STREAM_STATUS.PUBLISHING){
throw new Error('Invalid stream state');
}
mediaConnection.setMicrophoneGain(volume);
};
/**
* Stop stream.
*
* @memberof Stream
* @inner
*/
var stop = function () {
logger.debug(LOG_PREFIX, "Stop stream " + name_);
if (status_ == STREAM_STATUS.NEW) {
//trigger FAILED status
streamRefreshHandlers[id_]({status: STREAM_STATUS.FAILED});
return;
} else if (status_ == STREAM_STATUS.PENDING) {
logger.warn(LOG_PREFIX, "Stopping stream before server response " + id_);
setTimeout(stop, 200);
return;
} else if (status_ == STREAM_STATUS.FAILED) {
logger.warn(LOG_PREFIX, "Stream status FAILED");
return;
}
if (published_) {
send("unPublishStream", {
mediaSessionId: id_,
name: name_,
published: published_,
hasVideo: true,
hasAudio: true,
status: status_,
record: false
});
} else {
send("stopStream", {
mediaSessionId: id_,
name: name_,
published: published_,
hasVideo: true,
hasAudio: true,
status: status_,
record: false
});
}
//free media provider
if (mediaConnection) {
mediaConnection.close(cacheLocalResources);
}
};
/**
* Request remote stream snapshot.
* @throws {Error} Error if stream status is not {@link Flashphoner.constants.STREAM_STATUS.NEW}
* @memberof Stream
* @inner
*/
var snapshot = function () {
logger.debug(LOG_PREFIX, "Request snapshot, stream " + name_);
if (status_ !== STREAM_STATUS.NEW && status_ !== STREAM_STATUS.PLAYING && status_ !== STREAM_STATUS.PUBLISHING) {
throw new Error("Invalid stream state");
}
send("snapshot", {
name: name_,
mediaSessionId: id_
});
};
/**
* Get stream status.
*
* @returns {string} One of {@link Flashphoner.constants.STREAM_STATUS}
* @memberof Stream
* @inner
*/
var status = function () {
return status_;
};
/**
* Get stream id.
*
* @returns {string} Stream id
* @memberof Stream
* @inner
*/
var id = function () {
return id_;
};
/**
* Get stream name.
*
* @returns {string} Stream name
* @memberof Stream
* @inner
*/
var name = function () {
return name_;
};
/**
* Is stream published.
*
* @returns {Boolean} True if stream published, otherwise false
* @memberof Stream
* @inner
*/
var published = function () {
return published_;
};
/**
* Get record file name
* @returns {string} File name
* @memberof Stream
* @inner
*/
var getRecordInfo = function () {
return recordFileName;
};
/**
* Get stream info
* @returns {string} Info
* @memberof Stream
* @inner
*/
var getInfo = function () {
return info_;
};
/**
* Get stream error info
* @returns {string} Error info
* @memberof Stream
* @inner
*/
var getErrorInfo = function () {
return errorInfo_;
};
/**
* Get stream video size
* @returns {Object} Video size
* @memberof Stream
* @inner
*/
var videoResolution = function () {
if (!published_) {
return resolution;
} else {
throw new Error("This function available only on playing stream");
}
};
/**
* Media controls
*/
/**
* Set other oupout audio device
*
* @param {string} id Id of output device
* @memberof Call
* @inner
*/
var setAudioOutputId = function(id) {
audioOutputId = id;
if (mediaConnection && mediaConnection.setAudioOutputId) {
return mediaConnection.setAudioOutputId(id);
}
};
/**
* Set volume of remote media
*
* @param {number} volume Volume between 0 and 100
* @memberof Stream
* @inner
*/
var setVolume = function (volume) {
if (mediaConnection) {
mediaConnection.setVolume(volume);
}
};
/**
* Get current volume
*
* @returns {number} Volume or -1 if audio is not available
* @memberof Stream
* @inner
*/
var getVolume = function () {
if (mediaConnection) {
return mediaConnection.getVolume();
}
return -1;
};
function sendStreamEvent(type, payload) {
send("sendStreamEvent", {
mediaSessionId: id_,
type: type,
payload: payload
});
}
/**
* Mute outgoing audio
*
* @memberof Stream
* @inner
*/
var muteAudio = function () {
if (mediaConnection) {
mediaConnection.muteAudio();
sendStreamEvent(STREAM_EVENT_TYPE.AUDIO_MUTED);
}
};
/**
* Unmute outgoing audio
*
* @memberof Stream
* @inner
*/
var unmuteAudio = function () {
if (mediaConnection) {
mediaConnection.unmuteAudio();
sendStreamEvent(STREAM_EVENT_TYPE.AUDIO_UNMUTED);
}
};
/**
* Check outgoing audio mute state
*
* @returns {boolean} True if audio is muted or not available
* @memberof Stream
* @inner
*/
var isAudioMuted = function () {
if (mediaConnection) {
return mediaConnection.isAudioMuted();
}
return true;
};
/**
* Mute outgoing video
*
* @memberof Stream
* @inner
*/
var muteVideo = function () {
if (mediaConnection) {
mediaConnection.muteVideo();
sendStreamEvent(STREAM_EVENT_TYPE.VIDEO_MUTED);
}
};
/**
* Unmute outgoing video
*
* @memberof Stream
* @inner
*/
var unmuteVideo = function () {
if (mediaConnection) {
mediaConnection.unmuteVideo();
sendStreamEvent(STREAM_EVENT_TYPE.VIDEO_UNMUTED);
}
};
/**
* Check outgoing video mute state
*
* @returns {boolean} True if video is muted or not available
* @memberof Stream
* @inner
*/
var isVideoMuted = function () {
if (mediaConnection) {
return mediaConnection.isVideoMuted();
}
return true;
};
/**
* Get statistics
*
* @param {callbackFn} callbackFn The callback that handles response
* @param {Boolean} nativeStats If true, use native browser statistics
* @returns {Object} Stream audio\video statistics
* @memberof Stream
* @inner
*/
var getStats = function (callbackFn, nativeStats) {
if (mediaConnection) {
mediaConnection.getStats(callbackFn, nativeStats);
}
};
/**
* Get remote bitrate reported by server, works only for subscribe Stream
*
* @returns {number} Remote bitrate in bps or -1
* @memberof Stream
* @inner
*/
var getRemoteBitrate = function () {
return remoteBitrate;
};
/**
* Get network bandwidth reported by server, works only for subscribe Stream
*
* @returns {number} Network bandwidth in bps or -1
* @memberof Stream
* @inner
*/
var getNetworkBandwidth = function () {
return networkBandwidth;
};
/**
* Get audio state (muted)
*
* @returns AudioState
* @memberof Stream
* @inner
*/
var getAudioState = function () {
return audioState_;
};
/**
* Get video state (muted)
*
* @returns VideoState
* @memberof Stream
* @inner
*/
var getVideoState = function () {
return videoState_;
};
/**
* Request full screen for player stream
* @memberof Stream
* @inner
*/
var fullScreen = function () {
if (published()) {
logger.warn(LOG_PREFIX, "Full screen is allowed only for played streams");
} else {
if (mediaConnection)
mediaConnection.fullScreen();
}
};
/**
* Stream status event callback.
*
* @callback Stream~eventCallback
* @param {Stream} stream Stream that corresponds to the event
*/
/**
* Add stream status event callback.
*
* @param {string} event One of {@link Flashphoner.constants.STREAM_STATUS} events
* @param {Stream~eventCallback} callback Callback function
* @returns {Stream} Stream callback was attached to
* @throws {TypeError} Error if event is not specified
* @throws {Error} Error if callback is not a valid function
* @memberof Stream
* @inner
*/
var on = function (event, callback) {
if (!event) {
throw new TypeError("Event can't be null");
}
if (!callback || typeof callback !== 'function') {
throw new Error("Callback needs to be a valid function");
}
callbacks[event] = callback;
return stream;
};
/**
* Сhecks the availability of stream on the server
*
* @returns {Promise} Resolves if is stream available, otherwise rejects
* @memberof Stream
* @inner
*/
var available = function(){
return new Promise(function(resolve, reject){
send("availableStream", {
mediaSessionId: id_,
name: name_
});
var promise = {};
promise.resolve = resolve;
promise.reject = reject;
availableCallbacks.push(promise);
});
};
/**
* Get stream logger
*
* @returns {Object} Logger
* @memberof Stream
*/
var getLogger = function () {
return streamLogger;
};
var fireUnmuteEvent = function() {
if (isRemoteAudioMuted()) {
if (streamRefreshHandlers[id_] && typeof streamRefreshHandlers[id_] === 'function') {
streamRefreshHandlers[id_]({status: STREAM_EVENT, type: STREAM_EVENT_TYPE.UNMUTE_REQUIRED});
}
}
};
stream.play = play;
stream.publish = publish;
stream.stop = stop;
stream.id = id;
stream.status = status;
stream.name = name;
stream.published = published;
stream.getRecordInfo = getRecordInfo;
stream.getInfo = getInfo;
stream.getErrorInfo = getErrorInfo;
stream.videoResolution = videoResolution;
stream.setAudioOutputId = setAudioOutputId;
stream.setVolume = setVolume;
stream.unmuteRemoteAudio = unmuteRemoteAudio;
stream.muteRemoteAudio = muteRemoteAudio;
stream.isRemoteAudioMuted = isRemoteAudioMuted;
stream.setMicrophoneGain = setMicrophoneGain;
stream.getVolume = getVolume;
stream.muteAudio = muteAudio;
stream.unmuteAudio = unmuteAudio;
stream.isAudioMuted = isAudioMuted;
stream.muteVideo = muteVideo;
stream.unmuteVideo = unmuteVideo;
stream.isVideoMuted = isVideoMuted;
stream.getStats = getStats;
stream.snapshot = snapshot;
stream.getAudioState = getAudioState;
stream.getVideoState = getVideoState;
stream.getNetworkBandwidth = getNetworkBandwidth;
stream.getRemoteBitrate = getRemoteBitrate;
stream.fullScreen = fullScreen;
stream.on = on;
stream.available = available;
stream.switchCam = switchCam;
stream.switchMic = switchMic;
stream.switchToScreen = switchToScreen;
stream.switchToCam = switchToCam;
stream.sendData = sendData;
stream.getLogger = getLogger;
streams[id_] = stream;
return stream;
};
/**
* Disconnect session.
*
* @memberof Session
* @inner
*/
var disconnect = function () {
if (wsConnection) {
wsConnection.close();
}
};
/**
* Get session id
*
* @returns {string} session id
* @memberof Session
* @inner
*/
var id = function () {
return id_;
};
/**
* Get server address
*
* @returns {string} Server url
* @memberof Session
* @inner
*/
var getServerUrl = function () {
return urlServer;
};
/**
* Get session status
*
* @returns {string} One of {@link Flashphoner.constants.SESSION_STATUS}
* @memberof Session
* @inner
*/
var status = function () {
return sessionStatus;
};
/**
* Get stream by id.
*
* @param {string} streamId Stream id
* @returns {Stream} Stream
* @memberof Session
* @inner
*/
var getStream = function (streamId) {
return streams[streamId];
};
/**
* Get streams.
*
* @returns {Array<Stream>} Streams
* @memberof Session
* @inner
*/
var getStreams = function () {
return util.copyObjectToArray(streams);
};
/**
* Submit bug report.
*
* @param {Object} reportObject Report object
* @memberof Session
* @inner
*/
var submitBugReport = function (reportObject) {
send("submitBugReport", reportObject);
}
/**
* Start session debug
* @memberof Session
* @inner
*/
var startDebug = function () {
logger.setPushLogs(true);
logger.setLevel("DEBUG");
send("sessionDebug", {command: "start"});
}
/**
* Stop session debug
* @memberof Session
* @inner
*/
var stopDebug = function () {
logger.setLevel("INFO");
send("sessionDebug", {command: "stop"});
}
/**
* Session event callback.
*
* @callback Session~eventCallback
* @param {Session} session Session that corresponds to the event
*/
/**
* Add session event callback.
*
* @param {string} event One of {@link Flashphoner.constants.SESSION_STATUS} events
* @param {Session~eventCallback} callback Callback function
* @returns {Session} Session
* @throws {TypeError} Error if event is not specified
* @throws {Error} Error if callback is not a valid function
* @memberof Session
* @inner
*/
var on = function (event, callback) {
if (!event) {
throw new Error("Event can't be null", "TypeError");
}
if (!callback || typeof callback !== 'function') {
throw new Error("Callback needs to be a valid function");
}
callbacks[event] = callback;
return session;
};
var restAppCommunicator = function () {
var pending = {};
var exports = {};
/**
* Send data to REST App
*
* @param {Object} data Object to send
* @returns {Promise} Resolves if data accepted, otherwise rejects
* @memberof Session
* @name sendData
* @method
* @inner
*/
exports.sendData = function (data) {
return new Promise(function (resolve, reject) {
var obj = {
operationId: uuid_v1(),
payload: data
};
pending[obj.operationId] = {
FAILED: function (info) {
reject(info);
},
ACCEPTED: function (info) {
resolve(info);
}
};
send("sendData", obj);
});
};
exports.resolveData = function (data) {
if (pending[data.operationId]) {
var handler = pending[data.operationId];
delete pending[data.operationId];
delete data.operationId;
handler[data.status](data);
}
};
return exports;
}();
var sdpHookHandler = function(sdp, sdpHook){
if (sdpHook != undefined && typeof sdpHook == 'function') {
var sdpObject = {sdpString: sdp};
var newSdp = sdpHook(sdpObject);
if (newSdp != null && newSdp != "") {
return newSdp;
}
return sdp;
}
return sdp;
}
/**
* Get session logger
*
* @returns {Object} Logger
* @memberof Session
*/
var getLogger = function () {
return sessionLogger;
};
//export Session
session.id = id;
session.status = status;
session.getServerUrl = getServerUrl;
session.createStream = createStream;
session.createCall = createCall;
session.getStream = getStream;
session.getStreams = getStreams;
session.sendData = restAppCommunicator.sendData;
session.disconnect = disconnect;
session.submitBugReport = submitBugReport;
session.startDebug = startDebug;
session.stopDebug = stopDebug;
session.on = on;
session.getLogger = getLogger;
//save interface to global map
sessions[id_] = session;
return session;
};
var isUsingTemasys = function () {
return isUsingTemasysPlugin;
};
module.exports = {
init: init,
isUsingTemasys: isUsingTemasys,
getMediaProviders: getMediaProviders,
getMediaDevices: getMediaDevices,
getMediaAccess: getMediaAccess,
releaseLocalMedia: releaseLocalMedia,
getSessions: getSessions,
getSession: getSession,
createSession: createSession,
playFirstSound: playFirstSound,
playFirstVideo: playFirstVideo,
getLogger: getLogger,
constants: constants,
/**
* The Screensharing whitelist is no longer needed to share your screen or windows starting Firefox 52
* https://wiki.mozilla.org/Screensharing
*/
firefoxScreenSharingExtensionInstalled: true,
Browser: util.Browser
};