import React from 'react'; import { AutoSizer, List } from 'react-virtualized'; import { ConversationListItem, PropsData as ConversationListItemPropsType, } from '../ConversationListItem'; import { LeftPane, RowRendererParamsType } from '../LeftPane'; import { SessionButton, SessionButtonColor, SessionButtonType, } from './SessionButton'; import { PropsData as SearchResultsProps, SearchResults, } from '../SearchResults'; import { SearchOptions } from '../../types/Search'; import { debounce } from 'lodash'; import { cleanSearchTerm } from '../../util/cleanSearchTerm'; import { SessionSearchInput } from './SessionSearchInput'; import { SessionClosableOverlay } from './SessionClosableOverlay'; import { MainViewController } from '../MainViewController'; export interface Props { searchTerm: string; isSecondaryDevice: boolean; conversations?: Array; searchResults?: SearchResultsProps; updateSearchTerm: (searchTerm: string) => void; search: (query: string, options: SearchOptions) => void; openConversationInternal: (id: string, messageId?: string) => void; clearSearch: () => void; } interface State { showAddChannelView: boolean; channelUrlPasted: string; loading: boolean; connectSuccess: boolean; } export class LeftPaneChannelSection extends React.Component { private readonly updateSearchBound: (searchedString: string) => void; private readonly debouncedSearch: (searchTerm: string) => void; public constructor(props: Props) { super(props); this.state = { showAddChannelView: false, channelUrlPasted: '', loading: false, connectSuccess: false, }; this.handleOnPasteUrl = this.handleOnPasteUrl.bind(this); this.handleJoinChannelButtonClick = this.handleJoinChannelButtonClick.bind( this ); this.handleToggleOverlay = this.handleToggleOverlay.bind(this); this.updateSearchBound = this.updateSearch.bind(this); this.debouncedSearch = debounce(this.search.bind(this), 20); this.attemptConnection = this.attemptConnection.bind(this); } public componentWillUnmount() { this.updateSearch(''); } public getCurrentConversations(): | Array | undefined { const { conversations } = this.props; let conversationList = conversations; if (conversationList !== undefined) { conversationList = conversationList.filter( // a channel is either a public group or a rss group conversation => conversation.type === 'group' && (conversation.isPublic || (conversation.lastMessage && conversation.lastMessage.isRss)) ); } return conversationList; } public renderRow = ({ index, key, style, }: RowRendererParamsType): JSX.Element => { const { openConversationInternal } = this.props; const conversations = this.getCurrentConversations(); if (!conversations) { throw new Error('renderRow: Tried to render without conversations'); } const conversation = conversations[index]; return ( ); }; public renderList(): JSX.Element | Array { const { openConversationInternal, searchResults } = this.props; if (searchResults) { return ( ); } const conversations = this.getCurrentConversations(); if (!conversations) { throw new Error( 'render: must provided conversations if no search results are provided' ); } const length = conversations.length; // Note: conversations is not a known prop for List, but it is required to ensure that // it re-renders when our conversation data changes. Otherwise it would just render // on startup and scroll. const list = (
{({ height, width }) => ( )}
); return [list]; } public renderHeader(): JSX.Element { const labels = [window.i18n('channels')]; return LeftPane.RENDER_HEADER(labels, null); } public render(): JSX.Element { MainViewController.renderMessageView(); return (
{this.renderHeader()} {this.state.showAddChannelView ? this.renderClosableOverlay() : this.renderGroups()}
); } public renderGroups() { return (
{this.renderList()} {this.renderBottomButtons()}
); } public updateSearch(searchTerm: string) { const { updateSearchTerm, clearSearch } = this.props; if (!searchTerm) { clearSearch(); return; } this.setState({ channelUrlPasted: '' }, () => { window.Session.emptyContentEditableDivs(); }); if (updateSearchTerm) { updateSearchTerm(searchTerm); } if (searchTerm.length < 2) { return; } const cleanedTerm = cleanSearchTerm(searchTerm); if (!cleanedTerm) { return; } this.debouncedSearch(cleanedTerm); } public clearSearch() { this.props.clearSearch(); } public search() { const { search } = this.props; const { searchTerm, isSecondaryDevice } = this.props; if (search) { search(searchTerm, { noteToSelf: window.i18n('noteToSelf').toLowerCase(), ourNumber: window.textsecure.storage.user.getNumber(), regionCode: '', isSecondaryDevice, }); } } private handleToggleOverlay() { this.setState(prevState => ({ showAddChannelView: !prevState.showAddChannelView, })); } private renderClosableOverlay() { const { searchTerm } = this.props; const { loading } = this.state; return ( ); } private renderBottomButtons(): JSX.Element { const edit = window.i18n('edit'); const addChannel = window.i18n('addChannel'); const showEditButton = false; return (
{showEditButton && ( )}
); } private handleOnPasteUrl(e: any) { if (e.target.innerHTML) { const cleanText = e.target.innerHTML.replace(/<\/?[^>]+(>|$)/g, ''); this.setState({ channelUrlPasted: cleanText }); } } private handleJoinChannelButtonClick() { const { loading, channelUrlPasted } = this.state; if (loading) { return false; } const regexURL = /(http:\/\/www\.|https:\/\/www\.|http:\/\/|https:\/\/)?[a-z0-9]+([\-\.]{1}[a-z0-9]+)*\.[a-z]{2,5}(:[0-9]{1,5})?(\/.*)?/; if (channelUrlPasted.length <= 0) { window.pushToast({ title: window.i18n('noServerURL'), type: 'error', id: 'connectToServerFail', }); return false; } if (!regexURL.test(channelUrlPasted)) { window.pushToast({ title: window.i18n('noServerURL'), type: 'error', id: 'connectToServerFail', }); return false; } // TODO: Make this not hard coded const channelId = 1; this.setState({ loading: true }); const connectionResult = this.attemptConnection( channelUrlPasted, channelId ); // Give 5s maximum for promise to revole. Else, throw error. const maxConnectionDuration = 5000; const connectionTimeout = setTimeout(() => { if (!this.state.connectSuccess) { this.setState({ loading: false }); window.pushToast({ title: window.i18n('connectToServerFail'), type: 'error', id: 'connectToServerFail', }); return; } }, maxConnectionDuration); connectionResult .then(() => { clearTimeout(connectionTimeout); if (this.state.loading) { this.setState({ connectSuccess: true, loading: false, }); window.pushToast({ title: window.i18n('connectToServerSuccess'), id: 'connectToServerSuccess', type: 'success', }); this.handleToggleOverlay(); } }) .catch((connectionError: string) => { clearTimeout(connectionTimeout); this.setState({ connectSuccess: true, loading: false, }); window.pushToast({ title: connectionError, id: 'connectToServerFail', type: 'error', }); return false; }); return true; } private async attemptConnection(serverURL: string, channelId: number) { const rawserverURL = serverURL .replace(/^https?:\/\//i, '') .replace(/[/\\]+$/i, ''); const sslServerURL = `https://${rawserverURL}`; const conversationId = `publicChat:${channelId}@${rawserverURL}`; const conversationExists = window.ConversationController.get( conversationId ); if (conversationExists) { // We are already a member of this public chat return new Promise((_resolve, reject) => { reject(window.i18n('publicChatExists')); }); } const serverAPI = await window.lokiPublicChatAPI.findOrCreateServer( sslServerURL ); if (!serverAPI) { // Url incorrect or server not compatible return new Promise((_resolve, reject) => { reject(window.i18n('connectToServerFail')); }); } const conversation = await window.ConversationController.getOrCreateAndWait( conversationId, 'group' ); await serverAPI.findOrCreateChannel(channelId, conversationId); await conversation.setPublicSource(sslServerURL, channelId); await conversation.setFriendRequestStatus( window.friends.friendRequestStatusEnum.friends ); return conversation; } }