Google ccs server connection

NodeCCS.js

var config = require('./gcmConfig');

var xmpp = require('node-xmpp');

var jobPayload;
var xmppClient;

var options = {
    type: 'client',
    jid: config.jid,
    password: config.password,
    port: config.port,
    host: config.host,
    legacySSL: true,
    preferredSaslMechanism: 'PLAIN'
};

xmppClient = new xmpp.Client(options);

//xmppClient.connection.socket.setTimeout(0);
//xmppClient.connection.socket.setKeepAlive(true, 10000);

xmppClient.on('online', function() {
    console.log("online");
});

xmppClient.on('connection', function() {
    console.log('online');
});

xmppClient.on('stanza',
        function(stanza) {
            if (stanza.is('message') && stanza.attrs.type !== 'error') {
                // Best to ignore an error
                //Message format as per here: https://developer.android.com/google/gcm/ccs.html#upstream
                var messageData = JSON.parse(stanza.getChildText("gcm"));
                messageData.channel = redisSubChan;
                var messageType = messageData.message_type;

                if (messageType != "ack" && messageType != "nack" && messageType != "receipt" && messageType != "control") {

                    var ackMsg = new xmpp.Element('message', {'id': ''}).c('gcm', {xmlns: 'google:mobile:data'}).t(JSON.stringify({
                        "to": messageData.from,
                        "message_id": messageData.message_id,
                        "message_type": "ack"
                    }));
                    //send back the ack.
                    xmppClient.send(ackMsg);
                }
                //use the message
            } else {
                console.log("stanza error");
            }
            console.log(stanza.toString());
        });

xmppClient.on('authenticate', function(opts, cb) {
    console.log('AUTH' + opts.jid + ' -> ' + opts.password);
    cb(null);
});

xmppClient.on('close', function(){
	setTimeout(function(){
    	process.exit(0);
	}, 1000);
});

xmppClient.on('disconnect', function(){
	setTimeout(function(){
    	process.exit(0);
	}, 1000);
});

xmppClient.on('end', function(){
	setTimeout(function(){
    	process.exit(0);
	}, 1000);
});

xmppClient.on('error', function(e) {
    console.log("Error occured:");
    console.error(e);
    console.error(e.children);
    process.exit(0);
});