123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453 |
- "use strict";
- var __assign = (this && this.__assign) || function () {
- __assign = Object.assign || function(t) {
- for (var s, i = 1, n = arguments.length; i < n; i++) {
- s = arguments[i];
- for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))
- t[p] = s[p];
- }
- return t;
- };
- return __assign.apply(this, arguments);
- };
- var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
- return new (P || (P = Promise))(function (resolve, reject) {
- function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
- function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
- function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
- step((generator = generator.apply(thisArg, _arguments || [])).next());
- });
- };
- var __generator = (this && this.__generator) || function (thisArg, body) {
- var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g;
- return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;
- function verb(n) { return function (v) { return step([n, v]); }; }
- function step(op) {
- if (f) throw new TypeError("Generator is already executing.");
- while (_) try {
- if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;
- if (y = 0, t) op = [op[0] & 2, t.value];
- switch (op[0]) {
- case 0: case 1: t = op; break;
- case 4: _.label++; return { value: op[1], done: false };
- case 5: _.label++; y = op[1]; op = [0]; continue;
- case 7: op = _.ops.pop(); _.trys.pop(); continue;
- default:
- if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }
- if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }
- if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }
- if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }
- if (t[2]) _.ops.pop();
- _.trys.pop(); continue;
- }
- op = body.call(thisArg, _);
- } catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }
- if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
- }
- };
- Object.defineProperty(exports, "__esModule", { value: true });
- var ts_linker_sdk_1 = require("@bilingo.com/ts-linker-sdk");
- var meta_1 = require("./meta");
- var meta = meta_1.getMetaData();
- var PING_INTERVAL = 50 * 1000;
- var WebSocketClient = (function () {
- function WebSocketClient(wsUrl, token, sid, chatToken, extendOpts) {
- this.status = {
- created: false,
- connected: false,
- login: false
- };
- this.wsUrl = wsUrl;
- this.token = token;
- this.chatToken = chatToken;
- this.sid = sid;
- this.extendOpts = extendOpts;
- }
- WebSocketClient.prototype.init = function () {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.create()];
- });
- });
- };
- WebSocketClient.prototype.getStatus = function () {
- return this.status;
- };
- WebSocketClient.prototype.create = function () {
- return __awaiter(this, void 0, void 0, function () {
- var url;
- var _this = this;
- return __generator(this, function (_a) {
- url = this.wsUrl;
- return [2, new Promise(function (resolve, reject) {
- if (!url) {
- throw new Error('websocket url is required.');
- }
- var binaryType = 'blob';
- if (_this.extendOpts && _this.extendOpts.binaryType) {
- binaryType = _this.extendOpts.binaryType;
- }
- _this.client = ts_linker_sdk_1.Client.getInstance(url, {
- onOpen: function () { return __awaiter(_this, void 0, void 0, function () {
- var data;
- var _this = this;
- return __generator(this, function (_a) {
- switch (_a.label) {
- case 0:
- try {
- this.ping();
- this.interval = setInterval(function () {
- _this.ping();
- }, PING_INTERVAL);
- }
- catch (err) {
- console.error(err);
- reject(err);
- }
- return [4, this.connect()];
- case 1:
- data = _a.sent();
- return [4, this.authentication()];
- case 2:
- _a.sent();
- resolve(data.value);
- return [2];
- }
- });
- }); },
- onError: function () {
- resolve(false);
- },
- onClose: function () {
- clearInterval(_this.interval);
- }
- }, binaryType, true);
- })];
- });
- });
- };
- WebSocketClient.prototype.on = function (url, callback) {
- if (!url) {
- throw new Error('url is required.');
- }
- this.client.addMessageListener(url, callback);
- };
- WebSocketClient.prototype.off = function (url) {
- this.client.removeMessageListener(url);
- };
- WebSocketClient.prototype.request = function (url, data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.client.request(url, data)];
- });
- });
- };
- WebSocketClient.prototype.connect = function () {
- return __awaiter(this, void 0, void 0, function () {
- var sid, param, data, id;
- return __generator(this, function (_a) {
- switch (_a.label) {
- case 0:
- sid = this.sid;
- if (sid) {
- this.client.setRequestProperty('sid', sid);
- }
- param = __assign({}, this.chatToken, meta);
- if (this.extendOpts && this.extendOpts.connectOptions) {
- param = __assign({}, param, this.extendOpts.connectOptions);
- }
- return [4, this.request('/v1/session/start', __assign({}, param))];
- case 1:
- data = _a.sent();
- if (data && data.value) {
- id = data.value;
- this.sid = id;
- this.client.setRequestProperty('sid', id);
- }
- return [2, data || true];
- }
- });
- });
- };
- WebSocketClient.prototype.ping = function () {
- return this.client.ping({});
- };
- WebSocketClient.prototype.authentication = function () {
- return __awaiter(this, void 0, void 0, function () {
- var tk, data;
- return __generator(this, function (_a) {
- switch (_a.label) {
- case 0:
- tk = this.token;
- return [4, this.request('/v1/session/bind/uid/by/token', { token: tk })];
- case 1:
- data = _a.sent();
- return [2, data || true];
- }
- });
- });
- };
- WebSocketClient.prototype.onMessage = function (callback) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- this.on('/v1/message/listener', callback);
- return [2];
- });
- });
- };
- WebSocketClient.prototype.sendMessage = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/send/message', data)];
- });
- });
- };
- WebSocketClient.prototype.markServiced = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/mark/message/serviced', data)];
- });
- });
- };
- WebSocketClient.prototype.messageReaded = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/mark/messages/read', data)];
- });
- });
- };
- WebSocketClient.prototype.getHistoryMessage = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/history/message', data)];
- });
- });
- };
- WebSocketClient.prototype.updateStatus = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/session/status', data)];
- });
- });
- };
- WebSocketClient.prototype.getSessionLists = function () {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/session/lists', {})];
- });
- });
- };
- WebSocketClient.prototype.getAllConversations = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/get/all/conversation', data)];
- });
- });
- };
- WebSocketClient.prototype.getAllContact = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/users/friends', data)];
- });
- });
- };
- WebSocketClient.prototype.addContact = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/add/contact', data)];
- });
- });
- };
- WebSocketClient.prototype.deleteContact = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/delete/contact', data)];
- });
- });
- };
- WebSocketClient.prototype.maskingContact = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/add/contact/masking', data)];
- });
- });
- };
- WebSocketClient.prototype.removeMaskingContact = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/remove/contact/masking', data)];
- });
- });
- };
- WebSocketClient.prototype.stickingContact = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/add/contact/stick', data)];
- });
- });
- };
- WebSocketClient.prototype.removeStickContact = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/remove/contact/stick', data)];
- });
- });
- };
- WebSocketClient.prototype.setNoDisturbing = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/add/contact/no/disturbing', data)];
- });
- });
- };
- WebSocketClient.prototype.removeNoDisturbing = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/remove/contact/no/disturbing', data)];
- });
- });
- };
- WebSocketClient.prototype.agreeAddContact = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/add/contact/agree', data)];
- });
- });
- };
- WebSocketClient.prototype.rejectAddContact = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/add/contact/reject', data)];
- });
- });
- };
- WebSocketClient.prototype.addContactServiced = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/add/contact/serviced', data)];
- });
- });
- };
- WebSocketClient.prototype.createChatroom = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/create/chatroom', data)];
- });
- });
- };
- WebSocketClient.prototype.destroyChatroom = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/destroy/chatroom', data)];
- });
- });
- };
- WebSocketClient.prototype.leaveChatroom = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/leave/chatroom', data)];
- });
- });
- };
- WebSocketClient.prototype.getChatroomProfile = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/get/chatroom/profile', data)];
- });
- });
- };
- WebSocketClient.prototype.updateChatroomSubject = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/update/chatroom/subject', data)];
- });
- });
- };
- WebSocketClient.prototype.updateChatroomDescription = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/update/chatroom/description', data)];
- });
- });
- };
- WebSocketClient.prototype.addChatroomAdmin = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/add/chatroom/admin', data)];
- });
- });
- };
- WebSocketClient.prototype.removeChatroomAdmin = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/remove/chatroom/admin', data)];
- });
- });
- };
- WebSocketClient.prototype.addChatroomAdmins = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/add/chatroom/admins', data)];
- });
- });
- };
- WebSocketClient.prototype.removeChatroomAdmins = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/remove/chatroom/admins', data)];
- });
- });
- };
- WebSocketClient.prototype.joinChatroom = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/join/chatroom', data)];
- });
- });
- };
- WebSocketClient.prototype.removeChatroomMember = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/remove/chatroom/member', data)];
- });
- });
- };
- WebSocketClient.prototype.fetchStickChatroom = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/fetch/stick/chatroom', data)];
- });
- });
- };
- WebSocketClient.prototype.fetchChatroomMembers = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/chatroom/members', data)];
- });
- });
- };
- WebSocketClient.prototype.setConversationIsTop = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/set/conversation/is/top/request', data)];
- });
- });
- };
- WebSocketClient.prototype.searchHistoryMessage = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/search/history/message', data)];
- });
- });
- };
- WebSocketClient.prototype.startGroupChat = function (data) {
- return __awaiter(this, void 0, void 0, function () {
- return __generator(this, function (_a) {
- return [2, this.request('/v1/create/group/request', data)];
- });
- });
- };
- return WebSocketClient;
- }());
- exports.WebSocketClient = WebSocketClient;
|