loaded status; do not preload submitted statuses into community/public timelines, unless those timelines have already been loaded; do not close streaming API connections for community/public timelines, once they have been established (most users navigate back to them eventually)
		
			
				
	
	
		
			81 lines
		
	
	
	
		
			2.3 KiB
		
	
	
	
		
			JavaScript
		
	
	
	
	
	
			
		
		
	
	
			81 lines
		
	
	
	
		
			2.3 KiB
		
	
	
	
		
			JavaScript
		
	
	
	
	
	
import { connect } from 'react-redux';
 | 
						|
import PureRenderMixin from 'react-addons-pure-render-mixin';
 | 
						|
import StatusListContainer from '../ui/containers/status_list_container';
 | 
						|
import Column from '../ui/components/column';
 | 
						|
import {
 | 
						|
  refreshTimeline,
 | 
						|
  updateTimeline,
 | 
						|
  deleteFromTimelines
 | 
						|
} from '../../actions/timelines';
 | 
						|
import { defineMessages, injectIntl, FormattedMessage } from 'react-intl';
 | 
						|
import ColumnBackButtonSlim from '../../components/column_back_button_slim';
 | 
						|
import createStream from '../../stream';
 | 
						|
 | 
						|
const messages = defineMessages({
 | 
						|
  title: { id: 'column.public', defaultMessage: 'Whole Known Network' }
 | 
						|
});
 | 
						|
 | 
						|
const mapStateToProps = state => ({
 | 
						|
  hasUnread: state.getIn(['timelines', 'public', 'unread']) > 0,
 | 
						|
  accessToken: state.getIn(['meta', 'access_token'])
 | 
						|
});
 | 
						|
 | 
						|
let subscription;
 | 
						|
 | 
						|
const PublicTimeline = React.createClass({
 | 
						|
 | 
						|
  propTypes: {
 | 
						|
    dispatch: React.PropTypes.func.isRequired,
 | 
						|
    intl: React.PropTypes.object.isRequired,
 | 
						|
    accessToken: React.PropTypes.string.isRequired,
 | 
						|
    hasUnread: React.PropTypes.bool
 | 
						|
  },
 | 
						|
 | 
						|
  mixins: [PureRenderMixin],
 | 
						|
 | 
						|
  componentDidMount () {
 | 
						|
    const { dispatch, accessToken } = this.props;
 | 
						|
 | 
						|
    dispatch(refreshTimeline('public'));
 | 
						|
 | 
						|
    if (typeof subscription !== 'undefined') {
 | 
						|
      return;
 | 
						|
    }
 | 
						|
 | 
						|
    subscription = createStream(accessToken, 'public', {
 | 
						|
 | 
						|
      received (data) {
 | 
						|
        switch(data.event) {
 | 
						|
        case 'update':
 | 
						|
          dispatch(updateTimeline('public', JSON.parse(data.payload)));
 | 
						|
          break;
 | 
						|
        case 'delete':
 | 
						|
          dispatch(deleteFromTimelines(data.payload));
 | 
						|
          break;
 | 
						|
        }
 | 
						|
      }
 | 
						|
 | 
						|
    });
 | 
						|
  },
 | 
						|
 | 
						|
  componentWillUnmount () {
 | 
						|
    // if (typeof subscription !== 'undefined') {
 | 
						|
    //   subscription.close();
 | 
						|
    //   subscription = null;
 | 
						|
    // }
 | 
						|
  },
 | 
						|
 | 
						|
  render () {
 | 
						|
    const { intl, hasUnread } = this.props;
 | 
						|
 | 
						|
    return (
 | 
						|
      <Column icon='globe' active={hasUnread} heading={intl.formatMessage(messages.title)}>
 | 
						|
        <ColumnBackButtonSlim />
 | 
						|
        <StatusListContainer type='public' emptyMessage={<FormattedMessage id='empty_column.public' defaultMessage='There is nothing here! Write something publicly, or manually follow users from other instances to fill it up' />} />
 | 
						|
      </Column>
 | 
						|
    );
 | 
						|
  },
 | 
						|
 | 
						|
});
 | 
						|
 | 
						|
export default connect(mapStateToProps)(injectIntl(PublicTimeline));
 |