mirror of
https://github.com/terribleplan/next.js.git
synced 2024-01-19 02:48:18 +00:00
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 ChatTwo extends Component {
|
||
|
// fetch old messages data from the server
|
||
|
static async getInitialProps ({ req }) {
|
||
|
const response = await fetch('http://localhost:3000/messages/chat2')
|
||
|
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.chat2', this.handleMessage)
|
||
|
this.props.socket.on('message.chat1', 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.handleOtherMessage)
|
||
|
this.props.socket.off('message.chat2', this.handleMessage)
|
||
|
}
|
||
|
|
||
|
// 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.chat2', 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 ${this.state.newMessage > 0 ? `( ${this.state.newMessage} new message )` : ''}`}</a></Link>
|
||
|
<br />
|
||
|
<Link href={'/clone'}><a>{'Chat Two'}</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 ChatTwo
|