/* Jappix - An open social platform These are the microblog JS scripts for Jappix ------------------------------------------------- License: AGPL Author: Vanaryon Last revision: 03/12/11 */ // Completes arrays of an entry's attached files function attachedMicroblog(selector, tFName, tFURL, tFThumb, tFSource, tFType, tFLength, tFEComments, tFNComments) { if($(selector).attr('title')) tFName.push($(selector).attr('title')); else tFName.push(''); if($(selector).attr('href')) tFURL.push($(selector).attr('href')); else tFURL.push(''); if($(selector).find('link[rel=self][title=thumb]:first').attr('href')) tFThumb.push($(selector).find('link[rel=self][title=thumb]:first').attr('href')); else tFThumb.push(''); if($(selector).attr('source')) tFSource.push($(selector).attr('source')); else tFSource.push(''); if($(selector).attr('type')) tFType.push($(selector).attr('type')); else tFType.push(''); if($(selector).attr('length')) tFLength.push($(selector).attr('length')); else tFLength.push(''); // Comments? var comments_href_c = $(selector).find('link[rel=replies][title=comments_file]:first').attr('href'); if(comments_href_c && comments_href_c.match(/^xmpp:(.+)\?;node=(.+)/)) { tFEComments.push(RegExp.$1); tFNComments.push(decodeURIComponent(RegExp.$2)); } else { tFEComments.push(''); tFNComments.push(''); } } // Displays a given microblog item function displayMicroblog(packet, from, hash, mode, way) { // Get some values var iParse = $(packet.getNode()).find('items item'); iParse.each(function() { // Initialize var tTitle, tFiltered, tTime, tDate, tStamp, tBody, tName, tID, tHash, tIndividual, tFEClick; // Arrays var tFName = []; var tFURL = []; var tFThumb = []; var tFSource = []; var tFType = []; var tFLength = []; var tFEComments = []; var tFNComments = []; var aFURL = []; var aFCat = []; // Get the values tDate = $(this).find('published').text(); tBody = $(this).find('body').text(); tID = $(this).attr('id'); tName = getBuddyName(from); tHash = 'update-' + hex_md5(tName + tDate + tID); // Read attached files with a thumb (place them at first) $(this).find('link[rel=enclosure]:has(link[rel=self][title=thumb])').each(function() { attachedMicroblog(this, tFName, tFURL, tFThumb, tFSource, tFType, tFLength, tFEComments, tFNComments); }); // Read attached files without any thumb $(this).find('link[rel=enclosure]:not(:has(link[rel=self][title=thumb]))').each(function() { attachedMicroblog(this, tFName, tFURL, tFThumb, tFSource, tFType, tFLength, tFEComments, tFNComments); }); // Get the repeat value var uRepeat = [$(this).find('source author name').text(), explodeThis(':', $(this).find('source author uri').text(), 1)]; var uRepeated = false; if(!uRepeat[0]) uRepeat = [getBuddyName(from), uRepeat[1]]; if(!uRepeat[1]) uRepeat = [uRepeat[0], from]; // Repeated? if(uRepeat[1] != from) uRepeated = true; // Get the comments node var entityComments, nodeComments; // Get the comments var comments_href = $(this).find('link[title=comments]:first').attr('href'); if(comments_href && comments_href.match(/^xmpp:(.+)\?;node=(.+)/)) { entityComments = RegExp.$1; nodeComments = decodeURIComponent(RegExp.$2); } // No comments node? if(!entityComments || !nodeComments) { entityComments = ''; nodeComments = ''; } // Get the stamp & time if(tDate) { tStamp = extractStamp(Date.jab2date(tDate)); tTime = relativeDate(tDate); } else { tStamp = getTimeStamp(); tTime = ''; } // Get the item geoloc var tGeoloc = ''; var sGeoloc = $(this).find('geoloc[xmlns=' + NS_GEOLOC + ']:first'); var gLat = sGeoloc.find('lat').text(); var gLon = sGeoloc.find('lon').text(); if(gLat && gLon) { tGeoloc += ''; // Human-readable name? var gHuman = humanPosition( sGeoloc.find('locality').text(), sGeoloc.find('region').text(), sGeoloc.find('country').text() ); if(gHuman) tGeoloc += gHuman.htmlEnc(); else tGeoloc += gLat.htmlEnc() + '; ' + gLon.htmlEnc(); tGeoloc += ''; } // Retrieve the message body tTitle = $(this).find('content[type=text]').text(); if(!tTitle) { // Legacy? tTitle = $(this).find('title:not(source > title)').text(); // Last chance? if(!tTitle) tTitle = tBody; } // Trim the content tTitle = trim(tTitle); // Any content? if(tTitle) { // Apply links to message body tFiltered = filterThisMessage(tTitle, tName.htmlEnc(), true); // Display the received message var html = '
' + '
' + '
' + '' + '
' + '
' + '
' + '

'; // Is it a repeat? if(uRepeated) html += ''; html += '' + tName.htmlEnc() + ' ' + tFiltered + '

