import React from 'react'; import PropTypes from 'prop-types'; import { Text, View, StyleSheet, Button, SafeAreaView } from 'react-native'; import { ListView } from 'realm/react-native'; import { connect } from 'react-redux'; import { bindActionCreators } from 'redux'; import * as actions from '../actions'; import { openRoom } from '../actions/room'; import { editCancel } from '../actions/messages'; import realm from '../lib/realm'; import RocketChat from '../lib/rocketchat'; import Message from '../containers/message'; import MessageActions from '../containers/MessageActions'; import MessageBox from '../containers/MessageBox'; import Typing from '../containers/Typing'; import KeyboardView from '../presentation/KeyboardView'; const ds = new ListView.DataSource({ rowHasChanged: (r1, r2) => r1._id !== r2._id }); const styles = StyleSheet.create({ typing: { fontWeight: 'bold', paddingHorizontal: 15, height: 25 }, container: { flex: 1, backgroundColor: '#fff' }, safeAreaView: { flex: 1 }, list: { flex: 1, transform: [{ scaleY: -1 }] }, separator: { height: 1, backgroundColor: '#CED0CE' }, bannerContainer: { backgroundColor: 'orange' }, bannerText: { margin: 5, textAlign: 'center', color: '#a00' }, loadingMore: { transform: [{ scaleY: -1 }], textAlign: 'center', padding: 5, color: '#ccc' } }); const typing = () => ; @connect( state => ({ server: state.server.server, Site_Url: state.settings.Site_Url, Message_TimeFormat: state.settings.Message_TimeFormat, loading: state.messages.isFetching }), dispatch => ({ actions: bindActionCreators(actions, dispatch), openRoom: room => dispatch(openRoom(room)), editCancel: () => dispatch(editCancel()) }) ) export default class RoomView extends React.Component { static propTypes = { navigation: PropTypes.object.isRequired, openRoom: PropTypes.func.isRequired, editCancel: PropTypes.func, rid: PropTypes.string, server: PropTypes.string, sid: PropTypes.string, name: PropTypes.string, Site_Url: PropTypes.string, Message_TimeFormat: PropTypes.string, loading: PropTypes.bool }; constructor(props) { super(props); this.sid = props.navigation.state.params.room.sid; this.rid = props.rid || props.navigation.state.params.room.rid || realm.objectForPrimaryKey('subscriptions', this.sid).rid; this.data = realm .objects('messages') .filtered('_server.id = $0 AND rid = $1', this.props.server, this.rid) .sorted('ts', true); this.room = realm.objects('subscriptions').filtered('rid = $0', this.rid); this.state = { slow: false, dataSource: ds.cloneWithRows([]), loaded: true, joined: typeof props.rid === 'undefined' }; } componentWillMount() { this.props.navigation.setParams({ title: this.props.name || this.props.navigation.state.params.room.name || realm.objectForPrimaryKey('subscriptions', this.sid).name }); this.timer = setTimeout(() => this.setState({ slow: true }), 5000); this.props.openRoom({ rid: this.rid }); this.data.addListener(this.updateState); } componentDidMount() { this.updateState(); } componentDidUpdate() { return !this.props.loading && clearTimeout(this.timer); } componentWillUnmount() { clearTimeout(this.timer); this.data.removeAllListeners(); this.props.editCancel(); } onEndReached = () => { const rowCount = this.state.dataSource.getRowCount(); if ( rowCount && this.state.loaded && this.state.loadingMore !== true && this.state.end !== true ) { this.setState({ loadingMore: true }); const lastRowData = this.data[rowCount - 1]; RocketChat.loadMessagesForRoom(this.rid, lastRowData.ts, ({ end }) => { this.setState({ loadingMore: false, end }); }); } } updateState = () => { this.setState({ dataSource: ds.cloneWithRows(this.data) }); }; sendMessage = message => RocketChat.sendMessage(this.rid, message); joinRoom = async() => { await RocketChat.joinRoom(this.props.rid); this.setState({ joined: true }); }; renderBanner = () => (this.state.slow && this.props.loading ? ( Loading new messages... ) : null); renderItem = ({ item }) => ( ); renderSeparator = () => ; renderFooter = () => { if (!this.state.joined) { return ( You are in preview mode.