PSĜS: storage.js annotate

annotate storage.js @ 23:5fc4ee90c1bc

A lot of refactorization. First attempt to modularize the server.

author	Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
date	Sun, 31 Oct 2010 23:58:07 +0100
parents	9a6b8b3357c6
children	f2e9365bc8ec

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 sha1hex = require('sha1').hex;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	21 require('./iso8601');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	22 var errors = require('./errors');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	23 var config = require('./configuration');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	24 var service_configuration = config.service_configuration;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	25 var Configuration = config.Configuration;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	26 var utils = require('./util');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	27 var toBareJID = utils.toBareJID;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	28
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	29 var nodes = require('./nodes');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	30 var Node = nodes.Node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	31 var Item = nodes.Item;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	32
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	33 var fs = require('fs');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	34
9 a6429f48e403 First implementation of XEP-0050 (ad-hoc commands). Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 6 diff changeset	35 var list;
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	36
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	37 var storage = exports;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	38 storage.createNode = function(nodeID, params) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	39 for (var i in list)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	40 if (i == nodeID)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	41 return errors.owner.create.nodeid_already_exists.n;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	42
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	43 list[nodeID] = new Node(params);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	44 storage.save();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	45 return errors.success;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	46 };
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 storage.getMetadata = function(nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	49 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	50 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	51 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	52
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	53 if (!config.enabled('meta-data'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	54 return {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	55
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	56 var md = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	57 for (var i in service_configuration.node_metadata) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	58 if (i == 'FORM_TYPE')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	59 continue;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	60
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	61 if (node.configuration[i])
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	62 md[i] = node.configuration[i];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	63 else if (node.metadata[i])
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	64 md[i] = node.metadata[i];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	65 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	66 return md;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	67 };
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 storage.getConfiguration = function(nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	70 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	71 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	72 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	73
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	74 if (config.enabled('config-node'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	75 return node.configuration;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	76
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	77 return {}; //FIXME
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	78 };
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 storage.configure = function(nodeID, params) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	81 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	82 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	83 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	84
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	85 if (!config.enabled('config-node'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	86 return 42; //FIXME
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	87
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	88 for (var i in params)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	89 if (service_configuration.node_config[i])
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	90 node.configuration[i] = params[i];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	91
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	92 storage.save();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	93 return errors.success;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	94 };
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 storage.configureSubscription = function(nodeID, jid, params) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	97 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	98 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	99 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	100
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	101 if (!config.enabled('subscription-options'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	102 return 42; //FIXME
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	103
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	104 var options = node.subscribers[jid].options;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	105 if (!options)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	106 return 42; //FIXME
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	107
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	108 for (var i in params)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	109 if (service_configuration.subscribe_options[i])
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	110 options[i] = params[i];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	111
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	112 storage.save();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	113 return errors.success;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	114 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	115
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	116 storage.getChildren = function(node) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	117 var n;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	118 var items = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	119 if (node)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	120 n = storage.getNode(node).items;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	121 else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	122 n = list;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	123
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	124 for (var i in n) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	125 var type;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	126 if (n[i].content)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	127 type = 'item';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	128 else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	129 type = 'node';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	130 items[i] = type;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	131 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	132 return items;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	133 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	134
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	135 storage.getNode = function(nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	136 if (list[nodeID])
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	137 return list[nodeID];
6 2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 5 diff changeset	138 return errors.node_does_not_exist.n;
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	139 };
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 storage.existsNode = function(nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	142 if (list[nodeID])
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	143 return true;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	144 return false;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	145 };
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 storage.purgeNode = function(nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	148 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	149 if (typeof n == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	150 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	151
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	152 var notifs = storage.getSubscriptionsFromNodeID(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	153
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	154 var item = storage.getLastItem(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	155 if (typeof item == 'number') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	156 node.items = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	157 } else {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	158 items = node.items[item];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	159 node.items = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	160 node.items[item] = items;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	161 }
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 storage.save();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	164 return notifs;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	165 };
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 storage.deleteNodeWithRedirect = function(nodeID, uri) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	168 var del = storage.deleteNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	169 if (typeof del == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	170 return del;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	171
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	172 list[nodeID] = uri;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	173 storage.save();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	174 return errors.success;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	175 };
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 storage.deleteNode = function(nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	178 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	179 if (typeof n == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	180 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	181
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	182 var notifs = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	183 for (var i in node.subscribers)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	184 notifs[i] = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	185 for (var i in node.owner)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	186 notifs[node.owner[i]] = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	187 if (config.enabled('publisher-affiliation'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	188 for (var i in node.publisher)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	189 notifs[node.publisher[i]] = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	190 if (config.enabled('publish-only-affiliation'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	191 for (var i in node.publishOnly)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	192 notifs[node.publishOnly[i]] = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	193
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	194 delete list[nodeID];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	195 storage.save();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	196 return notifs;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	197 };
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 storage.setItem = function(nodeID, itemID, content) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	200 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	201 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	202 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	203
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	204 if (typeof itemID != 'string')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	205 itemID = utils.makeRandomId();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	206
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	207 i = node.setItem(itemID, content);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	208 if (content)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	209 i.content = content;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	210
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	211 storage.save();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	212 return storage.getSubscriptionsFromNodeID(nodeID)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	213 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	214
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	215 storage.deleteItem = function(nodeID, itemID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	216 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	217 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	218 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	219
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	220 if (typeof itemID != 'string')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	221 return errors.pub.retract.item_or_itemid_required.n;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	222
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	223 item = node.setItem(itemID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	224 if (typeof item == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	225 return item;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	226
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	227 storage.save();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	228 return storage.getSubscriptionsFromNodeID(nodeID)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	229 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	230
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	231 storage.getItems = function(nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	232 var node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	233 if (typeof nodeID == 'string')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	234 node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	235 else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	236 node = nodeID;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	237
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	238 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	239 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	240
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	241 return node.items;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	242 };
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 storage.getLastItem = function(nodeID, number) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	245 var items = storage.getItems(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	246 if (typeof items == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	247 return items;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	248
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	249 if (items == {})
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	250 return 42; //FIXME
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	251
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	252 if (number) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	253 var last = [];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	254 var j = 0;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	255 for (var i in items) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	256 last.push({name: i, date: items[i].date, content: items[i].content});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	257 j++;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	258 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	259 if (j < number)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	260 return last;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	261
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	262 var cmp = function(a, b) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	263 return b.date - a.date;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	264 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	265 last = last.sort(cmp).slice(0, number);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	266 } else {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	267 var last;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	268 for (var i in items)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	269 if ((typeof last == 'undefined') \|\| (items[i].date >= items[last].date))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	270 last = i;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	271 }
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 if (last)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	274 return last;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	275 return 42; //FIXME
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	276 };
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 storage.existsItem = function(nodeID, itemID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	279 var items = storage.getItems(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	280 if (typeof items == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	281 return items;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	282
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	283 for (var i in items)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	284 if (i == itemID)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	285 return items[i];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	286 return false;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	287 };
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 storage.getItem = function(nodeID, itemID) {
10 44889cfb2f8c Fix getItem method. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 9 diff changeset	290 var items = storage.getItems(nodeID);
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	291 if (typeof items == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	292 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	293
10 44889cfb2f8c Fix getItem method. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 9 diff changeset	294 if (items[itemID])
44889cfb2f8c Fix getItem method. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 9 diff changeset	295 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	296
10 44889cfb2f8c Fix getItem method. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 9 diff changeset	297 return errors.success;
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	298 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	299
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	300 storage.getSubscription = function(jid, nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	301 var subs = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	302 if (nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	303 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	304 for (var sub in node.subscribers)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	305 if (toBareJID(sub) == jid)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	306 return node.subscribers[sub]
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	307 } else {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	308 for (var node in list) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	309 for (var sub in list[node].subscribers) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	310 if (toBareJID(sub) == jid)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	311 subs[node] = list[node].subscribers[sub];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	312 }
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 return subs;
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 storage.getSubscriptionsFromNodeID = function(nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	319 var node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	320 if (typeof nodeID == 'string') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	321 node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	322 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	323 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	324 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	325 node = nodeID;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	326
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	327 var subs = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	328 for (var sub in node.subscribers) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	329 if (typeof sub == 'string') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	330 var subscription = {subid: node.subscribers[sub].subid, type: node.subscribers[sub].type};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	331 if (node.subscribers[sub].options)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	332 subscription.options = node.subscribers[sub].options;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	333 subs[sub] = subscription;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	334 }
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 return subs;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	337 };
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 storage.subscribe = function(nodeID, jid, type, params) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	340 if (!config.enabled('subscribe'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	341 return errors.sub.subscribe.not_supported.n;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	342
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	343 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	344 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	345 return node;
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 if (typeof type == 'undefined')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	348 type = 'subscribed';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	349
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	350 if (type == 'none') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	351 if (!node.subscribers[jid])
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	352 return errors.sub.unsubscribe.no_such_subscriber.n;
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
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	355 var subid = node.setSubscriber(jid, type, null, params);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	356 storage.save();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	357 return {subid: subid, type: type};
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
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	360 storage.setAffiliation = function(nodeID, jid, affil) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	361 var node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	362 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	363 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	364
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	365 if (affil == 'owner')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	366 node.owner.push(jid);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	367 else if (config.enabled('publisher-affiliation') && affil == 'publisher')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	368 node.publisher.push(jid);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	369 else if (config.enabled('publish-only-affiliation') && affil == 'publish-only')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	370 node.publishOnly.push(jid);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	371 else if (config.enabled('member-affiliation') && affil == 'member')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	372 node.member.push(jid);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	373 else if (config.enabled('outcast-affiliation') && affil == 'outcast')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	374 node.outcast.push(jid);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	375
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	376 storage.save();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	377 return errors.success;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	378 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	379
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	380 storage.getAffiliation = function(jid, nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	381 var node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	382 if (typeof nodeID == 'string') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	383 node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	384 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	385 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	386 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	387 node = nodeID;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	388
1 c2954a9e5665 Add a super-owner that has power over all nodes; add support for Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 0 diff changeset	389 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	390 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	391 return 'super-owner';
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	392 for (var affil in node.owner)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	393 if (typeof affil == 'string' && node.owner[affil] == jid)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	394 return 'owner';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	395 if (config.enabled('publisher-affiliation'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	396 for (var affil in node.publisher)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	397 if (typeof affil == 'string' && node.publisher[affil] == jid)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	398 return 'publisher';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	399 if (config.enabled('publish-only-affiliation'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	400 for (var affil in node.publishOnly)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	401 if (typeof affil == 'string' && node.publishOnly[affil] == jid)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	402 return 'publish-only';
6 2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 5 diff changeset	403 if (config.enabled('member-affiliation'))
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 5 diff changeset	404 for (var affil in node.member)
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 5 diff changeset	405 if (typeof affil == 'string' && node.member[affil] == jid)
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 5 diff changeset	406 return 'member';
0 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 }
6 2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 5 diff changeset	440 if (config.enabled('member-affiliation'))
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 5 diff changeset	441 for (var affil in node.member)
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 5 diff changeset	442 if (typeof affil == 'string' && node.member[affil] == jid) {
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 5 diff changeset	443 affils[nodeID] = 'member';
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 5 diff changeset	444 break;
2bcadb0531f4 A few changes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 5 diff changeset	445 }
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	446 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	447 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	448 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	449 affils[nodeID] = 'outcast';
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	450 break;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	451 }
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 return affils;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	454 };
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 storage.getAffiliationsFromNodeID = function(nodeID) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	457 var node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	458 if (typeof nodeID == 'string') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	459 node = storage.getNode(nodeID);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	460 if (typeof node == 'number')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	461 return node;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	462 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	463 node = nodeID;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	464
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	465 var 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	466 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	467 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	468 affils[config.owner[jid]] = 'super-owner';
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	469 for (var jid in node.owner)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	470 if (typeof jid == 'string')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	471 affils[node.owner[jid]] = 'owner';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	472 if (config.enabled('publisher-affiliation'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	473 for (var jid in node.publisher)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	474 if (typeof jid == 'string')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	475 affils[node.publisher[jid]] = 'publisher';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	476 if (config.enabled('publish-only-affiliation'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	477 for (var jid in node.publishOnly)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	478 if (typeof jid == 'string')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	479 affils[node.publishOnly[jid]] = 'publish-only';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	480 if (config.enabled('member-affiliation'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	481 for (var jid in node.member)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	482 if (typeof jid == 'string')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	483 affils[node.member[jid]] = 'member';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	484 if (config.enabled('outcast-affiliation'))
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	485 for (var jid in node.outcast)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	486 if (typeof jid == 'string')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	487 affils[node.outcast[jid]] = 'outcast';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	488 return affils;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	489 };
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	490
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	491 storage.save = function(file) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	492 function sanitize(o) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	493 var n = {};
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	494 for (var i in o) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	495 if (i == 'content' \|\| o[i].setISO8601)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	496 n[i] = o[i].toString();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	497 else if (o[i] instanceof Array)
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 else if (typeof o[i] == 'object')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	500 n[i] = sanitize(o[i]);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	501 else if (typeof o[i] == 'function')
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 else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	504 n[i] = o[i];
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	505 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	506 return n;
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
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	509 var data = sanitize(list);
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 if (!file)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	512 file = 'save.json';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	513
12 9a6b8b3357c6 Use new functions like console.log instead of sys.puts, and aerate a bit. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 10 diff changeset	514 fs.writeFile(file, require('sys').inspect(data, null, null));
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	515 }
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 storage.load = function(file) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	518 var xmpp = require('xmpp');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	519 function parseStanza(path, content) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	520 var stanza = null;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	521 var stream = new xmpp.Stream({
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	522 stanza: function (stanza) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	523 path[content] = stanza;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	524 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	525 });
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	526 stream.opened = true;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	527 stream.data(path[content]);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	528 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	529
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	530 function endParsing(o) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	531 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	532 for (var i in o) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	533 if (typeof o[i] == 'string' && i == 'content')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	534 parseStanza(o, i);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	535 else if (typeof o[i] == 'string' && regexp(o[i])) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	536 var today = new Date();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	537 today.setISO8601(o[i]);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	538 o[i] = today;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	539 } else if (typeof o[i] == 'object')
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	540 endParsing(o[i]);
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 return o;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	543 }
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 if (!file)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	546 file = 'save.json';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	547
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	548 var data = fs.readFileSync(file);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	549 var obj = eval('('+data+')');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	550 list = endParsing(obj);
5 d8a98540d749 Reimport nodes methods when loading from file. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 1 diff changeset	551
d8a98540d749 Reimport nodes methods when loading from file. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 1 diff changeset	552 for (var i in list)
d8a98540d749 Reimport nodes methods when loading from file. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 1 diff changeset	553 for (var j in Node.prototype)
d8a98540d749 Reimport nodes methods when loading from file. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 1 diff changeset	554 list[i][j] = Node.prototype[j];
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	555 }
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 storage.debug = function() {
12 9a6b8b3357c6 Use new functions like console.log instead of sys.puts, and aerate a bit. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 10 diff changeset	558 console.log('\033[1;33m' + require('sys').inspect(list, null, null) + '\033[0m');
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	559 };