Server : Apache/2.4.6 (CentOS) OpenSSL/1.0.2k-fips PHP/7.4.20 System : Linux st2.domain.com 3.10.0-1127.10.1.el7.x86_64 #1 SMP Wed Jun 3 14:28:03 UTC 2020 x86_64 User : apache ( 48) PHP Version : 7.4.20 Disable Function : NONE Directory : /proc/self/root/usr/local/FlashphonerWebCallServer/client2/doc/ |
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="utf-8">
<title>JSDoc: Source: flashphoner-core.js</title>
<script src="scripts/prettify/prettify.js"> </script>
<script src="scripts/prettify/lang-css.js"> </script>
<!--[if lt IE 9]>
<script src="//html5shiv.googlecode.com/svn/trunk/html5.js"></script>
<![endif]-->
<link type="text/css" rel="stylesheet" href="styles/prettify-tomorrow.css">
<link type="text/css" rel="stylesheet" href="styles/jsdoc-default.css">
</head>
<body>
<div id="main">
<h1 class="page-title">Source: flashphoner-core.js</h1>
<section>
<article>
<pre class="prettyprint source linenums"><code>'use strict';
var uuid_v1 = require('uuid/v1');
var constants = require("./constants");
var util = require('./util');
var logger = require('./util').logger;
var loggerConf = {push: false, severity: "INFO"};
var Promise = require('promise-polyfill');
var KalmanFilter = require('kalmanjs');
var browserDetails = require('webrtc-adapter').default.browserDetails;
var LOG_PREFIX = "core";
var isUsingTemasysPlugin = false;
/**
* @namespace Flashphoner
*/
var SESSION_STATUS = constants.SESSION_STATUS;
var STREAM_EVENT = constants.STREAM_EVENT;
var STREAM_EVENT_TYPE = constants.STREAM_EVENT_TYPE;
var STREAM_STATUS = constants.STREAM_STATUS;
var CALL_STATUS = constants.CALL_STATUS;
var TRANSPORT_TYPE = constants.TRANSPORT_TYPE;
var CONNECTION_QUALITY = constants.CONNECTION_QUALITY;
var ERROR_INFO = constants.ERROR_INFO;
var VIDEO_RATE_GOOD_QUALITY_PERCENT_DIFFERENCE = 20;
var VIDEO_RATE_BAD_QUALITY_PERCENT_DIFFERENCE = 50;
var LOW_VIDEO_RATE_THRESHOLD_BAD_PERFECT = 50000;
var LOW_VIDEO_RATE_BAD_QUALITY_PERCENT_DIFFERENCE = 150;
var OUTBOUND_VIDEO_RATE = "outboundVideoRate";
var INBOUND_VIDEO_RATE = "inboundVideoRate";
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 Enable logging
* @throws {Error} Error if none of MediaProviders available
* @memberof Flashphoner
*/
var init = function (options) {
if (!initialized) {
if (!options) {
options = {};
}
loggerConf = options.logger || loggerConf;
if (options.logger !== null) {
loggerConf.enableLogs = true;
}
// init logger
logger.init(loggerConf.severity || "INFO", loggerConf.push || false, loggerConf.customLogger, loggerConf.enableLogs);
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: logger,
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: logger
};
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));
}
});
}
}
var flashProvider = require("./flash-media-provider");
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: logger
};
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: logger
};
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 {
logger.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));
}
logger.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) {
for (var mp in MediaProvider) {
return MediaProvider[mp].playFirstVideo(display, isLocal, src);
}
};
/**
* Get logger
*
* @returns {Object} Logger
* @memberof Flashphoner
*/
var getLogger = function () {
if (!initialized) {
console.warn("Initialize API first.");
} else {
return logger;
}
}
/**
* @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];
};
/**
* 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
* @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");
}
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 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) {
console.log("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.170",
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);
};
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);
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) {
//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);
}
}
/**
* @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 {Array<string>=} options.stripCodecs Array of codecs which should be stripped from SDP (WebRTC)
* @param {Array<string>=} options.sipSDP Array of custom SDP params (ex. bandwidth (b=))
* @param {Array<string>=} options.sipHeaders Array of custom SIP headers
* @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) {
logger.info(LOG_PREFIX, "Status is " + sessionStatus);
throw new Error('Invalid session state');
}
//check options
if (!options) {
throw new TypeError("options must be provided");
}
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, "audio", undefined);
if (typeof audioProperty === 'object') {
audioOutputId = getConstraintsProperty(audioProperty, "outputId", 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;
/**
* 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);
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
}).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 {Array<string>=} answerOptions.stripCodecs Array of codecs which should be stripped from SDP (WebRTC)
* @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;
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);
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
}).then(function (newConnection) {
mediaConnection = newConnection;
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 Stream
* @inner
*/
var getInfo = function () {
return info_;
};
/**
* Get stream error info
* @returns {string} Error info
* @memberof Stream
* @inner
*/
var getErrorInfo = function () {
return errorInfo_;
};
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;
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 {Array<string>=} options.stripCodecs Array of codecs which should be stripped from SDP (WebRTC)
* @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 {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');
}
//check options
if (!options) {
throw new TypeError("options must be provided");
}
if (!options.name) {
throw new TypeError("options.name must be provided");
}
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, "audio", undefined);
if (typeof audioProperty === 'boolean') {
receiveAudio = audioProperty;
} else if (typeof audioProperty === 'object') {
receiveAudio = true;
var _stereo = getConstraintsProperty(audioProperty, "stereo", 0);
var _bitrate = getConstraintsProperty(audioProperty, "bitrate", 0);
var _fec = getConstraintsProperty(audioProperty, "fec", 0);
audioOutputId = getConstraintsProperty(audioProperty, "outputId", 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, "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, "video.bitrate", 0);
var minBitrate = getConstraintsProperty(constraints, "video.minBitrate", 0);
var maxBitrate = getConstraintsProperty(constraints, "video.maxBitrate", 0);
// Quality
var quality = getConstraintsProperty(constraints, "video.quality", 0);
if (quality > 100) quality = 100;
// Play resolution
var playWidth = (typeof options.playWidth !== 'undefined') ? options.playWidth : getConstraintsProperty(constraints, "video.width", 0);
var playHeight = (typeof options.playHeight !== 'undefined') ? options.playHeight : getConstraintsProperty(constraints, "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 audioState_;
var videoState_;
var connectionQuality;
var videoBytes = 0;
/**
* Represents media stream.
*
* @namespace Stream
* @see Session~createStream
*/
var stream = {};
streamEventRefreshHandlers[id_] = function (streamEvent) {
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);
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_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;
}
audioState_ = streamInfo.audioState;
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_ = 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
}, 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_ = 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
}).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);
});
};
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;
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;
}
//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;
//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,
roomApi: require('./room-module'),
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
};
</code></pre>
</article>
</section>
</div>
<nav>
<h2><a href="index.html">Web SDK</a></h2><h3>Events</h3><ul><li><a href="Flashphoner.constants.CALL_STATUS_INFO.html#.event:FAILED_BY_DTLS_ERROR">FAILED_BY_DTLS_ERROR</a></li><li><a href="Flashphoner.constants.CALL_STATUS_INFO.html#.event:FAILED_BY_DTLS_FINGERPRINT_ERROR">FAILED_BY_DTLS_FINGERPRINT_ERROR</a></li><li><a href="Flashphoner.constants.CALL_STATUS_INFO.html#.event:FAILED_BY_ERROR">FAILED_BY_ERROR</a></li><li><a href="Flashphoner.constants.CALL_STATUS_INFO.html#.event:FAILED_BY_ICE_ERROR">FAILED_BY_ICE_ERROR</a></li><li><a href="Flashphoner.constants.CALL_STATUS_INFO.html#.event:FAILED_BY_REQUEST_TIMEOUT">FAILED_BY_REQUEST_TIMEOUT</a></li><li><a href="Flashphoner.constants.CALL_STATUS_INFO.html#.event:FAILED_BY_RTMP_WRITER_ERROR">FAILED_BY_RTMP_WRITER_ERROR</a></li><li><a href="Flashphoner.constants.CALL_STATUS_INFO.html#.event:FAILED_BY_RTP_ACTIVITY">FAILED_BY_RTP_ACTIVITY</a></li><li><a href="Flashphoner.constants.CALL_STATUS_INFO.html#.event:FAILED_BY_SESSION_CREATION">FAILED_BY_SESSION_CREATION</a></li><li><a href="Flashphoner.constants.CALL_STATUS_INFO.html#.event:NO_COMMON_CODECS">NO_COMMON_CODECS</a></li><li><a href="Flashphoner.constants.CALL_STATUS_INFO.html#.event:NORMAL_CALL_CLEARING">NORMAL_CALL_CLEARING</a></li><li><a href="Flashphoner.constants.CALL_STATUS_INFO.html#.event:TRANSCODING_REQUIRED_BUT_DISABLED">TRANSCODING_REQUIRED_BUT_DISABLED</a></li><li><a href="Flashphoner.constants.ERROR_INFO.html#.event:CALLBACK_NEEDS_TO_BE_A_VALID_FUNCTION">CALLBACK_NEEDS_TO_BE_A_VALID_FUNCTION</a></li><li><a href="Flashphoner.constants.ERROR_INFO.html#.event:CAN_NOT_SWITCH_CAM">CAN_NOT_SWITCH_CAM</a></li><li><a href="Flashphoner.constants.ERROR_INFO.html#.event:CAN_NOT_SWITCH_MIC">CAN_NOT_SWITCH_MIC</a></li><li><a href="Flashphoner.constants.ERROR_INFO.html#.event:EVENT_CANT_BE_NULL">EVENT_CANT_BE_NULL</a></li><li><a href="Flashphoner.constants.ERROR_INFO.html#.event:FLASHPHONER_API_NOT_INITIALIZED">FLASHPHONER_API_NOT_INITIALIZED</a></li><li><a href="Flashphoner.constants.ERROR_INFO.html#.event:INVALID_CALL_STATE">INVALID_CALL_STATE</a></li><li><a href="Flashphoner.constants.ERROR_INFO.html#.event:INVALID_SESSION_STATE">INVALID_SESSION_STATE</a></li><li><a href="Flashphoner.constants.ERROR_INFO.html#.event:NONE_OF_MEDIAPROVIDERS_AVAILABLE">NONE_OF_MEDIAPROVIDERS_AVAILABLE</a></li><li><a href="Flashphoner.constants.ERROR_INFO.html#.event:NONE_OF_PREFERRED_MEDIAPROVIDERS_AVAILABLE">NONE_OF_PREFERRED_MEDIAPROVIDERS_AVAILABLE</a></li><li><a href="Flashphoner.constants.ERROR_INFO.html#.event:OPTIONS_MUST_BE_PROVIDED">OPTIONS_MUST_BE_PROVIDED</a></li><li><a href="Flashphoner.constants.ERROR_INFO.html#.event:OPTIONS_NAME_MUST_BE_PROVIDED">OPTIONS_NAME_MUST_BE_PROVIDED</a></li><li><a href="Flashphoner.constants.ERROR_INFO.html#.event:OPTIONS_URLSERVER_MUST_BE_PROVIDED">OPTIONS_URLSERVER_MUST_BE_PROVIDED</a></li><li><a href="Flashphoner.constants.NOT_ENOUGH_BANDWIDTH.html#.event:NOT_ENOUGH_BANDWIDTH">NOT_ENOUGH_BANDWIDTH</a></li><li><a href="Flashphoner.constants.SESSION_STATUS.html#.event:APP_DATA">APP_DATA</a></li><li><a href="Flashphoner.constants.SESSION_STATUS.html#.event:CONNECTED">CONNECTED</a></li><li><a href="Flashphoner.constants.SESSION_STATUS.html#.event:DEBUG">DEBUG</a></li><li><a href="Flashphoner.constants.SESSION_STATUS.html#.event:DISCONNECTED">DISCONNECTED</a></li><li><a href="Flashphoner.constants.SESSION_STATUS.html#.event:ESTABLISHED">ESTABLISHED</a></li><li><a href="Flashphoner.constants.SESSION_STATUS.html#.event:FAILED">FAILED</a></li><li><a href="Flashphoner.constants.SESSION_STATUS.html#.event:SEND_DATA_STATUS">SEND_DATA_STATUS</a></li><li><a href="Flashphoner.constants.SESSION_STATUS.html#.event:WARN">WARN</a></li><li><a href="Flashphoner.constants.STREAM_STATUS.html#.event:FAILED">FAILED</a></li><li><a href="Flashphoner.constants.STREAM_STATUS.html#.event:PAUSED">PAUSED</a></li><li><a href="Flashphoner.constants.STREAM_STATUS.html#.event:PLAYBACK_PROBLEM">PLAYBACK_PROBLEM</a></li><li><a href="Flashphoner.constants.STREAM_STATUS.html#.event:PLAYING">PLAYING</a></li><li><a href="Flashphoner.constants.STREAM_STATUS.html#.event:PUBLISHING">PUBLISHING</a></li><li><a href="Flashphoner.constants.STREAM_STATUS.html#.event:RESIZE">RESIZE</a></li><li><a href="Flashphoner.constants.STREAM_STATUS.html#.event:SNAPSHOT_COMPLETE">SNAPSHOT_COMPLETE</a></li><li><a href="Flashphoner.constants.STREAM_STATUS.html#.event:STOPPED">STOPPED</a></li><li><a href="Flashphoner.constants.STREAM_STATUS.html#.event:UNPUBLISHING">UNPUBLISHING</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:AGENT_SERVICING_ORIGIN_STREAM_IS_SHUTTING_DOWN">AGENT_SERVICING_ORIGIN_STREAM_IS_SHUTTING_DOWN</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:BAD_URI">BAD_URI</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:CDN_STREAM_NOT_FOUND">CDN_STREAM_NOT_FOUND</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:DISTRIBUTOR_STOPPED">DISTRIBUTOR_STOPPED</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:FAILED_BY_DTLS_ERROR">FAILED_BY_DTLS_ERROR</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:FAILED_BY_DTLS_FINGERPRINT_ERROR">FAILED_BY_DTLS_FINGERPRINT_ERROR</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:FAILED_BY_ERROR">FAILED_BY_ERROR</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:FAILED_BY_HLS_WRITER_ERROR">FAILED_BY_HLS_WRITER_ERROR</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:FAILED_BY_ICE_ERROR">FAILED_BY_ICE_ERROR</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:FAILED_BY_ICE_TIMEOUT">FAILED_BY_ICE_TIMEOUT</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:FAILED_BY_KEEP_ALIVE">FAILED_BY_KEEP_ALIVE</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:FAILED_BY_RTMP_WRITER_ERROR">FAILED_BY_RTMP_WRITER_ERROR</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:FAILED_BY_RTP_ACTIVITY">FAILED_BY_RTP_ACTIVITY</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:FAILED_TO_ADD_STREAM_TO_PROXY">FAILED_TO_ADD_STREAM_TO_PROXY</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:FAILED_TO_CONNECT_TO_ORIGIN_STREAM">FAILED_TO_CONNECT_TO_ORIGIN_STREAM</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:FAILED_TO_CONNECT_TO_RTSP_STREAM">FAILED_TO_CONNECT_TO_RTSP_STREAM</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:FAILED_TO_GET_AGENT_STORAGE">FAILED_TO_GET_AGENT_STORAGE</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:FAILED_TO_READ_FILE">FAILED_TO_READ_FILE</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:FILE_HAS_WRONG_FORMAT">FILE_HAS_WRONG_FORMAT</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:FILE_NOT_FOUND">FILE_NOT_FOUND</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:GOT_EXCEPTION_WHILE_STREAMING_FILE">GOT_EXCEPTION_WHILE_STREAMING_FILE</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:MEDIASESSION_ID_ALREADY_IN_USE">MEDIASESSION_ID_ALREADY_IN_USE</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:MEDIASESSION_ID_NULL">MEDIASESSION_ID_NULL</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:NO_COMMON_CODECS">NO_COMMON_CODECS</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:PUBLISH_STREAM_IS_NOT_READY">PUBLISH_STREAM_IS_NOT_READY</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:REQUESTED_STREAM_SHUTDOWN">REQUESTED_STREAM_SHUTDOWN</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:RESTRICTED_ACCESS">RESTRICTED_ACCESS</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:RTSP_HAS_WRONG_FORMAT">RTSP_HAS_WRONG_FORMAT</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:RTSP_STREAM_NOT_FOUND">RTSP_STREAM_NOT_FOUND</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:RTSPAGENT_SHUTDOWN">RTSPAGENT_SHUTDOWN</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:SESSION_DOES_NOT_EXIST">SESSION_DOES_NOT_EXIST</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:SESSION_NOT_READY">SESSION_NOT_READY</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:STOPPED_BY_PUBLISHER_STOP">STOPPED_BY_PUBLISHER_STOP</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:STOPPED_BY_REST_TERMINATE">STOPPED_BY_REST_TERMINATE</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:STOPPED_BY_SESSION_DISCONNECT">STOPPED_BY_SESSION_DISCONNECT</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:STOPPED_BY_USER">STOPPED_BY_USER</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:STREAM_FAILED">STREAM_FAILED</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:STREAM_NAME_ALREADY_IN_USE">STREAM_NAME_ALREADY_IN_USE</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:STREAM_NOT_FOUND">STREAM_NOT_FOUND</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:TERMINATED_BY_KEEP_ALIVE">TERMINATED_BY_KEEP_ALIVE</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html#.event:TRANSCODING_REQUIRED_BUT_DISABLED">TRANSCODING_REQUIRED_BUT_DISABLED</a></li></ul><h3>Namespaces</h3><ul><li><a href="Call.html">Call</a></li><li><a href="Flashphoner.html">Flashphoner</a></li><li><a href="Flashphoner.constants.CALL_STATUS.html">CALL_STATUS</a></li><li><a href="Flashphoner.constants.CALL_STATUS_INFO.html">CALL_STATUS_INFO</a></li><li><a href="Flashphoner.constants.ERROR_INFO.html">ERROR_INFO</a></li><li><a href="Flashphoner.constants.SESSION_STATUS.html">SESSION_STATUS</a></li><li><a href="Flashphoner.constants.STREAM_STATUS.html">STREAM_STATUS</a></li><li><a href="Flashphoner.constants.STREAM_STATUS_INFO.html">STREAM_STATUS_INFO</a></li><li><a href="roomApi.html">roomApi</a></li><li><a href="roomApi.Room.html">Room</a></li><li><a href="roomApi.Room.Participant.html">Participant</a></li><li><a href="roomApi.Session.html">Session</a></li><li><a href="Session.html">Session</a></li><li><a href="Stream.html">Stream</a></li></ul><h3><a href="global.html">Global</a></h3>
</nav>
<br class="clear">
<footer>
Documentation generated by <a href="https://github.com/jsdoc3/jsdoc">JSDoc 3.6.7</a> on Mon May 24 2021 14:25:08 GMT+0700 (+07)
</footer>
<script> prettyPrint(); </script>
<script src="scripts/linenumber.js"> </script>
</body>
</html>