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

openvidu-node-client updated to recording

pull/30/head
pabloFuente 2018-01-27 19:39:49 +01:00
parent dfeccdaa88
commit 4a1b4617b7
25 changed files with 182 additions and 53 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
openvidu-node-client/.gitignore vendored
View File

@ -41,3 +41,5 @@ testem.log
.DS_Store .DS_Store
Thumbs.db Thumbs.db
*.editorconfig *.editorconfig
/lib/

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

@ -1,7 +1,10 @@
import { Session } from "./Session"; import { Session } from "./Session";
import { SessionProperties } from "./SessionProperties";
export declare class OpenVidu { export declare class OpenVidu {
private urlOpenViduServer; private urlOpenViduServer;
private secret; private secret;
constructor(urlOpenViduServer: string, secret: string); constructor(urlOpenViduServer: string, secret: string);
createSession(): Session; createSession(properties?: SessionProperties): Session;
startArchive(sessionId: string): void;
stopArchive(sessionId: string): void;
} }

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

@ -1,13 +1,19 @@
"use strict"; "use strict";
Object.defineProperty(exports, "__esModule", { value: true }); Object.defineProperty(exports, "__esModule", { value: true });
var Session_1 = require("./Session"); var Session_1 = require("./Session");
var OpenVidu = (function () { var OpenVidu = /** @class */ (function () {
function OpenVidu(urlOpenViduServer, secret) { function OpenVidu(urlOpenViduServer, secret) {
this.urlOpenViduServer = urlOpenViduServer; this.urlOpenViduServer = urlOpenViduServer;
this.secret = secret; this.secret = secret;
} }
OpenVidu.prototype.createSession = function () { OpenVidu.prototype.createSession = function (properties) {
return new Session_1.Session(this.urlOpenViduServer, this.secret); return new Session_1.Session(this.urlOpenViduServer, this.secret, properties);
};
OpenVidu.prototype.startArchive = function (sessionId) {
// TODO: REST POST to start recording in OpenVidu Server
};
OpenVidu.prototype.stopArchive = function (sessionId) {
// TODO: REST POST to end recording in OpenVidu Server
}; };
return OpenVidu; return OpenVidu;
}()); }());

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

@ -1 +1 @@
{"version":3,"file":"OpenVidu.js","sourceRoot":"","sources":["../src/OpenVidu.ts"],"names":[],"mappings":";;AAAA,qCAAoC;AAEpC;IAEE,kBAAoB,iBAAyB,EAAU,MAAc;QAAjD,sBAAiB,GAAjB,iBAAiB,CAAQ;QAAU,WAAM,GAAN,MAAM,CAAQ;IAAG,CAAC;IAElE,gCAAa,GAApB;QACI,MAAM,CAAC,IAAI,iBAAO,CAAC,IAAI,CAAC,iBAAiB,EAAE,IAAI,CAAC,MAAM,CAAC,CAAC;IAC5D,CAAC;IAEH,eAAC;AAAD,CAAC,AARD,IAQC;AARY,4BAAQ"} {"version":3,"file":"OpenVidu.js","sourceRoot":"","sources":["../src/OpenVidu.ts"],"names":[],"mappings":";;AAAA,qCAAoC;AAGpC;IAEE,kBAAoB,iBAAyB,EAAU,MAAc;QAAjD,sBAAiB,GAAjB,iBAAiB,CAAQ;QAAU,WAAM,GAAN,MAAM,CAAQ;IAAI,CAAC;IAEnE,gCAAa,GAApB,UAAqB,UAA8B;QACjD,MAAM,CAAC,IAAI,iBAAO,CAAC,IAAI,CAAC,iBAAiB,EAAE,IAAI,CAAC,MAAM,EAAE,UAAU,CAAC,CAAC;IACtE,CAAC;IAEM,+BAAY,GAAnB,UAAoB,SAAiB;QACnC,wDAAwD;IAC1D,CAAC;IAEM,8BAAW,GAAlB,UAAmB,SAAiB;QAClC,sDAAsD;IACxD,CAAC;IAEH,eAAC;AAAD,CAAC,AAhBD,IAgBC;AAhBY,4BAAQ"}

