gistfile1.js

/*
 * Node Network Protocol Parser
 * https://github.com/miksago/ideabin/wiki/Node-Network-Protocol
 */
function NNPParser(readStream, callback)
{
    var self = this;
    if(callback) self.addListener('msg', callback);

    var buffer = '';
    var len = '';
    var hasLen = false;
    var i = 0;
    readStream.on('data', function(data)
    {
        if(data && data.length)
        {
            buffer += data;
            if(!hasLen)
            {
                for(; i < buffer.length; i++)
                {
                    if(buffer[i] === ',')
                    {
                        hasLen = true;
                        len = parseInt(len);
                        i++;
                        break;
                    }else{
                        len += buffer[i];
                    }
                }
            }
            if(hasLen)
            {
                if(i + len <= buffer.length)
                {
                    self.emit('msg', buffer.substr(i, len));
                    hasLen = false;
                    len = '';
                    i = 0;
                    if(i + len == buffer.length)
                    {
                        buffer = '';
                    }else{
                        buffer = buffer.substr(i + len);
                    }
                }
            }
        }
    });
}

require('sys').inherits(NNPParser, require('events').EventEmitter);

module.exports = function(readStream, callback)
{
    return new NNPParser(readStream, callback);
};