import React from 'react';
import PropTypes from 'prop-types';
import { Text, View, StyleSheet, Button, InteractionManager } from 'react-native';
import { ListView } from 'realm/react-native';
import { connect } from 'react-redux';
import { bindActionCreators } from 'redux';
import * as actions from '../actions';
import { messagesRequest } from '../actions/messages';
import realm from '../lib/realm';
import RocketChat from '../lib/rocketchat';
import Message from '../containers/Message';
import MessageBox from '../containers/MessageBox';
import KeyboardView from '../presentation/KeyboardView';
const ds = new ListView.DataSource({ rowHasChanged: (r1, r2) => r1._id !== r2._id });
const styles = StyleSheet.create({
container: {
flex: 1,
backgroundColor: '#fff'
},
list: {
flex: 1,
transform: [{ scaleY: -1 }]
},
separator: {
height: 1,
backgroundColor: '#CED0CE'
},
bannerContainer: {
backgroundColor: 'orange'
},
bannerText: {
margin: 5,
textAlign: 'center',
color: '#a00'
},
header: {
transform: [{ scaleY: -1 }],
textAlign: 'center',
padding: 5,
color: '#ccc'
}
});
@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),
getMessages: rid => dispatch(messagesRequest({ rid }))
}))
export default class RoomView extends React.Component {
static propTypes = {
navigation: PropTypes.object.isRequired,
getMessages: PropTypes.func.isRequired,
rid: PropTypes.string,
sid: PropTypes.string,
name: PropTypes.string,
server: 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 || 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.state = {
slow: false,
dataSource: [],
loaded: true,
joined: typeof props.rid === 'undefined'
};
}
componentWillMount() {
this.props.navigation.setParams({
title: this.props.name || realm.objectForPrimaryKey('subscriptions', this.sid).name
});
this.timer = setTimeout(() => this.setState({ slow: true }), 5000);
this.props.getMessages(this.rid);
this.data.addListener(this.updateState);
this.state.dataSource = ds.cloneWithRows(this.data);
}
componentDidMount() {
InteractionManager.runAfterInteractions(() => RocketChat.readMessages(this.rid));
}
componentDidUpdate() {
return !this.props.loading && clearTimeout(this.timer);
}
componentWillUnmount() {
clearTimeout(this.timer);
this.data.removeAllListeners();
}
onEndReached = () => {
const rowCount = this.state.dataSource.getRowCount();
if (rowCount && this.state.loaded && this.state.loadingMore !== true && this.state.end !== true) {
this.setState({
// ...this.state,
loadingMore: true
});
const lastRowData = this.data[rowCount - 1];
RocketChat.loadMessagesForRoom(this.rid, lastRowData.ts, ({ end }) => {
this.setState({
// ...this.state,
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.
);
}
return (
this.box = box}
onSubmit={this.sendMessage}
rid={this.rid}
/>
);
}
renderHeader = () => {
if (this.state.loadingMore) {
return Loading more messages...;
}
if (this.state.end) {
return Start of conversation;
}
}
render() {
return (
{this.renderBanner()}
this.renderItem({ item })}
initialListSize={10}
/>
{this.renderFooter()}
);
}
}