6
openvidu-node-client/lib/OpenViduRole.d.ts vendored
View File

@ -1,5 +1,5 @@
export declare enum OpenViduRole { export declare enum OpenViduRole {
SUBSCRIBER, SUBSCRIBER = "SUBSCRIBER",
PUBLISHER, PUBLISHER = "PUBLISHER",
MODERATOR, MODERATOR = "MODERATOR",
} }

6
openvidu-node-client/lib/OpenViduRole.js
View File

@ -2,8 +2,8 @@
Object.defineProperty(exports, "__esModule", { value: true }); Object.defineProperty(exports, "__esModule", { value: true });
var OpenViduRole; var OpenViduRole;
(function (OpenViduRole) { (function (OpenViduRole) {
OpenViduRole[OpenViduRole["SUBSCRIBER"] = 'SUBSCRIBER'] = "SUBSCRIBER"; OpenViduRole["SUBSCRIBER"] = "SUBSCRIBER";
OpenViduRole[OpenViduRole["PUBLISHER"] = 'PUBLISHER'] = "PUBLISHER"; OpenViduRole["PUBLISHER"] = "PUBLISHER";
OpenViduRole[OpenViduRole["MODERATOR"] = 'MODERATOR'] = "MODERATOR"; OpenViduRole["MODERATOR"] = "MODERATOR"; // SUBSCRIBER + PUBLIHSER permissions + can force unpublish() and disconnect() over a third-party stream or user
})(OpenViduRole = exports.OpenViduRole || (exports.OpenViduRole = {})); })(OpenViduRole = exports.OpenViduRole || (exports.OpenViduRole = {}));
//# sourceMappingURL=OpenViduRole.js.map //# sourceMappingURL=OpenViduRole.js.map

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

@ -1 +1 @@
{"version":3,"file":"OpenViduRole.js","sourceRoot":"","sources":["../src/OpenViduRole.ts"],"names":[],"mappings":";;AAAA,IAAY,YAIX;AAJD,WAAY,YAAY;IACvB,0CAAkB,YAAY,gBAAA,CAAA;IAC9B,yCAAiB,WAAW,eAAA,CAAA;IAC5B,yCAAiB,WAAW,eAAA,CAAA;AAC7B,CAAC,EAJW,YAAY,GAAZ,oBAAY,KAAZ,oBAAY,QAIvB"} {"version":3,"file":"OpenViduRole.js","sourceRoot":"","sources":["../src/OpenViduRole.ts"],"names":[],"mappings":";;AAAA,IAAY,YAIX;AAJD,WAAY,YAAY;IACvB,yCAAyB,CAAA;IACzB,uCAAuB,CAAA;IACvB,uCAAuB,CAAA,CAAE,gHAAgH;AAC1I,CAAC,EAJW,YAAY,GAAZ,oBAAY,KAAZ,oBAAY,QAIvB"}

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

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

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

