Mercurial > psgxs
view modules/mod_publish_message.js @ 41:bc717575e66a
Much better handling of modules.
author | Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> |
---|---|
date | Sun, 20 Feb 2011 15:51:12 +0100 |
parents | 6697f394301f |
children | 023f767662d3 |
line wrap: on
line source
exports.publishMessage = { stanza: 'message', child: 'body', func: function(response, stanza, request, to, from) { if (!config.enabled('publish')) return makeError(response, errors.pub.publish.item_publication_not_supported.n); var nodeID = fdsq.toResource(from); if (!nodeID || nodeID == '') return makeError(response, errors.nodeid_required.n); var autocreate = false; if (!storage.existsNode(nodeID)) { if (config.enabled('auto-create')) autocreate = true; else return makeError(response, errors.node_does_not_exist.n); } var affil = storage.getAffiliation(toBareJID(to), nodeID); if (typeof affil == 'number' && affil != errors.node_does_not_exist.n) return makeError(response, affil); if (!autocreate && affil != 'super-owner' && affil != 'owner' && affil != 'publisher' && affil != 'publish-only') return makeError(response, errors.forbidden.n); if (!config.enabled('item-ids')) return makeError(response, errors.itemid_required.n); var itemID = fdsq.makeRandomId(); var now = new Date(); var item = xmpp.stanza('item', {xmlns: NS.PUBSUB, id: itemID}); item.c('entry', {xmlns: NS.ATOM}); if (stanza.getChild('subject')) item.c('title').t(stanza.getChild('subject')).up(); item.c('summary').t(request.getText()).up(); item.c('id').t(itemID).up(); item.c('published').t(now.toString()).up(); item.c('updated').t(now.toString()).up(); if (!config.enabled('persistent-items')) { var notifications = storage.purgeNode(nodeID); if (typeof notifications == 'number') return makeError(response, r); } if (autocreate) { if (!form) form = {}; form['pubsub#creator'] = toBareJID(to); var r = storage.createNode(nodeID, form); if (typeof r == 'number') return makeError(response, r); } var content = item.getChild(); subscribers = storage.setItem(nodeID, itemID, content); if (typeof subscribers == 'number') return makeError(response, subscribers); var attrs = {}; if (content) attrs[itemID] = {content: content}; else attrs[itemID] = {}; notifs.send(subscribers, 'items', nodeID, attrs); response.c('pubsub', {xmlns: NS.PUBSUB}) .c('publish', {node: nodeID}) .c('item', {id: itemID}); return response; } }