import { Q } from '@nozbe/watermelondb'; import { Base64 } from 'js-base64'; import React from 'react'; import { BackHandler, Image, Keyboard, StyleSheet, Text, View } from 'react-native'; import { TouchableOpacity } from 'react-native-gesture-handler'; import Orientation from 'react-native-orientation-locker'; import { connect } from 'react-redux'; import parse from 'url-parse'; import { inviteLinksClear } from '../../actions/inviteLinks'; import { selectServerRequest, serverFinishAdd, serverRequest } from '../../actions/server'; import { themes } from '../../constants/colors'; import Button from '../../containers/Button'; import FormContainer, { FormContainerInner } from '../../containers/FormContainer'; import * as HeaderButton from '../../containers/HeaderButton'; import OrSeparator from '../../containers/OrSeparator'; import { IBaseScreen, TServerHistoryModel } from '../../definitions'; import { withDimensions } from '../../dimensions'; import I18n from '../../i18n'; import database from '../../lib/database'; import { sanitizeLikeString } from '../../lib/database/utils'; import RocketChat from '../../lib/rocketchat'; import UserPreferences from '../../lib/userPreferences'; import { OutsideParamList } from '../../stacks/types'; import { withTheme } from '../../theme'; import { isTablet } from '../../utils/deviceInfo'; import EventEmitter from '../../utils/events'; import { BASIC_AUTH_KEY, setBasicAuth } from '../../utils/fetch'; import { showConfirmationAlert } from '../../utils/info'; import { events, logEvent } from '../../utils/log'; import { moderateScale, verticalScale } from '../../utils/scaling'; import SSLPinning from '../../utils/sslPinning'; import sharedStyles from '../Styles'; import ServerInput from './ServerInput'; const styles = StyleSheet.create({ onboardingImage: { alignSelf: 'center', resizeMode: 'contain' }, title: { ...sharedStyles.textBold, letterSpacing: 0, alignSelf: 'center' }, subtitle: { ...sharedStyles.textRegular, alignSelf: 'center' }, certificatePicker: { alignItems: 'center', justifyContent: 'flex-end' }, chooseCertificateTitle: { ...sharedStyles.textRegular }, chooseCertificate: { ...sharedStyles.textSemibold }, description: { ...sharedStyles.textRegular, textAlign: 'center' }, connectButton: { marginBottom: 0 } }); interface INewServerViewProps extends IBaseScreen { connecting: boolean; previousServer: string; width: number; height: number; } interface INewServerViewState { text: string; connectingOpen: boolean; certificate: any; serversHistory: TServerHistoryModel[]; } interface ISubmitParams { fromServerHistory?: boolean; username?: string; } class NewServerView extends React.Component { constructor(props: INewServerViewProps) { super(props); if (!isTablet) { Orientation.lockToPortrait(); } this.setHeader(); this.state = { text: '', connectingOpen: false, certificate: null, serversHistory: [] }; EventEmitter.addEventListener('NewServer', this.handleNewServerEvent); BackHandler.addEventListener('hardwareBackPress', this.handleBackPress); } componentDidMount() { this.queryServerHistory(); } componentWillUnmount() { EventEmitter.removeListener('NewServer', this.handleNewServerEvent); BackHandler.removeEventListener('hardwareBackPress', this.handleBackPress); const { previousServer, dispatch } = this.props; if (previousServer) { dispatch(serverFinishAdd()); } } setHeader = () => { const { previousServer, navigation } = this.props; if (previousServer) { return navigation.setOptions({ headerTitle: I18n.t('Workspaces'), headerLeft: () => }); } return navigation.setOptions({ headerShown: false }); }; handleBackPress = () => { const { navigation, previousServer } = this.props; if (navigation.isFocused() && previousServer) { this.close(); return true; } return false; }; onChangeText = (text: string) => { this.setState({ text }); this.queryServerHistory(text); }; queryServerHistory = async (text?: string) => { const db = database.servers; try { const serversHistoryCollection = db.get('servers_history'); let whereClause = [Q.where('username', Q.notEq(null)), Q.experimentalSortBy('updated_at', Q.desc), Q.experimentalTake(3)]; if (text) { const likeString = sanitizeLikeString(text); whereClause = [...whereClause, Q.where('url', Q.like(`%${likeString}%`))]; } const serversHistory = await serversHistoryCollection.query(...whereClause).fetch(); this.setState({ serversHistory }); } catch { // Do nothing } }; close = () => { const { dispatch, previousServer } = this.props; dispatch(inviteLinksClear()); dispatch(selectServerRequest(previousServer)); }; handleNewServerEvent = (event: { server: string }) => { let { server } = event; if (!server) { return; } const { dispatch } = this.props; this.setState({ text: server }); server = this.completeUrl(server); dispatch(serverRequest(server)); }; onPressServerHistory = (serverHistory: TServerHistoryModel) => { this.setState({ text: serverHistory.url }, () => this.submit({ fromServerHistory: true, username: serverHistory?.username })); }; submit = async ({ fromServerHistory = false, username }: ISubmitParams = {}) => { logEvent(events.NS_CONNECT_TO_WORKSPACE); const { text, certificate } = this.state; const { dispatch } = this.props; this.setState({ connectingOpen: false }); if (text) { Keyboard.dismiss(); const server = this.completeUrl(text); // Save info - SSL Pinning await UserPreferences.setStringAsync(`${RocketChat.CERTIFICATE_KEY}-${server}`, certificate); // Save info - HTTP Basic Authentication await this.basicAuth(server, text); if (fromServerHistory) { dispatch(serverRequest(server, username, true)); } else { dispatch(serverRequest(server)); } } }; connectOpen = () => { logEvent(events.NS_JOIN_OPEN_WORKSPACE); this.setState({ connectingOpen: true }); const { dispatch } = this.props; dispatch(serverRequest('https://open.rocket.chat')); }; basicAuth = async (server: string, text: string) => { try { const parsedUrl = parse(text, true); if (parsedUrl.auth.length) { const credentials = Base64.encode(parsedUrl.auth); await UserPreferences.setStringAsync(`${BASIC_AUTH_KEY}-${server}`, credentials); setBasicAuth(credentials); } } catch { // do nothing } }; chooseCertificate = async () => { try { const certificate = await SSLPinning?.pickCertificate(); this.setState({ certificate }); } catch { // Do nothing } }; completeUrl = (url: string) => { const parsedUrl = parse(url, true); if (parsedUrl.auth.length) { url = parsedUrl.origin; } url = url && url.replace(/\s/g, ''); if (/^(\w|[0-9-_]){3,}$/.test(url) && /^(htt(ps?)?)|(loca((l)?|(lh)?|(lho)?|(lhos)?|(lhost:?\d*)?)$)/.test(url) === false) { url = `${url}.rocket.chat`; } if (/^(https?:\/\/)?(((\w|[0-9-_])+(\.(\w|[0-9-_])+)+)|localhost)(:\d+)?$/.test(url)) { if (/^localhost(:\d+)?/.test(url)) { url = `http://${url}`; } else if (/^https?:\/\//.test(url) === false) { url = `https://${url}`; } } return url.replace(/\/+$/, '').replace(/\\/g, '/'); }; uriToPath = (uri: string) => uri.replace('file://', ''); handleRemove = () => { showConfirmationAlert({ message: I18n.t('You_will_unset_a_certificate_for_this_server'), confirmationText: I18n.t('Remove'), // @ts-ignore onPress: this.setState({ certificate: null }) // We not need delete file from DocumentPicker because it is a temp file }); }; deleteServerHistory = async (item: TServerHistoryModel) => { const db = database.servers; try { await db.write(async () => { await item.destroyPermanently(); }); this.setState((prevstate: INewServerViewState) => ({ serversHistory: prevstate.serversHistory.filter(server => server.id !== item.id) })); } catch { // Nothing } }; renderCertificatePicker = () => { const { certificate } = this.state; const { theme, width, height, previousServer } = this.props; return ( {certificate ? I18n.t('Your_certificate') : I18n.t('Do_you_have_a_certificate')} {certificate ?? I18n.t('Apply_Your_Certificate')} ); }; render() { const { connecting, theme, previousServer, width, height } = this.props; const { text, connectingOpen, serversHistory } = this.state; const marginTop = previousServer ? 0 : 35; return ( Rocket.Chat {I18n.t('Onboarding_subtitle')}