PSĜS: storage.js annotate

annotate storage.js @ 1:c2954a9e5665

Add a super-owner that has power over all nodes; add support for affiliation changes; support pubsub#creator metadata; change pubsub#digest_frequency default; and use better default config values.

author	Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
date	Mon, 28 Jun 2010 21:55:30 +0200
parents	9ee956af41e3
children	d8a98540d749

rev	line source
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1 /*
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	2 * Copyright (C) 2010 Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
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 * 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	5 *
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	6 * PSĜS is free software: you can redistribute it and/or modify
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	7 * it under the terms of the GNU Affero General Public License as
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	8 * published by the Free Software Foundation, either version 3 of the
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	9 * License.
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	10 *
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	11 * PSĜS is distributed in the hope that it will be useful,
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	14 * GNU Affero General Public License for more details.
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	15 *
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	16 * 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	17 * along with PSĜS. If not, see <http://www.gnu.org/licenses/>.
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	18 */
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	19
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	20 var sys = require('sys');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	21 var sha1hex = require('sha1').hex;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	22 require('./iso8601');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	23 var errors = require('./errors');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	24 var config = require('./configuration');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	25 var service_configuration = config.service_configuration;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	26 var Configuration = config.Configuration;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	27 var utils = require('./util');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	28 var toBareJID = utils.toBareJID;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	29
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	30 var nodes = require('./nodes');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	31 var Node = nodes.Node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	32 var Item = nodes.Item;
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 fs = require('fs');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	35
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	36 var list = {};
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 var storage = exports;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	39 storage.createNode = function(nodeID, params) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	40 for (var i in list)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	41 if (i == nodeID)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	42 return errors.owner.create.nodeid_already_exists.n;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	43
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	44 list[nodeID] = new Node(params);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	45 storage.save();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	46 return errors.success;
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 storage.getMetadata = function(nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	50 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	51 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	52 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	53
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	54 if (!config.enabled('meta-data'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	55 return {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	56
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	57 var md = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	58 for (var i in service_configuration.node_metadata) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	59 if (i == 'FORM_TYPE')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	60 continue;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	61
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	62 if (node.configuration[i])
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	63 md[i] = node.configuration[i];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	64 else if (node.metadata[i])
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	65 md[i] = node.metadata[i];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	66 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	67 return md;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	68 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	69
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	70 storage.getConfiguration = function(nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	71 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	72 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	73 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	74
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	75 if (config.enabled('config-node'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	76 return node.configuration;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	77
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	78 return {}; //FIXME
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	79 };
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 storage.configure = function(nodeID, params) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	82 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	83 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	84 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	85
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	86 if (!config.enabled('config-node'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	87 return 42; //FIXME
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	88
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	89 for (var i in params)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	90 if (service_configuration.node_config[i])
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	91 node.configuration[i] = params[i];
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 storage.save();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	94 return errors.success;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	95 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	96
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	97 storage.configureSubscription = function(nodeID, jid, params) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	98 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	99 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	100 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	101
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	102 if (!config.enabled('subscription-options'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	103 return 42; //FIXME
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	104
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	105 var options = node.subscribers[jid].options;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	106 if (!options)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	107 return 42; //FIXME
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	108
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	109 for (var i in params)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	110 if (service_configuration.subscribe_options[i])
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	111 options[i] = params[i];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	112
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	113 storage.save();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	114 return errors.success;
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
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	117 storage.getChildren = function(node) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	118 var n;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	119 var items = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	120 if (node)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	121 n = storage.getNode(node).items;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	122 else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	123 n = list;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	124
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	125 for (var i in n) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	126 var type;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	127 if (n[i].content)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	128 type = 'item';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	129 else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	130 type = 'node';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	131 items[i] = type;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	132 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	133 return items;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	134 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	135
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	136 storage.getNode = function(nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	137 if (list[nodeID])
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	138 return list[nodeID];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	139 return errors.sub.subscribe.node_does_not_exist.n;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	140 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	141
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	142 storage.existsNode = function(nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	143 if (list[nodeID])
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	144 return true;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	145 return false;
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
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	148 storage.purgeNode = function(nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	149 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	150 if (typeof n == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	151 return node;
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 var notifs = storage.getSubscriptionsFromNodeID(nodeID);
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 var item = storage.getLastItem(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	156 if (typeof item == 'number') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	157 node.items = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	158 } else {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	159 items = node.items[item];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	160 node.items = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	161 node.items[item] = items;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	162 }
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 storage.save();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	165 return notifs;
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
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	168 storage.deleteNodeWithRedirect = function(nodeID, uri) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	169 var del = storage.deleteNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	170 if (typeof del == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	171 return del;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	172
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	173 list[nodeID] = uri;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	174 storage.save();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	175 return errors.success;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	176 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	177
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	178 storage.deleteNode = function(nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	179 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	180 if (typeof n == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	181 return node;
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 var notifs = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	184 for (var i in node.subscribers)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	185 notifs[i] = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	186 for (var i in node.owner)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	187 notifs[node.owner[i]] = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	188 if (config.enabled('publisher-affiliation'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	189 for (var i in node.publisher)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	190 notifs[node.publisher[i]] = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	191 if (config.enabled('publish-only-affiliation'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	192 for (var i in node.publishOnly)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	193 notifs[node.publishOnly[i]] = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	194
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	195 delete list[nodeID];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	196 storage.save();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	197 return notifs;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	198 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	199
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	200 storage.setItem = function(nodeID, itemID, content) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	201 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	202 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	203 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	204
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	205 if (typeof itemID != 'string')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	206 itemID = utils.makeRandomId();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	207
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	208 i = node.setItem(itemID, content);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	209 if (content)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	210 i.content = content;
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 storage.save();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	213 return storage.getSubscriptionsFromNodeID(nodeID)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	214 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	215
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	216 storage.deleteItem = function(nodeID, itemID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	217 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	218 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	219 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	220
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	221 if (typeof itemID != 'string')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	222 return errors.pub.retract.item_or_itemid_required.n;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	223
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	224 item = node.setItem(itemID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	225 if (typeof item == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	226 return item;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	227
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	228 storage.save();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	229 return storage.getSubscriptionsFromNodeID(nodeID)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	230 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	231
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	232 storage.getItems = function(nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	233 var node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	234 if (typeof nodeID == 'string')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	235 node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	236 else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	237 node = nodeID;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	238
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	239 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	240 return node;
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 return node.items;
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
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	245 storage.getLastItem = function(nodeID, number) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	246 var items = storage.getItems(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	247 if (typeof items == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	248 return items;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	249
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	250 if (items == {})
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	251 return 42; //FIXME
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	252
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	253 if (number) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	254 var last = [];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	255 var j = 0;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	256 for (var i in items) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	257 last.push({name: i, date: items[i].date, content: items[i].content});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	258 j++;
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 if (j < number)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	261 return last;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	262
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	263 var cmp = function(a, b) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	264 return b.date - a.date;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	265 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	266 last = last.sort(cmp).slice(0, number);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	267 } else {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	268 var last;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	269 for (var i in items)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	270 if ((typeof last == 'undefined') \|\| (items[i].date >= items[last].date))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	271 last = i;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	272 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	273
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	274 if (last)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	275 return last;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	276 return 42; //FIXME
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	277 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	278
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	279 storage.existsItem = function(nodeID, itemID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	280 var items = storage.getItems(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	281 if (typeof items == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	282 return items;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	283
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	284 for (var i in items)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	285 if (i == itemID)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	286 return items[i];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	287 return false;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	288 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	289
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	290 storage.getItem = function(nodeID, itemID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	291 if (!storage.existsItem(nodeID, itemID))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	292 return 42; //FIXME
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 var items = storage.existsItem(nodeID, itemID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	295 if (typeof items == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	296 return items;
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	297
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	298 if (items)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	299 return items.content;
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	300
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	301 return errors.item_not_found;
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
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	304 storage.getSubscription = function(jid, nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	305 var subs = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	306 if (nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	307 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	308 for (var sub in node.subscribers)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	309 if (toBareJID(sub) == jid)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	310 return node.subscribers[sub]
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	311 } else {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	312 for (var node in list) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	313 for (var sub in list[node].subscribers) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	314 if (toBareJID(sub) == jid)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	315 subs[node] = list[node].subscribers[sub];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	316 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	317 }
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 return subs;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	320 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	321
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	322 storage.getSubscriptionsFromNodeID = function(nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	323 var node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	324 if (typeof nodeID == 'string') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	325 node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	326 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	327 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	328 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	329 node = nodeID;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	330
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	331 var subs = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	332 for (var sub in node.subscribers) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	333 if (typeof sub == 'string') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	334 var subscription = {subid: node.subscribers[sub].subid, type: node.subscribers[sub].type};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	335 if (node.subscribers[sub].options)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	336 subscription.options = node.subscribers[sub].options;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	337 subs[sub] = subscription;
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 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	340 return subs;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	341 };
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 storage.subscribe = function(nodeID, jid, type, params) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	344 if (!config.enabled('subscribe'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	345 return errors.sub.subscribe.not_supported.n;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	346
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	347 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	348 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	349 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	350
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	351 if (typeof type == 'undefined')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	352 type = 'subscribed';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	353
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	354 if (type == 'none') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	355 if (!node.subscribers[jid])
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	356 return errors.sub.unsubscribe.no_such_subscriber.n;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	357 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	358
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	359 var subid = node.setSubscriber(jid, type, null, params);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	360 storage.save();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	361 return {subid: subid, type: type};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	362 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	363
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	364 storage.setAffiliation = function(nodeID, jid, affil) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	365 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	366 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	367 return node;
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 if (affil == 'owner')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	370 node.owner.push(jid);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	371 else if (config.enabled('publisher-affiliation') && affil == 'publisher')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	372 node.publisher.push(jid);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	373 else if (config.enabled('publish-only-affiliation') && affil == 'publish-only')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	374 node.publishOnly.push(jid);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	375 else if (config.enabled('member-affiliation') && affil == 'member')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	376 node.member.push(jid);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	377 else if (config.enabled('outcast-affiliation') && affil == 'outcast')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	378 node.outcast.push(jid);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	379
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	380 storage.save();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	381 return errors.success;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	382 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	383
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	384 storage.getAffiliation = function(jid, nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	385 var node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	386 if (typeof nodeID == 'string') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	387 node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	388 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	389 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	390 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	391 node = nodeID;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	392
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	393 for (var affil in config.owner)
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	394 if (typeof affil == 'string' && node.owner[affil] == 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	395 return 'super-owner';
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	396 for (var affil in node.owner)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	397 if (typeof affil == 'string' && node.owner[affil] == jid)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	398 return 'owner';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	399 if (config.enabled('publisher-affiliation'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	400 for (var affil in node.publisher)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	401 if (typeof affil == 'string' && node.publisher[affil] == jid)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	402 return 'publisher';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	403 if (config.enabled('publish-only-affiliation'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	404 for (var affil in node.publishOnly)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	405 if (typeof affil == 'string' && node.publishOnly[affil] == jid)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	406 return 'publish-only';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	407 if (config.enabled('outcast-affiliation'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	408 for (var affil in node.outcast)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	409 if (typeof affil == 'string' && node.outcast[affil] == jid)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	410 return 'outcast';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	411 return 'none';
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
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	414 storage.getAffiliationsFromJID = function(jid) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	415 var affils = {};
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	416 for (var nodeID in list) {
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	417 var node = list[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	418 for (var affil in config.owner)
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	419 if (typeof affil == 'string' && config.owner[affil] == 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	420 affils[nodeID] = 'super-owner';
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	421 break;
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	422 }
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	423 for (var affil in node.owner)
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	424 if (typeof affil == 'string' && node.owner[affil] == 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	425 affils[nodeID] = 'owner';
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	426 break;
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 if (config.enabled('publisher-affiliation'))
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	429 for (var affil in node.publisher)
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	430 if (typeof affil == 'string' && node.publisher[affil] == 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	431 affils[nodeID] = 'publisher';
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	432 break;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	433 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	434 if (config.enabled('publish-only-affiliation'))
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	435 for (var affil in node.publishOnly)
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	436 if (typeof affil == 'string' && node.publishOnly[affil] == 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	437 affils[nodeID] = 'publish-only';
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	438 break;
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 if (config.enabled('outcast-affiliation'))
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	441 for (var affil in node.outcast)
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	442 if (typeof affil == 'string' && node.outcast[affil] == 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	443 affils[nodeID] = 'outcast';
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	444 break;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	445 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	446 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	447 return affils;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	448 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	449
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	450 storage.getAffiliationsFromNodeID = function(nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	451 var node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	452 if (typeof nodeID == 'string') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	453 node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	454 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	455 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	456 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	457 node = nodeID;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	458
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	459 var affils = {};
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	460 for (var jid in config.owner)
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	461 if (typeof jid == 'string')
c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	462 affils[config.owner[jid]] = 'super-owner';
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	463 for (var jid in node.owner)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	464 if (typeof jid == 'string')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	465 affils[node.owner[jid]] = 'owner';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	466 if (config.enabled('publisher-affiliation'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	467 for (var jid in node.publisher)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	468 if (typeof jid == 'string')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	469 affils[node.publisher[jid]] = 'publisher';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	470 if (config.enabled('publish-only-affiliation'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	471 for (var jid in node.publishOnly)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	472 if (typeof jid == 'string')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	473 affils[node.publishOnly[jid]] = 'publish-only';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	474 if (config.enabled('member-affiliation'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	475 for (var jid in node.member)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	476 if (typeof jid == 'string')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	477 affils[node.member[jid]] = 'member';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	478 if (config.enabled('outcast-affiliation'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	479 for (var jid in node.outcast)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	480 if (typeof jid == 'string')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	481 affils[node.outcast[jid]] = 'outcast';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	482 return affils;
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
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	485 storage.save = function(file) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	486 function sanitize(o) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	487 var n = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	488 for (var i in o) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	489 if (i == 'content' \|\| o[i].setISO8601)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	490 n[i] = o[i].toString();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	491 else if (o[i] instanceof Array)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	492 n[i] = o[i];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	493 else if (typeof o[i] == 'object')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	494 n[i] = sanitize(o[i]);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	495 else if (typeof o[i] == 'function')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	496 ;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	497 else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	498 n[i] = o[i];
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 return n;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	501 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	502
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	503 var data = sanitize(list);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	504
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	505 if (!file)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	506 file = 'save.json';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	507
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	508 fs.writeFile(file, sys.inspect(data, null, null));
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 storage.load = function(file) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	512 var xmpp = require('xmpp');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	513 function parseStanza(path, content) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	514 var stanza = null;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	515 var stream = new xmpp.Stream({
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	516 stanza: function (stanza) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	517 path[content] = stanza;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	518 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	519 });
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	520 stream.opened = true;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	521 stream.data(path[content]);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	522 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	523
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	524 function endParsing(o) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	525 var regexp = /\d{4}-\d\d-\d\dT\d\d:\d\d:\d\dZ/;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	526 for (var i in o) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	527 if (typeof o[i] == 'string' && i == 'content')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	528 parseStanza(o, i);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	529 else if (typeof o[i] == 'string' && regexp(o[i])) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	530 var today = new Date();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	531 today.setISO8601(o[i]);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	532 o[i] = today;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	533 } else if (typeof o[i] == 'object')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	534 endParsing(o[i]);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	535 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	536 return o;
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
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	539 if (!file)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	540 file = 'save.json';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	541
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	542 var data = fs.readFileSync(file);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	543 var obj = eval('('+data+')');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	544 list = endParsing(obj);
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
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	547 storage.debug = function() {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	548 sys.puts('\033[1;33m' + sys.inspect(list, null, null) + '\033[0m');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	549 };