' + '

' + tTime + tGeoloc + '

'; // Any file to display? if(tFURL.length) html += '

'; // Generate an array of the files URL for(var a = 0; a < tFURL.length; a++) { // Not enough data? if(!tFURL[a]) continue; // Push the current URL! (YouTube or file) if(tFURL[a].match(/(\w{3,5})(:)(\S+)((\.youtube\.com\/watch(\?v|\?\S+v|\#\!v|\#\!\S+v)\=)|(youtu\.be\/))([^& ]+)((&\S)|(&\S)|\s|$)/gim)) { aFURL.push(trim(RegExp.$8)); aFCat.push('youtube'); } else if(canIntegrateBox(explodeThis('/', tFType[a], 1))) { aFURL.push(tFURL[a]); aFCat.push(fileCategory(explodeThis('/', tFType[a], 1))); } } // Add each file code for(var f = 0; f < tFURL.length; f++) { // Not enough data? if(!tFURL[f]) continue; // Get the file type var tFExt = explodeThis('/', tFType[f], 1); var tFCat = fileCategory(tFExt); var tFLink = tFURL[f]; // Youtube video? if(tFLink.match(/(\w{3,5})(:)(\S+)((\.youtube\.com\/watch(\?v|\?\S+v|\#\!v|\#\!\S+v)\=)|(youtu\.be\/))([^& ]+)((&\S)|(&\S)|\s|$)/gim)) { tFLink = trim(RegExp.$8); tFCat = 'youtube'; } // Supported image/video/sound if(canIntegrateBox(tFExt) || (tFCat == 'youtube')) tFEClick = 'onclick="return applyIntegrateBox(\'' + encodeOnclick(tFLink) + '\', \'' + encodeOnclick(tFCat) + '\', \'' + encodeOnclick(aFURL) + '\', \'' + encodeOnclick(aFCat) + '\', \'' + encodeOnclick(tFEComments) + '\', \'' + encodeOnclick(tFNComments) + '\', \'large\');" '; else tFEClick = ''; // Any thumbnail? if(tFThumb[f]) html += ''; else html += '' + tFName[f].htmlEnc() + ''; } if(tFURL.length) html += '

