mirror of
https://github.com/terribleplan/next.js.git
synced 2024-01-19 02:48:18 +00:00
6ed2da4575
with-socket.io example was using a single index file and was managing connection in there. This would lead handling connection (disconnecting and reconnecting) in each added page. I updated example with addition of `_app.js` and handled connection in there. This helped only subscribing to event in page and maintaining connection throughout example.
114 lines
2.9 KiB
JavaScript
114 lines
2.9 KiB
JavaScript
import { Component } from 'react'
|
|
import Link from 'next/link'
|
|
import fetch from 'isomorphic-unfetch'
|
|
|
|
class ChatOne extends Component {
|
|
// fetch old messages data from the server
|
|
static async getInitialProps ({ req }) {
|
|
const response = await fetch('http://localhost:3000/messages/chat1')
|
|
const messages = await response.json()
|
|
return { messages }
|
|
}
|
|
|
|
static defaultProps = {
|
|
messages: []
|
|
}
|
|
|
|
// init state with the prefetched messages
|
|
state = {
|
|
field: '',
|
|
newMessage: 0,
|
|
messages: this.props.messages,
|
|
subscribe: false,
|
|
subscribed: false
|
|
}
|
|
|
|
subscribe = () => {
|
|
if (this.state.subscribe && !this.state.subscribed) {
|
|
// connect to WS server and listen event
|
|
this.props.socket.on('message.chat1', this.handleMessage)
|
|
this.props.socket.on('message.chat2', this.handleOtherMessage)
|
|
this.setState({ subscribed: true })
|
|
}
|
|
}
|
|
componentDidMount () {
|
|
this.subscribe()
|
|
}
|
|
|
|
componentDidUpdate () {
|
|
this.subscribe()
|
|
}
|
|
|
|
static getDerivedStateFromProps (props, state) {
|
|
if (props.socket && !state.subscribe) return { subscribe: true }
|
|
return null
|
|
}
|
|
|
|
// close socket connection
|
|
componentWillUnmount () {
|
|
this.props.socket.off('message.chat1', this.handleMessage)
|
|
this.props.socket.off('message.chat2', this.handleOtherMessage)
|
|
}
|
|
|
|
// add messages from server to the state
|
|
handleMessage = (message) => {
|
|
this.setState(state => ({ messages: state.messages.concat(message) }))
|
|
}
|
|
|
|
handleOtherMessage = () => {
|
|
this.setState((prevState) => ({ newMessage: (prevState.newMessage + 1) }))
|
|
}
|
|
|
|
handleChange = event => {
|
|
this.setState({ field: event.target.value })
|
|
}
|
|
|
|
// send messages to server and add them to the state
|
|
handleSubmit = event => {
|
|
event.preventDefault()
|
|
|
|
// create message object
|
|
const message = {
|
|
id: (new Date()).getTime(),
|
|
value: this.state.field
|
|
}
|
|
|
|
// send object to WS server
|
|
this.props.socket.emit('message.chat1', message)
|
|
|
|
// add it to state and clean current input value
|
|
this.setState(state => ({
|
|
field: '',
|
|
messages: state.messages.concat(message)
|
|
}))
|
|
}
|
|
|
|
render () {
|
|
return (
|
|
<main>
|
|
<div>
|
|
<Link href={'/'}><a>{'Chat One'}</a></Link>
|
|
<br />
|
|
<Link href={'/clone'}><a>{`Chat Two ${this.state.newMessage > 0 ? `( ${this.state.newMessage} new message )` : ''}`}</a></Link>
|
|
<ul>
|
|
{this.state.messages.map(message =>
|
|
<li key={message.id}>{message.value}</li>
|
|
)}
|
|
</ul>
|
|
<form onSubmit={(e) => this.handleSubmit(e)}>
|
|
<input
|
|
onChange={this.handleChange}
|
|
type='text'
|
|
placeholder='Hello world!'
|
|
value={this.state.field}
|
|
/>
|
|
<button>Send</button>
|
|
</form>
|
|
</div>
|
|
</main>
|
|
)
|
|
}
|
|
}
|
|
|
|
export default ChatOne
|