ambiser
/
openvidu
mirror of https://github.com/OpenVidu/openvidu.git
8
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

openvidu-node-client recording support

pull/39/head
pabloFuente 2018-03-14 18:48:29 +01:00
parent bd8b1d5340
commit e462277cde
17 changed files with 620 additions and 104 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
openvidu-node-client/lib/OpenVidu.d.ts vendored
View File

@ -1,10 +1,21 @@
import { Session } from "./Session";
import { SessionProperties } from "./SessionProperties";
import { Archive } from "./Archive";
export declare class OpenVidu {
private urlOpenViduServer;
private secret;
private static readonly API_RECORDINGS;
private static readonly API_RECORDINGS_START;
private static readonly API_RECORDINGS_STOP;
private hostname;
private port;
private basicAuth;
constructor(urlOpenViduServer: string, secret: string);
createSession(properties?: SessionProperties): Session;
startArchive(sessionId: string): void;
stopArchive(sessionId: string): void;
startRecording(sessionId: string): Promise<Archive>;
stopRecording(recordingId: string): Promise<Archive>;
getRecording(recordingId: string): Promise<Archive>;
listRecordings(): Promise<Archive[]>;
deleteRecording(recordingId: string): Promise<Error>;
private getBasicAuth(secret);
private setHostnameAndPort();
}

223
openvidu-node-client/lib/OpenVidu.js
View File