@ -1,14 +1,21 @@
"use strict"; "use strict";
Object.defineProperty(exports, "__esModule", { value: true }); Object.defineProperty(exports, "__esModule", { value: true });
var OpenViduRole_1 = require("./OpenViduRole"); var OpenViduRole_1 = require("./OpenViduRole");
var SessionProperties_1 = require("./SessionProperties");
var https = require('https'); var https = require('https');
var Session = (function () { var Session = /** @class */ (function () {
function Session(urlOpenViduServer, secret) { function Session(urlOpenViduServer, secret, properties) {
this.urlOpenViduServer = urlOpenViduServer; this.urlOpenViduServer = urlOpenViduServer;
this.secret = secret; this.secret = secret;
this.sessionIdURL = '/api/sessions'; this.sessionIdURL = '/api/sessions';
this.tokenURL = '/api/tokens'; this.tokenURL = '/api/tokens';
this.sessionId = ""; this.sessionId = "";
if (properties == null) {
this.properties = new SessionProperties_1.SessionProperties.Builder().build();
}
else {
this.properties = properties;
}
this.setHostnameAndPort(); this.setHostnameAndPort();
} }
Session.prototype.getSessionId = function (callback) { Session.prototype.getSessionId = function (callback) {
@ -17,13 +24,20 @@ var Session = (function () {
callback(this.sessionId); callback(this.sessionId);
return; return;
} }
var requestBody = JSON.stringify({
'archiveLayout': this.properties.archiveLayout(),
'archiveMode': this.properties.archiveMode(),
'mediaMode': this.properties.mediaMode()
});
var options = { var options = {
hostname: this.hostname, hostname: this.hostname,
port: this.port, port: this.port,
path: this.sessionIdURL, path: this.sessionIdURL,
method: 'POST', method: 'POST',
headers: { headers: {
'Authorization': this.getBasicAuth() 'Authorization': this.getBasicAuth(),
'Content-Type': 'application/json',
'Content-Length': Buffer.byteLength(requestBody)
} }
}; };
var req = https.request(options, function (res) { var req = https.request(options, function (res) {
@ -42,6 +56,7 @@ var Session = (function () {
req.on('error', function (e) { req.on('error', function (e) {
console.error(e); console.error(e);
}); });
req.write(requestBody);
req.end(); req.end();
}; };
Session.prototype.generateToken = function (tokenOptions, callback) { Session.prototype.generateToken = function (tokenOptions, callback) {
@ -90,6 +105,9 @@ var Session = (function () {
req.write(requestBody); req.write(requestBody);
req.end(); req.end();
}; };
Session.prototype.getProperties = function () {
return this.properties;
};
Session.prototype.getBasicAuth = function () { Session.prototype.getBasicAuth = function () {
return 'Basic ' + (new Buffer('OPENVIDUAPP:' + this.secret).toString('base64')); return 'Basic ' + (new Buffer('OPENVIDUAPP:' + this.secret).toString('base64'));
}; };

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;AAK9C,IAAI,KAAK,GAAG,OAAO,CAAC,OAAO,CAAC,CAAC;AAE7B;IAQI,iBAAoB,iBAAyB,EAAU,MAAc;QAAjD,sBAAiB,GAAjB,iBAAiB,CAAQ;QAAU,WAAM,GAAN,MAAM,CAAQ;QAN7D,iBAAY,GAAW,eAAe,CAAC;QACvC,aAAQ,GAAW,aAAa,CAAC;QACjC,cAAS,GAAW,EAAE,CAAC;QAK3B,IAAI,CAAC,kBAAkB,EAAE,CAAC;IAC9B,CAAC;IAEM,8BAAY,GAAnB,UAAoB,QAAkB;QAAtC,iBAkCC;QAhCG,EAAE,CAAC,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC,CAAC;YACjB,QAAQ,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC;YACzB,MAAM,CAAC;QACX,CAAC;QAED,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;aACvC;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,GAAG,EAAE,CAAC;IACd,CAAC;IAMM,+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;IAEO,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,AAtHD,IAsHC;AAtHY,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;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"}

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

@ -1,11 +1,9 @@
"use strict"; "use strict";
Object.defineProperty(exports, "__esModule", { value: true }); Object.defineProperty(exports, "__esModule", { value: true });
var TokenOptions = (function () { var TokenOptions = /** @class */ (function () {
function TokenOptions(data, role) { function TokenOptions(data, role) {
this.data = data; this.data = data;
this.role = role; this.role = role;
this.data = data;
this.role = role;
} }
TokenOptions.prototype.getData = function () { TokenOptions.prototype.getData = function () {
return this.data; return this.data;
@ -17,7 +15,7 @@ var TokenOptions = (function () {
}()); }());
exports.TokenOptions = TokenOptions; exports.TokenOptions = TokenOptions;
(function (TokenOptions) { (function (TokenOptions) {
var Builder = (function () { var Builder = /** @class */ (function () {
function Builder() { function Builder() {
} }
Builder.prototype.build = function () { Builder.prototype.build = function () {

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;QACxD,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC;QACjB,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC;IACrB,CAAC;IAEM,8BAAO,GAAd;QACI,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC;IACrB,CAAC;IAEM,8BAAO,GAAd;QACI,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC;IACrB,CAAC;IACL,mBAAC;AAAD,CAAC,AAdD,IAcC;AAdY,oCAAY;AAgBzB,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;AArCY,oCAAY"} {"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"}

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

@ -2,3 +2,7 @@ export * from './OpenVidu';
export * from './OpenViduRole'; export * from './OpenViduRole';
export * from './Session'; export * from './Session';
export * from './TokenOptions'; export * from './TokenOptions';
export * from './MediaMode';
export * from './ArchiveLayout';
export * from './ArchiveMode';
export * from './SessionProperties';

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

@ -7,4 +7,8 @@ __export(require("./OpenVidu"));
__export(require("./OpenViduRole")); __export(require("./OpenViduRole"));
__export(require("./Session")); __export(require("./Session"));
__export(require("./TokenOptions")); __export(require("./TokenOptions"));
__export(require("./MediaMode"));
__export(require("./ArchiveLayout"));
__export(require("./ArchiveMode"));
__export(require("./SessionProperties"));
//# sourceMappingURL=index.js.map //# 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"} {"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"}

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

@ -15,10 +15,10 @@
}, },
"dependencies": {}, "dependencies": {},
"devDependencies": { "devDependencies": {
"@types/node": "^6.0.78", "@types/node": "9.4.0",
"codelyzer": "~2.0.0", "codelyzer": "4.1.0",
"ts-node": "~2.0.0", "ts-node": "4.1.0",
"tslint": "~4.5.0", "tslint": "5.9.1",
"typescript": "2.3.4" "typescript": "2.6.2"
} }
} }

6
openvidu-node-client/src/ArchiveLayout.ts Normal file
View File

@ -0,0 +1,6 @@
export enum ArchiveLayout {
BEST_FIT = 'BEST_FIT',
PICTURE_IN_PICTURE = 'PICTURE_IN_PICTURE',
VERTICAL_PRESENTATION = 'VERTICAL_PRESENTATION',
HORIZONTAL_PRESENTATION = 'VERTICAL_PRESENTATION'
}

4
openvidu-node-client/src/ArchiveMode.ts Normal file
View File

@ -0,0 +1,4 @@
export enum ArchiveMode {
ALWAYS = 'ALWAYS', // The session is archived automatically (as soon as there are clients publishing streams to the session)
MANUAL = 'MANUAL' // The session is not archived automatically. To archive the session, you can call the OpenVidu.StartArchive() method
}

4
openvidu-node-client/src/MediaMode.ts Normal file
View File

@ -0,0 +1,4 @@
export enum MediaMode {
RELAYED = 'RELAYED', // The session will attempt to transmit streams directly between clients
ROUTED = 'ROUTED' // The session will transmit streams using OpenVidu Media Server
}

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

@ -1,11 +1,20 @@
import { Session } from "./Session"; import { Session } from "./Session";
import { SessionProperties } from "./SessionProperties";
export class OpenVidu { export class OpenVidu {
constructor(private urlOpenViduServer: string, private secret: string){ } constructor(private urlOpenViduServer: string, private secret: string) { }
public createSession(): Session { public createSession(properties?: SessionProperties): Session {
return new Session(this.urlOpenViduServer, this.secret); return new Session(this.urlOpenViduServer, this.secret, properties);
}
public startArchive(sessionId: string) {
// TODO: REST POST to start recording in OpenVidu Server
}
public stopArchive(sessionId: string) {
// TODO: REST POST to end recording in OpenVidu Server
} }
} }

6
openvidu-node-client/src/OpenViduRole.ts
View File

@ -1,5 +1,5 @@
export enum OpenViduRole { export enum OpenViduRole {
SUBSCRIBER = <any>'SUBSCRIBER', SUBSCRIBER = 'SUBSCRIBER', // Can subscribe to published streams of other users
PUBLISHER = <any>'PUBLISHER', PUBLISHER = 'PUBLISHER', // SUBSCRIBER permissions + can subscribe to published streams of other users and publish their own streams
MODERATOR = <any>'MODERATOR' MODERATOR = 'MODERATOR' // SUBSCRIBER + PUBLIHSER permissions + can force unpublish() and disconnect() over a third-party stream or user
} }

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

@ -1,20 +1,27 @@
import { TokenOptions } from './TokenOptions'; import { TokenOptions } from './TokenOptions';
import { OpenViduRole } from './OpenViduRole'; import { OpenViduRole } from './OpenViduRole';
import { SessionProperties } from './SessionProperties';
declare const Buffer; declare const Buffer;
declare const require; declare const require;
var https = require('https'); let https = require('https');
export class Session { export class Session {
private sessionIdURL: string = '/api/sessions'; private sessionIdURL: string = '/api/sessions';
private tokenURL: string = '/api/tokens'; private tokenURL: string = '/api/tokens';
private sessionId: string = ""; private sessionId: string = "";
private properties: SessionProperties;
private hostname: string; private hostname: string;
private port: number; private port: number;
constructor(private urlOpenViduServer: string, private secret: string) { constructor(private urlOpenViduServer: string, private secret: string, properties?: SessionProperties) {
if (properties == null) {
this.properties = new SessionProperties.Builder().build();
} else {
this.properties = properties;
}
this.setHostnameAndPort(); this.setHostnameAndPort();
} }
@ -25,24 +32,32 @@ export class Session {
return; return;
} }
let requestBody = JSON.stringify({
'archiveLayout': this.properties.archiveLayout(),
'archiveMode': this.properties.archiveMode(),
'mediaMode': this.properties.mediaMode()
});
let options = { let options = {
hostname: this.hostname, hostname: this.hostname,
port: this.port, port: this.port,
path: this.sessionIdURL, path: this.sessionIdURL,
method: 'POST', method: 'POST',
headers: { headers: {
'Authorization': this.getBasicAuth() 'Authorization': this.getBasicAuth(),
'Content-Type': 'application/json',
'Content-Length': Buffer.byteLength(requestBody)
} }
} }
const req = https.request(options, (res) => { const req = https.request(options, (res) => {
var body = ''; let body = '';
res.on('data', (d) => { res.on('data', (d) => {
// Continuously update stream with data // Continuously update stream with data
body += d; body += d;
}); });
res.on('end', () => { res.on('end', () => {
// Data reception is done // Data reception is done
var parsed = JSON.parse(body); let parsed = JSON.parse(body);
this.sessionId = parsed.id; this.sessionId = parsed.id;
callback(parsed.id); callback(parsed.id);
}); });
@ -51,15 +66,15 @@ export class Session {
req.on('error', (e) => { req.on('error', (e) => {
console.error(e); console.error(e);
}); });
req.write(requestBody);
req.end(); req.end();
} }
public generateToken(callback: Function); public generateToken(callback: Function);
public generateToken(tokenOptions: TokenOptions, callback: Function); public generateToken(tokenOptions: TokenOptions, callback: Function);
public generateToken(tokenOptions: any, callback?: any) { public generateToken(tokenOptions: any, callback?: any) {
var requestBody; let requestBody;
if (callback) { if (callback) {
requestBody = JSON.stringify({ requestBody = JSON.stringify({
@ -76,7 +91,7 @@ export class Session {
callback = tokenOptions; callback = tokenOptions;
} }
var options = { let options = {
hostname: this.hostname, hostname: this.hostname,
port: this.port, port: this.port,
path: this.tokenURL, path: this.tokenURL,
@ -88,14 +103,14 @@ export class Session {
} }
}; };
const req = https.request(options, (res) => { const req = https.request(options, (res) => {
var body = ''; let body = '';
res.on('data', (d) => { res.on('data', (d) => {
// Continuously update stream with data // Continuously update stream with data
body += d; body += d;
}); });
res.on('end', () => { res.on('end', () => {
// Data reception is done // Data reception is done
var parsed = JSON.parse(body); let parsed = JSON.parse(body);
callback(parsed.id); callback(parsed.id);
}); });
}); });
@ -107,12 +122,16 @@ export class Session {
req.end(); req.end();
} }
public getProperties(): SessionProperties {
return this.properties;
}
private getBasicAuth() { private getBasicAuth() {
return 'Basic ' + (new Buffer('OPENVIDUAPP:' + this.secret).toString('base64')); return 'Basic ' + (new Buffer('OPENVIDUAPP:' + this.secret).toString('base64'));
} }
private setHostnameAndPort() { private setHostnameAndPort() {
var urlSplitted = this.urlOpenViduServer.split(':'); let urlSplitted = this.urlOpenViduServer.split(':');
if (urlSplitted.length === 3) { // URL has format: http:// + hostname + :port if (urlSplitted.length === 3) { // URL has format: http:// + hostname + :port
this.hostname = this.urlOpenViduServer.split(':')[1].replace(/\//g, ''); this.hostname = this.urlOpenViduServer.split(':')[1].replace(/\//g, '');
this.port = parseInt(this.urlOpenViduServer.split(':')[2].replace(/\//g, '')); this.port = parseInt(this.urlOpenViduServer.split(':')[2].replace(/\//g, ''));

48
openvidu-node-client/src/SessionProperties.ts Normal file
View File

@ -0,0 +1,48 @@
import { MediaMode } from "./MediaMode";
import { ArchiveMode } from "./ArchiveMode";
import { ArchiveLayout } from "./ArchiveLayout";
export class SessionProperties {
constructor(private mediaModeProp: MediaMode, private archiveModeProp: ArchiveMode, private archiveLayoutProp: ArchiveLayout) { }
mediaMode(): string {
return this.mediaModeProp;
}
archiveMode(): ArchiveMode {
return this.archiveModeProp;
}
archiveLayout(): ArchiveLayout {
return this.archiveLayoutProp;
}
}
export namespace SessionProperties {
export class Builder {
private mediaModeProp: MediaMode = MediaMode.ROUTED;
private archiveModeProp: ArchiveMode = ArchiveMode.MANUAL;
private archiveLayoutProp: ArchiveLayout = ArchiveLayout.BEST_FIT;
build(): SessionProperties {
return new SessionProperties(this.mediaModeProp, this.archiveModeProp, this.archiveLayoutProp);
}
mediaMode(mediaMode: MediaMode): Builder {
this.mediaModeProp = mediaMode;
return this;
}
archiveMode(archiveMode: ArchiveMode): Builder {
this.archiveModeProp = archiveMode;
return this;
}
archiveLayout(archiveLayout: ArchiveLayout): Builder {
this.archiveLayoutProp = archiveLayout;
return this;
}
};
}

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

@ -2,16 +2,13 @@ import { OpenViduRole } from "./OpenViduRole";
export class TokenOptions { export class TokenOptions {
constructor(private data: string, private role: OpenViduRole) { constructor(private data: string, private role: OpenViduRole) { }
this.data = data;
this.role = role;
}
public getData(): string { getData(): string {
return this.data; return this.data;
} }
public getRole(): OpenViduRole { getRole(): OpenViduRole {
return this.role; return this.role;
} }
} }

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

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