var Janus = require('../externals/janus.nojquery');
var Promise = require('bluebird/js/release/bluebird');
var DataChannel = require('../modules/datachannel');
/**
* SplitAgent usecase
* @class
* @classdesc SplitAgent usecase
* @param {object} onEvents Event handlers: onDestroyed, onError, onJoined, onDataReceived, onAcceptedVideo, onAcceptedData, onReadyLocalStream, onFileTransferOk, onFileTransferKo, onScreensharingAccepted, onScreensharingClosed, onNotified
* @param {object} domElements DOM elements: client, agent, screenRemote, screenLocal
* @param {object} options Available options: dataChannel, session, stream
* @return {Promise} SplitAgent methods: getLicense, sendData, startRecording, startScreensharing, stopRecording, stopScreensharing, toggleVideo
* @example
* var onEvents = {
* onDestroyed: function() {
* // Destroyed
* },
* onError: function(cause) {
* // Error
* },
* onJoined: function(screenRoom) {
* // Joined
* },
* onDataReceived: function(type, data, filename) {
* // Data received
* if(type === 'application/x-chat') { }
* else if(type === 'text/plain') { }
* else if(type === 'application/pdf') { }
* else if(type === 'application/zip') { }
* else if(type === 'application/x-rar') { }
* else if(type === 'image/jpeg') {}
* else if(type === 'image/png') {}
* else if(type === 'application/x-docx') {}
* else if(type === 'application/x-pptx') {}
* else if(type === 'application/x-xlsx') {}
* else if(type === 'application/vnd.oasis.opendocument.text') {}
* },
* onAcceptedVideo: function(stream) {
* // Accepted Video
* },
* onAcceptedData: function() {
* // Accepted Data
* },
* onReadyLocalStream: function(isReady) {
* // Local Video is ready
* },
* onScreensharingAccepted: function() {
* // ScreenSharing Accepted
* },
* onScreensharingClosed: function() {
* // ScreenSharing Closed
* },
* onFileTransferOk: function(fileId) {
* // File Transfer OK
* },
* onFileTransferKo: function(fileId) {
* // File Transfer KO
* },
* onNotified: function(action, data) {
* // Notification
* }
* };
*
* var domElements = {
* client: document.getElementById('clientvideo'),
* agent: document.getElementById('agentvideo'),
* screenRemote: document.getElementById('screenRemote'),
* screenLocal: document.getElementById('localscreen')
* };
*
* var options = {
* dataChannel: {
* dataEnabled: true,
* allowedTypes: ['application/x-chat', 'image/jpeg', 'image/png', 'application/pdf'],
* maxSize: 5, // In MB
* fileTransmission: {
* timeout: 5, // Minutes
* retransmissionDelay: 15 // Seconds
* }
* },
* session: {
* agentName: 'Anna',
* sessionId: 6655
* },
* stream: {
* videoEnabled: true,
* aDeviceId: null,
* vDeviceId: null,
* videoStream: null
* }
* };
*
* usecases.splitAgent(onEvents, domElements, options)
* .then(function(action) {
* // Use Case has been atacched succesfully
* ...
* })
* .catch(function(cause) {
* // Error attaching the Use Case
* console.log("Error Attach " + cause );
* })
*/
var splitAgent = function(onEvents, domElements, options) {
if(!domElements || !domElements.agent || !domElements.client || domElements.agent.nodeType !== 1 || domElements.client.nodeType !== 1) return null;
if(domElements.screenAgent) domElements.screenLocal = domElements.screenAgent; // Support last version (until major update 4.X)
// Stream options
var streamOptions = (options && options.stream) ? options.stream : {};
var isDataEnabled = (options && options.dataChannel && options.dataChannel.dataEnabled) ? options.dataChannel.dataEnabled : false;
if(!streamOptions.videoEnabled) streamOptions.videoEnabled = false;
if(!streamOptions.aDeviceId) streamOptions.aDeviceId = undefined;
if(!streamOptions.vDeviceId) streamOptions.vDeviceId = undefined;
if(!streamOptions.videoStream) streamOptions.videoStream = undefined;
// Session options
var sessionOptions = (options && options.session) ? options.session : {};
if(!sessionOptions.agentName) sessionOptions.agentName = 'Unknown';
if(!sessionOptions.sessionId) sessionOptions.sessionId = 1234;
// Vars
var splitAgentHandle = null;
var screenRoomHandle = null;
var agentName = sessionOptions.agentName;
var sessionId = sessionOptions.sessionId;
var screenid = null;
var feeds = [];
var bitrateTimer = [];
var prefixName = null;
var screenFeed = null;
var screenRoom = null;
var recordId = null;
/**
* Close the current UseCase. It's recommended combine with disconnect method
* @return {nothing}
* @example
* action.closeUsecase();
* myVideoApp.disconnect(); // Recommended
*/
var closeUsecase = function() {
if(domElements) {
for (var element in domElements) {
if (!domElements.hasOwnProperty(element)) continue;
var obj = domElements[element];
if(obj && obj.innerHTML) obj.innerHTML = '';
}
}
};
/**
* The Agent can connect to establish a Video session
* @param {integer} id Session ID
* @param {string} display Display name
* @return {nothing}
* @private
*/
var joinVideoSession = function(id, display) {
var register = {
"request": "join",
"room": id || 1234,
"ptype": "publisher",
"display": display || 'Agent'
};
splitAgentHandle.send({"message": register});
};
/**
* The Agent sends a request to start recording the session
* @param {string} recordPrefix Prefix of records: e.g: '__default__'
* @return {nothing}
* @example
* action.startRecording();
*/
var startRecording = function(recordPrefix) {
prefixName = recordPrefix;
var req = {
"request": "startRec",
"room": sessionId
}
splitAgentHandle.send({"message": req});
// ScreenSharing
/*if(screenRoomHandle !== null) {
var req = {
"request": "startRec",
"room": screenid
}
splitAgentHandle.send({"message": req});
}*/
};
/**
* The Agent sends a request to stop recording the session
* @return {nothing}
* @example
* action.stopRecording();
*/
var stopRecording = function() {
var req = {
"request": "stopRec",
"room": sessionId
}
splitAgentHandle.send({"message": req});
// ScreenSharing
/*if(screenRoomHandle !== null) {
var req = {
"request": "stopRec",
"room": screenid
}
splitAgentHandle.send({"message": req});
}*/
};
/**
* Start recording (Slave)
* @param {integer} id Session ID
* @param {string} recordPrefix Prefix of records: e.g: '__default__'
* @return {nothing}
* @private
*/
var recordVideoroom = function(id, recordPrefix) {
var req = {
"request": "configure",
//"audio": true,
"room": id,
"record": true,
"prefixtheme": recordPrefix,
"record_id": recordId,
"role": "agent"
}
splitAgentHandle.send({"message": req});
};
/**
* Start recording (Slave) (ScreenRoom)
* @param {integer} id Screen ID
* @param {string} recordPrefix Prefix of records: e.g: '__ScreenSharingdefault__'
* @return {nothing}
* @private
*/
var recordScreenroom = function(id, recordPrefix, recordId) {
var req = {
"request": "configure",
//"audio": true,
"room": id,
"record": true,
"prefixtheme": recordPrefix + 'ScreenSharing', // Hidden on VideoPlayer
"record_id": recordId
}
screenRoomHandle.send({"message": req});
};
/**
* Stop recording (Slave)
* @param {integer} id Session ID
* @return {nothing}
* @private
*/
var stoprecordVideoroom = function(id) {
var req = {
"request": "configure",
"room": id,
"record": false
}
splitAgentHandle.send({"message": req});
};
/**
* Stop recording (Slave)
* @param {integer} id Session ID
* @return {nothing}
* @private
*/
var stoprecordScreenroom = function(id) {
var req = {
"request": "configure",
"room": id,
"record": false
}
screenRoomHandle.send({"message": req});
};
/**
* The VideoGateway is requested about the features of the contracted license
* @return {Object} License Information (Screensharing, Livechat and VideoRecording )
* @example
* var myLicense = action.getLicense();
* console.log(myLicense);
*/
var getLicense = function() {
return window.VideoRTC.license;
};
/**
* Toggle local Video stream (Mute/Unmute)
* @return {boolean} Is video muted?
* @example
* action.toggleVideo(); // true or false
*/
var toggleVideo = function() {
if (splitAgentHandle.isVideoMuted()) splitAgentHandle.unmuteVideo();
else splitAgentHandle.muteVideo();
return splitAgentHandle.isVideoMuted();
};
/**
* Sends a message (Chat or File) through the DataChannel
* @param {string} type MIME Type (e.g: 'application/x-chat', 'text/plain', 'application/pdf', 'application/zip', 'application/x-rar', 'image/jpeg', 'image/png', 'application/x-docx', 'application/x-pptx', 'application/x-xlsx', 'application/vnd.oasis.opendocument.text')
* @param {string} data Data Content
* @param {function} cOk Callback success function
* @param {function} cKo Callback failed function
* @param {string} (Optional) filename File Name (e.g: file.zip)
* @return {nothing}
* @example
* action.sendData('application/x-chat', 'Hello Mike!',
* function(cOk) {
* // Success
* },
* function(error) {
* // Error
* console.log(error);
* }
* )
*/
var sendData = function(type, data, cOk, cKo, filename) {
DataChannel.send(type, data, cOk, cKo, filename);
};
/**
* New remote Feed
* @param {integer} id Session ID
* @param {string} display Display name
* @return {nothing}
* @private
*/
var newRemoteFeed = function(id, display) {
var remoteFeed = null;
window.VideoRTC.connection.handle.attach({
plugin: "janus.plugin.split",
success: function(pluginHandle) {
remoteFeed = pluginHandle;
var listen = {
"request": "join",
"room": sessionId,
"ptype": "listener",
"feed": id
};
remoteFeed.send({"message": listen});
},
error: function(cause) {
console.log(" -- Error attaching plugin...", error);
},
destroyed: function() {
},
consentDialog: function(on) {
},
onmessage: function(msg, jsep) {
Janus.debug(" ::: Got a message (listener) :::");
var event = msg["split"];
if (event != undefined && event != null) {
if (event === "attached") {
// Subscriber created and attached
for (var i = 1; i < 6; i++) {
if (feeds[i] === undefined || feeds[i] === null) {
feeds[i] = remoteFeed;
remoteFeed.rfindex = i;
break;
}
}
remoteFeed.rfid = msg["id"];
remoteFeed.rfdisplay = msg["display"];
Janus.log("Successfully attached to feed " + remoteFeed.rfid + " (" + remoteFeed.rfdisplay + ") in room " + msg["room"]);
} else if (msg["error"] !== undefined && msg["error"] !== null) {
console.log(msg["error"]);
} else {
// What has just happened?
}
}
if (jsep !== undefined && jsep !== null) {
// Answer and attach
remoteFeed.createAnswer(
{
jsep: jsep,
media: {audioSend: false, videoSend: false, data: true}, // We want recvonly audio/video
success: function (jsep) {
var body = {"request": "start", "room": sessionId};
remoteFeed.send({"message": body, "jsep": jsep});
},
error: function (error) {
Janus.error("WebRTC error:", error);
}
});
}
},
onlocalstream: function(stream) {
},
onremotestream: function(stream) {
Janus.debug("Remote feed #" + remoteFeed.rfindex);
var generateLabel = function(id, content, backgroundColor, position) {
var output = '';
output += '<span id="'+id+'" style="';
output += ' position:absolute;margin:10px;padding:3px 5px;color:white;font-weight:bold;border-radius:5px;';
output += 'background:'+backgroundColor+';';
output += position;
output += '">'+content+'</span>';
return output;
};
var container = domElements.client;
var tpl = '';
tpl += '<div id="container-remote1">';
tpl += '<video autoplay poster="data:image/gif;base64,R0lGODlhAQABAIAAAAAAAP///yH5BAEAAAAALAAAAAABAAEAAAIBRAA7" id="videoremote1"></video>';
tpl += generateLabel('remote-name', remoteFeed.rfdisplay, '#55D8D5', 'left:0; margin-top: 10px;');
tpl += generateLabel('remote-resolution', '', '#8DCC6D', 'left:0; margin-top: 40px;');
tpl += generateLabel('remote-bitrate', '', '#FF6E5F', 'left:0; margin-top: 70px;');
tpl += '</div>';
container.innerHTML += tpl;
var remoteContainer = document.getElementById('container-remote1');
var videoElem = document.getElementById('videoremote1');
videoElem.onplaying = function() {
var width = this.videoWidth;
var height = this.videoHeight;
document.getElementById('remote-resolution').innerHTML = width+'x'+height;
if(window.VideoRTC.getBrowser() === 'firefox') {
// Firefox Stable has a bug: width and height are not immediately available after a playing
setTimeout(function() {
var width = videoElem.videoWidth;
var height = videoElem.videoHeight;
document.getElementById('remote-resolution').innerHTML = width+'x'+height;
}, 2000);
}
};
Janus.attachMediaStream(videoElem, stream);
videoElem.muted = true;
var videoTracks = stream.getVideoTracks();
if(videoTracks === null || videoTracks === undefined || videoTracks.length === 0 || videoTracks[0].muted) {
// No remote video
var nodeNoCamera = document.createElement('div');
nodeNoCamera.innerHTML = 'No camera available';
nodeNoCamera.style.position = "relative";
nodeNoCamera.style.height = "100%";
nodeNoCamera.style.width = "100%";
nodeNoCamera.style.top = "100%";
nodeNoCamera.style.left = "50%";
nodeNoCamera.style.transform = "translate(-50%,-50%)";
nodeNoCamera.className = "no-camera-available";
remoteContainer.insertBefore(nodeNoCamera, remoteContainer.firstChild);
// We Hide Bitrate and Resolution labels
for(var i = 0; i < remoteContainer.childNodes.length; i++) {
if(remoteContainer.childNodes[i].id && (remoteContainer.childNodes[i].id.indexOf('remote-resolution') >= 0 || remoteContainer.childNodes[i].id.indexOf('remote-bitrate') >= 0 )) {
remoteContainer.childNodes[i].style.display = 'none';
}
}
}
bitrateTimer[remoteFeed.rfindex] = setInterval(function() {
// Display updated bitrate, if supported
var bitrate = remoteFeed.getBitrate();
if(document.getElementById('remote-bitrate')) document.getElementById('remote-bitrate').innerHTML = bitrate;
}, 1000);
if(onEvents && onEvents.onAcceptedVideo) onEvents.onAcceptedVideo(stream);
},
oncleanup: function() {
Janus.log(" ::: Got a cleanup notification (remote feed " + id + ") :::");
if (bitrateTimer[remoteFeed.rfindex] !== null && bitrateTimer[remoteFeed.rfindex] !== null)
clearInterval(bitrateTimer[remoteFeed.rfindex]);
bitrateTimer[remoteFeed.rfindex] = null;
},
detached: function() {
},
ondataopen: function () {
Janus.log("The DataChannel is available!");
if(onEvents && onEvents.onAcceptedData) onEvents.onAcceptedData();
},
ondata: function (data) {
Janus.debug("We got data from the DataChannel! " + data);
DataChannel.receive(data, onEvents.onDataReceived);
}
});
};
/**
* Publish own stream
* @return {nothing}
* @private
*/
var publishOwnFeed = function() {
var mediaOffer = {
audioRecv: false,
videoRecv: false,
audioSend: false,
videoSend: streamOptions.videoEnabled,
data: isDataEnabled,
video: {
deviceId: {
exact: streamOptions.vDeviceId || undefined
}
}
};
splitAgentHandle.createOffer(
{
media: mediaOffer, // Publishers are sendonly
stream: streamOptions.videoStream,
success: function (jsep) {
var publish = {"request": "configure", "audio": false, "video": true, "record": false}; // useAudio
splitAgentHandle.send({"message": publish, "jsep": jsep});
},
error: function (error) {
console.log("WebRTC error:", error);
publishOwnFeed();
}
});
};
/**
* Join Screen Room
* @param {integer} screenRoom Screen Room ID
* @return {nothing}
* @private
*/
var joinScreenroom = function(screenRoom) {
window.VideoRTC.connection.handle.attach({
plugin: "janus.plugin.split",
success: function(pluginHandle) {
// Plugin attached! 'pluginHandle' is our handle
screenRoomHandle = pluginHandle;
var register = { "request": "join", "room": screenRoom, "ptype": "publisher", "display": 'ScreenAgent' };
screenRoomHandle.send({"message": register});
},
error: function(cause) {
},
consentDialog: function(on) {
},
onmessage: function(msg, jsep) {
var event = msg.split;
if(event !== undefined && event !== null) {
if(event === "joined") {
if(msg["publishers"] !== undefined && msg["publishers"] !== null) {
var list = msg["publishers"];
Janus.debug("Got a list of available publishers/feeds:");
Janus.debug(list);
for(var f in list) {
var id = list[f]["id"];
var display = list[f]["display"];
Janus.debug(" >> [" + id + "] " + display);
listenScreenSharing(screenRoom, id);
}
}
} else if(event === "destroyed") {
Janus.warn("The room has been destroyed!");
} else if(event === "event") {
if(msg["publishers"] !== undefined && msg["publishers"] !== null) {
var list = msg["publishers"];
Janus.debug("Got a list of available publishers/feeds:");
Janus.debug(list);
for(var f in list) {
var id = list[f]["id"];
var display = list[f]["display"];
Janus.debug(" >> [" + id + "] " + display);
listenScreenSharing(screenRoom, id);
}
} else if(msg["leaving"] !== undefined && msg["leaving"] !== null) {
var leaving = msg["leaving"];
Janus.log("Publisher left: " + leaving);
var container = domElements.screenRemote;
container.innerHTML = '';
container.style = '';
//container.className = '';
screenFeed.detach();
if(onEvents && onEvents.onScreensharingClosed) onEvents.onScreensharingClosed();
} else if(msg["unpublished"] !== undefined && msg["unpublished"] !== null) {
var unpublished = msg["unpublished"];
Janus.log("Publisher left: " + unpublished);
var container = domElements.screenRemote;
container.innerHTML = '';
container.style = '';
//container.className = '';
screenFeed.detach();
} else if(msg["error"] !== undefined && msg["error"] !== null) {
Janus.error(msg["error"]);
}
}
}
if(jsep !== undefined && jsep !== null) {
Janus.debug("Handling SDP as well...");
Janus.debug(jsep);
screenRoomHandle.handleRemoteJsep({jsep: jsep});
}
},
onlocalstream: function(stream) {
// We have a local stream (getUserMedia worked!) to display
var container = domElements.screenLocal;
container.innerHTML = '<video autoplay poster="data:image/gif;base64,R0lGODlhAQABAIAAAAAAAP///yH5BAEAAAAALAAAAAABAAEAAAIBRAA7" id="screenAgent"></video>';
var videoElem = document.getElementById('screenAgent');
Janus.attachMediaStream(videoElem, stream);
videoElem.muted = true;
},
onremotestream: function(stream) {
},
oncleanup: function() {
},
detached: function() {
}
});
};
/**
* Listen ScreenSharing
* @param {integer} screenRoom Screen Room ID
* @param {integer} peerId Peer ID
* @return {nothing}
* @private
*/
var listenScreenSharing = function(screenRoom, peerId) {
window.VideoRTC.connection.handle.attach(
{
plugin: "janus.plugin.split",
success: function(pluginHandle) {
//if(screenFeed) screenFeed.detach();
screenFeed = pluginHandle;
var listen = { "request": "join", "room": screenRoom, "ptype": "listener", "feed": peerId };
screenFeed.send({"message": listen});
},
error: function(error) {
Janus.error(" -- Error attaching plugin...", error);
},
onmessage: function(msg, jsep) {
Janus.debug(" ::: Got a message (listener) :::");
var event = msg["split"];
if(event !== undefined && event !== null) {
if(event === "attached") {
} else if(msg["error"] !== undefined && msg["error"] !== null) {
Janus.error(msg["error"]);
} else {
// What has just happened?
}
}
if(jsep !== undefined && jsep !== null) {
Janus.debug("Handling SDP as well...");
Janus.debug(jsep);
// Answer and attach
screenFeed.createAnswer(
{
jsep: jsep,
media: {
audioSend: false,
videoSend: false,
audioRecv: false,
videoRecv: true,
data: false
}, // We want recvonly audio/video
success: function(jsep) {
Janus.debug("Got SDP!");
Janus.debug(jsep);
var body = { "request": "start", "room": sessionId };
screenFeed.send({"message": body, "jsep": jsep});
},
error: function(error) {
Janus.error("WebRTC error:", error);
}
});
}
},
onlocalstream: function(stream) {
// The subscriber stream is recvonly, we don't expect anything here
},
onremotestream: function(stream) {
var container = domElements.screenRemote;
var tpl = '';
tpl += '<div id="container-screenremote">';
tpl += '<video autoplay poster="data:image/gif;base64,R0lGODlhAQABAIAAAAAAAP///yH5BAEAAAAALAAAAAABAAEAAAIBRAA7" id="screenremote"></video>';
tpl += '</div>';
container.innerHTML = tpl;
var videoElem = document.getElementById('screenremote');
Janus.attachMediaStream(videoElem, stream);
videoElem.muted = true;
if(onEvents && onEvents.onScreensharingAccepted) onEvents.onScreensharingAccepted();
},
oncleanup: function() {
}
});
};
/**
* The Agent sends a request to start Screensharing
* @param {integer} screenId Screen Id
* @param {function} cOk Callback Ok
* @param {function} cKo Callback Error
* @return {nothing}
* @example
* action.startScreensharing(1234, function() {
* // Success
* }, function(cause) {
* // Error
* })
*/
var startScreensharing = function(screenId, cOk, cKo) {
if(!getLicense().screensharing) {
cKo ('Screensharing is not a feature of your Gateway');
return false;
}
if(window.location.protocol !== 'https:') {
cKo ('Screensharing requires HTTPS');
return false;
}
if(window.isMobile) {
cKo ('Screensharing is not available on Mobile devices');
return false;
}
if(!Janus.isExtensionEnabled()) {
cKo("You're using a recent version of Chrome but don't have the screensharing extension installed: click <b><a href='https://chrome.google.com/webstore/detail/videortc-screensharing/pkilckpboojemoogepfpkgbihkfkikel' target='_blank'>here</a></b> to do so");
return false;
}
screenid = screenId;
var capture = 'screen';
screenRoomHandle.createOffer(
{
//media: { audioRecv: false, videoRecv: false, audioSend: useAudio, videoSend: true/*, video:"hires"*/}, // Publishers are sendonly
media: { video: capture, audio: false, videoRecv: false },
success: function(jsep) {
var publish = { "request": "configure", "audio": false, "video": true };
screenRoomHandle.send({"message": publish, "jsep": jsep});
cOk();
},
error: function(error) {
console.log(error);
if(error && error.name === 'NotAllowedError' && window.getBrowser() === 'firefox') {
cKo('Firefox needs that the domain this web application is from is listed in Allowed domains.');
}
Janus.error("WebRTC error:", error);
}
}
);
};
/**
* The Agent sends a request to stop Screensharing
* @param {function} cOk Callback Ok
* @param {function} cKo Callback Error
* @return {nothing}
* @example
* action.stopScreensharing(function() {
* // Success
* }, function(cause) {
* // Error
* })
*/
var stopScreensharing = function(cOk, cKo) {
var leave = { "request": "leave" };
screenRoomHandle.send({"message": leave});
screenRoomHandle.detach();
joinScreenroom(screenRoom);
var container = domElements.screenLocal;
container.innerHTML = '';
container.style = '';
cOk();
};
/**
* Send a notification to the other peer via the VideoGateway
* @param {string} action Identifies the notification type
* @param {string} data Useful for sending extra data (Optional)
* @example
* action.notify('open-map');
*/
var notify = function(action, data) {
if(!action) return;
var not = {
"request": "notify",
"action": action,
"room": sessionId,
"origin": "agent"
};
if(data) not.data = data;
splitAgentHandle.send({"message": not});
};
return new Promise(function (resolve, reject) {
window.VideoRTC.connection.handle.attach({
plugin: "janus.plugin.split",
success: function(pluginHandle) {
// Plugin attached! 'pluginHandle' is our handle
splitAgentHandle = pluginHandle;
// DataChannel options
var optionsDataChannel = (options && options.dataChannel) ? options.dataChannel : {};
var cbks = {
fileOk: onEvents.onFileTransferOk || function() {},
fileKo: onEvents.onFileTransferKo || function() {}
};
var result = DataChannel.initialize(optionsDataChannel, pluginHandle, cbks);
if(!result) console.log("Datachannel options can't be loaded:");
joinVideoSession(sessionId, agentName);
splitAgentHandle.send({
message: {
request: "license_info"
},
success: function(data) {
if(data && data["error_code"]){
reject(data["error"]);
}
else {
/*resolve({
closeUsecase: closeUsecase,
getLicense: getLicense,
startRecording: startRecording,
stopRecording: stopRecording,
startScreensharing: startScreensharing,
stopScreensharing: stopScreensharing,
toggleVideo: toggleVideo,
sendData: sendData
});*/
}
}
});
},
error: function(cause) {
if(cause && cause.indexOf('482') >= 0) {
reject("Sorry, all channels are busy!");
}
else if(cause && cause.indexOf('480') >= 0) {
reject("License has been expired. Please, contact with an Administrator");
}
else {
reject(cause);
}
},
destroyed: function() {
},
consentDialog: function(on) {
},
onmessage: function(msg, jsep) {
var event = msg["split"];
if (event != undefined && event != null) {
if (event === "joined") {
// Publisher/manager created, negotiate WebRTC and attach to existing feeds, if any
publishOwnFeed();
// Any new feed to attach to?
if (msg["publishers"] !== undefined && msg["publishers"] !== null) {
var list = msg["publishers"];
for (var f in list) {
var id = list[f]["id"];
var display = list[f]["display"];
newRemoteFeed(id, display);
}
}
screenRoom = msg["screenroom"] > 0 ? msg["screenroom"] : undefined;
if(onEvents && onEvents.onJoined) onEvents.onJoined(screenRoom);
if(screenRoom && screenRoom > 0 && domElements.screenRemote) joinScreenroom(screenRoom);
} else if (event === "destroyed") {
// The room has been destroyed
if(onEvents && onEvents.onDestroyed) onEvents.onDestroyed();
} else if (event === "event") {
// Any new feed to attach to?
if (msg["publishers"] !== undefined && msg["publishers"] !== null) {
var list = msg["publishers"];
for (var f in list) {
var id = list[f]["id"];
var display = list[f]["display"];
newRemoteFeed(id, display);
}
} else if (msg["leaving"] !== undefined && msg["leaving"] !== null) {
// One of the publishers has gone away?
var leaving = msg["leaving"];
var remoteFeed = null;
for (var i = 1; i < 6; i++) {
if (feeds[i] != null && feeds[i] != undefined && feeds[i].rfid == leaving) {
remoteFeed = feeds[i];
break;
}
}
if (remoteFeed != null) {
// REVIEW: Clean container?
feeds[remoteFeed.rfindex] = null;
remoteFeed.detach();
}
} else if (msg["unpublished"] !== undefined && msg["unpublished"] !== null) {
// One of the publishers has unpublished?
var unpublished = msg["unpublished"];
Janus.log("Publisher left: " + unpublished);
if (unpublished === 'ok') {
// That's us
splitAgentHandle.hangup();
return;
}
var remoteFeed = null;
for (var i = 1; i < 6; i++) {
if (feeds[i] != null && feeds[i] != undefined && feeds[i].rfid == unpublished) {
remoteFeed = feeds[i];
break;
}
}
if (remoteFeed != null) {
// TODO: Clean container?
feeds[remoteFeed.rfindex] = null;
remoteFeed.detach();
}
} else if(msg["startedRec"] !== undefined && msg["startedRec"] !== null) {
recordId = msg["recordId"];
recordVideoroom(sessionId, prefixName);
//if(screenRoomHandle !== null) recordScreenroom(screenid, prefixName, msg["recordId"]);
} else if(msg["stoppedRec"] !== undefined && msg["stoppedRec"] !== null) {
stoprecordVideoroom(sessionId);
//if(screenRoomHandle !== null) stoprecordScreenroom(screenid);
} else if(msg["notified"] !== undefined && msg["notified"] !== null) {
if(onEvents && onEvents.onNotified && msg["origin"] !== 'agent') {
Janus.debug("Notification received: " + msg["action"]);
onEvents.onNotified(msg["action"], msg["data"]);
}
} else if (msg["error"] !== undefined && msg["error"] !== null) {
if(onEvents && onEvents.onError) onEvents.onError(msg["error"]);
} else if (msg['result'] !== undefined && msg['result'] !== null) {
var result = msg['result'];
if (result['event'] == 'license_info') {
window.VideoRTC.license = {
screensharing: (result['screensharing'] == 'true'),
livechat: (result['livechat'] == 'true'),
videorecording: (result['videorecording'] == 'true')
};
Janus.debug("License", window.VideoRTC.license);
resolve({
closeUsecase: closeUsecase,
getLicense: getLicense,
notify: notify,
startRecording: startRecording,
stopRecording: stopRecording,
startScreensharing: startScreensharing,
stopScreensharing: stopScreensharing,
toggleVideo: toggleVideo,
sendData: sendData
});
}
}
}
}
if (jsep !== undefined && jsep !== null) {
splitAgentHandle.handleRemoteJsep({jsep: jsep});
}
},
onlocalstream: function(stream) {
// We have a local stream (getUserMedia worked!) to display
var container = domElements.agent;
container.innerHTML = '<video autoplay poster="data:image/gif;base64,R0lGODlhAQABAIAAAAAAAP///yH5BAEAAAAALAAAAAABAAEAAAIBRAA7" id="videoAgent"></video>';
var videoElem = document.getElementById('videoAgent');
Janus.attachMediaStream(videoElem, stream);
videoElem.muted = true;
var videoTracks = stream.getVideoTracks();
if(videoTracks === null || videoTracks === undefined || videoTracks.length === 0) {
// No remote video
var nodeNoCamera = document.createElement('div');
nodeNoCamera.innerHTML = 'No camera available';
nodeNoCamera.style.position = "relative";
nodeNoCamera.style.height = "100%";
nodeNoCamera.style.width = "100%";
nodeNoCamera.style.top = "100%";
nodeNoCamera.style.left = "50%";
nodeNoCamera.style.transform = "translate(-50%,-50%)";
nodeNoCamera.className = "no-camera-available";
container.insertBefore(nodeNoCamera, container.firstChild);
if(onEvents && onEvents.onReadyLocalStream) onEvents.onReadyLocalStream(false);
}
else {
if(onEvents && onEvents.onReadyLocalStream) onEvents.onReadyLocalStream(true);
}
},
onremotestream: function(stream) {
},
oncleanup: function() {
},
detached: function() {
}
});
});
};
exports.splitAgent = splitAgent;