Commit | Line | Data |
---|---|---|
2117e02e MW |
1 | #include <sys/types.h> |
2 | #include <sys/socket.h> | |
3 | #include <netinet/in.h> | |
4 | #include <arpa/inet.h> | |
5 | #include "sig.h" | |
2117e02e MW |
6 | #include "stralloc.h" |
7 | #include "substdio.h" | |
8 | #include "subfd.h" | |
9 | #include "scan.h" | |
10 | #include "case.h" | |
11 | #include "error.h" | |
12 | #include "auto_qmail.h" | |
13 | #include "control.h" | |
14 | #include "dns.h" | |
15 | #include "alloc.h" | |
16 | #include "quote.h" | |
17 | #include "ip.h" | |
18 | #include "ipalloc.h" | |
19 | #include "ipme.h" | |
20 | #include "gen_alloc.h" | |
21 | #include "gen_allocdefs.h" | |
22 | #include "str.h" | |
23 | #include "now.h" | |
24 | #include "exit.h" | |
25 | #include "constmap.h" | |
26 | #include "tcpto.h" | |
212b6f5d | 27 | #include "readwrite.h" |
2117e02e MW |
28 | #include "timeoutconn.h" |
29 | #include "timeoutread.h" | |
30 | #include "timeoutwrite.h" | |
31 | ||
32 | #define HUGESMTPTEXT 5000 | |
33 | ||
34 | #define PORT_SMTP 25 /* silly rabbit, /etc/services is for users */ | |
35 | unsigned long port = PORT_SMTP; | |
36 | ||
37 | GEN_ALLOC_typedef(saa,stralloc,sa,len,a) | |
38 | GEN_ALLOC_readyplus(saa,stralloc,sa,len,a,i,n,x,10,saa_readyplus) | |
39 | static stralloc sauninit = {0}; | |
40 | ||
41 | stralloc helohost = {0}; | |
42 | stralloc routes = {0}; | |
43 | struct constmap maproutes; | |
44 | stralloc host = {0}; | |
45 | stralloc sender = {0}; | |
46 | ||
47 | saa reciplist = {0}; | |
48 | ||
49 | struct ip_address partner; | |
50 | ||
212b6f5d MW |
51 | void out(s) char *s; { if (substdio_puts(subfdoutsmall,s) == -1) _exit(0); } |
52 | void zero() { if (substdio_put(subfdoutsmall,"\0",1) == -1) _exit(0); } | |
53 | void zerodie() { zero(); substdio_flush(subfdoutsmall); _exit(0); } | |
2117e02e MW |
54 | void outsafe(sa) stralloc *sa; { int i; char ch; |
55 | for (i = 0;i < sa->len;++i) { | |
56 | ch = sa->s[i]; if (ch < 33) ch = '?'; if (ch > 126) ch = '?'; | |
212b6f5d | 57 | if (substdio_put(subfdoutsmall,&ch,1) == -1) _exit(0); } } |
2117e02e MW |
58 | |
59 | void temp_nomem() { out("ZOut of memory. (#4.3.0)\n"); zerodie(); } | |
60 | void temp_oserr() { out("Z\ | |
61 | System resources temporarily unavailable. (#4.3.0)\n"); zerodie(); } | |
62 | void temp_noconn() { out("Z\ | |
63 | Sorry, I wasn't able to establish an SMTP connection. (#4.4.1)\n"); zerodie(); } | |
64 | void temp_read() { out("ZUnable to read message. (#4.3.0)\n"); zerodie(); } | |
65 | void temp_dnscanon() { out("Z\ | |
66 | CNAME lookup failed temporarily. (#4.4.3)\n"); zerodie(); } | |
67 | void temp_dns() { out("Z\ | |
68 | Sorry, I couldn't find any host by that name. (#4.1.2)\n"); zerodie(); } | |
69 | void temp_chdir() { out("Z\ | |
70 | Unable to switch to home directory. (#4.3.0)\n"); zerodie(); } | |
71 | void temp_control() { out("Z\ | |
72 | Unable to read control files. (#4.3.0)\n"); zerodie(); } | |
73 | void perm_partialline() { out("D\ | |
74 | SMTP cannot transfer messages with partial final lines. (#5.6.2)\n"); zerodie(); } | |
75 | void perm_usage() { out("D\ | |
76 | I (qmail-remote) was invoked improperly. (#5.3.5)\n"); zerodie(); } | |
77 | void perm_dns() { out("D\ | |
78 | Sorry, I couldn't find any host named "); | |
79 | outsafe(&host); | |
80 | out(". (#5.1.2)\n"); zerodie(); } | |
81 | void perm_nomx() { out("D\ | |
82 | Sorry, I couldn't find a mail exchanger or IP address. (#5.4.4)\n"); | |
83 | zerodie(); } | |
84 | void perm_ambigmx() { out("D\ | |
85 | Sorry. Although I'm listed as a best-preference MX or A for that host,\n\ | |
86 | it isn't in my control/locals file, so I don't treat it as local. (#5.4.6)\n"); | |
87 | zerodie(); } | |
88 | ||
212b6f5d MW |
89 | void outhost() |
90 | { | |
91 | char x[IPFMT]; | |
92 | if (substdio_put(subfdoutsmall,x,ip_fmt(x,&partner)) == -1) _exit(0); | |
93 | } | |
94 | ||
95 | int flagcritical = 0; | |
96 | ||
97 | void dropped() { | |
98 | out("ZConnected to "); | |
99 | outhost(); | |
100 | out(" but connection died. "); | |
101 | if (flagcritical) out("Possible duplicate! "); | |
102 | out("(#4.4.2)\n"); | |
103 | zerodie(); | |
104 | } | |
105 | ||
2117e02e | 106 | int timeoutconnect = 60; |
212b6f5d MW |
107 | int smtpfd; |
108 | int timeout = 1200; | |
2117e02e | 109 | |
212b6f5d | 110 | int saferead(fd,buf,len) int fd; char *buf; int len; |
2117e02e | 111 | { |
212b6f5d MW |
112 | int r; |
113 | r = timeoutread(timeout,smtpfd,buf,len); | |
114 | if (r <= 0) dropped(); | |
115 | return r; | |
116 | } | |
117 | int safewrite(fd,buf,len) int fd; char *buf; int len; | |
118 | { | |
119 | int r; | |
120 | r = timeoutwrite(timeout,smtpfd,buf,len); | |
121 | if (r <= 0) dropped(); | |
122 | return r; | |
2117e02e MW |
123 | } |
124 | ||
212b6f5d MW |
125 | char inbuf[1024]; |
126 | substdio ssin = SUBSTDIO_FDBUF(read,0,inbuf,sizeof inbuf); | |
2117e02e | 127 | char smtptobuf[1024]; |
212b6f5d | 128 | substdio smtpto = SUBSTDIO_FDBUF(safewrite,-1,smtptobuf,sizeof smtptobuf); |
2117e02e | 129 | char smtpfrombuf[128]; |
212b6f5d MW |
130 | substdio smtpfrom = SUBSTDIO_FDBUF(saferead,-1,smtpfrombuf,sizeof smtpfrombuf); |
131 | ||
2117e02e MW |
132 | stralloc smtptext = {0}; |
133 | ||
212b6f5d MW |
134 | void get(ch) |
135 | char *ch; | |
2117e02e | 136 | { |
212b6f5d MW |
137 | substdio_get(&smtpfrom,ch,1); |
138 | if (*ch != '\r') | |
139 | if (smtptext.len < HUGESMTPTEXT) | |
140 | if (!stralloc_append(&smtptext,ch)) temp_nomem(); | |
2117e02e MW |
141 | } |
142 | ||
212b6f5d | 143 | unsigned long smtpcode() |
2117e02e | 144 | { |
212b6f5d MW |
145 | unsigned char ch; |
146 | unsigned long code; | |
147 | ||
148 | if (!stralloc_copys(&smtptext,"")) temp_nomem(); | |
149 | ||
150 | get(&ch); code = ch - '0'; | |
151 | get(&ch); code = code * 10 + (ch - '0'); | |
152 | get(&ch); code = code * 10 + (ch - '0'); | |
153 | for (;;) { | |
154 | get(&ch); | |
155 | if (ch != '-') break; | |
156 | while (ch != '\n') get(&ch); | |
157 | get(&ch); | |
158 | get(&ch); | |
159 | get(&ch); | |
2117e02e | 160 | } |
212b6f5d | 161 | while (ch != '\n') get(&ch); |
2117e02e | 162 | |
212b6f5d | 163 | return code; |
2117e02e MW |
164 | } |
165 | ||
212b6f5d | 166 | void outsmtptext() |
2117e02e | 167 | { |
212b6f5d MW |
168 | int i; |
169 | if (smtptext.s) if (smtptext.len) { | |
170 | out("Remote host said: "); | |
171 | for (i = 0;i < smtptext.len;++i) | |
172 | if (!smtptext.s[i]) smtptext.s[i] = '?'; | |
173 | if (substdio_put(subfdoutsmall,smtptext.s,smtptext.len) == -1) _exit(0); | |
174 | smtptext.len = 0; | |
175 | } | |
2117e02e MW |
176 | } |
177 | ||
212b6f5d MW |
178 | void quit(prepend,append) |
179 | char *prepend; | |
180 | char *append; | |
2117e02e | 181 | { |
212b6f5d MW |
182 | substdio_putsflush(&smtpto,"QUIT\r\n"); |
183 | /* waiting for remote side is just too ridiculous */ | |
184 | out(prepend); | |
185 | outhost(); | |
186 | out(append); | |
187 | out(".\n"); | |
188 | outsmtptext(); | |
189 | zerodie(); | |
2117e02e MW |
190 | } |
191 | ||
212b6f5d | 192 | void blast() |
2117e02e | 193 | { |
212b6f5d MW |
194 | int r; |
195 | char ch; | |
196 | ||
197 | for (;;) { | |
198 | r = substdio_get(&ssin,&ch,1); | |
199 | if (r == 0) break; | |
200 | if (r == -1) temp_read(); | |
201 | if (ch == '.') | |
202 | substdio_put(&smtpto,".",1); | |
203 | while (ch != '\n') { | |
204 | substdio_put(&smtpto,&ch,1); | |
205 | r = substdio_get(&ssin,&ch,1); | |
206 | if (r == 0) perm_partialline(); | |
207 | if (r == -1) temp_read(); | |
208 | } | |
209 | substdio_put(&smtpto,"\r\n",2); | |
2117e02e | 210 | } |
212b6f5d MW |
211 | |
212 | flagcritical = 1; | |
213 | substdio_put(&smtpto,".\r\n",3); | |
214 | substdio_flush(&smtpto); | |
2117e02e MW |
215 | } |
216 | ||
217 | stralloc recip = {0}; | |
218 | ||
212b6f5d | 219 | void smtp() |
2117e02e | 220 | { |
212b6f5d MW |
221 | unsigned long code; |
222 | int flagbother; | |
223 | int i; | |
224 | ||
225 | if (smtpcode() != 220) quit("ZConnected to "," but greeting failed"); | |
226 | ||
227 | substdio_puts(&smtpto,"HELO "); | |
228 | substdio_put(&smtpto,helohost.s,helohost.len); | |
229 | substdio_puts(&smtpto,"\r\n"); | |
230 | substdio_flush(&smtpto); | |
231 | if (smtpcode() != 250) quit("ZConnected to "," but my name was rejected"); | |
232 | ||
233 | substdio_puts(&smtpto,"MAIL FROM:<"); | |
234 | substdio_put(&smtpto,sender.s,sender.len); | |
235 | substdio_puts(&smtpto,">\r\n"); | |
236 | substdio_flush(&smtpto); | |
237 | code = smtpcode(); | |
238 | if (code >= 500) quit("DConnected to "," but sender was rejected"); | |
239 | if (code >= 400) quit("ZConnected to "," but sender was rejected"); | |
240 | ||
241 | flagbother = 0; | |
242 | for (i = 0;i < reciplist.len;++i) { | |
243 | substdio_puts(&smtpto,"RCPT TO:<"); | |
244 | substdio_put(&smtpto,reciplist.sa[i].s,reciplist.sa[i].len); | |
245 | substdio_puts(&smtpto,">\r\n"); | |
246 | substdio_flush(&smtpto); | |
247 | code = smtpcode(); | |
248 | if (code >= 500) { | |
249 | out("h"); outhost(); out(" does not like recipient.\n"); | |
250 | outsmtptext(); zero(); | |
2117e02e | 251 | } |
212b6f5d MW |
252 | else if (code >= 400) { |
253 | out("s"); outhost(); out(" does not like recipient.\n"); | |
254 | outsmtptext(); zero(); | |
2117e02e | 255 | } |
212b6f5d MW |
256 | else { |
257 | out("r"); zero(); | |
258 | flagbother = 1; | |
2117e02e MW |
259 | } |
260 | } | |
212b6f5d MW |
261 | if (!flagbother) quit("DGiving up on ",""); |
262 | ||
263 | substdio_putsflush(&smtpto,"DATA\r\n"); | |
264 | code = smtpcode(); | |
265 | if (code >= 500) quit("D"," failed on DATA command"); | |
266 | if (code >= 400) quit("Z"," failed on DATA command"); | |
267 | ||
268 | blast(); | |
269 | code = smtpcode(); | |
270 | flagcritical = 0; | |
271 | if (code >= 500) quit("D"," failed after I sent the message"); | |
272 | if (code >= 400) quit("Z"," failed after I sent the message"); | |
273 | quit("K"," accepted message"); | |
2117e02e MW |
274 | } |
275 | ||
276 | stralloc canonhost = {0}; | |
277 | stralloc canonbox = {0}; | |
278 | ||
279 | void addrmangle(saout,s,flagalias,flagcname) | |
280 | stralloc *saout; /* host has to be canonical, box has to be quoted */ | |
281 | char *s; | |
282 | int *flagalias; | |
283 | int flagcname; | |
284 | { | |
212b6f5d MW |
285 | int j; |
286 | ||
287 | *flagalias = flagcname; | |
288 | ||
289 | j = str_rchr(s,'@'); | |
290 | if (!s[j]) { | |
291 | if (!stralloc_copys(saout,s)) temp_nomem(); | |
292 | return; | |
2117e02e | 293 | } |
212b6f5d MW |
294 | if (!stralloc_copys(&canonbox,s)) temp_nomem(); |
295 | canonbox.len = j; | |
296 | if (!quote(saout,&canonbox)) temp_nomem(); | |
297 | if (!stralloc_cats(saout,"@")) temp_nomem(); | |
298 | ||
299 | if (!stralloc_copys(&canonhost,s + j + 1)) temp_nomem(); | |
300 | if (flagcname) | |
301 | switch(dns_cname(&canonhost)) { | |
302 | case 0: *flagalias = 0; break; | |
303 | case DNS_MEM: temp_nomem(); | |
304 | case DNS_SOFT: temp_dnscanon(); | |
305 | case DNS_HARD: ; /* alias loop, not our problem */ | |
2117e02e MW |
306 | } |
307 | ||
212b6f5d MW |
308 | if (!stralloc_cat(saout,&canonhost)) temp_nomem(); |
309 | } | |
310 | ||
311 | void getcontrols() | |
312 | { | |
313 | if (control_init() == -1) temp_control(); | |
314 | if (control_readint(&timeout,"control/timeoutremote") == -1) temp_control(); | |
315 | if (control_readint(&timeoutconnect,"control/timeoutconnect") == -1) | |
316 | temp_control(); | |
317 | if (control_rldef(&helohost,"control/helohost",1,(char *) 0) != 1) | |
318 | temp_control(); | |
319 | switch(control_readfile(&routes,"control/smtproutes",0)) { | |
320 | case -1: | |
321 | temp_control(); | |
322 | case 0: | |
323 | if (!constmap_init(&maproutes,"",0,1)) temp_nomem(); break; | |
324 | case 1: | |
325 | if (!constmap_init(&maproutes,routes.s,routes.len,1)) temp_nomem(); break; | |
326 | } | |
2117e02e MW |
327 | } |
328 | ||
329 | void main(argc,argv) | |
330 | int argc; | |
331 | char **argv; | |
332 | { | |
212b6f5d MW |
333 | static ipalloc ip = {0}; |
334 | int i; | |
335 | unsigned long random; | |
336 | char **recips; | |
337 | unsigned long prefme; | |
338 | int flagallaliases; | |
339 | int flagalias; | |
340 | char *relayhost; | |
341 | ||
342 | sig_pipeignore(); | |
343 | if (argc < 4) perm_usage(); | |
344 | if (chdir(auto_qmail) == -1) temp_chdir(); | |
345 | getcontrols(); | |
346 | ||
347 | ||
348 | if (!stralloc_copys(&host,argv[1])) temp_nomem(); | |
349 | ||
350 | relayhost = 0; | |
351 | for (i = 0;i <= host.len;++i) | |
352 | if ((i == 0) || (i == host.len) || (host.s[i] == '.')) | |
353 | if (relayhost = constmap(&maproutes,host.s + i,host.len - i)) | |
354 | break; | |
355 | if (relayhost && !*relayhost) relayhost = 0; | |
356 | ||
357 | if (relayhost) { | |
358 | i = str_chr(relayhost,':'); | |
359 | if (relayhost[i]) { | |
360 | scan_ulong(relayhost + i + 1,&port); | |
361 | relayhost[i] = 0; | |
2117e02e | 362 | } |
212b6f5d | 363 | if (!stralloc_copys(&host,relayhost)) temp_nomem(); |
2117e02e MW |
364 | } |
365 | ||
366 | ||
212b6f5d MW |
367 | addrmangle(&sender,argv[2],&flagalias,0); |
368 | ||
369 | if (!saa_readyplus(&reciplist,0)) temp_nomem(); | |
370 | if (ipme_init() != 1) temp_oserr(); | |
371 | ||
372 | flagallaliases = 1; | |
373 | recips = argv + 3; | |
374 | while (*recips) { | |
375 | if (!saa_readyplus(&reciplist,1)) temp_nomem(); | |
376 | reciplist.sa[reciplist.len] = sauninit; | |
377 | addrmangle(reciplist.sa + reciplist.len,*recips,&flagalias,!relayhost); | |
378 | if (!flagalias) flagallaliases = 0; | |
379 | ++reciplist.len; | |
380 | ++recips; | |
2117e02e MW |
381 | } |
382 | ||
212b6f5d MW |
383 | |
384 | random = now() + (getpid() << 16); | |
385 | switch (relayhost ? dns_ip(&ip,&host) : dns_mxip(&ip,&host,random)) { | |
386 | case DNS_MEM: temp_nomem(); | |
387 | case DNS_SOFT: temp_dns(); | |
388 | case DNS_HARD: perm_dns(); | |
389 | case 1: | |
390 | if (ip.len <= 0) temp_dns(); | |
2117e02e | 391 | } |
212b6f5d MW |
392 | |
393 | if (ip.len <= 0) perm_nomx(); | |
394 | ||
395 | prefme = 100000; | |
396 | for (i = 0;i < ip.len;++i) | |
397 | if (ipme_is(&ip.ix[i].ip)) | |
398 | if (ip.ix[i].pref < prefme) | |
399 | prefme = ip.ix[i].pref; | |
400 | ||
401 | if (relayhost) prefme = 300000; | |
402 | if (flagallaliases) prefme = 500000; | |
403 | ||
404 | for (i = 0;i < ip.len;++i) | |
405 | if (ip.ix[i].pref < prefme) | |
406 | break; | |
407 | ||
408 | if (i >= ip.len) | |
409 | perm_ambigmx(); | |
410 | ||
411 | for (i = 0;i < ip.len;++i) if (ip.ix[i].pref < prefme) { | |
412 | if (tcpto(&ip.ix[i].ip)) continue; | |
413 | ||
414 | smtpfd = socket(AF_INET,SOCK_STREAM,0); | |
415 | if (smtpfd == -1) temp_oserr(); | |
416 | ||
417 | if (timeoutconn(smtpfd,&ip.ix[i].ip,(unsigned int) port,timeoutconnect) == 0) { | |
418 | tcpto_err(&ip.ix[i].ip,0); | |
419 | partner = ip.ix[i].ip; | |
420 | smtp(); /* does not return */ | |
2117e02e | 421 | } |
212b6f5d MW |
422 | tcpto_err(&ip.ix[i].ip,errno == error_timeout); |
423 | close(smtpfd); | |
2117e02e | 424 | } |
212b6f5d MW |
425 | |
426 | temp_noconn(); | |
2117e02e | 427 | } |