index.js

const RTM = require('satori-rtm-sdk')

// create an RTM client instance
const rtm = new RTM('YOUR_ENDPOINT', 'YOUR_APPKEY')

// create a new subscription with 'your-channel'
const channel = rtm.subscribe('YOUR_CHANNEL', RTM.SubscriptionMode.SIMPLE)

// add channel data handlers

// channel receives any published message
channel.on('rtm/subscription/data', pdu => {
  const messages = pdu.body.messages
                              
  messages.forEach(console.log)
})

// client enters 'connected' state
rtm.on('enter-connected', () => {
    const payload = {key: 'value'}
    
    rtm.publish('YOUR_CHANNEL', payload)
})

// client receives any PDU and PDU is passed as a parameter
rtm.on('data', pdu => {
    if (pdu.action.endsWith('/error')) {
        rtm.restart()
    }
})

// start the client
rtm.start()