"use strict"; var __extends = (this && this.__extends) || (function () { var extendStatics = function (d, b) { extendStatics = Object.setPrototypeOf || ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) || function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; }; return extendStatics(d, b); }; return function (d, b) { extendStatics(d, b); function __() { this.constructor = d; } d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __()); }; })(); 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) { function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); } 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) : adopt(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 }; } }; var __spreadArrays = (this && this.__spreadArrays) || function () { for (var s = 0, i = 0, il = arguments.length; i < il; i++) s += arguments[i].length; for (var r = Array(s), k = 0, i = 0; i < il; i++) for (var a = arguments[i], j = 0, jl = a.length; j < jl; j++, k++) r[k] = a[j]; return r; }; exports.__esModule = true; var TUIPlugin_1 = require("../../../TUIPlugin"); var IComponentServer_1 = require("../IComponentServer"); var utils_1 = require("./utils/utils"); /** * class TUIChatServer * * TUIChat 逻辑主体 */ var TUIChatServer = /** @class */ (function (_super) { __extends(TUIChatServer, _super); function TUIChatServer(TUICore) { var _this = _super.call(this) || this; _this.currentStore = {}; _this.TUICore = TUICore; _this.bindTIMEvent(); _this.store = TUICore.setComponentStore("TUIChat", {}, _this.updateStore.bind(_this)); return _this; } /** * 组件销毁 * destroy */ TUIChatServer.prototype.destroyed = function () { this.unbindTIMEvent(); }; /** * 数据监听回调 * data listener callback * * @param {any} newValue 新数据 * @param {any} oldValue 旧数据 * */ TUIChatServer.prototype.updateStore = function (newValue, oldValue) { Object.assign(this.currentStore, newValue); if (!newValue.conversation.conversationID) { this.currentStore.messageList = []; return; } if (newValue.conversation.conversationID && newValue.conversation.conversationID !== oldValue.conversation.conversationID) { this.render(newValue.conversation); } }; TUIChatServer.prototype.render = function (conversation) { var _this = this; var _a, _b, _c; var len = 15; this.currentStore.isFirstRender = true; this.currentStore.messageList = []; this.currentStore.readSet.clear(); this.getMessageList({ conversationID: conversation.conversationID, count: len }); if (conversation.type === this.TUICore.TIM.TYPES.CONV_GROUP) { this.currentStore.userInfo.isGroup = true; var options = { groupID: conversation.groupProfile.groupID, userIDList: [conversation.groupProfile.selfInfo.userID] }; this.getGroupProfile({ groupID: conversation.groupProfile.groupID }); this.getGroupMemberProfile(options).then(function (res) { var memberList = res.data.memberList; var selfInfo = memberList[0]; _this.currentStore.selfInfo = selfInfo; }); (_c = (_b = (_a = this === null || this === void 0 ? void 0 : this.TUICore) === null || _a === void 0 ? void 0 : _a.TUIServer) === null || _b === void 0 ? void 0 : _b.TUIGroup) === null || _c === void 0 ? void 0 : _c.getGroupMemberList({ groupID: conversation.groupProfile.groupID, count: 100, offset: 0 }).then(function (res) { var _a; _this.currentStore.allMemberList = (_a = res.data) === null || _a === void 0 ? void 0 : _a.memberList; }); } else { this.currentStore.userInfo.isGroup = false; this.currentStore.userInfo.list = [conversation === null || conversation === void 0 ? void 0 : conversation.userProfile]; } }; /** * ///////////////////////////////////////////////////////////////////////////////// * // * // TIM 事件监听注册接口 * // TIM Event listener registration interface * // * ///////////////////////////////////////////////////////////////////////////////// */ TUIChatServer.prototype.bindTIMEvent = function () { this.TUICore.tim.on(this.TUICore.TIM.EVENT.MESSAGE_RECEIVED, this.handleMessageReceived, this); this.TUICore.tim.on(this.TUICore.TIM.EVENT.MESSAGE_MODIFIED, this.handleMessageModified, this); this.TUICore.tim.on(this.TUICore.TIM.EVENT.MESSAGE_REVOKED, this.handleMessageRevoked, this); this.TUICore.tim.on(this.TUICore.TIM.EVENT.MESSAGE_READ_BY_PEER, this.handleMessageReadByPeer, this); this.TUICore.tim.on(this.TUICore.TIM.EVENT.GROUP_LIST_UPDATED, this.handleGroupListUpdated, this); this.TUICore.tim.on(this.TUICore.TIM.EVENT.MESSAGE_READ_RECEIPT_RECEIVED, this.handleMessageReadReceiptReceived, this); }; TUIChatServer.prototype.unbindTIMEvent = function () { this.TUICore.tim.off(this.TUICore.TIM.EVENT.MESSAGE_RECEIVED, this.handleMessageReceived); this.TUICore.tim.off(this.TUICore.TIM.EVENT.MESSAGE_MODIFIED, this.handleMessageModified); this.TUICore.tim.off(this.TUICore.TIM.EVENT.MESSAGE_REVOKED, this.handleMessageRevoked); this.TUICore.tim.off(this.TUICore.TIM.EVENT.MESSAGE_READ_BY_PEER, this.handleMessageReadByPeer); this.TUICore.tim.off(this.TUICore.TIM.EVENT.GROUP_LIST_UPDATED, this.handleGroupListUpdated); this.TUICore.tim.off(this.TUICore.TIM.EVENT.MESSAGE_READ_RECEIPT_RECEIVED, this.handleMessageReadReceiptReceived); }; TUIChatServer.prototype.handleMessageReceived = function (event) { var _this = this; var _a; (_a = event === null || event === void 0 ? void 0 : event.data) === null || _a === void 0 ? void 0 : _a.forEach(function (message) { var _a, _b; if ((message === null || message === void 0 ? void 0 : message.conversationID) === ((_b = (_a = _this === null || _this === void 0 ? void 0 : _this.store) === null || _a === void 0 ? void 0 : _a.conversation) === null || _b === void 0 ? void 0 : _b.conversationID)) { _this.currentStore.messageList = __spreadArrays(_this.currentStore.messageList, [ message, ]); } TUIPlugin_1.TUINotification.getInstance().notify(message); }); }; TUIChatServer.prototype.handleMessageModified = function (event) { var middleData = this.currentStore.messageList; this.currentStore.messageList = []; this.currentStore.messageList = middleData; }; TUIChatServer.prototype.handleMessageRevoked = function (event) { var middleData = this.currentStore.messageList; this.currentStore.messageList = []; this.currentStore.messageList = middleData; }; TUIChatServer.prototype.handleMessageReadByPeer = function (event) { var middleData = this.currentStore.messageList; this.currentStore.messageList = []; this.currentStore.messageList = middleData; }; TUIChatServer.prototype.handleGroupListUpdated = function (event) { var _this = this; event === null || event === void 0 ? void 0 : event.data.map(function (item) { var _a, _b, _c; if ((item === null || item === void 0 ? void 0 : item.groupID) === ((_c = (_b = (_a = _this === null || _this === void 0 ? void 0 : _this.store) === null || _a === void 0 ? void 0 : _a.conversation) === null || _b === void 0 ? void 0 : _b.groupProfile) === null || _c === void 0 ? void 0 : _c.groupID)) { _this.store.conversation.groupProfile = item; _this.currentStore.conversation = {}; _this.currentStore.conversation = _this.store.conversation; } return item; }); }; TUIChatServer.prototype.handleMessageReadReceiptReceived = function (event) { var middleData = this.currentStore.messageList; this.currentStore.messageList = []; this.currentStore.messageList = middleData; }; /** * ///////////////////////////////////////////////////////////////////////////////// * // * // 处理 TIM 接口参数及回调 * // Handling TIM interface parameters and callbacks * // * ///////////////////////////////////////////////////////////////////////////////// */ /** * 创建消息生成参数 * Create message generation parameters * * @param {Object} content 消息体 * @param {String} type 消息类型 text: 文本类型 file: 文件类型 face: 表情 location: 地址 custom: 自定义 merger: 合并 forward: 转发 * @param {Callback} callback 回调函数 * @param {any} to 发送的对象 * @returns {options} 消息参数 */ TUIChatServer.prototype.handleMessageOptions = function (content, type, callback, to) { var _a, _b, _c, _d, _e, _f; var options = { to: "", conversationType: (to === null || to === void 0 ? void 0 : to.type) || this.store.conversation.type, payload: content, needReadReceipt: this.currentStore.needReadReceipt }; if (this.currentStore.needTyping) { options.cloudCustomData = { messageFeature: { needTyping: 1, version: 1 } }; options.cloudCustomData = JSON.stringify(options.cloudCustomData); } if (type === "file" && callback) { options.onProgress = callback; } switch (options.conversationType) { case this.TUICore.TIM.TYPES.CONV_C2C: options.to = ((_a = to === null || to === void 0 ? void 0 : to.userProfile) === null || _a === void 0 ? void 0 : _a.userID) || ((_c = (_b = this.store.conversation) === null || _b === void 0 ? void 0 : _b.userProfile) === null || _c === void 0 ? void 0 : _c.userID) || ""; break; case this.TUICore.TIM.TYPES.CONV_GROUP: options.to = ((_d = to === null || to === void 0 ? void 0 : to.groupProfile) === null || _d === void 0 ? void 0 : _d.groupID) || ((_f = (_e = this.store.conversation) === null || _e === void 0 ? void 0 : _e.groupProfile) === null || _f === void 0 ? void 0 : _f.groupID) || ""; break; default: break; } return options; }; /** * 处理异步函数 * Handling asynchronous functions * * @param {callback} callback 回调函数 * @returns {Promise} 返回异步函数 */ TUIChatServer.prototype.handlePromiseCallback = function (callback) { var _this = this; return new Promise(function (resolve, reject) { var config = { TUIName: "TUIChat", callback: function () { callback && callback(resolve, reject); } }; _this.TUICore.setAwaitFunc(config.TUIName, config.callback); }); }; /** * 重试异步函数 * Retry asynchronous functions * 默认执行一次，之后按时间间隔列表重复执行直到成功，重复次数完毕后仍失败则失败 * Execute once by default, and then repeat it according to the time interval list until it succeeds. * If it still fails after the number of repetitions is complete, it will reject. * * @param {callback} callback 回调函数/callback function * @param {Array} intervalList 间隔时间列表/interval list * @param {callback} retryBreakFn 强制重复结束条件函数/break retry function * @returns {Promise} 返回异步函数/return */ TUIChatServer.prototype.handlePromiseCallbackRetry = function (callback, intervalList, retryBreakFn) { if (intervalList === void 0) { intervalList = []; } if (retryBreakFn === void 0) { retryBreakFn = function () { return false; }; } return new Promise(function (resolve, reject) { var times = 0; function tryFn() { times++; callback() .then(resolve)["catch"](function (error) { if (times > intervalList.length || (retryBreakFn && retryBreakFn(error))) { reject(error); return; } setTimeout(tryFn, intervalList[times - 1]); }); } tryFn(); }); }; /** * 文件上传进度函数处理 * File upload progress function processing * * @param {number} progress 文件上传进度 1表示完成 * @param {message} message 文件消息 */ TUIChatServer.prototype.handleUploadProgress = function (progress, message) { this.currentStore.messageList.map(function (item) { if (item.ID === message.ID) { item.progress = progress; } return item; }); }; /** * ///////////////////////////////////////////////////////////////////////////////// * // * // TIM 方法 * // TIM methods * // * ///////////////////////////////////////////////////////////////////////////////// */ /** * 发送表情消息 * Send face messages * * @param {Object} data 消息内容/message content * @param {Number} data.index 表情索引/face index * @param {String} data.data 额外数据/extra data * @returns {Promise} */ TUIChatServer.prototype.sendFaceMessage = function (data) { var _this = this; return this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var options, message, imResponse_1, error_1, middleData; return __generator(this, function (_a) { switch (_a.label) { case 0: _a.trys.push([0, 2, , 3]); options = this.handleMessageOptions(data, "face"); message = this.TUICore.tim.createFaceMessage(options); this.currentStore.messageList.push(message); return [4 /*yield*/, this.TUICore.tim.sendMessage(message)]; case 1: imResponse_1 = _a.sent(); this.currentStore.messageList = this.currentStore.messageList.map(function (item) { if (item.ID === imResponse_1.data.message.ID) { return imResponse_1.data.message; } return item; }); resolve(imResponse_1); return [3 /*break*/, 3]; case 2: error_1 = _a.sent(); reject(error_1); middleData = this.currentStore.messageList; this.currentStore.messageList = []; this.currentStore.messageList = middleData; return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); }); }; /** * 发送图片消息 * Send image message * * @param {Image} image 图片文件/image * @returns {Promise} */ TUIChatServer.prototype.sendImageMessage = function (image) { var _this = this; return this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var options, message_1, imResponse_2, error_2, middleData; var _this = this; return __generator(this, function (_a) { switch (_a.label) { case 0: _a.trys.push([0, 2, , 3]); options = this.handleMessageOptions({ file: image }, "file", function (progress) { _this.handleUploadProgress(progress, message_1); }); message_1 = this.TUICore.tim.createImageMessage(options); message_1.progress = 0.01; this.currentStore.messageList.push(message_1); return [4 /*yield*/, this.TUICore.tim.sendMessage(message_1)]; case 1: imResponse_2 = _a.sent(); this.currentStore.messageList = this.currentStore.messageList.map(function (item) { if (item.ID === imResponse_2.data.message.ID) { return imResponse_2.data.message; } return item; }); resolve(imResponse_2); return [3 /*break*/, 3]; case 2: error_2 = _a.sent(); reject(error_2); middleData = this.currentStore.messageList; this.currentStore.messageList = []; this.currentStore.messageList = middleData; return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); }); }; /** * 发送视频消息 * Send video message * * @param {Video} video 视频文件/video * @returns {Promise} */ TUIChatServer.prototype.sendVideoMessage = function (video) { var _this = this; return this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var options, message_2, imResponse_3, error_3, middleData; var _this = this; return __generator(this, function (_a) { switch (_a.label) { case 0: _a.trys.push([0, 2, , 3]); options = this.handleMessageOptions({ file: video }, "file", function (progress) { _this.handleUploadProgress(progress, message_2); }); message_2 = this.TUICore.tim.createVideoMessage(options); message_2.progress = 0.01; this.currentStore.messageList.push(message_2); return [4 /*yield*/, this.TUICore.tim.sendMessage(message_2)]; case 1: imResponse_3 = _a.sent(); this.currentStore.messageList = this.currentStore.messageList.map(function (item) { if (item.ID === imResponse_3.data.message.ID) { return imResponse_3.data.message; } return item; }); resolve(imResponse_3); return [3 /*break*/, 3]; case 2: error_3 = _a.sent(); reject(error_3); middleData = this.currentStore.messageList; this.currentStore.messageList = []; this.currentStore.messageList = middleData; return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); }); }; /** * 发送文件消息 * Send file message * * @param {File} file 文件/file * @returns {Promise} */ TUIChatServer.prototype.sendFileMessage = function (file) { var _this = this; return this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var options, message_3, imResponse_4, error_4, middleData; var _this = this; return __generator(this, function (_a) { switch (_a.label) { case 0: _a.trys.push([0, 2, , 3]); options = this.handleMessageOptions({ file: file }, "file", function (progress) { _this.handleUploadProgress(progress, message_3); }); message_3 = this.TUICore.tim.createFileMessage(options); message_3.progress = 0.01; this.currentStore.messageList.push(message_3); return [4 /*yield*/, this.TUICore.tim.sendMessage(message_3)]; case 1: imResponse_4 = _a.sent(); this.currentStore.messageList = this.currentStore.messageList.map(function (item) { if (item.ID === imResponse_4.data.message.ID) { return imResponse_4.data.message; } return item; }); resolve(imResponse_4); return [3 /*break*/, 3]; case 2: error_4 = _a.sent(); reject(error_4); middleData = this.currentStore.messageList; this.currentStore.messageList = []; this.currentStore.messageList = middleData; return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); }); }; /** * 发送自定义消息 * Send Custom message * * @param {Object} data 消息内容/message content * @param {String} data.data 自定义消息的数据字段/custom message data fields * @param {String} data.description 自定义消息的说明字段/custom message description fields * @param {String} data.extension 自定义消息的扩展字段/custom message extension fields * @returns {Promise} */ TUIChatServer.prototype.sendCustomMessage = function (data) { var _this = this; return this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var options, message, imResponse_5, error_5, middleData; return __generator(this, function (_a) { switch (_a.label) { case 0: _a.trys.push([0, 2, , 3]); data.data = JSON.stringify(data.data); options = this.handleMessageOptions(data, "custom"); message = this.TUICore.tim.createCustomMessage(options); this.currentStore.messageList.push(message); return [4 /*yield*/, this.TUICore.tim.sendMessage(message)]; case 1: imResponse_5 = _a.sent(); this.currentStore.messageList = this.currentStore.messageList.map(function (item) { if (item.ID === imResponse_5.data.message.ID) { return imResponse_5.data.message; } return item; }); resolve(imResponse_5); return [3 /*break*/, 3]; case 2: error_5 = _a.sent(); reject(error_5); middleData = this.currentStore.messageList; this.currentStore.messageList = []; this.currentStore.messageList = middleData; return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); }); }; /** * 发送地理位置消息 * Send location message * * @param {Object} data 消息内容/message content * @param {String} data.description 地理位置描述信息/geographic descriptive information * @param {Number} data.longitude 经度/longitude * @param {Number} data.latitude 纬度/latitude * @returns {Promise} */ TUIChatServer.prototype.sendLocationMessage = function (data) { var _this = this; return this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var options, message, imResponse, error_6, middleData; return __generator(this, function (_a) { switch (_a.label) { case 0: _a.trys.push([0, 2, , 3]); options = this.handleMessageOptions(data, "location"); message = this.TUICore.tim.createLocationMessage(options); this.currentStore.messageList.push(message); return [4 /*yield*/, this.TUICore.tim.sendMessage(message)]; case 1: imResponse = _a.sent(); resolve(imResponse); return [3 /*break*/, 3]; case 2: error_6 = _a.sent(); reject(error_6); middleData = this.currentStore.messageList; this.currentStore.messageList = []; this.currentStore.messageList = middleData; return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); }); }; /** * 转发消息 * forward message * * @param {message} message 消息实例/message * @param {any} to 转发的对象/forward to * @returns {Promise} */ TUIChatServer.prototype.forwardMessage = function (message, to) { var _this = this; return this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var options, imMessage, imResponse, error_7, middleData; return __generator(this, function (_a) { switch (_a.label) { case 0: _a.trys.push([0, 2, , 3]); options = this.handleMessageOptions(message, "forward", {}, to); imMessage = this.TUICore.tim.createForwardMessage(options); return [4 /*yield*/, this.TUICore.tim.sendMessage(imMessage)]; case 1: imResponse = _a.sent(); if (this.store.conversation.conversationID === imResponse.data.message.conversationID) { this.currentStore.messageList.push(imResponse.data.message); } resolve(imResponse); return [3 /*break*/, 3]; case 2: error_7 = _a.sent(); reject(error_7); middleData = this.currentStore.messageList; this.currentStore.messageList = []; this.currentStore.messageList = middleData; return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); }); }; /** * 发送消息已读回执 * Send message read receipt * * @param {Array} messageList 同一个 C2C 或 GROUP 会话的消息列表，最大长度为30/A list of messages for the same C2C or GROUP conversation, with a maximum length of 30 * @returns {Promise} */ TUIChatServer.prototype.sendMessageReadReceipt = function (messageList) { return __awaiter(this, void 0, void 0, function () { var _this = this; return __generator(this, function (_a) { return [2 /*return*/, this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var imResponse, error_8; return __generator(this, function (_a) { switch (_a.label) { case 0: _a.trys.push([0, 2, , 3]); return [4 /*yield*/, this.TUICore.tim.sendMessageReadReceipt(messageList)]; case 1: imResponse = _a.sent(); resolve(imResponse); return [3 /*break*/, 3]; case 2: error_8 = _a.sent(); reject(error_8); return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); })]; }); }); }; /** * 拉取已读回执列表 * Pull read receipt list * * @param {Array} messageList 同一群会话的消息列表/The message list of the same group of the conversation * @returns {Promise} */ TUIChatServer.prototype.getMessageReadReceiptList = function (messageList) { return __awaiter(this, void 0, void 0, function () { var _this = this; return __generator(this, function (_a) { return [2 /*return*/, this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var imResponse, error_9; return __generator(this, function (_a) { switch (_a.label) { case 0: _a.trys.push([0, 2, , 3]); return [4 /*yield*/, this.TUICore.tim.getMessageReadReceiptList(messageList)]; case 1: imResponse = _a.sent(); resolve(imResponse); return [3 /*break*/, 3]; case 2: error_9 = _a.sent(); reject(error_9); return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); })]; }); }); }; /** * ///////////////////////////////////////////////////////////////////////////////// * // * // 对外方法 * // * ///////////////////////////////////////////////////////////////////////////////// */ /** * 获取 messageList * get messagelist * * @param {any} options 获取 messageList 参数/messageList options * @param {Boolean} history 是否获取历史消息/Whether to get historical information * @returns {Promise} */ TUIChatServer.prototype.getMessageList = function (options, history) { return __awaiter(this, void 0, void 0, function () { var _this = this; return __generator(this, function (_a) { return [2 /*return*/, this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var imResponse, error_10; return __generator(this, function (_a) { switch (_a.label) { case 0: _a.trys.push([0, 4, , 5]); return [4 /*yield*/, this.TUICore.tim.getMessageList(options)]; case 1: imResponse = _a.sent(); console.warn(imResponse.data.messageList); if (!imResponse.data.messageList.length) return [3 /*break*/, 3]; return [4 /*yield*/, this.getMessageReadReceiptList(imResponse.data.messageList)]; case 2: _a.sent(); _a.label = 3; case 3: if (!history) { this.currentStore.messageList = imResponse.data.messageList; } else { this.currentStore.messageList = __spreadArrays(imResponse.data.messageList, this.currentStore.messageList); } this.currentStore.nextReqMessageID = imResponse.data.nextReqMessageID; this.currentStore.isCompleted = imResponse.data.isCompleted; resolve(imResponse); return [3 /*break*/, 5]; case 4: error_10 = _a.sent(); reject(error_10); return [3 /*break*/, 5]; case 5: return [2 /*return*/]; } }); }); })]; }); }); }; /** * 获取历史消息 * get history messagelist * * @returns {Promise} */ TUIChatServer.prototype.getHistoryMessageList = function () { return __awaiter(this, void 0, void 0, function () { var options; return __generator(this, function (_a) { options = { conversationID: this.currentStore.conversation.conversationID, nextReqMessageID: this.currentStore.nextReqMessageID, count: 15 }; if (!this.currentStore.isCompleted) { this.getMessageList(options, true); } return [2 /*return*/]; }); }); }; /** * 发送文本消息 * send text message * * @param {any} text 发送的消息/text message * @param {object} data 被引用消息的内容/The content of the quoted message * @returns {Promise} */ TUIChatServer.prototype.sendTextMessage = function (text, data) { var _this = this; return this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var options, cloudCustomDataObj, cloudCustomData, secondOptions, message, imResponse_6, error_11, middleData; return __generator(this, function (_a) { switch (_a.label) { case 0: _a.trys.push([0, 2, , 3]); options = this.handleMessageOptions({ text: text }, "text"); cloudCustomDataObj = {}; if (options.cloudCustomData) { try { cloudCustomDataObj = utils_1.JSONToObject(options.cloudCustomData); } catch (_b) { cloudCustomDataObj = {}; } } cloudCustomData = JSON.stringify(data); secondOptions = Object.assign(options, __assign({ cloudCustomData: cloudCustomData }, cloudCustomDataObj)); message = this.TUICore.tim.createTextMessage(secondOptions); this.currentStore.messageList.push(message); return [4 /*yield*/, this.TUICore.tim.sendMessage(message)]; case 1: imResponse_6 = _a.sent(); this.currentStore.messageList = this.currentStore.messageList.map(function (item) { if (item.ID === imResponse_6.data.message.ID) { return imResponse_6.data.message; } return item; }); resolve(imResponse_6); return [3 /*break*/, 3]; case 2: error_11 = _a.sent(); reject(error_11); middleData = this.currentStore.messageList; this.currentStore.messageList = []; this.currentStore.messageList = middleData; return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); }); }; /** * 发送【对方正在输入中】在线自定义消息 * send typing online custom message * * @param {Object} data 消息内容/message content * @param {String} data.data 自定义消息的数据字段/custom message data field * @param {String} data.description 自定义消息的说明字段/custom message description field * @param {String} data.extension 自定义消息的扩展字段/custom message extension field * @returns {Promise} */ TUIChatServer.prototype.sendTypingMessage = function (data) { var _this = this; return this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var options, message, imResponse, error_12, middleData; return __generator(this, function (_a) { switch (_a.label) { case 0: _a.trys.push([0, 2, , 3]); data.data = JSON.stringify(data.data); options = this.handleMessageOptions(data, "custom"); message = this.TUICore.tim.createCustomMessage(options); return [4 /*yield*/, this.TUICore.tim.sendMessage(message, { onlineUserOnly: true })]; case 1: imResponse = _a.sent(); resolve(imResponse); return [3 /*break*/, 3]; case 2: error_12 = _a.sent(); reject(error_12); middleData = this.currentStore.messageList; this.currentStore.messageList = []; this.currentStore.messageList = middleData; return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); }); }; /** * 发送@ 提醒功能的文本消息 * Send @ Reminder text message * * @param {any} data 消息内容/message content * @param {String} data.text 文本消息/text message * @param {Array} data.atUserList 需要 @ 的用户列表，如果需要 @ALL，请传入 TIM.TYPES.MSG_AT_ALL / List of users who need @, if you need @ALL, please pass in TIM.TYPES.MSG_AT_ALL * @returns {message} * * - 注：此接口仅用于群聊/This interface is only used for group chat */ TUIChatServer.prototype.sendTextAtMessage = function (data) { var _this = this; return this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var options, message, imResponse_7, error_13, middleData; return __generator(this, function (_a) { switch (_a.label) { case 0: _a.trys.push([0, 2, , 3]); options = this.handleMessageOptions(data, "text"); message = this.TUICore.tim.createTextAtMessage(options); this.currentStore.messageList.push(message); return [4 /*yield*/, this.TUICore.tim.sendMessage(message)]; case 1: imResponse_7 = _a.sent(); this.currentStore.messageList = this.currentStore.messageList.map(function (item) { if (item.ID === imResponse_7.data.message.ID) { return imResponse_7.data.message; } return item; }); resolve(imResponse_7); return [3 /*break*/, 3]; case 2: error_13 = _a.sent(); reject(error_13); middleData = this.currentStore.messageList; this.currentStore.messageList = []; this.currentStore.messageList = middleData; return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); }); }; /** * 发送合并消息 * send merger message * * @param {Object} data 消息内容/message content * @param {Array.} data.messageList 合并的消息列表/merger message list * @param {String} data.title 合并的标题/merger title * @param {String} data.abstractList 摘要列表，不同的消息类型可以设置不同的摘要信息/Summary list, different message types can set different summary information * @param {String} data.compatibleText 兼容文本/ompatible text * @returns {Promise} */ TUIChatServer.prototype.sendMergerMessage = function (data) { var _this = this; return this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var options, message, imResponse_8, error_14, middleData; return __generator(this, function (_a) { switch (_a.label) { case 0: _a.trys.push([0, 2, , 3]); options = this.handleMessageOptions(data, "merger"); message = this.TUICore.tim.createMergerMessage(options); this.currentStore.messageList.push(message); return [4 /*yield*/, this.TUICore.tim.sendMessage(message)]; case 1: imResponse_8 = _a.sent(); this.currentStore.messageList = this.currentStore.messageList.map(function (item) { if (item.ID === imResponse_8.data.message.ID) { return imResponse_8.data.message; } return item; }); resolve(imResponse_8); return [3 /*break*/, 3]; case 2: error_14 = _a.sent(); reject(error_14); middleData = this.currentStore.messageList; this.currentStore.messageList = []; this.currentStore.messageList = middleData; return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); }); }; /** * 消息撤回 * revoke message * * @param {message} message 消息实例/message * @returns {Promise} */ TUIChatServer.prototype.revokeMessage = function (message) { var _this = this; return this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var imResponse, cloudCustomData, error_15, middleData; var _a; return __generator(this, function (_b) { switch (_b.label) { case 0: _b.trys.push([0, 4, , 5]); return [4 /*yield*/, this.TUICore.tim.revokeMessage(message)]; case 1: imResponse = _b.sent(); cloudCustomData = utils_1.JSONToObject(message === null || message === void 0 ? void 0 : message.cloudCustomData); if (!((_a = cloudCustomData === null || cloudCustomData === void 0 ? void 0 : cloudCustomData.messageReply) === null || _a === void 0 ? void 0 : _a.messageRootID)) return [3 /*break*/, 3]; return [4 /*yield*/, this.revokeReplyMessage(message)]; case 2: _b.sent(); _b.label = 3; case 3: resolve(imResponse); return [3 /*break*/, 5]; case 4: error_15 = _b.sent(); reject(error_15); middleData = this.currentStore.messageList; this.currentStore.messageList = []; this.currentStore.messageList = middleData; return [3 /*break*/, 5]; case 5: return [2 /*return*/]; } }); }); }); }; /** * 重发消息 * resend message * * @param {message} message 消息实例/message * @returns {Promise} */ TUIChatServer.prototype.resendMessage = function (message) { var _this = this; return this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var imResponse, error_16; return __generator(this, function (_a) { switch (_a.label) { case 0: _a.trys.push([0, 2, , 3]); return [4 /*yield*/, this.TUICore.tim.resendMessage(message)]; case 1: imResponse = _a.sent(); this.currentStore.messageList = this.currentStore.messageList.filter(function (item) { return item.ID !== message.ID; }); this.currentStore.messageList.push(imResponse.data.message); resolve(imResponse); return [3 /*break*/, 3]; case 2: error_16 = _a.sent(); reject(error_16); return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); }); }; /** * 删除消息 * delete message * * @param {Array.} messages 消息实例/message * @returns {Promise} */ TUIChatServer.prototype.deleteMessage = function (messages) { var _this = this; return this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var imResponse, middleData, error_17; return __generator(this, function (_a) { switch (_a.label) { case 0: _a.trys.push([0, 2, , 3]); return [4 /*yield*/, this.TUICore.tim.deleteMessage(messages)]; case 1: imResponse = _a.sent(); resolve(imResponse); middleData = this.currentStore.messageList; this.currentStore.messageList = []; this.currentStore.messageList = middleData; return [3 /*break*/, 3]; case 2: error_17 = _a.sent(); reject(error_17); return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); }); }; /** * 变更消息 * modify message * * @param {Array.} message 消息实例/message * @returns {Promise} */ TUIChatServer.prototype.modifyMessage = function (message) { var _this = this; return this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var imResponse, error_18, code, data; var _a, _b; return __generator(this, function (_c) { switch (_c.label) { case 0: _c.trys.push([0, 2, , 3]); return [4 /*yield*/, this.TUICore.tim.modifyMessage(message)]; case 1: imResponse = _c.sent(); resolve(imResponse); return [3 /*break*/, 3]; case 2: error_18 = _c.sent(); code = (_a = error_18) === null || _a === void 0 ? void 0 : _a.code; data = (_b = error_18) === null || _b === void 0 ? void 0 : _b.data; if (code === 2480) { console.warn("MODIFY_MESSAGE_ERROR", "修改消息发生冲突，data.message 是最新的消息", "data.message:", data === null || data === void 0 ? void 0 : data.message); } else if (code === 2481) { console.warn("MODIFY_MESSAGE_ERROR", "不支持修改直播群消息"); } else if (code === 20026) { console.warn("MODIFY_MESSAGE_ERROR", "消息不存在"); } reject(error_18); return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); }); }; /** * 回复消息 * reply message * @param {Array.} message 消息实例/message * @returns {Promise} */ TUIChatServer.prototype.replyMessage = function (message, messageRoot) { var _this = this; var replyFunction = function () { return _this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var repliesObject, cloudCustomData, messageRootID_1, rootCloudCustomData, imResponse, error_19; var _a, _b, _c, _d, _e, _f; return __generator(this, function (_g) { switch (_g.label) { case 0: _g.trys.push([0, 3, , 4]); repliesObject = { messageAbstract: (_a = message === null || message === void 0 ? void 0 : message.payload) === null || _a === void 0 ? void 0 : _a.text, messageSender: message === null || message === void 0 ? void 0 : message.from, messageID: message === null || message === void 0 ? void 0 : message.ID, messageType: message === null || message === void 0 ? void 0 : message.type, messageTime: message === null || message === void 0 ? void 0 : message.time, messageSequence: message === null || message === void 0 ? void 0 : message.sequence, version: 1 }; if (!!messageRoot) return [3 /*break*/, 2]; cloudCustomData = utils_1.JSONToObject(message === null || message === void 0 ? void 0 : message.cloudCustomData); messageRootID_1 = (_b = cloudCustomData === null || cloudCustomData === void 0 ? void 0 : cloudCustomData.messageReply) === null || _b === void 0 ? void 0 : _b.messageRootID; return [4 /*yield*/, ((_d = (_c = this === null || this === void 0 ? void 0 : this.currentStore) === null || _c === void 0 ? void 0 : _c.messageList) === null || _d === void 0 ? void 0 : _d.find(function (item) { return (item === null || item === void 0 ? void 0 : item.ID) === messageRootID_1; }))]; case 1: messageRoot = (_g.sent()) || this.findMessage(messageRootID_1); _g.label = 2; case 2: rootCloudCustomData = (messageRoot === null || messageRoot === void 0 ? void 0 : messageRoot.cloudCustomData) ? utils_1.JSONToObject(messageRoot === null || messageRoot === void 0 ? void 0 : messageRoot.cloudCustomData) : { messageReplies: {} }; if ((_e = rootCloudCustomData === null || rootCloudCustomData === void 0 ? void 0 : rootCloudCustomData.messageReplies) === null || _e === void 0 ? void 0 : _e.replies) { rootCloudCustomData.messageReplies.replies = __spreadArrays((_f = rootCloudCustomData === null || rootCloudCustomData === void 0 ? void 0 : rootCloudCustomData.messageReplies) === null || _f === void 0 ? void 0 : _f.replies, [ repliesObject, ]); } else { rootCloudCustomData.messageReplies = { replies: [repliesObject], version: 1 }; } messageRoot.cloudCustomData = JSON.stringify(rootCloudCustomData); imResponse = this.modifyMessage(messageRoot); resolve(imResponse); return [3 /*break*/, 4]; case 3: error_19 = _g.sent(); reject(error_19); return [3 /*break*/, 4]; case 4: return [2 /*return*/]; } }); }); }); }; var retryBreakFunction = function (error) { if (error && (error === null || error === void 0 ? void 0 : error.code) === 2480) return false; return true; }; return this.handlePromiseCallbackRetry(replyFunction, [500, 1000, 3000], retryBreakFunction); }; /** * 撤回回复消息 * revoke reply message * @param {Array.} message 消息实例/message * @returns {Promise} */ TUIChatServer.prototype.revokeReplyMessage = function (message, messageRoot) { var _this = this; var revokeReplyFunction = function () { return _this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var cloudCustomData, messageRootID_2, rootCloudCustomData, index, imResponse, error_20; var _a, _b, _c, _d, _e, _f; return __generator(this, function (_g) { switch (_g.label) { case 0: _g.trys.push([0, 3, , 4]); if (!!messageRoot) return [3 /*break*/, 2]; cloudCustomData = utils_1.JSONToObject(message === null || message === void 0 ? void 0 : message.cloudCustomData); messageRootID_2 = (_a = cloudCustomData === null || cloudCustomData === void 0 ? void 0 : cloudCustomData.messageReply) === null || _a === void 0 ? void 0 : _a.messageRootID; return [4 /*yield*/, ((_c = (_b = this === null || this === void 0 ? void 0 : this.currentStore) === null || _b === void 0 ? void 0 : _b.messageList) === null || _c === void 0 ? void 0 : _c.find(function (item) { return (item === null || item === void 0 ? void 0 : item.ID) === messageRootID_2; }))]; case 1: messageRoot = (_g.sent()) || this.findMessage(messageRootID_2); _g.label = 2; case 2: rootCloudCustomData = (messageRoot === null || messageRoot === void 0 ? void 0 : messageRoot.cloudCustomData) ? utils_1.JSONToObject(messageRoot === null || messageRoot === void 0 ? void 0 : messageRoot.cloudCustomData) : { messageReplies: {} }; if ((_d = rootCloudCustomData === null || rootCloudCustomData === void 0 ? void 0 : rootCloudCustomData.messageReplies) === null || _d === void 0 ? void 0 : _d.replies) { index = rootCloudCustomData.messageReplies.replies.findIndex(function (item) { return (item === null || item === void 0 ? void 0 : item.messageID) === (message === null || message === void 0 ? void 0 : message.ID); }); (_f = (_e = rootCloudCustomData === null || rootCloudCustomData === void 0 ? void 0 : rootCloudCustomData.messageReplies) === null || _e === void 0 ? void 0 : _e.replies) === null || _f === void 0 ? void 0 : _f.splice(index, 1); } messageRoot.cloudCustomData = JSON.stringify(rootCloudCustomData); imResponse = this.modifyMessage(messageRoot); resolve(imResponse); return [3 /*break*/, 4]; case 3: error_20 = _g.sent(); reject(error_20); return [3 /*break*/, 4]; case 4: return [2 /*return*/]; } }); }); }); }; var retryBreakFunction = function (error) { if (error && (error === null || error === void 0 ? void 0 : error.code) === 2480) return false; return true; }; return this.handlePromiseCallbackRetry(revokeReplyFunction, [500, 1000, 3000], retryBreakFunction); }; /** * 表情回应 * emoji react * @param {Array.} message 消息实例/message * @returns {Promise} */ TUIChatServer.prototype.emojiReact = function (message, emojiID) { var _this = this; var emojiReactFunction = function () { return _this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var userID, cloudCustomData, index, imResponse, error_21; var _a, _b, _c, _d, _e, _f, _g, _h, _j, _k, _l, _m, _o, _p, _q, _r, _s, _t; return __generator(this, function (_u) { switch (_u.label) { case 0: _u.trys.push([0, 2, , 3]); if (!message || !(message === null || message === void 0 ? void 0 : message.ID) || !emojiID) reject(); userID = (_e = (_d = (_c = (_b = (_a = this.TUICore) === null || _a === void 0 ? void 0 : _a.TUIServer) === null || _b === void 0 ? void 0 : _b.TUIProfile) === null || _c === void 0 ? void 0 : _c.store) === null || _d === void 0 ? void 0 : _d.profile) === null || _e === void 0 ? void 0 : _e.userID; return [4 /*yield*/, ((_g = (_f = this === null || this === void 0 ? void 0 : this.currentStore) === null || _f === void 0 ? void 0 : _f.messageList) === null || _g === void 0 ? void 0 : _g.find(function (item) { return (item === null || item === void 0 ? void 0 : item.ID) === (message === null || message === void 0 ? void 0 : message.ID); }))]; case 1: message = (_u.sent()) || this.findMessage(message === null || message === void 0 ? void 0 : message.ID); cloudCustomData = (message === null || message === void 0 ? void 0 : message.cloudCustomData) ? utils_1.JSONToObject(message === null || message === void 0 ? void 0 : message.cloudCustomData) : { messageReact: {} }; if ((_h = cloudCustomData === null || cloudCustomData === void 0 ? void 0 : cloudCustomData.messageReact) === null || _h === void 0 ? void 0 : _h.reacts) { if ((_j = cloudCustomData === null || cloudCustomData === void 0 ? void 0 : cloudCustomData.messageReact) === null || _j === void 0 ? void 0 : _j.reacts[emojiID]) { index = (_l = (_k = cloudCustomData === null || cloudCustomData === void 0 ? void 0 : cloudCustomData.messageReact) === null || _k === void 0 ? void 0 : _k.reacts[emojiID]) === null || _l === void 0 ? void 0 : _l.indexOf(userID); if (index === -1) { (_o = (_m = cloudCustomData === null || cloudCustomData === void 0 ? void 0 : cloudCustomData.messageReact) === null || _m === void 0 ? void 0 : _m.reacts[emojiID]) === null || _o === void 0 ? void 0 : _o.push(userID); } else { (_q = (_p = cloudCustomData === null || cloudCustomData === void 0 ? void 0 : cloudCustomData.messageReact) === null || _p === void 0 ? void 0 : _p.reacts[emojiID]) === null || _q === void 0 ? void 0 : _q.splice(index, 1); if (((_s = (_r = cloudCustomData === null || cloudCustomData === void 0 ? void 0 : cloudCustomData.messageReact) === null || _r === void 0 ? void 0 : _r.reacts[emojiID]) === null || _s === void 0 ? void 0 : _s.length) === 0) { (_t = cloudCustomData === null || cloudCustomData === void 0 ? void 0 : cloudCustomData.messageReact) === null || _t === void 0 ? true : delete _t.reacts[emojiID]; } } } else { cloudCustomData.messageReact.reacts[emojiID] = [userID]; } } else { cloudCustomData.messageReact = { reacts: {}, version: 1 }; cloudCustomData.messageReact.reacts[emojiID] = [userID]; } message.cloudCustomData = JSON.stringify(cloudCustomData); imResponse = this.modifyMessage(message); resolve(imResponse); return [3 /*break*/, 3]; case 2: error_21 = _u.sent(); reject(error_21); return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); }); }; var retryBreakFunction = function (error) { if (error && (error === null || error === void 0 ? void 0 : error.code) === 2480) return false; return true; }; return this.handlePromiseCallbackRetry(emojiReactFunction, [500, 1000, 3000], retryBreakFunction); }; /** * 查询消息 * find message * @param {String} messageID 消息实例ID/messageID * @returns {Promise} */ TUIChatServer.prototype.findMessage = function (messageID) { var _this = this; return this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var imResponse, error_22; return __generator(this, function (_a) { switch (_a.label) { case 0: _a.trys.push([0, 2, , 3]); return [4 /*yield*/, this.TUICore.tim.findMessage(messageID)]; case 1: imResponse = _a.sent(); resolve(imResponse); return [3 /*break*/, 3]; case 2: error_22 = _a.sent(); reject(error_22); return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); }); }; /** * 获取群组属性 * get group profile * * @param {any} options 参数 * @param {String} options.groupID 群组ID * @param {Array.} options.groupProfileFilter 群资料过滤器 * @returns {Promise} */ TUIChatServer.prototype.getGroupProfile = function (options) { var _this = this; return this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var imResponse, error_23; return __generator(this, function (_a) { switch (_a.label) { case 0: _a.trys.push([0, 2, , 3]); return [4 /*yield*/, this.TUICore.tim.getGroupProfile(options)]; case 1: imResponse = _a.sent(); this.currentStore.conversation.groupProfile = imResponse.data.group; resolve(imResponse); return [3 /*break*/, 3]; case 2: error_23 = _a.sent(); reject(error_23); return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); }); }; /** * 获取群成员资料 * get group member profile * * @param {any} options 参数 * @param {String} options.groupID 群组ID * @param {Array.} options.userIDList 要查询的群成员用户 ID 列表 * @param { Array.} options.memberCustomFieldFilter 群成员自定义字段筛选 * @returns {Promise} */ TUIChatServer.prototype.getGroupMemberProfile = function (options) { var _this = this; return this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var imResponse, error_24; return __generator(this, function (_a) { switch (_a.label) { case 0: _a.trys.push([0, 2, , 3]); return [4 /*yield*/, this.TUICore.tim.getGroupMemberProfile(options)]; case 1: imResponse = _a.sent(); resolve(imResponse); return [3 /*break*/, 3]; case 2: error_24 = _a.sent(); reject(error_24); return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); }); }; /** * 处理申请加群 * handling group application * - 管理员 * administrator * * @param {any} options 参数 * @param {String} options.handleAction 处理结果 Agree(同意) / Reject(拒绝) * @param {String} options.handleMessage 附言 * @param {Message} options.message 对应【群系统通知】的消息实例 * @returns {Promise} */ TUIChatServer.prototype.handleGroupApplication = function (options) { var _this = this; return this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var imResponse, error_25; return __generator(this, function (_a) { switch (_a.label) { case 0: _a.trys.push([0, 2, , 3]); return [4 /*yield*/, this.TUICore.tim.handleGroupApplication(options)]; case 1: imResponse = _a.sent(); resolve(imResponse); return [3 /*break*/, 3]; case 2: error_25 = _a.sent(); reject(error_25); return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); }); }; /** * 获取其他用户资料 * get user profile * * @param {Array} userIDList 用户的账号列表/userID list * @returns {Promise} */ TUIChatServer.prototype.getUserProfile = function (userIDList) { return __awaiter(this, void 0, void 0, function () { var _this = this; return __generator(this, function (_a) { return [2 /*return*/, this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var imResponse, error_26; return __generator(this, function (_a) { switch (_a.label) { case 0: _a.trys.push([0, 2, , 3]); return [4 /*yield*/, this.TUICore.tim.getUserProfile({ userIDList: userIDList })]; case 1: imResponse = _a.sent(); resolve(imResponse); return [3 /*break*/, 3]; case 2: error_26 = _a.sent(); reject(error_26); return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); })]; }); }); }; /** * 获取 SDK 缓存的好友列表 * Get the friend list cached by the SDK * * @param {Array} userIDList 用户的账号列表 * @returns {Promise} */ TUIChatServer.prototype.getFriendList = function () { return __awaiter(this, void 0, Promise, function () { var _this = this; return __generator(this, function (_a) { return [2 /*return*/, this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var imResponse, error_27; return __generator(this, function (_a) { switch (_a.label) { case 0: _a.trys.push([0, 2, , 3]); return [4 /*yield*/, this.TUICore.tim.getFriendList()]; case 1: imResponse = _a.sent(); resolve(imResponse); return [3 /*break*/, 3]; case 2: error_27 = _a.sent(); reject(error_27); return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); })]; }); }); }; /** * 校验好友关系 * check friend * * @param {string} userID 用户账号 * @returns {Promise} */ TUIChatServer.prototype.checkFriend = function (userID, type) { return __awaiter(this, void 0, Promise, function () { var _this = this; return __generator(this, function (_a) { return [2 /*return*/, this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var imResponse, isFriendShip, error_28; var _a, _b; return __generator(this, function (_c) { switch (_c.label) { case 0: _c.trys.push([0, 2, , 3]); return [4 /*yield*/, this.TUICore.tim.checkFriend({ userIDList: [userID], type: type })]; case 1: imResponse = _c.sent(); isFriendShip = (_b = (_a = imResponse === null || imResponse === void 0 ? void 0 : imResponse.data) === null || _a === void 0 ? void 0 : _a.successUserIDList[0]) === null || _b === void 0 ? void 0 : _b.relation; resolve(isFriendShip); return [3 /*break*/, 3]; case 2: error_28 = _c.sent(); reject(error_28); return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); })]; }); }); }; /** * 获取群消息已读成员列表 * Get the list of memebers who have read the group message. * * @param {message} message 消息实例/message * @param {string} cursor 分页拉取的游标，第一次拉取传''/Paging pull the cursor,first pull pass '' * @param {number} count 分页拉取的个数/The number of page pulls * @returns {Promise} */ TUIChatServer.prototype.getGroupReadMemberList = function (message, cursor, count) { if (cursor === void 0) { cursor = ""; } if (count === void 0) { count = 15; } return __awaiter(this, void 0, Promise, function () { var _this = this; return __generator(this, function (_a) { return [2 /*return*/, this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var imResponse, error_29; return __generator(this, function (_a) { switch (_a.label) { case 0: _a.trys.push([0, 2, , 3]); return [4 /*yield*/, this.TUICore.tim.getGroupMessageReadMemberList({ message: message, filter: 0, cursor: cursor, count: count })]; case 1: imResponse = _a.sent(); resolve(imResponse); return [3 /*break*/, 3]; case 2: error_29 = _a.sent(); reject(error_29); return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); })]; }); }); }; /** * 获取群消息未读成员列表 * Get the list of memebers who have not read the group message. * * @param {message} message 消息实例/message * @param {string} cursor 分页拉取的游标，第一次拉取传''/Paging pull the cursor,first pull pass '' * @param {number} count 分页拉取的个数/The number of page pulls * @returns {Promise} */ TUIChatServer.prototype.getGroupUnreadMemberList = function (message, cursor, count) { if (cursor === void 0) { cursor = ""; } if (count === void 0) { count = 15; } return __awaiter(this, void 0, Promise, function () { var _this = this; return __generator(this, function (_a) { return [2 /*return*/, this.handlePromiseCallback(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () { var imResponse, error_30; return __generator(this, function (_a) { switch (_a.label) { case 0: _a.trys.push([0, 2, , 3]); return [4 /*yield*/, this.TUICore.tim.getGroupMessageReadMemberList({ message: message, filter: 1, cursor: cursor, count: count })]; case 1: imResponse = _a.sent(); resolve(imResponse); return [3 /*break*/, 3]; case 2: error_30 = _a.sent(); reject(error_30); return [3 /*break*/, 3]; case 3: return [2 /*return*/]; } }); }); })]; }); }); }; /** * 自己发送消息上屏显示 * * @param {message} message 消息实例/message */ TUIChatServer.prototype.handleMessageSentByMeToView = function (message) { var _a, _b; return __awaiter(this, void 0, void 0, function () { return __generator(this, function (_c) { if ((message === null || message === void 0 ? void 0 : message.conversationID) === ((_b = (_a = this === null || this === void 0 ? void 0 : this.store) === null || _a === void 0 ? void 0 : _a.conversation) === null || _b === void 0 ? void 0 : _b.conversationID)) { this.currentStore.messageList.push(message); } return [2 /*return*/]; }); }); }; /** * ///////////////////////////////////////////////////////////////////////////////// * // * // UI 数据绑定server数据同步 * // UI data binding server data synchronization * // * ///////////////////////////////////////////////////////////////////////////////// */ /** * 赋值 * bind * * @param {Object} params 使用的数据/params * @returns {Object} 数据/data */ TUIChatServer.prototype.bind = function (params) { return (this.currentStore = params); }; return TUIChatServer; }(IComponentServer_1["default"])); exports["default"] = TUIChatServer;