eldonilo/lightstring: lightstring.js comparison

comparison lightstring.js @ 97:11e38a9bfe38

multi-transport is now possible

author	Sonny Piers <sonny.piers@gmail.com>
date	Tue, 12 Jun 2012 16:35:27 +0200
parents	b211a00efa7f
children	f14558915187

comparison

equal deleted inserted replaced

-:646695bde8e9
+:11e38a9bfe38
 if (!this.jid.bare)
 return; //TODO: error
 if (!this.service)
 return; //TODO: error
-// Standard
+function getProtocol(aURL) {
-if (typeof(WebSocket) === 'function')
+var a = document.createElement('a');
-this.socket = new WebSocket(this.service, 'xmpp');
+a.href = aURL;
-// Safari
+return a.protocol.replace(':', '');
-else if (typeof(WebSocket) === 'object')
+}
-this.socket = new WebSocket(this.service, 'xmpp');
+var protocol = getProtocol(this.service);
-// Old Gecko
-else if (typeof(MozWebSocket) === 'function') {
+if (protocol.match('http'))
-this.socket = new MozWebSocket(this.service, 'xmpp');
+this.connection = new Lightstring.BOSHConnection(this.service);
-}
+else if (protocol.match('ws'))
-// No known WebSocket support
+this.connection = new Lightstring.WebSocketConnection(this.service);
-else {
-return; //TODO: error
+this.connection.connect();
-}
+var that = this;
-var Conn = this;
-this.socket.addEventListener('open', function() {
+this.connection.once('open', function() {
-//FIXME: Opera/Safari WebSocket implementation doesn't support sub-protocol mechanism.
+var stream = Lightstring.stanzas.stream.open(that.jid.domain);
-//if (this.protocol !== 'xmpp')
+that.connection.send(stream);
-//return; //TODO: error
-var stream = Lightstring.stanzas.stream.open(Conn.jid.domain);
-this.send(stream);
 var stanza = {
 XML: stream
 };
-Conn.emit('output', stanza);
+that.emit('output', stanza);
 });
-this.socket.addEventListener('error', function(e) {
+this.connection.on('stanza', function(stanza) {
-Conn.emit('disconnecting', e.data);
+var stanza = new Lightstring.Stanza(stanza);
-//TODO: error
-});
-this.socket.addEventListener('close', function(e) {
-Conn.emit('disconnected', e.data);
-});
-this.socket.addEventListener('message', function(e) {
-var stanza = new Lightstring.Stanza(e.data);
 //FIXME: node-xmpp-bosh sends a self-closing stream:stream tag; it is wrong!
-Conn.emit('input', stanza);
+that.emit('input', stanza);
 if (!stanza.DOM)
 return;
 var name = stanza.DOM.localName;
 if (stanza.DOM.firstChild.localName === 'mechanisms') {
 stanza.mechanisms = [];
 var nodes = stanza.DOM.getElementsByTagName('mechanism');
 for (var i = 0; i < nodes.length; i++)
 stanza.mechanisms.push(nodes[i].textContent);
-Conn.emit('mechanisms', stanza);
+that.emit('mechanisms', stanza);
 }
 //XMPP features
 else {
 //TODO: stanza.features
-Conn.emit('features', stanza);
+that.emit('features', stanza);
 }
 }
 else if (name === 'challenge') {
-Conn.emit('challenge', stanza);
+that.emit('challenge', stanza);
 }
 else if (name === 'failure') {
-Conn.emit('failure', stanza);
+that.emit('failure', stanza);
 }
 else if (name === 'success') {
-Conn.emit('success', stanza);
+that.emit('success', stanza);
 }
 //Iq callbacks
 else if (name === 'iq') {
 var payload = stanza.DOM.firstChild;
 if (payload)
-Conn.emit('iq/' + payload.namespaceURI + ':' + payload.localName, stanza);
+that.emit('iq/' + payload.namespaceURI + ':' + payload.localName, stanza);
 var id = stanza.DOM.getAttribute('id');
-if (!(id && id in Conn.callbacks))
+if (!(id && id in that.callbacks))
 return;
 var type = stanza.DOM.getAttribute('type');
 if (type !== 'result' && type !== 'error')
 return; //TODO: warning
-var callback = Conn.callbacks[id];
+var callback = that.callbacks[id];
 if (type === 'result' && callback.success)
-callback.success.call(Conn, stanza);
+callback.success.call(that, stanza);
 else if (type === 'error' && callback.error)
-callback.error.call(Conn, stanza);
+callback.error.call(that, stanza);
-delete Conn.callbacks[id];
+delete that.callbacks[id];
 }
 else if (name === 'presence' || name === 'message') {
-Conn.emit(name, stanza);
+that.emit(name, stanza);
 }
 });
 },
 /**
 * @function Send a message.
 //FIXME this.socket.send(stanza.XML); (need some work on Lightstring.Stanza)
 var fixme = Lightstring.DOM2XML(stanza.DOM);
 stanza.XML = fixme;
-this.socket.send(fixme);
+this.connection.send(fixme);
 this.emit('output', stanza);
 },
 /**
 * @function Closes the XMPP stream and the socket.
 */