var helpers = (function (helpers) { helpers.oc = function (a) { // Thanks to Jonathan Snook: http://snook.ca var o = {}; for(var i=0; i= 30) { msgs.pop(); } msgs.push(now+' '+direction+' '+msg); store.set(bare_jid, msgs); }; methods.getMessages = function (jid) { return store.get(jid) || []; }; return methods; })(); ob.Messages.getMessages = function (jid, callback) { var bare_jid = Strophe.getBareJidFromJid(jid), msgs = this.ClientStorage.getMessages(bare_jid); callback(msgs); }; ob.Messages.sendMessage = function (jid, text, callback) { // TODO: Look in ChatPartners to see what resources we have for the recipient. // if we have one resource, we sent to only that resources, if we have multiple // we send to the bare jid. // FIXME: see if @@content-transform is required var message, that = this; $.getJSON(portal_url + '/content-transform?', {text: text}, function (data) { message = $msg({to: jid, type: 'chat'}) .c('body').t(data.text).up() .c('active', {'xmlns': 'http://jabber.org/protocol/chatstates'}); xmppchat.connection.send(message); that.ClientStorage.addMessage(jid, data.text, 'to'); callback(); }); }; ob.Messages.messageReceived = function (message) { var jid = $(message).attr('from'), bare_jid = Strophe.getBareJidFromJid(jid), resource = Strophe.getResourceFromJid(jid), delayed = $(message).find('delay').length > 0; ob.ChatPartners.add(bare_jid, resource); var body = $(message).children('body').text(); if (body === "") { // TODO: return true; // This is a typing notification, we do not handle it here... } var xhtml_body = $(message).find('html > body').contents(), event = jQuery.Event('jarnxmpp.message'); event.from = jid; event.delayed = delayed; if (xhtml_body.length > 0) { event.mtype = 'xhtml'; event.body = xhtml_body.html(); } else { event.body = body; event.mtype = 'text'; } ob.Messages.ClientStorage.addMessage(jid, event.body, 'from'); $(document).trigger(event); return true; }; ob.Collections.getLastCollection = function (jid, callback) { var bare_jid = Strophe.getBareJidFromJid(jid), iq = $iq({'type':'get'}) .c('list', {'xmlns': this.URI, 'with': bare_jid }) .c('set', {'xmlns': 'http://jabber.org/protocol/rsm'}) .c('before').up() .c('max') .t('1'); xmppchat.connection.sendIQ(iq, callback, function () { console.log('Error while retrieving collections'); }); }; ob.Collections.getLastMessages = function (jid, callback) { var that = this; this.getLastCollection(jid, function (result) { // Retrieve the last page of a collection (max 30 elements). var $collection = $(result).find('chat'), jid = $collection.attr('with'), start = $collection.attr('start'), iq = $iq({'type':'get'}) .c('retrieve', {'start': start, 'xmlns': that.URI, 'with': jid }) .c('set', {'xmlns': 'http://jabber.org/protocol/rsm'}) .c('max') .t('30'); xmppchat.connection.sendIQ(iq, callback); }); }; ob.Presence.onlineCount = function () { return xmppchat.ChatPartners.getTotal(); }; ob.Presence.sendPresence = function (type) { if (type === undefined) { type = xmppchat.Storage.get(xmppchat.username+'-xmpp-status') || 'online'; } xmppchat.connection.send($pres({'type':type})); }; ob.Presence.presenceReceived = function (presence) { var jid = $(presence).attr('from'), bare_jid = Strophe.getBareJidFromJid(jid), resource = Strophe.getResourceFromJid(jid), ptype = $(presence).attr('type'), status = ''; if (ptype === 'subscribe') { // User wants to subscribe to us. Always approve and // ask to subscribe to him jarnxmpp.connection.send($pres({to: jid, type: 'subscribed'})); jarnxmpp.connection.send($pres({to: jid, type: 'subscribe'})); } else if (ptype !== 'error') { // Presence has changed if (ptype === 'unavailable') { status = 'unavailable'; } else if (ptype === 'offline') { status = 'offline'; } else if (ptype === 'busy') { status = 'busy'; } else if (ptype === 'away') { status = 'away'; } else { status = ($(presence).find('show').text() === '') ? 'online' : 'away'; } if ((status !== 'offline')&&(status !== 'unavilable')) { xmppchat.ChatPartners.add(bare_jid, resource); } else { xmppchat.ChatPartners.remove(bare_jid, resource); } $(document).trigger('jarnxmpp.presence', [jid, status, presence]); } return true; }; ob.Taskbuffer = (function ($) { buffer = {}; buffer.tasks = []; buffer.deferred = $.when(); buffer.handleTasks = function () { var task; // If the current deferred task is resolved and there are more tasks if (buffer.deferred.isResolved() && buffer.tasks.length > 0) { // Get the next task in the queue and set the new deferred. task = buffer.tasks.shift(); buffer.deferred = $.when(task.method.apply(task.that, task.parameters)); if (buffer.tasks.length > 0) { buffer.deferred.done(buffer.handleTasks); } } }; return buffer; })(jQuery); return ob; })(jarnxmpp || {}, jQuery, console || {log: function(){}});