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();
        });
};