PSĜS: psgxs.js annotate

annotate psgxs.js @ 7:781ac4f1e304

Allow others JIDs than super-owners to create nodes.

author	Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
date	Thu, 26 Aug 2010 23:43:45 +0200
parents	2bcadb0531f4
children	efe8dbd34780

rev	line source
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1 #!/usr/bin/env node
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	2
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	3 /*
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	4 * Copyright (C) 2010 Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	5 *
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	6 * This file is part of PSĜS, a PubSub server written in JavaScript.
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	7 *
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	8 * PSĜS is free software: you can redistribute it and/or modify
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	9 * it under the terms of the GNU Affero General Public License as
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	10 * published by the Free Software Foundation, either version 3 of the
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	11 * License.
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	12 *
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	13 * PSĜS is distributed in the hope that it will be useful,
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	14 * but WITHOUT ANY WARRANTY; without even the implied warranty of
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	16 * GNU Affero General Public License for more details.
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	17 *
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	18 * You should have received a copy of the GNU Affero General Public License
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	19 * along with PSĜS. If not, see <http://www.gnu.org/licenses/>.
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	20 */
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	21
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	22 var sys = require('sys');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	23 var xmpp = require('xmpp');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	24 var sha1 = require('sha1');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	25 require('./iso8601');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	26 var storage = require('./storage');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	27 var errors = require('./errors');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	28 var utils = require('./util');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	29 var toBareJID = utils.toBareJID;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	30 var config = require('./configuration');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	31 var forms = require('./forms');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	32 var conn = new xmpp.Connection();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	33
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	34 var service_configuration = config.service_configuration;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	35 var componentJID = config.jid;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	36 var componentPassword = config.password;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	37
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	38 conn.log = function (_, m) { sys.puts(m); };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	39
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	40 function _(m, c) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	41 if (c)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	42 sys.print('\033[1;'+c+'m');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	43 sys.print(sys.inspect(m, false, null));
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	44 if (c)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	45 sys.print('\033[0m');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	46 sys.puts('');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	47 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	48
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	49 function onIq(stanza) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	50 var type = stanza.getAttribute('type');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	51 var from = stanza.getAttribute('to');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	52 var to = stanza.getAttribute('from');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	53 var id = stanza.getAttribute('id');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	54
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	55 var response;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	56 if (id)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	57 response = xmpp.iq({to: to, from: from, type: 'result', id: id});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	58 else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	59 response = xmpp.iq({to: to, from: from, type: 'result'});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	60
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	61 if (type == 'get') {
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	62
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	63 // XEP-0092
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	64 if (stanza.getChild('query', 'jabber:iq:version')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	65 var query = xmpp.stanza('query', {xmlns: 'jabber:iq:version'})
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	66 .s('name').t('PSĜS')
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	67 .s('version').t(config.version)
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	68 .s('os').t(config.os);
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	69 response.cx(query);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	70
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	71 // SECTION 5.1
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	72 } else if (stanza.getChild('query', 'http://jabber.org/protocol/disco#info')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	73 var query = stanza.getChild('query', 'http://jabber.org/protocol/disco#info');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	74 var nodeID = query.getAttribute('node');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	75
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	76 // SECTION 5.3
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	77 if (nodeID && nodeID != '') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	78 if (!storage.existsNode(nodeID))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	79 return makeError(response, errors.node_does_not_exist.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	80
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	81 var conf = storage.getConfiguration(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	82 if (typeof conf == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	83 return makeError(response, conf);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	84
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	85 var type = 'leaf'
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	86 if (conf['pubsub#node_type'])
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	87 type = conf['pubsub#node_type'];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	88
6 2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	89 var q = xmpp.stanza('query', {xmlns: 'http://jabber.org/protocol/disco#info', node: nodeID})
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	90 q.s('identity', {category: 'pubsub', type: type});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	91 q.s('feature', {'var': 'http://jabber.org/protocol/pubsub'});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	92
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	93 // SECTION 5.4
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	94 if (config.enabled('meta-data')) {
4 4c93e76fa371 Ensure that the creator of a node is the default owner; don’t crash Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 3 diff changeset	95 var x = forms.build('result', 'node_metadata', storage.getMetadata(nodeID), true);
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	96 if (x)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	97 q.cx(x);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	98 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	99 response.cx(q);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	100
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	101 // SECTION 5.1
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	102 } else {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	103 var q = xmpp.stanza('query', {xmlns: 'http://jabber.org/protocol/disco#info'})
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	104 .s('identity', {category: 'pubsub', type: 'service', name: 'PubSub JavaScript Server'})
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	105 .s('feature', {'var': 'http://jabber.org/protocol/disco#info'})
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	106 .s('feature', {'var': 'http://jabber.org/protocol/disco#items'})
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	107 .s('feature', {'var': 'http://jabber.org/protocol/pubsub'})
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	108 .s('feature', {'var': 'jabber:iq:version'})
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	109 // .s('feature', {'var': 'http://jabber.org/protocol/commands'})
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	110 for (var i in config.activated)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	111 if (typeof i == 'string')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	112 q.s('feature', {'var': 'http://jabber.org/protocol/pubsub#' + config.activated[i]});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	113 response.cx(q);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	114 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	115
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	116 // SECTION 5.2
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	117 } else if (stanza.getChild('query', 'http://jabber.org/protocol/disco#items')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	118 var query = stanza.getChild('query', 'http://jabber.org/protocol/disco#items');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	119 var q;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	120 var children;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	121 var nodeID = query.getAttribute('node');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	122 if (nodeID && nodeID != '') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	123 if (!storage.existsNode(nodeID))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	124 return makeError(response, errors.node_does_not_exist.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	125
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	126 q = xmpp.stanza('query', {xmlns: 'http://jabber.org/protocol/disco#items', node: nodeID});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	127
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	128 children = storage.getChildren(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	129 if (typeof children == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	130 return makeError(response, children);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	131 } else {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	132 q = xmpp.stanza('query', {xmlns: 'http://jabber.org/protocol/disco#items'});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	133
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	134 children = storage.getChildren();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	135 if (typeof children == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	136 return makeError(response, children);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	137 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	138
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	139 for (var i in children) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	140 var attr = {jid: componentJID};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	141 if (children[i] == 'node') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	142 if (config.enabled('meta-data')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	143 var metadata = storage.getMetadata(i);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	144 if (metadata['pubsub#title'])
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	145 attr.name = metadata['pubsub#title'];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	146 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	147 attr.node = i;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	148
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	149 // SECTION 5.5
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	150 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	151 attr.name = i;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	152
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	153 q.s('item', attr);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	154 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	155 response.cx(q);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	156 } else if (stanza.getChild('pubsub', 'http://jabber.org/protocol/pubsub')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	157 var pubsub = stanza.getChild('pubsub', 'http://jabber.org/protocol/pubsub');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	158
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	159 // SECTION 5.6
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	160 if (pubsub.getChild('subscriptions')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	161 if (!config.enabled('retrieve-subscriptions'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	162 return makeError(response, errors.subscriptions_retrieval_not_supported.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	163
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	164 var subscriptions = pubsub.getChild('subscriptions');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	165 var subs;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	166
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	167 var nodeID = subscriptions.getAttribute('node');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	168 if (nodeID && nodeID != '') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	169 if (!storage.existsNode(nodeID))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	170 return makeError(response, errors.node_does_not_exist.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	171 subs = storage.getSubscription(toBareJID(to), node);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	172 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	173 subs = storage.getSubscription(toBareJID(to));
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	174
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	175 var s = xmpp.stanza('subscriptions');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	176 for (i in subs)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	177 s.s('subscription', {node: i, jid: to, subscription: subs[i].type, subid: subs[i].subid});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	178
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	179 var p = xmpp.stanza('pubsub', {xmlns: 'http://jabber.org/protocol/pubsub'});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	180 p.cx(s);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	181 response.cx(p);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	182
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	183 // SECTION 5.7
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	184 } else if (pubsub.getChild('affiliations')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	185 if (!config.enabled('retrieve-affiliations'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	186 return makeError(response, errors.affiliations_retrieval_not_supported.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	187
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	188 var affiliations = pubsub.getChild('affiliations');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	189 var nodeID = affiliations.getAttribute('node');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	190 var affils;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	191 if (nodeID && nodeID != '') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	192 if (!storage.existsNode(nodeID))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	193 return makeError(response, errors.node_does_not_exist.n);
6 2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	194 affils = {};
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	195 affils[nodeID] = storage.getAffiliation(toBareJID(to), nodeID);
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	196 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	197 affils = storage.getAffiliationsFromJID(toBareJID(to));
6 2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	198
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	199 var s = xmpp.stanza('affiliations');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	200 for (i in affils)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	201 s.s('affiliation', {node: i, affiliation: affils[i]});
6 2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	202
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	203 var p = xmpp.stanza('pubsub', {xmlns: 'http://jabber.org/protocol/pubsub'});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	204 p.cx(s);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	205 response.cx(p);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	206
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	207 // SECTION 6.3.2
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	208 } else if (pubsub.getChild('options')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	209 if (!config.enabled('subscription-options'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	210 return makeError(response, errors.sub.configure.subscription_options_not_supported.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	211
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	212 var options = pubsub.getChild('options');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	213
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	214 var nodeID = options.getAttribute('node');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	215 if (!nodeID \|\| nodeID == '')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	216 return makeError(response, errors.nodeid_required.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	217 if (!storage.existsNode(nodeID))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	218 return makeError(response, errors.node_does_not_exist.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	219
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	220 var jid = options.getAttribute('jid');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	221 if (!jid)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	222 return makeError(response, errors.sub.configure.subscriber_jid_required.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	223 if (toBareJID(jid) != toBareJID(to))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	224 return makeError(response, errors.sub.configure.insufficient_privileges.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	225
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	226 var subs = storage.getSubscription(jid, nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	227 if (subs == {})
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	228 return makeError(response, errors.sub.configure.no_such_subscriber.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	229
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	230 var s = xmpp.stanza('options', {node: nodeID, jid: jid});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	231 var p = xmpp.stanza('pubsub', {xmlns: 'http://jabber.org/protocol/pubsub'});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	232 var form = forms.build('form', 'subscribe_options', subs.options, true);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	233 s.cx(form);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	234 p.cx(s);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	235 response.cx(p);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	236
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	237 // SECTION 6.4
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	238 } else if (pubsub.getChild('default')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	239 if (!config.enabled('retrieve-default-sub'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	240 return makeError(response, errors.sub.default_options.default_subscription_configuration_retrieval_not_supported.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	241
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	242 var def = pubsub.getChild('default');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	243
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	244 var nodeID = def.getAttribute('node');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	245 if (nodeID && !storage.existsNode(nodeID))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	246 return makeError(response, errors.node_does_not_exist.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	247
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	248 var p = xmpp.stanza('pubsub', {xmlns: 'http://jabber.org/protocol/pubsub'});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	249 var s;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	250 if (nodeID)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	251 s = xmpp.stanza('default', {node: nodeID});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	252 else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	253 s = xmpp.stanza('default');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	254
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	255 var form = forms.build('form', 'subscribe_options', 'default', false);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	256 s.cx(form);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	257 p.cx(s);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	258 response.cx(p);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	259
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	260 // SECTION 6.5
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	261 } else if (pubsub.getChild('items')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	262 if (!config.enabled('retrieve-items'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	263 return makeError(response, errors.sub.default_options.node_configuration_not_supported.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	264
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	265 var items = pubsub.getChild('items');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	266
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	267 var nodeID = items.getAttribute('node');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	268 if (!nodeID \|\| nodeID == '')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	269 return makeError(response, errors.nodeid_required.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	270 if (!storage.existsNode(nodeID))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	271 return makeError(response, errors.node_does_not_exist.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	272
6 2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	273 var configuration = storage.getConfiguration(nodeID);
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	274 if (configuration['pubsub#access_model'] == 'whitelist') {
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	275 var affil = storage.getAffiliation(toBareJID(to), nodeID);
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	276 if (affil != 'super-owner' && affil != 'owner' && affil != 'publisher' && affil != 'member')
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	277 return makeError(response, errors.pub.publish.insufficient_privileges.n);
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	278 }
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	279
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	280 var item = [];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	281 for (var i=0; i<items.children.length; i++) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	282 var j = items.children[i];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	283 if (j.name == 'item' && j.attr['id'] && j.attr['id'] != '')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	284 item.push(j.attr['id']);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	285 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	286
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	287 var max_items = items.getAttribute('max_items');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	288 if (max_items)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	289 max_items = Number (max_items);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	290
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	291 if (item.length) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	292 var s = xmpp.stanza('items', {node: nodeID});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	293
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	294 for (var i=0; i<item.length; i++) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	295 var j = storage.getItem(nodeID, item[i]);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	296 if (typeof j == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	297 return makeError(response, j);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	298
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	299 var k = xmpp.stanza('item', {id: item[i]})
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	300 k.cx(j);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	301 s.cx(k);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	302 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	303 } else {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	304 var s = xmpp.stanza('items', {node: nodeID});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	305
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	306 var j;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	307 if (max_items)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	308 j = storage.getLastItem(nodeID, max_items);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	309 else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	310 j = storage.getItems(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	311 if (typeof j == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	312 return makeError(response, j);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	313
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	314 var k = 0;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	315 for (var i in j) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	316 var contentItem = xmpp.stanza('item', {id: i}).t(j[i].content);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	317 s.cx(contentItem);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	318 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	319 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	320 var p = xmpp.stanza('pubsub', {xmlns: 'http://jabber.org/protocol/pubsub'});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	321 p.cx(s);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	322 response.cx(p);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	323 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	324 return makeError(response, errors.feature_not_implemented.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	325 } else if (stanza.getChild('pubsub', 'http://jabber.org/protocol/pubsub#owner')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	326 var pubsub = stanza.getChild('pubsub', 'http://jabber.org/protocol/pubsub#owner');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	327
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	328 // SECTION 8.2
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	329 if (pubsub.getChild('configure')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	330 if (!config.enabled('config-node'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	331 return makeError(response, errors.owner.configure.node_configuration_not_supported.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	332
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	333 var nodeID = pubsub.getChild('configure').getAttribute('node');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	334 if (!nodeID \|\| nodeID == '')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	335 return makeError(response, errors.nodeid_required.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	336 if (!storage.existsNode(nodeID))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	337 return makeError(response, errors.node_does_not_exist.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	338
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	339 var affil = storage.getAffiliation(toBareJID(to), nodeID);
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	340 if (affil != 'super-owner' && affil != 'owner' && affil != 'publish-only')
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	341 return makeError(response, errors.pub.publish.insufficient_privileges.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	342
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	343 var p = xmpp.stanza('pubsub', {xmlns: 'http://jabber.org/protocol/pubsub#owner'});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	344 var s = xmpp.stanza('configure', {node: nodeID});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	345 var form = forms.build('form', 'node_config', 'default', true);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	346 s.cx(form);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	347 p.cx(s);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	348 response.cx(p);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	349
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	350 // SECTION 8.3
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	351 } else if (pubsub.getChild('default')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	352 if (!config.enabled('config-node'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	353 return makeError(response, errors.owner.default_options.node_configuration_not_supported.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	354
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	355 var p = xmpp.stanza('pubsub', {xmlns: 'http://jabber.org/protocol/pubsub#owner'});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	356 var s = xmpp.stanza('default');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	357 var form = forms.build('node_config', service_configuration.node_config, null, true);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	358 s.cx(form);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	359 p.cx(s);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	360 response.cx(p);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	361
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	362 // SECTION 8.8
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	363 } else if (pubsub.getChild('subscriptions')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	364 if (!config.enabled('manage-subscriptions'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	365 return makeError(response, errors.owner.manage_subscriptions.not_supported.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	366
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	367 var subscriptions = pubsub.getChild('subscriptions');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	368
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	369 var nodeID = subscriptions.getAttribute('node');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	370 if (!nodeID \|\| nodeID == '')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	371 return makeError(response, errors.nodeid_required.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	372 if (!storage.existsNode(nodeID))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	373 return makeError(response, errors.node_does_not_exist.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	374
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	375 var affil = storage.getAffiliation(toBareJID(to), nodeID);
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	376 if (affil != 'super-owner' && affil != 'owner')
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	377 return makeError(response, errors.forbidden.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	378
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	379 var p = xmpp.stanza('pubsub', {xmlns: 'http://jabber.org/protocol/pubsub#owner'});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	380 var s = xmpp.stanza('subscriptions', {node: nodeID});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	381
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	382 var subs = storage.getSubscriptionsFromNodeID(nodeID)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	383 for (var jid in subs)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	384 s.s('subscription', {jid: jid, subscription: subs[jid].type, subid: subs[jid].subid})
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	385
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	386 p.cx(s);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	387 response.cx(p);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	388
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	389 // SECTION 8.9
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	390 } else if (pubsub.getChild('affiliations')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	391 if (!config.enabled('modify-affiliations'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	392 return makeError(response, errors.owner.manage_affiliations.not_supported.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	393
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	394 var affiliations = pubsub.getChild('affiliations');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	395
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	396 var nodeID = affiliations.getAttribute('node');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	397 if (!nodeID \|\| nodeID == '')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	398 return makeError(response, errors.nodeid_required.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	399 if (!storage.existsNode(nodeID))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	400 return makeError(response, errors.node_does_not_exist.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	401
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	402 var affils = storage.getAffiliationsFromNodeID(nodeID);
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	403 var affil = affils[toBareJID(to)];
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	404 if (affil != 'super-owner' && affil != 'owner')
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	405 return makeError(response, errors.owner.manage_affiliations.retrieve_list.entity_is_not_an_owner.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	406
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	407 var p = xmpp.stanza('pubsub', {xmlns: 'http://jabber.org/protocol/pubsub#owner'});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	408 var s = xmpp.stanza('affiliations', {node: nodeID});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	409
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	410 for (var jid in affils)
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	411 s.s('affiliation', {jid: jid, affiliation: affils[jid]})
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	412
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	413 p.cx(s);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	414 response.cx(p);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	415 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	416 return makeError(response, errors.feature_not_implemented.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	417 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	418 return makeError(response, errors.feature_not_implemented.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	419 } else if (type == 'set') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	420 if (stanza.getChild('pubsub', 'http://jabber.org/protocol/pubsub')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	421 var pubsub = stanza.getChild('pubsub', 'http://jabber.org/protocol/pubsub');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	422
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	423 // SECTION 6.1
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	424 if (pubsub.getChild('subscribe')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	425 if (!config.enabled('subscribe'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	426 return makeError(response, errors.sub.subscribe.not_supported.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	427
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	428 var subscribe = pubsub.getChild('subscribe');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	429
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	430 var nodeID = subscribe.getAttribute('node');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	431 if (!nodeID \|\| nodeID == '')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	432 return makeError(response, errors.nodeid_required.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	433 if (!storage.existsNode(nodeID))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	434 return makeError(response, errors.node_does_not_exist.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	435
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	436 var configuration = storage.getConfiguration(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	437 if (!configuration['pubsub#subscribe'])
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	438 return makeError(response, errors.sub.subscribe.not_supported.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	439
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	440 var affil = storage.getAffiliation(toBareJID(to), nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	441 if (affil == 'publish-only' \|\| affil == 'outcast')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	442 return makeError(response, errors.pub.publish.insufficient_privileges.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	443
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	444 var jid = subscribe.getAttribute('jid');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	445 if (!jid \|\| toBareJID(jid) != toBareJID(to))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	446 return makeError(response, errors.sub.subscribe.jids_do_not_match.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	447
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	448 // SECTION 6.3.7
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	449 var options = pubsub.getChild('options');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	450 if (options && config.enabled('subscription-options')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	451 if (options.getAttribute('node') \|\| options.getAttribute('jid'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	452 return makeError(response, errors.bad_request.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	453
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	454 var x = options.getChild('x', 'jabber:x:data');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	455 if (!x \|\| x.getAttribute('type') != 'submit')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	456 return makeError(response, errors.bad_request.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	457
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	458 var form = forms.parse(x, true);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	459 if (typeof form == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	460 return makeError(response, form);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	461
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	462 var conf = form;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	463 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	464
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	465 var subID;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	466 if (configuration['pubsub#access_model'] == 'open') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	467 subID = storage.subscribe(nodeID, jid, 'subscribe', conf);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	468 if (typeof subID == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	469 return makeError(response, subID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	470 } else if (configuration['pubsub#access_model'] == 'authorize') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	471 subID = storage.subscribe(nodeID, jid, 'pending', conf);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	472 if (typeof subID == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	473 return makeError(response, subID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	474 } else if (configuration['pubsub#access_model'] == 'whitelist') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	475 var affil = storage.getAffiliation(jid, nodeID);
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	476 if (affil != 'super-owner' && affil != 'owner' && affil != 'publisher' && affil != 'member')
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	477 return makeError(response, errors.sub.subscribe.not_on_whitelist.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	478
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	479 subID = storage.subscribe(nodeID, jid, conf);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	480 if (typeof subID == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	481 return makeError(response, subID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	482 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	483
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	484 response.c('pubsub', {xmlns: 'http://jabber.org/protocol/pubsub'})
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	485 .c('subscription', {node: nodeID, jid: jid, subid: subID.subid, subscription: subID.type});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	486
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	487 if (conf)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	488 response.cx(options);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	489
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	490 if (config.enabled('get-pending')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	491 var affiliates = storage.getAffiliationsFromNodeID(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	492 var form = forms.build('form', 'subscribe_authorization', {allow: false, node: nodeID, subscriber_jid: jid}, true); //168
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	493 for (var i in affiliates) {
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	494 if (affiliates[i] == 'super-owner' \|\| affiliates[i] == 'owner') {
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	495 var message = xmpp.message({to: i}).cx(form);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	496 conn.send(message);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	497 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	498 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	499 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	500
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	501 if (config.enabled('last-published')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	502 var last = storage.getLastItem(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	503 if (typeof last != 'number') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	504 var item = storage.getItem(nodeID, last);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	505 if (typeof item != 'number') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	506 var attr = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	507 attr[last] = {content: item};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	508 sendNotifs(jid, 'items', nodeID, attr);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	509 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	510 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	511 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	512
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	513 // SECTION 6.2
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	514 } else if (pubsub.getChild('unsubscribe')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	515 if (!config.enabled('subscribe'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	516 return makeError(response, errors.sub.subscribe.not_supported.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	517
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	518 var unsubscribe = pubsub.getChild('unsubscribe');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	519 var nodeID = unsubscribe.getAttribute('node');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	520 if (!nodeID \|\| nodeID == '')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	521 return makeError(response, errors.nodeid_required.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	522 if (!storage.existsNode(nodeID))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	523 return makeError(response, errors.node_does_not_exist.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	524
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	525 var jid = unsubscribe.getAttribute('jid');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	526 if (!jid \|\| toBareJID(jid) != toBareJID(to))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	527 return makeError(response, errors.sub.unsubscribe.insufficient_privileges.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	528
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	529 var subID = storage.subscribe(nodeID, jid, 'none');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	530 if (typeof subID == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	531 return makeError(response, subID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	532
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	533 // SECTIONS 6.3.5
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	534 } else if (pubsub.getChild('options')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	535 if (!config.enabled('subscription-options'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	536 return makeError(response, errors.sub.subscribe.not_supported.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	537
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	538 var options = pubsub.getChild('options');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	539
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	540 var nodeID = unsubscribe.getAttribute('node');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	541 if (!nodeID \|\| nodeID == '')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	542 return makeError(response, errors.nodeid_required.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	543 if (!storage.existsNode(nodeID))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	544 return makeError(response, errors.node_does_not_exist.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	545
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	546 var jid = unsubscribe.getAttribute('jid');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	547 if (!jid \|\| toBareJID(jid) != toBareJID(to))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	548 return makeError(response, errors.sub.unsubscribe.insufficient_privileges.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	549
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	550 var x = options.getChild('x', 'jabber:x:data');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	551 if (!x \|\| x.getAttribute(type) != 'submit')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	552 return makeError(response, errors.bad_request);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	553
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	554 var form = forms.parse(x, true);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	555 if (typeof form == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	556 return makeError(response, form);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	557
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	558 var set = storage.configureSubscription(nodeID, jid, form);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	559 if (typeof form == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	560 return makeError(response, form);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	561
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	562 // SECTION 7.1
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	563 } else if (pubsub.getChild('publish')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	564 if (!config.enabled('publish'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	565 return makeError(response, errors.pub.publish.item_publication_not_supported.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	566
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	567 var publish = pubsub.getChild('publish');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	568 var nodeID = publish.getAttribute('node');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	569 if (!nodeID \|\| nodeID == '')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	570 return makeError(response, errors.nodeid_required.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	571
6 2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	572 var autocreate = false;
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	573 if (!storage.existsNode(nodeID)) {
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	574 if (config.enabled('auto-create'))
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	575 autocreate = true;
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	576 else
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	577 return makeError(response, errors.node_does_not_exist.n);
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	578 }
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	579
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	580 var affil = storage.getAffiliation(toBareJID(to), nodeID);
6 2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	581 if (typeof affil == 'number' && affil != errors.node_does_not_exist.n)
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	582 return makeError(response, affil);
6 2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	583 if (!autocreate && affil != 'super-owner' && affil != 'owner' && affil != 'publisher' && affil != 'publish-only')
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	584 return makeError(response, errors.forbidden.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	585
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	586 var item = publish.getChild('item');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	587 var itemID = item.getAttribute('id');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	588 if (!config.enabled('item-ids') && itemID)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	589 return makeError(response, errors.itemid_required.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	590 itemID = itemID? itemID: utils.makeRandomId();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	591
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	592 if (item.tags.length != 1)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	593 return makeError(response, errors.pub.publish.bad_payload.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	594
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	595 var conf = storage.getConfiguration(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	596 var publishOptions = pubsub.getChild('publish-options');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	597 if (publishOptions && config.enabled('publish-options')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	598 var x = publishOptions.getChild('x', 'jabber:x:data');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	599 if (!x \|\| x.getAttribute('type') != 'submit')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	600 return makeError(response, errors.bad_request.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	601
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	602 var form = forms.parse(x, true);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	603 if (form.access_model != conf['pubsub#access_model'] && !autocreate)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	604 return makeError(response, errors.pub.configuration.precondition.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	605 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	606
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	607 if (!config.enabled('persistent-items')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	608 var notifs = storage.purgeNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	609 if (typeof notifs == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	610 return makeError(response, r);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	611 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	612
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	613 if (autocreate) {
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	614 if (!form)
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	615 form = {};
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	616 form['pubsub#creator'] = toBareJID(to);
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	617
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	618 var r = storage.createNode(nodeID, form);
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	619 if (typeof r == 'number')
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	620 return makeError(response, r);
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	621 }
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	622
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	623 var content = item.getChild();
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	624
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	625 subscribers = storage.setItem(nodeID, itemID, content);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	626 if (typeof subscribers == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	627 return makeError(response, subscribers);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	628
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	629 var attrs = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	630 if (content)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	631 attrs[itemID] = {content: content};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	632 else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	633 attrs[itemID] = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	634 sendNotifs(subscribers, 'items', nodeID, attrs);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	635
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	636 response.c('pubsub', {xmlns: 'http://jabber.org/protocol/pubsub'})
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	637 .c('publish', {node: nodeID})
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	638 .c('item', {id: itemID});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	639
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	640 // SECTION 7.2
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	641 } else if (pubsub.getChild('retract')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	642 if (!config.enabled('retract-items'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	643 return makeError(response, errors.pub.retract.item_deletion_not_supported.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	644
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	645 var retract = pubsub.getChild('retract');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	646
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	647 var nodeID = retract.getAttribute('node');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	648 if (!nodeID \|\| nodeID == '')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	649 return makeError(response, errors.nodeid_required.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	650 if (!storage.existsNode(nodeID))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	651 return makeError(response, errors.node_does_not_exist.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	652
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	653 var item = retract.getChild('item');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	654 if (!item)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	655 return makeError(response, errors.pub.retract.item_or_itemid_required.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	656
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	657 var itemID = item.getAttribute('id')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	658 if (!itemID \|\| itemID == '')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	659 return makeError(response, errors.pub.retract.item_or_itemid_required.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	660
6 2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	661 var affil = storage.getAffiliation(toBareJID(to), nodeID);
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	662 if (affil != 'super-owner' && affil != 'owner' && affil != 'publish-only')
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	663 return makeError(response, errors.forbidden.n);
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 4 diff changeset	664
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	665 var subscribers = storage.deleteItem(nodeID, itemID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	666 if (typeof subscribers == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	667 return makeError(response, subscribers);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	668
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	669 var attrs = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	670 attrs[itemID] = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	671 sendNotifs(subscribers, 'items', nodeID, attrs, 'retract')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	672
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	673 // SECTION 8.1
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	674 } else if (pubsub.getChild('create')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	675 if (!config.enabled('create-nodes'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	676 return makeError(response, errors.owner.create.node_creation_not_supported.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	677
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	678 var instant = false;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	679
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	680 var nodeID = pubsub.getChild('create').getAttribute('node');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	681 if (!nodeID \|\| nodeID == '') {
4 4c93e76fa371 Ensure that the creator of a node is the default owner; don’t crash Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 3 diff changeset	682 if (!config.enabled('instant-nodes'))
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	683 return makeError(response, errors.owner.create.instant_nodes_not_supported.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	684 nodeID = utils.makeRandomId();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	685 instant = true;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	686 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	687 if (storage.existsNode(nodeID))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	688 return makeError(response, errors.nodeid_already_exists.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	689
2 d3ae2f8b685d Make create node working. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 1 diff changeset	690 var bare = toBareJID(to);
d3ae2f8b685d Make create node working. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 1 diff changeset	691 var right = false;
7 781ac4f1e304 Allow others JIDs than super-owners to create nodes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 6 diff changeset	692
781ac4f1e304 Allow others JIDs than super-owners to create nodes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 6 diff changeset	693 // Check for super-owner
2 d3ae2f8b685d Make create node working. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 1 diff changeset	694 for (var i in config.owner)
d3ae2f8b685d Make create node working. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 1 diff changeset	695 if (config.owner[i] == bare)
d3ae2f8b685d Make create node working. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 1 diff changeset	696 right = true;
d3ae2f8b685d Make create node working. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 1 diff changeset	697
7 781ac4f1e304 Allow others JIDs than super-owners to create nodes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 6 diff changeset	698 // Check for authorized user
781ac4f1e304 Allow others JIDs than super-owners to create nodes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 6 diff changeset	699 for (var i in config.allowCreateNode)
781ac4f1e304 Allow others JIDs than super-owners to create nodes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 6 diff changeset	700 if (config.allowCreateNode[i].exec(bare))
781ac4f1e304 Allow others JIDs than super-owners to create nodes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 6 diff changeset	701 right = true;
781ac4f1e304 Allow others JIDs than super-owners to create nodes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 6 diff changeset	702
2 d3ae2f8b685d Make create node working. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 1 diff changeset	703 if (!right)
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	704 return makeError(response, errors.forbidden.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	705
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	706 var configure = pubsub.getChild('configure');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	707 if (configure && config.enabled('create-and-configure')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	708 if (!config.enabled('config-node'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	709 return makeError(response, errors.owner.configure.node_configuration_not_supported.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	710
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	711 if (configure.getAttribute('node'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	712 return makeError(response, errors.bad_request.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	713
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	714 var x = configure.getChild('x', 'jabber:x:data');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	715 if (!x \|\| x.getAttribute('type') != 'submit')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	716 return makeError(response, errors.bad_request.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	717
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	718 var form = forms.parse(x, true);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	719 if (typeof form == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	720 return makeError(response, form);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	721
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	722 var conf = form;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	723 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	724
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	725 if (!conf)
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	726 conf = {};
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	727 conf['pubsub#creator'] = toBareJID(to);
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	728 var r = storage.createNode(nodeID, conf);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	729 if (typeof r == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	730 return makeError(response, r);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	731
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	732 if (instant)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	733 response.c('pubsub', {xmlns: 'http://jabber.org/protocol/pubsub'})
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	734 .c('create', {node: nodeID});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	735 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	736 return makeError(response, errors.feature_not_implemented.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	737 } else if (stanza.getChild('pubsub', 'http://jabber.org/protocol/pubsub#owner')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	738 var pubsub = stanza.getChild('pubsub', 'http://jabber.org/protocol/pubsub#owner');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	739
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	740 // SECTION 8.2.4
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	741 if (pubsub.getChild('configure')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	742 if (!config.enabled('config-node'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	743 return makeError(response, errors.owner.configure.node_configuration_not_supported.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	744
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	745 var nodeID = configure.getAttribute('node');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	746 if (!nodeID)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	747 return makeError(response, errors.nodeid_required.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	748 if (!storage.existsNode(nodeID))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	749 return makeError(response, errors.node_does_not_exist.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	750
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	751 var affil = storage.getAffiliation(toBareJID(to), nodeID);
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	752 if (affil != 'super-owner' && affil != 'owner' && affil != 'publish-only')
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	753 return makeError(response, errors.forbidden.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	754
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	755 var x = configure.getChild('x', 'jabber:x:data');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	756 if (!x \|\| x.getAttribute(type) != 'submit')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	757 return makeError(response, errors.bad_request.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	758
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	759 var form = forms.parse(x, true);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	760 if (typeof form == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	761 return makeError(response, form);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	762
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	763 var conf = form;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	764
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	765 var set = storage.configure(nodeID, conf);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	766 if (typeof set == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	767 return makeError(response, set);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	768
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	769 // SECTION 8.4
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	770 } else if (pubsub.getChild('delete')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	771 if (!config.enabled('delete-nodes'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	772 return makeError(response, errors.feature_not_implemented.n); //XXX
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	773
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	774 var del = pubsub.getChild('delete');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	775
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	776 var nodeID = del.getAttribute('node');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	777 if (!nodeID)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	778 return makeError(response, errors.nodeid_required.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	779 if (!storage.existsNode(nodeID))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	780 return makeError(response, errors.node_does_not_exist.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	781
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	782 var affil = storage.getAffiliation(toBareJID(to), nodeID);
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	783 if (affil != 'super-owner' && affil != 'owner')
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	784 return makeError(response, errors.forbidden.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	785
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	786 var notifs = storage.deleteNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	787 if (typeof notifs == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	788 return makeError(response, r);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	789
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	790 sendNotifs(notifs, 'delete', nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	791
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	792 // SECTION 8.5
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	793 } else if (pubsub.getChild('purge')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	794 if (!config.enabled('purge-nodes'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	795 return makeError(response, errors.owner.purge.node_purging_not_supported.n); //XXX
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	796
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	797 var purge = pubsub.getChild('purge');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	798
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	799 var nodeID = purge.getAttribute('node');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	800 if (!nodeID)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	801 return makeError(response, errors.nodeid_required.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	802 if (!storage.existsNode(nodeID))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	803 return makeError(response, errors.node_does_not_exist.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	804
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	805 var affil = storage.getAffiliation(toBareJID(to), nodeID);
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	806 if (affil != 'super-owner' && affil != 'owner')
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	807 return makeError(response, errors.forbidden.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	808
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	809 if (!config.enabled('persistent-items')) //FIXME: autre condition, supporté par le node
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	810 return makeError(response, errors.owner.purge.node_does_not_persist_items.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	811
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	812 var notifs = storage.purgeNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	813 if (typeof notifs == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	814 return makeError(response, r);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	815
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	816 sendNotifs(notifs, 'purge', nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	817
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	818 // SECTION 8.8.2
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	819 } else if (pubsub.getChild('subscriptions')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	820 if (!config.enabled('manage-subscriptions'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	821 return makeError(response, errors.owner.manage_subscriptions.not_supported.n); //XXX
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	822
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	823 var subscriptions = pubsub.getChild('subscriptions');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	824
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	825 var nodeID = subscriptions.getAttribute('node');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	826 if (!nodeID)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	827 return makeError(response, errors.nodeid_required.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	828 if (!storage.existsNode(nodeID))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	829 return makeError(response, errors.node_does_not_exist.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	830
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	831 var affil = storage.getAffiliation(toBareJID(to), nodeID);
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	832 if (affil != 'super-owner' && affil != 'owner')
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	833 return makeError(response, errors.forbidden.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	834
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	835 var e = false;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	836 for (i in subscriptions.tags) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	837 var jid = subscriptions.tags[i].getAttribute('jid');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	838 var subscription = subscriptions.tags[i].getAttribute('subscription');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	839
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	840 var set = storage.subscribe(nodeID, jid, subscription);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	841 if (typeof set == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	842 e = true;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	843 else {
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	844 // SECTION 8.8.4
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	845 sendNotifs(jid, 'subscription', nodeID, {jid: jid, subscription: subscription});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	846 subscriptions.tags.splice(i, 1);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	847 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	848 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	849
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	850 if (e)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	851 return makeError(response, errors.owner.manage_subscriptions.modify.multiple_simultaneous_modifications.n, pubsub);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	852
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	853 // SECTION 8.9.2
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	854 } else if (pubsub.getChild('affiliations')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	855 if (!config.enabled('modify-affiliations'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	856 return makeError(response, errors.owner.manage_affiliations.not_supported.n); //XXX
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	857
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	858 var affiliations = pubsub.getChild('affiliations');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	859
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	860 var nodeID = affiliations.getAttribute('node');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	861 if (!nodeID)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	862 return makeError(response, errors.nodeid_required.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	863 if (!storage.existsNode(nodeID))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	864 return makeError(response, errors.node_does_not_exist.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	865
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	866 var affil = storage.getAffiliation(toBareJID(to), nodeID);
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	867 if (affil != 'super-owner' && affil != 'owner')
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	868 return makeError(response, errors.forbidden.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	869
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	870 var e = false;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	871 for (i in affiliations.children) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	872 var jid = affiliations.children[i].getAttribute('jid');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	873 var affiliation = affiliations.children[i].getAttribute('affiliation');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	874
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	875 var set = storage.setAffiliation(nodeID, jid, affiliation);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	876 if (typeof set == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	877 e = true;
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	878 else {
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	879 // SECTION 8.9.4
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	880 sendNotifs(jid, 'affiliations', nodeID, {jid: jid, affiliation: affiliation});
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	881 affiliations.children.splice(i, 1);
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	882 }
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	883 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	884
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	885 if (e)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	886 return makeError(response, errors.owner.manage_affiliations.modify.multiple_simultaneous_modifications.n, pubsub);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	887 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	888 return makeError(response, errors.feature_not_implemented.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	889 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	890 return makeError(response, errors.feature_not_implemented.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	891 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	892 return makeError(response, errors.feature_not_implemented.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	893 conn.send(response);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	894 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	895
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	896 function onMessage(stanza) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	897 var from = stanza.getAttribute('to');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	898 var to = stanza.getAttribute('from');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	899 var id = stanza.getAttribute('id');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	900
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	901 var response;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	902 if (id)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	903 response = xmpp.message({to: to, from: from, id: id});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	904 else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	905 response = xmpp.message({to: to, from: from});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	906
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	907 var x = stanza.getChild('x', 'jabber:x:data');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	908 if (x) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	909 var form = forms.parse(x);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	910 if (form.type == 'submit' && form.fields.FORM_TYPE.value == 'subscribe_authorization') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	911 if (form.fields.subid && form.fields.subid.value)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	912 var subID = form.fields.subid.value;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	913 if (form.fields.node && form.fields.node.value)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	914 var nodeID = form.fields.node.value;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	915 if (form.fields.subscriber_jid && form.fields.subscriber_jid.value)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	916 var jid = form.fields.subscriber_jid.value;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	917 if (form.fields.allow && form.fields.allow.value)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	918 var allow = form.fields.allow.value;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	919
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	920 var type = allow? 'subscribed': 'none';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	921 var set = storage.subscribe(nodeID, jid, type)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	922 //if (set.subid != subID) //TODO: support the multi-subscribe feature
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	923 sendNotifs(jid, 'subscription', nodeID, {jid: jid, subscription: type});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	924 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	925 return makeError(response, errors.feature_not_implemented.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	926 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	927 return makeError(response, errors.feature_not_implemented.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	928 conn.send(response)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	929 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	930
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	931 function onPresence(stanza) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	932 var from = stanza.getAttribute('to');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	933 var to = stanza.getAttribute('from');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	934 var id = stanza.getAttribute('id');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	935
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	936 var response;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	937 if (id)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	938 response = xmpp.presence({to: to, from: from, id: id});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	939 else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	940 response = xmpp.presence({to: to, from: from});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	941
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	942 makeError(response, errors.feature_not_implemented.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	943 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	944
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	945 function makeError(response, errorNumber, payload) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	946 response.attr.type = 'error';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	947 if (payload)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	948 response.cx(payload);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	949
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	950 var e = errors.reverse[errorNumber];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	951 var error = xmpp.stanza('error', {type: e.type});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	952
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	953 error.s(e.error, {xmlns: 'urn:ietf:params:xml:ns:xmpp-stanzas'})
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	954
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	955 if (e.reason) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	956 if (e.feature)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	957 error.s(e.reason, {xmlns: 'http://jabber.org/protocol/pubsub#errors', feature: e.feature});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	958 else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	959 error.s(e.reason, {xmlns: 'http://jabber.org/protocol/pubsub#errors'});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	960 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	961
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	962 response.cx(error);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	963 conn.send(response);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	964 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	965
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	966 function sendNotifs(notifs, type, nodeID, a1, a2) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	967 var ev = xmpp.stanza('event', {xmlns: 'http://jabber.org/protocol/pubsub#event'});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	968
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	969 if (type == 'affiliations') {
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	970 ev.attr.xmlns = 'http://jabber.org/protocol/pubsub';
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	971
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	972 var args = {};
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	973 for (i in a1) {
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	974 var attr = a1[i];
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	975 if (i == 'affiliation')
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	976 args.affiliation = attr;
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	977 else if (i == 'jid')
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	978 args.jid = attr;
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	979 }
3 80e607c0b39e Make affiliation notifications working. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 2 diff changeset	980 var affiliations = xmpp.stanza('affiliations', {node: nodeID})
4 4c93e76fa371 Ensure that the creator of a node is the default owner; don’t crash Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 3 diff changeset	981 .c('affiliation', args);
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	982 ev.cx(affiliations);
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	983 } else if (type == 'collection') {
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	984 var collection = xmpp.stanza('collection', {node: nodeID});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	985 if (a1 == 'associate')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	986 collection.cx('associate', {node: nodeID});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	987 else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	988 collection.cx('disassociate', {node: nodeID});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	989 ev.cx(collection);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	990 } else if (type == 'configuration') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	991 if (!config.enabled('config-node')) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	992 _('Error #4', 41)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	993 return;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	994 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	995
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	996 var configuration = xmpp.stanza('configuration', {node: nodeID});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	997 if (a1) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	998 var x = forms.build('node_config', service_configuration.node_config, storage.getConfiguration(nodeID));
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	999 if (x)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1000 configuration.cx(x); //TODO: voir exemple 150
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1001 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1002 ev.cx(configuration);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1003 } else if (type == 'delete') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1004 var del = xmpp.stanza('delete', {node: nodeID});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1005 if (a1)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1006 del.c('redirect', {uri: a1});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1007 ev.cx(del);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1008 } else if (type == 'items') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1009 var items = xmpp.stanza(type, {node: nodeID});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1010 if (a2 == 'retract')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1011 for (var i in a1)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1012 items.s('retract', {id: i});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1013 else {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1014 for (var i in a1) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1015 var item = a1[i];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1016 var args = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1017 if (i != '')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1018 args.id = i;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1019 if (item.node)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1020 args.node = item.node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1021 if (item.publisher)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1022 args.publisher = item.publisher;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1023 var it = xmpp.stanza('item', args);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1024 if (item.content)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1025 it.cx(item.content);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1026 items.cx(it);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1027 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1028 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1029 ev.cx(items);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1030 } else if (type == 'purge') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1031 ev.c('purge', {node: nodeID});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1032 } else if (type == 'subscription') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1033 if (!config.enabled('subscription-notifications'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1034 return;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1035
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1036 var args = {node: nodeID};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1037 for (i in a1) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1038 var attr = a1[i];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1039 if (i == 'subscription') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1040 if (attr == 'none' \|\| attr == 'pending' \|\| attr == 'subscribed' \|\| attr == 'unconfigured')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1041 args[i] = attr;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1042 else {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1043 _('Error #3', 41)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1044 return;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1045 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1046 } else if (i == 'jid' \|\| i == 'subid')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1047 args[i] = attr;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1048 else if (i == 'expiry')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1049 args[i] = attr.toString();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1050 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1051 if (!args.jid \|\| args.jid == '') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1052 _('Error #2', 41)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1053 return;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1054 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1055 var sub = xmpp.stanza('subscription', args);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1056 ev.cx(sub);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1057 } else {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1058 _('Error #1', 41)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1059 return;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1060 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1061
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1062 var subs;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1063 if (typeof notifs == 'string') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1064 subs = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1065 subs[notifs] = storage.getSubscription(notifs, nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1066 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1067 subs = notifs;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1068
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1069 for (var i in subs) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1070 var sub = subs[i];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1071
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1072 if (sub.options) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1073 if (typeof sub.options['pubsub#deliver'] != 'undefined' && !sub.options['pubsub#deliver'])
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1074 continue;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1075
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1076 if (typeof sub.options['pubsub#digest'] != 'undefined' && sub.options['pubsub#digest']) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1077 if (!sub.digest)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1078 sub.digest = [];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1079 sub.digest.push(ev)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1080
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1081 if (sub.digestTimeout)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1082 continue;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1083
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1084 var freq;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1085 if (typeof sub.options['pubsub#digest_frequency'] == 'undefined')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1086 freq = 0;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1087 else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1088 freq = parseInt(sub.options['pubsub#digest_frequency']);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1089
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1090 if (freq == 0)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1091 freq = 246060*1000;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1092
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1093 setTimeout(sendDigest, freq, notifs[i], nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1094 sub.digestTimeout = true;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1095 continue;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1096 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1097 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1098
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1099 var message = xmpp.message({to: i, from: componentJID, id: conn.getUniqueId()});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1100 message.cx(ev);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1101 conn.send(message);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1102 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1103 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1104
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1105 function sendDigest(jid, nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1106 var sub = storage.getSubscription(jid, nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1107 if (sub.digestTimeout)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1108 sub.digestTimeout = false;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1109
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1110 var message = xmpp.message({to: jid, from: componentJID, id: conn.getUniqueId()});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1111 for (var i in sub.digest)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1112 message.cx(sub.digest[i]);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1113 conn.send(message);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1114 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1115
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1116 conn.connect(componentJID, componentPassword, function (status, condition) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1117 if (status == xmpp.Status.CONNECTED) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1118 conn.addHandler(onMessage, null, 'message', null, null, null);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1119 conn.addHandler(onIq, null, 'iq', null, null, null);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1120 conn.addHandler(onPresence, null, 'presence', null, null, null);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1121
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1122 if (process.argv.length >= 3)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1123 storage.load(process.argv[2]);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1124 else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1125 storage.load();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1126
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1127 var stdin = process.openStdin();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1128 stdin.setEncoding('utf8');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1129 stdin.addListener('data', storage.debug);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1130 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1131 conn.log(xmpp.LogLevel.DEBUG, 'New connection status: ' + status + (condition? (' ('+condition+')'): ''));
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1132 });