mirror of https://github.com/OpenVidu/openvidu.git
openvidu-node-client lib folder update with buffer and axios dependencies
pabloFuente
parent
9eae6974af
commit
615b4fb2e4
|
|
@ -10,6 +10,7 @@ export declare class OpenVidu {
|
|||
private hostname;
|
||||
private port;
|
||||
private basicAuth;
|
||||
private Buffer;
|
||||
/**
|
||||
* @param urlOpenViduServer Public accessible IP where your instance of OpenVidu Server is up an running
|
||||
* @param secret Secret used on OpenVidu Server initialization
|
||||
|
|
@ -59,6 +60,6 @@ export declare class OpenVidu {
|
|||
* - `409`: the recording has `started` status. Stop it before deletion
|
||||
*/
|
||||
deleteRecording(recordingId: string): Promise<Error>;
|
||||
private getBasicAuth(secret);
|
||||
private setHostnameAndPort();
|
||||
private getBasicAuth;
|
||||
private setHostnameAndPort;
|
||||
}
|
||||
|
|
|
|||
|
|
@ -18,10 +18,7 @@
|
|||
Object.defineProperty(exports, "__esModule", { value: true });
|
||||
var Session_1 = require("./Session");
|
||||
var Recording_1 = require("./Recording");
|
||||
/**
|
||||
* @hidden
|
||||
*/
|
||||
var https = require('https');
|
||||
var axios_1 = require("axios");
|
||||
var OpenVidu = /** @class */ (function () {
|
||||
/**
|
||||
* @param urlOpenViduServer Public accessible IP where your instance of OpenVidu Server is up an running
|
||||
|
|
@ -29,6 +26,7 @@ var OpenVidu = /** @class */ (function () {
|
|||
*/
|
||||
function OpenVidu(urlOpenViduServer, secret) {
|
||||
this.urlOpenViduServer = urlOpenViduServer;
|
||||
this.Buffer = require('buffer/').Buffer;
|
||||
this.setHostnameAndPort();
|
||||
this.basicAuth = this.getBasicAuth(secret);
|
||||
}
|
||||
|
|
@ -65,11 +63,11 @@ var OpenVidu = /** @class */ (function () {
|
|||
OpenVidu.prototype.startRecording = function (sessionId, param2) {
|
||||
var _this = this;
|
||||
return new Promise(function (resolve, reject) {
|
||||
var requestBody;
|
||||
var data;
|
||||
if (!!param2) {
|
||||
if (!(typeof param2 === 'string')) {
|
||||
var properties = param2;
|
||||
requestBody = JSON.stringify({
|
||||
data = JSON.stringify({
|
||||
session: sessionId,
|
||||
name: !!properties.name ? properties.name : '',
|
||||
recordingLayout: !!properties.recordingLayout ? properties.recordingLayout : '',
|
||||
|
|
@ -77,7 +75,7 @@ var OpenVidu = /** @class */ (function () {
|
|||
});
|
||||
}
|
||||
else {
|
||||
requestBody = JSON.stringify({
|
||||
data = JSON.stringify({
|
||||
session: sessionId,
|
||||
name: param2,
|
||||
recordingLayout: '',
|
||||
|
|
@ -86,46 +84,44 @@ var OpenVidu = /** @class */ (function () {
|
|||
}
|
||||
}
|
||||
else {
|
||||
requestBody = JSON.stringify({
|
||||
data = JSON.stringify({
|
||||
session: sessionId,
|
||||
name: '',
|
||||
recordingLayout: '',
|
||||
customLayout: ''
|
||||
});
|
||||
}
|
||||
var options = {
|
||||
hostname: _this.hostname,
|
||||
port: _this.port,
|
||||
path: OpenVidu.API_RECORDINGS + OpenVidu.API_RECORDINGS_START,
|
||||
method: 'POST',
|
||||
axios_1.default.post('https://' + _this.hostname + ':' + _this.port + OpenVidu.API_RECORDINGS + OpenVidu.API_RECORDINGS_START, data, {
|
||||
headers: {
|
||||
'Authorization': _this.basicAuth,
|
||||
'Content-Type': 'application/json',
|
||||
'Content-Length': Buffer.byteLength(requestBody)
|
||||
'Content-Type': 'application/json'
|
||||
}
|
||||
})
|
||||
.then(function (res) {
|
||||
if (res.status === 200) {
|
||||
// SUCCESS response from openvidu-server (Recording in JSON format). Resolve new Recording
|
||||
resolve(new Recording_1.Recording(res.data));
|
||||
}
|
||||
else {
|
||||
// ERROR response from openvidu-server. Resolve HTTP status
|
||||
reject(new Error(res.status.toString()));
|
||||
}
|
||||
}).catch(function (error) {
|
||||
if (error.response) {
|
||||
// The request was made and the server responded with a status code (not 2xx)
|
||||
reject(new Error(error.response.status.toString()));
|
||||
}
|
||||
else if (error.request) {
|
||||
// The request was made but no response was received
|
||||
// `error.request` is an instance of XMLHttpRequest in the browser and an instance of
|
||||
// http.ClientRequest in node.js
|
||||
console.error(error.request);
|
||||
}
|
||||
else {
|
||||
// Something happened in setting up the request that triggered an Error
|
||||
console.error('Error', error.message);
|
||||
}
|
||||
};
|
||||
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 (Recording in JSON format). Resolve new Recording
|
||||
resolve(new Recording_1.Recording(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();
|
||||
});
|
||||
};
|
||||
/**
|
||||
|
|
@ -140,38 +136,37 @@ var OpenVidu = /** @class */ (function () {
|
|||
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',
|
||||
axios_1.default.post('https://' + _this.hostname + ':' + _this.port + OpenVidu.API_RECORDINGS + OpenVidu.API_RECORDINGS_STOP + '/' + recordingId, undefined, {
|
||||
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 (Recording in JSON format). Resolve new Recording
|
||||
resolve(new Recording_1.Recording(JSON.parse(body)));
|
||||
}
|
||||
else {
|
||||
// ERROR response from openvidu-server. Resolve HTTP status
|
||||
reject(new Error(res.statusCode));
|
||||
}
|
||||
});
|
||||
})
|
||||
.then(function (res) {
|
||||
if (res.status === 200) {
|
||||
// SUCCESS response from openvidu-server (Recording in JSON format). Resolve new Recording
|
||||
resolve(new Recording_1.Recording(res.data));
|
||||
}
|
||||
else {
|
||||
// ERROR response from openvidu-server. Resolve HTTP status
|
||||
reject(new Error(res.status.toString()));
|
||||
}
|
||||
}).catch(function (error) {
|
||||
if (error.response) {
|
||||
// The request was made and the server responded with a status code (not 2xx)
|
||||
reject(new Error(error.response.status.toString()));
|
||||
}
|
||||
else if (error.request) {
|
||||
// The request was made but no response was received
|
||||
// `error.request` is an instance of XMLHttpRequest in the browser and an instance of
|
||||
// http.ClientRequest in node.js
|
||||
console.error(error.request);
|
||||
}
|
||||
else {
|
||||
// Something happened in setting up the request that triggered an Error
|
||||
console.error('Error', error.message);
|
||||
}
|
||||
});
|
||||
req.on('error', function (e) {
|
||||
reject(new Error(e));
|
||||
});
|
||||
// req.write();
|
||||
req.end();
|
||||
});
|
||||
};
|
||||
/**
|
||||
|
|
@ -185,38 +180,37 @@ var OpenVidu = /** @class */ (function () {
|
|||
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',
|
||||
axios_1.default.get('https://' + _this.hostname + ':' + _this.port + OpenVidu.API_RECORDINGS + '/' + recordingId, {
|
||||
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 (Recording in JSON format). Resolve new Recording
|
||||
resolve(new Recording_1.Recording(JSON.parse(body)));
|
||||
}
|
||||
else {
|
||||
// ERROR response from openvidu-server. Resolve HTTP status
|
||||
reject(new Error(res.statusCode));
|
||||
}
|
||||
});
|
||||
})
|
||||
.then(function (res) {
|
||||
if (res.status === 200) {
|
||||
// SUCCESS response from openvidu-server (Recording in JSON format). Resolve new Recording
|
||||
resolve(new Recording_1.Recording(res.data));
|
||||
}
|
||||
else {
|
||||
// ERROR response from openvidu-server. Resolve HTTP status
|
||||
reject(new Error(res.status.toString()));
|
||||
}
|
||||
}).catch(function (error) {
|
||||
if (error.response) {
|
||||
// The request was made and the server responded with a status code (not 2xx)
|
||||
reject(new Error(error.response.status.toString()));
|
||||
}
|
||||
else if (error.request) {
|
||||
// The request was made but no response was received
|
||||
// `error.request` is an instance of XMLHttpRequest in the browser and an instance of
|
||||
// http.ClientRequest in node.js
|
||||
console.error(error.request);
|
||||
}
|
||||
else {
|
||||
// Something happened in setting up the request that triggered an Error
|
||||
console.error('Error', error.message);
|
||||
}
|
||||
});
|
||||
req.on('error', function (e) {
|
||||
reject(new Error(e));
|
||||
});
|
||||
// req.write();
|
||||
req.end();
|
||||
});
|
||||
};
|
||||
/**
|
||||
|
|
@ -227,44 +221,43 @@ var OpenVidu = /** @class */ (function () {
|
|||
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',
|
||||
axios_1.default.get('https://' + _this.hostname + ':' + _this.port + OpenVidu.API_RECORDINGS, {
|
||||
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 recordings in JSON format). Resolve list of new recordings
|
||||
var recordingArray = [];
|
||||
var responseItems = JSON.parse(body).items;
|
||||
for (var _i = 0, responseItems_1 = responseItems; _i < responseItems_1.length; _i++) {
|
||||
var item = responseItems_1[_i];
|
||||
recordingArray.push(new Recording_1.Recording(item));
|
||||
}
|
||||
resolve(recordingArray);
|
||||
})
|
||||
.then(function (res) {
|
||||
if (res.status === 200) {
|
||||
// SUCCESS response from openvidu-server (JSON arrays of recordings in JSON format). Resolve list of new recordings
|
||||
var recordingArray = [];
|
||||
var responseItems = res.data.items;
|
||||
for (var _i = 0, responseItems_1 = responseItems; _i < responseItems_1.length; _i++) {
|
||||
var item = responseItems_1[_i];
|
||||
recordingArray.push(new Recording_1.Recording(item));
|
||||
}
|
||||
else {
|
||||
// ERROR response from openvidu-server. Resolve HTTP status
|
||||
reject(new Error(res.statusCode));
|
||||
}
|
||||
});
|
||||
resolve(recordingArray);
|
||||
}
|
||||
else {
|
||||
// ERROR response from openvidu-server. Resolve HTTP status
|
||||
reject(new Error(res.status.toString()));
|
||||
}
|
||||
}).catch(function (error) {
|
||||
if (error.response) {
|
||||
// The request was made and the server responded with a status code (not 2xx)
|
||||
reject(new Error(error.response.status.toString()));
|
||||
}
|
||||
else if (error.request) {
|
||||
// The request was made but no response was received
|
||||
// `error.request` is an instance of XMLHttpRequest in the browser and an instance of
|
||||
// http.ClientRequest in node.js
|
||||
console.error(error.request);
|
||||
}
|
||||
else {
|
||||
// Something happened in setting up the request that triggered an Error
|
||||
console.error('Error', error.message);
|
||||
}
|
||||
});
|
||||
req.on('error', function (e) {
|
||||
reject(new Error(e));
|
||||
});
|
||||
// req.write();
|
||||
req.end();
|
||||
});
|
||||
};
|
||||
/**
|
||||
|
|
@ -279,42 +272,41 @@ var OpenVidu = /** @class */ (function () {
|
|||
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',
|
||||
axios_1.default.delete('https://' + _this.hostname + ':' + _this.port + OpenVidu.API_RECORDINGS + '/' + recordingId, {
|
||||
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));
|
||||
}
|
||||
});
|
||||
})
|
||||
.then(function (res) {
|
||||
if (res.status === 204) {
|
||||
// SUCCESS response from openvidu-server. Resolve undefined
|
||||
resolve(undefined);
|
||||
}
|
||||
else {
|
||||
// ERROR response from openvidu-server. Resolve HTTP status
|
||||
reject(new Error(res.status.toString()));
|
||||
}
|
||||
}).catch(function (error) {
|
||||
if (error.response) {
|
||||
// The request was made and the server responded with a status code (not 2xx)
|
||||
reject(new Error(error.response.status.toString()));
|
||||
}
|
||||
else if (error.request) {
|
||||
// The request was made but no response was received
|
||||
// `error.request` is an instance of XMLHttpRequest in the browser and an instance of
|
||||
// http.ClientRequest in node.js
|
||||
console.error(error.request);
|
||||
}
|
||||
else {
|
||||
// Something happened in setting up the request that triggered an Error
|
||||
console.error('Error', error.message);
|
||||
}
|
||||
});
|
||||
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'));
|
||||
return 'Basic ' + this.Buffer('OPENVIDUAPP:' + secret).toString('base64');
|
||||
};
|
||||
OpenVidu.prototype.setHostnameAndPort = function () {
|
||||
var urlSplitted = this.urlOpenViduServer.split(':');
|
||||
|
|
|
|||
File diff suppressed because one or more lines are too long
|
|
@ -10,5 +10,5 @@ export declare enum OpenViduRole {
|
|||
/**
|
||||
* _(not available yet)_ SUBSCRIBER + PUBLIHSER permissions + can force `unpublish()` and `disconnect()` over a third-party stream or user
|
||||
*/
|
||||
MODERATOR = "MODERATOR",
|
||||
MODERATOR = "MODERATOR"
|
||||
}
|
||||
|
|
|
|||
|
|
@ -8,6 +8,7 @@ export declare class Session {
|
|||
private static readonly API_TOKENS;
|
||||
sessionId: string;
|
||||
properties: SessionProperties;
|
||||
private Buffer;
|
||||
constructor(hostname: string, port: number, basicAuth: string, properties?: SessionProperties);
|
||||
/**
|
||||
* Gets the unique identifier of the Session
|
||||
|
|
|
|||
|
|
@ -20,15 +20,13 @@ var MediaMode_1 = require("./MediaMode");
|
|||
var OpenViduRole_1 = require("./OpenViduRole");
|
||||
var RecordingLayout_1 = require("./RecordingLayout");
|
||||
var RecordingMode_1 = require("./RecordingMode");
|
||||
/**
|
||||
* @hidden
|
||||
*/
|
||||
var https = require('https');
|
||||
var axios_1 = require("axios");
|
||||
var Session = /** @class */ (function () {
|
||||
function Session(hostname, port, basicAuth, properties) {
|
||||
this.hostname = hostname;
|
||||
this.port = port;
|
||||
this.basicAuth = basicAuth;
|
||||
this.Buffer = require('buffer/').Buffer;
|
||||
if (!properties) {
|
||||
this.properties = {};
|
||||
}
|
||||
|
|
@ -50,45 +48,42 @@ var Session = /** @class */ (function () {
|
|||
Session.prototype.generateToken = function (tokenOptions) {
|
||||
var _this = this;
|
||||
return new Promise(function (resolve, reject) {
|
||||
var requestBody = JSON.stringify({
|
||||
var data = JSON.stringify({
|
||||
session: _this.sessionId,
|
||||
role: (!!tokenOptions && !!tokenOptions.role) ? tokenOptions.role : OpenViduRole_1.OpenViduRole.PUBLISHER,
|
||||
data: (!!tokenOptions && !!tokenOptions.data) ? tokenOptions.data : ''
|
||||
});
|
||||
var options = {
|
||||
hostname: _this.hostname,
|
||||
port: _this.port,
|
||||
path: Session.API_TOKENS,
|
||||
method: 'POST',
|
||||
axios_1.default.post('https://' + _this.hostname + ':' + _this.port + Session.API_TOKENS, data, {
|
||||
headers: {
|
||||
'Authorization': _this.basicAuth,
|
||||
'Content-Type': 'application/json',
|
||||
'Content-Length': Buffer.byteLength(requestBody)
|
||||
'Content-Type': 'application/json'
|
||||
}
|
||||
})
|
||||
.then(function (res) {
|
||||
if (res.status === 200) {
|
||||
// SUCCESS response from openvidu-server. Resolve token
|
||||
resolve(res.data.id);
|
||||
}
|
||||
else {
|
||||
// ERROR response from openvidu-server. Resolve HTTP status
|
||||
reject(new Error(res.status.toString()));
|
||||
}
|
||||
}).catch(function (error) {
|
||||
if (error.response) {
|
||||
// The request was made and the server responded with a status code (not 2xx)
|
||||
reject(new Error(error.response.status.toString()));
|
||||
}
|
||||
else if (error.request) {
|
||||
// The request was made but no response was received
|
||||
// `error.request` is an instance of XMLHttpRequest in the browser and an instance of
|
||||
// http.ClientRequest in node.js
|
||||
console.error(error.request);
|
||||
}
|
||||
else {
|
||||
// Something happened in setting up the request that triggered an Error
|
||||
console.error('Error', error.message);
|
||||
}
|
||||
};
|
||||
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. Resolve token
|
||||
var parsed = JSON.parse(body);
|
||||
resolve(parsed.id);
|
||||
}
|
||||
else {
|
||||
// ERROR response from openvidu-server. Resolve HTTP status
|
||||
reject(new Error(res.statusCode));
|
||||
}
|
||||
});
|
||||
});
|
||||
req.on('error', function (e) {
|
||||
reject(e);
|
||||
});
|
||||
req.write(requestBody);
|
||||
req.end();
|
||||
});
|
||||
};
|
||||
/**
|
||||
|
|
@ -100,53 +95,52 @@ var Session = /** @class */ (function () {
|
|||
if (!!_this.sessionId) {
|
||||
resolve(_this.sessionId);
|
||||
}
|
||||
var requestBody = JSON.stringify({
|
||||
var data = JSON.stringify({
|
||||
mediaMode: !!_this.properties.mediaMode ? _this.properties.mediaMode : MediaMode_1.MediaMode.ROUTED,
|
||||
recordingMode: !!_this.properties.recordingMode ? _this.properties.recordingMode : RecordingMode_1.RecordingMode.MANUAL,
|
||||
defaultRecordingLayout: !!_this.properties.defaultRecordingLayout ? _this.properties.defaultRecordingLayout : RecordingLayout_1.RecordingLayout.BEST_FIT,
|
||||
defaultCustomLayout: !!_this.properties.defaultCustomLayout ? _this.properties.defaultCustomLayout : '',
|
||||
customSessionId: !!_this.properties.customSessionId ? _this.properties.customSessionId : ''
|
||||
});
|
||||
var options = {
|
||||
hostname: _this.hostname,
|
||||
port: _this.port,
|
||||
path: Session.API_SESSIONS,
|
||||
method: 'POST',
|
||||
axios_1.default.post('https://' + _this.hostname + ':' + _this.port + Session.API_SESSIONS, data, {
|
||||
headers: {
|
||||
'Authorization': _this.basicAuth,
|
||||
'Content-Type': 'application/json',
|
||||
'Content-Length': Buffer.byteLength(requestBody)
|
||||
'Content-Type': 'application/json'
|
||||
}
|
||||
};
|
||||
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. Resolve sessionId
|
||||
var parsed = JSON.parse(body);
|
||||
_this.sessionId = parsed.id;
|
||||
resolve(parsed.id);
|
||||
}
|
||||
else if (res.statusCode === 409) {
|
||||
})
|
||||
.then(function (res) {
|
||||
if (res.status === 200) {
|
||||
// SUCCESS response from openvidu-server. Resolve token
|
||||
_this.sessionId = res.data.id;
|
||||
resolve(_this.sessionId);
|
||||
}
|
||||
else {
|
||||
// ERROR response from openvidu-server. Resolve HTTP status
|
||||
reject(new Error(res.status.toString()));
|
||||
}
|
||||
}).catch(function (error) {
|
||||
if (error.response) {
|
||||
// The request was made and the server responded with a status code (not 2xx)
|
||||
if (error.response.status === 409) {
|
||||
// 'customSessionId' already existed
|
||||
_this.sessionId = _this.properties.customSessionId;
|
||||
resolve(_this.sessionId);
|
||||
}
|
||||
else {
|
||||
// ERROR response from openvidu-server. Resolve HTTP status
|
||||
reject(new Error(res.statusCode));
|
||||
reject(new Error(error.response.status.toString()));
|
||||
}
|
||||
});
|
||||
}
|
||||
else if (error.request) {
|
||||
// The request was made but no response was received
|
||||
// `error.request` is an instance of XMLHttpRequest in the browser and an instance of
|
||||
// http.ClientRequest in node.js
|
||||
console.error(error.request);
|
||||
}
|
||||
else {
|
||||
// Something happened in setting up the request that triggered an Error
|
||||
console.error('Error', error.message);
|
||||
}
|
||||
});
|
||||
req.on('error', function (e) {
|
||||
reject(e);
|
||||
});
|
||||
req.write(requestBody);
|
||||
req.end();
|
||||
});
|
||||
};
|
||||
Session.API_SESSIONS = '/api/sessions';
|
||||
|
|
|
|||
|
|
@ -1 +1 @@
|
|||
{"version":3,"file":"Session.js","sourceRoot":"","sources":["../src/Session.ts"],"names":[],"mappings":";AAAA;;;;;;;;;;;;;;;GAeG;;AAEH,yCAAwC;AACxC,+CAA8C;AAC9C,qDAAoD;AACpD,iDAAgD;AAIhD;;GAEG;AACH,IAAM,KAAK,GAAG,OAAO,CAAC,OAAO,CAAC,CAAC;AAE/B;IAQI,iBAAoB,QAAgB,EAAU,IAAY,EAAU,SAAiB,EAAE,UAA8B;QAAjG,aAAQ,GAAR,QAAQ,CAAQ;QAAU,SAAI,GAAJ,IAAI,CAAQ;QAAU,cAAS,GAAT,SAAS,CAAQ;QACjF,IAAI,CAAC,UAAU,EAAE;YACb,IAAI,CAAC,UAAU,GAAG,EAAE,CAAC;SACxB;aAAM;YACH,IAAI,CAAC,UAAU,GAAG,UAAU,CAAC;SAChC;IACL,CAAC;IAED;;OAEG;IACI,8BAAY,GAAnB;QACI,OAAO,IAAI,CAAC,SAAS,CAAC;IAC1B,CAAC;IAED;;;;OAIG;IACI,+BAAa,GAApB,UAAqB,YAA2B;QAAhD,iBA6CC;QA5CG,OAAO,IAAI,OAAO,CAAS,UAAC,OAAO,EAAE,MAAM;YAEvC,IAAM,WAAW,GAAG,IAAI,CAAC,SAAS,CAAC;gBAC/B,OAAO,EAAE,KAAI,CAAC,SAAS;gBACvB,IAAI,EAAE,CAAC,CAAC,CAAC,YAAY,IAAI,CAAC,CAAC,YAAY,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,YAAY,CAAC,IAAI,CAAC,CAAC,CAAC,2BAAY,CAAC,SAAS;gBAC1F,IAAI,EAAE,CAAC,CAAC,CAAC,YAAY,IAAI,CAAC,CAAC,YAAY,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,YAAY,CAAC,IAAI,CAAC,CAAC,CAAC,EAAE;aACzE,CAAC,CAAC;YAEH,IAAM,OAAO,GAAG;gBACZ,QAAQ,EAAE,KAAI,CAAC,QAAQ;gBACvB,IAAI,EAAE,KAAI,CAAC,IAAI;gBACf,IAAI,EAAE,OAAO,CAAC,UAAU;gBACxB,MAAM,EAAE,MAAM;gBACd,OAAO,EAAE;oBACL,eAAe,EAAE,KAAI,CAAC,SAAS;oBAC/B,cAAc,EAAE,kBAAkB;oBAClC,gBAAgB,EAAE,MAAM,CAAC,UAAU,CAAC,WAAW,CAAC;iBACnD;aACJ,CAAC;YAEF,IAAM,GAAG,GAAG,KAAK,CAAC,OAAO,CAAC,OAAO,EAAE,UAAC,GAAG;gBACnC,IAAI,IAAI,GAAG,EAAE,CAAC;gBACd,GAAG,CAAC,EAAE,CAAC,MAAM,EAAE,UAAC,CAAC;oBACb,uCAAuC;oBACvC,IAAI,IAAI,CAAC,CAAC;gBACd,CAAC,CAAC,CAAC;gBACH,GAAG,CAAC,EAAE,CAAC,KAAK,EAAE;oBACV,IAAI,GAAG,CAAC,UAAU,KAAK,GAAG,EAAE;wBACxB,uDAAuD;wBACvD,IAAM,MAAM,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;wBAChC,OAAO,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;qBACtB;yBAAM;wBACH,2DAA2D;wBAC3D,MAAM,CAAC,IAAI,KAAK,CAAC,GAAG,CAAC,UAAU,CAAC,CAAC,CAAC;qBACrC;gBACL,CAAC,CAAC,CAAC;YACP,CAAC,CAAC,CAAC;YAEH,GAAG,CAAC,EAAE,CAAC,OAAO,EAAE,UAAC,CAAC;gBACd,MAAM,CAAC,CAAC,CAAC,CAAC;YACd,CAAC,CAAC,CAAC;YACH,GAAG,CAAC,KAAK,CAAC,WAAW,CAAC,CAAC;YACvB,GAAG,CAAC,GAAG,EAAE,CAAC;QACd,CAAC,CAAC,CAAC;IACP,CAAC;IAED;;OAEG;IACI,kCAAgB,GAAvB;QAAA,iBAwDC;QAvDG,OAAO,IAAI,OAAO,CAAS,UAAC,OAAO,EAAE,MAAM;YAEvC,IAAI,CAAC,CAAC,KAAI,CAAC,SAAS,EAAE;gBAClB,OAAO,CAAC,KAAI,CAAC,SAAS,CAAC,CAAC;aAC3B;YAED,IAAM,WAAW,GAAG,IAAI,CAAC,SAAS,CAAC;gBAC/B,SAAS,EAAE,CAAC,CAAC,KAAI,CAAC,UAAU,CAAC,SAAS,CAAC,CAAC,CAAC,KAAI,CAAC,UAAU,CAAC,SAAS,CAAC,CAAC,CAAC,qBAAS,CAAC,MAAM;gBACrF,aAAa,EAAE,CAAC,CAAC,KAAI,CAAC,UAAU,CAAC,aAAa,CAAC,CAAC,CAAC,KAAI,CAAC,UAAU,CAAC,aAAa,CAAC,CAAC,CAAC,6BAAa,CAAC,MAAM;gBACrG,sBAAsB,EAAE,CAAC,CAAC,KAAI,CAAC,UAAU,CAAC,sBAAsB,CAAC,CAAC,CAAC,KAAI,CAAC,UAAU,CAAC,sBAAsB,CAAC,CAAC,CAAC,iCAAe,CAAC,QAAQ;gBACpI,mBAAmB,EAAE,CAAC,CAAC,KAAI,CAAC,UAAU,CAAC,mBAAmB,CAAC,CAAC,CAAC,KAAI,CAAC,UAAU,CAAC,mBAAmB,CAAC,CAAC,CAAC,EAAE;gBACrG,eAAe,EAAE,CAAC,CAAC,KAAI,CAAC,UAAU,CAAC,eAAe,CAAC,CAAC,CAAC,KAAI,CAAC,UAAU,CAAC,eAAe,CAAC,CAAC,CAAC,EAAE;aAC5F,CAAC,CAAC;YAEH,IAAM,OAAO,GAAG;gBACZ,QAAQ,EAAE,KAAI,CAAC,QAAQ;gBACvB,IAAI,EAAE,KAAI,CAAC,IAAI;gBACf,IAAI,EAAE,OAAO,CAAC,YAAY;gBAC1B,MAAM,EAAE,MAAM;gBACd,OAAO,EAAE;oBACL,eAAe,EAAE,KAAI,CAAC,SAAS;oBAC/B,cAAc,EAAE,kBAAkB;oBAClC,gBAAgB,EAAE,MAAM,CAAC,UAAU,CAAC,WAAW,CAAC;iBACnD;aACJ,CAAC;YAEF,IAAM,GAAG,GAAG,KAAK,CAAC,OAAO,CAAC,OAAO,EAAE,UAAC,GAAG;gBACnC,IAAI,IAAI,GAAG,EAAE,CAAC;gBACd,GAAG,CAAC,EAAE,CAAC,MAAM,EAAE,UAAC,CAAC;oBACb,uCAAuC;oBACvC,IAAI,IAAI,CAAC,CAAC;gBACd,CAAC,CAAC,CAAC;gBACH,GAAG,CAAC,EAAE,CAAC,KAAK,EAAE;oBACV,IAAI,GAAG,CAAC,UAAU,KAAK,GAAG,EAAE;wBACxB,2DAA2D;wBAC3D,IAAM,MAAM,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;wBAChC,KAAI,CAAC,SAAS,GAAG,MAAM,CAAC,EAAE,CAAC;wBAC3B,OAAO,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;qBACtB;yBAAM,IAAI,GAAG,CAAC,UAAU,KAAK,GAAG,EAAE;wBAC/B,oCAAoC;wBACpC,KAAI,CAAC,SAAS,GAAG,KAAI,CAAC,UAAU,CAAC,eAAe,CAAC;wBACjD,OAAO,CAAC,KAAI,CAAC,SAAS,CAAC,CAAC;qBAC3B;yBAAM;wBACH,2DAA2D;wBAC3D,MAAM,CAAC,IAAI,KAAK,CAAC,GAAG,CAAC,UAAU,CAAC,CAAC,CAAC;qBACrC;gBACL,CAAC,CAAC,CAAC;YACP,CAAC,CAAC,CAAC;YAEH,GAAG,CAAC,EAAE,CAAC,OAAO,EAAE,UAAC,CAAC;gBACd,MAAM,CAAC,CAAC,CAAC,CAAC;YACd,CAAC,CAAC,CAAC;YACH,GAAG,CAAC,KAAK,CAAC,WAAW,CAAC,CAAC;YACvB,GAAG,CAAC,GAAG,EAAE,CAAC;QACd,CAAC,CAAC,CAAC;IACP,CAAC;IApIuB,oBAAY,GAAG,eAAe,CAAC;IAC/B,kBAAU,GAAG,aAAa,CAAC;IAqIvD,cAAC;CAAA,AAxID,IAwIC;AAxIY,0BAAO"}
|
||||
{"version":3,"file":"Session.js","sourceRoot":"","sources":["../src/Session.ts"],"names":[],"mappings":";AAAA;;;;;;;;;;;;;;;GAeG;;AAEH,yCAAwC;AACxC,+CAA8C;AAC9C,qDAAoD;AACpD,iDAAgD;AAIhD,+BAAiE;AAEjE;IAUI,iBAAoB,QAAgB,EAAU,IAAY,EAAU,SAAiB,EAAE,UAA8B;QAAjG,aAAQ,GAAR,QAAQ,CAAQ;QAAU,SAAI,GAAJ,IAAI,CAAQ;QAAU,cAAS,GAAT,SAAS,CAAQ;QAF7E,WAAM,GAAG,OAAO,CAAC,SAAS,CAAC,CAAC,MAAM,CAAC;QAGvC,IAAI,CAAC,UAAU,EAAE;YACb,IAAI,CAAC,UAAU,GAAG,EAAE,CAAC;SACxB;aAAM;YACH,IAAI,CAAC,UAAU,GAAG,UAAU,CAAC;SAChC;IACL,CAAC;IAED;;OAEG;IACI,8BAAY,GAAnB;QACI,OAAO,IAAI,CAAC,SAAS,CAAC;IAC1B,CAAC;IAED;;;;OAIG;IACI,+BAAa,GAApB,UAAqB,YAA2B;QAAhD,iBA0CC;QAzCG,OAAO,IAAI,OAAO,CAAS,UAAC,OAAO,EAAE,MAAM;YAEvC,IAAM,IAAI,GAAG,IAAI,CAAC,SAAS,CAAC;gBACxB,OAAO,EAAE,KAAI,CAAC,SAAS;gBACvB,IAAI,EAAE,CAAC,CAAC,CAAC,YAAY,IAAI,CAAC,CAAC,YAAY,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,YAAY,CAAC,IAAI,CAAC,CAAC,CAAC,2BAAY,CAAC,SAAS;gBAC1F,IAAI,EAAE,CAAC,CAAC,CAAC,YAAY,IAAI,CAAC,CAAC,YAAY,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,YAAY,CAAC,IAAI,CAAC,CAAC,CAAC,EAAE;aACzE,CAAC,CAAC;YAEH,eAAK,CAAC,IAAI,CACN,UAAU,GAAG,KAAI,CAAC,QAAQ,GAAG,GAAG,GAAG,KAAI,CAAC,IAAI,GAAG,OAAO,CAAC,UAAU,EACjE,IAAI,EACJ;gBACI,OAAO,EAAE;oBACL,eAAe,EAAE,KAAI,CAAC,SAAS;oBAC/B,cAAc,EAAE,kBAAkB;iBACrC;aACJ,CACJ;iBACI,IAAI,CAAC,UAAA,GAAG;gBACL,IAAI,GAAG,CAAC,MAAM,KAAK,GAAG,EAAE;oBACpB,uDAAuD;oBACvD,OAAO,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC,CAAC;iBACxB;qBAAM;oBACH,2DAA2D;oBAC3D,MAAM,CAAC,IAAI,KAAK,CAAC,GAAG,CAAC,MAAM,CAAC,QAAQ,EAAE,CAAC,CAAC,CAAC;iBAC5C;YACL,CAAC,CAAC,CAAC,KAAK,CAAC,UAAA,KAAK;gBACV,IAAI,KAAK,CAAC,QAAQ,EAAE;oBAChB,6EAA6E;oBAC7E,MAAM,CAAC,IAAI,KAAK,CAAC,KAAK,CAAC,QAAQ,CAAC,MAAM,CAAC,QAAQ,EAAE,CAAC,CAAC,CAAC;iBACvD;qBAAM,IAAI,KAAK,CAAC,OAAO,EAAE;oBACtB,oDAAoD;oBACpD,qFAAqF;oBACrF,gCAAgC;oBAChC,OAAO,CAAC,KAAK,CAAC,KAAK,CAAC,OAAO,CAAC,CAAC;iBAChC;qBAAM;oBACH,uEAAuE;oBACvE,OAAO,CAAC,KAAK,CAAC,OAAO,EAAE,KAAK,CAAC,OAAO,CAAC,CAAC;iBACzC;YACL,CAAC,CAAC,CAAC;QACX,CAAC,CAAC,CAAC;IACP,CAAC;IAED;;OAEG;IACI,kCAAgB,GAAvB;QAAA,iBAuDC;QAtDG,OAAO,IAAI,OAAO,CAAS,UAAC,OAAO,EAAE,MAAM;YAEvC,IAAI,CAAC,CAAC,KAAI,CAAC,SAAS,EAAE;gBAClB,OAAO,CAAC,KAAI,CAAC,SAAS,CAAC,CAAC;aAC3B;YAED,IAAM,IAAI,GAAG,IAAI,CAAC,SAAS,CAAC;gBACxB,SAAS,EAAE,CAAC,CAAC,KAAI,CAAC,UAAU,CAAC,SAAS,CAAC,CAAC,CAAC,KAAI,CAAC,UAAU,CAAC,SAAS,CAAC,CAAC,CAAC,qBAAS,CAAC,MAAM;gBACrF,aAAa,EAAE,CAAC,CAAC,KAAI,CAAC,UAAU,CAAC,aAAa,CAAC,CAAC,CAAC,KAAI,CAAC,UAAU,CAAC,aAAa,CAAC,CAAC,CAAC,6BAAa,CAAC,MAAM;gBACrG,sBAAsB,EAAE,CAAC,CAAC,KAAI,CAAC,UAAU,CAAC,sBAAsB,CAAC,CAAC,CAAC,KAAI,CAAC,UAAU,CAAC,sBAAsB,CAAC,CAAC,CAAC,iCAAe,CAAC,QAAQ;gBACpI,mBAAmB,EAAE,CAAC,CAAC,KAAI,CAAC,UAAU,CAAC,mBAAmB,CAAC,CAAC,CAAC,KAAI,CAAC,UAAU,CAAC,mBAAmB,CAAC,CAAC,CAAC,EAAE;gBACrG,eAAe,EAAE,CAAC,CAAC,KAAI,CAAC,UAAU,CAAC,eAAe,CAAC,CAAC,CAAC,KAAI,CAAC,UAAU,CAAC,eAAe,CAAC,CAAC,CAAC,EAAE;aAC5F,CAAC,CAAC;YAEH,eAAK,CAAC,IAAI,CACN,UAAU,GAAG,KAAI,CAAC,QAAQ,GAAG,GAAG,GAAG,KAAI,CAAC,IAAI,GAAG,OAAO,CAAC,YAAY,EACnE,IAAI,EACJ;gBACI,OAAO,EAAE;oBACL,eAAe,EAAE,KAAI,CAAC,SAAS;oBAC/B,cAAc,EAAE,kBAAkB;iBACrC;aACJ,CACJ;iBACI,IAAI,CAAC,UAAA,GAAG;gBACL,IAAI,GAAG,CAAC,MAAM,KAAK,GAAG,EAAE;oBACpB,uDAAuD;oBACvD,KAAI,CAAC,SAAS,GAAG,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC;oBAC7B,OAAO,CAAC,KAAI,CAAC,SAAS,CAAC,CAAC;iBAC3B;qBAAM;oBACH,2DAA2D;oBAC3D,MAAM,CAAC,IAAI,KAAK,CAAC,GAAG,CAAC,MAAM,CAAC,QAAQ,EAAE,CAAC,CAAC,CAAC;iBAC5C;YACL,CAAC,CAAC,CAAC,KAAK,CAAC,UAAA,KAAK;gBACV,IAAI,KAAK,CAAC,QAAQ,EAAE;oBAChB,6EAA6E;oBAC7E,IAAI,KAAK,CAAC,QAAQ,CAAC,MAAM,KAAK,GAAG,EAAE;wBAC/B,oCAAoC;wBACpC,KAAI,CAAC,SAAS,GAAG,KAAI,CAAC,UAAU,CAAC,eAAe,CAAC;wBACjD,OAAO,CAAC,KAAI,CAAC,SAAS,CAAC,CAAC;qBAC3B;yBAAM;wBACH,MAAM,CAAC,IAAI,KAAK,CAAC,KAAK,CAAC,QAAQ,CAAC,MAAM,CAAC,QAAQ,EAAE,CAAC,CAAC,CAAC;qBACvD;iBACJ;qBAAM,IAAI,KAAK,CAAC,OAAO,EAAE;oBACtB,oDAAoD;oBACpD,qFAAqF;oBACrF,gCAAgC;oBAChC,OAAO,CAAC,KAAK,CAAC,KAAK,CAAC,OAAO,CAAC,CAAC;iBAChC;qBAAM;oBACH,uEAAuE;oBACvE,OAAO,CAAC,KAAK,CAAC,OAAO,EAAE,KAAK,CAAC,OAAO,CAAC,CAAC;iBACzC;YACL,CAAC,CAAC,CAAC;QACX,CAAC,CAAC,CAAC;IACP,CAAC;IAlIuB,oBAAY,GAAG,eAAe,CAAC;IAC/B,kBAAU,GAAG,aAAa,CAAC;IAmIvD,cAAC;CAAA,AAtID,IAsIC;AAtIY,0BAAO"}
|
||||
Loading…
Reference in New Issue