Mercurial > xmpp2smtp
annotate xmpp2smtp.js @ 6:5cf8a08ef7fe
Fix errors in disco#info.
author | Sonny Piers <sonny.piers@gmail.com> |
---|---|
date | Wed, 15 Jun 2011 12:25:18 +0200 |
parents | c1a19866a233 |
children |
rev | line source |
---|---|
0 | 1 var os = require('os'); |
2 var fs = require('fs'); | |
3 | |
4 var xmpp = require('node-xmpp'); | |
5 var ispdb = require('./node-ispdb'); | |
6 var smtp = require("./Nodemailer/lib/mail"); | |
7 | |
8 var config = require("./configuration"); | |
9 | |
10 var info = []; | |
11 //~ info.push(new xmpp.Element("feature", {"var": "http://jabber.org/protocol/caps"})); | |
12 //~ info.push(new xmpp.Element("feature", {"var": "http://jabber.org/protocol/commands"})); | |
13 info.push(new xmpp.Element("feature", {"var": "http://jabber.org/protocol/disco#info"})); | |
14 info.push(new xmpp.Element("feature", {"var": "jabber:iq:register"})); | |
15 info.push(new xmpp.Element("feature", {"var": "jabber:iq:version"})); | |
6
5cf8a08ef7fe
Fix errors in disco#info.
Sonny Piers <sonny.piers@gmail.com>
parents:
5
diff
changeset
|
16 info.push(new xmpp.Element("feature", {"var": "jabber:iq:gateway"})); |
5cf8a08ef7fe
Fix errors in disco#info.
Sonny Piers <sonny.piers@gmail.com>
parents:
5
diff
changeset
|
17 info.push(new xmpp.Element("identity", {category: "gateway", type: "smtp", name: config.XMPP.name})); |
0 | 18 |
19 var cl = new xmpp.Component({ | |
20 jid: config.XMPP.jid, | |
21 password: config.XMPP.password, | |
22 host: config.XMPP.host, | |
23 port: config.XMPP.port | |
24 }); | |
25 | |
26 cl.on('stanza', | |
27 function(stanza) { | |
28 var type = stanza.attrs.type; | |
29 //jabber:iq:register remove | |
30 if((stanza.is("iq")) && (type == "set") && (stanza.getChild("query", "jabber:iq:register")) && (stanza.getChild("query").getChild("remove"))) { | |
31 fs.unlink("storage/"+stanza.attrs['from'].split("/")[0], | |
32 function() { | |
33 cl.send(new xmpp.Element( | |
34 "iq", { | |
35 id: stanza.attrs.id, | |
36 to: stanza.attrs.from, | |
37 from: config.XMPP.jid, | |
38 type: 'result' | |
39 } | |
40 )); | |
41 } | |
42 ); | |
43 } | |
44 //jabber:iq:register get | |
45 else if((stanza.is("iq")) && (type == "get") && (stanza.getChild("query", "jabber:iq:register"))) { | |
46 var result = new xmpp.Element( | |
47 "iq", { | |
48 id: stanza.attrs.id, | |
49 to: stanza.attrs.from, | |
50 from: config.XMPP.jid, | |
51 type: 'result' | |
52 } | |
53 ) | |
54 .c("query", {xmlns: "jabber:iq:register"}); | |
55 | |
56 | |
57 fs.readFile("storage/"+stanza.attrs['from'].split("/")[0], | |
58 function(err, data) { | |
59 if(config.easySMTPConf && ispdb) { | |
60 result.c("instructions").t("Please enter your email and password, we will try to find the SMTP configuration for you."); | |
61 result.c("username"); | |
62 result.c("password"); | |
63 } | |
64 else { | |
65 result.c("x", {type: "form", xmlns: "jabber:x:data"}); | |
66 var fields; | |
5
c1a19866a233
Fix some bugs with SMTP settings.
Sonny Piers <sonny.piers@gmail.com>
parents:
0
diff
changeset
|
67 data ? fields = JSON.parse(data) : fields = {host:"smtp.example.com",use_authentication: "login", port:"465", ssl: false, user: "example(@example.com)", pass: "example", sender: "example@example.com"}; |
0 | 68 result.c("field", {type: "hidden", "var": "FORM_TYPE"}).c("value").t("jabber:iq:register"); |
69 result.c("field", {type: "text-single", label: "Host", "var": "host"}).c("required").up().c("value").t(fields.host); | |
70 result.c("field", {type: "text-single", label: "Port", "var": "port"}).c("required").up().c("value").t(fields.port); | |
71 result.c("field", {type: "boolean", label: "Enable SSL", "var": "ssl"}).c("required").up().c("value").t(fields.ssl); | |
5
c1a19866a233
Fix some bugs with SMTP settings.
Sonny Piers <sonny.piers@gmail.com>
parents:
0
diff
changeset
|
72 result.c("field", {type: "boolean", label: "Use authentication", "var": "authentication"}).c("required").up().c("value").t(fields.user_authentication); |
c1a19866a233
Fix some bugs with SMTP settings.
Sonny Piers <sonny.piers@gmail.com>
parents:
0
diff
changeset
|
73 result.c("field", {type: "text-single", label: "Email address", "var": "sender"}).c("required").up().c("value").t(fields.from); |
c1a19866a233
Fix some bugs with SMTP settings.
Sonny Piers <sonny.piers@gmail.com>
parents:
0
diff
changeset
|
74 result.c("field", {type: "text-single", label: "Username", "var": "user"}).c("required").up().c("value").t(fields.username); |
c1a19866a233
Fix some bugs with SMTP settings.
Sonny Piers <sonny.piers@gmail.com>
parents:
0
diff
changeset
|
75 result.c("field", {type: "text-private", label: "Password", "var": "pass"}).c("required").up().c("value").t(fields.password); |
0 | 76 } |
77 cl.send(result); | |
78 } | |
79 ); | |
80 } | |
81 //jabber:iq:register set | |
82 else if((stanza.is("iq")) && (type == "set") && (stanza.getChild("query", "jabber:iq:register"))) { | |
83 var test = {}; | |
84 var path = "storage/"+stanza.attrs["from"].split("/")[0]; | |
85 //easySMTPConfig :) | |
86 if(stanza.getChild("query").getChild("username")) { | |
87 var username = stanza.getChild("query").getChild("username").getText(); | |
88 var password = stanza.getChild("query").getChild("password").getText(); | |
89 ispdb.get(username.split("@")[1], function(data) { | |
90 if(data == null) { | |
91 cl.send(new xmpp.Element("iq", {to: stanza.attrs.from, from: config.XMPP.jid, id: stanza.attrs.id, type: "error"})); | |
92 } | |
93 else { | |
94 var smtp = data.outgoing; | |
95 test.port = smtp.port; | |
96 test.host = smtp.hostname; | |
97 if(smtp.socketType == "SSL") | |
5
c1a19866a233
Fix some bugs with SMTP settings.
Sonny Piers <sonny.piers@gmail.com>
parents:
0
diff
changeset
|
98 test.ssl = true; |
c1a19866a233
Fix some bugs with SMTP settings.
Sonny Piers <sonny.piers@gmail.com>
parents:
0
diff
changeset
|
99 if((smtp.authentication == "secure") || (smtp.authentication == "plain")) |
c1a19866a233
Fix some bugs with SMTP settings.
Sonny Piers <sonny.piers@gmail.com>
parents:
0
diff
changeset
|
100 test.use_authentication = true; |
c1a19866a233
Fix some bugs with SMTP settings.
Sonny Piers <sonny.piers@gmail.com>
parents:
0
diff
changeset
|
101 test.sender = username; |
c1a19866a233
Fix some bugs with SMTP settings.
Sonny Piers <sonny.piers@gmail.com>
parents:
0
diff
changeset
|
102 test.user = username; |
c1a19866a233
Fix some bugs with SMTP settings.
Sonny Piers <sonny.piers@gmail.com>
parents:
0
diff
changeset
|
103 test.pass = password; |
0 | 104 } |
105 fs.writeFile(path, JSON.stringify(test), function () { | |
106 cl.send(new xmpp.Element("iq", {to: stanza.attrs.from, from: config.XMPP.jid, id: stanza.attrs.id, type: "result"})); | |
107 }); | |
108 }); | |
109 | |
110 } | |
111 //not easy | |
112 else { | |
113 var fields = stanza.getChild("query").getChild("x").getChildren("field"); | |
114 for (var i=0;i<fields.length;i++) { | |
115 if(fields[i].attrs["var"] != "FORM_TYPE") | |
116 test[fields[i].attrs["var"]] = fields[i].getChild("value").getText(); | |
117 } | |
118 fs.writeFile(path, JSON.stringify(test), function () { | |
119 cl.send(new xmpp.Element("iq", {to: stanza.attrs.from, from: config.XMPP.jid, id: stanza.attrs.id, type: "result"})); | |
120 }); | |
121 } | |
122 } | |
123 //jabber:iq:version | |
124 else if((stanza.is("iq")) && (type == "get") && (stanza.getChild("query", "jabber:iq:version"))) { | |
125 var result = new xmpp.Element( | |
126 "iq", { | |
127 to: stanza.attrs.from, | |
128 from: config.XMPP.jid, | |
129 id: stanza.attrs.id, | |
130 type: 'result' | |
131 } | |
132 ).c("query", {xmlns: "jabber:iq:version"}) | |
133 stanza.c("name").t("xmpp2smtp"); | |
134 stanza.c("version").t("0.1"); | |
135 stanza.c("os").t(os.type()+" "+os.release()); | |
136 cl.send(result); | |
137 } | |
138 //disco#info | |
139 else if((stanza.is("iq")) && (type == "get") && (stanza.getChild("query", "http://jabber.org/protocol/disco#info"))) { | |
140 var stanza = new xmpp.Element( | |
141 'iq', { | |
142 to: stanza.attrs.from, | |
143 from: config.XMPP.jid, | |
144 id: stanza.attrs.id, | |
145 type: 'result' | |
146 } | |
147 ); | |
148 for(var i=0;i<info.length;i++) { | |
149 stanza.cnode(info[i]); | |
150 } | |
151 cl.send(stanza); | |
152 } | |
153 //message | |
154 else if (stanza.is('message') && (type == 'chat')||(type == 'normal')) { | |
155 fs.readFile("storage/"+stanza.attrs['from'].split("/")[0], | |
156 function(err, data) { | |
157 var settings; | |
158 data ? settings = JSON.parse(data) : settings = config.SMTP; | |
5
c1a19866a233
Fix some bugs with SMTP settings.
Sonny Piers <sonny.piers@gmail.com>
parents:
0
diff
changeset
|
159 smtp.SMTP = settings; |
0 | 160 smtp.send_mail( |
161 { | |
5
c1a19866a233
Fix some bugs with SMTP settings.
Sonny Piers <sonny.piers@gmail.com>
parents:
0
diff
changeset
|
162 sender:settings.sender, |
0 | 163 to: stanza.attrs.to.split("@")[0].replace("%", "@"), |
164 subject: (type == "normal" ? stanza.getChildText("subject") : ""), | |
165 body: stanza.getChildText("body") | |
166 }, | |
167 function(error, success){ | |
168 if(error) { | |
169 cl.send(new xmpp.Element('message', {type: stanza.attrs.type, to: stanza.attrs.from, from: config.XMPP.jid}).c("body").t("Sorry we haven't been able to deliver the mail, check your settings.")); | |
170 } | |
171 } | |
172 ); | |
173 } | |
174 ); | |
175 } | |
176 } | |
177 ); | |
178 cl.on('error', | |
179 function(e) { | |
180 console.log(e); | |
181 } | |
182 ); | |
183 |