Advanced BLOCKS Techniques - KV Store BLOCK

pubnub_kvstore_block.js

export default (request) => {
    const db = require('kvstore');

    var by = request.message.by || request.params.uuid;
    var last_key = by + ":last_msg";
    var count_key = by + ":count";

    if (request.message && (request.message.text == '/my_stats')) {
        //
        // special "my_stats" command handling
        //
        return db.get(last_key).then((last_msg) => {
            return db.getCounter(count_key).then((count) => {
                request.message.last_msg = last_msg || "<not found>";
                request.message.count = count || 0;

                return request.ok(); 
            });
        });
    }
               
    //
    // normal case, store the message details
    //
    request.message.at = new Date().toISOString();

    return db.set(last_key, request.message).then((last_result) => {
        return db.incrCounter(count_key).then((count_result) => {
            return request.ok();
        });
    });
}