in web/src/App.js [52:76]
componentDidMount(){
PubSub.subscribe(mqtt_topic).subscribe({
next: data => {
data.value.client_received_at = new Date()
console.log(`Message received: ${JSON.stringify(data.value)} \nRaw data: ${JSON.stringify(data)}`)
this.setState(prevState => ({
connectionState: `Connected and Subscribed to topic '${mqtt_topic}'; Messages Received`,
messages: [...prevState.messages, data.value]
}))
},
error: error => {
console.log(JSON.stringify(error, null, 2))
this.setState(prevState => ({
connectionState: `Failed to subscribe to topic '${mqtt_topic}' on endpoint ${mqtt_host}: ${error.error.errorMessage}`
}))
},
close: () => {
this.setState({ connectionState: `Connection Closed` })
},
})
this.setState({ connectionState: `Connected and Subscribed to topic '${mqtt_topic}'; Awaiting Messages...` })
}