const ChatEngine = ChatEngineCore.create({
    publishKey: 'pub-key-here',
    subscribeKey: 'sub-key-here',
}, {
    endpoint: 'http://chatengine:server/',
    globalChannel: 'global-channel-name'
});
 
ChatEngine.connect('Username');
ChatEngine.on('$.ready', () => { ... });

const status = require('chat-engine-event-status');
 
chat.plugin(status({ event: 'message' }));

let sent = [];
 
//gets the tracking id of the new message sent
 
chat.on('$.eventStatus.sent', (payload) => {
    const { data } = payload;
    sent.push(data.id);
});

//synchronizes the message received into the stream with the tracking id got from event $.eventStatus.sent
 
let messages = [];
 
chat.on('message', (payload) => {
    const index = this.sent.indexOf(payload.eventStatus.id);
 
    if (index >= 0) {
        payload.eventStatus.sent = true;
        sent.splice(index, 1);
    }
 
    messages.push(payload);
});

chat.on('$.eventStatus.delivered', (payload) => {
    let message = messages.find(w => w.eventStatus.id === payload.data.id);
 
    if (message) {
        message.eventStatus.delivery = true;
    }
});

chat.on('message', (payload) => {
    chat.eventStatus.read(payload);
});

chat.on('$.eventStatus.read', (payload) => {
    let message = this.messages.find(w => w.eventStatus.id === payload.data.id);
 
    if (message) {
        message.eventStatus.read = true;
    }
});