@ -1,20 +1,231 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
var Session_1 = require("./Session");
var Archive_1 = require("./Archive");
var https = require('https');
var OpenVidu = /** @class */ (function () {
function OpenVidu(urlOpenViduServer, secret) {
this.urlOpenViduServer = urlOpenViduServer;
this.secret = secret;
this.setHostnameAndPort();
this.basicAuth = this.getBasicAuth(secret);
}
OpenVidu.prototype.createSession = function (properties) {
return new Session_1.Session(this.urlOpenViduServer, this.secret, properties);
return new Session_1.Session(this.hostname, this.port, this.basicAuth, properties);
};
OpenVidu.prototype.startArchive = function (sessionId) {
// TODO: REST POST to start recording in OpenVidu Server
OpenVidu.prototype.startRecording = function (sessionId) {
var _this = this;
return new Promise(function (resolve, reject) {
var requestBody = JSON.stringify({
'session': sessionId
});
var options = {
hostname: _this.hostname,
port: _this.port,
path: OpenVidu.API_RECORDINGS + OpenVidu.API_RECORDINGS_START,
method: 'POST',
headers: {
'Authorization': _this.basicAuth,
'Content-Type': 'application/json',
'Content-Length': Buffer.byteLength(requestBody)
}
};
var req = https.request(options, function (res) {
var body = '';
res.on('data', function (d) {
// Continuously update stream with data
body += d;
});
res.on('end', function () {
if (res.statusCode === 200) {
// SUCCESS response from openvidu-server (Archive in JSON format). Resolve new Archive
resolve(new Archive_1.Archive(JSON.parse(body)));
}
else {
// ERROR response from openvidu-server. Resolve HTTP status
reject(new Error(res.statusCode));
}
});
});
req.on('error', function (e) {
reject(new Error(e));
});
req.write(requestBody);
req.end();
});
};
OpenVidu.prototype.stopArchive = function (sessionId) {
// TODO: REST POST to end recording in OpenVidu Server
OpenVidu.prototype.stopRecording = function (recordingId) {
var _this = this;
return new Promise(function (resolve, reject) {
var options = {
hostname: _this.hostname,
port: _this.port,
path: OpenVidu.API_RECORDINGS + OpenVidu.API_RECORDINGS_STOP + '/' + recordingId,
method: 'POST',
headers: {
'Authorization': _this.basicAuth,
'Content-Type': 'application/x-www-form-urlencoded'
}
};
var req = https.request(options, function (res) {
var body = '';
res.on('data', function (d) {
// Continuously update stream with data
body += d;
});
res.on('end', function () {
if (res.statusCode === 200) {
// SUCCESS response from openvidu-server (Archive in JSON format). Resolve new Archive
resolve(new Archive_1.Archive(JSON.parse(body)));
}
else {
// ERROR response from openvidu-server. Resolve HTTP status
reject(new Error(res.statusCode));
}
});
});
req.on('error', function (e) {
reject(new Error(e));
});
//req.write();
req.end();
});
};
OpenVidu.prototype.getRecording = function (recordingId) {
var _this = this;
return new Promise(function (resolve, reject) {
var options = {
hostname: _this.hostname,
port: _this.port,
path: OpenVidu.API_RECORDINGS + '/' + recordingId,
method: 'GET',
headers: {
'Authorization': _this.basicAuth,
'Content-Type': 'application/x-www-form-urlencoded'
}
};
var req = https.request(options, function (res) {
var body = '';
res.on('data', function (d) {
// Continuously update stream with data
body += d;
});
res.on('end', function () {
if (res.statusCode === 200) {
// SUCCESS response from openvidu-server (Archive in JSON format). Resolve new Archive
resolve(new Archive_1.Archive(JSON.parse(body)));
}
else {
// ERROR response from openvidu-server. Resolve HTTP status
reject(new Error(res.statusCode));
}
});
});
req.on('error', function (e) {
reject(new Error(e));
});
//req.write();
req.end();
});
};
OpenVidu.prototype.listRecordings = function () {
var _this = this;
return new Promise(function (resolve, reject) {
var options = {
hostname: _this.hostname,
port: _this.port,
path: OpenVidu.API_RECORDINGS,
method: 'GET',
headers: {
'Authorization': _this.basicAuth,
'Content-Type': 'application/x-www-form-urlencoded'
}
};
var req = https.request(options, function (res) {
var body = '';
res.on('data', function (d) {
// Continuously update stream with data
body += d;
});
res.on('end', function () {
if (res.statusCode === 200) {
// SUCCESS response from openvidu-server (JSON arrays of Archives in JSON format). Resolve list of new Archives
var archiveArray = [];
var responseItems = JSON.parse(body)['items'];
for (var i = 0; i < responseItems.length; i++) {
archiveArray.push(new Archive_1.Archive(responseItems[i]));
}
resolve(archiveArray);
}
else {
// ERROR response from openvidu-server. Resolve HTTP status
reject(new Error(res.statusCode));
}
});
});
req.on('error', function (e) {
reject(new Error(e));
});
//req.write();
req.end();
});
};
OpenVidu.prototype.deleteRecording = function (recordingId) {
var _this = this;
return new Promise(function (resolve, reject) {
var options = {
hostname: _this.hostname,
port: _this.port,
path: OpenVidu.API_RECORDINGS + '/' + recordingId,
method: 'DELETE',
headers: {
'Authorization': _this.basicAuth,
'Content-Type': 'application/x-www-form-urlencoded'
}
};
var req = https.request(options, function (res) {
var body = '';
res.on('data', function (d) {
// Continuously update stream with data
body += d;
});
res.on('end', function () {
if (res.statusCode === 204) {
// SUCCESS response from openvidu-server. Resolve undefined
resolve(undefined);
}
else {
// ERROR response from openvidu-server. Resolve HTTP status
reject(new Error(res.statusCode));
}
});
});
req.on('error', function (e) {
reject(new Error(e));
});
//req.write();
req.end();
});
};
OpenVidu.prototype.getBasicAuth = function (secret) {
return 'Basic ' + (new Buffer('OPENVIDUAPP:' + secret).toString('base64'));
};
OpenVidu.prototype.setHostnameAndPort = function () {
var urlSplitted = this.urlOpenViduServer.split(':');
if (urlSplitted.length === 3) {
this.hostname = this.urlOpenViduServer.split(':')[1].replace(/\//g, '');
this.port = parseInt(this.urlOpenViduServer.split(':')[2].replace(/\//g, ''));
}
else if (urlSplitted.length == 2) {
this.hostname = this.urlOpenViduServer.split(':')[0].replace(/\//g, '');
this.port = parseInt(this.urlOpenViduServer.split(':')[1].replace(/\//g, ''));
}
else {
console.error("URL format incorrect: it must contain hostname and port (current value: '" + this.urlOpenViduServer + "')");
}
};
OpenVidu.API_RECORDINGS = '/api/recordings';
OpenVidu.API_RECORDINGS_START = '/start';
OpenVidu.API_RECORDINGS_STOP = '/stop';
return OpenVidu;
}());
exports.OpenVidu = OpenVidu;

2
openvidu-node-client/lib/OpenVidu.js.map
View File

File diff suppressed because one or more lines are too long

15
openvidu-node-client/lib/Session.d.ts vendored
View File

@ -1,19 +1,16 @@
import { TokenOptions } from './TokenOptions';
import { SessionProperties } from './SessionProperties';
export declare class Session {
private urlOpenViduServer;
private secret;
private sessionIdURL;
private tokenURL;
private sessionId;
private properties;
private hostname;
private port;
constructor(urlOpenViduServer: string, secret: string, properties?: SessionProperties);
private basicAuth;
private static readonly API_SESSIONS;
private static readonly API_TOKENS;
private sessionId;
private properties;
constructor(hostname: string, port: number, basicAuth: string, properties?: SessionProperties);
getSessionId(callback: Function): void;
generateToken(callback: Function): any;
generateToken(tokenOptions: TokenOptions, callback: Function): any;
getProperties(): SessionProperties;
private getBasicAuth();
private setHostnameAndPort();
}

63
openvidu-node-client/lib/Session.js
View File

@ -4,11 +4,10 @@ var OpenViduRole_1 = require("./OpenViduRole");
var SessionProperties_1 = require("./SessionProperties");
var https = require('https');
var Session = /** @class */ (function () {
function Session(urlOpenViduServer, secret, properties) {
this.urlOpenViduServer = urlOpenViduServer;
this.secret = secret;
this.sessionIdURL = '/api/sessions';
this.tokenURL = '/api/tokens';
function Session(hostname, port, basicAuth, properties) {
this.hostname = hostname;
this.port = port;
this.basicAuth = basicAuth;
this.sessionId = "";
if (properties == null) {
this.properties = new SessionProperties_1.SessionProperties.Builder().build();
@ -16,7 +15,6 @@ var Session = /** @class */ (function () {
else {
this.properties = properties;
}
this.setHostnameAndPort();
}
Session.prototype.getSessionId = function (callback) {
var _this = this;
@ -32,10 +30,10 @@ var Session = /** @class */ (function () {
var options = {
hostname: this.hostname,
port: this.port,
path: this.sessionIdURL,
path: Session.API_SESSIONS,
method: 'POST',
headers: {
'Authorization': this.getBasicAuth(),
'Authorization': this.basicAuth,
'Content-Type': 'application/json',
'Content-Length': Buffer.byteLength(requestBody)
}
@ -47,10 +45,16 @@ var Session = /** @class */ (function () {
body += d;
});
res.on('end', function () {
// Data reception is done
var parsed = JSON.parse(body);
_this.sessionId = parsed.id;
callback(parsed.id);
if (res.statusCode === 200) {
// SUCCESS response from openvidu-server. Resolve sessionId
var parsed = JSON.parse(body);
_this.sessionId = parsed.id;
callback(parsed.id);
}
else {
// ERROR response from openvidu-server. Resolve HTTP status
console.error(res.statusCode);
}
});
});
req.on('error', function (e) {
@ -79,10 +83,10 @@ var Session = /** @class */ (function () {
var options = {
hostname: this.hostname,
port: this.port,
path: this.tokenURL,
path: Session.API_TOKENS,
method: 'POST',
headers: {
'Authorization': this.getBasicAuth(),
'Authorization': this.basicAuth,
'Content-Type': 'application/json',
'Content-Length': Buffer.byteLength(requestBody)
}
@ -94,9 +98,15 @@ var Session = /** @class */ (function () {
body += d;
});
res.on('end', function () {
// Data reception is done
var parsed = JSON.parse(body);
callback(parsed.id);
if (res.statusCode === 200) {
// SUCCESS response from openvidu-server. Resolve token
var parsed = JSON.parse(body);
callback(parsed.id);
}
else {
// ERROR response from openvidu-server. Resolve HTTP status
console.error(res.statusCode);
}
});
});
req.on('error', function (e) {
@ -108,23 +118,8 @@ var Session = /** @class */ (function () {
Session.prototype.getProperties = function () {
return this.properties;
};
Session.prototype.getBasicAuth = function () {
return 'Basic ' + (new Buffer('OPENVIDUAPP:' + this.secret).toString('base64'));
};
Session.prototype.setHostnameAndPort = function () {
var urlSplitted = this.urlOpenViduServer.split(':');
if (urlSplitted.length === 3) {
this.hostname = this.urlOpenViduServer.split(':')[1].replace(/\//g, '');
this.port = parseInt(this.urlOpenViduServer.split(':')[2].replace(/\//g, ''));
}
else if (urlSplitted.length == 2) {
this.hostname = this.urlOpenViduServer.split(':')[0].replace(/\//g, '');
this.port = parseInt(this.urlOpenViduServer.split(':')[1].replace(/\//g, ''));
}
else {
console.error("URL format incorrect: it must contain hostname and port (current value: '" + this.urlOpenViduServer + "')");
}
};
Session.API_SESSIONS = '/api/sessions';
Session.API_TOKENS = '/api/tokens';
return Session;
}());
exports.Session = Session;

2
openvidu-node-client/lib/Session.js.map
View File

@ -1 +1 @@
{"version":3,"file":"Session.js","sourceRoot":"","sources":["../src/Session.ts"],"names":[],"mappings":";;AACA,+CAA8C;AAC9C,yDAAwD;AAKxD,IAAI,KAAK,GAAG,OAAO,CAAC,OAAO,CAAC,CAAC;AAE7B;IASI,iBAAoB,iBAAyB,EAAU,MAAc,EAAE,UAA8B;QAAjF,sBAAiB,GAAjB,iBAAiB,CAAQ;QAAU,WAAM,GAAN,MAAM,CAAQ;QAP7D,iBAAY,GAAW,eAAe,CAAC;QACvC,aAAQ,GAAW,aAAa,CAAC;QACjC,cAAS,GAAW,EAAE,CAAC;QAM3B,EAAE,CAAC,CAAC,UAAU,IAAI,IAAI,CAAC,CAAC,CAAC;YACrB,IAAI,CAAC,UAAU,GAAG,IAAI,qCAAiB,CAAC,OAAO,EAAE,CAAC,KAAK,EAAE,CAAC;QAC9D,CAAC;QAAC,IAAI,CAAC,CAAC;YACJ,IAAI,CAAC,UAAU,GAAG,UAAU,CAAC;QACjC,CAAC;QACD,IAAI,CAAC,kBAAkB,EAAE,CAAC;IAC9B,CAAC;IAEM,8BAAY,GAAnB,UAAoB,QAAkB;QAAtC,iBA2CC;QAzCG,EAAE,CAAC,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC,CAAC;YACjB,QAAQ,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC;YACzB,MAAM,CAAC;QACX,CAAC;QAED,IAAI,WAAW,GAAG,IAAI,CAAC,SAAS,CAAC;YAC7B,eAAe,EAAE,IAAI,CAAC,UAAU,CAAC,aAAa,EAAE;YAChD,aAAa,EAAE,IAAI,CAAC,UAAU,CAAC,WAAW,EAAE;YAC5C,WAAW,EAAE,IAAI,CAAC,UAAU,CAAC,SAAS,EAAE;SAC3C,CAAC,CAAC;QAEH,IAAI,OAAO,GAAG;YACV,QAAQ,EAAE,IAAI,CAAC,QAAQ;YACvB,IAAI,EAAE,IAAI,CAAC,IAAI;YACf,IAAI,EAAE,IAAI,CAAC,YAAY;YACvB,MAAM,EAAE,MAAM;YACd,OAAO,EAAE;gBACL,eAAe,EAAE,IAAI,CAAC,YAAY,EAAE;gBACpC,cAAc,EAAE,kBAAkB;gBAClC,gBAAgB,EAAE,MAAM,CAAC,UAAU,CAAC,WAAW,CAAC;aACnD;SACJ,CAAA;QACD,IAAM,GAAG,GAAG,KAAK,CAAC,OAAO,CAAC,OAAO,EAAE,UAAC,GAAG;YACnC,IAAI,IAAI,GAAG,EAAE,CAAC;YACd,GAAG,CAAC,EAAE,CAAC,MAAM,EAAE,UAAC,CAAC;gBACb,uCAAuC;gBACvC,IAAI,IAAI,CAAC,CAAC;YACd,CAAC,CAAC,CAAC;YACH,GAAG,CAAC,EAAE,CAAC,KAAK,EAAE;gBACV,yBAAyB;gBACzB,IAAI,MAAM,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;gBAC9B,KAAI,CAAC,SAAS,GAAG,MAAM,CAAC,EAAE,CAAC;gBAC3B,QAAQ,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;YACxB,CAAC,CAAC,CAAC;QACP,CAAC,CAAC,CAAC;QAEH,GAAG,CAAC,EAAE,CAAC,OAAO,EAAE,UAAC,CAAC;YACd,OAAO,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;QACrB,CAAC,CAAC,CAAC;QACH,GAAG,CAAC,KAAK,CAAC,WAAW,CAAC,CAAC;QACvB,GAAG,CAAC,GAAG,EAAE,CAAC;IACd,CAAC;IAKM,+BAAa,GAApB,UAAqB,YAAiB,EAAE,QAAc;QAClD,IAAI,WAAW,CAAC;QAEhB,EAAE,CAAC,CAAC,QAAQ,CAAC,CAAC,CAAC;YACX,WAAW,GAAG,IAAI,CAAC,SAAS,CAAC;gBACzB,SAAS,EAAE,IAAI,CAAC,SAAS;gBACzB,MAAM,EAAE,YAAY,CAAC,OAAO,EAAE;gBAC9B,MAAM,EAAE,YAAY,CAAC,OAAO,EAAE;aACjC,CAAC,CAAC;QACP,CAAC;QAAC,IAAI,CAAC,CAAC;YACJ,WAAW,GAAG,IAAI,CAAC,SAAS,CAAC;gBACzB,SAAS,EAAE,IAAI,CAAC,SAAS;gBACzB,MAAM,EAAE,2BAAY,CAAC,SAAS;gBAC9B,MAAM,EAAE,EAAE;aACb,CAAC,CAAC;YACH,QAAQ,GAAG,YAAY,CAAC;QAC5B,CAAC;QAED,IAAI,OAAO,GAAG;YACV,QAAQ,EAAE,IAAI,CAAC,QAAQ;YACvB,IAAI,EAAE,IAAI,CAAC,IAAI;YACf,IAAI,EAAE,IAAI,CAAC,QAAQ;YACnB,MAAM,EAAE,MAAM;YACd,OAAO,EAAE;gBACL,eAAe,EAAE,IAAI,CAAC,YAAY,EAAE;gBACpC,cAAc,EAAE,kBAAkB;gBAClC,gBAAgB,EAAE,MAAM,CAAC,UAAU,CAAC,WAAW,CAAC;aACnD;SACJ,CAAC;QACF,IAAM,GAAG,GAAG,KAAK,CAAC,OAAO,CAAC,OAAO,EAAE,UAAC,GAAG;YACnC,IAAI,IAAI,GAAG,EAAE,CAAC;YACd,GAAG,CAAC,EAAE,CAAC,MAAM,EAAE,UAAC,CAAC;gBACb,uCAAuC;gBACvC,IAAI,IAAI,CAAC,CAAC;YACd,CAAC,CAAC,CAAC;YACH,GAAG,CAAC,EAAE,CAAC,KAAK,EAAE;gBACV,yBAAyB;gBACzB,IAAI,MAAM,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;gBAC9B,QAAQ,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;YACxB,CAAC,CAAC,CAAC;QACP,CAAC,CAAC,CAAC;QAEH,GAAG,CAAC,EAAE,CAAC,OAAO,EAAE,UAAC,CAAC;YACd,OAAO,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;QACrB,CAAC,CAAC,CAAC;QACH,GAAG,CAAC,KAAK,CAAC,WAAW,CAAC,CAAC;QACvB,GAAG,CAAC,GAAG,EAAE,CAAC;IACd,CAAC;IAEM,+BAAa,GAApB;QACF,MAAM,CAAC,IAAI,CAAC,UAAU,CAAC;IACxB,CAAC;IAEU,8BAAY,GAApB;QACI,MAAM,CAAC,QAAQ,GAAG,CAAC,IAAI,MAAM,CAAC,cAAc,GAAG,IAAI,CAAC,MAAM,CAAC,CAAC,QAAQ,CAAC,QAAQ,CAAC,CAAC,CAAC;IACpF,CAAC;IAEO,oCAAkB,GAA1B;QACI,IAAI,WAAW,GAAG,IAAI,CAAC,iBAAiB,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;QACpD,EAAE,CAAC,CAAC,WAAW,CAAC,MAAM,KAAK,CAAC,CAAC,CAAC,CAAC;YAC3B,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAC,iBAAiB,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,CAAC,OAAO,CAAC,KAAK,EAAE,EAAE,CAAC,CAAC;YACxE,IAAI,CAAC,IAAI,GAAG,QAAQ,CAAC,IAAI,CAAC,iBAAiB,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,CAAC,OAAO,CAAC,KAAK,EAAE,EAAE,CAAC,CAAC,CAAC;QAClF,CAAC;QAAC,IAAI,CAAC,EAAE,CAAC,CAAC,WAAW,CAAC,MAAM,IAAI,CAAC,CAAC,CAAC,CAAC;YACjC,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAC,iBAAiB,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,CAAC,OAAO,CAAC,KAAK,EAAE,EAAE,CAAC,CAAC;YACxE,IAAI,CAAC,IAAI,GAAG,QAAQ,CAAC,IAAI,CAAC,iBAAiB,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,CAAC,OAAO,CAAC,KAAK,EAAE,EAAE,CAAC,CAAC,CAAC;QAClF,CAAC;QAAC,IAAI,CAAC,CAAC;YACJ,OAAO,CAAC,KAAK,CAAC,2EAA2E,GAAG,IAAI,CAAC,iBAAiB,GAAG,IAAI,CAAC,CAAC;QAC/H,CAAC;IACL,CAAC;IAEL,cAAC;AAAD,CAAC,AAxID,IAwIC;AAxIY,0BAAO"}
{"version":3,"file":"Session.js","sourceRoot":"","sources":["../src/Session.ts"],"names":[],"mappings":";;AACA,+CAA8C;AAC9C,yDAAwD;AAKxD,IAAI,KAAK,GAAG,OAAO,CAAC,OAAO,CAAC,CAAC;AAE7B;IAQI,iBAAoB,QAAgB,EAAU,IAAY,EAAU,SAAiB,EAAE,UAA8B;QAAjG,aAAQ,GAAR,QAAQ,CAAQ;QAAU,SAAI,GAAJ,IAAI,CAAQ;QAAU,cAAS,GAAT,SAAS,CAAQ;QAH7E,cAAS,GAAW,EAAE,CAAC;QAI3B,EAAE,CAAC,CAAC,UAAU,IAAI,IAAI,CAAC,CAAC,CAAC;YACrB,IAAI,CAAC,UAAU,GAAG,IAAI,qCAAiB,CAAC,OAAO,EAAE,CAAC,KAAK,EAAE,CAAC;QAC9D,CAAC;QAAC,IAAI,CAAC,CAAC;YACJ,IAAI,CAAC,UAAU,GAAG,UAAU,CAAC;QACjC,CAAC;IACL,CAAC;IAEM,8BAAY,GAAnB,UAAoB,QAAkB;QAAtC,iBAgDC;QA9CG,EAAE,CAAC,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC,CAAC;YACjB,QAAQ,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC;YACzB,MAAM,CAAC;QACX,CAAC;QAED,IAAI,WAAW,GAAG,IAAI,CAAC,SAAS,CAAC;YAC7B,eAAe,EAAE,IAAI,CAAC,UAAU,CAAC,aAAa,EAAE;YAChD,aAAa,EAAE,IAAI,CAAC,UAAU,CAAC,WAAW,EAAE;YAC5C,WAAW,EAAE,IAAI,CAAC,UAAU,CAAC,SAAS,EAAE;SAC3C,CAAC,CAAC;QAEH,IAAI,OAAO,GAAG;YACV,QAAQ,EAAE,IAAI,CAAC,QAAQ;YACvB,IAAI,EAAE,IAAI,CAAC,IAAI;YACf,IAAI,EAAE,OAAO,CAAC,YAAY;YAC1B,MAAM,EAAE,MAAM;YACd,OAAO,EAAE;gBACL,eAAe,EAAE,IAAI,CAAC,SAAS;gBAC/B,cAAc,EAAE,kBAAkB;gBAClC,gBAAgB,EAAE,MAAM,CAAC,UAAU,CAAC,WAAW,CAAC;aACnD;SACJ,CAAA;QACD,IAAM,GAAG,GAAG,KAAK,CAAC,OAAO,CAAC,OAAO,EAAE,UAAC,GAAG;YACnC,IAAI,IAAI,GAAG,EAAE,CAAC;YACd,GAAG,CAAC,EAAE,CAAC,MAAM,EAAE,UAAC,CAAC;gBACb,uCAAuC;gBACvC,IAAI,IAAI,CAAC,CAAC;YACd,CAAC,CAAC,CAAC;YACH,GAAG,CAAC,EAAE,CAAC,KAAK,EAAE;gBACV,EAAE,CAAC,CAAC,GAAG,CAAC,UAAU,KAAK,GAAG,CAAC,CAAC,CAAC;oBACzB,2DAA2D;oBAC3D,IAAI,MAAM,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;oBAC9B,KAAI,CAAC,SAAS,GAAG,MAAM,CAAC,EAAE,CAAC;oBAC3B,QAAQ,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;gBACxB,CAAC;gBAAC,IAAI,CAAC,CAAC;oBACJ,2DAA2D;oBAC3D,OAAO,CAAC,KAAK,CAAC,GAAG,CAAC,UAAU,CAAC,CAAC;gBAClC,CAAC;YACL,CAAC,CAAC,CAAC;QACP,CAAC,CAAC,CAAC;QAEH,GAAG,CAAC,EAAE,CAAC,OAAO,EAAE,UAAC,CAAC;YACd,OAAO,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;QACrB,CAAC,CAAC,CAAC;QACH,GAAG,CAAC,KAAK,CAAC,WAAW,CAAC,CAAC;QACvB,GAAG,CAAC,GAAG,EAAE,CAAC;IACd,CAAC;IAKM,+BAAa,GAApB,UAAqB,YAAiB,EAAE,QAAc;QAClD,IAAI,WAAW,CAAC;QAEhB,EAAE,CAAC,CAAC,QAAQ,CAAC,CAAC,CAAC;YACX,WAAW,GAAG,IAAI,CAAC,SAAS,CAAC;gBACzB,SAAS,EAAE,IAAI,CAAC,SAAS;gBACzB,MAAM,EAAE,YAAY,CAAC,OAAO,EAAE;gBAC9B,MAAM,EAAE,YAAY,CAAC,OAAO,EAAE;aACjC,CAAC,CAAC;QACP,CAAC;QAAC,IAAI,CAAC,CAAC;YACJ,WAAW,GAAG,IAAI,CAAC,SAAS,CAAC;gBACzB,SAAS,EAAE,IAAI,CAAC,SAAS;gBACzB,MAAM,EAAE,2BAAY,CAAC,SAAS;gBAC9B,MAAM,EAAE,EAAE;aACb,CAAC,CAAC;YACH,QAAQ,GAAG,YAAY,CAAC;QAC5B,CAAC;QAED,IAAI,OAAO,GAAG;YACV,QAAQ,EAAE,IAAI,CAAC,QAAQ;YACvB,IAAI,EAAE,IAAI,CAAC,IAAI;YACf,IAAI,EAAE,OAAO,CAAC,UAAU;YACxB,MAAM,EAAE,MAAM;YACd,OAAO,EAAE;gBACL,eAAe,EAAE,IAAI,CAAC,SAAS;gBAC/B,cAAc,EAAE,kBAAkB;gBAClC,gBAAgB,EAAE,MAAM,CAAC,UAAU,CAAC,WAAW,CAAC;aACnD;SACJ,CAAC;QACF,IAAM,GAAG,GAAG,KAAK,CAAC,OAAO,CAAC,OAAO,EAAE,UAAC,GAAG;YACnC,IAAI,IAAI,GAAG,EAAE,CAAC;YACd,GAAG,CAAC,EAAE,CAAC,MAAM,EAAE,UAAC,CAAC;gBACb,uCAAuC;gBACvC,IAAI,IAAI,CAAC,CAAC;YACd,CAAC,CAAC,CAAC;YACH,GAAG,CAAC,EAAE,CAAC,KAAK,EAAE;gBACV,EAAE,CAAC,CAAC,GAAG,CAAC,UAAU,KAAK,GAAG,CAAC,CAAC,CAAC;oBACzB,uDAAuD;oBACvD,IAAI,MAAM,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;oBAC9B,QAAQ,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;gBACxB,CAAC;gBAAC,IAAI,CAAC,CAAC;oBACJ,2DAA2D;oBAC3D,OAAO,CAAC,KAAK,CAAC,GAAG,CAAC,UAAU,CAAC,CAAC;gBAClC,CAAC;YACL,CAAC,CAAC,CAAC;QACP,CAAC,CAAC,CAAC;QAEH,GAAG,CAAC,EAAE,CAAC,OAAO,EAAE,UAAC,CAAC;YACd,OAAO,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;QACrB,CAAC,CAAC,CAAC;QACH,GAAG,CAAC,KAAK,CAAC,WAAW,CAAC,CAAC;QACvB,GAAG,CAAC,GAAG,EAAE,CAAC;IACd,CAAC;IAEM,+BAAa,GAApB;QACI,MAAM,CAAC,IAAI,CAAC,UAAU,CAAC;IAC3B,CAAC;IA3HuB,oBAAY,GAAW,eAAe,CAAC;IACvC,kBAAU,GAAW,aAAa,CAAC;IA4H/D,cAAC;CAAA,AA/HD,IA+HC;AA/HY,0BAAO"}

3
openvidu-node-client/lib/TokenOptions.js
View File

@ -1,5 +1,6 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
var OpenViduRole_1 = require("./OpenViduRole");
var TokenOptions = /** @class */ (function () {
function TokenOptions(data, role) {
this.data = data;
@ -17,6 +18,8 @@ exports.TokenOptions = TokenOptions;
(function (TokenOptions) {
var Builder = /** @class */ (function () {
function Builder() {
this.dataProp = '';
this.roleProp = OpenViduRole_1.OpenViduRole.PUBLISHER;
}
Builder.prototype.build = function () {
return new TokenOptions(this.dataProp, this.roleProp);

2
openvidu-node-client/lib/TokenOptions.js.map
View File

@ -1 +1 @@
{"version":3,"file":"TokenOptions.js","sourceRoot":"","sources":["../src/TokenOptions.ts"],"names":[],"mappings":";;AAEA;IAEI,sBAAoB,IAAY,EAAU,IAAkB;QAAxC,SAAI,GAAJ,IAAI,CAAQ;QAAU,SAAI,GAAJ,IAAI,CAAc;IAAI,CAAC;IAEjE,8BAAO,GAAP;QACI,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC;IACrB,CAAC;IAED,8BAAO,GAAP;QACI,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC;IACrB,CAAC;IACL,mBAAC;AAAD,CAAC,AAXD,IAWC;AAXY,oCAAY;AAazB,WAAiB,YAAY;IACzB;QAAA;QAmBA,CAAC;QAdG,uBAAK,GAAL;YACI,MAAM,CAAC,IAAI,YAAY,CAAC,IAAI,CAAC,QAAQ,EAAE,IAAI,CAAC,QAAQ,CAAC,CAAC;QAC1D,CAAC;QAED,sBAAI,GAAJ,UAAK,IAAY;YACb,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAC;YACrB,MAAM,CAAC,IAAI,CAAC;QAChB,CAAC;QAED,sBAAI,GAAJ,UAAK,IAAkB;YACnB,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAC;YACrB,MAAM,CAAC,IAAI,CAAC;QAChB,CAAC;QAEL,cAAC;IAAD,CAAC,AAnBD,IAmBC;IAnBY,oBAAO,UAmBnB,CAAA;IAAA,CAAC;AACN,CAAC,EArBgB,YAAY,GAAZ,oBAAY,KAAZ,oBAAY,QAqB5B;AAlCY,oCAAY"}
{"version":3,"file":"TokenOptions.js","sourceRoot":"","sources":["../src/TokenOptions.ts"],"names":[],"mappings":";;AAAA,+CAA8C;AAE9C;IAEI,sBAAoB,IAAY,EAAU,IAAkB;QAAxC,SAAI,GAAJ,IAAI,CAAQ;QAAU,SAAI,GAAJ,IAAI,CAAc;IAAI,CAAC;IAEjE,8BAAO,GAAP;QACI,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC;IACrB,CAAC;IAED,8BAAO,GAAP;QACI,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC;IACrB,CAAC;IACL,mBAAC;AAAD,CAAC,AAXD,IAWC;AAXY,oCAAY;AAazB,WAAiB,YAAY;IACzB;QAAA;YAEY,aAAQ,GAAW,EAAE,CAAC;YACtB,aAAQ,GAAiB,2BAAY,CAAC,SAAS,CAAC;QAgB5D,CAAC;QAdG,uBAAK,GAAL;YACI,MAAM,CAAC,IAAI,YAAY,CAAC,IAAI,CAAC,QAAQ,EAAE,IAAI,CAAC,QAAQ,CAAC,CAAC;QAC1D,CAAC;QAED,sBAAI,GAAJ,UAAK,IAAY;YACb,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAC;YACrB,MAAM,CAAC,IAAI,CAAC;QAChB,CAAC;QAED,sBAAI,GAAJ,UAAK,IAAkB;YACnB,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAC;YACrB,MAAM,CAAC,IAAI,CAAC;QAChB,CAAC;QAEL,cAAC;IAAD,CAAC,AAnBD,IAmBC;IAnBY,oBAAO,UAmBnB,CAAA;IAAA,CAAC;AACN,CAAC,EArBgB,YAAY,GAAZ,oBAAY,KAAZ,oBAAY,QAqB5B;AAlCY,oCAAY"}

3
openvidu-node-client/lib/index.d.ts vendored
View File

@ -1,8 +1,9 @@
export * from './OpenVidu';
export * from './OpenViduRole';
export * from './Session';
export * from './SessionProperties';
export * from './TokenOptions';
export * from './MediaMode';
export * from './ArchiveLayout';
export * from './ArchiveMode';
export * from './SessionProperties';
export * from './Archive';

3
openvidu-node-client/lib/index.js
View File

@ -6,9 +6,10 @@ Object.defineProperty(exports, "__esModule", { value: true });
__export(require("./OpenVidu"));
__export(require("./OpenViduRole"));
__export(require("./Session"));
__export(require("./SessionProperties"));
__export(require("./TokenOptions"));
__export(require("./MediaMode"));
__export(require("./ArchiveLayout"));
__export(require("./ArchiveMode"));
__export(require("./SessionProperties"));
__export(require("./Archive"));
//# sourceMappingURL=index.js.map

2
openvidu-node-client/lib/index.js.map
View File

@ -1 +1 @@
{"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";;;;;AAAA,gCAA2B;AAC3B,oCAA+B;AAC/B,+BAA0B;AAC1B,oCAA+B;AAC/B,iCAA4B;AAC5B,qCAAgC;AAChC,mCAA8B;AAC9B,yCAAoC"}
{"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";;;;;AAAA,gCAA2B;AAC3B,oCAA+B;AAC/B,+BAA0B;AAC1B,yCAAoC;AACpC,oCAA+B;AAC/B,iCAA4B;AAC5B,qCAAgC;AAChC,mCAA8B;AAC9B,+BAA0B"}

3
openvidu-node-client/package.json
View File

@ -16,9 +16,8 @@
"dependencies": {},
"devDependencies": {
"@types/node": "9.4.0",
"codelyzer": "4.1.0",
"ts-node": "4.1.0",
"tslint": "5.9.1",
"typescript": "2.6.2"
}
}
}

77
openvidu-node-client/src/Archive.ts Normal file
View File

@ -0,0 +1,77 @@
export class Archive {
private id: string;
private name: string;
private sessionId: string;
private createdAt: number;
private size: number = 0;
private duration: number = 0;
private url: string;
private hasaudio: boolean = true;
private hasvideo: boolean = true;
private status: Archive.Status;
constructor(json: JSON) {
this.id = json['id'];
this.name = json['name'];
this.sessionId = json['sessionId'];
this.createdAt = json['createdAt'];
this.size = json['size'];
this.duration = json['duration'];
this.url = json['url'];
this.hasaudio = json['hasAudio'];
this.hasvideo = json['hasVideo'];
this.status = json['status'];
}
public getStatus(): Archive.Status {
return this.status;
}
public getId(): string {
return this.id;
}
public getName(): string {
return this.name;
}
public getSessionId(): string {
return this.sessionId;
}
public getCreatedAt(): number {
return this.createdAt;
}
public getSize(): number {
return this.size;
}
public getDuration(): number {
return this.duration;
}
public getUrl(): string {
return this.url;
}
public hasAudio(): boolean {
return this.hasaudio;
}
public hasVideo(): boolean {
return this.hasvideo;
}
}
export namespace Archive {
export enum Status {
starting, // The recording is starting (cannot be stopped)
started, // The recording has started and is going on
stopped, // The recording has finished OK
available, // The recording is available for downloading. This status is reached for all
// stopped recordings if property 'openvidu.recording.free-access' is true
failed // The recording has failed
}
}

241
openvidu-node-client/src/OpenVidu.ts
View File

@ -1,20 +1,249 @@
import { Session } from "./Session";
import { SessionProperties } from "./SessionProperties";
import { Archive } from "./Archive";
declare const Buffer;
let https = require('https');
export class OpenVidu {
constructor(private urlOpenViduServer: string, private secret: string) { }
private static readonly API_RECORDINGS: string = '/api/recordings';
private static readonly API_RECORDINGS_START: string = '/start';
private static readonly API_RECORDINGS_STOP: string = '/stop';
private hostname: string;
private port: number;
private basicAuth: string;
constructor(private urlOpenViduServer: string, secret: string) {
this.setHostnameAndPort();
this.basicAuth = this.getBasicAuth(secret);
}
public createSession(properties?: SessionProperties): Session {
return new Session(this.urlOpenViduServer, this.secret, properties);
return new Session(this.hostname, this.port, this.basicAuth, properties);
}
public startRecording(sessionId: string) {
// TODO: REST POST to start recording in OpenVidu Server
public startRecording(sessionId: string): Promise<Archive> {
return new Promise<Archive>((resolve, reject) => {
let requestBody = JSON.stringify({
'session': sessionId
});
let options = {
hostname: this.hostname,
port: this.port,
path: OpenVidu.API_RECORDINGS + OpenVidu.API_RECORDINGS_START,
method: 'POST',
headers: {
'Authorization': this.basicAuth,
'Content-Type': 'application/json',
'Content-Length': Buffer.byteLength(requestBody)
}
}
const req = https.request(options, (res) => {
let body = '';
res.on('data', (d) => {
// Continuously update stream with data
body += d;
});
res.on('end', () => {
if (res.statusCode === 200) {
// SUCCESS response from openvidu-server (Archive in JSON format). Resolve new Archive
resolve(new Archive(JSON.parse(body)));
} else {
// ERROR response from openvidu-server. Resolve HTTP status
reject(new Error(res.statusCode));
}
});
});
req.on('error', (e) => {
reject(new Error(e));
});
req.write(requestBody);
req.end();
});
}
public stopRecording(sessionId: string) {
// TODO: REST POST to end recording in OpenVidu Server
public stopRecording(recordingId: string): Promise<Archive> {
return new Promise<Archive>((resolve, reject) => {
let options = {
hostname: this.hostname,
port: this.port,
path: OpenVidu.API_RECORDINGS + OpenVidu.API_RECORDINGS_STOP + '/' + recordingId,
method: 'POST',
headers: {
'Authorization': this.basicAuth,
'Content-Type': 'application/x-www-form-urlencoded'
}
}
const req = https.request(options, (res) => {
let body = '';
res.on('data', (d) => {
// Continuously update stream with data
body += d;
});
res.on('end', () => {
if (res.statusCode === 200) {
// SUCCESS response from openvidu-server (Archive in JSON format). Resolve new Archive
resolve(new Archive(JSON.parse(body)));
} else {
// ERROR response from openvidu-server. Resolve HTTP status
reject(new Error(res.statusCode));
}
});
});
req.on('error', (e) => {
reject(new Error(e));
});
//req.write();
req.end();
});
}
public getRecording(recordingId: string): Promise<Archive> {
return new Promise<Archive>((resolve, reject) => {
let options = {
hostname: this.hostname,
port: this.port,
path: OpenVidu.API_RECORDINGS + '/' + recordingId,
method: 'GET',
headers: {
'Authorization': this.basicAuth,
'Content-Type': 'application/x-www-form-urlencoded'
}
}
const req = https.request(options, (res) => {
let body = '';
res.on('data', (d) => {
// Continuously update stream with data
body += d;
});
res.on('end', () => {
if (res.statusCode === 200) {
// SUCCESS response from openvidu-server (Archive in JSON format). Resolve new Archive
resolve(new Archive(JSON.parse(body)));
} else {
// ERROR response from openvidu-server. Resolve HTTP status
reject(new Error(res.statusCode));
}
});
});
req.on('error', (e) => {
reject(new Error(e));
});
//req.write();
req.end();
});
}
public listRecordings(): Promise<Archive[]> {
return new Promise<Archive[]>((resolve, reject) => {
let options = {
hostname: this.hostname,
port: this.port,
path: OpenVidu.API_RECORDINGS,
method: 'GET',
headers: {
'Authorization': this.basicAuth,
'Content-Type': 'application/x-www-form-urlencoded'
}
}
const req = https.request(options, (res) => {
let body = '';
res.on('data', (d) => {
// Continuously update stream with data
body += d;
});
res.on('end', () => {
if (res.statusCode === 200) {
// SUCCESS response from openvidu-server (JSON arrays of Archives in JSON format). Resolve list of new Archives
let archiveArray: Archive[] = [];
let responseItems = JSON.parse(body)['items'];
for (let i = 0; i < responseItems.length; i++) {
archiveArray.push(new Archive(responseItems[i]));
}
resolve(archiveArray);
} else {
// ERROR response from openvidu-server. Resolve HTTP status
reject(new Error(res.statusCode));
}
});
});
req.on('error', (e) => {
reject(new Error(e));
});
//req.write();
req.end();
});
}
public deleteRecording(recordingId: string): Promise<Error> {
return new Promise<Error>((resolve, reject) => {
let options = {
hostname: this.hostname,
port: this.port,
path: OpenVidu.API_RECORDINGS + '/' + recordingId,
method: 'DELETE',
headers: {
'Authorization': this.basicAuth,
'Content-Type': 'application/x-www-form-urlencoded'
}
}
const req = https.request(options, (res) => {
let body = '';
res.on('data', (d) => {
// Continuously update stream with data
body += d;
});
res.on('end', () => {
if (res.statusCode === 204) {
// SUCCESS response from openvidu-server. Resolve undefined
resolve(undefined);
} else {
// ERROR response from openvidu-server. Resolve HTTP status
reject(new Error(res.statusCode));
}
});
});
req.on('error', (e) => {
reject(new Error(e));
});
//req.write();
req.end();
});
}
private getBasicAuth(secret: string): string {
return 'Basic ' + (new Buffer('OPENVIDUAPP:' + secret).toString('base64'));
}
private setHostnameAndPort(): void {
let urlSplitted = this.urlOpenViduServer.split(':');
if (urlSplitted.length === 3) { // URL has format: http:// + hostname + :port
this.hostname = this.urlOpenViduServer.split(':')[1].replace(/\//g, '');
this.port = parseInt(this.urlOpenViduServer.split(':')[2].replace(/\//g, ''));
} else if (urlSplitted.length == 2) { // URL has format: hostname + :port
this.hostname = this.urlOpenViduServer.split(':')[0].replace(/\//g, '');
this.port = parseInt(this.urlOpenViduServer.split(':')[1].replace(/\//g, ''));
} else {
console.error("URL format incorrect: it must contain hostname and port (current value: '" + this.urlOpenViduServer + "')");
}
}
}

61
openvidu-node-client/src/Session.ts
View File

@ -9,20 +9,18 @@ let https = require('https');
export class Session {
private sessionIdURL: string = '/api/sessions';
private tokenURL: string = '/api/tokens';
private static readonly API_SESSIONS: string = '/api/sessions';
private static readonly API_TOKENS: string = '/api/tokens';
private sessionId: string = "";
private properties: SessionProperties;
private hostname: string;
private port: number;
constructor(private urlOpenViduServer: string, private secret: string, properties?: SessionProperties) {
constructor(private hostname: string, private port: number, private basicAuth: string, properties?: SessionProperties) {
if (properties == null) {
this.properties = new SessionProperties.Builder().build();
} else {
this.properties = properties;
}
this.setHostnameAndPort();
}
public getSessionId(callback: Function) {
@ -41,10 +39,10 @@ export class Session {
let options = {
hostname: this.hostname,
port: this.port,
path: this.sessionIdURL,
path: Session.API_SESSIONS,
method: 'POST',
headers: {
'Authorization': this.getBasicAuth(),
'Authorization': this.basicAuth,
'Content-Type': 'application/json',
'Content-Length': Buffer.byteLength(requestBody)
}
@ -56,10 +54,15 @@ export class Session {
body += d;
});
res.on('end', () => {
// Data reception is done
let parsed = JSON.parse(body);
this.sessionId = parsed.id;
callback(parsed.id);
if (res.statusCode === 200) {
// SUCCESS response from openvidu-server. Resolve sessionId
let parsed = JSON.parse(body);
this.sessionId = parsed.id;
callback(parsed.id);
} else {
// ERROR response from openvidu-server. Resolve HTTP status
console.error(res.statusCode);
}
});
});
@ -94,10 +97,10 @@ export class Session {
let options = {
hostname: this.hostname,
port: this.port,
path: this.tokenURL,
path: Session.API_TOKENS,
method: 'POST',
headers: {
'Authorization': this.getBasicAuth(),
'Authorization': this.basicAuth,
'Content-Type': 'application/json',
'Content-Length': Buffer.byteLength(requestBody)
}
@ -109,9 +112,14 @@ export class Session {
body += d;
});
res.on('end', () => {
// Data reception is done
let parsed = JSON.parse(body);
callback(parsed.id);
if (res.statusCode === 200) {
// SUCCESS response from openvidu-server. Resolve token
let parsed = JSON.parse(body);
callback(parsed.id);
} else {
// ERROR response from openvidu-server. Resolve HTTP status
console.error(res.statusCode);
}
});
});
@ -123,24 +131,7 @@ export class Session {
}
public getProperties(): SessionProperties {
return this.properties;
}
private getBasicAuth() {
return 'Basic ' + (new Buffer('OPENVIDUAPP:' + this.secret).toString('base64'));
}
private setHostnameAndPort() {
let urlSplitted = this.urlOpenViduServer.split(':');
if (urlSplitted.length === 3) { // URL has format: http:// + hostname + :port
this.hostname = this.urlOpenViduServer.split(':')[1].replace(/\//g, '');
this.port = parseInt(this.urlOpenViduServer.split(':')[2].replace(/\//g, ''));
} else if (urlSplitted.length == 2) { // URL has format: hostname + :port
this.hostname = this.urlOpenViduServer.split(':')[0].replace(/\//g, '');
this.port = parseInt(this.urlOpenViduServer.split(':')[1].replace(/\//g, ''));
} else {
console.error("URL format incorrect: it must contain hostname and port (current value: '" + this.urlOpenViduServer + "')");
}
return this.properties;
}
}

4
openvidu-node-client/src/TokenOptions.ts
View File

@ -16,8 +16,8 @@ export class TokenOptions {
export namespace TokenOptions {
export class Builder {
private dataProp: string;
private roleProp: OpenViduRole;
private dataProp: string = '';
private roleProp: OpenViduRole = OpenViduRole.PUBLISHER;
build(): TokenOptions {
return new TokenOptions(this.dataProp, this.roleProp);

3
openvidu-node-client/src/index.ts
View File

@ -1,8 +1,9 @@
export * from './OpenVidu';
export * from './OpenViduRole';
export * from './Session';
export * from './SessionProperties';
export * from './TokenOptions';
export * from './MediaMode';
export * from './ArchiveLayout';
export * from './ArchiveMode';
export * from './SessionProperties';
export * from './Archive';