'; // It's my own notice, we can remove it! if(from == getXID()) html += ''; // Notice from another user else { // User profile html += ''; // If PEP is enabled if(enabledPEP()) html += ''; } html += '
'; // Mixed mode if((mode == 'mixed') && !exists('.mixed .' + tHash)) { // Remove the old element if(way == 'push') $('#channel .content.mixed .one-update.update_' + hash).remove(); // Get the nearest element var nearest = sortElementByStamp(tStamp, '#channel .mixed .one-update'); // Append the content at the right position (date relative) if(nearest == 0) $('#channel .content.mixed').append(html); else $('#channel .one-update[data-stamp=' + nearest + ']:first').before(html); // Show the new item if(way == 'push') $('#channel .content.mixed .one-update.' + tHash).fadeIn('fast'); else $('#channel .content.mixed .one-update.' + tHash).show(); // Remove the old notices to make the DOM lighter var oneUpdate = '#channel .content.mixed .one-update'; if($(oneUpdate).size() > 80) $(oneUpdate + ':last').remove(); // Click event on avatar/name $('.mixed .' + tHash + ' .avatar-container, .mixed .' + tHash + ' .body b').click(function() { getMicroblog(from, hash); }); } // Individual mode tIndividual = '#channel .content.individual.microblog-' + hash; // Can append individual content? var can_individual = true; if($('#channel .top.individual input[name=comments]').val() && exists(tIndividual + ' .one-update')) can_individual = false; if(can_individual && exists(tIndividual) && !exists('.individual .' + tHash)) { if(mode == 'mixed') $(tIndividual).prepend(html); else $(tIndividual + ' a.more').before(html); // Show the new item if(way == 'push') $('#channel .content.individual .one-update.' + tHash).fadeIn('fast'); else $('#channel .content.individual .one-update.' + tHash).show(); // Make 'more' link visible $(tIndividual + ' a.more').css('visibility', 'visible'); // Click event on name (if not me!) if(from != getXID()) $('.individual .' + tHash + ' .avatar-container, .individual .' + tHash + ' .body b').click(function() { checkChatCreate(from, 'chat'); }); } // Apply the click event $('.' + tHash + ' a.repost:not([data-event=true])').click(function() { return publishMicroblog(tTitle, tFName, tFURL, tFType, tFLength, tFThumb, uRepeat, entityComments, nodeComments, tFEComments, tFNComments); }) .attr('data-event', 'true'); // Apply the hover event if(nodeComments) $('.' + mode + ' .' + tHash).hover(function() { showCommentsMicroblog($(this), entityComments, nodeComments, tHash); }, function() { if($(this).find('div.comments a.one-comment.loading').size()) $(this).find('div.comments').remove(); }); } }); // Display the avatar of this buddy getAvatar(from, 'cache', 'true', 'forget'); } // Removes a given microblog item function removeMicroblog(id, hash) { /* REF: http://xmpp.org/extensions/xep-0060.html#publisher-delete */ // Initialize var selector = $('.' + hash); var get_last = false; // Get the latest item for the mixed mode if(exists('#channel .content.mixed .' + hash)) get_last = true; // Remove the item from our DOM selector.fadeOut('fast', function() { $(this).remove(); }); // Send the IQ to remove the item (and get eventual error callback) var iq = new JSJaCIQ(); iq.setType('set'); var pubsub = iq.appendNode('pubsub', {'xmlns': NS_PUBSUB}); var retract = pubsub.appendChild(iq.buildNode('retract', {'node': NS_URN_MBLOG, 'xmlns': NS_PUBSUB})); retract.appendChild(iq.buildNode('item', {'id': id, 'xmlns': NS_PUBSUB})); if(get_last) con.send(iq, handleRemoveMicroblog); else con.send(iq, handleErrorReply); return false; } // Handles the microblog item removal function handleRemoveMicroblog(iq) { // Handle the error reply handleErrorReply(iq); // Get the latest item requestMicroblog(getXID(), '1', false, handleUpdateRemoveMicroblog); } // Handles the microblog update function handleUpdateRemoveMicroblog(iq) { // Error? if(iq.getType() == 'error') return; // Initialize var xid = bareXID(getStanzaFrom(iq)); var hash = hex_md5(xid); // Display the item! displayMicroblog(iq, xid, hash, 'mixed', 'push'); } // Gets a given microblog comments node function getCommentsMicroblog(server, node, id) { /* REF: http://xmpp.org/extensions/xep-0060.html#subscriber-retrieve-requestall */ var iq = new JSJaCIQ(); iq.setType('get'); iq.setID('get_' + genID() + '-' + id); iq.setTo(server); var pubsub = iq.appendNode('pubsub', {'xmlns': NS_PUBSUB}); pubsub.appendChild(iq.buildNode('items', {'node': node, 'xmlns': NS_PUBSUB})); con.send(iq, handleCommentsMicroblog); return false; } // Handles a microblog comments node items function handleCommentsMicroblog(iq) { // Path var id = explodeThis('-', iq.getID(), 1); var path = 'div.comments[data-id=' + id + '] div.comments-content'; // Does not exist? if(!exists(path)) return false; // Any error? if(handleErrorReply(iq)) { $(path).html('
' + _e("Could not get the comments!") + '
'); return false; } // Initialize var data = iq.getNode(); var server = bareXID(getStanzaFrom(iq)); var node = $(data).find('items:first').attr('node'); var users_xid = []; var code = ''; // No node? if(!node) node = $(data).find('publish:first').attr('node'); // Get the parent microblog item var parent_select = $('#channel .one-update:has(*[data-node=' + node + '])'); var parent_data = [parent_select.attr('data-xid'), NS_URN_MBLOG, parent_select.attr('data-id')]; // Get the owner XID var owner_xid = parent_select.attr('data-xid'); var repeat_xid = parent_select.find('a.repeat').attr('data-xid'); // Must we create the complete DOM? var complete = true; if($(path).find('.one-comment.compose').size()) complete = false; // Add the comment tool if(complete) code += '
' + '' + '
'; // Append the comments $(data).find('item').each(function() { // Get comment var current_id = $(this).attr('id'); var current_xid = explodeThis(':', $(this).find('source author uri').text(), 1); var current_name = $(this).find('source author name').text(); var current_date = $(this).find('published').text(); var current_body = $(this).find('content[type=text]').text(); var current_bname = getBuddyName(current_xid); // Legacy? if(!current_body) current_body = $(this).find('title:not(source > title)').text(); // Yet displayed? (continue the loop) if($(path).find('.one-comment[data-id=' + current_id + ']').size()) return; // No XID? if(!current_xid) { current_xid = ''; if(!current_name) current_name = _e("unknown"); } else if(!current_name || (current_bname != getXIDNick(current_xid))) current_name = current_bname; // Any date? if(current_date) current_date = relativeDate(current_date); else current_date = getCompleteTime(); // Click event var onclick = 'false'; if(current_xid != getXID()) onclick = 'checkChatCreate(\'' + encodeOnclick(current_xid) + '\', \'chat\')'; // If this is my comment, add a marker var type = 'him'; var marker = ''; var remove = ''; if(current_xid == getXID()) { type = 'me'; marker = '
'; remove = '' + _e("Remove") + ''; } // New comment? var new_class = ''; if(!complete) new_class = ' new'; // Add the comment if(current_body) { // Add the XID if(!existArrayValue(users_xid, current_xid)) users_xid.push(current_xid); // Add the HTML code code += '
' + marker + '
' + '' + '
' + '
' + '' + current_name.htmlEnc() + '' + '' + current_date.htmlEnc() + '' + remove + '

' + filterThisMessage(current_body, current_name, true) + '

' + '
' + '
' + '
'; } }); // Add the HTML if(complete) { $(path).html(code); // Focus on the compose input $(document).oneTime(10, function() { $(path).find('.one-comment.compose input').focus(); }); } else { $(path).find('.one-comment.compose').after(code); // Beautiful effect $(path).find('.one-comment.new').slideDown('fast', function() { adaptCommentMicroblog(id); }).removeClass('new'); } // Set the good widths adaptCommentMicroblog(id); // Get the avatars for(a in users_xid) getAvatar(users_xid[a], 'cache', 'true', 'forget'); // Add the owner XID if(owner_xid && owner_xid.match('@') && !existArrayValue(users_xid, owner_xid)) users_xid.push(owner_xid); // Add the repeated from XID if(repeat_xid && repeat_xid.match('@') && !existArrayValue(users_xid, repeat_xid)) users_xid.push(repeat_xid); // Remove my own XID removeArrayValue(users_xid, getXID()); // DOM events if(complete) { // Update timer $(path).everyTime('60s', function() { getCommentsMicroblog(server, node, id); logThis('Updating comments node: ' + node + ' on ' + server + '...'); }); // Input key event $(path).find('.one-comment.compose input').placeholder() .keyup(function(e) { if((e.keyCode == 13) && $(this).val()) { // Send the comment! sendCommentMicroblog($(this).val(), server, node, id, users_xid, parent_data); // Reset the input value $(this).val(''); return false; } }); } } // Shows the microblog comments box function showCommentsMicroblog(path, entityComments, nodeComments, tHash) { // Do not display it twice! if(path.find('div.comments').size()) return; // Generate an unique ID var idComments = genID(); // Create comments container path.find('div.comments-container').append( '
' + '
' + '
' + '' + _e("Show comments") + '' + '
' + '
' ); // Click event path.find('div.comments a.one-comment').click(function() { // Set loading info $(this).parent().html('
' + _e("Loading comments...") + '
'); // Request comments getCommentsMicroblog(entityComments, nodeComments, idComments); // Remove the comments from the DOM if click away if(tHash) { $('#channel').die('click'); $('#channel').live('click', function(evt) { if(!$(evt.target).parents('.' + tHash).size()) { $('#channel').die('click'); $('#channel .one-update div.comments-content').stopTime(); $('#channel .one-update div.comments').remove(); } }); } return false; }); } // Sends a comment on a given microblog comments node function sendCommentMicroblog(value, server, node, id, notifiy_arr, parent_data) { /* REF: http://xmpp.org/extensions/xep-0060.html#publisher-publish */ // Not enough data? if(!value || !server || !node) return false; // Get some values var date = getXMPPTime('utc'); var hash = hex_md5(value + date); // New IQ var iq = new JSJaCIQ(); iq.setType('set'); iq.setTo(server); iq.setID('set_' + genID() + '-' + id); // PubSub main elements var pubsub = iq.appendNode('pubsub', {'xmlns': NS_PUBSUB}); var publish = pubsub.appendChild(iq.buildNode('publish', {'node': node, 'xmlns': NS_PUBSUB})); var item = publish.appendChild(iq.buildNode('item', {'id': hash, 'xmlns': NS_PUBSUB})); var entry = item.appendChild(iq.buildNode('entry', {'xmlns': NS_ATOM})); // Author infos var Source = entry.appendChild(iq.buildNode('source', {'xmlns': NS_ATOM})); var author = Source.appendChild(iq.buildNode('author', {'xmlns': NS_ATOM})); author.appendChild(iq.buildNode('name', {'xmlns': NS_ATOM}, getName())); author.appendChild(iq.buildNode('uri', {'xmlns': NS_ATOM}, 'xmpp:' + getXID())); // Create the comment entry.appendChild(iq.buildNode('content', {'type': 'text', 'xmlns': NS_ATOM}, value)); entry.appendChild(iq.buildNode('published', {'xmlns': NS_ATOM}, date)); con.send(iq); // Handle this comment! iq.setFrom(server); handleCommentsMicroblog(iq); // Notify users if(notifiy_arr && notifiy_arr.length) { // XMPP link to the item var href = 'xmpp:' + server + '?;node=' + encodeURIComponent(node) + ';item=' + encodeURIComponent(hash); // Loop! for(n in notifiy_arr) sendNotification(notifiy_arr[n], 'comment', href, value, parent_data); } return false; } // Removes a given microblog comment item function removeCommentMicroblog(server, node, id) { /* REF: http://xmpp.org/extensions/xep-0060.html#publisher-delete */ // Remove the item from our DOM $('.one-comment[data-id=' + id + ']').slideUp('fast', function() { // Get the parent ID var parent_id = $(this).parents('div.comments').attr('data-id'); // Remove it! $(this).remove(); // Adapt the width adaptCommentMicroblog(parent_id); }); // Send the IQ to remove the item (and get eventual error callback) var iq = new JSJaCIQ(); iq.setType('set'); iq.setTo(server); var pubsub = iq.appendNode('pubsub', {'xmlns': NS_PUBSUB}); var retract = pubsub.appendChild(iq.buildNode('retract', {'node': node, 'xmlns': NS_PUBSUB})); retract.appendChild(iq.buildNode('item', {'id': id, 'xmlns': NS_PUBSUB})); con.send(iq); return false; } // Adapts the comment elements width function adaptCommentMicroblog(id) { var selector = $('div.comments[data-id=' + id + '] div.comments-content'); var selector_width = selector.width(); // Change widths selector.find('.one-comment.compose input').css('width', selector_width - 60); selector.find('.one-comment .comment-container').css('width', selector_width - 55); } // Handles the microblog of an user function handleMicroblog(iq) { // Get the from attribute of this IQ var from = bareXID(getStanzaFrom(iq)); // Define the selector path var selector = '#channel .top.individual input[name='; // Is this request still alive? if(from == $(selector + 'jid]').val()) { var hash = hex_md5(from); // Update the items counter var old_count = parseInt($(selector + 'counter]').val()); $(selector + 'counter]').val(old_count + 20); // Display the microblog displayMicroblog(iq, from, hash, 'individual', 'request'); // Hide the waiting icon if(enabledPEP()) waitMicroblog('sync'); else waitMicroblog('unsync'); // Hide the 'more items' link? if($(iq.getNode()).find('item').size() < old_count) $('#channel .individual a.more').remove(); // Get the comments? var comments_node = $('#channel .top.individual input[name=comments]').val(); if(comments_node && comments_node.match(/^xmpp:(.+)\?;node=(.+);item=(.+)/)) { // Get the values var comments_entity = RegExp.$1; comments_node = decodeURIComponent(RegExp.$2); // Selectors var file_link = $('#channel .individual .one-update p.file a[data-node=' + comments_node + ']'); var entry_link = $('#channel .individual .one-update:has(*[data-node=' + comments_node + '])'); // Is it a file? if(file_link.size()) file_link.click(); // Is it a microblog entry? else if(entry_link.size()) { showCommentsMicroblog(entry_link, comments_entity, comments_node); entry_link.find('a.one-comment').click(); } } } logThis('Microblog got: ' + from, 3); } // Resets the microblog elements function resetMicroblog() { // Reset everything $('#channel .individual .one-update div.comments-content').stopTime(); $('#channel .individual').remove(); $('#channel .mixed').show(); // Hide the waiting icon if(enabledPEP()) waitMicroblog('sync'); else waitMicroblog('unsync'); return false; } // Gets the user's microblog to check it exists function getInitMicroblog() { getMicroblog(getXID(), hex_md5(getXID()), true); } // Handles the user's microblog to create it in case of error function handleInitMicroblog(iq) { // Any error? if((iq.getType() == 'error') && $(iq.getNode()).find('item-not-found').size()) { // The node may not exist, create it! setupMicroblog('', NS_URN_MBLOG, '1', '1000000', '', '', true); logThis('Error while getting microblog, trying to reconfigure the Pubsub node!', 2); } } // Requests an user's microblog function requestMicroblog(xid, items, get_item, handler) { // Ask the server the user's microblog var iq = new JSJaCIQ(); iq.setType('get'); iq.setTo(xid); var pubsub = iq.appendNode('pubsub', {'xmlns': NS_PUBSUB}); var ps_items = pubsub.appendChild(iq.buildNode('items', {'node': NS_URN_MBLOG, 'xmlns': NS_PUBSUB})); // Request a particular item? if(get_item) ps_items.appendChild(iq.buildNode('item', {'id': get_item, 'xmlns': NS_PUBSUB})); else ps_items.setAttribute('max_items', items); if(handler) con.send(iq, handler); else con.send(iq, handleMicroblog); return false; } // Gets the microblog of an user function getMicroblog(xid, hash, check) { /* REF: http://xmpp.org/extensions/xep-0060.html#subscriber-retrieve */ logThis('Get the microblog: ' + xid, 3); // Fire the wait event waitMicroblog('fetch'); // XMPP URI? var get_item = ''; if(xid.match(/^xmpp:(.+)\?;node=(.+);item=(.+)/)) { xid = RegExp.$1; get_item = decodeURIComponent(RegExp.$3); } // No hash? if(!hash) hash = hex_md5(xid); // Can display the individual channel? if(!check && !exists('#channel .individual')) { // Hide the mixed channel $('#channel .mixed').hide(); // Get the channel title depending on the XID var cTitle; var cShortcuts = ''; if(xid == getXID()) cTitle = _e("Your channel"); else { cTitle = _e("Channel of") + ' ' + getBuddyName(xid).htmlEnc(); cShortcuts = '
' + '' + '' + '' + '' + '
'; } // Create a new individual channel $('#channel .content.mixed').after( '
' + '' + _e("More notices...") + '' + '
' ) .before( '
' + '
' + '' + '
' + '
' + '

' + cTitle + '

' + '« ' + _e("Previous") + '' + '
' + cShortcuts + '' + '' + '
' ); // Display the user avatar getAvatar(xid, 'cache', 'true', 'forget'); } // Get the number of items to retrieve var items = '0'; if(!check) items = $('#channel .top.individual input[name=counter]').val(); // Request if(check) requestMicroblog(xid, items, get_item, handleInitMicroblog); else requestMicroblog(xid, items, get_item, handleMicroblog); return false; } // Show a given microblog waiting status function waitMicroblog(type) { // First hide all the infos elements $('#channel .footer div').hide(); // Display the good one $('#channel .footer div.' + type).show(); // Depending on the type, disable/enable certain tools var selector = $('#channel .top input[name=microblog_body]'); if(type == 'unsync') selector.attr('disabled', true); else if(type == 'sync') $(document).oneTime(10, function() { selector.removeAttr('disabled').focus(); }); } // Setups a new microblog function setupMicroblog(entity, node, persist, maximum, access, publish, create) { /* REF: http://xmpp.org/extensions/xep-0060.html#owner-create-and-configure */ // Create the PubSub node var iq = new JSJaCIQ(); iq.setType('set'); // Any external entity? if(entity) iq.setTo(entity); // Create it? if(create) { var pubsub = iq.appendNode('pubsub', {'xmlns': NS_PUBSUB}); pubsub.appendChild(iq.buildNode('create', {'xmlns': NS_PUBSUB, 'node': node})); } else var pubsub = iq.appendNode('pubsub', {'xmlns': NS_PUBSUB_OWNER}); // Configure it! var configure = pubsub.appendChild(iq.buildNode('configure', {'node': node, 'xmlns': NS_PUBSUB})); var x = configure.appendChild(iq.buildNode('x', {'xmlns': NS_XDATA, 'type': 'submit'})); var field1 = x.appendChild(iq.buildNode('field', {'var': 'FORM_TYPE', 'type': 'hidden', 'xmlns': NS_XDATA})); field1.appendChild(iq.buildNode('value', {'xmlns': NS_XDATA}, NS_PUBSUB_NC)); // Persist items? if(persist) { var field2 = x.appendChild(iq.buildNode('field', {'var': 'pubsub#persist_items', 'xmlns': NS_XDATA})); field2.appendChild(iq.buildNode('value', {'xmlns': NS_XDATA}, persist)); } // Maximum items? if(maximum) { var field3 = x.appendChild(iq.buildNode('field', {'var': 'pubsub#max_items', 'xmlns': NS_XDATA})); field3.appendChild(iq.buildNode('value', {'xmlns': NS_XDATA}, maximum)); } // Access rights? if(access) { var field4 = x.appendChild(iq.buildNode('field', {'var': 'pubsub#access_model', 'xmlns': NS_XDATA})); field4.appendChild(iq.buildNode('value', {'xmlns': NS_XDATA}, access)); } // Publish rights? if(publish) { var field5 = x.appendChild(iq.buildNode('field', {'var': 'pubsub#publish_model', 'xmlns': NS_XDATA})); field5.appendChild(iq.buildNode('value', {'xmlns': NS_XDATA}, publish)); } con.send(iq); } // Gets the microblog configuration function getConfigMicroblog() { // Lock the microblog options $('#persistent, #maxnotices').attr('disabled', true); // Get the microblog configuration var iq = new JSJaCIQ(); iq.setType('get'); var pubsub = iq.appendNode('pubsub', {'xmlns': NS_PUBSUB_OWNER}); pubsub.appendChild(iq.buildNode('configure', {'node': NS_URN_MBLOG, 'xmlns': NS_PUBSUB_OWNER})); con.send(iq, handleGetConfigMicroblog); } // Handles the microblog configuration function handleGetConfigMicroblog(iq) { // Reset the options stuffs waitOptions('microblog'); // Unlock the microblog options $('#persistent, #maxnotices').removeAttr('disabled'); // End if not a result if(!iq || (iq.getType() != 'result')) return; // Initialize the values var selector = $(iq.getNode()); var persistent = '0'; var maxnotices = '1000000'; // Get the values var xPersistent = selector.find('field[var=pubsub#persist_items] value:first').text(); var xMaxnotices = selector.find('field[var=pubsub#max_items] value:first').text(); // Any value? if(xPersistent) persistent = xPersistent; if(xMaxnotices) maxnotices = xMaxnotices; // Change the maxnotices value switch(maxnotices) { case '1': case '100': case '1000': case '10000': case '100000': case '1000000': break; default: maxnotices = '1000000'; break; } // Apply persistent value if(persistent == '0') $('#persistent').attr('checked', false); else $('#persistent').attr('checked', true); // Apply maxnotices value $('#maxnotices').val(maxnotices); } // Handles the user's microblog function handleMyMicroblog(packet) { // Reset the entire form $('#channel .top input[name=microblog_body]').removeAttr('disabled').val(''); $('#channel .top input[name=microblog_body]').placeholder(); unattachMicroblog(); // Check for errors handleErrorReply(packet); } // Performs the microblog sender checks function sendMicroblog() { logThis('Send a new microblog item', 3); // Avoid nasty errors try { // Get the values var selector = $('#channel .top input[name=microblog_body]'); var body = trim(selector.val()); // Sufficient parameters if(body) { // Disable & blur our input selector.attr('disabled', true).blur(); // Files array var fName = []; var fType = []; var fLength = []; var fURL = []; var fThumb = []; // Read the files $('#attach .one-file').each(function() { // Push the values! fName.push($(this).find('a.link').text()); fType.push($(this).attr('data-type')); fLength.push($(this).attr('data-length')); fURL.push($(this).find('a.link').attr('href')); fThumb.push($(this).attr('data-thumb')); }); // Containing YouTube videos? var yt_matches = body.match(/(\w{3,5})(:)(\S+)((\.youtube\.com\/watch(\?v|\?\S+v|\#\!v|\#\!\S+v)\=)|(youtu\.be\/))([^& ]+)((&\S)|(&\S)|\s|$)/gim); for(y in yt_matches) { fName.push(''); fType.push('text/html'); fLength.push(''); fURL.push(trim(yt_matches[y])); fThumb.push('https://img.youtube.com/vi/' + trim(yt_matches[y].replace(/(\w{3,5})(:)(\S+)((\.youtube\.com\/watch(\?v|\?\S+v|\#\!v|\#\!\S+v)\=)|(youtu\.be\/))([^& ]+)((&\S)|(&\S)|\s|$)/gim, '$8')) + '/0.jpg'); } // Send the message on the XMPP network publishMicroblog(body, fName, fURL, fType, fLength, fThumb); } } // Return false (security) finally { return false; } } // Publishes a given microblog item function publishMicroblog(body, attachedname, attachedurl, attachedtype, attachedlength, attachedthumb, repeat, comments_entity, comments_node, comments_entity_file, comments_node_file) { /* REF: http://xmpp.org/extensions/xep-0277.html */ // Generate some values var time = getXMPPTime('utc'); var id = hex_md5(body + time); var nick = getName(); var xid = getXID(); // Define repeat options var author_nick = nick; var author_xid = xid; if(repeat && repeat.length) { author_nick = repeat[0]; author_xid = repeat[1]; } // Define comments options var node_create = false; if(!comments_entity || !comments_node) { node_create = true; comments_entity = HOST_PUBSUB; comments_node = NS_URN_MBLOG + ':comments/' + id; } if(!comments_entity_file) comments_entity_file = []; if(!comments_node_file) comments_node_file = []; // Don't create another comments node if only 1 file is attached if(attachedurl && (attachedurl.length == 1) && (!comments_entity_file[0] || !comments_node_file[0])) { comments_entity_file = [comments_entity]; comments_node_file = [comments_node]; } // New IQ var iq = new JSJaCIQ(); iq.setType('set'); iq.setTo(xid); // Create the main XML nodes/childs var pubsub = iq.appendNode('pubsub', {'xmlns': NS_PUBSUB}); var publish = pubsub.appendChild(iq.buildNode('publish', {'node': NS_URN_MBLOG, 'xmlns': NS_PUBSUB})); var item = publish.appendChild(iq.buildNode('item', {'id': id, 'xmlns': NS_PUBSUB})); var entry = item.appendChild(iq.buildNode('entry', {'xmlns': NS_ATOM})); // Create the XML source childs var Source = entry.appendChild(iq.buildNode('source', {'xmlns': NS_ATOM})); var author = Source.appendChild(iq.buildNode('author', {'xmlns': NS_ATOM})); author.appendChild(iq.buildNode('name', {'xmlns': NS_ATOM}, author_nick)); author.appendChild(iq.buildNode('uri', {'xmlns': NS_ATOM}, 'xmpp:' + author_xid)); // Create the XML entry childs entry.appendChild(iq.buildNode('content', {'type': 'text', 'xmlns': NS_ATOM}, body)); entry.appendChild(iq.buildNode('published', {'xmlns': NS_ATOM}, time)); entry.appendChild(iq.buildNode('updated', {'xmlns': NS_ATOM}, time)); entry.appendChild(iq.buildNode('link', { 'rel': 'alternate', 'href': 'xmpp:' + xid + '?;node=' + encodeURIComponent(NS_URN_MBLOG) + ';item=' + encodeURIComponent(id), 'xmlns': NS_ATOM })); // Create the attached files nodes for(var i = 0; i < attachedurl.length; i++) { // Not enough data? if(!attachedurl[i]) continue; // Append a new file element var file = entry.appendChild(iq.buildNode('link', {'xmlns': NS_ATOM, 'rel': 'enclosure', 'href': attachedurl[i]})); // Add attributes if(attachedname[i]) file.setAttribute('title', attachedname[i]); if(attachedtype[i]) file.setAttribute('type', attachedtype[i]); if(attachedlength[i]) file.setAttribute('length', attachedlength[i]); // Any thumbnail? if(attachedthumb[i]) file.appendChild(iq.buildNode('link', {'xmlns': NS_URN_MBLOG, 'rel': 'self', 'title': 'thumb', 'type': attachedtype[i], 'href': attachedthumb[i]})); // Any comments node? if(!comments_entity_file[i] || !comments_node_file[i]) { // Generate values comments_entity_file[i] = HOST_PUBSUB; comments_node_file[i] = NS_URN_MBLOG + ':comments/' + hex_md5(attachedurl[i] + attachedname[i] + attachedtype[i] + attachedlength[i] + time); // Create the node setupMicroblog(comments_entity_file[i], comments_node_file[i], '1', '1000000', 'open', 'open', true); } file.appendChild(iq.buildNode('link', {'xmlns': NS_URN_MBLOG, 'rel': 'replies', 'title': 'comments_file', 'href': 'xmpp:' + comments_entity_file[i] + '?;node=' + encodeURIComponent(comments_node_file[i])})); } // Create the comments child entry.appendChild(iq.buildNode('link', {'xmlns': NS_ATOM, 'rel': 'replies', 'title': 'comments', 'href': 'xmpp:' + comments_entity + '?;node=' + encodeURIComponent(comments_node)})); // Create the geoloc child var geoloc_xml = getDB('geolocation', 'now'); if(geoloc_xml) { // Create two position arrays var geo_names = ['lat', 'lon', 'country', 'countrycode', 'region', 'postalcode', 'locality', 'street', 'building', 'text', 'uri', 'timestamp']; var geo_values = parsePosition(XMLFromString(geoloc_xml)); // New geoloc child var geoloc = entry.appendChild(iq.buildNode('geoloc', {'xmlns': NS_GEOLOC})); // Append the geoloc content for(var g = 0; g < geo_names.length; g++) { if(geo_names[g] && geo_values[g]) geoloc.appendChild(iq.buildNode(geo_names[g], {'xmlns': NS_GEOLOC}, geo_values[g])); } } // Send the IQ con.send(iq, handleMyMicroblog); // Create the XML comments PubSub nodes if(node_create) setupMicroblog(comments_entity, comments_node, '1', '1000000', 'open', 'open', true); return false; } // Attaches a file to a microblog post function attachMicroblog() { // File upload vars var attach_options = { dataType: 'xml', beforeSubmit: waitMicroblogAttach, success: handleMicroblogAttach }; // Upload form submit event $('#attach').submit(function() { if(!exists('#attach .wait') && $('#attach input[type=file]').val()) $(this).ajaxSubmit(attach_options); return false; }); // Upload input change event $('#attach input[type=file]').change(function() { if(!exists('#attach .wait') && $(this).val()) $('#attach').ajaxSubmit(attach_options); return false; }); } // Unattaches a microblog file function unattachMicroblog(id) { // Individual removal? if(id) $('#attach .one-file[data-id=' + id + ']').remove(); else $('#attach .one-file').remove(); // Must enable the popup again? if(!exists('#attach .one-file')) { // Restore the bubble class $('#attach').addClass('bubble'); // Enable the bubble click events if(id) { $('#attach').hide(); showBubble('#attach'); } else closeBubbles(); } return false; } // Wait event for file attaching function waitMicroblogAttach() { // Append the wait icon $('#attach input[type=submit]').after('
'); // Lock the bubble $('#attach').removeClass('bubble'); } // Success event for file attaching function handleMicroblogAttach(responseXML) { // Data selector var dData = $(responseXML).find('jappix'); // Process the returned data if(!dData.find('error').size()) { // Do not allow this bubble to be hidden $('#attach').removeClass('bubble'); // Get the file values var fName = dData.find('title').text(); var fType = dData.find('type').text(); var fLength = dData.find('length').text(); var fURL = dData.find('href').text(); var fThumb = dData.find('thumb').text(); // Generate a file ID var fID = hex_md5(fURL); // Add this file $('#attach .attach-subitem').append( '
' + '' + '' + fName.htmlEnc() + '' + '
' ); // Click event $('#attach .one-file[data-id=' + fID + '] a.remove').click(function() { return unattachMicroblog(fID); }); logThis('File attached.', 3); } // Any error? else { openThisError(4); // Unlock the bubble? if(!exists('#attach .one-file')) { $('#attach').addClass('bubble').hide(); // Show the bubble again! showBubble('#attach'); } logThis('Error while attaching the file: ' + dData.find('error').text(), 1); } // Reset the attach bubble $('#attach input[type=file]').val(''); $('#attach .wait').remove(); // Focus on the text input $(document).oneTime(10, function() { $('#channel .top input[name=microblog_body]').focus(); }); } // Shows the microblog of an user from his infos function fromInfosMicroblog(xid, hash) { // Renitialize the channel resetMicroblog(); // Switch to the channel switchChan('channel'); // Get the microblog getMicroblog(xid, hash); } // Addon launcher function launchMicroblog() { // Keyboard event $('#channel .top input[name=microblog_body]').keyup(function(e) { // Enter pressed: send the microblog notice if((e.keyCode == 13) && !exists('#attach .wait')) return sendMicroblog(); }) // Placeholder .placeholder(); // Microblog file attacher attachMicroblog(); }