import { horizontalMenu, putPreloader, renderImageFromUrl } from "../../components/misc"; //import Scrollable from '../../components/scrollable'; import Scrollable from '../../components/scrollable_new'; import { $rootScope } from "../utils"; import appMessagesManager from "./appMessagesManager"; import appPhotosManager from "./appPhotosManager"; import appPeersManager from "./appPeersManager"; import appUsersManager from "./appUsersManager"; import appProfileManager from "./appProfileManager"; import { RichTextProcessor } from "../richtextprocessor"; import { logger } from "../polyfill"; import appImManager from "./appImManager"; import appMediaViewer from "./appMediaViewer"; import LazyLoadQueue from "../../components/lazyLoadQueue"; import { wrapDocument, wrapAudio } from "../../components/wrappers"; import AppSearch, { SearchGroup } from "../../components/appSearch"; import AvatarElement from "../../components/avatar"; const testScroll = false; let setText = (text: string, el: HTMLDivElement) => { window.requestAnimationFrame(() => { if(el.childElementCount > 1) { el.firstElementChild.remove(); } let p = document.createElement('p'); p.innerHTML = text; el.prepend(p); el.style.display = ''; }); }; class AppSidebarRight { public sidebarEl = document.getElementById('column-right') as HTMLDivElement; public profileContainer = this.sidebarEl.querySelector('.profile-container') as HTMLDivElement; public profileContentEl = this.sidebarEl.querySelector('.profile-content') as HTMLDivElement; public contentContainer = this.sidebarEl.querySelector('.content-container') as HTMLDivElement; public profileElements = { avatar: this.profileContentEl.querySelector('.profile-avatar') as AvatarElement, name: this.profileContentEl.querySelector('.profile-name') as HTMLDivElement, subtitle: this.profileContentEl.querySelector('.profile-subtitle') as HTMLDivElement, bio: this.profileContentEl.querySelector('.profile-row-bio') as HTMLDivElement, username: this.profileContentEl.querySelector('.profile-row-username') as HTMLDivElement, phone: this.profileContentEl.querySelector('.profile-row-phone') as HTMLDivElement, notificationsRow: this.profileContentEl.querySelector('.profile-row-notifications') as HTMLDivElement, notificationsCheckbox: this.profileContentEl.querySelector('#profile-notifications') as HTMLInputElement, notificationsStatus: this.profileContentEl.querySelector('.profile-row-notifications > p') as HTMLParagraphElement }; public sharedMedia: { [type: string]: HTMLDivElement } = { contentMembers: this.profileContentEl.querySelector('#content-members') as HTMLDivElement, contentMedia: this.profileContentEl.querySelector('#content-media') as HTMLDivElement, contentDocuments: this.profileContentEl.querySelector('#content-docs') as HTMLDivElement, contentLinks: this.profileContentEl.querySelector('#content-links') as HTMLDivElement, contentAudio: this.profileContentEl.querySelector('#content-audio') as HTMLDivElement, }; private loadSidebarMediaPromises: {[type: string]: Promise} = {}; private loadedAllMedia: {[type: string]: boolean} = {}; public sharedMediaTypes = [ 'members', //'inputMessagesFilterContacts', 'inputMessagesFilterPhotoVideo', 'inputMessagesFilterDocument', 'inputMessagesFilterUrl', 'inputMessagesFilterMusic' ]; public sharedMediaType: AppSidebarRight['sharedMediaTypes'][number] = ''; private sharedMediaSelected: HTMLDivElement = null; private lazyLoadQueue = new LazyLoadQueue(5); public historiesStorage: { [peerID: number]: { [type: string]: number[] } } = {}; public usedFromHistory: { [type: string]: number } = {}; private log = logger('SR'); private peerID = 0; public scroll: Scrollable = null; private profileTabs: HTMLUListElement; private prevTabID = -1; private mediaDivsByIDs: { [mid: number]: HTMLDivElement } = {}; public urlsToRevoke: string[] = []; private searchContainer = this.sidebarEl.querySelector('#search-private-container') as HTMLDivElement; public searchCloseBtn = this.searchContainer.querySelector('.sidebar-close-button') as HTMLButtonElement; private searchInput = document.getElementById('private-search') as HTMLInputElement; public privateSearch = new AppSearch(this.searchContainer.querySelector('.chats-container') as HTMLDivElement, this.searchInput, { messages: new SearchGroup('Private Search', 'messages') }); private loadMutex: Promise = Promise.resolve(); constructor() { let container = this.profileContentEl.querySelector('.content-container .tabs-container') as HTMLDivElement; this.profileTabs = this.profileContentEl.querySelector('.profile-tabs') as HTMLUListElement; this.scroll = new Scrollable(this.profileContainer, 'y', 'SR', undefined, 400); this.scroll.onScrolledBottom = () => { if(this.sharedMediaSelected && this.sharedMediaSelected.childElementCount/* && false */) { this.log('onScrolledBottom will load media'); this.loadSidebarMedia(true); } }; //this.scroll.attachSentinels(undefined, 400); horizontalMenu(this.profileTabs, container, (id, tabContent) => { if(this.prevTabID == id) return; this.sharedMediaType = this.sharedMediaTypes[id]; this.sharedMediaSelected = tabContent.firstElementChild as HTMLDivElement; if(this.prevTabID != -1 && this.profileTabs.offsetTop) { this.scroll.scrollTop -= this.profileTabs.offsetTop; } /* this.log('setVirtualContainer', id, this.sharedMediaSelected, this.sharedMediaSelected.childElementCount); this.scroll.setVirtualContainer(this.sharedMediaSelected); */ if(this.prevTabID != -1 && !this.sharedMediaSelected.childElementCount) { // quick brown fix //this.contentContainer.classList.remove('loaded'); this.loadSidebarMedia(true); } this.prevTabID = id; }); let sidebarCloseBtn = this.sidebarEl.querySelector('.sidebar-close-button') as HTMLButtonElement; sidebarCloseBtn.addEventListener('click', () => { this.toggleSidebar(false); }); this.searchCloseBtn.addEventListener('click', () => { this.searchContainer.classList.remove('active'); this.privateSearch.reset(); }); this.sharedMedia.contentMedia.addEventListener('click', (e) => { let target = e.target as HTMLDivElement; let messageID = +target.dataset.mid; if(!messageID) { this.log.warn('no messageID by click on target:', target); return; } let message = appMessagesManager.getMessage(messageID); let ids = Object.keys(this.mediaDivsByIDs).map(k => +k).sort((a, b) => a - b); let idx = ids.findIndex(i => i == messageID); let targets = ids.map(id => ({element: this.mediaDivsByIDs[id].firstElementChild as HTMLElement, mid: id})); appMediaViewer.openMedia(message, target, false, this.sidebarEl, targets.slice(idx + 1).reverse(), targets.slice(0, idx).reverse(), true); }); this.profileElements.notificationsCheckbox.addEventListener('change', () => { //let checked = this.profileElements.notificationsCheckbox.checked; appImManager.mutePeer(this.peerID); }); if(testScroll) { let div = document.createElement('div'); for(let i = 0; i < 500; ++i) { //div.insertAdjacentHTML('beforeend', `
`); div.insertAdjacentHTML('beforeend', `
${i / 3 | 0}
`); if((i + 1) % 3 == 0) { this.sharedMedia.contentMedia.append(div); div = document.createElement('div'); } div.dataset.id = '' + (i / 3 | 0); } this.sharedMedia.contentMedia.append(div); (this.profileTabs.children[1] as HTMLLIElement).click(); // set media } } public beginSearch() { this.toggleSidebar(true); this.searchContainer.classList.add('active'); this.privateSearch.beginSearch(this.peerID); } public toggleSidebar(enable?: boolean) { /////this.log('sidebarEl', this.sidebarEl, enable, isElementInViewport(this.sidebarEl)); let active = this.sidebarEl.classList.contains('active'); let willChange: boolean; if(enable !== undefined) { if(enable) { if(!active) { willChange = true; } } else if(active) { willChange = true; } } else { willChange = true; } if(!willChange) return Promise.resolve(); let set = () => { if(enable !== undefined) { if(enable) this.sidebarEl.classList.add('active'); else this.sidebarEl.classList.remove('active'); } else { this.sidebarEl.classList.toggle('active'); } }; return new Promise((resolve, reject) => { let hidden: {element: HTMLDivElement, height: number}[] = []; let observer = new IntersectionObserver((entries) => { for(let entry of entries) { let bubble = entry.target as HTMLDivElement; if(!entry.isIntersecting) { hidden.push({element: bubble, height: bubble.scrollHeight}); } } for(let item of hidden) { item.element.style.minHeight = item.height + 'px'; (item.element.firstElementChild as HTMLElement).style.display = 'none'; item.element.style.width = '1px'; } //console.log('hidden', hidden); observer.disconnect(); set(); setTimeout(() => { for(let item of hidden) { item.element.style.minHeight = ''; item.element.style.width = ''; (item.element.firstElementChild as HTMLElement).style.display = ''; } resolve(); }, 200); }); let length = Object.keys(appImManager.bubbles).length; if(length) { for(let i in appImManager.bubbles) { observer.observe(appImManager.bubbles[i]); } } else { set(); setTimeout(resolve, 200); } }); } public filterMessagesByType(ids: number[], type: string) { let messages: any[] = []; for(let mid of ids) { let message = appMessagesManager.getMessage(mid); if(message.media) messages.push(message); } let filtered: any[] = []; switch(type) { case 'inputMessagesFilterPhotoVideo': { for(let message of messages) { let media = message.media.photo || message.media.document || (message.media.webpage && message.media.webpage.document); if(!media) { //this.log('no media!', message); continue; } if(media._ == 'document' && media.type != 'video'/* && media.type != 'gif' */) { //this.log('broken video', media); continue; } filtered.push(message); } break; } case 'inputMessagesFilterDocument': { for(let message of messages) { if(!message.media.document || message.media.document.type == 'voice' || message.media.document.type == 'audio') { continue; } let doc = message.media.document; if(doc.attributes) { if(doc.attributes.find((a: any) => a._ == "documentAttributeSticker")) { continue; } } filtered.push(message); } break; } case 'inputMessagesFilterUrl': { for(let message of messages) { if(!message.media.webpage || message.media.webpage._ == 'webPageEmpty') { continue; } filtered.push(message); } break; } case 'inputMessagesFilterMusic': { for(let message of messages) { if(!message.media.document || message.media.document.type != 'audio') { continue; } filtered.push(message); } break; } default: break; } return filtered; } public async performSearchResult(messages: any[], type: string) { let peerID = this.peerID; let sharedMediaDiv: HTMLDivElement; let elemsToAppend: HTMLElement[] = []; let promises: Promise[] = []; // https://core.telegram.org/type/MessagesFilter switch(type) { case 'inputMessagesFilterPhotoVideo': { sharedMediaDiv = this.sharedMedia.contentMedia; for(let message of messages) { let media = message.media.photo || message.media.document || (message.media.webpage && message.media.webpage.document); let div = document.createElement('div'); div.classList.add('media-item'); //console.log(message, photo); let isPhoto = media._ == 'photo'; let photo = isPhoto ? appPhotosManager.getPhoto(media.id) : null; let isDownloaded: boolean; if(photo) { isDownloaded = photo.downloaded > 0; } else { let cachedThumb = appPhotosManager.getDocumentCachedThumb(media.id); isDownloaded = cachedThumb?.downloaded > 0; } let img = new Image(); img.classList.add('media-image'); div.append(img); //this.log('inputMessagesFilterPhotoVideo', message, media); if(!isPhoto) { let span = document.createElement('span'); span.classList.add('video-time'); div.append(span); if(media.type != 'gif') { span.innerText = (media.duration + '').toHHMMSS(false); /* let spanPlay = document.createElement('span'); spanPlay.classList.add('video-play', 'tgico-largeplay', 'btn-circle', 'position-center'); div.append(spanPlay); */ } else { span.innerText = 'GIF'; } } let load = () => appPhotosManager.preloadPhoto(isPhoto ? media.id : media, appPhotosManager.choosePhotoSize(media, 200, 200)) .then(() => { if($rootScope.selectedPeerID != peerID) { this.log.warn('peer changed'); return; } let url = (photo && photo.url) || appPhotosManager.getDocumentCachedThumb(media.id).url; if(url) { renderImageFromUrl(img, url); } }); img.dataset.mid = '' + message.mid; let sizes = media.sizes || media.thumbs; if(isDownloaded || (sizes && sizes[0].bytes)) { let promise = new Promise((resolve, reject) => { img.addEventListener('load', () => { clearTimeout(timeout); resolve(); }); let timeout = setTimeout(() => { this.log('did not loaded', img, media, isDownloaded, sizes); reject(); }, 1e3); }); promises.push(promise); } if(isDownloaded) load(); else { if(sizes && sizes[0].bytes) { appPhotosManager.setAttachmentPreview(sizes[0].bytes, img, false, false); } this.lazyLoadQueue.push({div, load}); } elemsToAppend.push(div); this.mediaDivsByIDs[message.mid] = div; //sharedMediaDiv.append(div); } break; } case 'inputMessagesFilterDocument': { sharedMediaDiv = this.sharedMedia.contentDocuments; for(let message of messages) { let div = wrapDocument(message.media.document, true); elemsToAppend.push(div); } break; } case 'inputMessagesFilterUrl': { sharedMediaDiv = this.sharedMedia.contentLinks; for(let message of messages) { let webpage = message.media.webpage; let div = document.createElement('div'); let previewDiv = document.createElement('div'); previewDiv.classList.add('preview'); //this.log('wrapping webpage', webpage); previewDiv.innerText = (webpage.title || webpage.description || webpage.url || webpage.display_url).slice(0, 1); previewDiv.classList.add('empty'); if(webpage.photo) { let load = () => appPhotosManager.preloadPhoto(webpage.photo.id, appPhotosManager.choosePhotoSize(webpage.photo, 60, 60)) .then(() => { if($rootScope.selectedPeerID != peerID) { this.log.warn('peer changed'); return; } previewDiv.classList.remove('empty'); previewDiv.innerText = ''; renderImageFromUrl(previewDiv, webpage.photo.url); }); this.lazyLoadQueue.push({div: previewDiv, load}); } let title = webpage.rTitle || ''; let subtitle = webpage.rDescription || ''; let url = RichTextProcessor.wrapRichText(webpage.url || ''); if(!title) { //title = new URL(webpage.url).hostname; title = webpage.display_url.split('/', 1)[0]; } div.append(previewDiv); div.insertAdjacentHTML('beforeend', `
${title}
${subtitle}
${url}
`); if(div.innerText.trim().length) { elemsToAppend.push(div); } } break; } case 'inputMessagesFilterMusic': { sharedMediaDiv = this.sharedMedia.contentAudio; for(let message of messages) { let div = wrapAudio(message.media.document, true); elemsToAppend.push(div); } break; } default: console.warn('death is my friend', messages); break; } if(this.loadMutex) { promises.push(this.loadMutex); } if(elemsToAppend.length) { if(promises.length) { await Promise.all(promises); if(this.peerID != peerID) { this.log.warn('peer changed'); return; } } sharedMediaDiv.append(...elemsToAppend); } if(sharedMediaDiv) { let parent = sharedMediaDiv.parentElement; if(parent.lastElementChild.classList.contains('preloader')) { parent.lastElementChild.remove(); //this.contentContainer.classList.add('loaded'); } } } public loadSidebarMedia(single = false) { if(testScroll/* || 1 == 1 */) { return; } this.log('loadSidebarMedia', single, this.peerID, this.loadSidebarMediaPromises); let peerID = this.peerID; let typesToLoad = single ? [this.sharedMediaType] : this.sharedMediaTypes; typesToLoad = typesToLoad.filter(type => !this.loadedAllMedia[type]); if(!typesToLoad.length) return; let loadCount = (appPhotosManager.windowH / 130 | 0) * 3; // that's good for all types let historyStorage = this.historiesStorage[peerID] ?? (this.historiesStorage[peerID] = {}); let promises = typesToLoad.map(type => { if(this.loadSidebarMediaPromises[type]) return this.loadSidebarMediaPromises[type]; let history = historyStorage[type] ?? (historyStorage[type] = []); // render from cache if(history.length && this.usedFromHistory[type] < history.length) { let messages: any[] = []; let used = this.usedFromHistory[type]; do { let ids = history.slice(used, used + loadCount); this.log('loadSidebarMedia: will render from cache', used, history, ids, loadCount); used += ids.length; messages.push(...this.filterMessagesByType(ids, type)); } while(messages.length < loadCount && used < history.length); // если перебор if(messages.length > loadCount) { let diff = messages.length - loadCount; messages = messages.slice(0, messages.length - diff); used -= diff; } this.usedFromHistory[type] = used; if(messages.length) { return this.performSearchResult(messages, type); } return Promise.resolve(); } // заливать новую картинку сюда только после полной отправки! let maxID = history[history.length - 1] || 0; let ids = !maxID && appMessagesManager.historiesStorage[peerID] ? appMessagesManager.historiesStorage[peerID].history.slice() : []; maxID = !maxID && ids.length ? ids[ids.length - 1] : maxID; this.log('loadSidebarMedia: search house of glass pre', type, ids, maxID); //let loadCount = history.length ? 50 : 15; return this.loadSidebarMediaPromises[type] = appMessagesManager.getSearch(peerID, '', {_: type}, maxID, loadCount) .then(value => { ids = ids.concat(value.history); history.push(...ids); this.log('loadSidebarMedia: search house of glass', type, value, ids); if($rootScope.selectedPeerID != peerID) { this.log.warn('peer changed'); return; } if(value.history.length < loadCount) { this.loadedAllMedia[type] = true; } this.usedFromHistory[type] = history.length; if(ids.length) { return this.performSearchResult(this.filterMessagesByType(ids, type), type); } }, (err) => { this.log.error('load error:', err); }).then(() => { this.loadSidebarMediaPromises[type] = null; }); }); return Promise.all(promises); } public cleanup() { this.loadSidebarMediaPromises = {}; this.loadedAllMedia = {}; this.prevTabID = -1; this.mediaDivsByIDs = {}; this.lazyLoadQueue.clear(); this.sharedMediaTypes.forEach(type => { this.usedFromHistory[type] = 0; }); this.sharedMediaType = 'inputMessagesFilterPhotoVideo'; } public cleanupHTML() { //this.contentContainer.classList.remove('loaded'); //this.profileContentEl.parentElement.scrollTop = 0; this.profileElements.bio.style.display = 'none'; this.profileElements.phone.style.display = 'none'; this.profileElements.username.style.display = 'none'; this.profileElements.notificationsRow.style.display = ''; this.profileElements.notificationsCheckbox.checked = true; this.profileElements.notificationsStatus.innerText = 'Enabled'; if(this.urlsToRevoke.length) { this.urlsToRevoke.forEach(url => { URL.revokeObjectURL(url); }); this.urlsToRevoke.length = 0; } Object.keys(this.sharedMedia).forEach(key => { this.sharedMedia[key].innerHTML = ''; if(!this.historiesStorage[this.peerID] || !this.historiesStorage[this.peerID][key]) { let parent = this.sharedMedia[key].parentElement; if(!parent.querySelector('.preloader')) { putPreloader(parent, true); } } }); (this.profileTabs.firstElementChild.children[1] as HTMLLIElement).click(); // set media } public setLoadMutex(promise: Promise) { this.loadMutex = promise; } public setPeer(peerID: number) { this.peerID = peerID; this.cleanup(); } public fillProfileElements() { let peerID = this.peerID = $rootScope.selectedPeerID; this.cleanupHTML(); this.profileElements.avatar.setAttribute('peer', '' + peerID); // username if(peerID != $rootScope.myID) { let username = appPeersManager.getPeerUsername(peerID); if(username) { setText(appPeersManager.getPeerUsername(peerID), this.profileElements.username); } let dialog: any = appMessagesManager.getDialogByPeerID(peerID); if(dialog.length) { dialog = dialog[0]; let muted = false; if(dialog.notify_settings && dialog.notify_settings.mute_until) { muted = new Date(dialog.notify_settings.mute_until * 1000) > new Date(); } appImManager.setMutedState(muted); } } else { window.requestAnimationFrame(() => { this.profileElements.notificationsRow.style.display = 'none'; }); } let membersLi = this.profileTabs.firstElementChild.children[0] as HTMLLIElement; if(peerID > 0) { membersLi.style.display = 'none'; let user = appUsersManager.getUser(peerID); if(user.phone && peerID != $rootScope.myID) { setText(user.rPhone, this.profileElements.phone); } appProfileManager.getProfile(peerID, true).then(userFull => { if(this.peerID != peerID) { this.log.warn('peer changed'); return; } if(userFull.rAbout && peerID != $rootScope.myID) { setText(userFull.rAbout, this.profileElements.bio); } //this.log('userFull', userFull); if(userFull.pinned_msg_id) { // request pinned message appImManager.pinnedMsgID = userFull.pinned_msg_id; appMessagesManager.wrapSingleMessage(userFull.pinned_msg_id); } }); } else { membersLi.style.display = appPeersManager.isBroadcast(peerID) ? 'none' : ''; let chat = appPeersManager.getPeer(peerID); appProfileManager.getChatFull(chat.id).then((chatFull: any) => { if(this.peerID != peerID) { this.log.warn('peer changed'); return; } //this.log('chatInfo res 2:', chatFull); if(chatFull.about) { setText(RichTextProcessor.wrapRichText(chatFull.about), this.profileElements.bio); } }); } } } export default new AppSidebarRight();