[TIMOB-6212] Android: Add Support for TLS to TCP Sockets

var win = Ti.UI.createWindow({
    backgroundColor: '#fff'
});

var states = {
    WAITING_FOR_FIRST_RESPONSE: 0,
    WAITING_FOR_START_TLS: 1,
    WAITING_FOR_PROCEED: 2,
    WAITING_FOR_SECURED: 3,
    DONE: 4,
    ERRORED: 5
};
var currentState = Ti.Android ? states.WAITING_FOR_FIRST_RESPONSE : states.WAITING_FOR_START_TLS;

var socket = Ti.Network.Socket.createTCP({
    host: 'chat.facebook.com', port: 5222,
    connected: function (e) {
        Ti.API.info('Socket opened!');
        Ti.Stream.pump(e.socket, read, 1024, true);
        socket.write(Ti.createBuffer({
            value: '<stream:stream xmlns:stream="http://etherx.jabber.org/streams" version="1.0" \
                xmlns="jabber:client" to="chat.facebook.com" xml:lang="en" \
                xmlns:xml="http://www.w3.org/XML/1998/namespace">'
        }));
    },
    secured: function (e) {
        Ti.API.info('Socket secured!');
    },
    error: function (e) {
        Ti.API.info('Error (' + e.errorCode + '): ' + e.error);
    },
    closed: function (e) {
        Ti.API.info('Socket closed!');
    }
});
socket.connect();

function write(msg) {
    Ti.API.info('State: ' + currentState + ', Wrote: ' + msg);
    socket.write(Ti.createBuffer({
        value: msg
    }));
}

function read(e) {
    try {
        if (e.buffer) {
            var received = e.buffer.toString();
            Ti.API.info('State: ' + currentState + ', Received: ' + received);
            switch (currentState) {

                case states.WAITING_FOR_FIRST_RESPONSE:
                    if (received.split('<?xml version="1.0"?><stream:stream ').length <= 1) {
                        Ti.API.error('Unexpected response from server while WAITING_FOR_FIRST_RESPONSE!');
                        return currentState = states.ERRORED;
                    }
                    return currentState = states.WAITING_FOR_START_TLS;

                case states.WAITING_FOR_START_TLS:
                    if (received.split('<stream:features><starttls ').length <= 1) {
                        Ti.API.error('Unexpected response from server while WAITING_FOR_START_TLS!');
                        return currentState = states.ERRORED;
                    }
                    write('<starttls xmlns="urn:ietf:params:xml:ns:xmpp-tls"/>');
                    if (!Ti.Android) {
                        // Note: iOS requires that startTLS be called right after sending the above XML.
                        // This is required because of how reads and writes are queued up before a secure handshake.
                        socket.startTLS();
                        return currentState = states.WAITING_FOR_SECURED;
                    }
                    return currentState = states.WAITING_FOR_PROCEED;

                case states.WAITING_FOR_PROCEED:
                    if (received.split('<proceed xmlns="urn:ietf:params:xml:ns:xmpp-tls"/>').length <= 1) {
                        Ti.API.error('Unexpected response from server while WAITING_FOR_PROCEED!');
                        return currentState = states.ERRORED;
                    }
                    socket.startTLS();
                    return currentState = states.WAITING_FOR_SECURED;

                case states.WAITING_FOR_SECURED:
                    write('<stream:stream xmlns:stream="http://etherx.jabber.org/streams" version="1.0" \
                        xmlns="jabber:client" to="chat.facebook.com" xml:lang="en" \
                        xmlns:xml="http://www.w3.org/XML/1998/namespace">');
                    return currentState = states.DONE;

            }
        }
        else {
            Ti.API.error('Error: no e.buffer!');
        }
    } catch (ex) {
        Ti.API.error(ex);
    }
}

win.open();