Sequence id on pubnub

decorateWithSequenceId.js

const db = require('kvstore');
const console = require('console');

export default (request) => {
    const {channels} = request;
    
    const queue = channels
        .map((channelName) => {
            
            console.debug(`Get counter for channel "${channelName}"`);
            
            return db.getCounter(channelName)
                .then((sequenceId) => {
                    console.debug(`Counter for channel "${channelName}" was ${sequenceId}`);
                    
                    request.message.sequenceMetadata = request.message.sequenceMetadata || {};
                    request.message.sequenceMetadata[channelName] = sequenceId;
                    db.incrCounter(channelName);
                });
        });
    
    return Promise
        .all(queue)
        .then(() => {
            console.debug(`Resolving request`);
            return request.ok();
        });
};