var JanusVideoRoom = (function() {
|
|
|
/**
|
* Interface with Janus Gateway Video Room and WebRTC-streamer API
|
* @constructor
|
* @param {string} janusUrl - url of Janus Gateway
|
* @param {string} srvurl - url of WebRTC-streamer
|
*/
|
var JanusVideoRoom = function JanusVideoRoom (janusUrl, srvurl, bus) {
|
this.janusUrl = janusUrl;
|
this.handlers = [];
|
this.srvurl = srvurl || location.protocol+"//"+window.location.hostname+":"+window.location.port;
|
this.connection = [];
|
this.bus = bus;
|
};
|
|
JanusVideoRoom.prototype._handleHttpErrors = function (response) {
|
if (!response.ok) {
|
throw Error(response.statusText);
|
}
|
return response;
|
}
|
|
/**
|
* Ask to publish a stream from WebRTC-streamer in a Janus Video Room user
|
* @param {string} janusroomid - id of the Janus Video Room to join
|
* @param {string} url - WebRTC stream to publish
|
* @param {string} name - name in Janus Video Room
|
*/
|
JanusVideoRoom.prototype.join = function(janusroomid, url, name) {
|
// create a session
|
var createReq = {janus: "create", transaction: Math.random().toString() };
|
|
fetch(this.janusUrl, { method: "POST", body: JSON.stringify(createReq) })
|
.then(this._handleHttpErrors)
|
.then( (response) => (response.json()) )
|
.then( (response) => this.onCreateSession(response, janusroomid, url, name))
|
.catch( (error) => this.onError("create " + error ))
|
|
}
|
|
/**
|
* Ask to unpublish a stream from WebRTC-streamer in a Janus Video Room user
|
* @param {string} janusroomid - id of the Janus Video Room to join
|
* @param {string} url - WebRTC stream to publish
|
* @param {string} name - name in Janus Video Room
|
*/
|
JanusVideoRoom.prototype.leave = function(janusroomid, url, name) {
|
var connection = this.connection[janusroomid + "_" + url + "_" + name];
|
if (connection) {
|
var sessionId = connection.sessionId;
|
var pluginid = connection.pluginId;
|
|
var leaveReq = { "janus": "message", "body": {"request": "unpublish"}, "transaction": Math.random().toString() };
|
|
|
fetch(this.janusUrl + "/" + sessionId + "/" + pluginid, { method: "POST", body: JSON.stringify(leaveReq) })
|
.then(this._handleHttpErrors)
|
.then( (response) => (response.json()) )
|
.then( (response) => console.log("leave janus room answer:" + response) )
|
.catch( (error) => this.onError("leave " + error ))
|
}
|
}
|
|
|
JanusVideoRoom.prototype.emit = function(name, state) {
|
if (this.bus) {
|
this.bus.emit('state', name, state);
|
}
|
}
|
|
// ------------------------------------------
|
// Janus callback for Session Creation
|
// ------------------------------------------
|
JanusVideoRoom.prototype.onCreateSession = function(dataJson, janusroomid, url, name) {
|
var sessionId = dataJson.data.id;
|
console.log("onCreateSession sessionId:" + sessionId);
|
|
// attach to video room plugin
|
var attachReq = { "janus": "attach", "plugin": "janus.plugin.videoroom", "transaction": Math.random().toString() };
|
|
fetch(this.janusUrl + "/" + sessionId, { method: "POST", body: JSON.stringify(attachReq) })
|
.then(this._handleHttpErrors)
|
.then( (response) => (response.json()) )
|
.then( (response) => this.onPluginsAttached(response, janusroomid, url, name, sessionId) )
|
.catch( (error) => this.onError("attach " + error ))
|
|
}
|
|
// ------------------------------------------
|
// Janus callback for Video Room Plugins Connection
|
// ------------------------------------------
|
JanusVideoRoom.prototype.onPluginsAttached = function(dataJson, janusroomid, url, name, sessionId) {
|
var pluginid = dataJson.data.id;
|
console.log("onPluginsAttached pluginid:" + pluginid);
|
|
this.emit(name, "joining");
|
|
var joinReq = {"janus":"message","body":{"request":"join","room":janusroomid,"ptype":"publisher","display":name},"transaction":Math.random().toString()};
|
|
fetch(this.janusUrl + "/" + sessionId + "/" + pluginid, { method: "POST", body: JSON.stringify(joinReq) })
|
.then(this._handleHttpErrors)
|
.then( (response) => (response.json()) )
|
.then( (response) => this.onJoinRoom(response, janusroomid, url, name, sessionId, pluginid) )
|
.catch( (error) => this.onError("join " + error ))
|
|
}
|
|
// ------------------------------------------
|
// Janus callback for Video Room Joined
|
// ------------------------------------------
|
JanusVideoRoom.prototype.onJoinRoom = function(dataJson,janusroomid,url,name,sessionId,pluginid) {
|
console.log("onJoinRoom:" + JSON.stringify(dataJson));
|
|
fetch(this.janusUrl + "/" + sessionId + "?rid=" + new Date().getTime() + "&maxev=1")
|
.then(this._handleHttpErrors)
|
.then( (response) => (response.json()) )
|
.then( (response) => this.onJoinRoomResult(response, janusroomid, url, name, sessionId, pluginid) )
|
.catch( (error) => this.onError("join anwser " + error ))
|
}
|
|
// ------------------------------------------
|
// Janus callback for Video Room Joined
|
// ------------------------------------------
|
JanusVideoRoom.prototype.onJoinRoomResult = function(dataJson,janusroomid,url,name,sessionId,pluginid) {
|
console.log("onJoinRoomResult:" + JSON.stringify(dataJson));
|
|
if (dataJson.plugindata.data.videoroom === "joined") {
|
// register connection
|
this.connection[janusroomid + "_" + url + "_" + name] = {"sessionId":sessionId, "pluginId": pluginid };
|
|
// member of the room
|
var publishers = dataJson.plugindata.data.publishers;
|
for (var i=0; i<publishers.length; i++) {
|
var publisher = publishers[i];
|
this.emit(publisher.display, "up");
|
}
|
|
if (name) {
|
// notify new state
|
this.emit(name, "joined");
|
|
var peerid = Math.random().toString();
|
|
var videourl = url.video || url;
|
var createOfferUrl = this.srvurl + "/api/createOffer?peerid="+ peerid+"&url="+encodeURIComponent(videourl);
|
if (url.audio) {
|
createOfferUrl += "&audiourl="+encodeURIComponent(url.audio);
|
}
|
if (url.options) {
|
createOfferUrl += "&options="+encodeURIComponent(url.options);
|
}
|
|
fetch(createOfferUrl)
|
.then(this._handleHttpErrors)
|
.then( (response) => (response.json()) )
|
.then( (response) => this.onCreateOffer(response, name, sessionId, pluginid, peerid) )
|
.catch( (error) => this.onError("createOffer " + error ))
|
|
} else {
|
// start long polling
|
this.longpoll(null, name, sessionId);
|
}
|
} else {
|
this.emit(name, "joining room failed");
|
}
|
}
|
|
// ------------------------------------------
|
// WebRTC streamer callback for Offer
|
// ------------------------------------------
|
JanusVideoRoom.prototype.onCreateOffer = function(dataJson,name,sessionId,pluginid,peerid) {
|
console.log("onCreateOffer:" + JSON.stringify(dataJson));
|
|
this.emit(name, "publishing");
|
|
var publishReq = { "janus": "message", "body": {"request": "publish", "video": true, "audio": true, "data": true}, "jsep": dataJson, "transaction": Math.random().toString() };
|
|
fetch(this.janusUrl + "/" + sessionId + "/" + pluginid, { method: "POST", body: JSON.stringify(publishReq) })
|
.then(this._handleHttpErrors)
|
.then( (response) => (response.json()) )
|
.then( (response) => this.onPublishStream(response, name, sessionId, pluginid, peerid) )
|
.catch( (error) => this.onError("publish " + error ))
|
|
}
|
|
// ------------------------------------------
|
// Janus callback for WebRTC stream is published
|
// ------------------------------------------
|
JanusVideoRoom.prototype.onPublishStream = function(dataJson,name,sessionId,pluginid,peerid) {
|
console.log("onPublishStream:" + JSON.stringify(dataJson));
|
|
fetch(this.janusUrl + "/" + sessionId + "?rid=" + new Date().getTime() + "&maxev=1")
|
.then(this._handleHttpErrors)
|
.then( (response) => (response.json()) )
|
.then( (response) => this.onPublishStreamResult(response, name, sessionId, pluginid, peerid) )
|
.catch( (error) => this.onError("publish anwser " + error ))
|
|
}
|
|
// ------------------------------------------
|
// Janus callback for WebRTC stream is published
|
// ------------------------------------------
|
JanusVideoRoom.prototype.onPublishStreamResult = function(dataJson,name,sessionId,pluginid,peerid) {
|
console.log("onPublishStreamResult:" + JSON.stringify(dataJson));
|
|
if (dataJson.jsep) {
|
fetch(this.srvurl + "/api/setAnswer?peerid="+ peerid, { method: "POST", body: JSON.stringify(dataJson.jsep) })
|
.then(this._handleHttpErrors)
|
.then( (response) => (response.json()) )
|
.then( (response) => this.onSetAnswer(response, name, sessionId, pluginid, peerid) )
|
.catch( (error) => this.onError("setAnswer " + error ))
|
|
} else {
|
this.emit(name, "publishing failed (no SDP)");
|
}
|
}
|
|
// ------------------------------------------
|
// WebRTC streamer callback for Answer
|
// ------------------------------------------
|
JanusVideoRoom.prototype.onSetAnswer = function(dataJson,name,sessionId,pluginid,peerid) {
|
console.log("onSetAnswer:" + JSON.stringify(dataJson));
|
|
fetch(this.srvurl + "/api/getIceCandidate?peerid="+peerid)
|
.then(this._handleHttpErrors)
|
.then( (response) => (response.json()) )
|
.then( (response) => this.onReceiveCandidate(response, name, sessionId, pluginid) )
|
.catch( (error) => this.onError("getIceCandidate " + error ))
|
|
}
|
|
// ------------------------------------------
|
// WebRTC streamer callback for ICE candidate
|
// ------------------------------------------
|
JanusVideoRoom.prototype.onReceiveCandidate = function(dataJson,name,sessionId,pluginid) {
|
console.log("onReceiveCandidate answer:" + JSON.stringify(dataJson));
|
|
for (var i=0; i<dataJson.length; i++) {
|
// send ICE candidate to Janus
|
var candidateReq = { "janus": "trickle", "candidate": dataJson[i], "transaction": Math.random().toString() };
|
|
fetch(this.janusUrl + "/" + sessionId + "/" + pluginid, { method: "POST", body: JSON.stringify(candidateReq) })
|
.then(this._handleHttpErrors)
|
.then( (response) => (response.json()) )
|
.then( (response) => console.log("onReceiveCandidate janus answer:" + JSON.stringify(response)) )
|
.catch( (error) => this.onError("setAnswer " + error ))
|
|
}
|
|
// start long polling
|
this.longpoll(null, name, sessionId);
|
}
|
|
// ------------------------------------------
|
// Janus callback for keepAlive Session
|
// ------------------------------------------
|
JanusVideoRoom.prototype.keepAlive = function(sessionId) {
|
var keepAliveReq = { "janus": "keepalive", "session_id": sessionId, "transaction": Math.random().toString() };
|
|
fetch(this.janusUrl + "/" + sessionId, { method: "POST", body: JSON.stringify(keepAliveReq) })
|
.then(this._handleHttpErrors)
|
.then( (response) => (response.json()) )
|
.then( (response) => console.log("keepAlive answer:" + JSON.stringify(response)) )
|
.catch( (error) => this.onError("keepAlive " + error ))
|
|
}
|
|
// ------------------------------------------
|
// Janus callback for Long Polling
|
// ------------------------------------------
|
JanusVideoRoom.prototype.longpoll = function(dataJson, name, sessionId) {
|
if (dataJson) {
|
console.log("poll evt:" + JSON.stringify(dataJson));
|
|
if (dataJson.janus === "webrtcup") {
|
// notify connection
|
this.emit(name, "up");
|
|
// start keep alive
|
var bind = this;
|
setInterval( function() { bind.keepAlive(sessionId); }, 10000);
|
}
|
else if (dataJson.janus === "hangup") {
|
// notify connection
|
this.emit(name, "down");
|
}
|
else if (dataJson.janus === "event") {
|
// member of the room
|
var publishers = dataJson.plugindata.data.publishers;
|
if (publishers) {
|
for (var i=0; i<publishers.length; i++) {
|
var publisher = publishers[i];
|
this.emit(publisher.display, "up");
|
}
|
}
|
}
|
}
|
|
fetch(this.janusUrl + "/" + sessionId + "?rid=" + new Date().getTime() + "&maxev=1")
|
.then(this._handleHttpErrors)
|
.then( (response) => (response.json()) )
|
.then( (response) => this.longpoll(response, name, sessionId) )
|
.catch( (error) => this.onError("longpoll anwser " + error ))
|
|
}
|
|
// ------------------------------------------
|
// Janus callback for Error
|
// ------------------------------------------
|
JanusVideoRoom.prototype.onError = function(status) {
|
console.log("onError:" + status);
|
}
|
|
|
return JanusVideoRoom;
|
})();
|
|
if (typeof window !== 'undefined' && typeof window.document !== 'undefined') {
|
window.JanusVideoRoom = JanusVideoRoom;
|
}
|
if (typeof module !== 'undefined' && typeof module.exports !== 'undefined') {
|
module.exports = JanusVideoRoom;
|
}
|
|
