Mercurial > psgxs
annotate psgxs.js @ 31:13011b26181c
Fix non-PubSub commands.
| author | Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> |
|---|---|
| date | Thu, 04 Nov 2010 18:59:29 +0100 |
| parents | b2faacfefb90 |
| children | dcf1f09f8cee |
| rev | line source |
|---|---|
| 0 | 1 #!/usr/bin/env node |
| 2 | |
| 3 /* | |
| 4 * Copyright (C) 2010 Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> | |
| 5 * | |
| 6 * This file is part of PSĜS, a PubSub server written in JavaScript. | |
| 7 * | |
| 8 * PSĜS is free software: you can redistribute it and/or modify | |
| 9 * it under the terms of the GNU Affero General Public License as | |
| 10 * published by the Free Software Foundation, either version 3 of the | |
| 11 * License. | |
| 12 * | |
| 13 * PSĜS is distributed in the hope that it will be useful, | |
| 14 * but WITHOUT ANY WARRANTY; without even the implied warranty of | |
| 15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | |
| 16 * GNU Affero General Public License for more details. | |
| 17 * | |
| 18 * You should have received a copy of the GNU Affero General Public License | |
| 19 * along with PSĜS. If not, see <http://www.gnu.org/licenses/>. | |
| 20 */ | |
| 21 | |
| 22 var xmpp = require('xmpp'); | |
| 23 var sha1 = require('sha1'); | |
| 24 require('./iso8601'); | |
| 25 var storage = require('./storage'); | |
| 26 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
|
27 var makeError = errors.makeError; |
| 0 | 28 var utils = require('./util'); |
| 29 var toBareJID = utils.toBareJID; | |
| 30 var config = require('./configuration'); | |
| 31 var forms = require('./forms'); | |
| 32 var conn = new xmpp.Connection(); | |
| 33 | |
|
23
5fc4ee90c1bc
A lot of refactorization. First attempt to modularize the server.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
22
diff
changeset
|
34 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
|
35 notifs.setConnection(conn); |
|
5fc4ee90c1bc
A lot of refactorization. First attempt to modularize the server.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
22
diff
changeset
|
36 |
|
5fc4ee90c1bc
A lot of refactorization. First attempt to modularize the server.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
22
diff
changeset
|
37 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
|
38 |
| 0 | 39 var service_configuration = config.service_configuration; |
| 40 var componentJID = config.jid; | |
| 41 var componentPassword = config.password; | |
| 42 | |
|
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
|
43 conn.log = function (_, m) { console.log(m); }; |
| 0 | 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 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
|
46 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
|
47 if (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 console.log('\033['+c+';1m' + str + '\033[0m'); |
|
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 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
|
50 console.log(str); |
| 0 | 51 }; |
| 52 | |
|
11
0ed3c06c5191
Add an uncaught exceptions caughter to prevent the server from crashing.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
10
diff
changeset
|
53 process.addListener('uncaughtException', function (err) { |
|
17
ec7cea92fe8a
Show stack on unhandled error.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
12
diff
changeset
|
54 console.log('\033[41;1mUncaught exception (' + err + '), this should never happen:\033[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
|
55 }); |
|
0ed3c06c5191
Add an uncaught exceptions caughter to prevent the server from crashing.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
10
diff
changeset
|
56 |
|
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
|
57 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
|
58 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
|
59 { |
|
23
5fc4ee90c1bc
A lot of refactorization. First attempt to modularize the server.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
22
diff
changeset
|
60 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
|
61 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
|
62 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
|
63 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
|
64 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
|
65 }; |
|
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 } |
|
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 |
| 0 | 68 function onIq(stanza) { |
| 69 var type = stanza.getAttribute('type'); | |
| 70 var from = stanza.getAttribute('to'); | |
| 71 var to = stanza.getAttribute('from'); | |
| 72 var id = stanza.getAttribute('id'); | |
| 73 | |
| 74 var response; | |
| 75 if (id) | |
| 76 response = xmpp.iq({to: to, from: from, type: 'result', id: id}); | |
| 77 else | |
| 78 response = xmpp.iq({to: to, from: from, type: 'result'}); | |
| 79 | |
|
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
|
80 var send = false; |
|
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
|
81 |
|
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
|
82 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
|
83 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
|
84 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
|
85 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
|
86 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
|
87 |
|
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 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
|
89 var module = modules[k]; |
| 0 | 90 |
|
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
|
91 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
|
92 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
|
93 |
|
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
|
94 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
|
95 continue; |
| 0 | 96 |
|
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
|
97 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
|
98 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
|
99 |
|
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 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
|
101 continue; |
|
9
a6429f48e403
First implementation of XEP-0050 (ad-hoc commands).
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
8
diff
changeset
|
102 |
|
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
|
103 var toSend = module.func(response, stanza, child2, to); |
|
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 if (toSend) { |
|
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 response = toSend; |
|
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 send = true; |
|
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
|
107 delete toSend; |
|
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
|
108 } |
|
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
|
109 } |
|
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
|
110 } |
|
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
|
111 } 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
|
112 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
|
113 var module = modules[k]; |
| 0 | 114 |
|
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
|
115 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
|
116 continue; |
| 0 | 117 |
|
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
|
118 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
|
119 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
|
120 |
|
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
|
121 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
|
122 continue; |
| 0 | 123 |
|
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
|
124 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
|
125 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
|
126 |
|
31
13011b26181c
Fix non-PubSub commands.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
30
diff
changeset
|
127 var toSend = module.func(response, stanza, child1, to); |
|
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 if (toSend) { |
|
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 response = toSend; |
|
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 send = true; |
|
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
|
131 delete toSend; |
|
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 } |
| 0 | 133 } |
|
23
5fc4ee90c1bc
A lot of refactorization. First attempt to modularize the server.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
22
diff
changeset
|
134 } |
|
5fc4ee90c1bc
A lot of refactorization. First attempt to modularize the server.
Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
parents:
22
diff
changeset
|
135 } |
| 0 | 136 |
|
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
|
137 conn.send(send? response: makeError(response, errors.feature_not_implemented.n)); |
| 0 | 138 } |
| 139 | |
| 140 function onMessage(stanza) { | |
| 141 var from = stanza.getAttribute('to'); | |
| 142 var to = stanza.getAttribute('from'); | |
| 143 var id = stanza.getAttribute('id'); | |
| 144 | |
| 145 var response; | |
| 146 if (id) | |
| 147 response = xmpp.message({to: to, from: from, id: id}); | |
| 148 else | |
| 149 response = xmpp.message({to: to, from: from}); | |
| 150 | |
| 151 var x = stanza.getChild('x', 'jabber:x:data'); | |
| 152 if (x) { | |
| 153 var form = forms.parse(x); | |
| 154 if (form.type == 'submit' && form.fields.FORM_TYPE.value == 'subscribe_authorization') { | |
| 155 if (form.fields.subid && form.fields.subid.value) | |
| 156 var subID = form.fields.subid.value; | |
| 157 if (form.fields.node && form.fields.node.value) | |
| 158 var nodeID = form.fields.node.value; | |
| 159 if (form.fields.subscriber_jid && form.fields.subscriber_jid.value) | |
| 160 var jid = form.fields.subscriber_jid.value; | |
| 161 if (form.fields.allow && form.fields.allow.value) | |
| 162 var allow = form.fields.allow.value; | |
| 163 | |
| 164 var type = allow? 'subscribed': 'none'; | |
| 165 var set = storage.subscribe(nodeID, jid, type) | |
| 166 //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
|
167 notifs.send(jid, 'subscription', nodeID, {jid: jid, subscription: type}); |
| 0 | 168 } else |
| 169 return makeError(response, errors.feature_not_implemented.n); | |
| 170 } else | |
| 171 return makeError(response, errors.feature_not_implemented.n); | |
| 172 conn.send(response) | |
| 173 } | |
| 174 | |
| 175 function onPresence(stanza) { | |
| 176 var from = stanza.getAttribute('to'); | |
| 177 var to = stanza.getAttribute('from'); | |
| 178 var id = stanza.getAttribute('id'); | |
| 179 | |
| 180 var response; | |
| 181 if (id) | |
| 182 response = xmpp.presence({to: to, from: from, id: id}); | |
| 183 else | |
| 184 response = xmpp.presence({to: to, from: from}); | |
| 185 | |
| 186 makeError(response, errors.feature_not_implemented.n); | |
| 187 } | |
| 188 | |
| 189 conn.connect(componentJID, componentPassword, function (status, condition) { | |
| 190 if (status == xmpp.Status.CONNECTED) { | |
| 191 conn.addHandler(onMessage, null, 'message', null, null, null); | |
| 192 conn.addHandler(onIq, null, 'iq', null, null, null); | |
| 193 conn.addHandler(onPresence, null, 'presence', null, null, null); | |
| 194 | |
| 195 if (process.argv.length >= 3) | |
| 196 storage.load(process.argv[2]); | |
| 197 else | |
| 198 storage.load(); | |
| 199 | |
| 200 var stdin = process.openStdin(); | |
| 201 stdin.setEncoding('utf8'); | |
| 202 stdin.addListener('data', storage.debug); | |
| 203 } else | |
| 204 conn.log(xmpp.LogLevel.DEBUG, 'New connection status: ' + status + (condition? (' ('+condition+')'): '')); | |
| 205 }); |