File manager

File manager - Edit - /home/c14075/dragmet-ural.ru/www/bitrix/js/im/v2/provider/pull/dist/registry.bundle.js

Back
this.BX = this.BX \|\| {}; this.BX.Messenger = this.BX.Messenger \|\| {}; this.BX.Messenger.v2 = this.BX.Messenger.v2 \|\| {}; this.BX.Messenger.v2.Provider = this.BX.Messenger.v2.Provider \|\| {}; (function (exports,pull_client,ui_vue3_vuex,main_core,main_core_events,im_v2_lib_logger,im_v2_const) { 'use strict'; class ImBasePullHandler { static create(params = {}) { return new this(params); } constructor(params = {}) { if (typeof params.controller === 'object' && params.controller) { this.controller = params.controller; } if (typeof params.store === 'object' && params.store) { this.store = params.store; } this.option = typeof params.store === 'object' && params.store ? params.store : {}; if (!(typeof this.option.handlingDialog === 'object' && this.option.handlingDialog && this.option.handlingDialog.chatId && this.option.handlingDialog.dialogId)) { this.option.handlingDialog = false; } } getModuleId() { return 'im'; } getSubscriptionType() { return pull_client.PullClient.SubscriptionType.Server; } skipExecute(params, extra = {}) { if (!extra.optionImportant) { if (this.option.skip) { im_v2_lib_logger.Logger.info('Pull: command skipped while loading messages', params); return true; } if (!this.option.handlingDialog) { return false; } } if (typeof params.chatId !== 'undefined' \|\| typeof params.dialogId !== 'undefined') { if (typeof params.chatId !== 'undefined' && parseInt(params.chatId) === parseInt(this.option.handlingDialog.chatId)) { return false; } if (typeof params.dialogId !== 'undefined' && params.dialogId.toString() === this.option.handlingDialog.dialogId.toString()) { return false; } return true; } return false; } handleMessage(params, extra) { this.handleMessageAdd(params, extra); } handleMessageChat(params, extra) { this.handleMessageAdd(params, extra); } handleMessageAdd(params, extra) { im_v2_lib_logger.Logger.warn('handleMessageAdd', params); if (this.skipExecute(params, extra)) { return false; } if (params.lines) { return false; } let collection = this.store.state.messages.collection[params.chatId]; if (!collection) { collection = []; } //search for message with message id from params const message = collection.find(element => { if (params.message.templateId && element.id === params.message.templateId) { return true; } return element.id === params.message.id; }); //stop if it's message with 'push' (pseudo push message in mobile) if (message && params.message.push) { return false; } if (params.chat && params.chat[params.chatId]) { const existingChat = this.store.getters['dialogues/getByChatId'](params.chatId); if (!existingChat) { const chatToAdd = { ...params.chat[params.chatId], dialogId: params.dialogId }; this.store.dispatch('dialogues/set', chatToAdd); } else { this.store.dispatch('dialogues/update', { dialogId: params.dialogId, fields: params.chat[params.chatId] }); } } //set users if (params.users) { const { users, dialogues } = this.prepareUsersForModels(params.users); this.store.dispatch('dialogues/set', dialogues); this.store.dispatch('users/set', users); } //set files if (params.files) { const files = ui_vue3_vuex.BuilderModel.convertToArray(params.files); files.forEach(file => { if (files.length === 1 && params.message.templateFileId && this.store.state.files.index[params.chatId] && this.store.state.files.index[params.chatId][params.message.templateFileId]) { this.store.dispatch('files/update', { id: params.message.templateFileId, chatId: params.chatId, fields: file }).then(() => { main_core_events.EventEmitter.emit(im_v2_const.EventType.dialog.scrollToBottom, { chatId: params.chatId, cancelIfScrollChange: true }); }); } else { this.store.dispatch('files/set', file); } }); } //if we already have message - update it and scrollToBottom if (message) { im_v2_lib_logger.Logger.warn('New message pull handler: we already have this message', params.message); this.store.dispatch('messages/update', { id: message.id, chatId: message.chatId, fields: { ...params.message, sending: false, error: false } }).then(() => { if (!params.message.push) { main_core_events.EventEmitter.emit(im_v2_const.EventType.dialog.scrollToBottom, { chatId: message.chatId, cancelIfScrollChange: params.message.senderId !== this.controller.getUserId() }); } }); } //if we dont have message and we have all pages - add new message and send newMessage event (handles scroll stuff) //we dont do anything if we dont have message and there are unloaded messages else if (this.store.getters['dialogues/areUnreadMessagesLoaded'](params.dialogId)) { im_v2_lib_logger.Logger.warn('New message pull handler: we dont have this message', params.message); this.store.dispatch('messages/setAfter', { ...params.message, unread: true }).then(() => { if (!params.message.push) { main_core_events.EventEmitter.emit(im_v2_const.EventType.dialog.newMessage, { chatId: params.message.chatId, messageId: params.message.id }); } }); } //stop writing event this.store.dispatch('dialogues/stopWriting', { dialogId: params.dialogId, userId: params.message.senderId }); //if we sent message - read all messages on server and client, set counter to 0 if (params.message.senderId === this.controller.getUserId()) { if (this.store.state.dialogues.collection[params.dialogId] && this.store.state.dialogues.collection[params.dialogId].counter !== 0) { this.controller.restClient.callMethod('im.dialog.read', { dialog_id: params.dialogId }).then(() => { this.store.dispatch('messages/readMessages', { chatId: params.chatId }).then(result => { main_core_events.EventEmitter.emit(im_v2_const.EventType.dialog.scrollToBottom, { chatId: params.chatId, cancelIfScrollChange: false }); this.store.dispatch('dialogues/update', { dialogId: params.dialogId, fields: { counter: 0 } }); }); }); } } //increase the counter if message is not ours else if (params.message.senderId !== this.controller.getUserId()) { this.store.dispatch('dialogues/update', { dialogId: params.dialogId, fields: { counter: params.counter } }); } //set new lastMessageId (used for pagination) this.store.dispatch('dialogues/update', { dialogId: params.dialogId, fields: { lastMessageId: params.message.id } }); //increase total message count this.store.dispatch('dialogues/increaseMessageCounter', { dialogId: params.dialogId, count: 1 }); } handleMessageUpdate(params, extra, command) { this.execMessageUpdateOrDelete(params, extra, command); } handleMessageDelete(params, extra, command) { this.execMessageUpdateOrDelete(params, extra, command); } execMessageUpdateOrDelete(params, extra, command) { if (this.skipExecute(params, extra)) { return false; } this.store.dispatch('dialogues/stopWriting', { dialogId: params.dialogId, userId: params.senderId }); this.store.dispatch('messages/update', { id: params.id, chatId: params.chatId, fields: { text: command === "messageUpdate" ? params.text : '', textOriginal: command === "messageUpdate" ? params.textOriginal : '', params: params.params, blink: true } }).then(() => { main_core_events.EventEmitter.emit(im_v2_const.EventType.dialog.scrollToBottom, { chatId: params.chatId, cancelIfScrollChange: true }); }); } handleMessageDeleteComplete(params, extra) { if (this.skipExecute(params, extra)) { return false; } this.store.dispatch('messages/delete', { id: params.id, chatId: params.chatId }); this.store.dispatch('dialogues/stopWriting', { dialogId: params.dialogId, userId: params.senderId }); } handleMessageLike(params, extra) { if (this.skipExecute(params, extra)) { return false; } this.store.dispatch('messages/update', { id: params.id, chatId: params.chatId, fields: { params: { LIKE: params.users } } }); } handleChatOwner(params, extra) { if (this.skipExecute(params, extra)) { return false; } this.store.dispatch('dialogues/update', { dialogId: params.dialogId, fields: { ownerId: params.userId } }); } handleChatManagers(params, extra) { if (this.skipExecute(params, extra)) { return false; } this.store.dispatch('dialogues/update', { dialogId: params.dialogId, fields: { managerList: params.list } }); } handleChatUpdateParams(params, extra) { if (this.skipExecute(params, extra)) { return false; } this.store.dispatch('dialogues/update', { dialogId: params.dialogId, fields: params.params }); } handleChatUserAdd(params, extra) { if (this.skipExecute(params, extra)) { return false; } if (params.users) { const { users, dialogues } = this.prepareUsersForModels(params.users); this.store.dispatch('dialogues/set', dialogues); this.store.dispatch('users/set', users); } this.store.dispatch('dialogues/update', { dialogId: params.dialogId, fields: { userCounter: params.userCount } }); } handleChatUserLeave(params, extra) { this.handleChatUserAdd(params, extra); } handleMessageParamsUpdate(params, extra) { if (this.skipExecute(params, extra)) { return false; } this.store.dispatch('messages/update', { id: params.id, chatId: params.chatId, fields: { params: params.params } }).then(() => { main_core_events.EventEmitter.emit(im_v2_const.EventType.dialog.scrollToBottom, { chatId: params.chatId, cancelIfScrollChange: true }); }); } handleStartWriting(params, extra) { if (this.skipExecute(params, extra)) { return false; } const { dialogId, userId, userName } = params; this.store.dispatch('dialogues/startWriting', { dialogId, userId, userName }); } handleReadMessage(params, extra) { if (this.skipExecute(params, extra)) { return false; } this.store.dispatch('messages/readMessages', { chatId: params.chatId, readId: params.lastId }).then(() => { this.store.dispatch('dialogues/update', { dialogId: params.dialogId, fields: { counter: params.counter } }); }); } handleReadMessageChat(params, extra) { this.handleReadMessage(params, extra); } handleReadMessageOpponent(params, extra) { this.execReadMessageOpponent(params, extra); } handleReadMessageChatOpponent(params, extra) { this.execReadMessageOpponent(params, extra); } execReadMessageOpponent(params, extra) { if (this.skipExecute(params, extra)) { return false; } this.store.dispatch('dialogues/addToReadList', { dialogId: params.dialogId, userId: params.userId, userName: params.userName, messageId: params.lastId, date: params.date }); } handleUnreadMessage(params, extra) { if (this.skipExecute(params, extra)) { return false; } this.store.dispatch('dialogues/update', { dialogId: params.dialogId, fields: { counter: params.counter } }); } handleUnreadMessageChat(params, extra) { this.handleUnreadMessage(params, extra); } handleUnreadMessageOpponent(params, extra) { this.execUnreadMessageOpponent(params, extra); } handleUnreadMessageChatOpponent(params, extra) { this.execUnreadMessageOpponent(params, extra); } execUnreadMessageOpponent(params, extra) { if (this.skipExecute(params, extra)) { return false; } this.store.dispatch('dialogues/removeFromReadList', { dialogId: params.dialogId, userId: params.userId }); } handleFileUpload(params, extra) { if (this.skipExecute(params, extra)) { return false; } this.store.dispatch('files/set', ui_vue3_vuex.BuilderModel.convertToArray({ file: params.fileParams })).then(() => { main_core_events.EventEmitter.emit(im_v2_const.EventType.dialog.scrollToBottom, { cancelIfScrollChange: true }); }); } handleChatMuteNotify(params) { if (params.muted) { this.store.dispatch('dialogues/mute', { dialogId: params.dialogId }); return true; } this.store.dispatch('dialogues/unmute', { dialogId: params.dialogId }); } handleUserInvite(params) { if (!params.invited) { this.store.dispatch('users/update', { id: params.userId, fields: params.user }); } } handleChatRename(params) { const dialog = this.store.getters['dialogues/getByChatId'](params.chatId); if (!dialog) { return false; } this.store.dispatch('dialogues/update', { dialogId: dialog.dialogId, fields: { name: params.name } }); } handleChatAvatar(params) { const dialog = this.store.getters['dialogues/getByChatId'](params.chatId); if (!dialog) { return false; } this.store.dispatch('dialogues/update', { dialogId: dialog.dialogId, fields: { avatar: params.avatar } }); } prepareUsersForModels(users) { const userDialogues = ui_vue3_vuex.BuilderModel.convertToArray(users).map(user => { return { dialogId: user.id, avatar: user.avatar, color: user.color, name: user.name, type: im_v2_const.ChatTypes.user }; }); return { users: ui_vue3_vuex.BuilderModel.convertToArray(users), dialogues: userDialogues }; } } class RecentPullHandler { static create(params = {}) { return new this(params); } getModuleId() { return 'im'; } constructor(params) { this.controller = params.controller; this.store = params.store; this.application = params.application; } handleMessage(params) { this.handleMessageAdd(params); } handleMessageChat(params) { this.handleMessageAdd(params); } handleMessageAdd(params) { if (params.lines) { return false; } const currentUserId = this.store.state.application.common.userId; if (currentUserId && params.userInChat[params.chatId] && !params.userInChat[params.chatId].includes(currentUserId)) { return false; } im_v2_lib_logger.Logger.warn('RecentPullHandler: handleMessageAdd', params); const newRecentItem = { id: params.dialogId, message: { id: params.message.id, text: params.message.textOriginal, date: params.message.date, senderId: params.message.senderId, withFile: !main_core.Type.isUndefined(params.message.params['FILE_ID']), withAttach: !main_core.Type.isUndefined(params.message.params['ATTACH']) } }; const recentItem = this.store.getters['recent/get'](params.dialogId); if (recentItem) { newRecentItem.options = { birthdayPlaceholder: false }; this.store.dispatch('recent/like', { id: params.dialogId, liked: false }); } const { senderId } = params.message; const usersModel = this.store.state.users; if (usersModel != null && usersModel.botList[senderId] && usersModel.botList[senderId].type === 'human') { const { text } = params.message; setTimeout(() => { this.store.dispatch('recent/set', newRecentItem); }, this.getWaitTimeForHumanBot(text)); return; } this.store.dispatch('recent/set', newRecentItem); } handleMessageUpdate(params, extra, command) { const recentItem = this.store.getters['recent/get'](params.dialogId); if (!recentItem \|\| recentItem.message.id !== params.id) { return false; } im_v2_lib_logger.Logger.warn('RecentPullHandler: handleMessageUpdate', params, command); let text = params.textOriginal; if (command === 'messageDelete') { text = main_core.Loc.getMessage('IM_PULL_RECENT_MESSAGE_DELETED'); } this.store.dispatch('recent/update', { id: params.dialogId, fields: { message: { id: params.id, text: text, date: recentItem.message.date, status: recentItem.message.status, senderId: params.senderId } } }); } handleMessageDelete(params, extra, command) { this.handleMessageUpdate(params, extra, command); } handleReadMessageOpponent(params) { im_v2_lib_logger.Logger.warn('RecentPullHandler: handleReadMessageOpponent', params); const recentItem = this.store.getters['recent/get'](params.dialogId); const lastReadMessage = Number.parseInt(params.lastId, 10); if (!recentItem \|\| recentItem.message.id !== lastReadMessage) { return false; } this.store.dispatch('recent/update', { id: params.dialogId, fields: { message: { ...recentItem.message, status: im_v2_const.MessageStatus.delivered } } }); } handleReadMessageChatOpponent(params) { this.handleReadMessageOpponent(params); } handleUnreadMessageOpponent(params) { im_v2_lib_logger.Logger.warn('RecentPullHandler: handleUnreadMessageOpponent', params); const recentItem = this.store.getters['recent/get'](params.dialogId); if (!recentItem) { return false; } this.store.dispatch('recent/update', { id: params.dialogId, fields: { message: { ...recentItem.message, status: im_v2_const.MessageStatus.received } } }); } handleMessageLike(params) { im_v2_lib_logger.Logger.warn('RecentPullHandler: handleMessageLike', params); const recentItem = this.store.getters['recent/get'](params.dialogId); if (!recentItem) { return false; } const currentDialogId = BX.MessengerProxy.getCurrentDialogId(); // TODO: change to Core variable if (currentDialogId === params.dialogId) { return false; } const currentUserId = this.store.state.application.common.userId; const isOwnLike = currentUserId === params.senderId; const isOwnLastMessage = recentItem.message.senderId === currentUserId; if (isOwnLike \|\| !isOwnLastMessage) { return false; } this.store.dispatch('recent/like', { id: params.dialogId, messageId: params.id, liked: params.set }); } handleChatPin(params) { im_v2_lib_logger.Logger.warn('RecentPullHandler: handleChatPin', params); const recentItem = this.store.getters['recent/get'](params.dialogId); if (!recentItem) { return false; } this.store.dispatch('recent/pin', { id: params.dialogId, action: params.active }); } handleChatUnread(params) { im_v2_lib_logger.Logger.warn('RecentPullHandler: handleChatUnread', params); const recentItem = this.store.getters['recent/get'](params.dialogId); if (!recentItem) { return false; } this.store.dispatch('recent/unread', { id: params.dialogId, action: params.active }); } handleChatHide(params) { im_v2_lib_logger.Logger.warn('RecentPullHandler: handleChatHide', params); const recentItem = this.store.getters['recent/get'](params.dialogId); if (!recentItem) { return false; } this.store.dispatch('recent/delete', { id: params.dialogId }); } handleChatUserLeave(params) { im_v2_lib_logger.Logger.warn('RecentPullHandler: handleChatUserLeave', params); const recentItem = this.store.getters['recent/get'](params.dialogId); if (!recentItem) { return false; } const currentUserId = this.store.state.application.common.userId; if (currentUserId !== params.userId) { return false; } this.store.dispatch('recent/delete', { id: params.dialogId }); } handleUserInvite(params) { var _params$invited; im_v2_lib_logger.Logger.warn('RecentPullHandler: handleUserInvite', params); this.store.dispatch('recent/set', { id: params.user.id, invited: (_params$invited = params.invited) != null ? _params$invited : false }); this.store.dispatch('users/set', params.user); this.store.dispatch('dialogues/set', { dialogId: params.user.id, title: params.user.name, type: im_v2_const.ChatTypes.user, avatar: params.user.avatar, color: params.user.color }); } parseUserMention(text) { const hasUserMention = /\[user=(\d+)]\[\/user]/gi.exec(text); if (!hasUserMention) { return; } const userId = hasUserMention[1]; console.warn('FOUND USER MENTION', userId); const user = this.store.getters['users/get'](userId); if (!user) { console.warn('NO SUCH USER, NEED REQUEST FOR -', userId); main_core_events.EventEmitter.emit(im_v2_const.EventType.recent.requestUser, { userId }); } } getWaitTimeForHumanBot(text) { const INITIAL_WAIT = 1000; const WAIT_PER_WORD = 300; const WAIT_LIMIT = 5000; let waitTime = text.split(' ').length * WAIT_PER_WORD + INITIAL_WAIT; if (waitTime > WAIT_LIMIT) { waitTime = WAIT_LIMIT; } return waitTime; } } exports.ImBasePullHandler = ImBasePullHandler; exports.RecentPullHandler = RecentPullHandler; }((this.BX.Messenger.v2.Provider.Pull = this.BX.Messenger.v2.Provider.Pull \|\| {}),BX,BX.Vue3.Vuex,BX,BX.Event,BX.Messenger.v2.Lib,BX.Messenger.v2.Const)); //# sourceMappingURL=registry.bundle.js.map

| ver. 1.4 | Github | . | PHP 7.4.33 | Generation time: 0.25 | proxy | phpinfo | Settings