master
Lei OT
1 year ago
parent
8216ccedf4
commit
288be11acf
@ -1,202 +1,202 @@
|
|||||||
"use strict";
|
"use strict";
|
||||||
/**
|
/**
|
||||||
* Rocket.Chat RealTime API
|
* Rocket.Chat RealTime API
|
||||||
*/
|
*/
|
||||||
Object.defineProperty(exports, "__esModule", { value: true });
|
Object.defineProperty(exports, "__esModule", { value: true });
|
||||||
var webSocket_1 = require("rxjs/webSocket");
|
var webSocket_1 = require("rxjs/webSocket");
|
||||||
var operators_1 = require("rxjs/operators");
|
var operators_1 = require("rxjs/operators");
|
||||||
var uuid_1 = require("uuid");
|
var uuid_1 = require("uuid");
|
||||||
var crypto_js_1 = require("crypto-js");
|
var crypto_js_1 = require("crypto-js");
|
||||||
var RealTimeAPI = /** @class */ (function () {
|
var RealTimeAPI = (function () {
|
||||||
function RealTimeAPI(param) {
|
function RealTimeAPI(param) {
|
||||||
this.webSocket = webSocket_1.webSocket(param);
|
this.webSocket = webSocket_1.webSocket(param);
|
||||||
}
|
}
|
||||||
/**
|
/**
|
||||||
* Returns the Observable to the RealTime API Socket
|
* Returns the Observable to the RealTime API Socket
|
||||||
*/
|
*/
|
||||||
RealTimeAPI.prototype.getObservable = function () {
|
RealTimeAPI.prototype.getObservable = function () {
|
||||||
return this.webSocket;
|
return this.webSocket;
|
||||||
};
|
};
|
||||||
/**
|
/**
|
||||||
* Disconnect the WebSocket Connection between client and RealTime API
|
* Disconnect the WebSocket Connection between client and RealTime API
|
||||||
*/
|
*/
|
||||||
RealTimeAPI.prototype.disconnect = function () {
|
RealTimeAPI.prototype.disconnect = function () {
|
||||||
return this.webSocket.unsubscribe();
|
return this.webSocket.unsubscribe();
|
||||||
};
|
};
|
||||||
/**
|
/**
|
||||||
* onMessage
|
* onMessage
|
||||||
*/
|
*/
|
||||||
RealTimeAPI.prototype.onMessage = function (messageHandler) {
|
RealTimeAPI.prototype.onMessage = function (messageHandler) {
|
||||||
this.subscribe(messageHandler, undefined, undefined);
|
this.subscribe(messageHandler, undefined, undefined);
|
||||||
};
|
};
|
||||||
/**
|
/**
|
||||||
* onError
|
* onError
|
||||||
*/
|
*/
|
||||||
RealTimeAPI.prototype.onError = function (errorHandler) {
|
RealTimeAPI.prototype.onError = function (errorHandler) {
|
||||||
this.subscribe(undefined, errorHandler, undefined);
|
this.subscribe(undefined, errorHandler, undefined);
|
||||||
};
|
};
|
||||||
/**
|
/**
|
||||||
* onCompletion
|
* onCompletion
|
||||||
*/
|
*/
|
||||||
RealTimeAPI.prototype.onCompletion = function (completionHandler) {
|
RealTimeAPI.prototype.onCompletion = function (completionHandler) {
|
||||||
this.subscribe(undefined, undefined, completionHandler);
|
this.subscribe(undefined, undefined, completionHandler);
|
||||||
};
|
};
|
||||||
/**
|
/**
|
||||||
* Subscribe to the WebSocket of the RealTime API
|
* Subscribe to the WebSocket of the RealTime API
|
||||||
*/
|
*/
|
||||||
RealTimeAPI.prototype.subscribe = function (messageHandler, errorHandler, completionHandler) {
|
RealTimeAPI.prototype.subscribe = function (messageHandler, errorHandler, completionHandler) {
|
||||||
this.getObservable().subscribe(messageHandler, errorHandler, completionHandler);
|
this.getObservable().subscribe(messageHandler, errorHandler, completionHandler);
|
||||||
};
|
};
|
||||||
/**
|
/**
|
||||||
* sendMessage to Rocket.Chat Server
|
* sendMessage to Rocket.Chat Server
|
||||||
*/
|
*/
|
||||||
RealTimeAPI.prototype.sendMessage = function (messageObject) {
|
RealTimeAPI.prototype.sendMessage = function (messageObject) {
|
||||||
this.webSocket.next(messageObject);
|
this.webSocket.next(messageObject);
|
||||||
};
|
};
|
||||||
/**
|
/**
|
||||||
* getObservableFilteredByMessageType
|
* getObservableFilteredByMessageType
|
||||||
*/
|
*/
|
||||||
RealTimeAPI.prototype.getObservableFilteredByMessageType = function (messageType) {
|
RealTimeAPI.prototype.getObservableFilteredByMessageType = function (messageType) {
|
||||||
return this.getObservable().pipe(operators_1.filter(function (message) { return message.msg === messageType; }));
|
return this.getObservable().pipe(operators_1.filter(function (message) { return message.msg === messageType; }));
|
||||||
};
|
};
|
||||||
/**
|
/**
|
||||||
* getObservableFilteredByID
|
* getObservableFilteredByID
|
||||||
*/
|
*/
|
||||||
RealTimeAPI.prototype.getObservableFilteredByID = function (id) {
|
RealTimeAPI.prototype.getObservableFilteredByID = function (id) {
|
||||||
return this.getObservable().pipe(operators_1.filter(function (message) { return message.id === id; }));
|
return this.getObservable().pipe(operators_1.filter(function (message) { return message.id === id; }));
|
||||||
};
|
};
|
||||||
/**
|
/**
|
||||||
* connectToServer
|
* connectToServer
|
||||||
*/
|
*/
|
||||||
RealTimeAPI.prototype.connectToServer = function () {
|
RealTimeAPI.prototype.connectToServer = function () {
|
||||||
this.sendMessage({
|
this.sendMessage({
|
||||||
msg: "connect",
|
msg: "connect",
|
||||||
version: "1",
|
version: "1",
|
||||||
support: ["1", "pre2", "pre1"]
|
support: ["1", "pre2", "pre1"]
|
||||||
});
|
});
|
||||||
return this.getObservableFilteredByMessageType("connected");
|
return this.getObservableFilteredByMessageType("connected");
|
||||||
};
|
};
|
||||||
/**
|
/**
|
||||||
* Returns an Observable to subscribe to keepAlive, Ping and Pong to the Rocket.Chat Server to Keep the Connection Alive.
|
* Returns an Observable to subscribe to keepAlive, Ping and Pong to the Rocket.Chat Server to Keep the Connection Alive.
|
||||||
*/
|
*/
|
||||||
RealTimeAPI.prototype.keepAlive = function () {
|
RealTimeAPI.prototype.keepAlive = function () {
|
||||||
var _this = this;
|
var _this = this;
|
||||||
return this.getObservableFilteredByMessageType("ping").pipe(operators_1.tap(function () { return _this.sendMessage({ msg: "pong" }); }));
|
return this.getObservableFilteredByMessageType("ping").pipe(operators_1.tap(function () { return _this.sendMessage({ msg: "pong" }); }));
|
||||||
};
|
};
|
||||||
/**
|
/**
|
||||||
* Login with Username and Password
|
* Login with Username and Password
|
||||||
*/
|
*/
|
||||||
RealTimeAPI.prototype.login = function (username, password) {
|
RealTimeAPI.prototype.login = function (username, password) {
|
||||||
var _a;
|
var id = uuid_1.v4();
|
||||||
var id = uuid_1.v4();
|
var usernameType = username.indexOf("@") !== -1 ? "email" : "username";
|
||||||
var usernameType = username.indexOf("@") !== -1 ? "email" : "username";
|
this.sendMessage({
|
||||||
this.sendMessage({
|
msg: "method",
|
||||||
msg: "method",
|
method: "login",
|
||||||
method: "login",
|
id: id,
|
||||||
id: id,
|
params: [
|
||||||
params: [
|
{
|
||||||
{
|
user: (_a = {}, _a[usernameType] = username, _a),
|
||||||
user: (_a = {}, _a[usernameType] = username, _a),
|
password: {
|
||||||
password: {
|
digest: crypto_js_1.SHA256(password).toString(),
|
||||||
digest: crypto_js_1.SHA256(password).toString(),
|
algorithm: "sha-256"
|
||||||
algorithm: "sha-256"
|
}
|
||||||
}
|
}
|
||||||
}
|
]
|
||||||
]
|
});
|
||||||
});
|
return this.getLoginObservable(id);
|
||||||
return this.getLoginObservable(id);
|
var _a;
|
||||||
};
|
};
|
||||||
/**
|
/**
|
||||||
* Login with Authentication Token
|
* Login with Authentication Token
|
||||||
*/
|
*/
|
||||||
RealTimeAPI.prototype.loginWithAuthToken = function (authToken) {
|
RealTimeAPI.prototype.loginWithAuthToken = function (authToken) {
|
||||||
var id = uuid_1.v4();
|
var id = uuid_1.v4();
|
||||||
this.sendMessage({
|
this.sendMessage({
|
||||||
msg: "method",
|
msg: "method",
|
||||||
method: "login",
|
method: "login",
|
||||||
id: id,
|
id: id,
|
||||||
params: [{ resume: authToken }]
|
params: [{ resume: authToken }]
|
||||||
});
|
});
|
||||||
return this.getLoginObservable(id);
|
return this.getLoginObservable(id);
|
||||||
};
|
};
|
||||||
/**
|
/**
|
||||||
* Login with OAuth, with Client Token and Client Secret
|
* Login with OAuth, with Client Token and Client Secret
|
||||||
*/
|
*/
|
||||||
RealTimeAPI.prototype.loginWithOAuth = function (credToken, credSecret) {
|
RealTimeAPI.prototype.loginWithOAuth = function (credToken, credSecret) {
|
||||||
var id = uuid_1.v4();
|
var id = uuid_1.v4();
|
||||||
this.sendMessage({
|
this.sendMessage({
|
||||||
msg: "method",
|
msg: "method",
|
||||||
method: "login",
|
method: "login",
|
||||||
id: id,
|
id: id,
|
||||||
params: [
|
params: [
|
||||||
{
|
{
|
||||||
oauth: {
|
oauth: {
|
||||||
credentialToken: credToken,
|
credentialToken: credToken,
|
||||||
credentialSecret: credSecret
|
credentialSecret: credSecret
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
]
|
]
|
||||||
});
|
});
|
||||||
return this.getLoginObservable(id);
|
return this.getLoginObservable(id);
|
||||||
};
|
};
|
||||||
/**
|
/**
|
||||||
* getLoginObservable
|
* getLoginObservable
|
||||||
*/
|
*/
|
||||||
RealTimeAPI.prototype.getLoginObservable = function (id) {
|
RealTimeAPI.prototype.getLoginObservable = function (id) {
|
||||||
var resultObservable = this.getObservableFilteredByID(id);
|
var resultObservable = this.getObservableFilteredByID(id);
|
||||||
var resultId;
|
var resultId;
|
||||||
var addedObservable = this.getObservable().pipe(operators_1.buffer(resultObservable.pipe(operators_1.map(function (_a) {
|
var addedObservable = this.getObservable().pipe(operators_1.buffer(resultObservable.pipe(operators_1.map(function (_a) {
|
||||||
var msg = _a.msg, error = _a.error, result = _a.result;
|
var msg = _a.msg, error = _a.error, result = _a.result;
|
||||||
if (msg === "result" && !error)
|
if (msg === "result" && !error)
|
||||||
return (resultId = result.id); // Setting resultId to get Result from the buffer
|
return (resultId = result.id); // Setting resultId to get Result from the buffer
|
||||||
}))), operators_1.flatMap(function (x) { return x; }), // Flattening the Buffered Messages
|
}))), operators_1.flatMap(function (x) { return x; }), // Flattening the Buffered Messages
|
||||||
operators_1.filter(function (_a) {
|
operators_1.filter(function (_a) {
|
||||||
var msgId = _a.id;
|
var msgId = _a.id;
|
||||||
return resultId !== undefined && msgId === resultId;
|
return resultId !== undefined && msgId === resultId;
|
||||||
}), //Filtering the "added" result message.
|
}), //Filtering the "added" result message.
|
||||||
operators_1.merge(resultObservable) //Merging "result" and "added" messages.
|
operators_1.merge(resultObservable) //Merging "result" and "added" messages.
|
||||||
);
|
);
|
||||||
return addedObservable;
|
return addedObservable;
|
||||||
};
|
};
|
||||||
/**
|
/**
|
||||||
* Get Observalble to the Result of Method Call from Rocket.Chat Realtime API
|
* Get Observalble to the Result of Method Call from Rocket.Chat Realtime API
|
||||||
*/
|
*/
|
||||||
RealTimeAPI.prototype.callMethod = function (method) {
|
RealTimeAPI.prototype.callMethod = function (method) {
|
||||||
var params = [];
|
var params = [];
|
||||||
for (var _i = 1; _i < arguments.length; _i++) {
|
for (var _i = 1; _i < arguments.length; _i++) {
|
||||||
params[_i - 1] = arguments[_i];
|
params[_i - 1] = arguments[_i];
|
||||||
}
|
}
|
||||||
var id = uuid_1.v4();
|
var id = uuid_1.v4();
|
||||||
this.sendMessage({
|
this.sendMessage({
|
||||||
msg: "method",
|
msg: "method",
|
||||||
method: method,
|
method: method,
|
||||||
id: id,
|
id: id,
|
||||||
params: params
|
params: params
|
||||||
});
|
});
|
||||||
return this.getObservableFilteredByID(id);
|
return this.getObservableFilteredByID(id);
|
||||||
};
|
};
|
||||||
/**
|
/**
|
||||||
* getSubscription
|
* getSubscription
|
||||||
*/
|
*/
|
||||||
RealTimeAPI.prototype.getSubscription = function (streamName, streamParam, addEvent) {
|
RealTimeAPI.prototype.getSubscription = function (streamName, streamParam, addEvent) {
|
||||||
var id = uuid_1.v4();
|
var id = uuid_1.v4();
|
||||||
var subscription = this.webSocket.multiplex(function () { return ({
|
var subscription = this.webSocket.multiplex(function () { return ({
|
||||||
msg: "sub",
|
msg: "sub",
|
||||||
id: id,
|
id: id,
|
||||||
name: streamName,
|
name: streamName,
|
||||||
params: [streamParam, addEvent]
|
params: [streamParam, addEvent]
|
||||||
}); }, function () { return ({
|
}); }, function () { return ({
|
||||||
msg: "unsub",
|
msg: "unsub",
|
||||||
id: id
|
id: id
|
||||||
}); }, function (message) {
|
}); }, function (message) {
|
||||||
return typeof message.collection === "string" &&
|
return typeof message.collection === "string" &&
|
||||||
message.collection === streamName &&
|
message.collection === streamName &&
|
||||||
message.fields.eventName === streamParam;
|
message.fields.eventName === streamParam;
|
||||||
} // Proper Filtering to be done. This is temporary filter just for the stream-room-messages subscription
|
} // Proper Filtering to be done. This is temporary filter just for the stream-room-messages subscription
|
||||||
);
|
);
|
||||||
return subscription;
|
return subscription;
|
||||||
};
|
};
|
||||||
return RealTimeAPI;
|
return RealTimeAPI;
|
||||||
}());
|
}());
|
||||||
exports.RealTimeAPI = RealTimeAPI;
|
exports.RealTimeAPI = RealTimeAPI;
|
||||||
//# sourceMappingURL=RealTimeAPI.js.map
|
//# sourceMappingURL=RealTimeAPI.js.map
|
||||||
@ -1 +1 @@
|
|||||||
{"version":3,"file":"RealTimeAPI.js","sourceRoot":"","sources":["../src/RealTimeAPI.ts"],"names":[],"mappings":";AAAA;;GAEG;;AAEH,4CAAqF;AACrF,4CAA0E;AAC1E,6BAAkC;AAClC,uCAAmC;AAEnC;IAGE,qBAAY,KAA2C;QACrD,IAAI,CAAC,SAAS,GAAG,qBAAS,CAAC,KAAK,CAAC,CAAC;IACpC,CAAC;IAED;;OAEG;IACI,mCAAa,GAApB;QACE,OAAO,IAAI,CAAC,SAAS,CAAC;IACxB,CAAC;IAED;;OAEG;IACI,gCAAU,GAAjB;QACE,OAAO,IAAI,CAAC,SAAS,CAAC,WAAW,EAAE,CAAC;IACtC,CAAC;IAED;;OAEG;IACI,+BAAS,GAAhB,UAAiB,cAAkD;QACjE,IAAI,CAAC,SAAS,CAAC,cAAc,EAAE,SAAS,EAAE,SAAS,CAAC,CAAC;IACvD,CAAC;IAED;;OAEG;IACI,6BAAO,GAAd,UAAe,YAAiD;QAC9D,IAAI,CAAC,SAAS,CAAC,SAAS,EAAE,YAAY,EAAE,SAAS,CAAC,CAAC;IACrD,CAAC;IAED;;OAEG;IACI,kCAAY,GAAnB,UAAoB,iBAA4C;QAC9D,IAAI,CAAC,SAAS,CAAC,SAAS,EAAE,SAAS,EAAE,iBAAiB,CAAC,CAAC;IAC1D,CAAC;IAED;;OAEG;IACI,+BAAS,GAAhB,UACE,cAAkD,EAClD,YAAiD,EACjD,iBAA4C;QAE5C,IAAI,CAAC,aAAa,EAAE,CAAC,SAAS,CAC5B,cAAc,EACd,YAAY,EACZ,iBAAiB,CAClB,CAAC;IACJ,CAAC;IAED;;OAEG;IACI,iCAAW,GAAlB,UAAmB,aAAkB;QACnC,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,aAAa,CAAC,CAAC;IACrC,CAAC;IAED;;OAEG;IACI,wDAAkC,GAAzC,UAA0C,WAAmB;QAC3D,OAAO,IAAI,CAAC,aAAa,EAAE,CAAC,IAAI,CAC9B,kBAAM,CAAC,UAAC,OAAY,IAAK,OAAA,OAAO,CAAC,GAAG,KAAK,WAAW,EAA3B,CAA2B,CAAC,CACtD,CAAC;IACJ,CAAC;IAED;;OAEG;IACI,+CAAyB,GAAhC,UAAiC,EAAU;QACzC,OAAO,IAAI,CAAC,aAAa,EAAE,CAAC,IAAI,CAC9B,kBAAM,CAAC,UAAC,OAAY,IAAK,OAAA,OAAO,CAAC,EAAE,KAAK,EAAE,EAAjB,CAAiB,CAAC,CAC5C,CAAC;IACJ,CAAC;IAED;;OAEG;IACI,qCAAe,GAAtB;QACE,IAAI,CAAC,WAAW,CAAC;YACf,GAAG,EAAE,SAAS;YACd,OAAO,EAAE,GAAG;YACZ,OAAO,EAAE,CAAC,GAAG,EAAE,MAAM,EAAE,MAAM,CAAC;SAC/B,CAAC,CAAC;QACH,OAAO,IAAI,CAAC,kCAAkC,CAAC,WAAW,CAAC,CAAC;IAC9D,CAAC;IAED;;OAEG;IACI,+BAAS,GAAhB;QAAA,iBAIC;QAHC,OAAO,IAAI,CAAC,kCAAkC,CAAC,MAAM,CAAC,CAAC,IAAI,CACzD,eAAG,CAAC,cAAM,OAAA,KAAI,CAAC,WAAW,CAAC,EAAE,GAAG,EAAE,MAAM,EAAE,CAAC,EAAjC,CAAiC,CAAC,CAC7C,CAAC;IACJ,CAAC;IAED;;OAEG;IACI,2BAAK,GAAZ,UAAa,QAAgB,EAAE,QAAgB;;QAC7C,IAAI,EAAE,GAAG,SAAI,EAAE,CAAC;QAChB,IAAI,YAAY,GAAG,QAAQ,CAAC,OAAO,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC,UAAU,CAAC;QACvE,IAAI,CAAC,WAAW,CAAC;YACf,GAAG,EAAE,QAAQ;YACb,MAAM,EAAE,OAAO;YACf,EAAE,EAAE,EAAE;YACN,MAAM,EAAE;gBACN;oBACE,IAAI,YAAI,GAAC,YAAY,IAAG,QAAQ,KAAE;oBAClC,QAAQ,EAAE;wBACR,MAAM,EAAE,kBAAM,CAAC,QAAQ,CAAC,CAAC,QAAQ,EAAE;wBACnC,SAAS,EAAE,SAAS;qBACrB;iBACF;aACF;SACF,CAAC,CAAC;QACH,OAAO,IAAI,CAAC,kBAAkB,CAAC,EAAE,CAAC,CAAC;IACrC,CAAC;IAED;;OAEG;IACI,wCAAkB,GAAzB,UAA0B,SAAiB;QACzC,IAAI,EAAE,GAAG,SAAI,EAAE,CAAC;QAChB,IAAI,CAAC,WAAW,CAAC;YACf,GAAG,EAAE,QAAQ;YACb,MAAM,EAAE,OAAO;YACf,EAAE,EAAE,EAAE;YACN,MAAM,EAAE,CAAC,EAAE,MAAM,EAAE,SAAS,EAAE,CAAC;SAChC,CAAC,CAAC;QACH,OAAO,IAAI,CAAC,kBAAkB,CAAC,EAAE,CAAC,CAAC;IACrC,CAAC;IAED;;OAEG;IACI,oCAAc,GAArB,UAAsB,SAAiB,EAAE,UAAkB;QACzD,IAAI,EAAE,GAAG,SAAI,EAAE,CAAC;QAChB,IAAI,CAAC,WAAW,CAAC;YACf,GAAG,EAAE,QAAQ;YACb,MAAM,EAAE,OAAO;YACf,EAAE,EAAE,EAAE;YACN,MAAM,EAAE;gBACN;oBACE,KAAK,EAAE;wBACL,eAAe,EAAE,SAAS;wBAC1B,gBAAgB,EAAE,UAAU;qBAC7B;iBACF;aACF;SACF,CAAC,CAAC;QACH,OAAO,IAAI,CAAC,kBAAkB,CAAC,EAAE,CAAC,CAAC;IACrC,CAAC;IAED;;OAEG;IACI,wCAAkB,GAAzB,UAA0B,EAAU;QAClC,IAAI,gBAAgB,GAAG,IAAI,CAAC,yBAAyB,CAAC,EAAE,CAAC,CAAC;QAC1D,IAAI,QAAgB,CAAC;QAErB,IAAI,eAAe,GAAG,IAAI,CAAC,aAAa,EAAE,CAAC,IAAI,CAC7C,kBAAM,CACJ,gBAAgB,CAAC,IAAI,CACnB,eAAG,CAAC,UAAC,EAAsB;gBAApB,YAAG,EAAE,gBAAK,EAAE,kBAAM;YACvB,IAAI,GAAG,KAAK,QAAQ,IAAI,CAAC,KAAK;gBAAE,OAAO,CAAC,QAAQ,GAAG,MAAM,CAAC,EAAE,CAAC,CAAC,CAAC,iDAAiD;QAClH,CAAC,CAAC,CACH,CACF,EACD,mBAAO,CAAC,UAAA,CAAC,IAAI,OAAA,CAAC,EAAD,CAAC,CAAC,EAAE,mCAAmC;QACpD,kBAAM,CAAC,UAAC,EAAa;gBAAX,aAAS;YAAO,OAAA,QAAQ,KAAK,SAAS,IAAI,KAAK,KAAK,QAAQ;QAA5C,CAA4C,CAAC,EAAE,uCAAuC;QAChH,iBAAK,CAAC,gBAAgB,CAAC,CAAC,wCAAwC;SACjE,CAAC;QAEF,OAAO,eAAe,CAAC;IACzB,CAAC;IAED;;OAEG;IACI,gCAAU,GAAjB,UAAkB,MAAc;QAAE,gBAAoB;aAApB,UAAoB,EAApB,qBAAoB,EAApB,IAAoB;YAApB,+BAAoB;;QACpD,IAAI,EAAE,GAAG,SAAI,EAAE,CAAC;QAChB,IAAI,CAAC,WAAW,CAAC;YACf,GAAG,EAAE,QAAQ;YACb,MAAM,QAAA;YACN,EAAE,IAAA;YACF,MAAM,QAAA;SACP,CAAC,CAAC;QACH,OAAO,IAAI,CAAC,yBAAyB,CAAC,EAAE,CAAC,CAAC;IAC5C,CAAC;IAED;;OAEG;IACI,qCAAe,GAAtB,UACE,UAAkB,EAClB,WAAmB,EACnB,QAAiB;QAEjB,IAAI,EAAE,GAAG,SAAI,EAAE,CAAC;QAChB,IAAI,YAAY,GAAG,IAAI,CAAC,SAAS,CAAC,SAAS,CACzC,cAAM,OAAA,CAAC;YACL,GAAG,EAAE,KAAK;YACV,EAAE,EAAE,EAAE;YACN,IAAI,EAAE,UAAU;YAChB,MAAM,EAAE,CAAC,WAAW,EAAE,QAAQ,CAAC;SAChC,CAAC,EALI,CAKJ,EACF,cAAM,OAAA,CAAC;YACL,GAAG,EAAE,OAAO;YACZ,EAAE,EAAE,EAAE;SACP,CAAC,EAHI,CAGJ,EACF,UAAC,OAAY;YACX,OAAA,OAAO,OAAO,CAAC,UAAU,KAAK,QAAQ;gBACtC,OAAO,CAAC,UAAU,KAAK,UAAU;gBACjC,OAAO,CAAC,MAAM,CAAC,SAAS,KAAK,WAAW;QAFxC,CAEwC,CAAC,uGAAuG;SACnJ,CAAC;QACF,OAAO,YAAY,CAAC;IACtB,CAAC;IACH,kBAAC;AAAD,CAAC,AAjOD,IAiOC;AAjOY,kCAAW"}
|
{"version":3,"file":"RealTimeAPI.js","sourceRoot":"","sources":["../src/RealTimeAPI.ts"],"names":[],"mappings":";AAAA;;GAEG;;AAEH,4CAIwB;AACxB,4CAA0E;AAC1E,6BAAkC;AAClC,uCAAmC;AAEnC;IAGE,qBAAY,KAA2C;QACrD,IAAI,CAAC,SAAS,GAAG,qBAAS,CAAC,KAAK,CAAC,CAAC;IACpC,CAAC;IAED;;OAEG;IACI,mCAAa,GAApB;QACE,MAAM,CAAC,IAAI,CAAC,SAAS,CAAC;IACxB,CAAC;IAED;;OAEG;IACI,gCAAU,GAAjB;QACE,MAAM,CAAC,IAAI,CAAC,SAAS,CAAC,WAAW,EAAE,CAAC;IACtC,CAAC;IAED;;OAEG;IACI,+BAAS,GAAhB,UAAiB,cAAkD;QACjE,IAAI,CAAC,SAAS,CAAC,cAAc,EAAE,SAAS,EAAE,SAAS,CAAC,CAAC;IACvD,CAAC;IAED;;OAEG;IACI,6BAAO,GAAd,UAAe,YAAiD;QAC9D,IAAI,CAAC,SAAS,CAAC,SAAS,EAAE,YAAY,EAAE,SAAS,CAAC,CAAC;IACrD,CAAC;IAED;;OAEG;IACI,kCAAY,GAAnB,UAAoB,iBAA4C;QAC9D,IAAI,CAAC,SAAS,CAAC,SAAS,EAAE,SAAS,EAAE,iBAAiB,CAAC,CAAC;IAC1D,CAAC;IAED;;OAEG;IACI,+BAAS,GAAhB,UACE,cAAkD,EAClD,YAAiD,EACjD,iBAA4C;QAE5C,IAAI,CAAC,aAAa,EAAE,CAAC,SAAS,CAC5B,cAAc,EACd,YAAY,EACZ,iBAAiB,CAClB,CAAC;IACJ,CAAC;IAED;;OAEG;IACI,iCAAW,GAAlB,UAAmB,aAAkB;QACnC,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,aAAa,CAAC,CAAC;IACrC,CAAC;IAED;;OAEG;IACI,wDAAkC,GAAzC,UAA0C,WAAmB;QAC3D,MAAM,CAAC,IAAI,CAAC,aAAa,EAAE,CAAC,IAAI,CAC9B,kBAAM,CAAC,UAAC,OAAY,IAAK,OAAA,OAAO,CAAC,GAAG,KAAK,WAAW,EAA3B,CAA2B,CAAC,CACtD,CAAC;IACJ,CAAC;IAED;;OAEG;IACI,+CAAyB,GAAhC,UAAiC,EAAU;QACzC,MAAM,CAAC,IAAI,CAAC,aAAa,EAAE,CAAC,IAAI,CAC9B,kBAAM,CAAC,UAAC,OAAY,IAAK,OAAA,OAAO,CAAC,EAAE,KAAK,EAAE,EAAjB,CAAiB,CAAC,CAC5C,CAAC;IACJ,CAAC;IAED;;OAEG;IACI,qCAAe,GAAtB;QACE,IAAI,CAAC,WAAW,CAAC;YACf,GAAG,EAAE,SAAS;YACd,OAAO,EAAE,GAAG;YACZ,OAAO,EAAE,CAAC,GAAG,EAAE,MAAM,EAAE,MAAM,CAAC;SAC/B,CAAC,CAAC;QACH,MAAM,CAAC,IAAI,CAAC,kCAAkC,CAAC,WAAW,CAAC,CAAC;IAC9D,CAAC;IAED;;OAEG;IACI,+BAAS,GAAhB;QAAA,iBAIC;QAHC,MAAM,CAAC,IAAI,CAAC,kCAAkC,CAAC,MAAM,CAAC,CAAC,IAAI,CACzD,eAAG,CAAC,cAAM,OAAA,KAAI,CAAC,WAAW,CAAC,EAAE,GAAG,EAAE,MAAM,EAAE,CAAC,EAAjC,CAAiC,CAAC,CAC7C,CAAC;IACJ,CAAC;IAED;;OAEG;IACI,2BAAK,GAAZ,UAAa,QAAgB,EAAE,QAAgB;QAC7C,IAAI,EAAE,GAAG,SAAI,EAAE,CAAC;QAChB,IAAI,YAAY,GAAG,QAAQ,CAAC,OAAO,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC,GAAG,OAAO,GAAG,UAAU,CAAC;QACvE,IAAI,CAAC,WAAW,CAAC;YACf,GAAG,EAAE,QAAQ;YACb,MAAM,EAAE,OAAO;YACf,EAAE,EAAE,EAAE;YACN,MAAM,EAAE;gBACN;oBACE,IAAI,YAAI,GAAC,YAAY,IAAG,QAAQ,KAAE;oBAClC,QAAQ,EAAE;wBACR,MAAM,EAAE,kBAAM,CAAC,QAAQ,CAAC,CAAC,QAAQ,EAAE;wBACnC,SAAS,EAAE,SAAS;qBACrB;iBACF;aACF;SACF,CAAC,CAAC;QACH,MAAM,CAAC,IAAI,CAAC,kBAAkB,CAAC,EAAE,CAAC,CAAC;;IACrC,CAAC;IAED;;OAEG;IACI,wCAAkB,GAAzB,UAA0B,SAAiB;QACzC,IAAI,EAAE,GAAG,SAAI,EAAE,CAAC;QAChB,IAAI,CAAC,WAAW,CAAC;YACf,GAAG,EAAE,QAAQ;YACb,MAAM,EAAE,OAAO;YACf,EAAE,EAAE,EAAE;YACN,MAAM,EAAE,CAAC,EAAE,MAAM,EAAE,SAAS,EAAE,CAAC;SAChC,CAAC,CAAC;QACH,MAAM,CAAC,IAAI,CAAC,kBAAkB,CAAC,EAAE,CAAC,CAAC;IACrC,CAAC;IAED;;OAEG;IACI,oCAAc,GAArB,UAAsB,SAAiB,EAAE,UAAkB;QACzD,IAAI,EAAE,GAAG,SAAI,EAAE,CAAC;QAChB,IAAI,CAAC,WAAW,CAAC;YACf,GAAG,EAAE,QAAQ;YACb,MAAM,EAAE,OAAO;YACf,EAAE,EAAE,EAAE;YACN,MAAM,EAAE;gBACN;oBACE,KAAK,EAAE;wBACL,eAAe,EAAE,SAAS;wBAC1B,gBAAgB,EAAE,UAAU;qBAC7B;iBACF;aACF;SACF,CAAC,CAAC;QACH,MAAM,CAAC,IAAI,CAAC,kBAAkB,CAAC,EAAE,CAAC,CAAC;IACrC,CAAC;IAED;;OAEG;IACI,wCAAkB,GAAzB,UAA0B,EAAU;QAClC,IAAI,gBAAgB,GAAG,IAAI,CAAC,yBAAyB,CAAC,EAAE,CAAC,CAAC;QAC1D,IAAI,QAAgB,CAAC;QAErB,IAAI,eAAe,GAAG,IAAI,CAAC,aAAa,EAAE,CAAC,IAAI,CAC7C,kBAAM,CACJ,gBAAgB,CAAC,IAAI,CACnB,eAAG,CAAC,UAAC,EAAsB;gBAApB,YAAG,EAAE,gBAAK,EAAE,kBAAM;YACvB,EAAE,CAAC,CAAC,GAAG,KAAK,QAAQ,IAAI,CAAC,KAAK,CAAC;gBAAC,MAAM,CAAC,CAAC,QAAQ,GAAG,MAAM,CAAC,EAAE,CAAC,CAAC,CAAC,iDAAiD;QAClH,CAAC,CAAC,CACH,CACF,EACD,mBAAO,CAAC,UAAA,CAAC,IAAI,OAAA,CAAC,EAAD,CAAC,CAAC,EAAE,mCAAmC;QACpD,kBAAM,CAAC,UAAC,EAAa;gBAAX,aAAS;YAAO,OAAA,QAAQ,KAAK,SAAS,IAAI,KAAK,KAAK,QAAQ;QAA5C,CAA4C,CAAC,EAAE,uCAAuC;QAChH,iBAAK,CAAC,gBAAgB,CAAC,CAAC,wCAAwC;SACjE,CAAC;QAEF,MAAM,CAAC,eAAe,CAAC;IACzB,CAAC;IAED;;OAEG;IACI,gCAAU,GAAjB,UAAkB,MAAc;QAAE,gBAA2B;aAA3B,UAA2B,EAA3B,qBAA2B,EAA3B,IAA2B;YAA3B,+BAA2B;;QAC3D,IAAI,EAAE,GAAG,SAAI,EAAE,CAAC;QAChB,IAAI,CAAC,WAAW,CAAC;YACf,GAAG,EAAE,QAAQ;YACb,MAAM,QAAA;YACN,EAAE,IAAA;YACF,MAAM,QAAA;SACP,CAAC,CAAC;QACH,MAAM,CAAC,IAAI,CAAC,yBAAyB,CAAC,EAAE,CAAC,CAAC;IAC5C,CAAC;IAED;;OAEG;IACI,qCAAe,GAAtB,UACE,UAAkB,EAClB,WAAmB,EACnB,QAAiB;QAEjB,IAAI,EAAE,GAAG,SAAI,EAAE,CAAC;QAChB,IAAI,YAAY,GAAG,IAAI,CAAC,SAAS,CAAC,SAAS,CACzC,cAAM,OAAA,CAAC;YACL,GAAG,EAAE,KAAK;YACV,EAAE,EAAE,EAAE;YACN,IAAI,EAAE,UAAU;YAChB,MAAM,EAAE,CAAC,WAAW,EAAE,QAAQ,CAAC;SAChC,CAAC,EALI,CAKJ,EACF,cAAM,OAAA,CAAC;YACL,GAAG,EAAE,OAAO;YACZ,EAAE,EAAE,EAAE;SACP,CAAC,EAHI,CAGJ,EACF,UAAC,OAAY;YACX,OAAA,OAAO,OAAO,CAAC,UAAU,KAAK,QAAQ;gBACtC,OAAO,CAAC,UAAU,KAAK,UAAU;gBACjC,OAAO,CAAC,MAAM,CAAC,SAAS,KAAK,WAAW;QAFxC,CAEwC,CAAC,uGAAuG;SACnJ,CAAC;QACF,MAAM,CAAC,YAAY,CAAC;IACtB,CAAC;IACH,kBAAC;AAAD,CAAC,AAjOD,IAiOC;AAjOY,kCAAW"}
|
||||||
@ -1 +1 @@
|
|||||||
export { RealTimeAPI } from "./RealTimeAPI";
|
export { RealTimeAPI } from "./RealTimeAPI";
|
||||||
|
|||||||
@ -1,5 +1,5 @@
|
|||||||
"use strict";
|
"use strict";
|
||||||
Object.defineProperty(exports, "__esModule", { value: true });
|
Object.defineProperty(exports, "__esModule", { value: true });
|
||||||
var RealTimeAPI_1 = require("./RealTimeAPI");
|
var RealTimeAPI_1 = require("./RealTimeAPI");
|
||||||
exports.RealTimeAPI = RealTimeAPI_1.RealTimeAPI;
|
exports.RealTimeAPI = RealTimeAPI_1.RealTimeAPI;
|
||||||
//# sourceMappingURL=index.js.map
|
//# sourceMappingURL=index.js.map
|
||||||
Loading…
Reference in New Issue