PSĜS: psgxs.js annotate

annotate psgxs.js @ 55:fd69d35cf2e6

Move default storage directory; better naming of nodes; fix notification sending.

author	Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
date	Mon, 25 Jul 2011 17:35:32 -0700
parents	0d3f18bb1d36
children	99bd1d1ac071

rev	line source
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	1 #!/usr/bin/env node
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	2
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	3 /*
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	4 * Copyright (C) 2010 Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	5 *
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	6 * This file is part of PSĜS, a PubSub server written in JavaScript.
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	7 *
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	8 * PSĜS is free software: you can redistribute it and/or modify
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	9 * it under the terms of the GNU Affero General Public License as
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	10 * published by the Free Software Foundation, either version 3 of the
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	11 * License.
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	12 *
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	13 * PSĜS is distributed in the hope that it will be useful,
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	14 * but WITHOUT ANY WARRANTY; without even the implied warranty of
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	16 * GNU Affero General Public License for more details.
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	17 *
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	18 * You should have received a copy of the GNU Affero General Public License
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	19 * along with PSĜS. If not, see <http://www.gnu.org/licenses/>.
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	20 */
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	21
43 023f767662d3 Fix compatibility with strict mode of node 0.4 and some files without licence header. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 35 diff changeset	22 'use strict';
023f767662d3 Fix compatibility with strict mode of node 0.4 and some files without licence header. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 35 diff changeset	23
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	24 var xmpp = require('xmpp');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	25 var sha1 = require('sha1');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	26 require('./iso8601');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	27 var storage = require('./storage');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	28 var errors = require('./errors');
23 5fc4ee90c1bc A lot of refactorization. First attempt to modularize the server. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 22 diff changeset	29 var makeError = errors.makeError;
35 6697f394301f Replace util with fdsq to work around a stupid bug. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 34 diff changeset	30 var fdsq = require('./fdsq');
47 0d3f18bb1d36 Remove usage of fdsq.js in modules. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 46 diff changeset	31 var toBare = fdsq.toBare;
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	32 var config = require('./configuration');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	33 var forms = require('./forms');
45 8b20f2efb939 Add an option to choose the host and port of the connection. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 44 diff changeset	34 var conn = new xmpp.Connection(config.host, config.port);
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	35
23 5fc4ee90c1bc A lot of refactorization. First attempt to modularize the server. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 22 diff changeset	36 var notifs = require('./notifs');
5fc4ee90c1bc A lot of refactorization. First attempt to modularize the server. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 22 diff changeset	37 notifs.setConnection(conn);
5fc4ee90c1bc A lot of refactorization. First attempt to modularize the server. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 22 diff changeset	38
5fc4ee90c1bc A lot of refactorization. First attempt to modularize the server. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 22 diff changeset	39 var modules = require('./modules');
5fc4ee90c1bc A lot of refactorization. First attempt to modularize the server. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 22 diff changeset	40
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	41 var service_configuration = config.service_configuration;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	42 var componentJID = config.jid;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	43 var componentPassword = config.password;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	44
12 9a6b8b3357c6 Use new functions like console.log instead of sys.puts, and aerate a bit. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 11 diff changeset	45 conn.log = function (_, m) { console.log(m); };
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	46
12 9a6b8b3357c6 Use new functions like console.log instead of sys.puts, and aerate a bit. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 11 diff changeset	47 function _(obj, color) {
9a6b8b3357c6 Use new functions like console.log instead of sys.puts, and aerate a bit. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 11 diff changeset	48 var str = require('sys').inspect(obj, false, null);
9a6b8b3357c6 Use new functions like console.log instead of sys.puts, and aerate a bit. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 11 diff changeset	49 if (color)
43 023f767662d3 Fix compatibility with strict mode of node 0.4 and some files without licence header. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 35 diff changeset	50 console.log('\x1b['+c+';1m' + str + '\x1b[0m');
12 9a6b8b3357c6 Use new functions like console.log instead of sys.puts, and aerate a bit. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 11 diff changeset	51 else
9a6b8b3357c6 Use new functions like console.log instead of sys.puts, and aerate a bit. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 11 diff changeset	52 console.log(str);
0 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
11 0ed3c06c5191 Add an uncaught exceptions caughter to prevent the server from crashing. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 10 diff changeset	55 process.addListener('uncaughtException', function (err) {
43 023f767662d3 Fix compatibility with strict mode of node 0.4 and some files without licence header. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 35 diff changeset	56 console.log('\x1b[41;1mUncaught exception (' + err + '), this should never happen:\x1b[0m\n' + err.stack);
11 0ed3c06c5191 Add an uncaught exceptions caughter to prevent the server from crashing. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 10 diff changeset	57 });
0ed3c06c5191 Add an uncaught exceptions caughter to prevent the server from crashing. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 10 diff changeset	58
8 efe8dbd34780 Rename cx method to cnode and define it if xmpp.js didn’t. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 7 diff changeset	59 if (typeof xmpp.StanzaBuilder.cnode != 'function' \|\| typeof xmpp.StanzaBuilder.prototype.cnode != 'function') {
efe8dbd34780 Rename cx method to cnode and define it if xmpp.js didn’t. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 7 diff changeset	60 xmpp.StanzaBuilder.prototype.cnode = function (stanza)
efe8dbd34780 Rename cx method to cnode and define it if xmpp.js didn’t. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 7 diff changeset	61 {
23 5fc4ee90c1bc A lot of refactorization. First attempt to modularize the server. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 22 diff changeset	62 var parent = this.last_node[this.last_node.length-1];
8 efe8dbd34780 Rename cx method to cnode and define it if xmpp.js didn’t. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 7 diff changeset	63 parent.tags.push(stanza);
efe8dbd34780 Rename cx method to cnode and define it if xmpp.js didn’t. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 7 diff changeset	64 parent.children.push(stanza);
23 5fc4ee90c1bc A lot of refactorization. First attempt to modularize the server. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 22 diff changeset	65 this.last_node.push(stanza);
8 efe8dbd34780 Rename cx method to cnode and define it if xmpp.js didn’t. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 7 diff changeset	66 return this;
efe8dbd34780 Rename cx method to cnode and define it if xmpp.js didn’t. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 7 diff changeset	67 };
efe8dbd34780 Rename cx method to cnode and define it if xmpp.js didn’t. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 7 diff changeset	68 }
efe8dbd34780 Rename cx method to cnode and define it if xmpp.js didn’t. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 7 diff changeset	69
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	70 function onIq(stanza) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	71 var type = stanza.getAttribute('type');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	72 var from = stanza.getAttribute('to');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	73 var to = stanza.getAttribute('from');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	74 var id = stanza.getAttribute('id');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	75
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	76 var response;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	77 if (id)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	78 response = xmpp.iq({to: to, from: from, type: 'result', id: id});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	79 else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	80 response = xmpp.iq({to: to, from: from, type: 'result'});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	81
44 3e0ca96d2dce Fix an error in strict mode. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 43 diff changeset	82 var send = {};
30 b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	83
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	84 for (var i in stanza.tags) {
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	85 var child1 = stanza.tags[i];
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	86 if (child1.name == 'pubsub') {
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	87 for (var j in child1.tags) {
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	88 var child2 = child1.tags[j];
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	89
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	90 for (var k in modules) {
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	91 var module = modules[k];
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	92
34 dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	93 if (module.stanza && (module.stanza != 'iq'))
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	94 continue;
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	95
30 b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	96 if (module.type && (module.type != type))
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	97 continue;
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	98
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	99 if (module.child2 && (module.child2 != child2.name))
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	100 continue;
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	101
30 b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	102 if (module.ns && (module.ns != child2.attr.xmlns))
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	103 continue;
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	104
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	105 if (module.number && (module.number != j))
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	106 continue;
9 a6429f48e403 First implementation of XEP-0050 (ad-hoc commands). Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 8 diff changeset	107
44 3e0ca96d2dce Fix an error in strict mode. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 43 diff changeset	108 send.response = module.func(response, stanza, child2, to, from);
3e0ca96d2dce Fix an error in strict mode. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 43 diff changeset	109 if (send.response) {
3e0ca96d2dce Fix an error in strict mode. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 43 diff changeset	110 response = send.response;
3e0ca96d2dce Fix an error in strict mode. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 43 diff changeset	111 send.good = true;
3e0ca96d2dce Fix an error in strict mode. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 43 diff changeset	112 delete send.response;
30 b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	113 }
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	114 }
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	115 }
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	116 } else {
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	117 for (var k in modules) {
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	118 var module = modules[k];
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	119
34 dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	120 if (module.stanza && (module.stanza != 'iq'))
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	121 continue;
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	122
30 b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	123 if (module.type && (module.type != type))
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	124 continue;
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	125
30 b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	126 if (module.child && (module.child != child1.name))
23 5fc4ee90c1bc A lot of refactorization. First attempt to modularize the server. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 22 diff changeset	127 continue;
30 b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	128
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	129 if (module.ns && (module.ns != child1.attr.xmlns))
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	130 continue;
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	131
30 b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	132 if (module.number && (module.number != k))
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	133 continue;
b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	134
44 3e0ca96d2dce Fix an error in strict mode. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 43 diff changeset	135 send.response = module.func(response, stanza, child1, to, from);
3e0ca96d2dce Fix an error in strict mode. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 43 diff changeset	136 if (send.response) {
3e0ca96d2dce Fix an error in strict mode. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 43 diff changeset	137 response = send.response;
3e0ca96d2dce Fix an error in strict mode. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 43 diff changeset	138 send.good = true;
3e0ca96d2dce Fix an error in strict mode. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 43 diff changeset	139 delete send.response;
30 b2faacfefb90 Rewrite of the module manager; fix of some modules; fix of the directory backend. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 25 diff changeset	140 }
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	141 }
23 5fc4ee90c1bc A lot of refactorization. First attempt to modularize the server. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 22 diff changeset	142 }
5fc4ee90c1bc A lot of refactorization. First attempt to modularize the server. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 22 diff changeset	143 }
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	144
44 3e0ca96d2dce Fix an error in strict mode. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 43 diff changeset	145 conn.send(send.good? response: makeError(response, errors.feature_not_implemented.n));
0 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 function onMessage(stanza) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	149 var from = stanza.getAttribute('to');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	150 var to = stanza.getAttribute('from');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	151 var id = stanza.getAttribute('id');
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 response;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	154 if (id)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	155 response = xmpp.message({to: to, from: from, id: id});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	156 else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	157 response = xmpp.message({to: to, from: from});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	158
34 dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	159 var send = false;
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	160
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	161 for (var i in stanza.tags) {
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	162 var child = stanza.tags[i];
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	163 for (var k in modules) {
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	164 var module = modules[k];
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	165
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	166 if (module.stanza !== 'message')
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	167 continue;
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	168
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	169 if (module.type && (module.type != type))
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	170 continue;
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	171
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	172 if (module.child && (module.child != child.name))
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	173 continue;
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	174
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	175 if (module.ns && (module.ns != child.attr.xmlns))
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	176 continue;
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	177
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	178 if (module.number && (module.number != k))
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	179 continue;
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	180
44 3e0ca96d2dce Fix an error in strict mode. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 43 diff changeset	181 send.response = module.func(response, stanza, child, to, from);
3e0ca96d2dce Fix an error in strict mode. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 43 diff changeset	182 if (send.response) {
3e0ca96d2dce Fix an error in strict mode. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 43 diff changeset	183 response = send.response;
3e0ca96d2dce Fix an error in strict mode. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 43 diff changeset	184 send.good = true;
3e0ca96d2dce Fix an error in strict mode. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 43 diff changeset	185 delete send.response;
34 dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	186 }
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	187 }
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	188 }
dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	189
46 3126f8d6a5e3 Typo in 3e0ca96d2dce. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 45 diff changeset	190 conn.send(send.good? response: makeError(response, errors.feature_not_implemented.n));
44 3e0ca96d2dce Fix an error in strict mode. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 43 diff changeset	191 return;
34 dcf1f09f8cee Add message to publish module and various fixes. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 31 diff changeset	192
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	193 var x = stanza.getChild('x', 'jabber:x:data');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	194 if (x) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	195 var form = forms.parse(x);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	196 if (form.type == 'submit' && form.fields.FORM_TYPE.value == 'subscribe_authorization') {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	197 if (form.fields.subid && form.fields.subid.value)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	198 var subID = form.fields.subid.value;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	199 if (form.fields.node && form.fields.node.value)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	200 var nodeID = form.fields.node.value;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	201 if (form.fields.subscriber_jid && form.fields.subscriber_jid.value)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	202 var jid = form.fields.subscriber_jid.value;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	203 if (form.fields.allow && form.fields.allow.value)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	204 var allow = form.fields.allow.value;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	205
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	206 var type = allow? 'subscribed': 'none';
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	207 var set = storage.subscribe(nodeID, jid, type)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	208 //if (set.subid != subID) //TODO: support the multi-subscribe feature
23 5fc4ee90c1bc A lot of refactorization. First attempt to modularize the server. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 22 diff changeset	209 notifs.send(jid, 'subscription', nodeID, {jid: jid, subscription: type});
0 9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	210 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	211 return makeError(response, errors.feature_not_implemented.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	212 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	213 return makeError(response, errors.feature_not_implemented.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	214 conn.send(response)
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
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	217 function onPresence(stanza) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	218 var from = stanza.getAttribute('to');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	219 var to = stanza.getAttribute('from');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	220 var id = stanza.getAttribute('id');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	221
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	222 var response;
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	223 if (id)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	224 response = xmpp.presence({to: to, from: from, id: id});
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	225 else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	226 response = xmpp.presence({to: to, from: from});
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 makeError(response, errors.feature_not_implemented.n);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	229 }
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	230
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	231 conn.connect(componentJID, componentPassword, function (status, condition) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	232 if (status == xmpp.Status.CONNECTED) {
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	233 conn.addHandler(onMessage, null, 'message', null, null, null);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	234 conn.addHandler(onIq, null, 'iq', null, null, null);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	235 conn.addHandler(onPresence, null, 'presence', null, null, null);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	236
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	237 if (process.argv.length >= 3)
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	238 storage.load(process.argv[2]);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	239 else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	240 storage.load();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	241
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	242 var stdin = process.openStdin();
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	243 stdin.setEncoding('utf8');
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	244 stdin.addListener('data', storage.debug);
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	245 } else
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	246 conn.log(xmpp.LogLevel.DEBUG, 'New connection status: ' + status + (condition? (' ('+condition+')'): ''));
9ee956af41e3 Initial commit Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: diff changeset	247 });