/* ---------------------------------------------------------------------------

    Init PubNub and Get your PubNub API Keys:
    http://www.pubnub.com/account#api-keys

--------------------------------------------------------------------------- */
var pubnub = require("./../pubnub.js").init({
    publish_key   : "demo",
    subscribe_key : "demo"
})                                         // PubNub Module
,   userid  = Math.random() * 1000000 | 1  // Random UID
,   channel = "my_channel"                 // Communication Channel
,   users   = {}                           // List of Chaters
,   lines   = [];                          // Local History

/* ---------------------------------------------------------------------------
Open Network Connection to PubNub
--------------------------------------------------------------------------- */
pubnub.subscribe({
    channel  : channel,
    connect  : function() {
        console.log("Ready To Receive Messages");
    },
    callback : function(update) {
        // Create New User if Need Be.
        update.userid in users || (users[update.userid] = '');

        // New Line?
        if (
            update.key.indexOf('\r') >= 0 ||
            update.key.indexOf('\n') >= 0
        ) {
            lines.push(chatln( update.userid, users[update.userid] ));
            users[update.userid] = '';
            return render();
        }

        // Append Key(s)
        users[update.userid] += update.key;

        // Draw
        render();
    }
});

/* ---------------------------------------------------------------------------
Render Chat
--------------------------------------------------------------------------- */
function chatln( user, message ) { return user + ': ' + message + '\r\n' }
function render() {
    // Clear Screen
    process.stdout.write('\u001B[2J\u001B[0;0f');

    // Print History Lines
    lines.forEach(function(line){ process.stdout.write(line) });
    console.log('---------------------------------------------------------');

    // Print Active Lines
    for (var user in users) process.stdout.write(chatln( user, users[user] ));
}

/* ---------------------------------------------------------------------------
Keystrokes
--------------------------------------------------------------------------- */
require('tty').setRawMode(true);
process.openStdin().on( 'keypress', function (chunk, key) {
    // Watch for Exit Command
    if (key && key.ctrl && key.name == 'c') return process.exit();

    // Send Keystroke
    pubnub.publish({
        channel : channel,
        message : { userid : userid, key : chunk }
    });
} );