PSĜS: storage.js annotate

annotate storage.js @ 10:44889cfb2f8c

Fix getItem method.

author	Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
date	Fri, 27 Aug 2010 01:02:56 +0200
parents	a6429f48e403
children	9a6b8b3357c6

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
9 a6429f48e403 First implementation of XEP-0050 (ad-hoc commands). Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 6 diff changeset	36 var list;
0 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];
6 2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 5 diff changeset	139 return errors.node_does_not_exist.n;
0 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) {
10 44889cfb2f8c Fix getItem method. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 9 diff changeset	291 var items = storage.getItems(nodeID);
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	292 if (typeof items == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	293 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	294
10 44889cfb2f8c Fix getItem method. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 9 diff changeset	295 if (items[itemID])
44889cfb2f8c Fix getItem method. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 9 diff changeset	296 return items[itemID].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	297
10 44889cfb2f8c Fix getItem method. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 9 diff changeset	298 return errors.success;
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	299 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	300
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	301 storage.getSubscription = function(jid, nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	302 var subs = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	303 if (nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	304 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	305 for (var sub in node.subscribers)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	306 if (toBareJID(sub) == jid)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	307 return node.subscribers[sub]
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	308 } else {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	309 for (var node in list) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	310 for (var sub in list[node].subscribers) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	311 if (toBareJID(sub) == jid)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	312 subs[node] = list[node].subscribers[sub];
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 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	315 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	316 return subs;
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 storage.getSubscriptionsFromNodeID = function(nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	320 var node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	321 if (typeof nodeID == 'string') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	322 node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	323 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	324 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	325 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	326 node = nodeID;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	327
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	328 var subs = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	329 for (var sub in node.subscribers) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	330 if (typeof sub == 'string') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	331 var subscription = {subid: node.subscribers[sub].subid, type: node.subscribers[sub].type};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	332 if (node.subscribers[sub].options)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	333 subscription.options = node.subscribers[sub].options;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	334 subs[sub] = subscription;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	335 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	336 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	337 return subs;
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 storage.subscribe = function(nodeID, jid, type, params) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	341 if (!config.enabled('subscribe'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	342 return errors.sub.subscribe.not_supported.n;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	343
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	344 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	345 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	346 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	347
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	348 if (typeof type == 'undefined')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	349 type = 'subscribed';
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 (type == 'none') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	352 if (!node.subscribers[jid])
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	353 return errors.sub.unsubscribe.no_such_subscriber.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
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	356 var subid = node.setSubscriber(jid, type, null, params);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	357 storage.save();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	358 return {subid: subid, type: type};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	359 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	360
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	361 storage.setAffiliation = function(nodeID, jid, affil) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	362 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	363 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	364 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	365
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	366 if (affil == 'owner')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	367 node.owner.push(jid);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	368 else if (config.enabled('publisher-affiliation') && affil == 'publisher')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	369 node.publisher.push(jid);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	370 else if (config.enabled('publish-only-affiliation') && affil == 'publish-only')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	371 node.publishOnly.push(jid);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	372 else if (config.enabled('member-affiliation') && affil == 'member')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	373 node.member.push(jid);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	374 else if (config.enabled('outcast-affiliation') && affil == 'outcast')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	375 node.outcast.push(jid);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	376
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	377 storage.save();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	378 return errors.success;
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
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	381 storage.getAffiliation = function(jid, nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	382 var node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	383 if (typeof nodeID == 'string') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	384 node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	385 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	386 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	387 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	388 node = nodeID;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	389
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	390 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	391 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	392 return 'super-owner';
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	393 for (var affil in node.owner)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	394 if (typeof affil == 'string' && node.owner[affil] == jid)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	395 return 'owner';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	396 if (config.enabled('publisher-affiliation'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	397 for (var affil in node.publisher)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	398 if (typeof affil == 'string' && node.publisher[affil] == jid)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	399 return 'publisher';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	400 if (config.enabled('publish-only-affiliation'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	401 for (var affil in node.publishOnly)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	402 if (typeof affil == 'string' && node.publishOnly[affil] == jid)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	403 return 'publish-only';
6 2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 5 diff changeset	404 if (config.enabled('member-affiliation'))
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 5 diff changeset	405 for (var affil in node.member)
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 5 diff changeset	406 if (typeof affil == 'string' && node.member[affil] == jid)
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 5 diff changeset	407 return 'member';
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	408 if (config.enabled('outcast-affiliation'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	409 for (var affil in node.outcast)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	410 if (typeof affil == 'string' && node.outcast[affil] == jid)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	411 return 'outcast';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	412 return 'none';
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
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	415 storage.getAffiliationsFromJID = function(jid) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	416 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	417 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	418 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	419 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	420 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	421 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	422 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	423 }
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 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	425 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	426 affils[nodeID] = 'owner';
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	427 break;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	428 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	429 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	430 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	431 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	432 affils[nodeID] = 'publisher';
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	433 break;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	434 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	435 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	436 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	437 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	438 affils[nodeID] = 'publish-only';
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	439 break;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	440 }
6 2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 5 diff changeset	441 if (config.enabled('member-affiliation'))
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 5 diff changeset	442 for (var affil in node.member)
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 5 diff changeset	443 if (typeof affil == 'string' && node.member[affil] == jid) {
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 5 diff changeset	444 affils[nodeID] = 'member';
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 5 diff changeset	445 break;
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 5 diff changeset	446 }
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	447 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	448 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	449 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	450 affils[nodeID] = 'outcast';
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	451 break;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	452 }
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 return affils;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	455 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	456
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	457 storage.getAffiliationsFromNodeID = function(nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	458 var node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	459 if (typeof nodeID == 'string') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	460 node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	461 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	462 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	463 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	464 node = nodeID;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	465
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	466 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	467 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	468 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	469 affils[config.owner[jid]] = 'super-owner';
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	470 for (var jid in node.owner)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	471 if (typeof jid == 'string')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	472 affils[node.owner[jid]] = 'owner';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	473 if (config.enabled('publisher-affiliation'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	474 for (var jid in node.publisher)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	475 if (typeof jid == 'string')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	476 affils[node.publisher[jid]] = 'publisher';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	477 if (config.enabled('publish-only-affiliation'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	478 for (var jid in node.publishOnly)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	479 if (typeof jid == 'string')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	480 affils[node.publishOnly[jid]] = 'publish-only';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	481 if (config.enabled('member-affiliation'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	482 for (var jid in node.member)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	483 if (typeof jid == 'string')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	484 affils[node.member[jid]] = 'member';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	485 if (config.enabled('outcast-affiliation'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	486 for (var jid in node.outcast)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	487 if (typeof jid == 'string')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	488 affils[node.outcast[jid]] = 'outcast';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	489 return affils;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	490 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	491
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	492 storage.save = function(file) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	493 function sanitize(o) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	494 var n = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	495 for (var i in o) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	496 if (i == 'content' \|\| o[i].setISO8601)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	497 n[i] = o[i].toString();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	498 else if (o[i] instanceof Array)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	499 n[i] = o[i];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	500 else if (typeof o[i] == 'object')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	501 n[i] = sanitize(o[i]);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	502 else if (typeof o[i] == 'function')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	503 ;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	504 else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	505 n[i] = o[i];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	506 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	507 return n;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	508 }
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 var data = sanitize(list);
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 if (!file)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	513 file = 'save.json';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	514
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	515 fs.writeFile(file, sys.inspect(data, null, null));
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	516 }
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 storage.load = function(file) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	519 var xmpp = require('xmpp');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	520 function parseStanza(path, content) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	521 var stanza = null;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	522 var stream = new xmpp.Stream({
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	523 stanza: function (stanza) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	524 path[content] = stanza;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	525 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	526 });
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	527 stream.opened = true;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	528 stream.data(path[content]);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	529 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	530
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	531 function endParsing(o) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	532 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	533 for (var i in o) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	534 if (typeof o[i] == 'string' && i == 'content')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	535 parseStanza(o, i);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	536 else if (typeof o[i] == 'string' && regexp(o[i])) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	537 var today = new Date();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	538 today.setISO8601(o[i]);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	539 o[i] = today;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	540 } else if (typeof o[i] == 'object')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	541 endParsing(o[i]);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	542 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	543 return o;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	544 }
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 if (!file)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	547 file = 'save.json';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	548
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	549 var data = fs.readFileSync(file);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	550 var obj = eval('('+data+')');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	551 list = endParsing(obj);
5 d8a98540d749 Reimport nodes methods when loading from file. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 1 diff changeset	552
d8a98540d749 Reimport nodes methods when loading from file. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 1 diff changeset	553 for (var i in list)
d8a98540d749 Reimport nodes methods when loading from file. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 1 diff changeset	554 for (var j in Node.prototype)
d8a98540d749 Reimport nodes methods when loading from file. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 1 diff changeset	555 list[i][j] = Node.prototype[j];
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	556 }
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 storage.debug = function() {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	559 sys.puts('\033[1;33m' + sys.inspect(list, null, null) + '\033[0m');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	560 };